123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912 |
- #include "module_call.h"
- #include <boost/bind.hpp>
- #include <boost/algorithm/string.hpp>
- #include <vector>
- #include <set>
- #include <string>
- #include <chrono>
- #include <algorithm>
- #include <area.h>
- #include "common_tool.h"
- #include "tool_time.h"
- #include "ant.h"
- #include "websocket/constdef.h"
- #include "websocket/wsClientMgr.h"
- #include "crc.h"
- #include "mine.h"
- #include "event.h"
- uint64_t call_card::to_id64()
- {
- return tool_other::type_id_to_u64(cardtype, cardid);
- }
- std::string call_card::to_id64_str()
- {
- return tool_other::type_id_to_str(cardtype, cardid);
- }
- bool call_card::is_timeout()
- {
- uint32_t seconds = tool_time::elapse_seconds(call_time);
- return (seconds >= call_time_out*60);
- }
- bool module_call::call_user::is_timeout()
- {
- uint32_t seconds = tool_time::elapse_seconds(call_time);
- return (seconds >= call_time_out*60);
- }
- void module_call::to_node_element(rapidjson::Value& out_elemet,
- const std::shared_ptr<call_card> card_ptr,
- rapidjson::Document::AllocatorType& allocator,bool f)
- {
- tool_json::push_back(out_elemet, card_ptr->user_name, allocator);
- tool_json::push_back(out_elemet, card_ptr->to_id64_str(), allocator);
- uint32_t sid= card_ptr->stationid;
- if(f)sid=0;
- out_elemet.PushBack(sid, allocator);
- out_elemet.PushBack(tool_time::to_ms(card_ptr->call_time), allocator);
- out_elemet.PushBack(card_ptr->call_type_id, allocator);
- out_elemet.PushBack(card_ptr->call_state, allocator);
- }
- void module_call::run()
- {
- std::vector<call_card_ptr> arr;
- get_all_call_cards(arr);
- if(arr.empty())
- {
- return ;
- }
-
-
-
-
-
- call_site_map site_map;
- get_site_map(arr, site_map);
- if(!site_map.empty())
- {
- send_to_sites(site_map);
- }
- }
- void module_call::send_to_sites(call_site_map& site_map)
- {
- auto iter_site = site_map.begin();
- for(; iter_site != site_map.end(); ++iter_site)
- {
- if(iter_site->second->cards.size() > 254)
- {
- log_error("呼叫:分站下卡数量过多:分站id=%d, 卡数=%d",
- iter_site->first, iter_site->second->cards.size());
- continue;
- }
- std::vector<char> arr;
- int16_t cmd = 0x77ab;
- arr.push_back(cmd>>8 & 0xff);
- arr.push_back(cmd & 0xff);
-
-
- uint32_t anchor_id = (iter_site->second->is_call_all()? 0xffffffff : static_cast<uint32_t>(iter_site->first));
- memcpy_uint32(arr,anchor_id);
-
- arr.push_back(static_cast<char>(iter_site->second->cards.size()));
-
- arr.push_back(static_cast<char>(iter_site->second->call_type_id));
- if(!iter_site->second->is_call_all())
- {
-
- auto it_card = iter_site->second->cards.begin();
- for(; it_card != iter_site->second->cards.end(); ++it_card)
- {
-
- arr.push_back(static_cast<char>(it_card->second->call_level_id));
-
- arr.push_back(static_cast<char>(it_card->second->cardtype));
-
- int id_len = 4;
- arr.push_back(static_cast<char>(id_len));
-
- memcpy_uint32(arr, it_card->second->cardid);
- }
- }
- auto sit_ptr = sit_list::instance()->get(iter_site->first);
- if(!sit_ptr || !sit_ptr->m_clt)
- {
- log_error("在全局分站列表中找不到分站 或者sit_ptr->m_clt==null:分站id=%d", iter_site->first);
- continue;
- }
- int16_t len=arr.size()+2;
- int16_t crc=do_crc_1(arr,0);
- auto it= arr.begin();arr.insert(it,len&0xff);
- it= arr.begin();arr.insert(it,len>>8&0xff);
- arr.push_back(crc>>8&0xff);arr.push_back(crc&0xff);
- std::vector<char> arr2 = arr;
- sit_ptr->m_clt->send(std::move(arr));
- print_test(std::move(arr2), iter_site->first);
- }
- }
- void module_call::print_test(std::vector<char>&& arr, int siteid)
- {
- std::string str("呼叫发送的数据帧,分站号=");
- str.append(std::to_string(siteid));
- str.append(":");
- char a[4]={0};
- for(std::vector<char>::size_type i=0; i<arr.size(); i++)
- {
- sprintf(a, "%02X ", static_cast<unsigned char>(arr[i]));
- str.append(std::string(a));
- }
- log_info("%s", str.c_str());
- }
- void module_call::rev_from_card_resp(std::shared_ptr<card_location_base> card_ptr)
- {
- card_ptr->get_mine_tool()->m_status_call = CALL_SUCCESSED;
- }
- void module_call::accept_call(sio::message::ptr const& data)
- {
- int call_type = -1, call_level = 1, call_time_interval = -1;
- uint32_t call_time_out = 0;
- std::string user_name = "";
- call_time_interval = 5;
- if(!tool_map::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, data)
- || !tool_map::try_get_value(call_level, JSON_KEY_CALL_CARD_CALL_LEVEL, data)
- || !tool_map::try_get_value(call_time_out, JSON_KEY_CALL_CARD_CALL_TIME_OUT, data)
-
- || !tool_map::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, data)
- )
- {
- log_error("发起呼叫: 收到的json不对,解析不出call_type = %d, call_level = %d, \
- call_time_out=%d, call_time_interval=%d,user_name=%s", call_type, call_level, call_time_out, call_time_interval, user_name.c_str());
- return;
- }
- if(user_name.empty())
- {
- log_error("发起呼叫: user_name用户名为空");
- return;
- }
- std::vector<call_card_ptr> result_arr;
- call_user_ptr user_ptr;
- if(CCT_CALL_ALL==call_type)
- {
- user_ptr = call_user_ptr(new call_user());
- user_ptr->call_time = std::chrono::system_clock::now();
- user_ptr->call_time_out = call_time_out;
- user_ptr->call_time_interval = call_time_interval;
- user_ptr->call_type_id = call_type;
- user_ptr->call_level_id = call_level;
- user_ptr->user_name = user_name;
- call_card_ptr temp(new call_card());
- copy(user_ptr, temp);
- temp->cardid = CCT_CALL_ALL;
- temp->call_state = CALL_ING;
- result_arr.push_back(temp);
-
- user_ptr->cards.insert(std::make_pair(temp->cardid, temp));
-
- std::lock_guard<std::mutex> lock(_mutex);
- _map[user_name]=user_ptr;
- }
- else
- {
- std::lock_guard<std::mutex> lock(_mutex);
- auto user_map_ptr = _map.find(user_name);
- if(_map.end() == user_map_ptr)
- {
- user_ptr=call_user_ptr(new call_user());
- _map[user_name]=user_ptr;
- }
- else
- {
- user_ptr=user_map_ptr->second;
-
- auto card_temp = user_ptr->cards.find(CCT_CALL_ALL);
- if(user_ptr->cards.end() != card_temp)
- {
- return;
- }
- }
-
- user_ptr->call_time=std::chrono::system_clock::now();
- user_ptr->call_time_out=call_time_out;
- user_ptr->call_time_interval = call_time_interval;
- user_ptr->call_type_id=call_type;
- user_ptr->call_level_id=call_level;
- user_ptr->user_name=user_name;
- std::vector<sio::message::ptr> card_vec;
- if(!tool_map::try_get_value(card_vec, JSON_KEY_CALL_CARD_CARDS, data) || card_vec.size() == 0)
- {
- log_error("发起呼叫,web发来的数据JSON_KEY_CALL_CARD_CARDS字段为空 或者不是数组");
- return;
- }
- add_cards_to_user(card_vec, user_ptr);
- for(auto& it:user_ptr->cards)
- {
- result_arr.push_back(it.second);
- }
- }
-
- if(!result_arr.empty())
- {
- response_accept_call(result_arr);
- }
- }
- void module_call::response_accept_call(std::vector<call_card_ptr> cards)
- {
- rapidjson::Document doc(rapidjson::kObjectType);
- auto& allocator = doc.GetAllocator();
- rapidjson::Value node_cards(rapidjson::kArrayType);
-
- to_node_array(node_cards, cards, allocator,false);
- doc.AddMember(JSON_ROOT_KEY_CMD,JSON_CMD_VALUE_CALL_CARD_RESPONSE, allocator);
- doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
- doc.AddMember(JSON_ROOT_KEY_DATA, node_cards, allocator);
- swsClientMgr.send(JSON_CMD_VALUE_PUSH, tool_json::doc_to_json(doc));
- }
- void module_call::accept_cancel(sio::message::ptr const& node_data)
- {
- int call_type = -1;
- std::string user_name;
- int64_t call_time = 0;
- if(!tool_map::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, node_data)
- || !tool_map::try_get_value(call_time, JSON_KEY_CALL_CARD_CALL_TIME, node_data)
- || !tool_map::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, node_data)
- )
- {
- log_error("取消呼叫: 收到的json不对,解析不出int call_type = %d, call_time = %d,user_name=%s", call_type, call_time, user_name.c_str());
- return;
- }
- if(user_name.empty())
- {
- log_error("取消呼叫: user_name用户名为空");
- return;
- }
- call_user_ptr result_user_ptr(new call_user());
- result_user_ptr->call_type_id=call_type;
-
- result_user_ptr->call_time = std::chrono::system_clock::time_point(std::chrono::milliseconds(call_time));
- result_user_ptr->user_name=user_name;
-
-
-
- if(CCT_CALL_ALL==call_type)
- {
-
- std::lock_guard<std::mutex> lock(_mutex);
- _map.erase(user_name);
- }
- else
- {
- std::vector<sio::message::ptr> card_vec;
- if(!tool_map::try_get_value(card_vec, JSON_KEY_CALL_CARD_CARDS, node_data) || card_vec.size() == 0)
- {
- log_error("取消呼叫: web发来的数据cards字段为空 或者不是数组");
- return;
- }
- std::lock_guard<std::mutex> lock(_mutex);
- call_user_ptr user_ptr(new call_user());
- auto it_map = _map.find(user_name);
- if(_map.end()!=it_map)
- {
- user_ptr=it_map->second;
- }
- std::vector<sio::message::ptr>::const_iterator it_card = card_vec.begin();
- std::string s_card_id;
- for(; it_card != card_vec.end(); ++it_card)
- {
- if(!tool_map::try_get_value(s_card_id, JSON_KEY_CALL_CARD_CARD_ID, (*it_card)))
- {
- log_error("取消呼叫: web发来的数据 card_id 格式不对");
- continue;
- }
- uint32_t id = tool_other::id64_to_id(s_card_id);
- int type= tool_other::id64_to_type(s_card_id);
- log_info("取消呼叫: cardid=%d, cardtype=%d", id, type);
- call_card_ptr card_ptr(new call_card());
- card_ptr->cardid = id;
- card_ptr->cardtype = type;
- result_user_ptr->cards[card_ptr->cardid]=card_ptr;
- user_ptr->cards.erase(card_ptr->cardid);
- }
-
- if(user_ptr->cards.empty())
- {
- _map.erase(user_name);
- }
- }
-
- if(result_user_ptr->cards.empty())
- {
-
-
- result_user_ptr->call_time_out=0;
- result_user_ptr->call_type_id=call_type;
- result_user_ptr->user_name=user_name;
- call_card_ptr card_ptr(new call_card());
- card_ptr->cardid=CCT_CALL_ALL;
- result_user_ptr->cards[card_ptr->cardid]=card_ptr;
- }
-
- response_accept_cancel(result_user_ptr);
- }
- void module_call::response_accept_cancel(const call_user_ptr user_ptr)
- {
- rapidjson::Document doc(rapidjson::kObjectType);
- auto& allocator = doc.GetAllocator();
- rapidjson::Value node_data(rapidjson::kObjectType);
- tool_json::add_member(node_data, JSON_KEY_CALL_CARD_USER_NAME, user_ptr->user_name, allocator);
- node_data.AddMember(JSON_KEY_CALL_CARD_CALL_TIME, tool_time::to_ms(user_ptr->call_time), allocator);
- node_data.AddMember(JSON_KEY_CALL_CARD_CALL_TYPE, user_ptr->call_type_id, allocator);
- rapidjson::Value node_cards(rapidjson::kArrayType);
-
- auto iter = user_ptr->cards.begin();
- for(;iter != user_ptr->cards.end();++iter)
- {
- rapidjson::Value node_card(rapidjson::kObjectType);
- tool_json::add_member(node_card, JSON_KEY_CALL_CARD_CARD_ID, iter->second->to_id64_str(), allocator);
- node_card.AddMember(JSON_KEY_CALL_CARD_CARD_TYPE_ID,iter->second->cardtype, allocator);
- node_cards.PushBack(node_card,allocator);
- }
- node_data.AddMember(JSON_KEY_CALL_CARD_CARDS, node_cards, allocator);
- doc.AddMember(JSON_ROOT_KEY_CMD, JSON_CMD_VALUE_CALL_CARD_CANCEL_RESPONSE, allocator);
- doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
- doc.AddMember(JSON_ROOT_KEY_DATA, node_data, allocator);
-
- swsClientMgr.send(JSON_CMD_VALUE_PUSH, tool_json::doc_to_json(doc));
- }
- std::string module_call::accept_login()
- {
- std::vector<call_card_ptr> arr;
- get_all_call_cards(arr);
- if(arr.empty())
- {
- return "";
- }
- return to_call_card_list_json(arr);
- }
- std::string module_call::to_call_card_list_json(std::vector<call_card_ptr> arr)
- {
- rapidjson::Document doc(rapidjson::kObjectType);
- auto& allocator = doc.GetAllocator();
- rapidjson::Value node_cards(rapidjson::kArrayType);
- to_node_array(node_cards, arr, allocator);
- doc.AddMember(JSON_ROOT_KEY_CMD, JSON_CMD_VALUE_CALL_CARD_LIST, allocator);
- doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
- doc.AddMember(JSON_ROOT_KEY_DATA, node_cards, allocator);
- return tool_json::doc_to_json(doc);
- }
- void module_call::add_cards_to_user(const std::vector<sio::message::ptr>& card_vec, call_user_ptr user_ptr)
- {
- std::vector<sio::message::ptr>::const_iterator it_card = card_vec.begin();
- for(; it_card != card_vec.end(); ++it_card)
- {
- std::string s_card_id;
- if(!tool_map::try_get_value(s_card_id, JSON_KEY_CALL_CARD_CARD_ID, (*it_card))
- ||s_card_id.empty())
- {
- log_error("发起呼叫,web发来的数据 card_id 格式不对 或为空");
- continue;
- }
- uint32_t id = tool_other::id64_to_id(s_card_id);
- int type= tool_other::id64_to_type(s_card_id);
- log_info("发起呼叫 cardid=%d, cardtype=%d", id, type);
- call_card_ptr card_ptr(new call_card());
- card_ptr->cardid = id;
- card_ptr->cardtype = type;
- copy(user_ptr, card_ptr);
- card_ptr->call_state = CALL_ING;
- user_ptr->cards[card_ptr->cardid]=card_ptr;
- }
- }
- void module_call::get_user_all_call_cards(call_user_ptr& user_ptr,
- const std::unordered_map<uint64_t,std::shared_ptr<card_location_base>>& cardlist,
- std::vector<call_card_ptr>& out_data)
- {
- auto& cards=user_ptr->cards;
- int status = CALL_ING;
-
- auto card_it = cards.find(CCT_CALL_ALL);
- if(cards.end()!=card_it)
- {
- if(user_ptr->is_timeout())
- {
- log_info("全员呼叫发送线程:呼叫用户超时,用户名=%s", user_ptr->user_name.c_str());
- cards.clear();
- status=CALL_END;
- }
- auto g_it=cardlist.begin();
- for(;g_it!=cardlist.end();++g_it)
- {
- auto site_ptr = g_it->second->get_area_tool()->m_site;
- if(!site_ptr)
- {
- continue;
- }
- call_card_ptr card_ptr(new call_card());
- copy(user_ptr, card_ptr);
- card_ptr->cardid = g_it->second->m_id;
- card_ptr->cardtype = g_it->second->m_type;
- card_ptr->stationid=site_ptr->id();
- card_ptr->call_state=status;
- if(CALL_SUCCESSED == g_it->second->get_mine_tool()->m_status_call)
- {
- card_ptr->call_state = CALL_SUCCESSED;
- }
- else
- {
- g_it->second->get_mine_tool()->m_status_call = CALL_ING;
- }
- if(card_ptr->is_timeout())
- {
- g_it->second->get_mine_tool()->m_status_call = 0;
- }
- card_ptr->is_display = g_it->second->m_display;
- out_data.push_back(card_ptr);
- }
- return;
- }
-
- auto iter_card = cards.begin();
- for(;iter_card!=cards.end();++iter_card)
- {
-
- out_data.push_back(iter_card->second);
- auto g_card = cardlist.find(iter_card->second->to_id64());
- if(cardlist.end()==g_card)
- {
- log_error("定员呼叫发送线程:全局卡列表中没有这张卡,卡id=%d,卡类型=%d",
- iter_card->second->cardid, iter_card->second->cardtype);
- iter_card->second->call_state = CALL_FAILED;
- cards.erase(iter_card--);
- continue;
- }
- auto site_ptr = g_card->second->get_area_tool()->m_site;
- if(!site_ptr)
- {
- log_error("定员呼叫发送线程:全局卡列表中这张卡已经上井或无效,卡id=%d,卡类型=%d",
- iter_card->second->cardid, iter_card->second->cardtype);
- iter_card->second->call_state = CALL_FAILED;
- cards.erase(iter_card--);
- continue;
- }
-
- iter_card->second->stationid = site_ptr->id();
- if(CALL_SUCCESSED == g_card->second->get_mine_tool()->m_status_call)
- {
- iter_card->second->call_state = CALL_SUCCESSED;
- }
- else
- {
- g_card->second->get_mine_tool()->m_status_call = CALL_ING;
- }
- if(iter_card->second->is_timeout())
- {
- log_info("定员呼叫发送线程:呼叫卡超时,用户名=%s,卡id=%d,卡类型=%d",
- iter_card->second->user_name.c_str(),
- iter_card->second->cardid, iter_card->second->cardtype);
- iter_card->second->call_state = CALL_END;
- if(CALL_SUCCESSED == g_card->second->get_mine_tool()->m_status_call)
- {
- iter_card->second->call_state = CALL_SUCCESSED;
- g_card->second->get_mine_tool()->m_status_call = 0;
- }
- cards.erase(iter_card--);
- }
- }
- }
- void module_call::system_call_apoint(int card_id,int card_type)
- {
- int call_type = -1, call_level = 1, call_time_interval=-1;
- uint32_t call_time_out = 0;
- std::string user_name = "system_apoint";
- std::vector<call_card_ptr> result_arr;
- call_user_ptr user_ptr;
- std::lock_guard<std::mutex> lock(_mutex);
- auto user_map_ptr = _map.find(user_name);
- if(_map.end() == user_map_ptr)
- {
- user_ptr=call_user_ptr(new call_user());
- _map[user_name]=user_ptr;
- }
- else
- {
- user_ptr=user_map_ptr->second;
- }
-
- user_ptr->call_time=std::chrono::system_clock::now();
- user_ptr->call_time_out=call_time_out;
- user_ptr->call_time_interval = call_time_interval;
- user_ptr->call_type_id=call_type;
- user_ptr->call_level_id=call_level;
- user_ptr->user_name=user_name;
- call_card_ptr c_card_ptr(new call_card());
- c_card_ptr->cardid = card_id;
- c_card_ptr->cardtype = card_type;
- copy(user_ptr, c_card_ptr);
- c_card_ptr->call_state = CALL_ING;
- user_ptr->cards[c_card_ptr->cardid]=c_card_ptr;
- for(auto& it:user_ptr->cards)
- {
- result_arr.push_back(it.second);
- }
- log_info("发起呼叫 cardid=%d, cardtype=%d", card_id,card_type);
-
- response_accept_call(result_arr);
- }
- void module_call::system_cancel_call_apoint(int card_id,int card_type)
- {
- int call_type = -1;
- std::string user_name = "system_apoint";
- int64_t call_time;
- call_user_ptr result_user_ptr(new call_user());
- result_user_ptr->call_type_id=call_type;
-
- result_user_ptr->call_time = std::chrono::system_clock::time_point(std::chrono::milliseconds(call_time));
- result_user_ptr->user_name=user_name;
- std::lock_guard<std::mutex> lock(_mutex);
- call_user_ptr user_ptr(new call_user());
- auto it_map = _map.find(user_name);
- if(_map.end()!=it_map)
- {
- user_ptr=it_map->second;
- }
- if (user_ptr->cards.find(card_id) == user_ptr->cards.end())
- {
- return ;
- }
- call_card_ptr c_card_ptr(new call_card());
- c_card_ptr->cardid = card_id;
- c_card_ptr->cardtype = card_type;
- result_user_ptr->cards[c_card_ptr->cardid]=c_card_ptr;
- user_ptr->cards.erase(c_card_ptr->cardid);
- log_info("取消呼叫: cardid=%d, cardtype=%d", card_id,card_type);
-
- if(user_ptr->cards.empty())
- {
- _map.erase(user_name);
- }
- response_accept_cancel(result_user_ptr);
- }
- void module_call::send_anti_collision(const std::map<int, call_card>& cards)
- {
- std::vector<call_card_ptr> vt_cards;
- std::string vmsg = "";
- std::string pmsg = "";
- for(auto c : cards){
- char buf[100] = {0};
- snprintf(buf, 100, "%d,", c.second.cardid);
- switch(c.second.cardtype){
- case 1:
- pmsg += std::string(buf);
- break;
- case 2:
- vmsg += std::string(buf);
- break;
- }
-
- vt_cards.push_back(std::make_shared<call_card>(c.second));
- }
- log_info("[anti_coll] vehicle's cid = %s, person's cid = %s", vmsg.c_str(), pmsg.c_str());
- call_site_map site_map;
- get_site_map(vt_cards, site_map);
-
- if(!site_map.empty()){
- send_to_sites(site_map);
- }
- }
- std::string module_call::get_json_anti_collision()
- {
- rapidjson::Document doc(rapidjson::kObjectType);
- rapidjson::Document::AllocatorType& allocator = doc.GetAllocator();
- doc.SetObject();
- rapidjson::Value data(rapidjson::kArrayType);
- auto tmp = event_list::instance()->m_map;
- for(auto it_ev = tmp.cbegin(); it_ev != tmp.cend(); ++it_ev)
- {
- if(ET_PERSON_VEHICLE_ANTI_COLLISION != it_ev->second->m_ev_type)
- {
- continue;
- }
-
- rapidjson::Value obj(rapidjson::kObjectType);
-
-
-
-
- rapidjson::Value val;
- obj.AddMember("vid", val.SetString(it_ev->second->m_obj_id.c_str(), allocator), allocator);
- rapidjson::Value elems(rapidjson::kArrayType);
- std::string msg = it_ev->second->m_desc;
- std::vector<std::string> vt_msg;
- boost::split(vt_msg, msg, boost::is_any_of(";"));
- for(auto it_elem : vt_msg){
- std::vector<std::string> vt_cid_d;
- boost::split(vt_cid_d, it_elem, boost::is_any_of(","));
- if(vt_cid_d.size()<2){
- continue;
- }
- rapidjson::Value e(rapidjson::kArrayType);
- rapidjson::Value o(rapidjson::kObjectType);
-
-
- o.SetString(tool_other::to_cid(1, atoi(vt_cid_d[0].c_str())).c_str(), allocator);
- e.PushBack(o, allocator);
- o.SetDouble(atof(vt_cid_d[1].c_str()));
- e.PushBack(o, allocator);
-
- elems.PushBack(e, allocator);
- }
- obj.AddMember("pid", elems, allocator);
- std::string t = tool_time::to_str(it_ev->second->m_cur_time);
- tool_json::add_member(obj, "start_time", t, allocator);
- data.PushBack(obj, allocator);
- }
- if(!data.Size()){
- return "";
- }
- doc.AddMember(JSON_ROOT_KEY_CMD, "pv_anti_coll", allocator);
- doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
- doc.AddMember(JSON_ROOT_KEY_DATA, data, allocator);
- rapidjson::StringBuffer sb;
- rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(sb);
- doc.Accept(writer);
- return sb.GetString();
- }
|