area.h 6.3 KB

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