card_base.cpp 4.4 KB

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