callLogic.cc 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540
  1. #pragma once
  2. #include "uart/ProtocolSender.h"
  3. #include <string>
  4. #include "core/utilities.h"
  5. #include "voip/telephone.h"
  6. #include "base/strings.hpp"
  7. #include "storage/StoragePreferences.h"
  8. #include "core/sip_config.h"
  9. #include "zkaudio.h"
  10. #include "service/BusinessConfig.h"
  11. #include "net/tcp_client.h"
  12. #include "manager/ConfigManager.h"
  13. #include "voip/wav_player.h"
  14. #include "manager/LanguageManager.h"
  15. #include "media/ZKMediaPlayer.h"
  16. static ZKMediaPlayer* player;
  17. std::string _isOutgoing;
  18. std::string _toIdStr;
  19. voip::WAVPlayer wavPlayer; // 播放音频
  20. std::string tid;
  21. static bool _isSleepTimerRegistered = false;
  22. #define CALLING_TIME 60 // 用于控制呼叫时间,定时器
  23. const int goBack = 200;
  24. void callActivityFinish(CallFinishType type){
  25. switch (type){
  26. case CANCEL:
  27. LOGD("cancel");
  28. setSleepTimerRegistered(_isSleepTimerRegistered);
  29. EASYUICONTEXT->goBack();
  30. break;
  31. case REJECT:
  32. LOGD("reject");
  33. wavPlayer.Stop();
  34. mTextViewNamePtr->setTextTr("RemoteRefuse");
  35. mActivityPtr->unregisterUserTimer(CALLING_TIME);
  36. mActivityPtr->registerUserTimer(goBack, 5000);
  37. break;
  38. case BUSY:
  39. LOGD("BUSY");
  40. wavPlayer.Stop();
  41. mTextViewNamePtr->setTextTr("RemoteBusy");
  42. mActivityPtr->unregisterUserTimer(CALLING_TIME);
  43. mActivityPtr->registerUserTimer(goBack, 5000);
  44. break;
  45. case HANDOFF:
  46. LOGD("handoff");
  47. setSleepTimerRegistered(_isSleepTimerRegistered);
  48. EASYUICONTEXT->goBack();
  49. break;
  50. case FAILED:
  51. wavPlayer.Stop();
  52. mTextViewNamePtr->setTextTr("CallFailed");
  53. mActivityPtr->registerUserTimer(goBack, 5000);
  54. break;
  55. case ACCEPT:
  56. mActivityPtr->unregisterUserTimer(CALLING_TIME);
  57. break;
  58. case A1CLICK:
  59. LOGD("a1 click");
  60. if (StoragePreferences::getString(STORE_SIGNAL_TYPE,"TCP")=="TCP"){
  61. TcpModel storeModel = CallingStatus::instance()->getTcpModel();
  62. //只回传iId
  63. storeModel.data = storeModel.json["id"].asString();
  64. voip::CallInfo info = GetTelephone()->GetCallInfo();
  65. LOGD("info state = %d",info.state);
  66. if (info.state == voip::STATE_CALL_CALLING
  67. || info.state == voip::STATE_CALL_CALLING
  68. || info.state == voip::STATE_CALL_CONFIRMED){
  69. sendVoiceTcp(VoiceAction::HANDOFF, storeModel, storeModel.from_id);
  70. GetTelephone()->Hangup(info.id, voip::SIP_STATUS_CODE_DECLINE);
  71. GetTelephone()->Hangup();
  72. setSleepTimerRegistered(_isSleepTimerRegistered);
  73. EASYUICONTEXT->goBack();
  74. } else if (_isOutgoing == "false"){ //state = 5
  75. mButtonAnswerPtr->setVisible(false);
  76. TcpModel model = CallingStatus::instance()->getTcpModel();
  77. model.data = model.json["id"].asString();
  78. sendVoiceTcp(VoiceAction::ACCEPT, model, model.from_id);
  79. mActivityPtr->unregisterUserTimer(CALLING_TIME);
  80. } else if (_isOutgoing == "true") {
  81. sendVoiceTcp(VoiceAction::CANCEL, storeModel, storeModel.from_id);
  82. setSleepTimerRegistered(_isSleepTimerRegistered);
  83. EASYUICONTEXT->goBack();
  84. }
  85. }
  86. break;
  87. case KEY6_CLICK:
  88. LOGD("KEY6 click");
  89. if (StoragePreferences::getString(STORE_SIGNAL_TYPE,"TCP")=="TCP"){
  90. TcpModel storeModel = CallingStatus::instance()->getTcpModel();
  91. //只回传iId
  92. storeModel.data = storeModel.json["id"].asString();
  93. voip::CallInfo info = GetTelephone()->GetCallInfo();
  94. LOGD("info state = %d",info.state);
  95. if (info.state == voip::STATE_CALL_CALLING
  96. || info.state == voip::STATE_CALL_CALLING
  97. || info.state == voip::STATE_CALL_CONFIRMED){
  98. sendVoiceTcp(VoiceAction::HANDOFF, storeModel, storeModel.from_id);
  99. GetTelephone()->Hangup(info.id, voip::SIP_STATUS_CODE_DECLINE);
  100. GetTelephone()->Hangup();
  101. setSleepTimerRegistered(_isSleepTimerRegistered);
  102. EASYUICONTEXT->goBack();
  103. std::string heartStr = "DOORLED,000F";
  104. const char* sendMsg = heartStr.c_str();
  105. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  106. } else if (_isOutgoing == "false"){ //state = 5
  107. mButtonAnswerPtr->setVisible(false);
  108. TcpModel model = CallingStatus::instance()->getTcpModel();
  109. model.data = model.json["id"].asString();
  110. sendVoiceTcp(VoiceAction::ACCEPT, model, model.from_id);
  111. mActivityPtr->unregisterUserTimer(CALLING_TIME);
  112. }
  113. }
  114. break;
  115. }
  116. }
  117. void buildSIP(std::string toSipId){
  118. wavPlayer.Stop();
  119. int port = StoragePreferences::getInt(SIP_REG_PORT, SIP_REG_PORT_DEFAULT);
  120. std::string domain = StoragePreferences::getString(SIP_REG_DOMAIN, SIP_REG_DOMAIN_DEFAULT);
  121. //std::string od_number = StoragePreferences::getString(SIP_REG_DOOR_ACCOUNT, SIP_REG_DOOR_ACCOUNT_DEFAULT);
  122. std::string od_number_uri = URI(toSipId, domain, port);
  123. LOGD("xxxxxxxxxxxxxx %s",od_number_uri.c_str());
  124. GetTelephone()->MakeCall(od_number_uri);
  125. }
  126. void acceptSIP(){
  127. wavPlayer.Stop();
  128. voip::CallInfo info = GetTelephone()->GetCallInfo();
  129. GetTelephone()->Answer();
  130. }
  131. //static ZKMediaPlayer sPlayer(ZKMediaPlayer::E_MEDIA_TYPE_AUDIO);
  132. namespace {
  133. const int kTimerAutoAnswer = 100;
  134. std::string StateString(voip::State state) {
  135. switch (state) {
  136. case voip::STATE_CALL_CALLING:
  137. case voip::STATE_CALL_EARLY:
  138. return LANGUAGEMANAGER->getValue("Calling");
  139. case voip::STATE_CALL_CONFIRMED:
  140. return LANGUAGEMANAGER->getValue("CallConfirmed");
  141. case voip::STATE_CALL_CONNECTING:
  142. return LANGUAGEMANAGER->getValue("CallConnecting");
  143. case voip::STATE_CALL_INCOMING:
  144. return LANGUAGEMANAGER->getValue("CallInComing");
  145. default:
  146. break;
  147. }
  148. return "";
  149. }
  150. } /* anonymous namespace */
  151. /**
  152. * 注册定时器
  153. * 填充数组用于注册定时器
  154. * 注意:id不能重复
  155. */
  156. static S_ACTIVITY_TIMEER REGISTER_ACTIVITY_TIMER_TAB[] = {
  157. //{0, 6000}, //定时器id=0, 时间间隔6秒
  158. {1, 1000},
  159. {kTimerAutoAnswer, 2000},
  160. };
  161. /**
  162. * 当界面构造时触发
  163. */
  164. static void onUI_init(){
  165. CallingStatus::instance()->setBusy(true);
  166. EASYUICONTEXT->hideStatusBar();
  167. EASYUICONTEXT->hideNaviBar();
  168. player = new ZKMediaPlayer(ZKMediaPlayer::E_MEDIA_TYPE_AUDIO);
  169. player->play("/mnt/extsd/ui/ring.wav");
  170. //界面操作
  171. if (SIGNAL_TYPE=="SIP"){
  172. voip::CallInfo info = GetTelephone()->GetCallInfo();
  173. mTextViewNamePtr->setText(info.remote_uri);
  174. if (info.state == voip::STATE_CALL_CALLING) {
  175. mButtonAnswerPtr->setVisible(false);
  176. }
  177. }
  178. mSeekBarOutputVolumePtr->setMax(zk_audio_output_volume_native_max());
  179. //打开时的声音大小
  180. int serverVol = StoragePreferences::getInt(STORE_DAY_VOL,PartSetting::dayBedVol);
  181. if (checkIsDay()){
  182. serverVol = StoragePreferences::getInt(STORE_NIGHT_VOL,PartSetting::nightBedVol);
  183. }
  184. double percent = (double)serverVol/(double)100;
  185. int vol = (int)(zk_audio_output_volume_native_max()*percent);
  186. LOGD("bed vol is %d. server is %d. max is %d",vol,serverVol, zk_audio_output_volume_native_max());
  187. zk_audio_output_set_volume_native(vol);
  188. mSeekBarOutputVolumePtr->setProgress(vol);
  189. mTextViewOutputVolumePtr->setTouchPass(true);
  190. // mTextViewNamePtr->setVisible(false);
  191. // mTextViewStatePtr->setVisible(false);
  192. // mTextViewDurationPtr->setVisible(false);
  193. }
  194. /**
  195. * 当切换到该界面时触发
  196. */
  197. static void onUI_intent(const Intent *intentPtr) {
  198. if(intentPtr != NULL) {
  199. BRIGHTNESSHELPER->screenOn();
  200. _isSleepTimerRegistered = getSleepTimerRegistered();
  201. setSleepTimerRegistered(false);
  202. wavPlayer.Play(CONFIGMANAGER->getResFilePath("ring1.wav"));
  203. //wavPlayer.Play(CONFIGMANAGER->getResFilePath("1.mp3"));
  204. // 键值解析
  205. _isOutgoing = intentPtr->getExtra(isOutgoing);
  206. std::string _audioOnly = intentPtr->getExtra(audioOnly);
  207. // if (_isOutgoing == "true"){
  208. // int toId = 0;
  209. // _toIdStr = intentPtr->getExtra(toIdStr);
  210. // if (_toIdStr != "") {
  211. // toId = atoi(_toIdStr.c_str());
  212. // }
  213. //
  214. // //TCP call
  215. // TcpModel tcpModel;
  216. // tcpModel.tid = base::format("t%d", TimeHelper::getCurrentTime());
  217. // tcpModel.type = TcpType::VOICE;
  218. // tcpModel.action = VoiceAction::CALL;
  219. // tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
  220. // tcpModel.to_id = toId;
  221. // std::string req = getTcpModelString(tcpModel);
  222. // LOGD("TCP CALL : %s",req.c_str());
  223. //// TcpClient::instance()->sendMsg(req.c_str());
  224. //
  225. // //回调注册
  226. // TcpCallback callback;
  227. // callback.tid = tcpModel.tid;
  228. // callback.jsonStr = req;
  229. // callback.onSuccess = [](Json::Value json){
  230. // LOGD("voice callback success");
  231. // return 0;
  232. // };
  233. // callback.onFalied = [](Json::Value json){
  234. // LOGD("voice callback failed");
  235. // return 0;
  236. // };
  237. // TcpClient::instance()->sendMsgWithCb(req.c_str(), callback);
  238. //
  239. //
  240. // // 呼叫的时候需要把tid放进去
  241. // tid = tcpModel.tid;
  242. // mButtonAnswerPtr->setVisible(false);
  243. //
  244. // std::string _callName = intentPtr->getExtra(callName);
  245. // if (_callName != "") {
  246. // mTextViewNamePtr->setText(LANGUAGEMANAGER->getValue("Call") + _callName);
  247. // } else {
  248. // mTextViewNamePtr->setTextTr("CallOutTitle");
  249. // }
  250. //
  251. // mActivityPtr->registerUserTimer(CALLING_TIME, 60000); // 如果对方没接听,则发送一个CANCEL回去
  252. // } else {
  253. // TcpModel storeModel = CallingStatus::instance()->getTcpModel();
  254. // TcpModel backTcp = storeModel;
  255. // backTcp.data = storeModel.json["id"].asString();
  256. // //back voice success
  257. // sendVoiceTcp(VoiceAction::SUCCESS, backTcp, storeModel.from_id);
  258. //
  259. // mTextViewNamePtr->setText(storeModel.json["fromFrameName"].asString());
  260. // //自动接听处理
  261. // if (StoragePreferences::getBool(STORE_AUDO_ANSWER,false)){
  262. // mButtonAnswerPtr->setVisible(false);
  263. // voip::CallInfo info = GetTelephone()->GetCallInfo();
  264. // if (info.state == voip::STATE_CALL_INCOMING
  265. // || info.state == voip::STATE_CALL_EARLY) {
  266. // GetTelephone()->Answer();
  267. //
  268. // //发出TCP
  269. // sendVoiceTcp(VoiceAction::ACCEPT, storeModel, storeModel.from_id);
  270. // }
  271. // }
  272. // }
  273. }
  274. }
  275. /*
  276. * 当界面显示时触发
  277. */
  278. static void onUI_show() {
  279. }
  280. /*
  281. * 当界面隐藏时触发
  282. */
  283. static void onUI_hide() {
  284. }
  285. /*
  286. * 当界面完全退出时触发
  287. */
  288. static void onUI_quit() {
  289. EASYUICONTEXT->showStatusBar();
  290. EASYUICONTEXT->showNaviBar();
  291. wavPlayer.Stop();
  292. CallingStatus::instance()->setBusy(false);
  293. CallingStatus::instance()->clearTcpModel();
  294. mActivityPtr->unregisterUserTimer(goBack);
  295. }
  296. /**
  297. * 串口数据回调接口
  298. */
  299. static void onProtocolDataUpdate(const SProtocolData &data) {
  300. }
  301. /**
  302. * 定时器触发函数
  303. * 不建议在此函数中写耗时操作,否则将影响UI刷新
  304. * 参数: id
  305. * 当前所触发定时器的id,与注册时的id相同
  306. * 返回值: true
  307. * 继续运行当前定时器
  308. * false
  309. * 停止运行当前定时器
  310. */
  311. static bool onUI_Timer(int id){
  312. switch (id) {
  313. case 1: {
  314. if (SIGNAL_TYPE=="SIP"){
  315. voip::CallInfo info = GetTelephone()->GetCallInfo();
  316. if (info.state == voip::STATE_CALL_CONFIRMED){
  317. mButtonAnswerPtr->setVisible(false);
  318. }
  319. mTextViewNamePtr->setText(info.remote_uri);
  320. mTextViewStatePtr->setText(StateString(info.state));
  321. mTextViewDurationPtr->setText(
  322. base::format("%02d:%02d",
  323. info.duration/1000/60,
  324. info.duration/1000%60));
  325. } else {
  326. voip::CallInfo info = GetTelephone()->GetCallInfo();
  327. if (info.state == voip::STATE_CALL_CONFIRMED){
  328. mButtonAnswerPtr->setVisible(false);
  329. }
  330. mTextViewStatePtr->setText(StateString(info.state));
  331. mTextViewDurationPtr->setText(
  332. base::format("%02d:%02d",
  333. info.duration/1000/60,
  334. info.duration/1000%60));
  335. }
  336. }
  337. break;
  338. case kTimerAutoAnswer: {
  339. voip::CallInfo info = GetTelephone()->GetCallInfo();
  340. if (info.state == voip::STATE_CALL_INCOMING
  341. || info.state == voip::STATE_CALL_EARLY) {
  342. bool auto_answer = StoragePreferences::getBool(SIP_AUTO_ANSWER, false);
  343. LOGD("is auto answer: %d", auto_answer);
  344. if (auto_answer) {
  345. GetTelephone()->Answer();
  346. }
  347. }
  348. }
  349. return false;
  350. break;
  351. case goBack:{
  352. setSleepTimerRegistered(_isSleepTimerRegistered);
  353. EASYUICONTEXT->goBack();
  354. break;
  355. }
  356. case CALLING_TIME: {
  357. //TCP call
  358. TcpModel tcpModel;
  359. tcpModel.type = TcpType::VOICE;
  360. tcpModel.action = VoiceAction::CANCEL;
  361. tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID,0);
  362. tcpModel.to_id = 0;
  363. std::string req = getTcpModelString(tcpModel);
  364. LOGD("TCP CALL : %s",req.c_str());
  365. TcpClient::instance()->sendMsg(req.c_str());
  366. std::string heartStr = "DOORLED,000F";
  367. const char* sendMsg = heartStr.c_str();
  368. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  369. setSleepTimerRegistered(_isSleepTimerRegistered);
  370. EASYUICONTEXT->goBack();
  371. break;
  372. }
  373. default:
  374. break;
  375. }
  376. return true;
  377. }
  378. /**
  379. * 有新的触摸事件时触发
  380. * 参数:ev
  381. * 新的触摸事件
  382. * 返回值:true
  383. * 表示该触摸事件在此被拦截,系统不再将此触摸事件传递到控件上
  384. * false
  385. * 触摸事件将继续传递到控件上
  386. */
  387. static bool oncallActivityTouchEvent(const MotionEvent &ev) {
  388. switch (ev.mActionStatus) {
  389. case MotionEvent::E_ACTION_DOWN://触摸按下
  390. //LOGD("时刻 = %ld 坐标 x = %d, y = %d", ev.mEventTime, ev.mX, ev.mY);
  391. break;
  392. case MotionEvent::E_ACTION_MOVE://触摸滑动
  393. break;
  394. case MotionEvent::E_ACTION_UP: //触摸抬起
  395. break;
  396. default:
  397. break;
  398. }
  399. return false;
  400. }
  401. static void onVideoViewPlayerMessageListener_VideoView1(ZKVideoView *pVideoView, int msg) {
  402. switch (msg) {
  403. case ZKVideoView::E_MSGTYPE_VIDEO_PLAY_STARTED:
  404. break;
  405. case ZKVideoView::E_MSGTYPE_VIDEO_PLAY_COMPLETED:
  406. break;
  407. case ZKVideoView::E_MSGTYPE_VIDEO_PLAY_ERROR:
  408. break;
  409. }
  410. }
  411. static void onProgressChanged_SeekBarOutputVolume(ZKSeekBar *pSeekBar, int progress) {
  412. zk_audio_output_set_volume_native(progress);
  413. mTextViewOutputVolumePtr->setText(base::format("%d", progress));
  414. }
  415. static bool onButtonClick_ButtonHangup(ZKButton *pButton) {
  416. LOGD("handup click");
  417. voip::CallInfo info = GetTelephone()->GetCallInfo();
  418. LOGD("info id = %d",info.id);
  419. if (StoragePreferences::getString(STORE_SIGNAL_TYPE,"TCP")=="TCP"){
  420. TcpModel storeModel = CallingStatus::instance()->getTcpModel();
  421. if (storeModel.json != 0) {
  422. //只回传iId
  423. storeModel.data = storeModel.json["id"].asString();
  424. if (info.id>0){
  425. sendVoiceTcp(VoiceAction::HANDOFF, storeModel, storeModel.from_id);
  426. GetTelephone()->Hangup(info.id, voip::SIP_STATUS_CODE_DECLINE);
  427. GetTelephone()->Hangup();
  428. } else if (_isOutgoing == "true") {
  429. sendVoiceTcp(VoiceAction::CANCEL, storeModel, storeModel.from_id);
  430. // 还原成无灯光的状态
  431. std::string heartStr = "DOORLED,000F";
  432. const char* sendMsg = heartStr.c_str();
  433. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  434. } else {
  435. storeModel.data = storeModel.json["id"].asString();
  436. sendVoiceTcp(VoiceAction::REJECT, storeModel, storeModel.from_id);
  437. }
  438. } else {
  439. TcpModel tcpModel;
  440. tcpModel.tid = tid;
  441. sendVoiceTcp(VoiceAction::CANCEL, tcpModel, StoragePreferences::getInt(STORE_DEVICE_ID,0));
  442. // 还原成无灯光的状态
  443. std::string heartStr = "DOORLED,000F";
  444. const char* sendMsg = heartStr.c_str();
  445. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  446. }
  447. setSleepTimerRegistered(_isSleepTimerRegistered);
  448. EASYUICONTEXT->goBack();
  449. } else {
  450. GetTelephone()->Hangup();
  451. }
  452. return false;
  453. }
  454. static bool onButtonClick_ButtonAnswer(ZKButton *pButton) {
  455. LOGD(" ButtonClick ButtonAnswer !!!\n");
  456. mButtonAnswerPtr->setVisible(false);
  457. if (SIGNAL_TYPE=="SIP"){
  458. voip::CallInfo info = GetTelephone()->GetCallInfo();
  459. GetTelephone()->Answer();
  460. } else {
  461. TcpModel model = CallingStatus::instance()->getTcpModel();
  462. //LOGD("storeModel :::: type=%s,action=%s,from=%d,to=%d",model.type.c_str(),model.action.c_str(),model.from_id,model.to_id);
  463. //std::string storeModelStr = getTcpModelString(model);
  464. //LOGD("storeModelStr ===== %s",storeModelStr.c_str());
  465. //只回传iId
  466. model.data = model.json["id"].asString();
  467. sendVoiceTcp(VoiceAction::ACCEPT, model, model.from_id);
  468. }
  469. return false;
  470. }
  471. static bool onButtonClick_ButtonVol(ZKButton *pButton) {
  472. LOGD(" ButtonClick ButtonVol !!!\n");
  473. return false;
  474. }