123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698 |
- #ifndef MODULE_CONST_H
- #define MODULE_CONST_H
- #include<map>
- #include<vector>
- #include<string>
- #include<chrono>
- #include"db_api/CDBConnPool.h"
- #include"log.h"
- #include<rapidjson/document.h>
- #include<rapidjson/prettywriter.h>
- #include<rapidjson/stringbuffer.h>
- #include<websocket/wsClientMgr.h>
- #include<thread>
- #include"card.h"
- #include"area.h"
- #include"constdef.h"
- #define LENGTH_SQL 2000
- class global_constant
- {
- public:
-
- static int AREA_SPEED_COUNT_LIMIT;
-
- static int ATTENDANCE_VEHICLE_COUNT_LIMIT;
- };
- enum EVENT_STATUS
- {
-
- ES_START = 0,
-
- ES_DEAL_HELP = 1,
-
- ES_END = 100
- };
- enum EVENT_TYPE{
- ET_UNKNOWN = 0,
- ET_OVER_COUNT_PERSON = 1,
- ET_OVER_COUNT_VEHICLE = 2,
- ET_AREA_OVER_COUNT_PERSON = 3,
- ET_AREA_OVER_COUNT_VEHICLE = 4,
- ET_SECTION_OVER_COUNT = 5,
- ET_READER_ERROR = 6,
- ET_ctrl_reader_ERROR = 7,
- ET_LIGHT_ERROR = 8,
- ET_READER_CALL = 9,
- ET_READER_CALL_CANCEL = 10,
- ET_CARD_LOW_POWER = 11,
- ET_CARD_LOW_POWER_SERIOUS = 12,
- ET_CARD_OVER_TIME_PERSON = 13,
- ET_CARD_OVER_TIME_VEHICLE = 14,
- ET_CARD_AREA_OVER_TIME_PERSON = 15,
- ET_CARD_AREA_OVER_TIME_VEHICLE = 16,
- ET_CARD_AREA_LIMIT_PERSON = 17,
- ET_CARD_AREA_LIMIT_VEHICLE = 18,
- ET_CARD_AREA_FORBIDDEN_PERSON = 19,
- ET_CARD_AREA_FORBIDDEN_VEHICLE = 20,
- ET_CARD_OVER_SPEED = 21,
- ET_CARD_AREA_OVER_SPEED = 22,
- ET_CARD_RUN_THE_RED_LIGHT = 23,
- ET_CARD_HELP = 24,
- ET_CARD_CALLED = 25,
- ET_CARD_PATROL_ERROR = 26,
- ET_CARD_LOST = 27,
- ET_CARD_DRIVINGFACE_WARNING_AREA = 28,
- ET_CARD_NEAR_DRIVINGFACE_VEHICLE=29,
- ET_CARD_NEAR_DRIVINGFACE_OVERCOUNT=30,
- ET_UWB_MORE_CARD = 31,
- ET_CARD_MOTIONLESS=32,
- CARD_EVENT_COUNT_MAX,
- };
- enum OBJECT_TYPE
- {
-
- OT_MINE = 1,
-
- OT_AREA = 2,
-
- OT_SECTION = 3,
-
- OT_DEVICE_READER = 4,
-
- OT_DEVICE_LIGHT = 5,
-
- OT_DEVICE_ctrl_reader = 6,
-
- OT_DEVICE_LED = 7,
-
- OT_DEVICE_SPEAKER = 8,
-
- OT_CARD = 9,
-
- OT_DRIVINGFACE_AREA=10,
-
- OT_UWB_MORE_CARD=11,
- };
- class ya_event
- {
- private:
- uint64_t m_ev_id;
- public:
- ya_event(uint64_t e_id):m_cur_time(std::chrono::system_clock::now())
- {
- m_ev_id = e_id;
- m_obj_id = 0;
- m_map_id = 0;
- m_area_id = 0;
- x = 0;
- y = 0;
- m_limit_value = 0;
- m_cur_value = 0;
- m_desc = "";
- m_landmarkid = 0;
- m_landmarkdirect = 0;
- m_landmarkdist = 0;
- m_status=ES_START;
- }
- ~ya_event(){}
- public:
-
- EVENT_STATUS m_status;
-
- EVENT_TYPE m_ev_type;
-
- OBJECT_TYPE m_obj_type;
-
- uint64_t m_obj_id;
-
- std::chrono::system_clock::time_point m_cur_time;
-
- int m_map_id;
-
- int m_area_id;
-
- double x;
-
- double y;
-
- double m_limit_value;
-
- double m_cur_value;
-
- std::string m_desc;
-
- int m_landmarkid;
-
- double m_landmarkdist;
-
- int m_landmarkdirect;
-
- uint64_t m_list_id;
- uint64_t get_id(){return m_ev_id;}
- };
- typedef std::shared_ptr<ya_event> event_ptr;
- typedef std::map<uint64_t, std::shared_ptr<ya_event>> event_map;
- typedef std::shared_ptr<event_map> event_map_ptr;
- class tool_time
- {
- public:
- static uint32_t elapse_seconds(std::chrono::system_clock::time_point &start)
- {
- return std::chrono::duration_cast<std::chrono::seconds>
- (std::chrono::system_clock::now() - start).count();
- }
- static uint64_t elapse_ms(std::chrono::system_clock::time_point &start)
- {
- return std::chrono::duration_cast<std::chrono::milliseconds>
- (std::chrono::system_clock::now() - start).count();
- }
- static uint32_t now_to_seconds()
- {
- return std::chrono::duration_cast<std::chrono::seconds>
- (std::chrono::system_clock::now().time_since_epoch()).count();
- }
- static uint64_t now_to_ms()
- {
- return std::chrono::duration_cast<std::chrono::milliseconds>
- (std::chrono::system_clock::now().time_since_epoch()).count();
- }
- static uint64_t to_ms(const std::chrono::system_clock::time_point &time)
- {
- return std::chrono::duration_cast<std::chrono::milliseconds>
- (time.time_since_epoch()).count();
- }
- static std::string to_str(const std::chrono::system_clock::time_point &time)
- {
- char _time[25] = {0};
- time_t tt = std::chrono::system_clock::to_time_t(time);
- struct tm *local_time=localtime(&tt);
- strftime(_time, 22, "%Y-%m-%d %H:%M:%S", local_time);
- return std::string(_time);
- }
-
- static std::string to_str_ex(const std::chrono::system_clock::time_point &time)
- {
- uint64_t mill = std::chrono::duration_cast<std::chrono::milliseconds>(time.time_since_epoch()).count()
- -std::chrono::duration_cast<std::chrono::seconds>(time.time_since_epoch()).count()*1000;
- char _time[25] = {0};
- time_t tt = std::chrono::system_clock::to_time_t(time);
- struct tm *local_time=localtime(&tt);
-
- sprintf(_time, "%d-%02d-%02d %02d:%02d:%02d.%d", local_time->tm_year+1900,
- local_time->tm_mon+1, local_time->tm_mday, local_time->tm_hour,
- local_time->tm_min, local_time->tm_sec, mill);
- return std::string(_time);
- }
- };
- class tool_other
- {
- public:
- static bool is_person(int32_t type)
- {
- return CT_PERSON == type;
- }
- static bool is_vehicle(int32_t type)
- {
- return CT_VEHICLE == type;
- }
- static bool is_up_site(int32_t reader_type_id)
- {
- return READER_TYPE_ID_UP == reader_type_id;
- }
- static bool is_attendance(int32_t stat_attendance)
- {
- return AS_ATTENDANCE == stat_attendance;
- }
- static uint64_t to_uint64_cardid(uint64_t type, uint64_t id)
- {
- return (type<<32)|id;
- }
- static std::string to_uint64_cardid_str(uint64_t type, uint64_t id)
- {
- char sql[15] = {'\0'};
- sprintf(sql, "%03d%010d", type, id);
- return std::string(sql);
- }
- static bool is_attendance_area(int area_id, uint64_t vehicle_id)
- {
- char sql[1024] = {'\0'};
- sprintf(sql,
- "select vt.att_rule_id from dat_att_rule_area a, dat_att_rule_vehicle_type vt, dat_vehicle v\
- where a.area_id=%d and v.vehicle_id=%d \
- and vt.vehicle_type_id=v.vehicle_type_id \
- and a.att_rule_id=vt.att_rule_id;",
- area_id, vehicle_id);
- std::string Error;
- YADB::CDBResultSet DBRes;
- sDBConnPool.Query(sql,DBRes,Error);
- int nCount = DBRes.GetRecordCount( Error );
- log_debug("车卡考勤区域查询:nCount=%d,sql=%s", nCount, sql);
- return (nCount > 0);
- }
- static uint64_t to_event_list_id(int obj_id, EVENT_TYPE ev_type)
- {
- return (static_cast<uint64_t>(ev_type)<<32)|static_cast<uint64_t>(obj_id);
- }
- static event_ptr create_event(OBJECT_TYPE obj_type, int obj_id, EVENT_TYPE ev_type)
- {
- auto ev_ptr = std::make_shared<ya_event>(tool_time::now_to_ms());
- ev_ptr->m_ev_type = ev_type;
- ev_ptr->m_obj_type = obj_type;
- ev_ptr->m_obj_id = static_cast<OBJECT_TYPE>(obj_id);
- ev_ptr->m_list_id = to_event_list_id(obj_id, ev_type);
- return ev_ptr;
- }
- static void insert_event(const event_ptr ev_ptr, event_map& out_ev_map)
- {
- out_ev_map.insert(std::make_pair(ev_ptr->m_list_id, ev_ptr));
- }
- static void copy_event(const std::shared_ptr<card> card_ptr, event_ptr ev_ptr)
- {
- ev_ptr->x = card_ptr->x;
- ev_ptr->y = card_ptr->y;
- }
- static event_ptr find_event(int obj_id, EVENT_TYPE ev_type, const event_map& ev_map)
- {
- auto it = ev_map.find(to_event_list_id(obj_id, ev_type));
- if(ev_map.end() == it)
- {
- return nullptr;
- }
- return it->second;
- }
- };
- class tool_db
- {
- private:
-
-
- static void PushAsync(char* sql)
- {
- log_debug("PushAsync记录到队列中:%s\n", sql);
- if(!sDBConnPool.PushAsync(sql))
- {
- log_error( "PushAsync记录到队列中失败\n");
- }
- }
- public:
- static void save_event(const event_ptr ev_ptr)
- {
- char sql[LENGTH_SQL] = {'\0'};
- std::string _time = tool_time::to_str(ev_ptr->m_cur_time);
- sprintf(sql,
- "INSERT IGNORE INTO his_event_data(event_id, stat, event_type_id, obj_type_id, obj_id, \
- map_id, area_id, limit_value, cur_value, x, y, cur_time, description, \
- landmark_id, landmark_dist,direction_mapper_id )\
- VALUES(%ld, %d, %d, %d, %ld, %d, %d, %.2f, %.2f, %f, %f, '%s', '%s', %d, %d, %10.3f);",
- ev_ptr->get_id(), ev_ptr->m_status, ev_ptr->m_ev_type, ev_ptr->m_obj_type, ev_ptr->m_obj_id,
- ev_ptr->m_map_id, ev_ptr->m_area_id, ev_ptr->m_limit_value, ev_ptr->m_cur_value, ev_ptr->x, ev_ptr->y,
- _time.c_str(), ev_ptr->m_desc.c_str(),
- ev_ptr->m_landmarkid, ev_ptr->m_landmarkdirect, ev_ptr->m_landmarkdist);
- PushAsync(sql);
- }
- static void save_attendance(const std::shared_ptr<card_location_base> card_ptr,
- const std::shared_ptr<area_hover> area_hover_ptr)
- {
- char sql[LENGTH_SQL] = {0};
- std::string call("add_att_staff");
- if(tool_other::is_vehicle(card_ptr->m_type))
- {
- call="add_att_vehicle";
- }
- auto start = card_ptr->m_attendance_start_time;
- auto end = card_ptr->m_attendance_start_time;
- if(!tool_other::is_attendance(card_ptr->m_stat_attendance))
- {
- std::time_t end_t= card_ptr->m_time/1000;
- end = std::chrono::system_clock::from_time_t(end_t);
- }
- std::string start_str = tool_time::to_str(start);
- std::string end_str = tool_time::to_str(end);
- int landmarkid = 0;
- int landmarkdirect=0;
- double landmarkdist=0;
- if(area_hover_ptr)
- {
- landmarkid = area_hover_ptr->landmark_id;
- landmarkdirect = area_hover_ptr->landmark_dir;
- landmarkdist = area_hover_ptr->landmark_dis;
- }
- sprintf(sql, "CALL %s(%s, %d, '%s', '%s', %d, %d, %.3f);", call.c_str(),
- tool_other::to_uint64_cardid_str(card_ptr->m_type, card_ptr->m_id).c_str(),
- card_ptr->m_id, start_str.c_str(), end_str.c_str(),
- landmarkid, landmarkdirect, landmarkdist);
- PushAsync(sql);
- }
- static void save_his_raw_data(const std::shared_ptr<card> card_ptr)
- {
- }
- static void save_his_location(const std::shared_ptr<card_location_base> card_ptr)
- {
- }
- static void save_his_area_location_enter(const std::shared_ptr<card_location_base> card_ptr)
- {
- }
- static void save_his_area_location_leave(const std::shared_ptr<card_location_base> card_ptr)
- {
- }
- };
- class i_thread
- {
- public:
- i_thread()
- {
- sleep_ms=10*1000;
- }
- virtual ~i_thread(){}
-
- void start()
- {
- _thread_flag=true;
- _thread_handler=std::thread(&i_thread::thread_proc, this);
- }
-
- void stop()
- {
- _thread_flag=false;
- _thread_handler.join();
- }
-
- std::atomic<int> sleep_ms;
- protected:
-
- std::mutex _mutex;
-
- virtual void run(){}
- private:
-
- std::thread _thread_handler;
-
- std::atomic<bool> _thread_flag;
- void thread_proc()
- {
- while(_thread_flag)
- {
- run();
- std::this_thread::sleep_for(std::chrono::milliseconds(sleep_ms));
- }
- }
- };
- template<typename T>
- class singleton_base
- {
- public:
- static T *instance()
- {
- if(nullptr != _instance)
- {
- return _instance;
- }
- std::lock_guard<std::mutex> ll(_mutex_singleton_base);
- if(nullptr == _instance)
- {
- _instance = new(std::nothrow) T();
- }
- return _instance;
- }
- protected:
-
- singleton_base(){}
- virtual ~singleton_base(){}
- private:
-
- singleton_base(const singleton_base& src){}
- singleton_base &operator=(const singleton_base& src){}
-
- class Garbo
- {
- public:
- ~Garbo()
- {
- if (singleton_base::_instance)
- {
- delete singleton_base::_instance;
- singleton_base::_instance = nullptr;
- }
- }
- };
-
- static Garbo garbo;
- static T *_instance;
- static std::mutex _mutex_singleton_base;
- };
- template<typename T>
- T *singleton_base<T>::_instance = nullptr;
- template<typename T>
- std::mutex singleton_base<T>::_mutex_singleton_base;
- #endif
|