ec800m.c 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656
  1. #include "CONFIG.h"
  2. #if EC800M
  3. #include "stm32f10x.h"
  4. #include <stdio.h>
  5. #include <stdarg.h>
  6. #include <string.h>
  7. #include <stdlib.h>
  8. #include "ec800m.h"
  9. #include "Common_Util.h"
  10. #include "Log_Module.h"
  11. #include "At_Module.h"
  12. /**
  13. * 龙三郎
  14. **/
  15. // 方法声明
  16. void ec800m_reset(void); // 重置状态。该文件中的方法共用状态,在使用下面的方法前需要重置一下状态。
  17. void ec800m_exit_sleep(void); // 退出休眠
  18. void ec800m_enter_sleep(void); // 进入休眠
  19. /**
  20. * 查询休眠模式
  21. * 输入<<
  22. *
  23. * 输出>>
  24. * n 睡眠模式。0 禁用,默认;1 启用。
  25. **/
  26. enum Result ec800m_query_sleep(uint8_t * n); // 查询休眠模式。
  27. enum Result ec800m_query_sleep_sync(uint8_t * n); // 查询休眠模式。同步
  28. /**
  29. * 设置休眠模式
  30. * 输入<<
  31. * n 参数。0 禁用;1启用。
  32. * 输出>>
  33. *
  34. **/
  35. enum Result ec800m_set_sleep(uint8_t n); // 设置休眠模式。
  36. enum Result ec800m_set_sleep_sync(uint8_t n); // 设置休眠模式。同步
  37. /**
  38. * 设置功能模式
  39. * 输入<<
  40. * fun 0 最小功能模式;1 全功能模式。
  41. * 输出>>
  42. *
  43. **/
  44. enum Result ec800m_set_cfun(uint8_t fun);
  45. enum Result ec800m_set_cfun_sync(uint8_t fun); // 同步
  46. /**
  47. * 设置ps域网络注册状态
  48. * 输入<<
  49. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  50. * 输出>>
  51. *
  52. **/
  53. enum Result ec800m_set_cgreg(uint8_t n);
  54. enum Result ec800m_set_cgreg_sync(uint8_t n); // 同步
  55. /**
  56. * 查询ps域网络注册状态
  57. * 输入<<
  58. *
  59. * 输出>>
  60. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  61. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  62. * lac 基站位置区号。用于基站定位,2个字节。
  63. * ci 基站小区ID。用于基站定位,4个字节。
  64. *
  65. **/
  66. enum Result ec800m_query_cgreg(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci);
  67. enum Result ec800m_query_cgreg_sync(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci); // 同步
  68. /**
  69. * 查询socket服务状态
  70. * 输入<<
  71. * connectID Socket ID。范围1-11
  72. *
  73. * 输出>>
  74. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  75. *
  76. *
  77. **/
  78. enum Result ec800m_query_socket_state(uint8_t connectID, uint8_t * state);
  79. enum Result ec800m_query_socket_state_sync(uint8_t connectID, uint8_t * state); // 同步
  80. /**
  81. * 打开socket服务
  82. * 输入<<
  83. * connectID Socket ID。范围1-11
  84. * service_type Socket服务类型。取值为"UDP", "TCP"。
  85. * IP_address 远程服务器地址
  86. * remote_port 远程服务器端口
  87. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  88. *
  89. * 输出>>
  90. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  91. *
  92. **/
  93. enum Result ec800m_open_socket(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err);
  94. enum Result ec800m_open_socket_sync(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err); // 同步
  95. /**
  96. * 关闭socket服务
  97. * 输入<<
  98. * connectID Socket ID。范围1-11
  99. *
  100. * 输出>>
  101. *
  102. **/
  103. enum Result ec800m_close_socket(uint8_t connectID);
  104. enum Result ec800m_close_socket_sync(uint8_t connectID); // 同步
  105. /**
  106. * 解释:控制是否回显AT+QISEND要发送的数据
  107. * 为了便于处理返回,发送数据时需要关闭回显。
  108. * 输入<<
  109. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  110. *
  111. * 输出>>
  112. *
  113. **/
  114. enum Result ec800m_set_qisde(uint8_t echo);
  115. enum Result ec800m_set_qisde_sync(uint8_t echo); // 同步
  116. /**
  117. * 发送数据
  118. * 输入<<
  119. * connectID Socket ID。范围1-11。
  120. * send_length 发送长度。
  121. * data 待发送的数据。
  122. *
  123. *
  124. **/
  125. enum Result ec800m_send(uint8_t connectID, uint8_t * data, uint16_t data_length);
  126. enum Result ec800m_send_sync(uint8_t connectID, uint8_t * data, uint16_t data_length); // 同步
  127. /**
  128. * 接收数据
  129. * 输入<<
  130. * connectID Socket ID。范围0-11。
  131. *
  132. * 输出>>
  133. * data 接收的数据。
  134. * data_length 接收的数据长度。
  135. **/
  136. enum Result ec800m_recv(uint8_t connectID, uint8_t * data, uint16_t * data_length); // 接收数据
  137. /**
  138. * 接收数据。带计时
  139. * 输入<<
  140. * connectID Socket ID。范围0-11。
  141. *
  142. * 输出>>
  143. * data 接收的数据。
  144. * data_length 接收的数据长度。
  145. *
  146. **/
  147. enum Result ec800m_recv_with_time(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out);
  148. enum Result ec800m_recv_with_time_sync(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out); // 同步
  149. /**
  150. * 解释:关闭模块
  151. * 关闭模块,关闭后会自动重启。
  152. * 输入<<
  153. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  154. *
  155. *
  156. **/
  157. enum Result ec800m_power_down(uint8_t n);
  158. enum Result ec800m_power_down_sync(uint8_t n); // 同步
  159. /**
  160. * 模块是否启动成功
  161. * 输入<<
  162. *
  163. * 输出>>
  164. *
  165. **/
  166. enum Result ec800m_ready(void);
  167. /**
  168. * 查询信号质量
  169. * 输入<<
  170. *
  171. * 输出>>
  172. * RSRP
  173. * RSRQ
  174. * RSSI
  175. * SINR
  176. **/
  177. enum Result ec800m_qeng_servingcell(int * RSRP, int * RSRQ, int * RSSI, int * SINR);
  178. enum Result ec800m_qeng_servingcell_sync(int * RSRP, int * RSRQ, int * RSSI, int * SINR);
  179. /**
  180. * 查询ICCID
  181. * 输入<<
  182. *
  183. * 输出>>
  184. * iccid SIM卡卡号
  185. **/
  186. enum Result ec800m_query_qccid(char * iccid);
  187. enum Result ec800m_query_qccid_sync(char * iccid);
  188. // AT指令
  189. static char AT_CMD[256];
  190. // EC800M提供的一些方法
  191. struct EC800M_Struct ec800m =
  192. {
  193. .timer = {
  194. .time = 0,
  195. .flag = 0
  196. },
  197. .reset = ec800m_reset,
  198. .exit_sleep = ec800m_exit_sleep,
  199. .enter_sleep = ec800m_enter_sleep,
  200. .query_sleep = ec800m_query_sleep,
  201. .query_sleep_sync = ec800m_query_sleep_sync,
  202. .set_sleep = ec800m_set_sleep,
  203. .set_sleep_sync = ec800m_set_sleep_sync,
  204. .set_cfun = ec800m_set_cfun,
  205. .set_cfun_sync = ec800m_set_cfun_sync,
  206. .set_cgreg = ec800m_set_cgreg,
  207. .set_cgreg_sync = ec800m_set_cgreg_sync,
  208. .query_cgreg = ec800m_query_cgreg,
  209. .query_cgreg_sync = ec800m_query_cgreg_sync,
  210. .query_socket_state = ec800m_query_socket_state,
  211. .query_socket_state_sync = ec800m_query_socket_state_sync,
  212. .open_socket = ec800m_open_socket,
  213. .open_socket_sync = ec800m_open_socket_sync,
  214. .close_socket = ec800m_close_socket,
  215. .close_socket_sync = ec800m_close_socket_sync,
  216. .set_qisde = ec800m_set_qisde,
  217. .set_qisde_sync = ec800m_set_qisde_sync,
  218. .send = ec800m_send,
  219. .send_sync = ec800m_send_sync,
  220. .recv = ec800m_recv,
  221. .recv_with_time = ec800m_recv_with_time,
  222. .recv_with_time_sync = ec800m_recv_with_time_sync,
  223. .power_down = ec800m_power_down,
  224. .power_down_sync = ec800m_power_down_sync,
  225. .ready = ec800m_ready,
  226. .qeng_servingcell = ec800m_qeng_servingcell,
  227. .qeng_servingcell_sync = ec800m_qeng_servingcell_sync,
  228. .query_qccid = ec800m_query_qccid,
  229. .query_qccid_sync = ec800m_query_qccid_sync
  230. };
  231. // 发送AT指令
  232. static void send_data(uint8_t * data, uint16_t length)
  233. {
  234. // 发送AT指令
  235. AT_Send_Bytes(data, length);
  236. }
  237. // 发送AT指令
  238. static uint8_t send_at_string(char * cmd)
  239. {
  240. uint8_t state = 0;
  241. if(AT_Get_Status() == AT_Status_None)
  242. {
  243. // 发送AT指令
  244. AT_Send_String(cmd);
  245. state = 1;
  246. }
  247. return state;
  248. }
  249. // 获取状态
  250. static enum STATUS getStatus(void)
  251. {
  252. return ec800m.status;
  253. }
  254. // 设置状态
  255. static void setStatus(enum STATUS status)
  256. {
  257. ec800m.status = status;
  258. }
  259. // 获取定时
  260. static uint32_t getTimerMs(void)
  261. {
  262. return time_get_delay(&ec800m.timer);
  263. }
  264. // 清除定时
  265. static void clearTimer(void)
  266. {
  267. time_clear(&ec800m.timer);
  268. }
  269. // 设置定时
  270. //static void setTimerMs(uint32_t time)
  271. //{
  272. // ec800m.timer_ms = time;
  273. //}
  274. // 获取ID
  275. static uint8_t getActiveID(void)
  276. {
  277. return ec800m.activeID;
  278. }
  279. static void setActiveID(uint8_t activeID)
  280. {
  281. ec800m.activeID = activeID;
  282. }
  283. // 验证ID
  284. static uint8_t verifyActiveID(uint8_t activeID)
  285. {
  286. if(getActiveID() == 0 || getActiveID() == activeID){ return 1; }
  287. else
  288. {
  289. Log_Printf_Debug("activeID repetition!\r\n");
  290. return 0;
  291. }
  292. }
  293. // 返回超时结果
  294. static enum Result overtime(void)
  295. {
  296. setStatus(Status_Overtime); // 超时
  297. return Result_Failed; // 结果
  298. }
  299. // 返回成功结果
  300. static enum Result success(void)
  301. {
  302. // 成功
  303. setStatus(Status_Success);
  304. // 结果
  305. return Result_Success;
  306. }
  307. // 返回失败结果
  308. static enum Result failed(void)
  309. {
  310. // 失败
  311. setStatus(Status_Failed);
  312. // 失败结果
  313. return Result_Failed;
  314. }
  315. // 重置状态。该文件中的方法共用状态,在使用方法前需要重置一下状态。
  316. void ec800m_reset(void)
  317. {
  318. setStatus(Status_None); // 重置状态
  319. setActiveID(0); // 重置ID
  320. clearTimer(); // 重置计时
  321. AT_Clear(); // 清除AT指令
  322. }
  323. // 退出休眠
  324. void ec800m_exit_sleep(void)
  325. {
  326. GPIO_ResetBits(WAKE_GPIO, WAKE_GPIO_Pin); // 拉低io口,唤醒模组
  327. }
  328. // 进入休眠
  329. void ec800m_enter_sleep(void)
  330. {
  331. GPIO_SetBits(WAKE_GPIO, WAKE_GPIO_Pin); // 拉高io口,进入睡眠
  332. }
  333. // 发送指令并改变状态
  334. enum Result send_at(char * cmd, uint8_t activeID)
  335. {
  336. Log_Printf_Debug(cmd); // 打印AT指令
  337. if(send_at_string(cmd)) // 发送AT指令
  338. {
  339. setActiveID(activeID); // 活动ID
  340. setStatus(Status_Sending); // 设置已发送
  341. clearTimer(); // 重置计时
  342. return Result_None; // 未知结果
  343. }
  344. else
  345. {
  346. Log_Printf_Debug("AT指令发送失败\r\n"); // 打印日志
  347. return Result_Failed; // 失败结果
  348. }
  349. }
  350. /**
  351. * 查询休眠模式
  352. * 输入<<
  353. *
  354. * 输出>>
  355. * n 睡眠模式。0 禁用,默认;1 启用。
  356. *
  357. **/
  358. enum Result ec800m_query_sleep(uint8_t * n)
  359. {
  360. enum Result result = Result_None;
  361. int activeID = 1, time = 500; // 活动ID, 超时时间
  362. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  363. // 判断状态
  364. if(getStatus() == Status_None) // 空闲状态
  365. {
  366. sprintf(AT_CMD, "AT+QSCLK?\r\r\n"); // 拼接AT指令
  367. result = send_at(AT_CMD, activeID);
  368. }
  369. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  370. {
  371. Log_Printf_Debug("返回结果过期1,请重置状态\r\n"); // 打印日志
  372. result = failed(); // 失败
  373. }
  374. else if(getTimerMs() > time) // 正在发送状态。判断超时
  375. {
  376. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  377. result = overtime(); // 超时
  378. }
  379. if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  380. {
  381. // 发送日志
  382. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  383. Log_SendArray_Debug(AT_result(), AT_result_length());
  384. // 处理返回结果
  385. char * saveptr = NULL;
  386. char * split = "\r\n";
  387. // 第一行
  388. char * Line1 = strtok_r((char * )AT_result(), split, &saveptr);
  389. // 第二行
  390. char * Line2 = strtok_r(NULL, split, &saveptr);
  391. // 拆解第二行
  392. char * saveptr_inner = NULL;
  393. char * split_inner = ": ";
  394. strtok_r(Line2, split_inner, &saveptr_inner);
  395. // 获取mode
  396. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  397. result = success(); // 成功
  398. }
  399. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  400. {
  401. // 发送日志
  402. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  403. Log_SendArray_Debug(AT_result(), AT_result_length());
  404. result = failed(); // 失败
  405. }
  406. return result;
  407. }
  408. /**
  409. * 查询休眠模式。同步方法
  410. * 输入<<
  411. *
  412. * 输出>>
  413. * n 睡眠模式。0 禁用,默认;1 启用。
  414. *
  415. **/
  416. enum Result ec800m_query_sleep_sync(uint8_t * n)
  417. {
  418. enum Result result = Result_None;
  419. while(1)
  420. {
  421. result = ec800m_query_sleep(n);
  422. if(result != Result_None)
  423. {
  424. // 重置
  425. ec800m.reset();
  426. break;
  427. }
  428. }
  429. return result;
  430. }
  431. /**
  432. * 设置休眠模式
  433. * n 参数。0 禁用;1启用。
  434. **/
  435. enum Result ec800m_set_sleep(uint8_t n)
  436. {
  437. enum Result result = Result_None;
  438. int activeID = 2, time = 500; // 活动ID, 超时时间
  439. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  440. // 判断状态
  441. if(getStatus() == Status_None) // 空闲状态
  442. {
  443. sprintf(AT_CMD, "AT+QSCLK=%d\r\r\n", n); // 拼接AT指令
  444. result = send_at(AT_CMD, activeID);
  445. }
  446. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  447. {
  448. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  449. result = failed(); // 失败
  450. }
  451. else if(getTimerMs() > time) // 正在发送状态。判断超时
  452. {
  453. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  454. result = overtime(); // 超时
  455. }
  456. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  457. {
  458. // 发送日志
  459. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  460. Log_SendArray_Debug(AT_result(), AT_result_length());
  461. result = success(); // 成功
  462. }
  463. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  464. {
  465. // 发送日志
  466. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  467. Log_SendArray_Debug(AT_result(), AT_result_length());
  468. result = failed(); // 失败
  469. }
  470. return result;
  471. }
  472. /**
  473. * 设置休眠模式。同步
  474. * n 参数。0 禁用;1启用。
  475. **/
  476. enum Result ec800m_set_sleep_sync(uint8_t n)
  477. {
  478. enum Result result = Result_None;
  479. while(1)
  480. {
  481. result = ec800m_set_sleep(n);
  482. if(result != Result_None)
  483. {
  484. // 重置
  485. ec800m.reset();
  486. break;
  487. }
  488. }
  489. return result;
  490. }
  491. /**
  492. * 设置功能模式
  493. * fun 0 最小功能模式;1 全功能模式。
  494. **/
  495. enum Result ec800m_set_cfun(uint8_t fun)
  496. {
  497. enum Result result = Result_None;
  498. int activeID = 4, time; // 活动ID, 超时时间
  499. // 校验参数
  500. if(fun == 0){ time = 3000; }
  501. else if(fun == 1){ time = 5000; }
  502. else
  503. {
  504. Log_Printf_Debug("set_cfun params error!\r\n");
  505. return Result_Failed;
  506. }
  507. // 校验ID
  508. if(!verifyActiveID(activeID)){ return Result_Failed; }
  509. // 判断状态
  510. if(getStatus() == Status_None) // 空闲状态
  511. {
  512. sprintf(AT_CMD, "AT+CFUN=%d\r\r\n", fun); // 拼接AT指令
  513. result = send_at(AT_CMD, activeID);
  514. }
  515. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  516. {
  517. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  518. result = failed(); // 失败
  519. }
  520. else if(getTimerMs() > time) // 正在发送状态。判断超时
  521. {
  522. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  523. result = overtime(); // 超时
  524. }
  525. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  526. {
  527. // 防止接收不完整
  528. if(AT_wait_time() > 10) // 过10ms之后再取数据,避免数据截断。
  529. {
  530. // 发送日志
  531. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  532. Log_SendArray_Debug(AT_result(), AT_result_length());
  533. result = success(); // 成功
  534. }
  535. }
  536. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  537. {
  538. // 发送日志
  539. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  540. Log_SendArray_Debug(AT_result(), AT_result_length());
  541. result = failed(); // 失败
  542. }
  543. return result;
  544. }
  545. /**
  546. * 设置功能模式
  547. * 输入<<
  548. * fun 0 最小功能模式;1 全功能模式。
  549. * 输出>>
  550. *
  551. **/
  552. enum Result ec800m_set_cfun_sync(uint8_t fun)
  553. {
  554. enum Result result = Result_None;
  555. while(1)
  556. {
  557. result = ec800m_set_cfun(fun);
  558. if(result != Result_None)
  559. {
  560. // 重置
  561. ec800m.reset();
  562. break;
  563. }
  564. }
  565. return result;
  566. }
  567. /**
  568. * 设置ps域网络注册状态
  569. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  570. **/
  571. enum Result ec800m_set_cgreg(uint8_t n)
  572. {
  573. enum Result result = Result_None;
  574. int activeID = 6, time = 500; // 活动ID, 超时时间
  575. // 校验参数
  576. if(n > 2)
  577. {
  578. Log_Printf_Debug("set_cgreg params error!\r\n");
  579. return Result_Failed;
  580. }
  581. // 校验ID
  582. if(!verifyActiveID(activeID)){ return Result_Failed; }
  583. // 判断状态
  584. if(getStatus() == Status_None) // 空闲状态
  585. {
  586. sprintf(AT_CMD, "AT+CGREG=%d\r\r\n", n); // 拼接AT指令
  587. result = send_at(AT_CMD, activeID);
  588. }
  589. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  590. {
  591. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  592. result = failed(); // 失败
  593. }
  594. else if(getTimerMs() > time) // 正在发送状态。判断超时
  595. {
  596. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  597. result = overtime(); // 超时
  598. }
  599. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  600. {
  601. // 发送日志
  602. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  603. Log_SendArray_Debug(AT_result(), AT_result_length());
  604. result = success(); // 成功
  605. }
  606. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  607. {
  608. // 发送日志
  609. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  610. Log_SendArray_Debug(AT_result(), AT_result_length());
  611. result = failed(); // 失败
  612. }
  613. return result;
  614. }
  615. /**
  616. * 设置ps域网络注册状态
  617. * 输入<<
  618. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  619. * 输出>>
  620. *
  621. **/
  622. enum Result ec800m_set_cgreg_sync(uint8_t n)
  623. {
  624. enum Result result = Result_None;
  625. while(1)
  626. {
  627. result = ec800m_set_cgreg(n);
  628. if(result != Result_None)
  629. {
  630. // 重置
  631. ec800m.reset();
  632. break;
  633. }
  634. }
  635. return result;
  636. }
  637. /**
  638. * 查询ps域网络注册状态
  639. * 输入<<
  640. *
  641. * 输出>>
  642. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  643. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  644. * lac 基站位置区号。用于基站定位,2个字节。
  645. * ci 基站小区ID。用于基站定位,4个字节。
  646. *
  647. **/
  648. enum Result ec800m_query_cgreg(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci)
  649. {
  650. enum Result result = Result_None;
  651. int activeID = 9, time = 500; // 活动ID, 超时时间
  652. // 校验ID
  653. if(!verifyActiveID(activeID)){ return Result_Failed; }
  654. // 判断状态
  655. if(getStatus() == Status_None) // 空闲状态
  656. {
  657. sprintf(AT_CMD, "AT+CGREG?\r\r\n"); // 拼接AT指令
  658. result = send_at(AT_CMD, activeID);
  659. }
  660. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  661. {
  662. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  663. result = failed(); // 失败
  664. }
  665. else if(getTimerMs() > time) // 正在发送状态。判断超时
  666. {
  667. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  668. result = overtime(); // 超时
  669. }
  670. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  671. {
  672. // 发送日志
  673. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  674. Log_SendArray_Debug(AT_result(), AT_result_length());
  675. // 处理返回结果
  676. char * saveptr = NULL;
  677. char * split = "\r\n";
  678. // 第一行
  679. strtok_r((char * )AT_result(), split, &saveptr);
  680. // 第二行
  681. char * Line2 = strtok_r(NULL, split, &saveptr);
  682. // 拆解第二行
  683. char * saveptr_inner = NULL;
  684. char * split_inner = ": ,\"";
  685. strtok_r(Line2, split_inner, &saveptr_inner);
  686. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  687. * stat = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  688. * lac = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  689. * ci = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  690. // 打印
  691. Log_Printf_Debug("mode: %d, stat: %d, lac: %d, ci: %d\r\n", * n, * stat, * lac, * ci);
  692. result = success(); // 成功
  693. }
  694. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  695. {
  696. // 发送日志
  697. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  698. Log_SendArray_Debug(AT_result(), AT_result_length());
  699. result = failed(); // 失败
  700. }
  701. return result;
  702. }
  703. /**
  704. * 查询ps域网络注册状态
  705. * 输入<<
  706. *
  707. * 输出>>
  708. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  709. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  710. * lac 基站位置区号。用于基站定位,2个字节。
  711. * ci 基站小区ID。用于基站定位,4个字节。
  712. *
  713. **/
  714. enum Result ec800m_query_cgreg_sync(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci)
  715. {
  716. enum Result result = Result_None;
  717. while(1)
  718. {
  719. result = ec800m_query_cgreg(n, stat, lac, ci);
  720. if(result != Result_None)
  721. {
  722. // 重置
  723. ec800m.reset();
  724. break;
  725. }
  726. }
  727. return result;
  728. }
  729. /**
  730. * 查询socket服务状态
  731. * connectID Socket ID。范围1-11
  732. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  733. *
  734. * activeID 9
  735. **/
  736. enum Result ec800m_query_socket_state(uint8_t connectID, uint8_t * state)
  737. {
  738. enum Result result = Result_None;
  739. int activeID = 9, time = 500; // 活动ID, 超时时间
  740. // 校验ID
  741. if(!verifyActiveID(activeID)){ return Result_Failed; }
  742. // 判断状态
  743. if(getStatus() == Status_None) // 空闲状态
  744. {
  745. sprintf(AT_CMD, "AT+QISTATE=1,%d\r\r\n", connectID); // 拼接AT指令
  746. result = send_at(AT_CMD, activeID);
  747. }
  748. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  749. {
  750. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  751. result = failed(); // 失败
  752. }
  753. else if(getTimerMs() > time) // 正在发送状态。判断超时
  754. {
  755. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  756. result = overtime(); // 超时
  757. }
  758. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  759. {
  760. // 发送日志
  761. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  762. Log_SendArray_Debug(AT_result(), AT_result_length());
  763. // 处理返回结果
  764. char * saveptr = NULL;
  765. char * split = "\r\n";
  766. // 第一行
  767. strtok_r((char * )AT_result(), split, &saveptr);
  768. // 第二行
  769. char * Line2 = strtok_r(NULL, split, &saveptr);
  770. // 查询结果为空
  771. if(strcmp(Line2, "OK") == 0){ * state = 0; }
  772. else
  773. {
  774. // 拆解第二行
  775. char * saveptr_inner = NULL;
  776. char * split_inner = ": ,\"";
  777. strtok_r(Line2, split_inner, &saveptr_inner);
  778. strtok_r(NULL, split_inner, &saveptr_inner);
  779. strtok_r(NULL, split_inner, &saveptr_inner);
  780. strtok_r(NULL, split_inner, &saveptr_inner);
  781. strtok_r(NULL, split_inner, &saveptr_inner);
  782. strtok_r(NULL, split_inner, &saveptr_inner);
  783. * state = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  784. }
  785. // 打印
  786. Log_Printf_Debug("result: %d\r\n", * state);
  787. result = success(); // 成功
  788. }
  789. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  790. {
  791. // 发送日志
  792. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  793. Log_SendArray_Debug(AT_result(), AT_result_length());
  794. result = failed(); // 失败
  795. }
  796. return result;
  797. }
  798. /**
  799. * 查询socket服务状态
  800. * connectID Socket ID。范围1-11
  801. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  802. *
  803. * activeID 9
  804. **/
  805. enum Result ec800m_query_socket_state_sync(uint8_t connectID, uint8_t * state)
  806. {
  807. enum Result result = Result_None;
  808. while(1)
  809. {
  810. result = ec800m_query_socket_state(connectID, state);
  811. if(result != Result_None)
  812. {
  813. // 重置
  814. ec800m.reset();
  815. break;
  816. }
  817. }
  818. return result;
  819. }
  820. /**
  821. * 打开socket服务
  822. * 输入<<
  823. * connectID Socket ID。范围1-11
  824. * service_type Socket服务类型。取值为"UDP", "TCP"。
  825. * IP_address 远程服务器地址
  826. * remote_port 远程服务器端口
  827. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  828. *
  829. * 输出>>
  830. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  831. *
  832. * activeID 19
  833. **/
  834. enum Result ec800m_open_socket(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err)
  835. {
  836. enum Result result = Result_None;
  837. int activeID = 19, time = 3000; // 活动ID, 超时时间
  838. // 校验ID
  839. if(!verifyActiveID(activeID)){ return Result_Failed; }
  840. // 判断状态
  841. if(getStatus() == Status_None) // 空闲状态
  842. {
  843. sprintf(AT_CMD, "AT+QIOPEN=1,%d,\"%s\",\"%s\",%d,%d,%d\r\r\n", connectID, service_type, IP_address, remote_port, 0, access_mode); // 拼接AT指令
  844. result = send_at(AT_CMD, activeID);
  845. }
  846. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  847. {
  848. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  849. result = failed(); // 失败
  850. }
  851. else if(getTimerMs() > time) // 正在发送状态。判断超时
  852. {
  853. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  854. result = overtime(); // 超时
  855. }
  856. else if(strstr((char * )AT_result(), "+QIOPEN: ") != NULL) // 查询是否返回
  857. {
  858. // 发送日志
  859. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  860. Log_SendArray_Debug(AT_result(), AT_result_length());
  861. // 处理返回结果
  862. char * saveptr = NULL;
  863. char * split = "\r\n";
  864. // 第一行
  865. strtok_r((char * )AT_result(), split, &saveptr);
  866. // 第二行
  867. char * Line2 = strtok_r(NULL, split, &saveptr);
  868. // 第三行
  869. char * Line3 = strtok_r(NULL, split, &saveptr);
  870. // 查询结果为空
  871. if(strcmp(Line2, "OK") == 0)
  872. {
  873. // 拆解第三行
  874. char * saveptr_inner = NULL;
  875. char * split_inner = ": ,\"";
  876. strtok_r(Line3, split_inner, &saveptr_inner);
  877. uint8_t connID = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  878. * err = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  879. Log_Printf_Debug("result: %d, %d\r\n", connID, * err);
  880. }
  881. result = success(); // 成功
  882. }
  883. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  884. {
  885. // 发送日志
  886. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  887. Log_SendArray_Debug(AT_result(), AT_result_length());
  888. result = failed(); // 失败
  889. }
  890. return result;
  891. }
  892. /**
  893. * 打开socket服务
  894. * 输入<<
  895. * connectID Socket ID。范围1-11
  896. * service_type Socket服务类型。取值为"UDP", "TCP"。
  897. * IP_address 远程服务器地址
  898. * remote_port 远程服务器端口
  899. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  900. *
  901. * 输出>>
  902. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  903. *
  904. * activeID 19
  905. **/
  906. enum Result ec800m_open_socket_sync(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err)
  907. {
  908. enum Result result = Result_None;
  909. while(1)
  910. {
  911. result = ec800m_open_socket(connectID, service_type, IP_address, remote_port, access_mode, err);
  912. if(result != Result_None)
  913. {
  914. // 重置
  915. ec800m.reset();
  916. break;
  917. }
  918. }
  919. return result;
  920. }
  921. /**
  922. * 关闭socket服务
  923. * 输入<<
  924. * connectID Socket ID。范围1-11
  925. *
  926. * activeID 29
  927. **/
  928. enum Result ec800m_close_socket(uint8_t connectID)
  929. {
  930. enum Result result = Result_None;
  931. int activeID = 29, time = 500; // 活动ID, 超时时间
  932. // 校验ID
  933. if(!verifyActiveID(activeID)){ return Result_Failed; }
  934. // 判断状态
  935. if(getStatus() == Status_None) // 空闲状态
  936. {
  937. sprintf(AT_CMD, "AT+QICLOSE=%d\r\r\n", connectID); // 拼接AT指令
  938. result = send_at(AT_CMD, activeID);
  939. }
  940. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  941. {
  942. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  943. result = failed(); // 失败
  944. }
  945. else if(getTimerMs() > time) // 正在发送状态。判断超时
  946. {
  947. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  948. result = overtime(); // 超时
  949. }
  950. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  951. {
  952. // 发送日志
  953. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  954. Log_SendArray_Debug(AT_result(), AT_result_length());
  955. result = success(); // 成功
  956. }
  957. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  958. {
  959. // 发送日志
  960. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  961. Log_SendArray_Debug(AT_result(), AT_result_length());
  962. result = failed(); // 失败
  963. }
  964. return result;
  965. }
  966. /**
  967. * 关闭socket服务
  968. * 输入<<
  969. * connectID Socket ID。范围1-11
  970. *
  971. * activeID 29
  972. **/
  973. enum Result ec800m_close_socket_sync(uint8_t connectID)
  974. {
  975. enum Result result = Result_None;
  976. while(1)
  977. {
  978. result = ec800m_close_socket(connectID);
  979. if(result != Result_None)
  980. {
  981. // 重置
  982. ec800m.reset();
  983. break;
  984. }
  985. }
  986. return result;
  987. }
  988. /**
  989. * 解释:控制是否回显AT+QISEND要发送的数据
  990. * 为了便于处理返回,发送数据时需要关闭回显。
  991. * 输入<<
  992. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  993. *
  994. * activeID 45
  995. **/
  996. enum Result ec800m_set_qisde(uint8_t echo)
  997. {
  998. enum Result result = Result_None;
  999. int activeID = 45, time = 500; // 活动ID, 超时时间
  1000. // 校验ID
  1001. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1002. // 判断状态
  1003. if(getStatus() == Status_None) // 空闲状态
  1004. {
  1005. sprintf(AT_CMD, "AT+QISDE=%d\r\r\n", echo); // 拼接AT指令
  1006. result = send_at(AT_CMD, activeID);
  1007. }
  1008. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1009. {
  1010. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1011. result = failed(); // 失败
  1012. }
  1013. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1014. {
  1015. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1016. result = overtime(); // 超时
  1017. }
  1018. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1019. {
  1020. // 发送日志
  1021. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1022. Log_SendArray_Debug(AT_result(), AT_result_length());
  1023. result = success(); // 成功
  1024. }
  1025. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1026. {
  1027. // 发送日志
  1028. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1029. Log_SendArray_Debug(AT_result(), AT_result_length());
  1030. result = failed(); // 失败
  1031. }
  1032. return result;
  1033. }
  1034. /**
  1035. * 解释:控制是否回显AT+QISEND要发送的数据
  1036. * 为了便于处理返回,发送数据时需要关闭回显。
  1037. * 输入<<
  1038. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  1039. *
  1040. * activeID 45
  1041. **/
  1042. enum Result ec800m_set_qisde_sync(uint8_t echo)
  1043. {
  1044. enum Result result = Result_None;
  1045. while(1)
  1046. {
  1047. result = ec800m_set_qisde(echo);
  1048. if(result != Result_None)
  1049. {
  1050. // 重置
  1051. ec800m.reset();
  1052. break;
  1053. }
  1054. }
  1055. return result;
  1056. }
  1057. /**
  1058. * 发送数据
  1059. * 输入<<
  1060. * connectID Socket ID。范围1-11。
  1061. * send_length 发送长度。
  1062. * data 待发送的数据。
  1063. *
  1064. * activeID 49
  1065. **/
  1066. enum Result ec800m_send(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1067. {
  1068. enum Result result = Result_None;
  1069. int activeID = 49, time = 10000; // 活动ID, 超时时间
  1070. // 校验ID
  1071. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1072. // 判断状态
  1073. if(getStatus() == Status_None) // 空闲状态
  1074. {
  1075. sprintf(AT_CMD, "AT+QISEND=%d,%d\r\r\n", connectID, data_length); // 拼接AT指令
  1076. result = send_at(AT_CMD, activeID);
  1077. }
  1078. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1079. {
  1080. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1081. result = failed(); // 失败
  1082. }
  1083. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1084. {
  1085. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1086. result = overtime(); // 超时
  1087. }
  1088. else if(strstr((char * )AT_result(), "> ") != NULL) // 有响应
  1089. {
  1090. // 发送日志
  1091. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1092. Log_SendArray_Debug(AT_result(), AT_result_length());
  1093. // Log_Printf_Debug("coap:\r\n");
  1094. // Log_SendHex(data, data_length);
  1095. // Log_Printf_Debug("\r\n");
  1096. // 发送数据
  1097. send_data(data, data_length);
  1098. // 清理一下AT返回结果缓存
  1099. AT_Clear_Result();
  1100. }
  1101. else if(strstr((char * )AT_result(), "SEND OK\r\n") != NULL) // 查询是否返回
  1102. {
  1103. // 发送日志
  1104. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1105. Log_SendArray_Debug(AT_result(), AT_result_length());
  1106. result = success(); // 成功
  1107. }
  1108. else if(strstr((char * )AT_result(), "SEND FALL\r\n") != NULL) // 查询是否返回
  1109. {
  1110. // 发送日志
  1111. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1112. Log_SendArray_Debug(AT_result(), AT_result_length());
  1113. result = failed(); // 失败
  1114. }
  1115. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1116. {
  1117. // 发送日志
  1118. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1119. Log_SendArray_Debug(AT_result(), AT_result_length());
  1120. result = failed(); // 失败
  1121. }
  1122. return result;
  1123. }
  1124. /**
  1125. * 发送数据
  1126. * 输入<<
  1127. * connectID Socket ID。范围1-11。
  1128. * send_length 发送长度。
  1129. * data 待发送的数据。
  1130. *
  1131. * activeID 49
  1132. **/
  1133. enum Result ec800m_send_sync(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1134. {
  1135. enum Result result = Result_None;
  1136. while(1)
  1137. {
  1138. result = ec800m_send(connectID, data, data_length);
  1139. if(result != Result_None)
  1140. {
  1141. // 重置
  1142. ec800m.reset();
  1143. break;
  1144. }
  1145. }
  1146. return result;
  1147. }
  1148. /**
  1149. * 接收数据
  1150. * 输入<<
  1151. * connectID Socket ID。范围0-11。
  1152. *
  1153. * 输出>>
  1154. * data 接收的数据。
  1155. * data_length 接收的数据长度。
  1156. *
  1157. **/
  1158. enum Result ec800m_recv(uint8_t connectID, uint8_t * data, uint16_t * data_length)
  1159. {
  1160. // 设置AT为使用中,防止被其他程序占用
  1161. AT_Set_Status(AT_Status_Using);
  1162. enum Result result = Result_None;
  1163. // 校验参数
  1164. if(connectID > 11)
  1165. {
  1166. Log_Printf_Debug("recv params error!\r\n");
  1167. return Result_Failed;
  1168. }
  1169. char cmp[20];
  1170. sprintf(cmp, "+QIURC: \"recv\",%d", connectID); // 拼接AT指令
  1171. // 判断是否接收到
  1172. if(strstr((char * )AT_result(), cmp) != NULL)
  1173. {
  1174. // 防止接收不完整
  1175. uint32_t last_time = AT_wait_time();
  1176. if(last_time > 10) // 过10ms之后再取数据,避免数据截断。
  1177. {
  1178. // 发送日志
  1179. Log_Printf_Debug("AT返回: %d, time_diff: %d\r\n", AT_result_length(), last_time);
  1180. // Log_SendArray_Debug(AT_result(), AT_result_length());
  1181. char * saveptr = NULL;
  1182. char * split = "\r\n";
  1183. char * Line1 = strtok_r((char * )AT_result(), split, &saveptr);
  1184. uint8_t Line1_Len = strlen(Line1);
  1185. Log_Printf_Debug("Line1(%d): %s\r\n",Line1_Len ,Line1);
  1186. // 分割Line1,获取报文长度
  1187. char * saveptr_inner = NULL;
  1188. char * split_inner = ",";
  1189. strtok_r(Line1, split_inner, &saveptr_inner);
  1190. strtok_r(NULL, split_inner, &saveptr_inner);
  1191. * data_length = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 10);
  1192. uint16_t line_length = Line1_Len + 4;
  1193. // 内存拷贝
  1194. memcpy(data, AT_result() + line_length, * data_length);
  1195. // 成功
  1196. result = Result_Success;
  1197. // 清理一下AT返回结果缓存
  1198. AT_Clear_Result();
  1199. }
  1200. }
  1201. return result;
  1202. }
  1203. /**
  1204. * 接收数据。带计时
  1205. * 输入<<
  1206. * connectID Socket ID。范围0-11。
  1207. *
  1208. * 输出>>
  1209. * data 接收的数据。
  1210. * data_length 接收的数据长度。
  1211. *
  1212. **/
  1213. enum Result ec800m_recv_with_time(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1214. {
  1215. enum Result result = Result_None;
  1216. int activeID = 59, time = time_out; // 活动ID, 超时时间
  1217. // 校验ID
  1218. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1219. // 判断状态
  1220. if(getStatus() == Status_None) // 空闲状态
  1221. {
  1222. setStatus(Status_Sending);
  1223. }
  1224. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1225. {
  1226. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1227. result = failed(); // 失败
  1228. }
  1229. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1230. {
  1231. Log_Printf_Debug("等待时间超时\r\n"); // 打印日志
  1232. result = overtime(); // 超时
  1233. }
  1234. else
  1235. {
  1236. // 接收数据
  1237. result = ec800m.recv(connectID, data, data_length);
  1238. if(result == Result_Success)
  1239. {
  1240. result = success(); // 成功
  1241. }
  1242. }
  1243. return result;
  1244. }
  1245. /**
  1246. * 接收数据。带计时
  1247. * 输入<<
  1248. * connectID Socket ID。范围0-11。
  1249. *
  1250. * 输出>>
  1251. * data 接收的数据。
  1252. * data_length 接收的数据长度。
  1253. *
  1254. **/
  1255. enum Result ec800m_recv_with_time_sync(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1256. {
  1257. enum Result result = Result_None;
  1258. while(1)
  1259. {
  1260. result = ec800m_recv_with_time(connectID, data, data_length, time_out);
  1261. if(result != Result_None)
  1262. {
  1263. // 重置
  1264. ec800m.reset();
  1265. break;
  1266. }
  1267. }
  1268. return result;
  1269. }
  1270. /**
  1271. * 解释:关闭模块
  1272. * 关闭模块,关闭后会自动重启。
  1273. * 输入<<
  1274. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1275. *
  1276. * activeID 69
  1277. **/
  1278. enum Result ec800m_power_down(uint8_t n)
  1279. {
  1280. enum Result result = Result_None;
  1281. int activeID = 69, time = 3000; // 活动ID, 超时时间
  1282. // 校验ID
  1283. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1284. // 判断状态
  1285. if(getStatus() == Status_None) // 空闲状态
  1286. {
  1287. sprintf(AT_CMD, "AT+QPOWD=%d\r\r\n", n); // 拼接AT指令
  1288. result = send_at(AT_CMD, activeID);
  1289. }
  1290. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1291. {
  1292. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1293. result = failed(); // 失败
  1294. }
  1295. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1296. {
  1297. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1298. result = overtime();
  1299. }
  1300. else if(strstr((char * )AT_result(), "POWERED DOWN\r\n") != NULL) // 查询是否返回
  1301. {
  1302. // 发送日志
  1303. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1304. Log_SendArray_Debug(AT_result(), AT_result_length());
  1305. // 成功结果
  1306. result = success();
  1307. }
  1308. return result;
  1309. }
  1310. /**
  1311. * 解释:关闭模块。同步
  1312. * 关闭模块,关闭后会自动重启。
  1313. * 输入<<
  1314. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1315. *
  1316. * activeID 69
  1317. **/
  1318. enum Result ec800m_power_down_sync(uint8_t n)
  1319. {
  1320. enum Result result = Result_None;
  1321. while(1)
  1322. {
  1323. result = ec800m_power_down(n);
  1324. if(result != Result_None)
  1325. {
  1326. // 重置
  1327. ec800m.reset();
  1328. break;
  1329. }
  1330. }
  1331. return result;
  1332. }
  1333. /**
  1334. * 模块是否启动成功
  1335. * 输入<<
  1336. *
  1337. * 输出>>
  1338. *
  1339. **/
  1340. enum Result ec800m_ready(void)
  1341. {
  1342. if(AT_Get_Status() != AT_Status_None)
  1343. {
  1344. return Result_None;
  1345. }
  1346. enum Result result = Result_None;
  1347. // 判断是否接收到
  1348. uint8_t RDY[5]="RDY";
  1349. if(memmem(AT_result(),AT_result_length(),RDY,strlen((char *)RDY)) != 0)
  1350. {
  1351. // 发送日志
  1352. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1353. Log_SendArray_Debug(AT_result(), AT_result_length());
  1354. // 成功结果
  1355. result = Result_Success;
  1356. // 清理一下AT返回结果缓存
  1357. AT_Clear_Result();
  1358. }
  1359. return result;
  1360. }
  1361. /**
  1362. * 查询信号质量
  1363. * 输入<<
  1364. *
  1365. * 输出>>
  1366. * RSRP
  1367. * RSRQ
  1368. * RSSI
  1369. * SINR
  1370. **/
  1371. enum Result ec800m_qeng_servingcell(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1372. {
  1373. enum Result result = Result_None;
  1374. int activeID = 71, time = 500; // 活动ID, 超时时间
  1375. // 校验ID
  1376. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1377. // 判断状态
  1378. if(getStatus() == Status_None) // 空闲状态
  1379. {
  1380. sprintf(AT_CMD, "AT+QENG=\"servingcell\"\r\r\n"); // 拼接AT指令
  1381. result = send_at(AT_CMD, activeID);
  1382. }
  1383. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1384. {
  1385. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1386. result = failed(); // 失败
  1387. }
  1388. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1389. {
  1390. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1391. result = overtime(); // 超时
  1392. }
  1393. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1394. {
  1395. // 发送日志
  1396. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1397. Log_SendArray_Debug(AT_result(), AT_result_length());
  1398. // 处理返回结果
  1399. char * saveptr = NULL;
  1400. char * split = "\r\n";
  1401. // 第一行
  1402. strtok_r((char * )AT_result(), split, &saveptr);
  1403. // 第二行
  1404. char * Line2 = strtok_r(NULL, split, &saveptr);
  1405. // 拆解第二行
  1406. char * saveptr_inner = NULL;
  1407. char * split_inner = ": ,\"";
  1408. strtok_r(Line2, split_inner, &saveptr_inner);
  1409. strtok_r(NULL, split_inner, &saveptr_inner);
  1410. strtok_r(NULL, split_inner, &saveptr_inner);
  1411. strtok_r(NULL, split_inner, &saveptr_inner);
  1412. strtok_r(NULL, split_inner, &saveptr_inner);
  1413. strtok_r(NULL, split_inner, &saveptr_inner);
  1414. strtok_r(NULL, split_inner, &saveptr_inner);
  1415. strtok_r(NULL, split_inner, &saveptr_inner);
  1416. strtok_r(NULL, split_inner, &saveptr_inner);
  1417. strtok_r(NULL, split_inner, &saveptr_inner);
  1418. strtok_r(NULL, split_inner, &saveptr_inner);
  1419. strtok_r(NULL, split_inner, &saveptr_inner);
  1420. strtok_r(NULL, split_inner, &saveptr_inner);
  1421. strtok_r(NULL, split_inner, &saveptr_inner);
  1422. * RSRP = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1423. * RSRQ = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1424. * RSSI = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1425. * SINR = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1426. // 打印
  1427. Log_Printf_Debug("RSRP: %d, RSRQ: %d, RSSI: %d, SINR: %d\r\n", * RSRP, * RSRQ, * RSSI, * SINR);
  1428. result = success(); // 成功
  1429. }
  1430. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1431. {
  1432. // 发送日志
  1433. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1434. Log_SendArray_Debug(AT_result(), AT_result_length());
  1435. result = failed(); // 失败
  1436. }
  1437. return result;
  1438. }
  1439. enum Result ec800m_qeng_servingcell_sync(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1440. {
  1441. enum Result result = Result_None;
  1442. while(1)
  1443. {
  1444. result = ec800m_qeng_servingcell(RSRP, RSRQ, RSSI, SINR);
  1445. if(result != Result_None)
  1446. {
  1447. // 重置
  1448. ec800m.reset();
  1449. break;
  1450. }
  1451. }
  1452. return result;
  1453. }
  1454. /**
  1455. * 查询ICCID
  1456. * 输入<<
  1457. *
  1458. * 输出>>
  1459. * iccid SIM卡卡号
  1460. **/
  1461. enum Result ec800m_query_qccid(char * iccid)
  1462. {
  1463. enum Result result = Result_None;
  1464. int activeID = 75, time = 500; // 活动ID, 超时时间
  1465. // 校验ID
  1466. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1467. // 判断状态
  1468. if(getStatus() == Status_None) // 空闲状态
  1469. {
  1470. sprintf(AT_CMD, "AT+QCCID\r\r\n"); // 拼接AT指令
  1471. result = send_at(AT_CMD, activeID);
  1472. }
  1473. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1474. {
  1475. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1476. result = failed(); // 失败
  1477. }
  1478. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1479. {
  1480. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1481. result = overtime(); // 超时
  1482. }
  1483. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1484. {
  1485. // 发送日志
  1486. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1487. Log_SendArray_Debug(AT_result(), AT_result_length());
  1488. // 处理返回结果
  1489. char * saveptr = NULL;
  1490. char * split = "\r\n";
  1491. // 第一行
  1492. strtok_r((char * )AT_result(), split, &saveptr);
  1493. // 第二行
  1494. char * Line2 = strtok_r(NULL, split, &saveptr);
  1495. // 拆解第二行
  1496. char * saveptr_inner = NULL;
  1497. char * split_inner = ": ,\"";
  1498. strtok_r(Line2, split_inner, &saveptr_inner);
  1499. // 字符串拷贝
  1500. strcpy(iccid, strtok_r(NULL, split_inner, &saveptr_inner));
  1501. // 打印
  1502. Log_Printf_Debug("ICCID: %s\r\n", iccid);
  1503. result = success(); // 成功
  1504. }
  1505. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1506. {
  1507. // 发送日志
  1508. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1509. Log_SendArray_Debug(AT_result(), AT_result_length());
  1510. result = failed(); // 失败
  1511. }
  1512. return result;
  1513. }
  1514. enum Result ec800m_query_qccid_sync(char * iccid)
  1515. {
  1516. enum Result result = Result_None;
  1517. while(1)
  1518. {
  1519. result = ec800m_query_qccid(iccid);
  1520. if(result != Result_None)
  1521. {
  1522. // 重置
  1523. ec800m.reset();
  1524. break;
  1525. }
  1526. }
  1527. return result;
  1528. }
  1529. #endif