area.h 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254
  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 is_mine()//是矿井区域
  39. {
  40. return 0 == m_id;
  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. //是否是工作区域(0:不是、1:是)
  88. int m_is_work_area=0;
  89. };
  90. struct area_list:single_base<area_list,int,std::shared_ptr<area>>
  91. {
  92. area_list();
  93. //根据分站、所在点找出所在区域列表
  94. 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 &);
  95. std::vector<point> init_path(std::string &str);
  96. ///id=-1为初始化所有
  97. void init_from_db(int id=-1);
  98. void init_monkeycar_area(int id=-1);
  99. private:
  100. 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);
  101. //禁区功能-给禁区中的卡发送警告及呼叫
  102. void CheckAreaType(int area_id,int new_area_type,int old_area_type);
  103. void CheckAreaType( std::shared_ptr<area> pArea,int new_area_type,int old_area_type);
  104. };
  105. struct area_hover
  106. {
  107. std::shared_ptr<area> m_area;
  108. time_t m_enter_time,m_last_time;
  109. point m_enter_point,m_last_point;
  110. int landmark_id;
  111. int landmark_dir;
  112. double landmark_dis;
  113. /*
  114. 记录该业务所关心的需持续使用的数据,每个业务一个指针
  115. 建议该数据项在on_enter时初始化,on_leave时清除
  116. */
  117. std::vector<std::shared_ptr<business_data>> m_data;
  118. area_hover()=default;
  119. area_hover(std::shared_ptr<area>&area,const point&pt)
  120. :m_area(area)
  121. {
  122. m_enter_time=m_last_time=time(0);
  123. m_enter_point=m_last_point=pt;
  124. landmark_id=0;
  125. landmark_dir=0;
  126. landmark_dis=0;
  127. }
  128. std::shared_ptr<business_data>&get_business_data(int type)
  129. {
  130. if(type>=(int)m_data.size())
  131. {
  132. m_data.resize(type+1);
  133. }
  134. return m_data[type];
  135. }
  136. int id()const
  137. {
  138. return m_area->id();
  139. }
  140. int mapid()const
  141. {
  142. return m_area->mapid();
  143. }
  144. double scale()const
  145. {
  146. return m_area->scale();
  147. }
  148. bool operator == (const area_hover&o)const
  149. {
  150. return m_area->id()==o.m_area->id();
  151. }
  152. bool operator < (const area_hover&o)const
  153. {
  154. return m_area->id()<o.m_area->id();
  155. }
  156. std::tuple<time_t,time_t,int,int,int,int,double,double> getLandmark()
  157. {
  158. return std::make_tuple(m_enter_time,m_last_time,mapid(),id(),landmark_id,landmark_dir,landmark_dis,scale());
  159. }
  160. void setLandmark(const point &pt);
  161. void set(const point&pt)
  162. {
  163. m_last_time=time(0);
  164. m_last_point = pt;
  165. }
  166. };
  167. //每张卡包含一个对象
  168. //在解析出数据点时,调用on_point
  169. struct site;
  170. struct area_tool
  171. {
  172. //卡所在的所有area的列表,以id排序小->大
  173. std::vector<std::shared_ptr<area_hover>> m_hover_list;
  174. //推送卡位置时需要推送的所在区域id列表
  175. std::vector<int> m_push_area_id_list;
  176. std::shared_ptr<area_hover> get_area_first()const
  177. {
  178. if(m_hover_list.empty())
  179. return nullptr;
  180. return m_hover_list.front();
  181. }
  182. void init_area(std::shared_ptr<area>&a,const point&pt,const std::shared_ptr<card_location_base> &c)
  183. {
  184. m_hover_list.clear();
  185. m_hover_list.push_back(std::make_shared<area_hover>(a,pt));
  186. a->on_enter(m_hover_list.back(), c);
  187. }
  188. void on_point(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>& c,const point&pt);
  189. void on_leave(const std::shared_ptr<card_location_base>& c);
  190. void setLandmark(const point &pt)
  191. {
  192. for(const auto & ha:m_hover_list)
  193. ha->setLandmark(pt);
  194. }
  195. std::tuple<time_t,time_t,int,int,int,int,double,double> getLandmark()
  196. {
  197. double dis = DBL_MAX,d=0;
  198. std::shared_ptr<area_hover> tmp=nullptr;
  199. for(const auto & ha:m_hover_list)
  200. {
  201. d=ha->landmark_dis;
  202. if(d<dis){
  203. dis=d;tmp = ha;
  204. }
  205. }
  206. if(tmp)
  207. return tmp->getLandmark();
  208. else
  209. return std::make_tuple(0,0,0,0,0,0,0,0);
  210. }
  211. void change_area(uint32_t card_id,double speed,int16_t type,int32_t new_areaid)
  212. {
  213. #if 0
  214. do_leave_biz(card_id,speed,type);
  215. auto area = area_list::instance()->get(new_areaid);
  216. point pt;
  217. m_area_hover.reset(new area_hover(area,pt,speed));
  218. do_enter_biz(card_id,speed,type);
  219. #endif
  220. }
  221. };
  222. #endif