startLogic.cc 29 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033
  1. #pragma once
  2. #include "uart/ProtocolSender.h"
  3. #include "uart/UartContext.h"
  4. #include "core/utilities.h"
  5. #include "edge/call_log.h"
  6. #include "net/tcp_client.h"
  7. #include "net/tcp_model.h"
  8. #include "server/http_server.h"
  9. #include "base/strings.hpp"
  10. #include "utils/GpioHelper.h"
  11. #include "utils/TimeHelper.h"
  12. #include "utils/BrightnessHelper.h"
  13. #include <time.h>
  14. #include <thread>
  15. #include <string>
  16. #include <unistd.h>
  17. #include <sys/reboot.h>
  18. #include "service/BusinessConfig.h"
  19. static bool sosTimerRegistered = true;
  20. static bool isSleepTimerRegistered = false; // 是否开启息屏定时任务
  21. static bool isSleep = false; // 是否在息屏
  22. static string callTid = "";
  23. #define HELP_TIMER_HANDLE 3 // 增援的定时器id
  24. #define SOS_CLICK_TIME_HANDLE 4 // sos的定时器id
  25. #define SOS_LAMP_TIME_HANDLE 5 // sos的门灯定时器id
  26. #define NURSING_TIME_HANDLE 6 // 护理的定时器id
  27. #define EVENT_TIME_HANDLE 8 // 事件定时器
  28. #define SLEEP_STRAT_TIME_HANDLE 9 // 息屏
  29. #define SYS_RESTART 10 // 重启
  30. #define HTTP_SERVER_PORT 80
  31. srv::HttpServer httpServer;
  32. namespace {
  33. std::string uilogic[] = {
  34. "testActivity",
  35. "ui3Activity"
  36. };
  37. void CloseUi();
  38. int feed_dogs = 0;
  39. void PrintCallLog() {
  40. CallLogEntries entries;
  41. int ret = GetCallLog(&entries);
  42. LOGD("GetCallRecord %d", ret);
  43. for (auto r : entries) {
  44. LOGD("id=%d, uri=%s, contact=%s,duration=%d,created_at=%d",
  45. r.id, r.uri.c_str(), r.contact.c_str(), r.duration, r.created_at);
  46. }
  47. }
  48. void OnCallStateChanged(voip::Telephone* telephone, int call_id, voip::State state) {
  49. LOGD("call state = %d", state);
  50. if (state == voip::STATE_CALL_INCOMING
  51. || state == voip::STATE_CALL_CALLING
  52. || state == voip::STATE_CALL_CONFIRMED) {
  53. if (StoragePreferences::getString(STORE_SIGNAL_TYPE, SIGNAL_TYPE) == "SIP"){
  54. //EASYUICONTEXT->goHome();
  55. EASYUICONTEXT->openActivity("callActivity");
  56. CloseUi();
  57. }
  58. voip::CallInfo info = GetTelephone()->GetCallInfo();
  59. LOGD("info.id == %d", info.id);
  60. LOGD("info.remote_uri == %s", info.remote_uri.c_str());
  61. LOGD("info.remote_contact == %s", info.remote_contact.c_str());
  62. if (state == voip::STATE_CALL_INCOMING) {
  63. if (telephone->GetCallCount() > 1) {
  64. LOGD("call count > 1, return");
  65. telephone->Hangup(call_id, voip::SIP_STATUS_CODE_BUSY_HERE);
  66. return;
  67. }
  68. //提前显示视频
  69. if (StoragePreferences::getString(STORE_SIGNAL_TYPE, SIGNAL_TYPE) == "SIP"){
  70. telephone->Answer(call_id, voip::SIP_STATUS_CODE_PROGRESS);
  71. telephone->Answer();
  72. } else {
  73. acceptSIP();
  74. }
  75. }
  76. }
  77. if (state == voip::STATE_CALL_DISCONNECTED) {
  78. if (telephone->GetCallCount() > 1) {
  79. LOGD("call count > 1, return");
  80. return;
  81. }
  82. if (StoragePreferences::getString(STORE_SIGNAL_TYPE, SIGNAL_TYPE) == "SIP"){
  83. //EASYUICONTEXT->goHome();
  84. EASYUICONTEXT->goBack();
  85. }
  86. //保存通话记录
  87. voip::CallInfo info = telephone->GetCallInfo(call_id);
  88. CallLogEntry entry;
  89. entry.uri = info.remote_uri;
  90. entry.contact = info.remote_contact;
  91. entry.duration = info.duration/1000;
  92. if (0 != PutCallLog(entry)) {
  93. LOGE("保存通话记录失败");
  94. }
  95. int n = GetCallLogCount();
  96. if (n > CALL_LOG_COUNT_MAX) {
  97. //超过最大通话记录条数,删除旧记录
  98. if (0 != DeleteOldCallLog(n - CALL_LOG_COUNT_MAX)) {
  99. LOGE("删除失败");
  100. }
  101. }
  102. //PrintCallLog();
  103. }
  104. }
  105. void CloseUi() {
  106. for(int i = 0; i < 2; i++){
  107. EASYUICONTEXT->closeActivity(uilogic[i].c_str());
  108. }
  109. }
  110. void setBrightness(){
  111. int dayLight = StoragePreferences::getInt(STORE_DAY_LIGHT,100);
  112. int nightLight = StoragePreferences::getInt(STORE_NIGHT_LIGHT,10);
  113. if (checkIsDay()){
  114. BRIGHTNESSHELPER->setBrightness(dayLight);
  115. } else {
  116. BRIGHTNESSHELPER->setBrightness(nightLight);
  117. }
  118. }
  119. }
  120. // 门灯还原
  121. void doorLampRestoration() {
  122. if (StoragePreferences::getBool(STORE_NURSING_TYPE, false)) {
  123. std::string color = StoragePreferences::getString(STORE_NURSING_COLOR_RGB, "010");
  124. std::string heartStr;
  125. if (color != "" && color.size() == 3) {
  126. heartStr = "DOORLED," + color + "F";
  127. } else {
  128. heartStr = "DOORLED,010F";
  129. }
  130. const char* sendMsg = heartStr.c_str();
  131. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  132. }
  133. else {
  134. // 收到ACCEPT,需要灭灯
  135. // 还原成无灯光的状态
  136. std::string heartStr = "DOORLED,000F";
  137. const char* sendMsg = heartStr.c_str();
  138. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  139. }
  140. }
  141. // 接收tcp消息
  142. void handleMsg(byte* inBytes){
  143. LOGD("TCP received: %s", inBytes);
  144. const char* cstr = reinterpret_cast<const char*>(inBytes);
  145. string str = cstr;
  146. if (str == "1"){
  147. LOGD("get a heart beat");
  148. return;
  149. }
  150. TcpModel tcpModel;
  151. tcpModel = getTcpModel(inBytes);
  152. LOGD("tcp model: %s, %s", tcpModel.type.c_str(), tcpModel.action.c_str());
  153. if (tcpModel.type == TcpType::OTHER) {
  154. LOGD("trans tcp json failed");
  155. } else if (tcpModel.type == TcpType::TIME) {
  156. if (tcpModel.action == TimeAction::SYNC) {
  157. string serverTime = "";
  158. if (tcpModel.data != ""){
  159. serverTime = tcpModel.data;
  160. } else {
  161. serverTime = tcpModel.json["time"].asString();
  162. }
  163. LOGD("sync time : %s", serverTime.c_str());
  164. time_t timet = stoi(serverTime);
  165. struct tm *t = gmtime(&timet);
  166. char pDate[25];
  167. sprintf(pDate,"%d-%02d-%02d %02d:%02d:%02d",
  168. 1900 + t->tm_year, 1+ t->tm_mon, t->tm_mday,
  169. t->tm_hour + 8,t->tm_min,t->tm_sec);
  170. LOGD("transfered time : %s", pDate);
  171. TimeHelper::setDateTime(pDate);
  172. dataRefresh();
  173. }
  174. } else if (tcpModel.type == TcpType::REINFORCE){
  175. if (tcpModel.action == ReinforceAction::RESPONSED){
  176. //回调
  177. TcpCallback callback = TcpCacheManager::instance()->getFunc(tcpModel.tid);
  178. if (callback.tid != "0"){
  179. callback.onSuccess(tcpModel.json);
  180. }
  181. cancelAutoBtnHelpTimer();
  182. // SetPainterInfo(0xFF37C127, LANGUAGEMANAGER->getValue("HelpResponse"));
  183. // setHelpButton("/button/button_help3.png", false);
  184. // setReinforce(false); // 设置增援状态为true
  185. // //3秒后还原白色
  186. // if (!isHelpTimerRegistered){
  187. // mActivityPtr->registerUserTimer(HELP_TIMER_HANDLE, 3000);
  188. // }
  189. setPainterInfo(StoragePreferences::getInt(STORE_DEVICE_ID,0), 0xFF37C127, LANGUAGEMANAGER->getValue("HelpResponse"), "REINFORCE", "UPDATE", 3);
  190. }
  191. } else if (tcpModel.type == TcpType::DEVICE){
  192. if (tcpModel.action == DeviceAction::APP_UPDATE){ //软件升级
  193. if (isSleep) {
  194. isSleep = false;
  195. BRIGHTNESSHELPER->screenOn();
  196. }
  197. Intent* intent = new Intent();
  198. intent->putExtra(appUpdate, "true");
  199. EASYUICONTEXT->openActivity("DeviceUpdateActivity", intent);
  200. }
  201. else if (tcpModel.action == DeviceAction::RESTART) { // 重启设备
  202. const char* req = "-1";
  203. TcpClient::instance()->sendMsg(req);
  204. sync();
  205. reboot(RB_AUTOBOOT);
  206. }
  207. else if (tcpModel.action == DeviceAction::DEVICE_REFRESH) { // 设备刷新
  208. dataRefresh();
  209. }
  210. else if (tcpModel.action == DeviceAction::SYSTEM_SETTING) { // 修改科室设置
  211. getPartSetting();
  212. }
  213. else if (tcpModel.action == DeviceAction::SERVER_CHANGE) {
  214. StoragePreferences::putString(STORE_GATEWAY, tcpModel.json["server_ip"].asCString());
  215. StoragePreferences::putString(STORE_HTTP_PORT, tcpModel.json["server_port"].asCString());
  216. const char* req = "-1";
  217. TcpClient::instance()->sendMsg(req);
  218. //重启
  219. sync();
  220. reboot(RB_AUTOBOOT);
  221. }
  222. } else if (tcpModel.type == TcpType::DATA){
  223. if (tcpModel.action == DataAction::REFRESH){ // 刷新数据
  224. dataRefresh();
  225. }
  226. } else if (tcpModel.type == TcpType::VOICE){
  227. if (tcpModel.action == VoiceAction::FAILED){
  228. string _cencalByDoorTid = getCencalByDoorTid();
  229. if (tcpModel.tid != _cencalByDoorTid) {
  230. callActivityFinish(CallFinishType::FAILED);
  231. }
  232. } else if (tcpModel.action == VoiceAction::SUCCESS){
  233. CallingStatus::instance()->setTcpModel(tcpModel); // 只有呼叫成功才闪红灯
  234. std::string heartStr = "DOORLED,200F"; // 红灯闪烁
  235. const char* sendMsg = heartStr.c_str();
  236. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  237. } else if (tcpModel.action == VoiceAction::ACCEPT){
  238. if (CallingStatus::instance()->busy()){
  239. CallingStatus::instance()->setTcpModel(tcpModel);
  240. std::string toSipId = tcpModel.json["toSipId"].asString();
  241. callActivityFinish(CallFinishType::ACCEPT);
  242. //接听
  243. buildSIP(toSipId);
  244. }
  245. // 还原成无灯光的状态
  246. std::string heartStr = "DOORLED,000F";
  247. const char* sendMsg = heartStr.c_str();
  248. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  249. } else if (tcpModel.action == VoiceAction::REJECT){
  250. if (CallingStatus::instance()->busy()){
  251. callActivityFinish(CallFinishType::REJECT);
  252. // 还原成无灯光的状态
  253. std::string heartStr = "DOORLED,000F";
  254. const char* sendMsg = heartStr.c_str();
  255. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  256. }
  257. } else if (tcpModel.action == VoiceAction::CANCEL){
  258. //CallingStatus::instance()->setTcpModel(tcpModel);
  259. if (CallingStatus::instance()->busy()){
  260. callActivityFinish(CallFinishType::CANCEL);
  261. }
  262. } else if (tcpModel.action == VoiceAction::CALLING){
  263. //CallingStatus::instance()->setTcpModel(tcpModel);
  264. //对方忙线
  265. callActivityFinish(CallFinishType::BUSY);
  266. } else if (tcpModel.action == VoiceAction::CALL){
  267. //我方忙线判断
  268. if (CallingStatus::instance()->busy()){
  269. sendVoiceTcp(VoiceAction::CALLING, tcpModel, tcpModel.from_id);
  270. } else {
  271. CallingStatus::instance()->setTcpModel(tcpModel);
  272. //来电话了
  273. Intent* intent = new Intent();
  274. intent->putExtra(isOutgoing, "false");
  275. intent->putExtra(audioOnly, "true");
  276. EASYUICONTEXT->openActivity("callActivity", intent);
  277. }
  278. } else if (tcpModel.action == VoiceAction::HANDOFF){
  279. //判断 是否同一个对话
  280. long iId = CallingStatus::instance()->getInteractionId();
  281. if (iId > 0 && CallingStatus::instance()->busy()){
  282. long inId = tcpModel.json["id"].asInt();
  283. if (iId == inId && CallingStatus::instance()->busy()){
  284. callActivityFinish(CallFinishType::HANDOFF);
  285. }
  286. }
  287. }
  288. }
  289. else if (tcpModel.type == TcpType::SOS) {
  290. if (tcpModel.action == SosAction::CANCEL) {
  291. // SOS还原成无灯光的状态
  292. std::string heartStr = "ULED,0F";
  293. const char* sendMsg = heartStr.c_str();
  294. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  295. // 门灯还原成无灯光的状态
  296. std::string heartStr2 = "DOORLED,000F";
  297. const char* sendMsg2 = heartStr2.c_str();
  298. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg2), strlen(sendMsg2));
  299. mActivityPtr->unregisterUserTimer(SOS_LAMP_TIME_HANDLE);
  300. }
  301. }
  302. else if (tcpModel.type == TcpType::SIDE) {
  303. if (tcpModel.action == SideAction::NURSING) {
  304. // 将tcpModel缓存起来
  305. setNursingTcpModel(tcpModel);
  306. // 收到nursing,需要把通话给挂断了
  307. voip::CallInfo info = GetTelephone()->GetCallInfo();
  308. LOGD("info state = %d",info.state);
  309. if (info.state == voip::STATE_CALL_CALLING
  310. || info.state == voip::STATE_CALL_CALLING
  311. || info.state == voip::STATE_CALL_CONFIRMED){
  312. TcpModel storeModel = CallingStatus::instance()->getTcpModel();
  313. //只回传iId
  314. storeModel.data = storeModel.json["id"].asString();
  315. sendVoiceTcp(VoiceAction::HANDOFF, storeModel, storeModel.from_id);
  316. GetTelephone()->Hangup(info.id, voip::SIP_STATUS_CODE_DECLINE);
  317. GetTelephone()->Hangup();
  318. EASYUICONTEXT->goBack();
  319. }
  320. std::string color = StoragePreferences::getString(STORE_NURSING_COLOR_RGB, "010");
  321. std::string heartStr;
  322. if (color != "" && color.size() == 3) {
  323. heartStr = "DOORLED," + color + "F";
  324. } else {
  325. heartStr = "DOORLED,010F";
  326. }
  327. const char* sendMsg = heartStr.c_str();
  328. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  329. // 删除这个定时器
  330. mActivityPtr->unregisterUserTimer(NURSING_TIME_HANDLE);
  331. LOGD("收到服务器返回的消息,关闭Nursing的定时器");
  332. }
  333. else if (tcpModel.action == SideAction::NURSING_END) {
  334. // 收到nursing_end
  335. std::string heartStr = "DOORLED,000F";
  336. const char* sendMsg = heartStr.c_str();
  337. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  338. }
  339. else if (tcpModel.action == SideAction::CALL) {
  340. // 收到CALL,需要亮红灯
  341. std::string heartStr = "DOORLED,200F"; // 红灯闪烁
  342. const char* sendMsg = heartStr.c_str();
  343. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  344. int deviceId = tcpModel.from_id;
  345. string fromFrameFullName = tcpModel.json["fromFrameFullName"].asString();
  346. setPainterInfo(deviceId, 0xFF2F9DF1, fromFrameFullName + " " + LANGUAGEMANAGER->getValue("CallInfo"), "VOICE", "ADD", 60);
  347. }
  348. else if (tcpModel.action == SideAction::ACCEPT) {
  349. // 先处理painterInfoList里的数据
  350. int deviceId = tcpModel.to_id;
  351. setPainterInfo(deviceId, 0xFFFFFFFF, "", "VOICE", "DELETE", 0);
  352. // 获取painterInfoList
  353. Json::Value _painterInfoList = getPainterInfoList();
  354. if (_painterInfoList.size() > 0) { // 如果painterInfoList.size > 0
  355. // 如果列表里还有VOICE,就不修改门灯,直接结束
  356. for (int i = 0; i < _painterInfoList.size(); i++) {
  357. if (_painterInfoList[i]["type"] == "VOICE") {
  358. return;
  359. }
  360. }
  361. }
  362. // 进行门灯还原
  363. doorLampRestoration();
  364. }
  365. else if (tcpModel.action == SideAction::CANCEL) {
  366. int deviceId = tcpModel.from_id;
  367. if (tcpModel.json.size() != 0) {
  368. deviceId = tcpModel.json["fromDeviceId"].asInt();
  369. }
  370. setPainterInfo(deviceId, 0xFFFFFFFF, "", "VOICE", "DELETE", 0);
  371. // 获取painterInfoList
  372. Json::Value _painterInfoList = getPainterInfoList();
  373. if (_painterInfoList.size() > 0) { // 如果painterInfoList.size > 0
  374. // 如果列表里还有VOICE,就不修改门灯,直接结束
  375. for (int i = 0; i < _painterInfoList.size(); i++) {
  376. if (_painterInfoList[i]["type"] == "VOICE") {
  377. return;
  378. }
  379. }
  380. }
  381. // 进行门灯还原
  382. doorLampRestoration();
  383. }
  384. else if (tcpModel.action == SideAction::SOS_CALL) {
  385. // 收到SOS_CALL,需要亮红灯
  386. // SOS亮红灯
  387. string heartStr = "ULED,1F";
  388. // 门灯亮红灯
  389. std::string heartStr2 = "DOORLED,200F";
  390. const char* sendMsg2 = heartStr2.c_str();
  391. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg2), strlen(sendMsg2));
  392. sosTimerRegistered = false;
  393. mActivityPtr->registerUserTimer(SOS_CLICK_TIME_HANDLE, 10000); // 10秒后才能触发
  394. mActivityPtr->registerUserTimer(SOS_LAMP_TIME_HANDLE, 120000); // 2分钟后才能触发
  395. int deviceId = tcpModel.from_id;
  396. string fromFrameFullName = tcpModel.json["fromFrameFullName"].asString();
  397. setPainterInfo(deviceId, 0xFFFF0000, fromFrameFullName + " " + LANGUAGEMANAGER->getValue("SOSCallInfo"), "SOS", "ADD", 120);
  398. }
  399. else if (tcpModel.action == SideAction::SOS_CANCEL) {
  400. int deviceId = tcpModel.to_id;
  401. setPainterInfo(deviceId, 0xFFFFFFFF, "", "SOS", "DELETE", 0);
  402. // 获取painterInfoList
  403. Json::Value _painterInfoList = getPainterInfoList();
  404. if (_painterInfoList.size() > 0) { // 如果painterInfoList.size > 0
  405. // 如果列表里还有VOICE,就不修改门灯,直接结束
  406. for (int i = 0; i < _painterInfoList.size(); i++) {
  407. if (_painterInfoList[i]["type"] == "SOS") {
  408. return;
  409. }
  410. }
  411. }
  412. // 进行门灯还原
  413. doorLampRestoration();
  414. }
  415. }
  416. else if (tcpModel.type == TcpType::CALLBACK) {
  417. if (tcpModel.action == CallbackAction::ACK) {
  418. LOGD("CALLBACK ACK !!!!");
  419. //回调
  420. TcpCallback callback = TcpCacheManager::instance()->getFunc(tcpModel.tid);
  421. if (callback.tid != "0"){
  422. callback.onSuccess(tcpModel.json);
  423. }
  424. }
  425. else if (tcpModel.action == CallbackAction::SUCCESS) {
  426. //回调
  427. TcpCallback callback = TcpCacheManager::instance()->getFunc(tcpModel.tid);
  428. if (callback.tid != "0"){
  429. callback.onSuccess(tcpModel.json);
  430. }
  431. }
  432. else if (tcpModel.action == CallbackAction::FAILED) {
  433. //回调
  434. TcpCallback callback = TcpCacheManager::instance()->getFunc(tcpModel.tid);
  435. if (callback.tid != "0"){
  436. callback.onFalied(tcpModel.json);
  437. }
  438. if (tcpModel.tid == callTid){
  439. callActivityFinish(CallFinishType::FAILED);
  440. }
  441. }
  442. }
  443. }
  444. bool getSleepTimerRegistered() {
  445. return isSleepTimerRegistered;
  446. }
  447. // 触发定时任务
  448. void setSleepTimerRegistered(bool result) {
  449. LOGD("isSleepTimerRegistered = %d", isSleepTimerRegistered);
  450. LOGD("result = %d", result);
  451. if (mActivityPtr == NULL) {
  452. return;
  453. }
  454. if (result != isSleepTimerRegistered) { // 与定时任务不同时,才进行处理
  455. if (isSleepTimerRegistered) { // 与定时任务开关进行判断,如果定时任务开启,那就要关闭
  456. isSleepTimerRegistered = result;
  457. mActivityPtr->unregisterUserTimer(SLEEP_STRAT_TIME_HANDLE); // 关闭定时器
  458. if (isSleep) {
  459. isSleep = false;
  460. BRIGHTNESSHELPER->screenOn();
  461. }
  462. LOGD("关闭息屏");
  463. } else { // 如果定时任务关着,那就要打开
  464. isSleepTimerRegistered = result;
  465. int sleepTime = StoragePreferences::getInt(STORE_SLEEP_TIME, 3);
  466. if (sleepTime > 0) {
  467. mActivityPtr->registerUserTimer(SLEEP_STRAT_TIME_HANDLE, sleepTime * 60 * 1000);
  468. LOGD("开启息屏");
  469. }
  470. }
  471. }
  472. }
  473. void scrrenOn() {
  474. isSleep = false;
  475. BRIGHTNESSHELPER->screenOn();
  476. }
  477. void setCallTid(std::string tid) {
  478. callTid = tid;
  479. }
  480. //================================= IO 口操作
  481. //紧急按钮灯,明/灭
  482. void setSOS_A5(bool light){
  483. int result = -1;
  484. int slight = light?0:1;
  485. result = GpioHelper::output("A5", slight);
  486. if (result==0){
  487. LOGD("set A5 SOS light %d. success",light);
  488. } else {
  489. LOGD("set A5 SOS light %d. failed",light);
  490. }
  491. }
  492. //A6,A7,A8 RGB灯控制
  493. void setRGB_A678(bool R, bool G, bool B){
  494. int rR = -1, rG = -1, rB = -1;
  495. int sR = R?0:1, sG = G?0:1, sB = B?0:1;
  496. rR = GpioHelper::output("A6", sR);
  497. rG = GpioHelper::output("A7", sG);
  498. rB = GpioHelper::output("A8", sB);
  499. const char *strLog = "set %s light %d. %d";
  500. LOGD(strLog,"A6 R",R, rR);
  501. LOGD(strLog,"A7 G",G, rG);
  502. LOGD(strLog,"A8 B",B, rB);
  503. }
  504. //手柄按钮
  505. class A1GpioListener : public IGpioListener{
  506. public:
  507. bool onGpioEdge(const char *pPin) override {
  508. int state = GpioHelper::input("A1");
  509. LOGD("IGpioListener GPIO IS A1=%d", state);
  510. if (state==0){
  511. voip::CallInfo info = GetTelephone()->GetCallInfo();
  512. //拨打 或 挂断
  513. if (CallingStatus::instance()->busy()){
  514. callActivityFinish(CallFinishType::A1CLICK);
  515. } else {
  516. Intent* intent = new Intent();
  517. intent->putExtra(isOutgoing, "true");
  518. intent->putExtra(audioOnly, "true");
  519. EASYUICONTEXT->openActivity("callActivity", intent);
  520. }
  521. }
  522. return true;
  523. }
  524. void onGpioError(const char *pPin, int error) override {
  525. LOGD("IGpioListener ERROR GPIO IS %s, %d", pPin, error);
  526. }
  527. };
  528. //7寸面板,呼出
  529. class A2GpioListener : public IGpioListener{
  530. public:
  531. bool onGpioEdge(const char *pPin) override {
  532. int state = GpioHelper::input("A2");
  533. LOGD("IGpioListener GPIO IS A2=%d", state);
  534. if (state==0){
  535. //拨打 或 接听
  536. }
  537. return true;
  538. }
  539. void onGpioError(const char *pPin, int error) override {
  540. LOGD("IGpioListener ERROR GPIO IS %s, %d", pPin, error);
  541. }
  542. };
  543. //7寸面板,挂断
  544. class A3GpioListener : public IGpioListener{
  545. public:
  546. bool onGpioEdge(const char *pPin) override {
  547. int state = GpioHelper::input("A3");
  548. LOGD("IGpioListener GPIO IS A3=%d", state);
  549. if (state==0){
  550. //挂断
  551. }
  552. return true;
  553. }
  554. void onGpioError(const char *pPin, int error) override {
  555. LOGD("IGpioListener ERROR GPIO IS %s, %d", pPin, error);
  556. }
  557. };
  558. //紧急按钮
  559. class A4GpioListener : public IGpioListener{
  560. public:
  561. bool onGpioEdge(const char *pPin) override {
  562. int state = GpioHelper::input("A4");
  563. LOGD("IGpioListener GPIO IS A4=%d", state);
  564. if (state==0){
  565. //发出
  566. setSOS_A5(true);
  567. }
  568. return true;
  569. }
  570. void onGpioError(const char *pPin, int error) override {
  571. LOGD("IGpioListener ERROR GPIO IS %s, %d", pPin, error);
  572. }
  573. };
  574. /**
  575. * 注册定时器
  576. * 填充数组用于注册定时器
  577. * 注意:id不能重复
  578. */
  579. static S_ACTIVITY_TIMEER REGISTER_ACTIVITY_TIMER_TAB[] = {
  580. {1, 5000},
  581. {2, 30*1000}
  582. };
  583. /**
  584. * 当界面构造时触发
  585. */
  586. static void onUI_init(){
  587. //IO监测
  588. IGpioListener *iGpioListenerA1 = new A1GpioListener();
  589. GpioHelper::registerGpioListener("A1", iGpioListenerA1, E_GPIO_EDGE_TYPE_FALLING);
  590. IGpioListener *iGpioListenerA2 = new A2GpioListener();
  591. GpioHelper::registerGpioListener("A2", iGpioListenerA1, E_GPIO_EDGE_TYPE_FALLING);
  592. IGpioListener *iGpioListenerA3 = new A3GpioListener();
  593. GpioHelper::registerGpioListener("A3", iGpioListenerA1, E_GPIO_EDGE_TYPE_FALLING);
  594. IGpioListener *iGpioListenerA4 = new A4GpioListener();
  595. GpioHelper::registerGpioListener("A4", iGpioListenerA1, E_GPIO_EDGE_TYPE_FALLING);
  596. //TCP启动
  597. TcpClient::instance()->startTcp();
  598. //监听SIP信令
  599. GetTelephone()->AddCallStateListener(OnCallStateChanged);
  600. //开启网页
  601. httpServer.RunAsync(HTTP_SERVER_PORT);
  602. // 启动的时候更改为tcp模式
  603. StoragePreferences::putString(STORE_SIGNAL_TYPE, "TCP");
  604. //请求版本号
  605. // if(UartContext::Uart3IsOpen()) {
  606. // string heartStr = "ASK,VNF-0";
  607. // const char* sendMsg = heartStr.c_str();
  608. // sendProtocolTo(UART_TTYS3, (byte*)(sendMsg), strlen(sendMsg));
  609. // }
  610. #if 0
  611. std::thread backend([](){
  612. while (true) {
  613. if (feed_dogs > 0) {
  614. --feed_dogs;
  615. LOGD("feed");
  616. int ret = GpioHelper::output("GPIO_2", 1); //拉高
  617. if (ret != 0) {
  618. LOGE("GPIO操作失败");
  619. }
  620. usleep(1000 * 20);
  621. ret = GpioHelper::output("GPIO_2", 0); //拉低
  622. if (ret != 0) {
  623. LOGE("GPIO操作失败");
  624. }
  625. }
  626. usleep(1000 * 1000);
  627. }
  628. });
  629. backend.detach();
  630. #endif
  631. }
  632. /**
  633. * 当切换到该界面时触发
  634. */
  635. static void onUI_intent(const Intent *intentPtr) {
  636. if (intentPtr != NULL) {
  637. //TODO
  638. }
  639. }
  640. /*
  641. * 当界面显示时触发
  642. */
  643. static void onUI_show() {
  644. StoragePreferences::putString(STORE_SIGNAL_TYPE, "TCP");
  645. //进入主界面
  646. EASYUICONTEXT->openActivity("mainActivity");
  647. }
  648. /*
  649. * 当界面隐藏时触发
  650. */
  651. static void onUI_hide() {
  652. }
  653. /*
  654. * 当界面完全退出时触发
  655. */
  656. static void onUI_quit() {
  657. }
  658. /**
  659. * 串口数据回调接口
  660. */
  661. static void onProtocolDataUpdate(const SProtocolData &data) {
  662. LOGD("cmd = %s", data.cmd.c_str());
  663. if (data.state!=""){
  664. LOGD("state = %s",data.state.c_str());
  665. }
  666. // if (data.msg != ""){
  667. // LOGD("msg = %s", data.msg.c_str());
  668. // }
  669. if(UartContext::Uart3IsOpen()) { // 如果是true,表示串口打开了
  670. string heartStr;
  671. //按下
  672. if (data.state=="0"){ // 0表示正被按下,1表示短按松开,2表示长按松开。
  673. if (data.cmd == "KEY5") { // key5是面板拨号按钮
  674. if (!StoragePreferences::getInt(STORE_SCREEN_LIGHT, 0)) {
  675. if (isSleep) {
  676. scrrenOn();
  677. }
  678. else {
  679. voip::CallInfo info = GetTelephone()->GetCallInfo();
  680. //拨打 或 挂断
  681. if (CallingStatus::instance()->busy()){
  682. callActivityFinish(CallFinishType::A1CLICK);
  683. } else {
  684. Intent* intent = new Intent();
  685. intent->putExtra(isOutgoing, "true");
  686. intent->putExtra(audioOnly, "true");
  687. EASYUICONTEXT->openActivity("callActivity", intent);
  688. }
  689. }
  690. }
  691. else {
  692. scrrenOn();
  693. voip::CallInfo info = GetTelephone()->GetCallInfo();
  694. //拨打 或 挂断
  695. if (CallingStatus::instance()->busy()){
  696. callActivityFinish(CallFinishType::A1CLICK);
  697. } else {
  698. Intent* intent = new Intent();
  699. intent->putExtra(isOutgoing, "true");
  700. intent->putExtra(audioOnly, "true");
  701. EASYUICONTEXT->openActivity("callActivity", intent);
  702. }
  703. }
  704. }
  705. else if (data.cmd == "KEY6"){ // key6是手柄触发,手柄只有呼叫和挂断功能,没有取消功能,防止用户不停地按
  706. if (!StoragePreferences::getInt(STORE_SCREEN_LIGHT, 0)) {
  707. if (isSleep) {
  708. scrrenOn();
  709. }
  710. else {
  711. voip::CallInfo info = GetTelephone()->GetCallInfo();
  712. //拨打 或 挂断
  713. if (CallingStatus::instance()->busy()){
  714. callActivityFinish(CallFinishType::KEY6_CLICK);
  715. } else {
  716. Intent* intent = new Intent();
  717. intent->putExtra(isOutgoing, "true");
  718. intent->putExtra(audioOnly, "true");
  719. EASYUICONTEXT->openActivity("callActivity", intent);
  720. }
  721. }
  722. }
  723. else {
  724. scrrenOn();
  725. voip::CallInfo info = GetTelephone()->GetCallInfo();
  726. //拨打 或 挂断
  727. if (CallingStatus::instance()->busy()){
  728. callActivityFinish(CallFinishType::KEY6_CLICK);
  729. } else {
  730. Intent* intent = new Intent();
  731. intent->putExtra(isOutgoing, "true");
  732. intent->putExtra(audioOnly, "true");
  733. EASYUICONTEXT->openActivity("callActivity", intent);
  734. }
  735. }
  736. }
  737. else if (data.cmd == "KEY7"){ // key7是紧急按钮
  738. if (isSleep) {
  739. scrrenOn();
  740. }
  741. if (sosTimerRegistered) {
  742. LOGD("TCP -> SOS_CALL");
  743. TcpModel tcpModel;
  744. tcpModel.type = TcpType::SOS;
  745. tcpModel.action = SosAction::CALL;
  746. tcpModel.from_id = StoragePreferences::getInt(STORE_DEVICE_ID, 0);
  747. tcpModel.tid = base::format("t%d",TimeHelper::getCurrentTime());
  748. std::string req = getTcpModelString(tcpModel);
  749. LOGD("TCP SOS_CALL : %s",req.c_str());
  750. TcpClient::instance()->sendMsg(req.c_str());
  751. // SOS亮红灯
  752. heartStr = "ULED,1F";
  753. // 门灯亮红灯
  754. std::string heartStr2 = "DOORLED,200F";
  755. const char* sendMsg2 = heartStr2.c_str();
  756. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg2), strlen(sendMsg2));
  757. sosTimerRegistered = false;
  758. mActivityPtr->registerUserTimer(SOS_CLICK_TIME_HANDLE, 10000); // 10秒后才能触发
  759. mActivityPtr->registerUserTimer(SOS_LAMP_TIME_HANDLE, 120000); // 2分钟后才能触发
  760. }
  761. }
  762. else if (data.cmd == "KEY<") { //下左3,红
  763. if (StoragePreferences::getString(STORE_SIGNAL_TYPE, SIGNAL_TYPE) == "SIP") {
  764. setCheckbox("KEY<");
  765. return;
  766. }
  767. if (isSleep) {
  768. scrrenOn();
  769. }
  770. // heartStr = "DOORLED,000F";
  771. }
  772. else if (data.cmd == "KEY>") { // key>是面板挂断按钮
  773. if (!StoragePreferences::getInt(STORE_SCREEN_LIGHT, 0)) {
  774. if (isSleep) {
  775. scrrenOn();
  776. }
  777. else {
  778. voip::CallInfo info = GetTelephone()->GetCallInfo();
  779. //拨打 或 挂断
  780. if (CallingStatus::instance()->busy()){
  781. callActivityFinish(CallFinishType::A1CLICK);
  782. heartStr = "DOORLED,000F";
  783. const char* sendMsg = heartStr.c_str();
  784. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  785. }
  786. }
  787. }
  788. else {
  789. scrrenOn();
  790. voip::CallInfo info = GetTelephone()->GetCallInfo();
  791. //拨打 或 挂断
  792. if (CallingStatus::instance()->busy()){
  793. callActivityFinish(CallFinishType::A1CLICK);
  794. heartStr = "DOORLED,000F";
  795. const char* sendMsg = heartStr.c_str();
  796. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  797. }
  798. }
  799. }
  800. else if (data.cmd == "KEY;"){ //下左4,白
  801. if (isSleep) {
  802. scrrenOn();
  803. }
  804. heartStr = "DOORLED,111F";
  805. }
  806. else {
  807. if (isSleep) {
  808. scrrenOn();
  809. }
  810. heartStr = "DOORLED,000F";
  811. }
  812. // 发送给板子的指令
  813. const char* sendMsg = heartStr.c_str();
  814. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  815. }
  816. }
  817. }
  818. /**
  819. * 定时器触发函数
  820. * 不建议在此函数中写耗时操作,否则将影响UI刷新
  821. * 参数: id
  822. * 当前所触发定时器的id,与注册时的id相同
  823. * 返回值: true
  824. * 继续运行当前定时器
  825. * false
  826. * 停止运行当前定时器
  827. */
  828. static bool onUI_Timer(int id){
  829. switch (id) {
  830. case 1:
  831. {
  832. //定时器跑在UI线程,这里将喂狗标记加1
  833. //++feed_dogs;
  834. //不用心跳
  835. // if(UartContext::Uart3IsOpen()) {
  836. // string heartStr = "HEART,1E";
  837. // const char* sendMsg = heartStr.c_str();
  838. // sendProtocolTo(UART_TTYS3, (byte*)(sendMsg), strlen(sendMsg));
  839. // }
  840. }
  841. break;
  842. case 2: //TCP心跳
  843. {
  844. const char* req = "0";
  845. TcpClient::instance()->sendMsg(req);
  846. }
  847. break;
  848. // case HELP_TIMER_HANDLE:
  849. // {
  850. // SetPainterInfo(0xFFFFFFFF,"");
  851. // setHelpButton("/button/button_help2.png", true);
  852. // setReinforce(false); // 设置增援状态为false
  853. //// //取消计时
  854. //// if (isHelpTimerRegistered) {
  855. //// mActivityPtr->unregisterUserTimer(HELP_TIMER_HANDLE);
  856. //// isHelpTimerRegistered = false;
  857. //// }
  858. // return false;
  859. // }
  860. // break;
  861. case SOS_CLICK_TIME_HANDLE: {
  862. sosTimerRegistered = true;
  863. return false;
  864. }
  865. break;
  866. case SOS_LAMP_TIME_HANDLE: {
  867. // SOS还原成无灯光的状态
  868. std::string heartStr = "ULED,0F";
  869. const char* sendMsg = heartStr.c_str();
  870. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg), strlen(sendMsg));
  871. // 门灯还原成无灯光的状态
  872. std::string heartStr2 = "DOORLED,000F";
  873. const char* sendMsg2 = heartStr2.c_str();
  874. sendProtocolTo(UART_TTYS2, (byte*)(sendMsg2), strlen(sendMsg2));
  875. return false;
  876. }
  877. break;
  878. case SLEEP_STRAT_TIME_HANDLE: { // 息屏
  879. if (isSleepTimerRegistered) {
  880. isSleep = true;
  881. BRIGHTNESSHELPER->screenOff();
  882. } else { // 如果是false的话,就需要关闭定时器
  883. isSleep = false;
  884. BRIGHTNESSHELPER->screenOn();
  885. }
  886. }
  887. break;
  888. default:
  889. break;
  890. }
  891. return true;
  892. }
  893. /**
  894. * 有新的触摸事件时触发
  895. * 参数:ev
  896. * 新的触摸事件
  897. * 返回值:true
  898. * 表示该触摸事件在此被拦截,系统不再将此触摸事件传递到控件上
  899. * false
  900. * 触摸事件将继续传递到控件上
  901. */
  902. static bool onstartActivityTouchEvent(const MotionEvent &ev) {
  903. switch (ev.mActionStatus) {
  904. case MotionEvent::E_ACTION_DOWN://触摸按下
  905. //LOGD("时刻 = %ld 坐标 x = %d, y = %d", ev.mEventTime, ev.mX, ev.mY);
  906. break;
  907. case MotionEvent::E_ACTION_MOVE://触摸滑动
  908. break;
  909. case MotionEvent::E_ACTION_UP: //触摸抬起
  910. break;
  911. default:
  912. break;
  913. }
  914. return false;
  915. }