123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505 |
- #include "module_call.h"
- #include <boost/bind.hpp>
- #include <vector>
- #include <set>
- #include <string>
- #include <chrono>
- #include<algorithm>
- enum CALL_CARD_TYPE
- {
-
- CCT_CALL_ALL = 0,
-
- CCT_CALL_APOINT=1,
- };
- enum CALL_CARD_LEVEL
- {
-
- CALL_LEVEL_NORMAL=1,
-
- CALL_LEVEL_CRITICAL=2
- };
- enum CALL_STATE{
-
- CALL_NONE = 0,
-
- CALL_SUCCESSED = 1,
-
- CALL_ING = 2,
-
- CALL_FAILED = 3,
-
- CALL_END=100
- };
- void module_call::run()
- {
- std::vector<call_card_ptr> arr;
- get_all_call_cards(arr);
- if(arr.empty())
- {
- return ;
- }
-
- swsClientMgr.send(JSON_CMD_VALUE_PUSH, to_call_card_list_json(arr));
-
- }
- void module_call::accept_call(const rapidjson::Document& node_data)
- {
- int call_type = -1, call_level = -1, call_time_out;
- std::string user_name;
- if(!tool_json::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, node_data)
- || !tool_json::try_get_value(call_level, JSON_KEY_CALL_CARD_CALL_LEVEL, node_data)
- || !tool_json::try_get_value(call_time_out, JSON_KEY_CALL_CARD_CALL_TIME_OUT, node_data)
- || !tool_json::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, node_data)
- )
- {
- log_error("收到的json不对,解析不出int call_type = -1, call_level = -1, call_time_out,user_name");
- return;
- }
- if(user_name.empty())
- {
- log_error("user_name用户名为空");
- return;
- }
- std::vector<call_card_ptr> 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_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;
- arr.push_back(temp);
-
- user_ptr->cards.insert(std::make_pair(CCT_CALL_ALL, 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(user_map_ptr==_map.end())
- {
- user_ptr=call_user_ptr(new call_user());
- _map[user_name]=user_ptr;
- }
- else
- {
- user_ptr=user_map_ptr->second;
-
- if(user_ptr->cards.size()==1 && CCT_CALL_ALL == user_ptr->cards[CCT_CALL_ALL]->cardid)
- {
- return;
- }
- }
-
- user_ptr->call_time=std::chrono::system_clock::now();
- user_ptr->call_time_out=call_time_out;
- user_ptr->call_type_id=call_type;
- user_ptr->call_level_id=call_level;
- user_ptr->user_name=user_name;
- auto node_cards_ptr = node_data.FindMember(JSON_KEY_CALL_CARD_CARDS);
- if(node_data.MemberEnd()==node_cards_ptr)
- {
- return;
- }
- const rapidjson::Value& node_cards = node_cards_ptr->value;
- if(!node_cards.IsArray())
- {
- return;
- }
- add_cards_to_user(call_level, node_cards, user_ptr);
- for(auto& it:user_ptr->cards)
- {
- arr.push_back(it.second);
- }
- }
-
- if(!arr.empty())
- {
- response_accept_call(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);
- 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(const rapidjson::Document& node_data)
- {
- int call_type = -1, call_level = -1;
- std::string user_name;
- if(!tool_json::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, node_data)
- || !tool_json::try_get_value(call_level, JSON_KEY_CALL_CARD_CALL_LEVEL, node_data)
- || !tool_json::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, node_data)
- )
- {
- log_error("收到的json不对,解析不出int call_type = -1, call_level = -1,user_name");
- 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_level_id=call_level;
- 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
- {
- auto node_cards_ptr = node_data.FindMember(JSON_KEY_CALL_CARD_CARDS);
- if(node_data.MemberEnd()==node_cards_ptr)
- {
- return;
- }
- const rapidjson::Value& node_cards = node_cards_ptr->value;
- if(!node_cards.IsArray())
- {
- 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;
- }
- uint64_t id_card;
- for(rapidjson::SizeType i = 0; i < node_cards.Size(); ++i)
- {
- if(!tool_json::try_get_value( id_card, JSON_KEY_CALL_CARD_CARD_ID, node_cards[i])
- || 0==id_card
- )
- {
- continue;
- }
- call_card_ptr card_ptr(new call_card());
- card_ptr->cardid = id_card;
- result_user_ptr->cards[id_card]=card_ptr;
- user_ptr->cards.erase(id_card);
- }
-
- if(user_ptr->cards.empty())
- {
- _map.erase(user_name);
- }
- }
-
- if(result_user_ptr->cards.empty())
- {
- result_user_ptr->call_level_id=call_level;
- result_user_ptr->call_time=std::chrono::system_clock::now();
- 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);
- node_data.AddMember(JSON_KEY_CALL_CARD_USER_NAME, rapidjson::StringRef(user_ptr->user_name.c_str()), allocator);
- node_data.AddMember(JSON_KEY_CALL_CARD_CALL_TIME, tool_time::to_ms(user_ptr->call_time), 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);
- node_card.AddMember(JSON_KEY_CALL_CARD_CARD_ID,iter->second->cardid, 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(int call_level, const rapidjson::Value& node_cards, call_user_ptr user_ptr)
- {
- uint64_t id_card;
- for(rapidjson::SizeType i = 0; i < node_cards.Size(); ++i)
- {
- if(!tool_json::try_get_value( id_card, JSON_KEY_CALL_CARD_CARD_ID, node_cards[i])
- || 0==id_card
- )
- {
- continue;
- }
- call_card_ptr card_ptr(new call_card());
- card_ptr->cardid = id_card;
- 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;
-
- if(cards.size()==1 && CCT_CALL_ALL == cards[0]->cardid)
- {
- uint32_t seconds = tool_time::elapse_seconds(user_ptr->call_time);
- if(seconds > user_ptr->call_time_out*60)
- {
- cards.clear();
- status=CALL_END;
- }
- auto g_it=cardlist.begin();
- for(;g_it!=cardlist.end();++g_it)
- {
- call_card_ptr card_ptr(new call_card());
- copy(user_ptr, card_ptr);
- card_ptr->cardid = g_it->second->m_id;
- card_ptr->stationid=g_it->second->m_site_id;
- card_ptr->call_state=status;
- 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->cardid);
- if(cardlist.end()==g_card)
- {
- iter_card->second->call_state = CALL_FAILED;
- cards.erase(iter_card--);
- continue;
- }
-
- iter_card->second->stationid = g_card->second->m_site_id;
- uint32_t seconds = tool_time::elapse_seconds(iter_card->second->call_time);
- if(seconds > iter_card->second->call_time_out*60)
- {
- iter_card->second->call_state = CALL_END;
- cards.erase(iter_card--);
- }
- }
- }
|