area.h 6.3 KB

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