card_person.cpp 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  1. #include <string>
  2. #include <thread>
  3. #include "card_person.h"
  4. #include "loc_point.h"
  5. #include "card_message_handle.h"
  6. #include "area.h"
  7. #include "mine.h"
  8. #include "his_location.h"
  9. #include "three_rates.h"
  10. #include "select_tool.h"
  11. #include "monkey_car/monkeycar_person.h"
  12. #include "websocket/ws_common.h"
  13. #include "event.h"
  14. #include "mine_business.h"
  15. #include"common_tool.h"
  16. #include"db/db_tool.h"
  17. person::person(const std::string &type,uint32_t cardid,uint16_t needdisplay,int16_t t,int32_t deptid,int32_t level_id,uint32_t cid,int wl,const std::string &sname,const std::string &dname,int worketype_id)
  18. :card_location_base(type,cardid,needdisplay,t,deptid,level_id,cid)
  19. ,m_workLine(wl)
  20. ,m_stafferName(sname)
  21. ,m_deptName(dname)
  22. ,m_worktype_id(worketype_id)
  23. {
  24. m_message_handle.reset(new card_message_handle(this));
  25. m_his_location_card.reset(new location_staff(m_id,m_type));
  26. }
  27. person::~person()
  28. {
  29. }
  30. void person::clear()
  31. {
  32. m_area_tool.reset(new area_tool);
  33. m_mine_tool.reset(new mine_tool);
  34. card_location_base::clear();
  35. }
  36. void person::set_area_info(int mapid,double scale,int areaid,uint64_t t,int type)
  37. {
  38. m_area_tool->set_area_info(mapid,scale,areaid,*this,t,type);
  39. }
  40. void person::site_hover(int sid)
  41. {
  42. IKSDK_DB(sid);
  43. }
  44. //虹膜识别入库功能
  45. void person::IKSDK_DB(int sid)
  46. {
  47. auto sit_ptr = sit_list::instance()->get(sid);
  48. if(nullptr == sit_ptr)
  49. return;
  50. if(sit_ptr->m_reader_type_id == READER_TYPE_ID_UP)
  51. {
  52. time_t now = time(0);
  53. if(now - m_iris_recognition_timeval > 5)
  54. {
  55. int f=0;
  56. if(event_list::instance()->get_event_card(m_id, m_type, ET_CARD_LOW_POWER_SERIOUS))
  57. f=1;
  58. std::string card_id = tool_other::type_id_to_str(m_type,m_id);
  59. std::string st = tool_time::to_str(now);
  60. char nsql[256]={0};
  61. const char*sql="REPLACE INTO his_att_interface (staff_id,card_id,reader_id,staff_name,dept_name,upt_time,low_power_warn) VALUES (%d,%s,%d,'%s','%s','%s',%d);";
  62. snprintf(nsql,256,sql,m_cid,card_id.c_str(),sid,m_stafferName.c_str(),m_deptName.c_str(),st.c_str(),f);
  63. db_tool::PushAsync(nsql);
  64. logn_info(2,"%s",nsql);
  65. m_iris_recognition_timeval = now;
  66. }
  67. }
  68. }
  69. std::shared_ptr<mine_tool> person::get_mine_tool()
  70. {
  71. return m_mine_tool;
  72. }
  73. void person::do_business(const std::shared_ptr<site>&site,const point &pt,double acc)
  74. {
  75. m_area_tool->set(site);
  76. m_area_tool->on_point(shared_from_this(),pt);
  77. m_timeval=m_time;
  78. handle_three_rates(pt);
  79. }
  80. void person::reset(std::shared_ptr<monkey_person> mp)
  81. {
  82. m_monkeyPerson = mp;
  83. }
  84. void person::handle_three_rates(const point & pt)
  85. {
  86. card_pos cp;
  87. cp.work_line=m_workLine;
  88. cp.work_type_id = m_worktype_id;
  89. m_biz_stat=get_stat();
  90. cp.biz_stat = m_biz_stat;
  91. cp.x=pt.x;cp.y=pt.y;cp.z=pt.z;
  92. cp.work_type_id=m_worktype_id;
  93. put_three_rates(cp);
  94. }
  95. void person::on_timer()
  96. {
  97. //人员井下超时
  98. // m_mine_tool->on_check_overtime(this->m_id,this->m_type);
  99. if(!m_mine_tool->m_is_attendance)
  100. return;
  101. YA::_CARD_POS_ cp;
  102. if(m_display)
  103. mine_business::inst()->fetch_add();
  104. uint64_t _time=0;
  105. point pt = getSmoothPoint(_time);
  106. // const auto lm = m_area_tool->getLandmark();
  107. // cp.enter_area_time = std::get<0>(lm)*1000;
  108. // cp.rec_time = std::get<1>(lm);
  109. // int32_t map_id = std::get<2>(lm);
  110. // int32_t area_id = std::get<3>(lm);
  111. // cp.map_id=map_id;cp.area_id=area_id;
  112. // cp.landmark_id = std::get<4>(lm);
  113. // cp.lm_direction = std::get<5>(lm);
  114. // cp.landmark_dis=std::get<6>(lm);
  115. cp.area_info=m_area_tool->m_area_info;
  116. cp.map_id =m_area_tool->m_mapid;
  117. cp.biz_stat = m_biz_stat;
  118. cp.down_time = m_mine_tool->get_down_time();
  119. cp.work_time = m_mine_tool->get_work_time();
  120. cp.is_on_duty= m_mine_tool->is_on_duty();
  121. upt_card_pos(cp,pt);
  122. log_info("on_timer here ...%d,%lld,%.2f,%.2f,%d,%d--",m_id,_time,pt.x,pt.y,cp.map_id,cp.area_info.size());
  123. if(!cp.area_info.empty())
  124. {
  125. int area_id = cp.area_info.begin()->first;
  126. m_his_location_card->push(_time,pt,area_id,cp.map_id);
  127. }
  128. uint64_t _now=tool_time::now_to_ms();
  129. uint64_t t=_now>m_timeval?_now-m_timeval:m_timeval-_now;
  130. if(t>10*1000)
  131. {
  132. m_area_tool->on_point(shared_from_this(),pt);
  133. m_biz_stat=get_stat();
  134. }
  135. }
  136. point person::getSmoothPoint(uint64_t& t)
  137. {
  138. point pt;
  139. loc_point lp = m_smo_tool->smooth_strategy();
  140. m_speed = lp.m_speed;
  141. m_stat = lp.m_stat;
  142. pt.x = lp.x;
  143. pt.y = -lp.y;
  144. t=lp.m_time;
  145. if(auto p = m_monkeyPerson.lock() )
  146. {
  147. if(p->is_on_bus())
  148. {
  149. m_stat = 7;
  150. pt = p->getPoint(t);
  151. log_info("getpoint_oncar:%d,%lld",m_id,t);
  152. }
  153. }
  154. return pt;
  155. }