card_base.cpp 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153
  1. #include <memory>
  2. #include <message.h>
  3. #include "card_message_handle.h"
  4. #include "card_person.h"
  5. #include "card_car.h"
  6. #include "config_file.h"
  7. #include "select_tool.h"
  8. #include "module_service/module_mgr.h"
  9. #include "websocket/wsClientMgr.h"
  10. #include "websocket/wsTimerThread.h"
  11. #include "three_rates.h"
  12. #include "his_location.h"
  13. extern config_file config;
  14. card_location_base::card_location_base(std::string type,uint32_t id,uint16_t dis,int16_t t,int32_t deptid,int32_t level_id,uint32_t cid)
  15. :card(id,dis,t,deptid,level_id,cid)
  16. {
  17. select_tool_manage::instance()->create_tool(type,m_sel_tool,m_smo_tool);
  18. }
  19. void card_location_base::do_status(int st)
  20. {
  21. module_mgr::do_status((STATUS_CARD)st, m_id, m_type);
  22. }
  23. void card_location_base::on_location(const std::vector<point>&vp,const std::vector<loc_message> &lm )
  24. {
  25. loc_point pt = m_sel_tool->select_solution(vp,lm);
  26. pt.y=-pt.y;
  27. if(pt.m_useless)
  28. {
  29. x = pt.x;
  30. y = pt.y;
  31. //Msg m;
  32. //m.type=m_type;m.x=(int)x;m.y=(int)y;m.cmd=CMD_HANDLE;m.cardid=m_type<<32|m_id;
  33. //cardMgr::instance()->tryPut(m);
  34. double acc = lm[0].m_acc;
  35. m_acc = lm[0].m_acc;
  36. log_info("useful:card_id:%d,ct:%d,timestamp:%llu, loc_point,x:%.2f,y:%.2f acc:%.2f",m_id,m_ct,m_time,pt.x,pt.y,acc);
  37. do_business(lm.front().m_sit, pt, acc);
  38. }
  39. }
  40. void card_location_base::on_message(zloop<task*> * loop,const message_locinfo&loc,bool is_history)
  41. {
  42. m_ct = loc.m_card_ct;
  43. m_time = loc.m_time_stamp;
  44. m_message_handle->on_message(loop,loc,is_history);
  45. }
  46. //前端推送位置函数.
  47. void card_location_base::upt_card_pos(YA::_CARD_POS_&cp, const point &pt)
  48. {
  49. // YA::_CARD_POS_ cp;
  50. cp.x = pt.x;
  51. cp.y = pt.y;
  52. cp.z = pt.z;
  53. cp.Type=m_type;
  54. cp.ID = m_id;
  55. cp.speed = abs(ceil(m_speed));
  56. cp.running_stat = m_stat;
  57. cp.dept_id = m_deptid;
  58. cp.display=m_display;
  59. cp.rec_time=m_time;
  60. cp.level_id = m_level_id;
  61. swsTimerThrd.upt_card_pos(cp);
  62. }
  63. void card_location_base::del_card_pos()
  64. {
  65. YA::_CARD_POS_ cp;
  66. cp.ID = m_id;
  67. cp.Type=m_type;
  68. swsTimerThrd.del_card_pos(cp);
  69. }
  70. int card_location_base::get_stat()
  71. {
  72. //盲区>呼救>呼叫>超时>超速>正常
  73. uint64_t now = time(0)*1000;
  74. if(now-m_time>CARD_LOST_TIME_OUT)
  75. {
  76. return STATUS_LOST;
  77. }
  78. else if(auto ev_ptr = event_list::instance()->get_event_card(m_id, m_type, ET_CARD_HELP))
  79. {
  80. return (ES_DEAL_HELP == ev_ptr->m_status) ? STATUS_HELP_DEALED : STATUS_HELP;
  81. }
  82. else if(CALL_NONE != get_mine_tool()->m_status_call)
  83. {
  84. return STATUS_CALL;
  85. }
  86. else if(event_list::instance()->get_event_card(m_id, m_type,
  87. is_person()? ET_CARD_AREA_OVER_TIME_PERSON: ET_CARD_AREA_OVER_TIME_VEHICLE))
  88. {
  89. return STATUS_AREA_OVER_TIME;
  90. }
  91. else if(event_list::instance()->get_event_card(m_id, m_type, ET_CARD_OVER_SPEED))
  92. {
  93. return STATUS_OVER_SPEED;
  94. }
  95. return STATUS_NORMAL;
  96. }
  97. void card_location_base::clear()
  98. {
  99. // uint16_t m_display; //1显示0不显示,往前端推送
  100. m_speed=0; //速度
  101. m_is_attendance=0; //井上井下状态 0初始状态 1 井上 2 井下
  102. m_stat=0; //运动静止状态
  103. //m_ct; //ct
  104. m_time=0; //时间戳
  105. }
  106. void card_location_base::put_three_rates(card_pos & cp)
  107. {
  108. cp.rec_time=m_time;cp.type=m_type;cp.id=m_id;
  109. cp.identifier_id=m_cid;cp.running_stat=m_stat;cp.final_v=m_speed;
  110. log_info("three_rates:type:%d,id:%d,cid:%d",cp.type,cp.id,cp.identifier_id);
  111. three_rates::get_instance()->put(cp);
  112. }
  113. bool card_location_base::is_person() const
  114. {
  115. return tool_other::is_person(m_type);
  116. }
  117. bool card_location_base::is_vehicle() const
  118. {
  119. return tool_other::is_vehicle(m_type);
  120. }
  121. card_location_base::~card_location_base()
  122. {
  123. }
  124. std::shared_ptr<card_location_base> card_location_base::make_person(const std::string&type,uint32_t cardid,uint16_t needdisplay,int16_t t,
  125. int32_t deptid,int32_t level_id,uint32_t cid,int wl,const std::string &sname,const std::string & dname)
  126. {
  127. return std::make_shared<person>(type,cardid,needdisplay,t, deptid,level_id,cid,wl,sname,dname);
  128. }
  129. std::shared_ptr<card_location_base> card_location_base::make_car(const std::string&type,uint32_t cardid,uint16_t needdisplay,int16_t t,
  130. int32_t deptid, int32_t categoryid, int type_id,int32_t level_id,uint32_t cid)
  131. {
  132. return std::make_shared<car>(type,cardid,needdisplay,t, deptid, categoryid, type_id,level_id,cid);
  133. }