card_base.h 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  1. #ifndef _CARD_BASE_HPP_
  2. #define _CARD_BASE_HPP_
  3. #include <vector>
  4. #include <map>
  5. #include <memory>
  6. #include <atomic>
  7. #include "point.h"
  8. #include "common.h"
  9. #include <boost/circular_buffer.hpp>
  10. struct task;
  11. template<typename T> struct zloop;
  12. struct select_tool;
  13. struct smooth_tool;
  14. struct monkey_person;
  15. struct card_message_handle;
  16. struct card_location_base;
  17. struct message_locinfo;
  18. struct loc_message;
  19. struct mine_tool;
  20. struct location_card;
  21. struct card_pos;
  22. struct area_hover;
  23. struct site_area_hover;
  24. struct site;
  25. struct area_tool;
  26. struct message_tdoa_locinfo;
  27. struct message_pdoa_locinfo;
  28. struct message_ins_locinfo;
  29. namespace sys{
  30. struct _CARD_POS_;
  31. }
  32. struct card:point
  33. {
  34. card(uint32_t id,uint16_t dis,uint64_t type,int32_t deptid,int32_t level_id,uint32_t cid)
  35. :m_type(type)
  36. ,m_time(0)
  37. ,m_id(id)
  38. ,m_cid(cid)
  39. ,m_deptid(deptid)
  40. ,m_level_id(level_id)
  41. ,m_stat(0)
  42. ,m_biz_stat(0)
  43. ,m_pwr_stat(0)
  44. ,m_display(dis)
  45. ,m_ct(0)
  46. ,m_freq_id(0)
  47. ,m_freq(0.0)
  48. ,m_acc(0)
  49. ,m_speed(0)
  50. ,m_v_point(0, 0, 0)
  51. {}
  52. uint64_t type_(){return m_type;}
  53. uint64_t time_(){return m_time;}
  54. uint64_t m_type; //类型
  55. uint64_t m_time; //时间戳 ms
  56. uint32_t m_id; //卡号
  57. uint32_t m_cid; //标识id 人staff_id 车 vehicle_id
  58. int32_t m_deptid; //部门编号
  59. int32_t m_level_id; //职务级别
  60. int m_stat; //运动静止状态
  61. int m_biz_stat;
  62. int m_pwr_stat; //电量状态
  63. int m_battery_value = 10; //电量值
  64. uint16_t m_display; //1显示0不显示,往前端推送
  65. uint16_t m_ct; //ct
  66. uint8_t m_freq_id; // 频率索引
  67. double m_freq; // 频率值
  68. ///人卡(加速度状态),其值就是0和1,掘进机和采煤机,其值就是0~255,车辆,其值就需要乘以0.01,用于表示加速度值
  69. double m_acc;
  70. double m_speed; //速度
  71. point m_v_point; //车辆定位系统的定位结果
  72. bool m_isVehicleMap = false;
  73. };
  74. struct card_location_base:card,std::enable_shared_from_this<card_location_base>
  75. {
  76. uint64_t m_timeval=0;
  77. uint16_t m_display_old{0}; //1显示0不显示,往前端推送
  78. void update_display()
  79. {
  80. m_display_old = m_display;
  81. }
  82. bool eq_display()
  83. {
  84. return m_display_old == m_display;
  85. }
  86. std::uint8_t m_event[CARD_EVENT_COUNT_MAX]{0};
  87. std::unique_ptr<select_tool> m_sel_tool;
  88. std::unique_ptr<smooth_tool> m_smo_tool;
  89. std::unique_ptr<card_message_handle> m_message_handle;
  90. std::unique_ptr<location_card> m_his_location_card;
  91. std::atomic<int> m_upmine_flag{0};
  92. time_t m_help_last_time = 0; // 呼救持续时间
  93. int m_help_bit = 0;
  94. // 基站对应的数据信息:距离+时间戳
  95. struct sinfo{
  96. int sct;
  97. double sdist;
  98. sinfo()
  99. : sct(0)
  100. , sdist(0.0)
  101. {}
  102. };
  103. std::map<int, sinfo> last_site_info;
  104. //pdoa
  105. int m_last_ct = -1;
  106. float m_last_dist = 0.0;
  107. uint16_t m_last_site_id = 0; // 卡上一次定位的分站id
  108. uint64_t m_last_recv_time = 0; // 卡上一次接收时间
  109. int m_last_site_dir = -1; // 卡上一次定位的分站天线1朝向
  110. bool m_last_over_site = false; // 卡是否过分站
  111. int m_cache_nums = 0; // 过分站后缓存的数据个数
  112. int m_buff_size = 0;
  113. float m_pdoa_diff = 100.0; // pdoa分站当前上传相位差
  114. float m_last_pdoa_diff = 100.0; // pdoa 分站上一帧数据的相位差
  115. boost::circular_buffer<float> m_cb_pdoa; // the list of current pdoa's different of phase;
  116. boost::circular_buffer<float> m_cb_tof; // the list of tof that is pdoa history value
  117. boost::circular_buffer<point> m_cb_point;
  118. point m_last_point;
  119. int m_cur_site_counts = 0; // 当前基站缓存数据总数
  120. std::vector<float> m_vtp_dist; // 相同分站存储距离数据
  121. bool m_over_site = false; // 过分站状态
  122. //int m_last_down_stream_idx = 0;
  123. boost::circular_buffer<int> m_cb_stream_idx; // 分站下行方向的索引号
  124. bool m_enable_anti_collision = false;
  125. int m_call_level = 0;
  126. std::map<int, std::vector<message_ins_locinfo>> m_msg_list;
  127. card_location_base()=default;
  128. card_location_base(const std::string&type,uint32_t id,uint16_t dis,int16_t t,int32_t,int32_t,uint32_t );
  129. void inc_upmine_flag(int flag){m_upmine_flag=flag;}
  130. int upmine_flag(){return m_upmine_flag.load();}
  131. virtual void do_business(const std::shared_ptr<site>&site,const point &pt)=0;
  132. virtual void on_timer()=0;
  133. virtual std::shared_ptr<mine_tool> get_mine_tool()=0;
  134. virtual void clear();
  135. virtual void reset(std::shared_ptr<monkey_person> mp){}
  136. virtual int get_vehicle_type_id(){return 0;}
  137. virtual void set_area_info(int mapid,double scale,int areaid,uint64_t t,int type)=0;
  138. virtual int get_area(){return -1;}
  139. virtual std::shared_ptr<area_tool> get_area_tool()=0;
  140. virtual int get_vehicle_category_id(){return -1;}
  141. virtual int get_workline(){return -1;}
  142. virtual void get_card(bool f)=0;
  143. virtual void site_hover(int sid){}
  144. virtual void handle_message(uint16_t ct,uint8_t& value){}
  145. void make_his_location(uint64_t t,const point & pt,bool bclose = false);
  146. void on_message(zloop<task*>* loop, message_locinfo&loc, bool is_history);
  147. void on_message(zloop<task*>* loop, message_tdoa_locinfo& loc, bool is_history);
  148. void on_message(zloop<task*>* loop, message_pdoa_locinfo& loc, bool is_history);
  149. void on_message(zloop<task*>* loop, message_ins_locinfo& loc, bool is_history);
  150. void on_location(const std::vector<point>&vp, const std::vector<loc_message> &lm);
  151. void do_status(int st);
  152. void upt_card_pos(sys::_CARD_POS_&cp, point &pt);
  153. void del_card_pos();
  154. int get_stat();
  155. void put_traffic_light(card_pos& cp);
  156. void set_event_flag(EVENT_TYPE et,std::uint8_t f=1){m_event[et]=f;}
  157. bool get_event_flag(EVENT_TYPE et){return m_event[et];}
  158. void do_site_coverage(message_pdoa_locinfo& loc);
  159. void do_card_locate_event(const message_pdoa_locinfo& loc);
  160. void do_site_locate_event(const message_pdoa_locinfo& loc);
  161. bool is_person() const;
  162. bool is_vehicle() const;
  163. void set_base_data(uint32_t cid,uint16_t type,uint32_t deptid,int32_t level_id);
  164. virtual ~card_location_base();
  165. static std::shared_ptr<card_location_base> make_person(const std::string&type,uint32_t cardid,uint16_t needdisplay,int16_t t,
  166. int32_t deptid,int32_t level_id,uint32_t cid,int wl,const std::string & sname,const std::string & dname,int worktype_id);
  167. static std::shared_ptr<card_location_base> make_car(const std::string&type,uint32_t cardid,uint16_t needdisplay,int16_t t,
  168. int32_t deptid, int32_t categoryid, int type_id,int32_t level_id,uint32_t cid);
  169. void set_freq_id(const uint8_t& val)
  170. {
  171. m_freq_id = val;
  172. }
  173. };
  174. #endif