module_const.h 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698
  1. #ifndef MODULE_CONST_H
  2. #define MODULE_CONST_H
  3. /**
  4. * @brief 包含常用的常量,接口基类,工具类
  5. * @author 戴月腾
  6. * @date 2018-08-24
  7. */
  8. #include<map>
  9. #include<vector>
  10. #include<string>
  11. #include<chrono>
  12. #include"db_api/CDBConnPool.h"
  13. #include"log.h"
  14. #include<rapidjson/document.h>
  15. #include<rapidjson/prettywriter.h>
  16. #include<rapidjson/stringbuffer.h>
  17. #include<websocket/wsClientMgr.h>
  18. #include<thread>
  19. #include"card.h"
  20. #include"area.h"
  21. #include"constdef.h"
  22. #define LENGTH_SQL 2000
  23. ///全局常量
  24. class global_constant
  25. {
  26. public:
  27. // ///区域超速最小次数门限
  28. // static int AREA_SPEED_COUNT_MIN;
  29. ///区域超速最大次数门限
  30. static int AREA_SPEED_COUNT_LIMIT;
  31. // ///区域超速最小时间门限
  32. // static int AREA_SPEED_TIME_MIN;
  33. // ///区域超速最大时间门限
  34. // static int AREA_SPEED_TIME_MAX;
  35. // ///车辆考勤最小次数门限
  36. // static int ATTENDANCE_VEHICLE_COUNT_MIN;
  37. ///车辆考勤最大次数门限
  38. static int ATTENDANCE_VEHICLE_COUNT_LIMIT;
  39. // ///车辆考勤最小时间门限
  40. // static int ATTENDANCE_VEHICLE_TIME_MIN;
  41. // ///车辆考勤最大时间门限
  42. // static int ATTENDANCE_VEHICLE_TIME_MAX;
  43. };
  44. /**
  45. * @brief 事件状态
  46. */
  47. enum EVENT_STATUS
  48. {
  49. ///事件开始
  50. ES_START = 0,
  51. ///呼救已处理状态
  52. ES_DEAL_HELP = 1,
  53. ///事件结束
  54. ES_END = 100
  55. };
  56. //enum STATUS_CARD
  57. //{
  58. // STATUS_NORMAL = 0, //正常
  59. // STATUS_ERROR = 1,
  60. // STATUS_ERROR_SERIOUS = 2,
  61. // STATUS_POWER_LOWER = 1, //电量低
  62. // STATUS_POWER_LOWER_SERIOUS = 2, //电量极低
  63. // STATUS_OVER_TIME = 4, //超时
  64. // //STATUS_OVER_COUNT = 1,
  65. // STATUS_OVER_SPEED = 8, //超速
  66. // STATUS_AREA_OVER_TIME = 16, //区域超时
  67. // //STATUS_AREA_OVER_COUNT = 1,
  68. // STATUS_AREA_OVER_SPEED = 32, //区域超速
  69. // STATUS_AREA_FORBIDDEN = 64, //进入限制区域
  70. // ////STATUS_HELP = 128, //呼救
  71. // STATUS_HELP_DEALED = 256, //呼救已处理
  72. // STATUS_CALL = 512, //呼叫
  73. // STATUS_LOST = 1024 //进入盲区
  74. // //STATUS_ERROR_DEALED,
  75. //};
  76. enum EVENT_TYPE{ // 事件类型
  77. ET_UNKNOWN = 0,
  78. ET_OVER_COUNT_PERSON = 1, // 井下人员超员mp_card_list_over_count_person
  79. ET_OVER_COUNT_VEHICLE = 2, // 井下车辆超员mp_card_list_over_count_person
  80. ET_AREA_OVER_COUNT_PERSON = 3, // 区域人员超员
  81. ET_AREA_OVER_COUNT_VEHICLE = 4, // 区域车辆超员
  82. ET_SECTION_OVER_COUNT = 5, // 路段拥堵
  83. ET_READER_ERROR = 6, // 分站通信异常
  84. ET_ctrl_reader_ERROR = 7, // 控制分站异常
  85. ET_LIGHT_ERROR = 8, // 交通灯异常
  86. ET_READER_CALL = 9, // 分站呼叫标识卡
  87. ET_READER_CALL_CANCEL = 10, // 取消呼叫分站
  88. ET_CARD_LOW_POWER = 11, // 电量低
  89. ET_CARD_LOW_POWER_SERIOUS = 12, // 电量极低
  90. ET_CARD_OVER_TIME_PERSON = 13, // 人员井下超时mp_card_list_over_time_person
  91. ET_CARD_OVER_TIME_VEHICLE = 14, // 车辆井下超时mp_card_list_over_time_vehicle
  92. ET_CARD_AREA_OVER_TIME_PERSON = 15, // 人员区域超时
  93. ET_CARD_AREA_OVER_TIME_VEHICLE = 16, // 车辆区域超时
  94. ET_CARD_AREA_LIMIT_PERSON = 17, // 人员进入限制区域
  95. ET_CARD_AREA_LIMIT_VEHICLE = 18, // 车辆进入限制区域
  96. ET_CARD_AREA_FORBIDDEN_PERSON = 19, // 人员进入禁止区域
  97. ET_CARD_AREA_FORBIDDEN_VEHICLE = 20, // 车辆进入禁止区域
  98. ET_CARD_OVER_SPEED = 21, // 车辆超速
  99. ET_CARD_AREA_OVER_SPEED = 22, // 车辆区域超速
  100. ET_CARD_RUN_THE_RED_LIGHT = 23, // 车辆闯红灯
  101. ET_CARD_HELP = 24, // 人员呼救
  102. ET_CARD_CALLED = 25, // 人员已被呼叫
  103. ET_CARD_PATROL_ERROR = 26, // 人员巡检异常
  104. ET_CARD_LOST = 27, // 标识卡信号丢失
  105. ET_CARD_DRIVINGFACE_WARNING_AREA = 28, // 掘进面靠近预警区域告警
  106. ET_CARD_NEAR_DRIVINGFACE_VEHICLE=29,// 人员靠近掘进机告警
  107. ET_CARD_NEAR_DRIVINGFACE_OVERCOUNT=30,//掘进机附近人员超员
  108. ET_UWB_MORE_CARD = 31,
  109. ET_CARD_MOTIONLESS=32,
  110. CARD_EVENT_COUNT_MAX,
  111. };
  112. /**
  113. * @brief 对象类型
  114. */
  115. enum OBJECT_TYPE
  116. {
  117. ///矿井
  118. OT_MINE = 1,
  119. ///区域
  120. OT_AREA = 2,
  121. ///路段
  122. OT_SECTION = 3,
  123. ///分站
  124. OT_DEVICE_READER = 4,
  125. ///交通灯
  126. OT_DEVICE_LIGHT = 5,
  127. ///控制分站
  128. OT_DEVICE_ctrl_reader = 6,
  129. ///led屏
  130. OT_DEVICE_LED = 7,
  131. ///防爆音箱
  132. OT_DEVICE_SPEAKER = 8,
  133. ///标识卡,包括人员、车辆、自组网等
  134. OT_CARD = 9,
  135. ///
  136. OT_DRIVINGFACE_AREA=10,
  137. ///
  138. OT_UWB_MORE_CARD=11,
  139. };
  140. /**
  141. * @brief 告警事件
  142. */
  143. class ya_event
  144. {
  145. private:
  146. uint64_t m_ev_id;
  147. public:
  148. ya_event(uint64_t e_id):m_cur_time(std::chrono::system_clock::now())
  149. {
  150. m_ev_id = e_id;
  151. m_obj_id = 0;
  152. m_map_id = 0;
  153. m_area_id = 0;
  154. x = 0;
  155. y = 0;
  156. m_limit_value = 0;
  157. m_cur_value = 0;
  158. m_desc = "";
  159. m_landmarkid = 0;
  160. m_landmarkdirect = 0;
  161. m_landmarkdist = 0;
  162. m_status=ES_START;
  163. }
  164. ~ya_event(){}
  165. public:
  166. ///告警状态,开始、结束
  167. EVENT_STATUS m_status;
  168. ///告警类型
  169. EVENT_TYPE m_ev_type;
  170. ///告警对象类型
  171. OBJECT_TYPE m_obj_type;
  172. /// 告警对象编号,与告警对象类型对应,如告警对象类型为分站,此字段为分站编号
  173. uint64_t m_obj_id;
  174. ///当前时间,为告警事件的触发时间,如果状态为开始,则表示开始时间,否则为结束时间
  175. std::chrono::system_clock::time_point m_cur_time;
  176. ///告警所在地图
  177. int m_map_id;
  178. ///告警所在区域
  179. int m_area_id;
  180. ///位置
  181. double x;
  182. ///位置
  183. double y;
  184. ///告警阈值
  185. double m_limit_value;
  186. ///当前值
  187. double m_cur_value;
  188. ///描述
  189. std::string m_desc;
  190. /// 地标信息
  191. int m_landmarkid;
  192. /// 与地标的距离
  193. double m_landmarkdist;
  194. /// 所处地标的方向
  195. int m_landmarkdirect;
  196. ///作为事件map列表的id,方便查找;(obj_type<<32| obj_id)
  197. uint64_t m_list_id;
  198. uint64_t get_id(){return m_ev_id;}
  199. };
  200. typedef std::shared_ptr<ya_event> event_ptr;
  201. typedef std::map<uint64_t, std::shared_ptr<ya_event>> event_map;
  202. typedef std::shared_ptr<event_map> event_map_ptr;
  203. class tool_time
  204. {
  205. public:
  206. static uint32_t elapse_seconds(std::chrono::system_clock::time_point &start)
  207. {
  208. return std::chrono::duration_cast<std::chrono::seconds>
  209. (std::chrono::system_clock::now() - start).count();
  210. }
  211. static uint64_t elapse_ms(std::chrono::system_clock::time_point &start)
  212. {
  213. return std::chrono::duration_cast<std::chrono::milliseconds>
  214. (std::chrono::system_clock::now() - start).count();
  215. }
  216. static uint32_t now_to_seconds()
  217. {
  218. return std::chrono::duration_cast<std::chrono::seconds>
  219. (std::chrono::system_clock::now().time_since_epoch()).count();
  220. }
  221. static uint64_t now_to_ms()
  222. {
  223. return std::chrono::duration_cast<std::chrono::milliseconds>
  224. (std::chrono::system_clock::now().time_since_epoch()).count();
  225. }
  226. static uint64_t to_ms(const std::chrono::system_clock::time_point &time)
  227. {
  228. return std::chrono::duration_cast<std::chrono::milliseconds>
  229. (time.time_since_epoch()).count();
  230. }
  231. static std::string to_str(const std::chrono::system_clock::time_point &time)
  232. {
  233. char _time[25] = {0};
  234. time_t tt = std::chrono::system_clock::to_time_t(time);
  235. struct tm *local_time=localtime(&tt);
  236. strftime(_time, 22, "%Y-%m-%d %H:%M:%S", local_time);
  237. return std::string(_time);
  238. }
  239. ///"%u-%u-%u %u:%u:%u.%u"
  240. static std::string to_str_ex(const std::chrono::system_clock::time_point &time)
  241. {
  242. uint64_t mill = std::chrono::duration_cast<std::chrono::milliseconds>(time.time_since_epoch()).count()
  243. -std::chrono::duration_cast<std::chrono::seconds>(time.time_since_epoch()).count()*1000;
  244. char _time[25] = {0};
  245. time_t tt = std::chrono::system_clock::to_time_t(time);
  246. struct tm *local_time=localtime(&tt);
  247. //strftime(_time, 22, "%Y-%m-%d %H:%M:%S", local_time);
  248. sprintf(_time, "%d-%02d-%02d %02d:%02d:%02d.%d", local_time->tm_year+1900,
  249. local_time->tm_mon+1, local_time->tm_mday, local_time->tm_hour,
  250. local_time->tm_min, local_time->tm_sec, mill);
  251. return std::string(_time);
  252. }
  253. };
  254. class tool_other
  255. {
  256. public:
  257. static bool is_person(int32_t type)
  258. {
  259. return CT_PERSON == type;
  260. }
  261. static bool is_vehicle(int32_t type)
  262. {
  263. return CT_VEHICLE == type;
  264. }
  265. static bool is_up_site(int32_t reader_type_id)
  266. {
  267. return READER_TYPE_ID_UP == reader_type_id;
  268. }
  269. static bool is_attendance(int32_t stat_attendance)
  270. {
  271. return AS_ATTENDANCE == stat_attendance;
  272. }
  273. static uint64_t to_uint64_cardid(uint64_t type, uint64_t id)
  274. {
  275. return (type<<32)|id; ////// (类型<<32)|卡号
  276. }
  277. static std::string to_uint64_cardid_str(uint64_t type, uint64_t id)
  278. {
  279. char sql[15] = {'\0'};
  280. sprintf(sql, "%03d%010d", type, id);
  281. return std::string(sql);
  282. }
  283. static bool is_attendance_area(int area_id, uint64_t vehicle_id)
  284. {
  285. char sql[1024] = {'\0'};
  286. sprintf(sql,
  287. "select vt.att_rule_id from dat_att_rule_area a, dat_att_rule_vehicle_type vt, dat_vehicle v\
  288. where a.area_id=%d and v.vehicle_id=%d \
  289. and vt.vehicle_type_id=v.vehicle_type_id \
  290. and a.att_rule_id=vt.att_rule_id;",
  291. area_id, vehicle_id);
  292. std::string Error;
  293. YADB::CDBResultSet DBRes;
  294. sDBConnPool.Query(sql,DBRes,Error);
  295. int nCount = DBRes.GetRecordCount( Error );
  296. log_debug("车卡考勤区域查询:nCount=%d,sql=%s", nCount, sql);
  297. return (nCount > 0);
  298. }
  299. static uint64_t to_event_list_id(int obj_id, EVENT_TYPE ev_type)
  300. {
  301. return (static_cast<uint64_t>(ev_type)<<32)|static_cast<uint64_t>(obj_id);
  302. }
  303. static event_ptr create_event(OBJECT_TYPE obj_type, int obj_id, EVENT_TYPE ev_type)
  304. {
  305. auto ev_ptr = std::make_shared<ya_event>(tool_time::now_to_ms());
  306. ev_ptr->m_ev_type = ev_type;
  307. ev_ptr->m_obj_type = obj_type;
  308. ev_ptr->m_obj_id = static_cast<OBJECT_TYPE>(obj_id);
  309. ev_ptr->m_list_id = to_event_list_id(obj_id, ev_type);
  310. return ev_ptr;
  311. }
  312. static void insert_event(const event_ptr ev_ptr, event_map& out_ev_map)
  313. {
  314. out_ev_map.insert(std::make_pair(ev_ptr->m_list_id, ev_ptr));
  315. }
  316. static void copy_event(const std::shared_ptr<card> card_ptr, event_ptr ev_ptr)
  317. {
  318. ev_ptr->x = card_ptr->x;
  319. ev_ptr->y = card_ptr->y;
  320. // if(nullptr!=card_ptr->m_area_hover)
  321. // {
  322. // ev_ptr->m_area_id = card_ptr->m_area_hover->m_area->id();
  323. // }
  324. // ev_ptr->m_landmarkid = card_ptr->m_landmarkid;
  325. // ev_ptr->m_landmarkdist = card_ptr->m_landmarkdist;
  326. // ev_ptr->m_landmarkdirect = card_ptr->m_landmarkdirect;
  327. }
  328. static event_ptr find_event(int obj_id, EVENT_TYPE ev_type, const event_map& ev_map)
  329. {
  330. auto it = ev_map.find(to_event_list_id(obj_id, ev_type));
  331. if(ev_map.end() == it)
  332. {
  333. return nullptr;
  334. }
  335. return it->second;
  336. }
  337. };
  338. class tool_db
  339. {
  340. private:
  341. //void CYAServerDlg::load_his_event_data()
  342. //load_alarm_reader()
  343. static void PushAsync(char* sql)
  344. {
  345. log_debug("PushAsync记录到队列中:%s\n", sql);
  346. if(!sDBConnPool.PushAsync(sql))
  347. {
  348. log_error( "PushAsync记录到队列中失败\n");
  349. }
  350. }
  351. public:
  352. static void save_event(const event_ptr ev_ptr)
  353. {
  354. char sql[LENGTH_SQL] = {'\0'};
  355. std::string _time = tool_time::to_str(ev_ptr->m_cur_time);
  356. sprintf(sql,
  357. "INSERT IGNORE INTO his_event_data(event_id, stat, event_type_id, obj_type_id, obj_id, \
  358. map_id, area_id, limit_value, cur_value, x, y, cur_time, description, \
  359. landmark_id, landmark_dist,direction_mapper_id )\
  360. VALUES(%ld, %d, %d, %d, %ld, %d, %d, %.2f, %.2f, %f, %f, '%s', '%s', %d, %d, %10.3f);",
  361. ev_ptr->get_id(), ev_ptr->m_status, ev_ptr->m_ev_type, ev_ptr->m_obj_type, ev_ptr->m_obj_id,
  362. 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,
  363. _time.c_str(), ev_ptr->m_desc.c_str(),
  364. ev_ptr->m_landmarkid, ev_ptr->m_landmarkdirect, ev_ptr->m_landmarkdist);
  365. PushAsync(sql);
  366. }
  367. static void save_attendance(const std::shared_ptr<card_location_base> card_ptr,
  368. const std::shared_ptr<area_hover> area_hover_ptr)
  369. {
  370. char sql[LENGTH_SQL] = {0};
  371. std::string call("add_att_staff");
  372. if(tool_other::is_vehicle(card_ptr->m_type))//车卡
  373. {
  374. call="add_att_vehicle";
  375. }
  376. auto start = card_ptr->m_attendance_start_time;
  377. auto end = card_ptr->m_attendance_start_time;
  378. if(!tool_other::is_attendance(card_ptr->m_stat_attendance))//考勤结束时间
  379. {
  380. std::time_t end_t= card_ptr->m_time/1000;
  381. end = std::chrono::system_clock::from_time_t(end_t);
  382. }
  383. std::string start_str = tool_time::to_str(start);
  384. std::string end_str = tool_time::to_str(end);
  385. int landmarkid = 0;
  386. int landmarkdirect=0;
  387. double landmarkdist=0;
  388. if(area_hover_ptr)
  389. {
  390. landmarkid = area_hover_ptr->landmark_id;
  391. landmarkdirect = area_hover_ptr->landmark_dir;
  392. landmarkdist = area_hover_ptr->landmark_dis;
  393. }
  394. sprintf(sql, "CALL %s(%s, %d, '%s', '%s', %d, %d, %.3f);", call.c_str(),
  395. tool_other::to_uint64_cardid_str(card_ptr->m_type, card_ptr->m_id).c_str(),
  396. card_ptr->m_id, start_str.c_str(), end_str.c_str(),
  397. landmarkid, landmarkdirect, landmarkdist);
  398. PushAsync(sql);
  399. }
  400. static void save_his_raw_data(const std::shared_ptr<card> card_ptr)
  401. {
  402. // char sql[LENGTH_SQL] = {0};
  403. // std::string _time = tool_time::to_str(card_ptr->m_deal_time);
  404. // sprintf(sql,
  405. // "INSERT IGNORE INTO his_raw_data(card_id, reader_id, antenna_id, reader_stamp, card_stamp, \
  406. // fly_time, distance, ranging_type, power_state, accelerate, his_time, rec_time ) \
  407. // VALUES(%d, %d, %d, %d, %d, %ld, %4.f, %d, %d, %d, '%s', '%s');",
  408. // card_ptr->m_id, card_ptr->m_site_id, card_ptr->m_antenna_id,
  409. // card_ptr->m_reader_tickcount, card_ptr->m_time_stamp,
  410. // card_ptr->m_flying_time, card_ptr->m_distance, card_ptr->m_ranging_type, card_ptr->m_power_state,
  411. // card_ptr->m_accelerate_state,
  412. // card_ptr->m_str_his_time.c_str(), card_ptr->m_str_rec_time.c_str());
  413. }
  414. static void save_his_location(const std::shared_ptr<card_location_base> card_ptr)
  415. {
  416. // sprintf_s(_time,
  417. // STR_LEN_TIME,
  418. // "%u-%u-%u %u:%u:%u.%u",
  419. // card->deal_time.wYear,card->deal_time.wMonth,card->deal_time.wDay,
  420. // card->deal_time.wHour,card->deal_time.wMinute,card->deal_time.wSecond,card->deal_time.wMilliseconds);
  421. // if(card->map_id != 0 && card->area_id != 0){
  422. // b_exec = true;
  423. // switch (card->card_type)
  424. // {
  425. // case CT_PERSON:
  426. // sprintf_s(sql, LENGTH_SQL,
  427. // "INSERT IGNORE INTO his_location_staff(card_id, staff_id, cur_time, x, y, z, map_id, area_id, state,speed,mileage, landmark_id, direction_mapper_id, landmark_dist) VALUES(%s, %d, '%s', %.3f, %.3f, %.3f, %d, %d, %d,%.3f,%.4f, %d, %d, %.4f);",
  428. // card->card_id.c_str(), card->id, _time, card->x_offset_after(), card->y_offset_after(), card->z_offset_after(), card->map_id, card->area_id, card->state,card->get_speed(),card->mileage, card->landmark_id, card->landmark_direction, card->landmark_dis);
  429. // break;
  430. // case CT_VEHICLE:
  431. // sprintf_s(sql, LENGTH_SQL,
  432. // "INSERT IGNORE INTO his_location_vehicle(card_id, vehicle_id, cur_time, x, y, z, map_id, area_id, state,speed,mileage, landmark_id, direction_mapper_id, landmark_dist) VALUES(%s, %d, '%s', %.3f, %.3f, %.3f, %d, %d, %d,%.3f,%.4f, %d, %d, %.4f);",
  433. // card->card_id.c_str(), card->id, _time, card->x_offset_after(), card->y_offset_after(), card->z_offset_after(), card->map_id, card->area_id, card->state,card->get_speed(),card->mileage, card->landmark_id, card->landmark_direction, card->landmark_dis);
  434. // break;
  435. // }
  436. // }
  437. }
  438. static void save_his_area_location_enter(const std::shared_ptr<card_location_base> card_ptr)
  439. {
  440. // sprintf_s(_time,
  441. // STR_LEN_TIME,
  442. // "%u-%u-%u %u:%u:%u.%u",
  443. // card->deal_time.wYear,card->deal_time.wMonth,card->deal_time.wDay,
  444. // card->deal_time.wHour,card->deal_time.wMinute,card->deal_time.wSecond,card->deal_time.wMilliseconds);
  445. // if(card->map_id != 0 && card->area_id != 0){
  446. // b_exec = true;
  447. // switch (card->card_type)
  448. // {
  449. // case CT_PERSON:
  450. // sprintf_s(sql, LENGTH_SQL,
  451. // "call add_area_staff(%s, %d, %d, %d, '%s','%s');",
  452. // card->card_id.c_str(), card->id, card->area_id, card->map_id, _time, _time);
  453. // break;
  454. // case CT_VEHICLE:
  455. // sprintf_s(sql, LENGTH_SQL,
  456. // "call add_area_vehicle(%s, %d, %d, %d, '%s','%s');",
  457. // card->card_id.c_str(), card->id, card->area_id, card->map_id, _time, _time);
  458. // break;
  459. // }
  460. // }
  461. }
  462. static void save_his_area_location_leave(const std::shared_ptr<card_location_base> card_ptr)
  463. {
  464. // sprintf_s(_time,
  465. // STR_LEN_TIME,
  466. // "%u-%u-%u %u:%u:%u.%u",
  467. // card->deal_time.wYear,card->deal_time.wMonth,card->deal_time.wDay,
  468. // card->deal_time.wHour,card->deal_time.wMinute,card->deal_time.wSecond,card->deal_time.wMilliseconds);
  469. // if(card->map_id != 0 && card->area_id != 0){
  470. // b_exec = true;
  471. // sprintf_s(_time_ex,
  472. // STR_LEN_TIME,
  473. // "%u-%u-%u %u:%u:%u.%u",
  474. // card->enter_area_time.wYear,card->enter_area_time.wMonth,card->enter_area_time.wDay,
  475. // card->enter_area_time.wHour,card->enter_area_time.wMinute,card->enter_area_time.wSecond,card->enter_area_time.wMilliseconds);
  476. // switch (card->card_type)
  477. // {
  478. // case CT_PERSON:
  479. // sprintf_s(sql, LENGTH_SQL,
  480. // "call add_area_staff(%s, %d, %d, %d, '%s','%s');",
  481. // card->card_id.c_str(), card->id, card->area_id, card->map_id, _time_ex, _time);
  482. // break;
  483. // case CT_VEHICLE:
  484. // sprintf_s(sql, LENGTH_SQL,
  485. // "call add_area_vehicle(%s, %d, %d, %d, '%s','%s');",
  486. // card->card_id.c_str(), card->id, card->area_id, card->map_id, _time_ex, _time);
  487. // break;
  488. // }
  489. // }
  490. }
  491. };
  492. /**
  493. * @brief 线程接口类,重写run函数,改变睡眠时间 sleep_ms
  494. */
  495. class i_thread
  496. {
  497. public:
  498. i_thread()
  499. {
  500. sleep_ms=10*1000;
  501. }
  502. virtual ~i_thread(){}
  503. /**
  504. * @brief 启动线程
  505. */
  506. void start()
  507. {
  508. _thread_flag=true;
  509. _thread_handler=std::thread(&i_thread::thread_proc, this);
  510. }
  511. /**
  512. * @brief 终止线程
  513. */
  514. void stop()
  515. {
  516. _thread_flag=false;
  517. _thread_handler.join();
  518. }
  519. ///线程睡眠时间 毫秒
  520. std::atomic<int> sleep_ms;
  521. protected:
  522. /// 互斥量
  523. std::mutex _mutex;
  524. /**
  525. * @brief 线程函数
  526. */
  527. virtual void run(){}
  528. private:
  529. /// 线程句柄
  530. std::thread _thread_handler;
  531. /// 线程标志
  532. std::atomic<bool> _thread_flag;
  533. void thread_proc()
  534. {
  535. while(_thread_flag)
  536. {
  537. run();
  538. std::this_thread::sleep_for(std::chrono::milliseconds(sleep_ms));
  539. }
  540. }
  541. };
  542. template<typename T>
  543. class singleton_base
  544. {
  545. public:
  546. static T *instance()
  547. {
  548. if(nullptr != _instance)
  549. {
  550. return _instance;
  551. }
  552. std::lock_guard<std::mutex> ll(_mutex_singleton_base);
  553. if(nullptr == _instance)
  554. {
  555. _instance = new(std::nothrow) T();
  556. }
  557. return _instance;
  558. }
  559. protected:
  560. //使继承者无法public构造函数和析构函数
  561. singleton_base(){}
  562. virtual ~singleton_base(){}
  563. private:
  564. //禁止拷贝构造和赋值运算符
  565. singleton_base(const singleton_base& src){}
  566. singleton_base &operator=(const singleton_base& src){}
  567. //它的唯一工作就是在析构函数中析构Singleton的实例,所以private
  568. class Garbo
  569. {
  570. public:
  571. ~Garbo()
  572. {
  573. if (singleton_base::_instance)
  574. {
  575. delete singleton_base::_instance;
  576. singleton_base::_instance = nullptr;
  577. }
  578. }
  579. };
  580. //定义一个静态成员变量,程序结束时,系统会自动调用它的析构函数,我们不需要访问这个变量,所以不需要初始化
  581. static Garbo garbo;
  582. static T *_instance;
  583. static std::mutex _mutex_singleton_base;
  584. };
  585. template<typename T>
  586. T *singleton_base<T>::_instance = nullptr;
  587. template<typename T>
  588. std::mutex singleton_base<T>::_mutex_singleton_base;
  589. #endif // MODULE_CONST_H