area.h 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253
  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. struct area_hover;
  12. struct point;
  13. struct area_business;
  14. struct business_data;
  15. struct card_location_base;
  16. struct site;
  17. /*
  18. 每个区域对应一个area对象。
  19. */
  20. struct area
  21. {
  22. area(int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t type);
  23. virtual void on_hover(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  24. virtual void on_enter(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  25. virtual void on_leave(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c);
  26. virtual bool in_area(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>&c, const point & p,int &);
  27. int id()const
  28. {
  29. return m_id;
  30. }
  31. int mapid()const
  32. {
  33. return m_mapid;
  34. }
  35. double scale()const
  36. {
  37. return m_scale;
  38. }
  39. bool is_mine()//是矿井区域
  40. {
  41. return 0 == m_id;
  42. }
  43. virtual ~area()
  44. {}
  45. void update(int limit_count_person, int limit_time_person,double scale,int32_t mapid,
  46. int32_t type,int limit_count_vehicle, int limit_time_vehicle)
  47. {
  48. m_area_type=type;
  49. m_limit_person_second=limit_time_person;
  50. m_limit_person_count=limit_count_person;
  51. m_scale=scale;
  52. m_mapid=mapid;
  53. m_limit_vehicle_count=limit_count_vehicle;
  54. m_limit_vehicle_second=limit_time_vehicle;
  55. }
  56. public:
  57. std::vector<area_business*> m_area_business_list;
  58. public:
  59. std::vector<point> m_bound;
  60. //数据库唯一ID
  61. int m_id;
  62. //用户定义的业务类型,BIT集合
  63. /*
  64. 1:位置[优先级]
  65. 2:超时[超时时间分钟数]
  66. 3:超员[人员数量、车辆数量]
  67. 4:超速[超速值、判断策略N/M]
  68. 5:人员考勤
  69. 6:车辆考勤[离开最小,离开最小距离]
  70. 7:禁区[进入时长]
  71. 8:猴车区域
  72. */
  73. int m_area_type;
  74. //人卡超时及超员数量(阀值)
  75. int m_limit_person_second;
  76. int m_limit_person_count;
  77. //人卡超时及超员数量(阀值)
  78. int m_limit_vehicle_second;
  79. int m_limit_vehicle_count;
  80. double m_scale;
  81. int32_t m_mapid;
  82. ///区域人卡数
  83. std::atomic<int> m_person_count;
  84. ///区域车卡数
  85. std::atomic<int> m_vehicle_count;
  86. //区域速度门限
  87. double m_over_speed_vehicle;
  88. };
  89. struct area_list:single_base<area_list,int,std::shared_ptr<area>>
  90. {
  91. area_list();
  92. //根据分站、所在点找出所在区域列表
  93. 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 &);
  94. std::vector<point> init_path(std::string &str);
  95. ///id=-1为初始化所有
  96. void init_from_db(int id=-1);
  97. void init_monkeycar_area(int id=-1);
  98. private:
  99. 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);
  100. //禁区功能-给禁区中的卡发送警告及呼叫
  101. void CheckAreaType(int area_id,int new_area_type,int old_area_type);
  102. void CheckAreaType( std::shared_ptr<area> pArea,int new_area_type,int old_area_type);
  103. };
  104. struct area_hover
  105. {
  106. std::shared_ptr<area> m_area;
  107. time_t m_enter_time,m_last_time;
  108. point m_enter_point,m_last_point;
  109. int landmark_id;
  110. int landmark_dir;
  111. double landmark_dis;
  112. /*
  113. 记录该业务所关心的需持续使用的数据,每个业务一个指针
  114. 建议该数据项在on_enter时初始化,on_leave时清除
  115. */
  116. std::vector<std::shared_ptr<business_data>> m_data;
  117. area_hover()=default;
  118. area_hover(std::shared_ptr<area>&area,const point&pt)
  119. :m_area(area)
  120. {
  121. m_enter_time=m_last_time=time(0);
  122. m_enter_point=m_last_point=pt;
  123. landmark_id=0;
  124. landmark_dir=0;
  125. landmark_dis=0;
  126. }
  127. std::shared_ptr<business_data>&get_business_data(int type)
  128. {
  129. if(type>=(int)m_data.size())
  130. {
  131. m_data.resize(type+1);
  132. }
  133. return m_data[type];
  134. }
  135. int id()const
  136. {
  137. return m_area->id();
  138. }
  139. int mapid()const
  140. {
  141. return m_area->mapid();
  142. }
  143. double scale()const
  144. {
  145. return m_area->scale();
  146. }
  147. bool operator == (const area_hover&o)const
  148. {
  149. return m_area->id()==o.m_area->id();
  150. }
  151. bool operator < (const area_hover&o)const
  152. {
  153. return m_area->id()<o.m_area->id();
  154. }
  155. std::tuple<time_t,time_t,int,int,int,int,double,double> getLandmark()
  156. {
  157. return std::make_tuple(m_enter_time,m_last_time,mapid(),id(),landmark_id,landmark_dir,landmark_dis,scale());
  158. }
  159. void setLandmark(const point &pt);
  160. void set(const point&pt)
  161. {
  162. m_last_time=time(0);
  163. m_last_point = pt;
  164. }
  165. };
  166. //每张卡包含一个对象
  167. //在解析出数据点时,调用on_point
  168. struct site;
  169. struct area_tool
  170. {
  171. //卡所在的所有area的列表,以id排序小->大
  172. std::vector<std::shared_ptr<area_hover>> m_hover_list;
  173. //推送卡位置时需要推送的所在区域id列表
  174. std::vector<int> m_push_area_id_list;
  175. std::shared_ptr<area_hover> get_area_first()const
  176. {
  177. if(m_hover_list.empty())
  178. return nullptr;
  179. return m_hover_list.front();
  180. }
  181. void init_area(std::shared_ptr<area>&a,const point&pt,const std::shared_ptr<card_location_base> &c)
  182. {
  183. m_hover_list.clear();
  184. m_hover_list.push_back(std::make_shared<area_hover>(a,pt));
  185. a->on_enter(m_hover_list.back(), c);
  186. }
  187. void on_point(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>& c,const point&pt);
  188. void on_leave(const std::shared_ptr<card_location_base>& c);
  189. void setLandmark(const point &pt)
  190. {
  191. for(const auto & ha:m_hover_list)
  192. ha->setLandmark(pt);
  193. }
  194. std::tuple<time_t,time_t,int,int,int,int,double,double> getLandmark()
  195. {
  196. double dis = DBL_MAX,d=0;
  197. std::shared_ptr<area_hover> tmp=nullptr;
  198. for(const auto & ha:m_hover_list)
  199. {
  200. d=ha->landmark_dis;
  201. if(d<dis){
  202. dis=d;tmp = ha;
  203. }
  204. }
  205. if(tmp)
  206. return tmp->getLandmark();
  207. else
  208. return std::make_tuple(0,0,0,0,0,0,0,0);
  209. }
  210. void change_area(uint32_t card_id,double speed,int16_t type,int32_t new_areaid)
  211. {
  212. #if 0
  213. do_leave_biz(card_id,speed,type);
  214. auto area = area_list::instance()->get(new_areaid);
  215. point pt;
  216. m_area_hover.reset(new area_hover(area,pt,speed));
  217. do_enter_biz(card_id,speed,type);
  218. #endif
  219. }
  220. };
  221. #endif