module_call.cpp 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747
  1. #include "module_call.h"
  2. #include <boost/bind.hpp>
  3. #include <vector>
  4. #include <set>
  5. #include <string>
  6. #include <chrono>
  7. #include<algorithm>
  8. #include <area.h>
  9. #include <site_area.h>
  10. #include"common_tool.h"
  11. #include"tool_time.h"
  12. #include"ant.h"
  13. #include"websocket/constdef.h"
  14. #include"websocket/wsClientMgr.h"
  15. #include"mine.h"
  16. uint64_t module_call::call_card::to_id64()
  17. {
  18. return tool_other::type_id_to_u64(cardtype, cardid);
  19. }
  20. std::string module_call::call_card::to_id64_str()
  21. {
  22. return tool_other::type_id_to_str(cardtype, cardid);
  23. }
  24. bool module_call::call_card::is_timeout()
  25. {
  26. uint32_t seconds = tool_time::elapse_seconds(call_time);
  27. return (seconds >= call_time_out*60);
  28. }
  29. bool module_call::call_user::is_timeout()
  30. {
  31. uint32_t seconds = tool_time::elapse_seconds(call_time);
  32. return (seconds >= call_time_out*60);
  33. }
  34. void module_call::to_node_element(rapidjson::Value& out_elemet,
  35. const std::shared_ptr<call_card> card_ptr,
  36. rapidjson::Document::AllocatorType& allocator)
  37. {
  38. tool_json::push_back(out_elemet, card_ptr->user_name, allocator);
  39. tool_json::push_back(out_elemet, card_ptr->to_id64_str(), allocator);
  40. out_elemet.PushBack(card_ptr->stationid, allocator);
  41. out_elemet.PushBack(card_ptr->call_time_interval, allocator);
  42. out_elemet.PushBack(card_ptr->call_type_id, allocator);
  43. out_elemet.PushBack(card_ptr->call_state, allocator);
  44. }
  45. void module_call::run()
  46. {
  47. std::vector<call_card_ptr> arr;
  48. get_all_call_cards(arr);
  49. if(arr.empty())
  50. {
  51. return ;
  52. }
  53. //转发给web
  54. swsClientMgr.send(JSON_CMD_VALUE_PUSH, to_call_card_list_json(arr));
  55. //将呼叫命令发送给标识卡终端
  56. call_site_map site_map;
  57. get_site_map(arr, site_map);
  58. if(!site_map.empty())
  59. {
  60. send_to_sites(site_map);
  61. }
  62. }
  63. ///发呼叫的报文数据给分站
  64. void module_call::send_to_sites(call_site_map& site_map)
  65. {
  66. auto iter_site = site_map.begin();
  67. for(; iter_site != site_map.end(); ++iter_site)
  68. {
  69. if(iter_site->second->cards.size() > 254)
  70. {
  71. log_error("呼叫:分站下卡数量过多:分站id=%d, 卡数=%d",
  72. iter_site->first, iter_site->second->cards.size());
  73. continue;
  74. }
  75. std::vector<char> arr;
  76. //分站地址 4字节,支持大小分站呼叫协议;added by zhuyf 2018/06/04
  77. //大小分站的全员呼叫,分站id要求4字节全为FF
  78. uint32_t anchor_id = (iter_site->second->is_call_all()? 0xffffffff : static_cast<uint32_t>(iter_site->first));
  79. memcpy_uint32(arr,anchor_id);
  80. //卡数
  81. arr.push_back(static_cast<char>(iter_site->second->cards.size()));
  82. //呼叫类型
  83. arr.push_back(static_cast<char>(iter_site->second->call_type_id));
  84. if(!iter_site->second->is_call_all())
  85. {
  86. //循环添加卡信息
  87. auto it_card = iter_site->second->cards.begin();
  88. for(; it_card != iter_site->second->cards.end(); ++it_card)
  89. {
  90. //呼叫类型
  91. arr.push_back(static_cast<char>(it_card->second->call_level_id));
  92. //卡类型
  93. arr.push_back(static_cast<char>(it_card->second->cardtype));
  94. //卡ID长度
  95. int id_len = 4;
  96. arr.push_back(static_cast<char>(id_len));
  97. //卡ID
  98. memcpy_uint32(arr, it_card->second->cardid);
  99. }
  100. }
  101. auto sit_ptr = sit_list::instance()->get(iter_site->first);
  102. if(!sit_ptr || !sit_ptr->m_clt)
  103. {
  104. log_error("在全局分站列表中找不到分站 或者sit_ptr->m_clt==null:分站id=%d", iter_site->first);
  105. continue;
  106. }
  107. //std::vector<char> arr2 = arr;
  108. sit_ptr->m_clt->send(std::move(arr));
  109. //print_test(std::move(arr2), iter_site->first);
  110. }
  111. }
  112. void module_call::print_test(std::vector<char>&& arr, int siteid)
  113. {
  114. std::string str("呼叫发送的数据帧,分站号=");
  115. str.append(std::to_string(siteid));
  116. str.append(":");
  117. char a[4]={0};
  118. for(std::vector<char>::size_type i=0; i<arr.size(); i++)
  119. {
  120. sprintf(a, "%02X ", static_cast<unsigned char>(arr[i]));
  121. str.append(std::string(a));
  122. }
  123. log_info("%s", str.c_str());
  124. }
  125. void module_call::rev_from_card_resp(std::shared_ptr<card_location_base> card_ptr)
  126. {
  127. card_ptr->get_mine_tool()->m_status_call = CALL_SUCCESSED;
  128. }
  129. /*
  130. web发给采集:发起呼叫
  131. {
  132. cmd: 'call_card_req',
  133. data: {
  134. call_type_id: this.cal_type, // 全员呼叫:0 定员呼叫:1
  135. call_time_out: this.choosedTime, // 呼叫时长
  136. call_level_id: this.call_type_id, // 呼叫类型 一般呼叫:1 紧急呼叫:2
  137. user_name: xdata.userName, // 呼叫人
  138. call_time: time, // 呼叫时间戳
  139. stations: [{ stationid: 0 }], // 分站 0为全员
  140. cards: cards // 人员 0为全员 //旧代码为map格式 [{ stationid: 0 }]
  141. }
  142. }
  143. */
  144. void module_call::accept_call(sio::message::ptr const& data)
  145. {
  146. int call_type = -1, call_level = -1, call_time_interval=-1;
  147. uint32_t call_time_out = 0;
  148. std::string user_name;
  149. if(!tool_map::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, data)
  150. || !tool_map::try_get_value(call_level, JSON_KEY_CALL_CARD_CALL_LEVEL, data)
  151. || !tool_map::try_get_value(call_time_out, JSON_KEY_CALL_CARD_CALL_TIME_OUT, data)
  152. || !tool_map::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, data)
  153. || !tool_map::try_get_value(call_time_interval, JSON_KEY_CALL_CARD_CALL_TIME, data)
  154. )
  155. {
  156. log_error("发起呼叫: 收到的json不对,解析不出call_type = -1, call_level = -1, \
  157. call_time_out=-1, call_time_interval=-1,user_name");
  158. return;
  159. }
  160. if(user_name.empty())
  161. {
  162. log_error("发起呼叫: user_name用户名为空");
  163. return;
  164. }
  165. std::vector<call_card_ptr> result_arr;//结果集
  166. call_user_ptr user_ptr;
  167. if(CCT_CALL_ALL==call_type)// 全员
  168. {
  169. user_ptr=call_user_ptr(new call_user());
  170. user_ptr->call_time=std::chrono::system_clock::now();
  171. user_ptr->call_time_out=call_time_out;
  172. user_ptr->call_time_interval = call_time_interval;
  173. user_ptr->call_type_id=call_type;
  174. user_ptr->call_level_id=call_level;
  175. user_ptr->user_name=user_name;
  176. call_card_ptr temp(new call_card());
  177. copy(user_ptr, temp);
  178. temp->cardid = CCT_CALL_ALL; //全员卡
  179. temp->call_state = CALL_ING;
  180. result_arr.push_back(temp);//增加到结果集中
  181. //添加全员卡
  182. user_ptr->cards.insert(std::make_pair(temp->cardid, temp));
  183. //更新用户信息
  184. std::lock_guard<std::mutex> lock(_mutex);
  185. _map[user_name]=user_ptr;
  186. }
  187. else// 定员: 如果有全员,定员不生效
  188. {
  189. std::lock_guard<std::mutex> lock(_mutex);
  190. auto user_map_ptr = _map.find(user_name);
  191. if(_map.end() == user_map_ptr)//没有这个用户就新建并加入
  192. {
  193. user_ptr=call_user_ptr(new call_user());
  194. _map[user_name]=user_ptr;
  195. }
  196. else//有这个用户
  197. {
  198. user_ptr=user_map_ptr->second;
  199. // 如果有全员,定员不生效
  200. auto card_temp = user_ptr->cards.find(CCT_CALL_ALL);
  201. if(user_ptr->cards.end() != card_temp)
  202. {
  203. return;
  204. }
  205. }
  206. //更新用户信息
  207. user_ptr->call_time=std::chrono::system_clock::now();
  208. user_ptr->call_time_out=call_time_out;
  209. user_ptr->call_time_interval = call_time_interval;
  210. user_ptr->call_type_id=call_type;
  211. user_ptr->call_level_id=call_level;
  212. user_ptr->user_name=user_name;
  213. std::vector<sio::message::ptr> card_vec;
  214. if(!tool_map::try_get_value(card_vec, JSON_KEY_CALL_CARD_CARDS, data) || card_vec.size() == 0)
  215. {
  216. log_error("发起呼叫,web发来的数据JSON_KEY_CALL_CARD_CARDS字段为空 或者不是数组");
  217. return;
  218. }
  219. add_cards_to_user(card_vec, user_ptr);
  220. for(auto& it:user_ptr->cards)//添加到结果集中
  221. {
  222. result_arr.push_back(it.second);
  223. }
  224. }
  225. //组装json发送给web
  226. if(!result_arr.empty())
  227. {
  228. response_accept_call(result_arr);
  229. }
  230. }
  231. //采集回复web发起呼叫
  232. //{
  233. // 'cmd': 'call_card_resp',
  234. // 'data': [
  235. // ["fjb", // 发起呼叫人
  236. // "0010000000001", // 呼叫的卡号
  237. // 103, // 分站号
  238. // 23431, // 发起呼叫时间
  239. // 0, //
  240. // 0 // 正在呼叫:2/结束呼叫/
  241. // ]
  242. // ]
  243. //}
  244. void module_call::response_accept_call(std::vector<call_card_ptr> cards)
  245. {
  246. rapidjson::Document doc(rapidjson::kObjectType);
  247. auto& allocator = doc.GetAllocator();
  248. rapidjson::Value node_cards(rapidjson::kArrayType);
  249. //组装json发送给web
  250. to_node_array(node_cards, cards, allocator);
  251. doc.AddMember(JSON_ROOT_KEY_CMD,JSON_CMD_VALUE_CALL_CARD_RESPONSE, allocator);
  252. doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
  253. doc.AddMember(JSON_ROOT_KEY_DATA, node_cards, allocator);
  254. swsClientMgr.send(JSON_CMD_VALUE_PUSH, tool_json::doc_to_json(doc));
  255. }
  256. //web发给采集:取消呼叫
  257. //{
  258. // cmd: 'call_card_cancel_req',
  259. // data: {
  260. // call_type_id: type, // 全员/定员
  261. // user_name: xdata.userName, // 取消人
  262. // call_time: callTime, // 时间戳
  263. // stations: this.stationid, // 分站
  264. // cards: this.cards // 取消呼叫卡 //旧代码为map格式 [{ stationid: 0 }]
  265. // }
  266. //}
  267. void module_call::accept_cancel(sio::message::ptr const& node_data)
  268. {
  269. int call_type = -1;//, call_level = -1;
  270. std::string user_name;
  271. int64_t call_time;
  272. if(!tool_map::try_get_value(call_type, JSON_KEY_CALL_CARD_CALL_TYPE, node_data)
  273. || !tool_map::try_get_value(call_time, JSON_KEY_CALL_CARD_CALL_TIME, node_data)
  274. || !tool_map::try_get_value(user_name, JSON_KEY_CALL_CARD_USER_NAME, node_data)
  275. )
  276. {
  277. log_error("取消呼叫: 收到的json不对,解析不出int call_type = -1, call_level = -1,user_name");
  278. return;
  279. }
  280. if(user_name.empty())
  281. {
  282. log_error("取消呼叫: user_name用户名为空");
  283. return;
  284. }
  285. call_user_ptr result_user_ptr(new call_user());
  286. result_user_ptr->call_type_id=call_type;
  287. // result_user_ptr->call_level_id=call_level;
  288. result_user_ptr->call_time = std::chrono::system_clock::time_point(std::chrono::milliseconds(call_time));
  289. result_user_ptr->user_name=user_name;
  290. //取消呼叫有两种:
  291. //取消全员呼叫
  292. //对指定卡取消呼叫
  293. if(CCT_CALL_ALL==call_type)// 取消全员呼叫
  294. {
  295. //删除用户
  296. std::lock_guard<std::mutex> lock(_mutex);
  297. _map.erase(user_name);
  298. }
  299. else// 取消定员呼叫
  300. {
  301. std::vector<sio::message::ptr> card_vec;
  302. if(!tool_map::try_get_value(card_vec, JSON_KEY_CALL_CARD_CARDS, node_data) || card_vec.size() == 0)
  303. {
  304. log_error("取消呼叫: web发来的数据cards字段为空 或者不是数组");
  305. return;
  306. }
  307. std::lock_guard<std::mutex> lock(_mutex);
  308. call_user_ptr user_ptr(new call_user());
  309. auto it_map = _map.find(user_name);
  310. if(_map.end()!=it_map)//呼叫用户
  311. {
  312. user_ptr=it_map->second;
  313. }
  314. std::vector<sio::message::ptr>::const_iterator it_card = card_vec.begin();
  315. std::string s_card_id;
  316. for(; it_card != card_vec.end(); ++it_card)
  317. {
  318. if(!tool_map::try_get_value(s_card_id, JSON_KEY_CALL_CARD_CARD_ID, (*it_card)))
  319. {
  320. log_error("取消呼叫: web发来的数据 card_id 格式不对");
  321. continue;
  322. }
  323. uint32_t id = tool_other::id64_to_id(s_card_id);
  324. int type= tool_other::id64_to_type(s_card_id);
  325. log_info("取消呼叫: cardid=%d, cardtype=%d", id, type);
  326. call_card_ptr card_ptr(new call_card());
  327. card_ptr->cardid = id;
  328. card_ptr->cardtype = type;
  329. result_user_ptr->cards[card_ptr->cardid]=card_ptr;//增加到结果集中
  330. user_ptr->cards.erase(card_ptr->cardid);//删除这个卡
  331. }
  332. // 没有呼叫信息,删除该用户记录
  333. if(user_ptr->cards.empty())
  334. {
  335. _map.erase(user_name);
  336. }
  337. }
  338. //如果要取消呼叫的用户下没有卡,建一张CCT_CALL_ALL卡返回
  339. if(result_user_ptr->cards.empty())
  340. {
  341. // result_user_ptr->call_level_id=call_level;
  342. //result_user_ptr->call_time=std::chrono::system_clock::now();
  343. result_user_ptr->call_time_out=0;
  344. result_user_ptr->call_type_id=call_type;
  345. result_user_ptr->user_name=user_name;
  346. call_card_ptr card_ptr(new call_card());
  347. card_ptr->cardid=CCT_CALL_ALL;
  348. result_user_ptr->cards[card_ptr->cardid]=card_ptr;
  349. }
  350. //转发给web
  351. response_accept_cancel(result_user_ptr);
  352. }
  353. /*
  354. 采集回复web:取消呼叫
  355. {
  356. "user_name":"fjb", // 取消人
  357. "call_time": 23432, // 发起呼叫时间
  358. "stations":[{"stationid":102}], // 分站号
  359. "cards":[{"cardid":"0","cardtype":"1"}] // 取消的卡
  360. }
  361. */
  362. void module_call::response_accept_cancel(const call_user_ptr user_ptr)
  363. {
  364. rapidjson::Document doc(rapidjson::kObjectType);
  365. auto& allocator = doc.GetAllocator();
  366. rapidjson::Value node_data(rapidjson::kObjectType);
  367. tool_json::add_member(node_data, JSON_KEY_CALL_CARD_USER_NAME, user_ptr->user_name, allocator);
  368. node_data.AddMember(JSON_KEY_CALL_CARD_CALL_TIME, tool_time::to_ms(user_ptr->call_time), allocator);
  369. node_data.AddMember(JSON_KEY_CALL_CARD_CALL_TYPE, user_ptr->call_type_id, allocator);
  370. rapidjson::Value node_cards(rapidjson::kArrayType);
  371. //加入取消呼叫的卡
  372. auto iter = user_ptr->cards.begin();
  373. for(;iter != user_ptr->cards.end();++iter)
  374. {
  375. rapidjson::Value node_card(rapidjson::kObjectType);
  376. tool_json::add_member(node_card, JSON_KEY_CALL_CARD_CARD_ID, iter->second->to_id64_str(), allocator);
  377. node_card.AddMember(JSON_KEY_CALL_CARD_CARD_TYPE_ID,iter->second->cardtype, allocator);
  378. node_cards.PushBack(node_card,allocator);
  379. }
  380. node_data.AddMember(JSON_KEY_CALL_CARD_CARDS, node_cards, allocator);
  381. doc.AddMember(JSON_ROOT_KEY_CMD, JSON_CMD_VALUE_CALL_CARD_CANCEL_RESPONSE, allocator);
  382. doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
  383. doc.AddMember(JSON_ROOT_KEY_DATA, node_data, allocator);
  384. //转发给web
  385. swsClientMgr.send(JSON_CMD_VALUE_PUSH, tool_json::doc_to_json(doc));
  386. }
  387. /*
  388. 登陆时,采集发送web:井下所有呼叫
  389. {"cmd":"callcardlist","data":[
  390. ["fjb", // 发起呼叫人
  391. "0010000000001", // 呼叫的卡号
  392. 103, // 分站号
  393. 23431, // 发起呼叫时间
  394. 0, //
  395. 0 // 正在呼叫:2/结束呼叫/
  396. ]
  397. ]}
  398. */
  399. std::string module_call::accept_login()
  400. {
  401. std::vector<call_card_ptr> arr;
  402. get_all_call_cards(arr);
  403. if(arr.empty())
  404. {
  405. return "";
  406. }
  407. return to_call_card_list_json(arr);
  408. }
  409. std::string module_call::to_call_card_list_json(std::vector<call_card_ptr> arr)
  410. {
  411. rapidjson::Document doc(rapidjson::kObjectType);
  412. auto& allocator = doc.GetAllocator();
  413. rapidjson::Value node_cards(rapidjson::kArrayType);
  414. to_node_array(node_cards, arr, allocator);
  415. doc.AddMember(JSON_ROOT_KEY_CMD, JSON_CMD_VALUE_CALL_CARD_LIST, allocator);
  416. doc.AddMember(JSON_ROOT_KEY_VERSION, INTERFACE_VERSION, allocator);
  417. doc.AddMember(JSON_ROOT_KEY_DATA, node_cards, allocator);
  418. return tool_json::doc_to_json(doc);
  419. }
  420. void module_call::add_cards_to_user(const std::vector<sio::message::ptr>& card_vec, call_user_ptr user_ptr)
  421. {
  422. std::vector<sio::message::ptr>::const_iterator it_card = card_vec.begin();
  423. for(; it_card != card_vec.end(); ++it_card)
  424. {
  425. std::string s_card_id;
  426. if(!tool_map::try_get_value(s_card_id, JSON_KEY_CALL_CARD_CARD_ID, (*it_card))
  427. ||s_card_id.empty())
  428. {
  429. log_error("发起呼叫,web发来的数据 card_id 格式不对 或为空");
  430. continue;
  431. }
  432. uint32_t id = tool_other::id64_to_id(s_card_id);
  433. int type= tool_other::id64_to_type(s_card_id);
  434. log_info("发起呼叫 cardid=%d, cardtype=%d", id, type);
  435. call_card_ptr card_ptr(new call_card());
  436. card_ptr->cardid = id;
  437. card_ptr->cardtype = type;
  438. copy(user_ptr, card_ptr);
  439. card_ptr->call_state = CALL_ING;
  440. user_ptr->cards[card_ptr->cardid]=card_ptr;
  441. }
  442. }
  443. void module_call::get_user_all_call_cards(call_user_ptr& user_ptr,
  444. const std::unordered_map<uint64_t,std::shared_ptr<card_location_base>>& cardlist,
  445. std::vector<call_card_ptr>& out_data)
  446. {
  447. auto& cards=user_ptr->cards;
  448. int status = CALL_ING;
  449. //如果是全员呼叫,增加所有卡
  450. auto card_it = cards.find(CCT_CALL_ALL);
  451. if(cards.end()!=card_it)
  452. {
  453. if(user_ptr->is_timeout())//呼叫超时, 清空全员卡, 并设置呼叫状态为结束
  454. {
  455. log_info("全员呼叫发送线程:呼叫用户超时,用户名=%s", user_ptr->user_name.c_str());
  456. cards.clear();
  457. status=CALL_END;
  458. }
  459. auto g_it=cardlist.begin();
  460. for(;g_it!=cardlist.end();++g_it)//如果是全员呼叫,增加所有卡
  461. {
  462. auto site_ptr = g_it->second->get_site_area();
  463. if(!site_ptr || site_ptr->is_invalid())
  464. {
  465. continue;
  466. }
  467. call_card_ptr card_ptr(new call_card());
  468. copy(user_ptr, card_ptr);
  469. card_ptr->cardid = g_it->second->m_id;
  470. card_ptr->cardtype = g_it->second->m_type;
  471. card_ptr->stationid=site_ptr->site_id();
  472. card_ptr->call_state=status;
  473. if(CALL_SUCCESSED == g_it->second->get_mine_tool()->m_status_call)
  474. {
  475. card_ptr->call_state = CALL_SUCCESSED;
  476. }
  477. else
  478. {
  479. g_it->second->get_mine_tool()->m_status_call = CALL_ING;
  480. }
  481. if(card_ptr->is_timeout())
  482. {
  483. g_it->second->get_mine_tool()->m_status_call = 0;
  484. }
  485. card_ptr->is_display = g_it->second->m_display;
  486. out_data.push_back(card_ptr);
  487. }
  488. return;
  489. }
  490. //定员呼叫
  491. auto iter_card = cards.begin();
  492. for(;iter_card!=cards.end();++iter_card)
  493. {
  494. //增加到结果集中
  495. out_data.push_back(iter_card->second);
  496. auto g_card = cardlist.find(iter_card->second->to_id64());
  497. if(cardlist.end()==g_card)//在全局卡列表中没有这张卡,
  498. {
  499. log_error("定员呼叫发送线程:全局卡列表中没有这张卡,卡id=%d,卡类型=%d",
  500. iter_card->second->cardid, iter_card->second->cardtype);
  501. iter_card->second->call_state = CALL_FAILED;
  502. cards.erase(iter_card--); //在用户下删除这张卡
  503. continue;
  504. }
  505. auto site_ptr = g_card->second->get_site_area();
  506. if(!site_ptr || site_ptr->is_invalid())
  507. {
  508. log_error("定员呼叫发送线程:全局卡列表中这张卡已经上井或无效,卡id=%d,卡类型=%d",
  509. iter_card->second->cardid, iter_card->second->cardtype);
  510. iter_card->second->call_state = CALL_FAILED;
  511. cards.erase(iter_card--); //在用户下删除这张卡
  512. continue;
  513. }
  514. //更新卡的分站id
  515. iter_card->second->stationid = site_ptr->site_id();
  516. if(CALL_SUCCESSED == g_card->second->get_mine_tool()->m_status_call)
  517. {
  518. iter_card->second->call_state = CALL_SUCCESSED;
  519. }
  520. else
  521. {
  522. g_card->second->get_mine_tool()->m_status_call = CALL_ING;
  523. }
  524. if(iter_card->second->is_timeout())//呼叫超时
  525. {
  526. log_info("定员呼叫发送线程:呼叫卡超时,用户名=%s,卡id=%d,卡类型=%d",
  527. iter_card->second->user_name.c_str(),
  528. iter_card->second->cardid, iter_card->second->cardtype);
  529. iter_card->second->call_state = CALL_END;
  530. if(CALL_SUCCESSED == g_card->second->get_mine_tool()->m_status_call)
  531. {
  532. iter_card->second->call_state = CALL_SUCCESSED;
  533. g_card->second->get_mine_tool()->m_status_call = 0;
  534. }
  535. cards.erase(iter_card--);//在用户下删除这张卡
  536. }
  537. }
  538. }
  539. /**
  540. * @brief 系统自动发送呼叫给指定的卡
  541. */
  542. void module_call::system_call_apoint(int card_id,int card_type)
  543. {
  544. int call_type = -1, call_level = -1, call_time_interval=-1;
  545. uint32_t call_time_out = 0;
  546. std::string user_name = "system_apoint";
  547. std::vector<call_card_ptr> result_arr;//结果集
  548. call_user_ptr user_ptr;
  549. std::lock_guard<std::mutex> lock(_mutex);
  550. auto user_map_ptr = _map.find(user_name);
  551. if(_map.end() == user_map_ptr)//没有这个用户就新建并加入
  552. {
  553. user_ptr=call_user_ptr(new call_user());
  554. _map[user_name]=user_ptr;
  555. }
  556. else//有这个用户
  557. {
  558. user_ptr=user_map_ptr->second;
  559. }
  560. //更新用户信息
  561. user_ptr->call_time=std::chrono::system_clock::now();
  562. user_ptr->call_time_out=call_time_out;
  563. user_ptr->call_time_interval = call_time_interval;
  564. user_ptr->call_type_id=call_type;
  565. user_ptr->call_level_id=call_level;
  566. user_ptr->user_name=user_name;
  567. call_card_ptr c_card_ptr(new call_card());
  568. c_card_ptr->cardid = card_id;
  569. c_card_ptr->cardtype = card_type;
  570. copy(user_ptr, c_card_ptr);
  571. c_card_ptr->call_state = CALL_ING;
  572. user_ptr->cards[c_card_ptr->cardid]=c_card_ptr;
  573. for(auto& it:user_ptr->cards)//添加到结果集中
  574. {
  575. result_arr.push_back(it.second);
  576. }
  577. log_info("发起呼叫 cardid=%d, cardtype=%d", card_id,card_type);
  578. //组装json发送给web
  579. response_accept_call(result_arr);
  580. }
  581. /**
  582. * @brief 系统自动发送呼叫给指定的卡
  583. */
  584. void module_call::system_cancel_call_apoint(int card_id,int card_type)
  585. {
  586. int call_type = -1;//, call_level = -1;
  587. std::string user_name = "system_apoint";
  588. int64_t call_time;
  589. call_user_ptr result_user_ptr(new call_user());
  590. result_user_ptr->call_type_id=call_type;
  591. // result_user_ptr->call_level_id=call_level;
  592. result_user_ptr->call_time = std::chrono::system_clock::time_point(std::chrono::milliseconds(call_time));
  593. result_user_ptr->user_name=user_name;
  594. std::lock_guard<std::mutex> lock(_mutex);
  595. call_user_ptr user_ptr(new call_user());
  596. auto it_map = _map.find(user_name);
  597. if(_map.end()!=it_map)//呼叫用户
  598. {
  599. user_ptr=it_map->second;
  600. }
  601. if (user_ptr->cards.find(card_id) == user_ptr->cards.end())
  602. {
  603. return ;
  604. }
  605. call_card_ptr c_card_ptr(new call_card());
  606. c_card_ptr->cardid = card_id;
  607. c_card_ptr->cardtype = card_type;
  608. result_user_ptr->cards[c_card_ptr->cardid]=c_card_ptr;//增加到结果集中
  609. user_ptr->cards.erase(c_card_ptr->cardid);//删除这个卡
  610. log_info("取消呼叫: cardid=%d, cardtype=%d", card_id,card_type);
  611. // 没有呼叫信息,删除该用户记录
  612. if(user_ptr->cards.empty())
  613. {
  614. _map.erase(user_name);
  615. }
  616. response_accept_cancel(result_user_ptr);
  617. }