#include #include #include "card_person.h" #include "loc_point.h" #include "card_message_handle.h" #include "area.h" #include "mine.h" #include "his_location.h" #include "three_rates.h" #include "select_tool.h" #include "monkey_car/monkeycar_person.h" #include "websocket/ws_common.h" #include "event.h" #include "mine_business.h" #include"common_tool.h" #include"db/db_tool.h" #include "forbid_staff_down_mine.h" #include #include "cardMgr.h" extern config_file config; int person::m_limit_detained_time=-1; int person::m_auto_up_mine_time=-1; 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) :card_location_base(type,cardid,needdisplay,t,deptid,level_id,cid) ,m_workLine(wl) ,m_worktype_id(worketype_id) ,m_stafferName(sname) ,m_deptName(dname) { if(person::m_auto_up_mine_time==-1){ person::m_limit_detained_time=config.get("service.detained_time",10); person::m_auto_up_mine_time=config.get("service.auto_up_mine_time",20); } m_message_handle.reset(new card_message_handle(this)); //m_his_location_card.reset(new location_staff(m_id,m_type,cid)); } person::~person() { } void person::clear() { //m_area_tool.reset(new area_tool); //m_mine_tool.reset(new mine_tool); m_mine_tool->clear(); m_area_tool->clear(); //清除部分信息 card_location_base::clear(); //清除告警信息 uint64_t id = tool_other::type_id_to_u64(m_type,m_id); for(std::uint8_t i=0;ihandle_event(OT_CARD,static_cast(i),id,0,0,false); m_event[i]=0; } } //清除一人多卡功能内存中的人卡相关数据, Msg m; m.cmd=CMD_CLEAR;m.cardid=m_type<<32|m_id; cardMgr::instance()->tryPut(m); } void person::set_area_info(int mapid,double scale,int areaid,uint64_t t,int type) { m_area_tool->set_area_info(mapid,scale,areaid,*this,t,type); } void person::site_hover(int sid) { IKSDK_DB(sid); } //虹膜识别入库功能 void person::IKSDK_DB(int sid) { time_t now = time(0); if(now - m_iris_recognition_timeval > 5) { if (forbid_staff_down_mine::instance()->IsForbid(m_cid,now)) { log_info("Staff:%d forbid down mine",m_cid); //禁止指定人员下井 return; } int f=0; if(event_list::instance()->get_event_card(m_id, m_type, ET_CARD_LOW_POWER_SERIOUS)) { f = 1; } std::string card_id = tool_other::type_id_to_str(m_type,m_id); std::string st = tool_time::to_str(now); char nsql[256]={0}; 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);"; snprintf(nsql,256,sql,m_cid,card_id.c_str(),sid,m_stafferName.c_str(),m_deptName.c_str(),st.c_str(),f); db_tool::PushAsync(nsql); m_iris_recognition_timeval = now; } } std::shared_ptr person::get_mine_tool() { return m_mine_tool; } void person::do_business(const std::shared_ptr&site,const point &pt,double acc) { m_area_tool->on_point(shared_from_this(),pt); make_his_location(m_time,pt); m_timeval=m_time; handle_three_rates(pt); } void person::reset(std::shared_ptr mp) { m_monkeyPerson = mp; } void person::handle_three_rates(const point & pt) { card_pos cp; cp.work_line=m_workLine; cp.work_type_id = m_worktype_id; m_biz_stat=get_stat(); cp.biz_stat = m_biz_stat; cp.x=pt.x;cp.y=pt.y;cp.z=pt.z; cp.work_type_id=m_worktype_id; put_three_rates(cp); } void person::on_timer() { if(!m_mine_tool->m_is_attendance) return; YA::_CARD_POS_ cp; uint64_t _time=0; point pt = getSmoothPoint(_time); cp.area_info=m_area_tool->m_area_info; cp.map_id =m_area_tool->get_mapid(); cp.biz_stat = m_biz_stat; cp.down_time = m_mine_tool->get_down_time(); cp.work_time = m_mine_tool->get_work_time(); cp.is_on_duty= m_mine_tool->is_on_duty(); upt_card_pos(cp,pt); log_info("on_timer here ...%d,%lld,%.2f,%.2f,%d,%d--%d",m_id,_time,pt.x,pt.y,cp.map_id,cp.area_info.size(),person::m_limit_detained_time); //int sid=0; if(auto st=m_area_tool->m_site)sid=st->m_area_id; m_his_location_card->push(_time,pt,sid,cp.map_id); uint64_t _now=tool_time::now_to_ms(); uint64_t t=_now>m_timeval?_now-m_timeval:m_timeval-_now; if(t>10*1000) { m_area_tool->on_point(shared_from_this(),pt); m_biz_stat=get_stat(); } print_card_detained(); if(m_upmine_flag.load()) { m_upmine_flag=0; m_area_tool->on_leave(shared_from_this()); } } //*********************************************** //整点打印入井超过设定时长（默认10h） //进入盲区超过2h的卡 void person::print_card_detained() { const point p(4677,-193.7); const double limit_dist=45.0; int h=tool_time::get_hour(); uint64_t _now=tool_time::now_to_ms(); uint64_t work_time=m_mine_tool->get_work_time(); uint64_t lost_time=_now>m_time?_now-m_time:m_time-_now; if(m_thour != h && (work_time > static_cast(person::m_limit_detained_time*60*60*1000)) && lost_time>2*60*60*1000) { m_thour=h; auto start = m_mine_tool->m_attendance_start_time; std::string enter_time=tool_time::to_str(start); uint32_t min=work_time/1000/60; uint32_t lmin=lost_time/1000/60; double dist=p.dist(*this); std::string last_time=tool_time::to_str_ex(m_time); std::string alarm_time{"No Alarm."}; auto event_power=event_list::instance()->get_event_card(m_id,m_type,ET_CARD_LOW_POWER_SERIOUS); if(event_power) alarm_time=tool_time::to_str(event_power->m_cur_time); log_warn("[card_detained]卡号:%03d%010d,分站:%d,入井时间点:%s,入井时长:%d小时%d分钟,(%.2f,%.2f)是否在处在井底范围内:%s,最后接收时间点:%s,进入盲区时长:%d小时%d分钟,是否低电量告警:%s,低电量开始时间点:%s", m_type,m_id,m_area_tool->get_site_id(),enter_time.c_str(),min/60,min%60,x,y,dist static_cast(person::m_auto_up_mine_time*60*60*1000)) inc_upmine_flag(); } } point person::getSmoothPoint(uint64_t& t) { point pt; loc_point lp = m_smo_tool->smooth_strategy(); m_speed = lp.m_speed; m_stat = lp.m_stat; pt.x = lp.x; pt.y = -lp.y; t=lp.m_time; if(auto p = m_monkeyPerson.lock() ) { if(p->is_on_bus()) { m_stat = 7; pt = p->getPoint(t); log_info("getpoint_oncar:%d,%lld",m_id,t); } } return pt; } void person::get_card(bool f) { if(!m_mine_tool->m_is_attendance) return; mine_business::inst()->fetch_add(m_display); }