1
0

area.h 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  1. #ifndef _AREA_HPP_
  2. #define _AREA_HPP_
  3. #include <atomic>
  4. #include <algorithm>
  5. #include <cfloat>
  6. #include <iterator>
  7. #include <point.h>
  8. #include "common.h"
  9. #include <write-copy.h>
  10. #include <set>
  11. #include <map>
  12. struct area_hover;
  13. struct point;
  14. struct area_business;
  15. struct business_data;
  16. struct card_location_base;
  17. struct site;
  18. /*
  19. 每个区域对应一个area对象。
  20. */
  21. struct area
  22. {
  23. area(int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t type);
  24. virtual void on_hover(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  25. virtual void on_enter(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  26. virtual void on_leave(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  27. virtual void on_load_his(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  28. virtual bool in_area(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>&c, const point & p,int &);
  29. int id()const
  30. {
  31. return m_id;
  32. }
  33. int mapid()const
  34. {
  35. return m_mapid;
  36. }
  37. double scale()const
  38. {
  39. return m_scale;
  40. }
  41. bool is_mine()//是矿井区域
  42. {
  43. return 0 == m_id;
  44. }
  45. virtual ~area()
  46. {}
  47. void update(int limit_count_person, int limit_time_person,double scale,int32_t mapid,
  48. int32_t type,int limit_count_vehicle, int limit_time_vehicle)
  49. {
  50. m_area_type=type;
  51. m_limit_person_second=limit_time_person;
  52. m_limit_person_count=limit_count_person;
  53. m_scale=scale;
  54. m_mapid=mapid;
  55. m_limit_vehicle_count=limit_count_vehicle;
  56. m_limit_vehicle_second=limit_time_vehicle;
  57. }
  58. public:
  59. std::vector<area_business*> m_area_business_list;
  60. public:
  61. std::vector<point> m_bound;
  62. //数据库唯一ID
  63. int m_id;
  64. //用户定义的业务类型,BIT集合
  65. /*
  66. 1:位置[优先级]
  67. 2:超时[超时时间分钟数]
  68. 3:超员[人员数量、车辆数量]
  69. 4:超速[超速值、判断策略N/M]
  70. 5:人员考勤
  71. 6:车辆考勤[离开最小,离开最小距离]
  72. 7:禁区[进入时长]
  73. 8:猴车区域
  74. */
  75. int m_area_type;
  76. //人卡超时及超员数量(阀值)
  77. int m_limit_person_second;
  78. int m_limit_person_count;
  79. //是否人卡超员已有告警
  80. bool m_event_person_count;
  81. //人卡超时及超员数量(阀值)
  82. int m_limit_vehicle_second;
  83. int m_limit_vehicle_count;
  84. //是否人卡超员已有告警
  85. bool m_event_vehicle_count;
  86. double m_scale;
  87. int32_t m_mapid;
  88. ///区域人卡数
  89. std::atomic<int> m_person_count;
  90. ///区域车卡数
  91. std::atomic<int> m_vehicle_count;
  92. //区域速度门限
  93. double m_over_speed_vehicle;
  94. //是否是工作区域(0:不是、1:是)
  95. int m_is_work_area=0;
  96. };
  97. struct area_list:single_base<area_list,int,std::shared_ptr<area>>
  98. {
  99. area_list();
  100. //根据分站、所在点找出所在区域列表
  101. std::vector<std::shared_ptr<area>> get_area(const std::shared_ptr<site> s,const std::shared_ptr<card_location_base> &c,const point&pt,int &);
  102. std::vector<point> init_path(std::string &str);
  103. ///id=-1为初始化所有
  104. void init_from_db(int id=-1);
  105. void init_monkeycar_area(int id=-1);
  106. private:
  107. std::shared_ptr<area> create(int type,int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t b_type);
  108. };
  109. struct area_hover
  110. {
  111. std::shared_ptr<area> m_area;
  112. uint64_t m_enter_time,m_last_time;
  113. point m_enter_point,m_last_point;
  114. /*
  115. 记录该业务所关心的需持续使用的数据,每个业务一个指针
  116. 建议该数据项在on_enter时初始化,on_leave时清除
  117. */
  118. std::vector<std::shared_ptr<business_data>> m_data;
  119. area_hover()=default;
  120. area_hover(const std::shared_ptr<area>&area,const point&pt);
  121. std::shared_ptr<business_data>&get_business_data(int type)
  122. {
  123. if(type>=(int)m_data.size())
  124. {
  125. m_data.resize(type+1);
  126. }
  127. return m_data[type];
  128. }
  129. int id()const
  130. {
  131. return m_area->id();
  132. }
  133. int mapid()const
  134. {
  135. return m_area->mapid();
  136. }
  137. double scale()const
  138. {
  139. return m_area->scale();
  140. }
  141. bool operator == (const area_hover&o)const
  142. {
  143. return m_area->id()==o.m_area->id();
  144. }
  145. bool operator < (const area_hover&o)const
  146. {
  147. return m_area->id()<o.m_area->id();
  148. }
  149. void set(const point&pt)
  150. {
  151. m_last_time=time(0);
  152. m_last_point = pt;
  153. }
  154. };
  155. //每张卡包含一个对象
  156. //在解析出数据点时,调用on_point
  157. struct site;
  158. struct area_tool
  159. {
  160. //卡所在的所有area的列表,以id排序小->大
  161. std::vector<std::shared_ptr<area_hover>> m_hover_list;
  162. //推送卡位置时需要推送的所在区域id列表
  163. std::map<int,std::tuple<int,int,int,double,uint64_t>> m_area_info;
  164. int m_mapid=-1;
  165. double m_scale=2.0;
  166. void on_point(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>& c,const point&pt);
  167. void on_leave(const std::shared_ptr<card_location_base>& c);
  168. void set_area_info(int mapid,double scale,int areaid,const point &pt,uint64_t t,int type);
  169. void set_area_info(int mapid,int areaid,const point &pt,uint64_t t);
  170. void change_area(uint32_t card_id,double speed,int16_t type,int32_t new_areaid)
  171. {
  172. #if 0
  173. do_leave_biz(card_id,speed,type);
  174. auto area = area_list::instance()->get(new_areaid);
  175. point pt;
  176. m_area_hover.reset(new area_hover(area,pt,speed));
  177. do_enter_biz(card_id,speed,type);
  178. #endif
  179. }
  180. };
  181. #endif