area.cpp 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748
  1. #include <memory>
  2. #include <write-copy.h>
  3. #include "db_api/CDBSingletonDefine.h"
  4. #include "log.h"
  5. #include <area.h>
  6. #include "worker.h"
  7. #include "point.h"
  8. #include "tool_time.h"
  9. #include "common_tool.h"
  10. #include "db_tool.h"
  11. #include "monkey_car/monkeycar_area.h"
  12. #include "landmark.h"
  13. #include "area_business.h"
  14. #include <boost/algorithm/string/split.hpp>
  15. #include <boost/algorithm/string/classification.hpp>
  16. #include "area_business.h"
  17. #include "card.h"
  18. #include "tool_time.h"
  19. #include "common_tool.h"
  20. #include "websocket/ws_common.h"
  21. #include "websocket/wsClientMgr.h"
  22. #include "ant.h"
  23. #include "event.h"
  24. //template<> std::shared_ptr<area_list> single_base<area_list, int, std::shared_ptr<area>>::m_instance=std::make_shared<area_list>();
  25. struct underground_area:area
  26. {
  27. underground_area(int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t biz_type)
  28. :area(id,limit_count_person,limit_time_person,scale,mapid,biz_type)
  29. {
  30. }
  31. virtual bool in_area(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>&c, const point & p,int &sarid)
  32. {
  33. return s&&!s->is_up_site();
  34. }
  35. };
  36. struct special_area:area
  37. {
  38. special_area(int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t biz_type)
  39. :area(id,limit_count_person,limit_time_person,scale,mapid,biz_type)
  40. {}
  41. virtual bool in_area(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>&c, const point & p,int &sarid)
  42. {
  43. bool f=false;
  44. int id = c->get_area();
  45. if(id == m_id)
  46. {
  47. f=true;
  48. sarid=m_id;
  49. }
  50. return f;
  51. }
  52. //推入特殊区域的是否需要其他信息
  53. virtual void on_enter(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c)
  54. {
  55. area::on_enter(a, c);
  56. YA::_CARD_POS_ cp;
  57. cp.area_id = m_id;
  58. swsClientMgr.SendSpecialAreaProcess(cp);
  59. }
  60. };
  61. area::area(int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t b_type)
  62. :m_id(id)
  63. ,m_biz_type(b_type)
  64. ,m_limit_person_min(limit_time_person)
  65. ,m_limit_person_count(limit_count_person)
  66. ,m_event_person_count(false)
  67. ,m_event_person_show_count(false)
  68. ,m_event_vehicle_count(false)
  69. ,m_event_vehicle_show_count(false)
  70. ,m_mapid(mapid)
  71. ,m_scale(scale)
  72. ,m_person_count(0)
  73. ,m_vehicle_count(0)
  74. ,m_person_show_count(0)
  75. ,m_vehicle_show_count(0)
  76. ,m_frozen_count(0)
  77. ,m_is_work_area(0)
  78. {
  79. m_area_business_list=area_business::get_instance_list(m_biz_type,id);
  80. }
  81. void area::clear()
  82. {
  83. EVENT_TYPE ev = is_mine()?EVENT_TYPE::ET_OVER_COUNT_PERSON : EVENT_TYPE::ET_AREA_OVER_COUNT_PERSON ;
  84. EVENT_TYPE ev_ = is_mine()?EVENT_TYPE::ET_OVER_COUNT_VEHICLE : EVENT_TYPE::ET_AREA_OVER_COUNT_VEHICLE ;
  85. if(m_event_person_count)
  86. event_tool::instance()->handle_event(OT_AREA,ev,m_id,m_limit_person_count,0,false,DT_NORMAL);
  87. if(m_event_person_show_count)
  88. event_tool::instance()->handle_event(OT_AREA,ev,m_id,m_limit_person_count,0,false,DT_SPECIAL);
  89. if(m_event_vehicle_count)
  90. event_tool::instance()->handle_event(OT_AREA,ev_,m_id,m_limit_vehicle_count,0,false,DT_NORMAL);
  91. if(m_event_vehicle_show_count)
  92. event_tool::instance()->handle_event(OT_AREA,ev_,m_id,m_limit_vehicle_count,0,false,DT_SPECIAL);
  93. }
  94. void area::change_business(uint32_t new_bits)
  95. {
  96. worker*w=worker::instance();
  97. uint32_t del=((m_biz_type^new_bits)|m_biz_type)^m_biz_type;
  98. uint32_t add=((m_biz_type^new_bits)|new_bits)^new_bits;
  99. log_info("change_area_business:area_id:%d,b_type:%d,area_type:%d [del:%d, add:%d]",m_id,new_bits,m_biz_type,del,add);
  100. if(del==0 && add==0)
  101. return;
  102. task*t =task::alloc<message_change_business>();
  103. t->m_cmd_code=0x10001; //区域业务类型修改的编码
  104. t->m_hash_id=0; //这个不用
  105. auto&mcb=t->body<message_change_business>();
  106. mcb.area_id=m_id;
  107. if(del!=0)
  108. {
  109. mcb.del_list=area_business::get_instance_list(del,m_id);
  110. }
  111. if(add!=0)
  112. {
  113. mcb.add_list=area_business::get_instance_list(add,m_id);
  114. }
  115. mcb.new_list=area_business::get_instance_list(new_bits,m_id);
  116. mcb.ref_count.store(w->num_thread());
  117. add_frozen_count(w->num_thread()+1);
  118. this->m_biz_type=new_bits;
  119. w->broadcast(t);
  120. }
  121. void area::on_hover(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c)
  122. {
  123. a->m_last_time=tool_time::now_to_ms();
  124. a->m_last_point=*c;
  125. for(const auto &i:m_area_business_list)
  126. {
  127. auto &x=a->get_business_data(i->area_business_type());
  128. i->on_hover(a,c,x);
  129. }
  130. }
  131. void area::on_enter(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c)
  132. {
  133. log_info("on_enter..%d areaId:%d",c->m_id,m_id);
  134. a->m_enter_time=tool_time::now_to_ms();
  135. a->m_enter_point=*c;
  136. for(const auto &i:m_area_business_list)
  137. {
  138. auto &x=a->get_business_data(i->area_business_type());
  139. i->on_enter(a,c,x);
  140. }
  141. }
  142. void area::on_load_his(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c)
  143. {
  144. log_info("on_load_his..%d areaId:%d",c->m_id,m_id);
  145. //a->m_last_time=tool_time::now_to_ms();
  146. a->m_last_point=*c;
  147. for(const auto &i:m_area_business_list)
  148. {
  149. auto &x=a->get_business_data(i->area_business_type());
  150. i->on_load_his(a,c,x);
  151. }
  152. }
  153. void area::on_leave(const std::shared_ptr<area_hover>&a,const std::shared_ptr<card_location_base>&c)
  154. {
  155. log_info("on_leave..%d areaId:%d",c->m_id,m_id);
  156. a->m_last_time=tool_time::now_to_ms();
  157. a->m_last_point=*c;
  158. for(const auto &i:m_area_business_list)
  159. {
  160. auto &x=a->get_business_data(i->area_business_type());
  161. i->on_leave(a,c,x);
  162. }
  163. }
  164. bool area::in_area(const std::shared_ptr<site>&s,const std::shared_ptr<card_location_base>&c, const point & p,int & sarid)
  165. {
  166. #ifdef SITE_AREA
  167. return false;
  168. #endif
  169. if(m_bound.empty())
  170. return false;
  171. int counter = 0;
  172. double xinters;
  173. point p1,p2;
  174. p1 = m_bound[0];
  175. int size = m_bound.size();
  176. for (int i=1;i<= size;i++) {
  177. p2 = m_bound[i%size];
  178. if (p.y > std::min(p1.y,p2.y)) {
  179. if (p.y <= std::max(p1.y,p2.y)) {
  180. if (p.x <= std::max(p1.x,p2.x)) {
  181. if (p1.y != p2.y) {
  182. xinters = (p.y-p1.y)*(p2.x-p1.x)/(p2.y-p1.y)+p1.x;
  183. if (p1.x == p2.x || p.x <= xinters)
  184. counter++;
  185. }
  186. }
  187. }
  188. }
  189. p1 = p2;
  190. }
  191. return (counter % 2 == 0) ? false : true;
  192. }
  193. area_list::area_list()
  194. {
  195. }
  196. void area_list::init_monkeycar_area(int id)
  197. {
  198. std::string sql = "SELECT a.area_id, a.name, a.map_id, a.area_type_id, a.path, c.scale,\
  199. over_count_person, over_count_vehicle, over_time_person, over_time_vehicle,\
  200. over_speed_vehicle, is_attendance ,b.monkeycar_coordinate,b.monkeycar_speed,a.business_type \
  201. FROM dat_area a ,dat_monkeycar_base_info b ,dat_map c\
  202. where a.area_id = b.monkeycar_base_info_id and a.map_id = c.map_id";
  203. if(-1 == id)
  204. {
  205. sql.append(";");
  206. }
  207. else
  208. {
  209. sql.append(" AND a.area_id=");
  210. sql.append(std::to_string(id));
  211. sql.append(";");
  212. log_info("基础数据 monkeycar area 增加或修改区域 sql=%s", sql.c_str());
  213. }
  214. std::string Error;
  215. YADB::CDBResultSet DBRes;
  216. sDBConnPool.Query(sql.c_str(),DBRes,Error);
  217. int nCount = DBRes.GetRecordCount( Error );
  218. if (nCount < 1)
  219. {
  220. log_error("基础数据 monkeycar area 增加或修改失败,数据库中找不到: area_id=%d", id);
  221. return ;
  222. }
  223. std::unordered_map<int,std::shared_ptr<area>> map;
  224. while ( DBRes.GetNextRecod(Error) )
  225. {
  226. int area_id = 0;
  227. DBRes.GetField( "area_id",area_id, Error );
  228. int map_id = 0;
  229. DBRes.GetField( "map_id",map_id, Error );
  230. unsigned int area_type_id = 0;
  231. DBRes.GetField( "area_type_id",area_type_id, Error );
  232. int over_count_person = 0;
  233. DBRes.GetField( "over_count_person",over_count_person, Error );
  234. int over_count_vehicle = 0;
  235. DBRes.GetField( "over_count_vehicle",over_count_vehicle, Error );
  236. int over_time_person = 0;
  237. DBRes.GetField( "over_time_person",over_time_person, Error );
  238. int over_time_vehicle = 0;
  239. DBRes.GetField( "over_time_vehicle",over_time_vehicle, Error );
  240. std::string path;
  241. DBRes.GetField( "path",path, Error );
  242. double monkeycar_speed = 0;
  243. DBRes.GetField( "monkeycar_speed",monkeycar_speed, Error );
  244. std::string monkeycar_coor;
  245. DBRes.GetField( "monkeycar_coordinate",monkeycar_coor, Error );
  246. double scale=0;
  247. DBRes.GetField( "scale",scale, Error );
  248. uint32_t b_type =0;
  249. DBRes.GetField( "business_type",b_type, Error );
  250. log_info("monkeycar area init_area : id:%d,path:%s",area_id, path.c_str());
  251. if(-1 == id)
  252. {
  253. std::shared_ptr<db_area> da = std::make_shared<db_area>();
  254. da->m_default_speed = monkeycar_speed;
  255. da->m_point = init_path(monkeycar_coor,area_id);
  256. std::shared_ptr<area> ap = std::make_shared<monkey_area>(da,area_id,over_count_person, over_time_person,scale,map_id,b_type);
  257. ap->update(over_count_person, over_time_person,scale,map_id,over_count_vehicle,over_time_vehicle);
  258. ap->m_bound=init_path(path,area_id);
  259. for(const auto &p : ap->m_bound)
  260. log_info("point:monkey:area_id:%d--x:%.2f,y:%.2f",area_id,p.x,p.y);
  261. for(const auto &p : da->m_point)
  262. log_info("point:monkey_coor:area_id:%d--x:%.2f,y:%.2f",area_id,p.x,p.y);
  263. map.insert({area_id,ap});
  264. }
  265. else
  266. {
  267. auto tmp_ptr = area_list::instance()->get(id);
  268. bool newobj=false;
  269. if(!tmp_ptr)
  270. {
  271. std::shared_ptr<db_area> da = std::make_shared<db_area>();
  272. da->m_default_speed = monkeycar_speed;
  273. da->m_point = init_path(monkeycar_coor,area_id);
  274. tmp_ptr=std::make_shared<monkey_area>(da,area_id,over_count_person, over_time_person,scale,map_id,b_type);
  275. newobj=true;
  276. }
  277. tmp_ptr->m_bound=init_path(path,area_id);
  278. tmp_ptr->update(over_count_person, over_time_person,scale,map_id, over_count_vehicle,over_time_vehicle);
  279. if(newobj)
  280. {
  281. area_list::instance()->add(id, tmp_ptr);
  282. }
  283. else
  284. {
  285. tmp_ptr->change_business(b_type);
  286. }
  287. log_info("基础数据 monkeycar area增加或修改区域成功:区域id:%d,over_count_person:%d over_time_person:%d,\
  288. scale:%.2f,map_id:%d,area_type_id:%d,over_count_vehicle:%d,over_time_vehicle:%d",
  289. id,over_count_person, over_time_person,scale,map_id,area_type_id,
  290. over_count_vehicle,over_time_vehicle);
  291. }
  292. }
  293. if(-1 == id)
  294. {
  295. log_info( "monkeycar area init_area. The record count=%d\n", nCount );
  296. area_list::instance()->add(map);
  297. }
  298. }
  299. std::shared_ptr<area> area_list::create(int type,int id,int limit_count_person, int limit_time_person,double scale,int32_t mapid,int32_t b_type)
  300. {
  301. if(type==AREA_TYPE_FORBIDDEN)
  302. {
  303. return std::make_shared<special_area>(id,limit_count_person,limit_time_person,scale,mapid,b_type);
  304. }
  305. else if(type == AREA_TYPE_DOWNMINE)
  306. {
  307. return std::make_shared<underground_area>(id,limit_count_person,limit_time_person,scale,mapid,b_type);
  308. }
  309. else
  310. {
  311. return std::make_shared<area>(id,limit_count_person,limit_time_person,scale,mapid,b_type);
  312. }
  313. }
  314. void area_list::init_from_db(int id/*=-1*/)
  315. {
  316. do{
  317. std::string sql = "SELECT a.area_id, a.name, a.map_id, a.area_type_id, a.path,b.scale, \
  318. over_count_person, over_count_vehicle, over_time_person, over_time_vehicle, \
  319. over_speed_vehicle, is_attendance,business_type, a.is_work_area\
  320. FROM dat_area a,dat_map b\
  321. where a.map_id = b.map_id and area_id not in \
  322. (select monkeycar_base_info_id from dat_monkeycar_base_info)";
  323. if(-1 == id)
  324. {
  325. sql.append(";");
  326. }
  327. else
  328. {
  329. sql.append(" AND a.area_id=");
  330. sql.append(std::to_string(id));
  331. sql.append(";");
  332. log_info("基础数据 增加或修改区域 sql=%s", sql.c_str());
  333. }
  334. std::string Error;
  335. YADB::CDBResultSet DBRes;
  336. sDBConnPool.Query(sql.c_str(),DBRes,Error);
  337. int nCount = DBRes.GetRecordCount( Error );
  338. if (nCount < 1)
  339. {
  340. log_error("基础数据 增加或修改失败,数据库中找不到: area_id=%d:%s", id,sql.c_str());
  341. break;
  342. }
  343. std::unordered_map<int,std::shared_ptr<area>> map;
  344. while ( DBRes.GetNextRecod(Error) )
  345. {
  346. int area_id = 0;
  347. DBRes.GetField( "area_id",area_id, Error );
  348. int map_id = 0;
  349. DBRes.GetField( "map_id",map_id, Error );
  350. unsigned int area_type_id = 0;
  351. DBRes.GetField( "area_type_id",area_type_id, Error );
  352. int over_count_person = 0;
  353. DBRes.GetField( "over_count_person",over_count_person, Error );
  354. int over_count_vehicle = 0;
  355. DBRes.GetField( "over_count_vehicle",over_count_vehicle, Error );
  356. int over_time_person = 0;
  357. DBRes.GetField( "over_time_person",over_time_person, Error );
  358. int over_time_vehicle = 0;
  359. DBRes.GetField( "over_time_vehicle",over_time_vehicle, Error );
  360. std::string over_speed_vehicle;
  361. DBRes.GetField( "over_speed_vehicle",over_speed_vehicle, Error );
  362. std::string path;
  363. DBRes.GetField( "path",path, Error );
  364. double scale = 0;
  365. DBRes.GetField( "scale",scale, Error );
  366. uint32_t b_type =0;
  367. DBRes.GetField( "business_type",b_type, Error );
  368. int is_work_area = 0;
  369. DBRes.GetField( "is_work_area",is_work_area, Error );
  370. log_info("init_area : id:%d,path:%s..speed:%s",area_id, path.c_str(),over_speed_vehicle.c_str());
  371. std::map<int,double> map_;
  372. auto vp=init_path(over_speed_vehicle,area_id);
  373. for(const auto &v:vp)
  374. map_.insert({v.x,v.y});
  375. if(-1 == id)
  376. {
  377. std::shared_ptr<area> ap = create(area_type_id,area_id,over_count_person,over_time_person, scale,map_id,b_type);
  378. ap->m_limit_vehicle_min = over_time_vehicle;
  379. ap->m_limit_vehicle_count = over_count_vehicle;
  380. ap->m_speed=std::move(map_);
  381. ap->m_is_work_area = is_work_area;
  382. ap->m_bound=init_path(path,area_id);
  383. for(const auto &p : ap->m_bound)
  384. log_info("point:area_id:%d--x:%.2f,y:%.2f",area_id,p.x,p.y);
  385. map.insert({area_id,ap});
  386. }
  387. else
  388. {
  389. auto tmp_ptr = area_list::instance()->get(id);
  390. bool newobj=false;
  391. if(!tmp_ptr)
  392. {
  393. tmp_ptr = create(area_type_id,area_id,over_count_person,over_time_person, scale,map_id,b_type);
  394. newobj=true;
  395. }
  396. tmp_ptr->update(over_count_person, over_time_person,scale,map_id, over_count_vehicle,over_time_vehicle);
  397. tmp_ptr->m_speed=std::move(map_);
  398. tmp_ptr->m_bound=init_path(path,area_id);
  399. tmp_ptr->m_is_work_area = is_work_area;
  400. for(const auto &p : tmp_ptr->m_bound)
  401. log_info("point:area_id:%d--x:%.2f,y:%.2f",area_id,p.x,p.y);
  402. log_info("基础数据 增加或修改区域成功:区域id:%d,over_count_person:%d over_time_person:%d,scale:%.2f,map_id:%d\
  403. ,area_type_id:%d,over_count_vehicle:%d,over_time_vehicle:%d",
  404. id,over_count_person, over_time_person,scale,map_id,area_type_id,
  405. over_count_vehicle,over_time_vehicle);
  406. if(newobj)
  407. {
  408. area_list::instance()->add(id, tmp_ptr);
  409. }
  410. else
  411. {
  412. tmp_ptr->change_business(b_type);
  413. }
  414. }
  415. }
  416. if(-1 == id)
  417. {
  418. log_info( "init_area. The record count=%d\n", nCount );
  419. area_list::instance()->add(map);
  420. }
  421. }while(0);
  422. init_monkeycar_area(id);
  423. }
  424. std::vector<point> area_list::init_path(std::string &str_0,int area_id)
  425. {
  426. const std::string str=str_0;
  427. if(str.empty())
  428. {
  429. log_error("area path is empty,area_id=%d.",area_id);
  430. }
  431. std::vector<point> vp;
  432. std::vector<std::string> vs;
  433. std::vector<std::string> vs1;
  434. boost::split(vs,str,boost::is_any_of("ML ;"));
  435. for(auto & s:vs)
  436. {
  437. if(s.empty())
  438. continue;
  439. boost::split(vs1,s,boost::is_any_of(","));
  440. if(vs1.size()!=2)
  441. {
  442. log_error("area path data Error.pls check data table,area_id=%d",area_id);
  443. continue;
  444. }
  445. vp.emplace_back(atof(vs1[0].c_str()),atof(vs1[1].c_str()));
  446. }
  447. return std::move(vp);
  448. }
  449. std::vector<std::shared_ptr<area>> area_list::get_area(const std::shared_ptr<site>& s,const std::shared_ptr<card_location_base> &c,const point&pt,int & sarid)
  450. {
  451. std::vector<std::shared_ptr<area>> ret;
  452. if(tool_other::is_person(c->type_())&&s&&s->is_up_site())
  453. return std::move(ret);
  454. auto map = area_list::instance()->m_map;
  455. for(const auto &a:map)
  456. if(a.second->in_area(s,c,pt,sarid))
  457. ret.push_back(a.second);
  458. if(s){
  459. ret.push_back(s->get_area());
  460. #ifdef SITE_AREA
  461. int area_id=s->m_area_id;
  462. if(auto area_=area_list::instance()->get(area_id))
  463. ret.push_back(area_);
  464. #endif
  465. }
  466. //区域覆盖不完全地图,很多车辆人行驶在地图外,如何确认.
  467. return std::move(ret);
  468. }
  469. area_hover::area_hover(const std::shared_ptr<area>&area,const point&pt)
  470. :m_area(area)
  471. {
  472. m_enter_time=m_last_time=tool_time::now_to_ms();
  473. m_enter_point=m_last_point=pt;
  474. }
  475. void area_tool::on_point(const std::shared_ptr<card_location_base>& c,const point&pt)
  476. {
  477. log_info("on_point...cardid:%d,type:%d,x:%.2f,y:%.2f",c->m_id,c->m_type,pt.x,pt.y);
  478. if(pt.empty()) return;
  479. int special_area=-1;
  480. std::vector<std::shared_ptr<area>> areas=area_list::instance()->get_area(m_site,c, pt,special_area);
  481. if(special_area != -1)
  482. {
  483. areas.clear();
  484. auto area_=area_list::instance()->get(special_area);
  485. areas.push_back(area_);
  486. }
  487. else
  488. {
  489. std::sort(areas.begin(),areas.end(),[](const std::shared_ptr<area>&l,const std::shared_ptr<area>&r){
  490. return l->id()<r->id();
  491. });
  492. }
  493. auto c1=m_hover_list.begin(),ce=m_hover_list.end();
  494. auto a1=areas.begin() ,ae=areas.end();
  495. std::vector<std::shared_ptr<area_hover>> nlist;
  496. while (c1!=ce && a1!=ae)
  497. {
  498. if ((*c1)->id()<(*a1)->id()) //离开区域
  499. {
  500. if((*c1)->m_area->get_frozen_count()==0)//如果该区域未在修改中,调用on_leave
  501. {
  502. (*c1)->m_area->on_leave(*c1, c);
  503. }
  504. else//否则,该区域持续保存在卡的区域列表,等待修改完成
  505. {
  506. nlist.push_back(*c1);
  507. log_warn("丢弃离开区域事件,cardid=%d,area_id=%d",c->m_id,(*c1)->id());
  508. }
  509. ++c1;
  510. }
  511. else if ((*a1)->id()<(*c1)->id()) //进入新区域
  512. {
  513. if((*a1)->get_frozen_count()==0)////如果该区域未在修改中,执行正常逻辑
  514. {
  515. nlist.push_back(std::make_shared<area_hover>(*a1,pt));
  516. (*a1)->on_enter(nlist.back(),c);
  517. }
  518. else//丢弃本次进入的点,等待修改完成
  519. {
  520. log_warn("丢弃进入区域事件,cardid=%d,area_id=%d",c->m_id,(*a1)->id());
  521. }
  522. ++a1;
  523. }
  524. else //需要持续的区域
  525. {
  526. nlist.push_back(*c1);
  527. if((*c1)->m_area->get_frozen_count()==0)//正常情况
  528. {
  529. (*c1)->m_area->on_hover(*c1,c);
  530. }
  531. else//丢弃本次on_hover时间
  532. {
  533. log_warn("丢弃区域行走事件,cardid=%d,area_id=%d",c->m_id,(*c1)->id());
  534. }
  535. ++c1,++a1;
  536. }
  537. }
  538. while(c1!=ce)
  539. {
  540. if((*c1)->m_area->get_frozen_count()==0)
  541. {
  542. (*c1)->m_area->on_leave(*c1, c);
  543. }
  544. else
  545. {
  546. log_warn("丢弃离开区域事件,cardid=%d,area_id=%d",c->m_id,(*c1)->id());
  547. }
  548. ++c1;
  549. }
  550. while(a1!=ae)
  551. {
  552. if((*a1)->get_frozen_count()==0)
  553. {
  554. nlist.push_back(std::make_shared<area_hover>(*a1,pt));
  555. (*a1)->on_enter(nlist.back(),c);
  556. }
  557. else
  558. {
  559. log_warn("丢弃进入区域事件,cardid=%d,area_id=%d",c->m_id,(*a1)->id());
  560. }
  561. ++a1;
  562. }
  563. m_hover_list=std::move(nlist);
  564. //更新到数据库
  565. if(m_site && !m_hover_list.empty())
  566. {
  567. std::string strAreaInfo = "";
  568. for (std::vector<std::shared_ptr<area_hover>>::iterator itvec = m_hover_list.begin(); itvec != m_hover_list.end(); ++itvec)
  569. {
  570. if ((*itvec)->id() >= 0)
  571. {
  572. char tmpArea[128] = {0};
  573. snprintf(tmpArea, 128, "%d,%lu|", (*itvec)->id(), (*itvec)->m_enter_time);
  574. strAreaInfo += tmpArea;
  575. }
  576. }
  577. char sql[1024] = {0};
  578. std::string _time=tool_time::to_str_ex(c->time_());
  579. snprintf(sql, 1024, "REPLACE INTO rt_location (card_id, site_id,cur_time, x, y, z, state, area_info) VALUES (%s, %d,'%s',%lf, %lf, %lf, 0, '%s');",
  580. tool_other::type_id_to_str(c->m_type, c->m_id).c_str(), m_site->id(),_time.c_str(), pt.x, pt.y, pt.z, strAreaInfo.c_str());
  581. db_tool::PushAsync(sql);
  582. }
  583. }
  584. void area_tool::on_leave(const std::shared_ptr<card_location_base>& c)
  585. {
  586. for(const auto& t:m_hover_list)
  587. {
  588. t->m_area->on_leave(t, c);
  589. }
  590. }
  591. void area_tool::set_area_info(int mapid,double scale,int areaid,const point &pt,uint64_t t,int type)
  592. {
  593. if(0==type)
  594. {
  595. m_mapid = mapid;
  596. m_scale=scale;
  597. set_area_info(mapid,areaid,pt,t);
  598. }
  599. else if(1==type)
  600. {
  601. if(m_mapid != mapid || m_scale!=scale){
  602. m_mapid=mapid;m_scale=scale;
  603. }
  604. set_area_info(mapid,areaid,pt,t);
  605. }
  606. else if(2==type)
  607. {
  608. auto it =m_area_info.find(areaid);
  609. if(it != m_area_info.end())
  610. m_area_info.erase(it);
  611. }
  612. else
  613. {
  614. log_info("wrong type..");
  615. }
  616. }
  617. void area_tool::set_area_info(int mapid,int areaid,const point &pt,uint64_t t)
  618. {
  619. auto lm = Landmark_list::instance()->get(mapid,areaid,pt);
  620. int landmark_id = std::get<0>(lm);
  621. int landmark_dir = std::get<1>(lm);
  622. double landmark_dis = std::get<2>(lm)*m_scale;
  623. std::tuple<int,int,int,double,uint64_t> tinfo=std::make_tuple(areaid,landmark_id,landmark_dir,landmark_dis,t);
  624. m_area_info[areaid].swap(tinfo);
  625. }
  626. void area_tool::on_change_business(const std::shared_ptr<card_location_base>& c, const task&t)
  627. {
  628. auto&mcb=t.body<message_change_business>();
  629. auto i=std::lower_bound(m_hover_list.begin(),m_hover_list.end(),mcb.area_id ,[&mcb](std::shared_ptr<area_hover>&ah,int id){
  630. return ah->m_area->m_id<id;
  631. });
  632. if(i==m_hover_list.end())
  633. return ;
  634. if((*i)->m_area->m_id!=mcb.area_id)
  635. return;
  636. log_info("调用调整的区域业务,card_id=%d,area_id=%d", c->m_id, mcb.area_id);
  637. for(auto&biz:mcb.add_list)
  638. {
  639. biz->on_enter(*i,c,(*i)->get_business_data(biz->area_business_type()));
  640. }
  641. for(auto&biz:mcb.del_list)
  642. {
  643. biz->on_leave(*i,c,(*i)->get_business_data(biz->area_business_type()));
  644. }
  645. }