module_call.cpp 23 KB

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