area_business.cpp 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303
  1. #include <assert.h>
  2. #include "card_base.h"
  3. #include "area_business.h"
  4. #include "area.h"
  5. #include "card.h"
  6. #include "ya_event.h"
  7. #include "module_service/module_call.h"
  8. struct area_business_factory
  9. {
  10. area_business_factory()
  11. {
  12. }
  13. void regist(int type,std::shared_ptr<area_business> ab)
  14. {
  15. if(type>=(int)m_check_list.size())
  16. {
  17. m_check_list.resize(type+1);
  18. }
  19. assert(m_check_list[type]);
  20. m_check_list[type]=ab;
  21. }
  22. std::vector<std::shared_ptr<area_business>> get_check_list(int business_type)
  23. {
  24. std::vector<std::shared_ptr<area_business>> check_list;
  25. for(int i=0,B=1;i<32;i++)
  26. {
  27. if((B&business_type)==0)
  28. continue;
  29. check_list.push_back(m_check_list[i]);
  30. }
  31. return std::move(m_check_list);
  32. }
  33. std::vector<std::shared_ptr<area_business>> m_check_list;
  34. static area_business_factory& instance()
  35. {
  36. static area_business_factory _instance;
  37. return _instance;
  38. }
  39. };
  40. /*
  41. 确定推送人员信息时的区域,每一个明确需要推送的区域,都要推送
  42. */
  43. struct area_business_post_area:area_business
  44. {
  45. virtual int area_business_type()
  46. {
  47. return 1;
  48. }
  49. //将推送区域信息加入人员数据
  50. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  51. {
  52. }
  53. //从人员数据中清除区域信息
  54. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  55. {
  56. }
  57. };
  58. /*
  59. 判断车辆超速,确定超速后记录日志、数据库并告警
  60. 每张卡在每个区域的超速相关的数据信息记录在 area_hover 对象
  61. 人员&车辆的代码重用,请自行设计
  62. */
  63. struct area_business_speed_checker:area_business
  64. {
  65. virtual int area_business_type()
  66. {
  67. return 4;
  68. }
  69. //在ptr对象中初始化超速检测所需的对象
  70. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  71. {
  72. }
  73. //根据超速检测的策略,进行超速判断,超速时进行告警
  74. //建议使用最近M秒内N秒超时进行判断,M=20,N=15,策略数据记录在ptr中
  75. virtual void on_hover(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  76. {
  77. }
  78. //清除超速检测所需的对象
  79. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  80. {
  81. }
  82. };
  83. /*
  84. 禁区
  85. */
  86. struct area_business_restricted:area_business
  87. {
  88. virtual int area_business_type()
  89. {
  90. return 7;
  91. }
  92. //记录进入时间等信息,生成告警
  93. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> )
  94. {
  95. a->m_enter_point = point(c->x,c->y,c->z);
  96. a->m_last_point.set(0,0,0);
  97. a->m_last_time = 0;
  98. a->m_enter_time = time(nullptr);
  99. // 发送警告
  100. event_ptr evPtr = event_list::instance()->get_event_card(c->m_id,c->m_type,ET_CARD_AREA_FORBIDDEN_PERSON);
  101. if (nullptr == evPtr)
  102. {
  103. event_ptr evPtr = event_list::create_event_card(c->m_id, c->m_type, ET_CARD_AREA_FORBIDDEN_PERSON);
  104. event_list::instance()->copy_event(c, evPtr);
  105. event_list::instance()->add(evPtr->get_list_id(), evPtr);
  106. }
  107. evPtr->m_limit_value = 0;
  108. evPtr->m_cur_value = 0;
  109. evPtr->m_is_display = false;
  110. evPtr->m_status = EVENT_STATUS::ES_START ;
  111. evPtr->m_cur_time = std::chrono::system_clock::now();
  112. event_list::save_event(evPtr);
  113. //呼叫
  114. module_call::instance()->system_call_apoint(c->m_id,c->m_type);
  115. }
  116. //记录退出时间等信息
  117. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  118. {
  119. a->m_last_point = point(c->x,c->y,c->z);
  120. a->m_last_time = time(nullptr);
  121. // 发送警告
  122. int oldStatus = -1;
  123. event_ptr evPtr = event_list::instance()->get_event_card(c->m_id,c->m_type,ET_CARD_AREA_FORBIDDEN_PERSON);
  124. if (nullptr == evPtr)
  125. {
  126. event_ptr evPtr = event_list::create_event_card(c->m_id, c->m_type, ET_CARD_AREA_FORBIDDEN_PERSON);
  127. event_list::instance()->copy_event(c, evPtr);
  128. event_list::instance()->add(evPtr->get_list_id(), evPtr);
  129. oldStatus = EVENT_STATUS::ES_END;
  130. } else{
  131. if (evPtr->m_status != EVENT_STATUS::ES_END)
  132. {
  133. oldStatus = EVENT_STATUS::ES_END;
  134. }
  135. }
  136. evPtr->m_limit_value = 0;
  137. evPtr->m_cur_value = 0;
  138. evPtr->m_is_display = false;
  139. evPtr->m_status = EVENT_STATUS::ES_END ;
  140. evPtr->m_cur_time = std::chrono::system_clock::now();
  141. if (oldStatus != -1)
  142. {
  143. event_list::save_event(evPtr);
  144. }
  145. //取消呼叫
  146. module_call::instance()->system_cancel_call_apoint(c->m_id,c->m_type);
  147. }
  148. };
  149. /*
  150. 猴车区域
  151. */
  152. struct area_business_monkey_area:area_business
  153. {
  154. virtual int area_business_type()
  155. {
  156. return 8;
  157. }
  158. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  159. {
  160. }
  161. virtual void on_hover(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  162. {
  163. }
  164. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  165. {
  166. }
  167. };
  168. /*
  169. 车辆考勤
  170. */
  171. struct area_business_car_attendance:area_business
  172. {
  173. virtual int area_business_type()
  174. {
  175. return 6;
  176. }
  177. //记录进入时间等信息,结束考勤,根据离开的时间和距离,判断是否记录一条新的考勤记录
  178. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  179. {
  180. }
  181. //记录离开考勤区域信息,开始考勤
  182. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  183. {
  184. }
  185. };
  186. /*
  187. 人员考勤
  188. */
  189. struct area_business_person_attendance:area_business
  190. {
  191. virtual int area_business_type()
  192. {
  193. return 5;
  194. }
  195. //记录进入时间等信息,开始考勤
  196. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  197. {
  198. }
  199. //记录离开考勤区域信息,结束考勤
  200. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  201. {
  202. }
  203. };
  204. /*
  205. 判断当前区域a中的人数是否超过设定人数,超过后告警
  206. 区域内实时人数存储在area对象中,在当前类on_enter/on_leave中进行更新
  207. 整个井下的超员和某个区域的超员都使用这个代码
  208. */
  209. struct area_business_count_checker:area_business
  210. {
  211. virtual int area_business_type()
  212. {
  213. return 3;
  214. }
  215. //增加计数,并进行判断
  216. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  217. {
  218. }
  219. //减少计数
  220. virtual void on_leave(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  221. {
  222. }
  223. };
  224. /*
  225. 判断当前区域a中的人卡停留时间
  226. 人员进入区域时间存储在area_hover对象中,在当前类on_enter/on_leave中进行更新
  227. 人员&车辆的代码重用,请自行设计
  228. */
  229. struct area_business_person_dwell_checker:area_business
  230. {
  231. virtual int area_business_type()
  232. {
  233. return 2;
  234. }
  235. //初始化 ptr 的相关数据项
  236. virtual void on_enter(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  237. {
  238. }
  239. //更新 ptr 的相关数据项,并进行超时判断
  240. virtual void on_hover(std::shared_ptr<area_hover>&a,std::shared_ptr<card_location_base>&c,std::shared_ptr<business_data> ptr)
  241. {
  242. }
  243. };
  244. std::vector<std::shared_ptr<area_business>> area_business::get_instance_list(int business_type)
  245. {
  246. return area_business_factory::instance().get_check_list(business_type);
  247. }