ec800m.c 40 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. setStatus(Status_Overtime); // 超时
  669. result = Result_Failed; // 结果
  670. }
  671. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  672. {
  673. // 发送日志
  674. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  675. Log_SendArray_Debug(AT_result(), AT_result_length());
  676. // 处理返回结果
  677. char * saveptr = NULL;
  678. char * split = "\r\n";
  679. // 第一行
  680. strtok_r((char * )AT_result(), split, &saveptr);
  681. // 第二行
  682. char * Line2 = strtok_r(NULL, split, &saveptr);
  683. // 拆解第二行
  684. char * saveptr_inner = NULL;
  685. char * split_inner = ": ,\"";
  686. strtok_r(Line2, split_inner, &saveptr_inner);
  687. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  688. * stat = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  689. * lac = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  690. * ci = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  691. // 打印
  692. Log_Printf_Debug("mode: %d, stat: %d, lac: %d, ci: %d\r\n", * n, * stat, * lac, * ci);
  693. result = success(); // 成功
  694. }
  695. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  696. {
  697. // 发送日志
  698. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  699. Log_SendArray_Debug(AT_result(), AT_result_length());
  700. result = failed(); // 失败
  701. }
  702. return result;
  703. }
  704. /**
  705. * 查询ps域网络注册状态
  706. * 输入<<
  707. *
  708. * 输出>>
  709. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  710. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  711. * lac 基站位置区号。用于基站定位,2个字节。
  712. * ci 基站小区ID。用于基站定位,4个字节。
  713. *
  714. **/
  715. enum Result ec800m_query_cgreg_sync(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci)
  716. {
  717. enum Result result = Result_None;
  718. while(1)
  719. {
  720. result = ec800m_query_cgreg(n, stat, lac, ci);
  721. if(result != Result_None)
  722. {
  723. // 重置
  724. ec800m.reset();
  725. break;
  726. }
  727. }
  728. return result;
  729. }
  730. /**
  731. * 查询socket服务状态
  732. * connectID Socket ID。范围1-11
  733. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  734. *
  735. * activeID 9
  736. **/
  737. enum Result ec800m_query_socket_state(uint8_t connectID, uint8_t * state)
  738. {
  739. enum Result result = Result_None;
  740. int activeID = 9, time = 500; // 活动ID, 超时时间
  741. // 校验ID
  742. if(!verifyActiveID(activeID)){ return Result_Failed; }
  743. // 判断状态
  744. if(getStatus() == Status_None) // 空闲状态
  745. {
  746. sprintf(AT_CMD, "AT+QISTATE=1,%d\r\r\n", connectID); // 拼接AT指令
  747. result = send_at(AT_CMD, activeID);
  748. }
  749. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  750. {
  751. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  752. result = failed(); // 失败
  753. }
  754. else if(getTimerMs() > time) // 正在发送状态。判断超时
  755. {
  756. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  757. result = overtime(); // 超时
  758. }
  759. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  760. {
  761. // 发送日志
  762. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  763. Log_SendArray_Debug(AT_result(), AT_result_length());
  764. // 处理返回结果
  765. char * saveptr = NULL;
  766. char * split = "\r\n";
  767. // 第一行
  768. strtok_r((char * )AT_result(), split, &saveptr);
  769. // 第二行
  770. char * Line2 = strtok_r(NULL, split, &saveptr);
  771. // 查询结果为空
  772. if(strcmp(Line2, "OK") == 0){ * state = 0; }
  773. else
  774. {
  775. // 拆解第二行
  776. char * saveptr_inner = NULL;
  777. char * split_inner = ": ,\"";
  778. strtok_r(Line2, 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. strtok_r(NULL, split_inner, &saveptr_inner);
  784. * state = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  785. }
  786. // 打印
  787. Log_Printf_Debug("result: %d\r\n", * state);
  788. result = success(); // 成功
  789. }
  790. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  791. {
  792. // 发送日志
  793. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  794. Log_SendArray_Debug(AT_result(), AT_result_length());
  795. result = failed(); // 失败
  796. }
  797. return result;
  798. }
  799. /**
  800. * 查询socket服务状态
  801. * connectID Socket ID。范围1-11
  802. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  803. *
  804. * activeID 9
  805. **/
  806. enum Result ec800m_query_socket_state_sync(uint8_t connectID, uint8_t * state)
  807. {
  808. enum Result result = Result_None;
  809. while(1)
  810. {
  811. result = ec800m_query_socket_state(connectID, state);
  812. if(result != Result_None)
  813. {
  814. // 重置
  815. ec800m.reset();
  816. break;
  817. }
  818. }
  819. return result;
  820. }
  821. /**
  822. * 打开socket服务
  823. * 输入<<
  824. * connectID Socket ID。范围1-11
  825. * service_type Socket服务类型。取值为"UDP", "TCP"。
  826. * IP_address 远程服务器地址
  827. * remote_port 远程服务器端口
  828. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  829. *
  830. * 输出>>
  831. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  832. *
  833. * activeID 19
  834. **/
  835. 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)
  836. {
  837. enum Result result = Result_None;
  838. int activeID = 19, time = 3000; // 活动ID, 超时时间
  839. // 校验ID
  840. if(!verifyActiveID(activeID)){ return Result_Failed; }
  841. // 判断状态
  842. if(getStatus() == Status_None) // 空闲状态
  843. {
  844. 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指令
  845. result = send_at(AT_CMD, activeID);
  846. }
  847. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  848. {
  849. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  850. result = failed(); // 失败
  851. }
  852. else if(getTimerMs() > time) // 正在发送状态。判断超时
  853. {
  854. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  855. result = overtime(); // 超时
  856. }
  857. else if(strstr((char * )AT_result(), "+QIOPEN: ") != NULL) // 查询是否返回
  858. {
  859. // 发送日志
  860. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  861. Log_SendArray_Debug(AT_result(), AT_result_length());
  862. // 处理返回结果
  863. char * saveptr = NULL;
  864. char * split = "\r\n";
  865. // 第一行
  866. strtok_r((char * )AT_result(), split, &saveptr);
  867. // 第二行
  868. char * Line2 = strtok_r(NULL, split, &saveptr);
  869. // 第三行
  870. char * Line3 = strtok_r(NULL, split, &saveptr);
  871. // 查询结果为空
  872. if(strcmp(Line2, "OK") == 0)
  873. {
  874. // 拆解第三行
  875. char * saveptr_inner = NULL;
  876. char * split_inner = ": ,\"";
  877. strtok_r(Line3, split_inner, &saveptr_inner);
  878. uint8_t connID = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  879. * err = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  880. Log_Printf_Debug("result: %d, %d\r\n", connID, * err);
  881. }
  882. result = success(); // 成功
  883. }
  884. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  885. {
  886. // 发送日志
  887. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  888. Log_SendArray_Debug(AT_result(), AT_result_length());
  889. result = failed(); // 失败
  890. }
  891. return result;
  892. }
  893. /**
  894. * 打开socket服务
  895. * 输入<<
  896. * connectID Socket ID。范围1-11
  897. * service_type Socket服务类型。取值为"UDP", "TCP"。
  898. * IP_address 远程服务器地址
  899. * remote_port 远程服务器端口
  900. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  901. *
  902. * 输出>>
  903. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  904. *
  905. * activeID 19
  906. **/
  907. 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)
  908. {
  909. enum Result result = Result_None;
  910. while(1)
  911. {
  912. result = ec800m_open_socket(connectID, service_type, IP_address, remote_port, access_mode, err);
  913. if(result != Result_None)
  914. {
  915. // 重置
  916. ec800m.reset();
  917. break;
  918. }
  919. }
  920. return result;
  921. }
  922. /**
  923. * 关闭socket服务
  924. * 输入<<
  925. * connectID Socket ID。范围1-11
  926. *
  927. * activeID 29
  928. **/
  929. enum Result ec800m_close_socket(uint8_t connectID)
  930. {
  931. enum Result result = Result_None;
  932. int activeID = 29, time = 500; // 活动ID, 超时时间
  933. // 校验ID
  934. if(!verifyActiveID(activeID)){ return Result_Failed; }
  935. // 判断状态
  936. if(getStatus() == Status_None) // 空闲状态
  937. {
  938. sprintf(AT_CMD, "AT+QICLOSE=%d\r\r\n", connectID); // 拼接AT指令
  939. result = send_at(AT_CMD, activeID);
  940. }
  941. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  942. {
  943. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  944. result = Result_Failed;
  945. }
  946. else if(getTimerMs() > time) // 正在发送状态。判断超时
  947. {
  948. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  949. result = overtime(); // 超时
  950. }
  951. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  952. {
  953. // 发送日志
  954. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  955. Log_SendArray_Debug(AT_result(), AT_result_length());
  956. result = success(); // 成功
  957. }
  958. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  959. {
  960. // 发送日志
  961. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  962. Log_SendArray_Debug(AT_result(), AT_result_length());
  963. result = failed(); // 失败
  964. }
  965. return result;
  966. }
  967. /**
  968. * 关闭socket服务
  969. * 输入<<
  970. * connectID Socket ID。范围1-11
  971. *
  972. * activeID 29
  973. **/
  974. enum Result ec800m_close_socket_sync(uint8_t connectID)
  975. {
  976. enum Result result = Result_None;
  977. while(1)
  978. {
  979. result = ec800m_close_socket(connectID);
  980. if(result != Result_None)
  981. {
  982. // 重置
  983. ec800m.reset();
  984. break;
  985. }
  986. }
  987. return result;
  988. }
  989. /**
  990. * 解释:控制是否回显AT+QISEND要发送的数据
  991. * 为了便于处理返回,发送数据时需要关闭回显。
  992. * 输入<<
  993. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  994. *
  995. * activeID 45
  996. **/
  997. enum Result ec800m_set_qisde(uint8_t echo)
  998. {
  999. enum Result result = Result_None;
  1000. int activeID = 45, time = 500; // 活动ID, 超时时间
  1001. // 校验ID
  1002. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1003. // 判断状态
  1004. if(getStatus() == Status_None) // 空闲状态
  1005. {
  1006. sprintf(AT_CMD, "AT+QISDE=%d\r\r\n", echo); // 拼接AT指令
  1007. result = send_at(AT_CMD, activeID);
  1008. }
  1009. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1010. {
  1011. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1012. result = Result_Failed;
  1013. }
  1014. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1015. {
  1016. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1017. result = overtime(); // 超时
  1018. }
  1019. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1020. {
  1021. // 发送日志
  1022. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1023. Log_SendArray_Debug(AT_result(), AT_result_length());
  1024. result = success(); // 成功
  1025. }
  1026. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1027. {
  1028. // 发送日志
  1029. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1030. Log_SendArray_Debug(AT_result(), AT_result_length());
  1031. result = failed(); // 失败
  1032. }
  1033. return result;
  1034. }
  1035. /**
  1036. * 解释:控制是否回显AT+QISEND要发送的数据
  1037. * 为了便于处理返回,发送数据时需要关闭回显。
  1038. * 输入<<
  1039. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  1040. *
  1041. * activeID 45
  1042. **/
  1043. enum Result ec800m_set_qisde_sync(uint8_t echo)
  1044. {
  1045. enum Result result = Result_None;
  1046. while(1)
  1047. {
  1048. result = ec800m_set_qisde(echo);
  1049. if(result != Result_None)
  1050. {
  1051. // 重置
  1052. ec800m.reset();
  1053. break;
  1054. }
  1055. }
  1056. return result;
  1057. }
  1058. /**
  1059. * 发送数据
  1060. * 输入<<
  1061. * connectID Socket ID。范围1-11。
  1062. * send_length 发送长度。
  1063. * data 待发送的数据。
  1064. *
  1065. * activeID 49
  1066. **/
  1067. enum Result ec800m_send(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1068. {
  1069. enum Result result = Result_None;
  1070. int activeID = 49, time = 10000; // 活动ID, 超时时间
  1071. // 校验ID
  1072. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1073. // 判断状态
  1074. if(getStatus() == Status_None) // 空闲状态
  1075. {
  1076. sprintf(AT_CMD, "AT+QISEND=%d,%d\r\r\n", connectID, data_length); // 拼接AT指令
  1077. result = send_at(AT_CMD, activeID);
  1078. }
  1079. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1080. {
  1081. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1082. result = Result_Failed;
  1083. }
  1084. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1085. {
  1086. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1087. result = overtime(); // 超时
  1088. }
  1089. else if(strstr((char * )AT_result(), "> ") != NULL) // 有响应
  1090. {
  1091. // 发送日志
  1092. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1093. Log_SendArray_Debug(AT_result(), AT_result_length());
  1094. // Log_Printf_Debug("coap:\r\n");
  1095. // Log_SendHex(data, data_length);
  1096. // Log_Printf_Debug("\r\n");
  1097. // 发送数据
  1098. send_data(data, data_length);
  1099. // 清理一下AT返回结果缓存
  1100. AT_Clear_Result();
  1101. }
  1102. else if(strstr((char * )AT_result(), "SEND OK\r\n") != NULL) // 查询是否返回
  1103. {
  1104. // 发送日志
  1105. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1106. Log_SendArray_Debug(AT_result(), AT_result_length());
  1107. result = success(); // 成功
  1108. }
  1109. else if(strstr((char * )AT_result(), "SEND FALL\r\n") != NULL) // 查询是否返回
  1110. {
  1111. // 发送日志
  1112. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1113. Log_SendArray_Debug(AT_result(), AT_result_length());
  1114. result = failed(); // 失败
  1115. }
  1116. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1117. {
  1118. // 发送日志
  1119. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1120. Log_SendArray_Debug(AT_result(), AT_result_length());
  1121. result = failed(); // 失败
  1122. }
  1123. return result;
  1124. }
  1125. /**
  1126. * 发送数据
  1127. * 输入<<
  1128. * connectID Socket ID。范围1-11。
  1129. * send_length 发送长度。
  1130. * data 待发送的数据。
  1131. *
  1132. * activeID 49
  1133. **/
  1134. enum Result ec800m_send_sync(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1135. {
  1136. enum Result result = Result_None;
  1137. while(1)
  1138. {
  1139. result = ec800m_send(connectID, data, data_length);
  1140. if(result != Result_None)
  1141. {
  1142. // 重置
  1143. ec800m.reset();
  1144. break;
  1145. }
  1146. }
  1147. return result;
  1148. }
  1149. /**
  1150. * 接收数据
  1151. * 输入<<
  1152. * connectID Socket ID。范围0-11。
  1153. *
  1154. * 输出>>
  1155. * data 接收的数据。
  1156. * data_length 接收的数据长度。
  1157. *
  1158. **/
  1159. enum Result ec800m_recv(uint8_t connectID, uint8_t * data, uint16_t * data_length)
  1160. {
  1161. // 设置AT为使用中,防止被其他程序占用
  1162. AT_Set_Status(AT_Status_Using);
  1163. enum Result result = Result_None;
  1164. // 校验参数
  1165. if(connectID > 11)
  1166. {
  1167. Log_Printf_Debug("recv params error!\r\n");
  1168. return Result_Failed;
  1169. }
  1170. char cmp[20];
  1171. sprintf(cmp, "+QIURC: \"recv\",%d", connectID); // 拼接AT指令
  1172. // 判断是否接收到
  1173. if(strstr((char * )AT_result(), cmp) != NULL)
  1174. {
  1175. // 防止接收不完整
  1176. uint32_t last_time = AT_wait_time();
  1177. if(last_time > 10) // 过10ms之后再取数据,避免数据截断。
  1178. {
  1179. // 发送日志
  1180. Log_Printf_Debug("AT返回: %d, time_diff: %d\r\n", AT_result_length(), last_time);
  1181. // Log_SendArray_Debug(AT_result(), AT_result_length());
  1182. char * saveptr = NULL;
  1183. char * split = "\r\n";
  1184. char * Line1 = strtok_r((char * )AT_result(), split, &saveptr);
  1185. uint8_t Line1_Len = strlen(Line1);
  1186. Log_Printf_Debug("Line1(%d): %s\r\n",Line1_Len ,Line1);
  1187. // 分割Line1,获取报文长度
  1188. char * saveptr_inner = NULL;
  1189. char * split_inner = ",";
  1190. strtok_r(Line1, split_inner, &saveptr_inner);
  1191. strtok_r(NULL, split_inner, &saveptr_inner);
  1192. * data_length = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 10);
  1193. uint16_t line_length = Line1_Len + 4;
  1194. // 内存拷贝
  1195. memcpy(data, AT_result() + line_length, * data_length);
  1196. // 成功
  1197. result = Result_Success;
  1198. // 清理一下AT返回结果缓存
  1199. AT_Clear_Result();
  1200. }
  1201. }
  1202. return result;
  1203. }
  1204. /**
  1205. * 接收数据。带计时
  1206. * 输入<<
  1207. * connectID Socket ID。范围0-11。
  1208. *
  1209. * 输出>>
  1210. * data 接收的数据。
  1211. * data_length 接收的数据长度。
  1212. *
  1213. **/
  1214. enum Result ec800m_recv_with_time(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1215. {
  1216. enum Result result = Result_None;
  1217. int activeID = 59, time = time_out; // 活动ID, 超时时间
  1218. // 校验ID
  1219. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1220. // 判断状态
  1221. if(getStatus() == Status_None) // 空闲状态
  1222. {
  1223. setStatus(Status_Sending);
  1224. }
  1225. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1226. {
  1227. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1228. result = Result_Failed;
  1229. }
  1230. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1231. {
  1232. Log_Printf_Debug("等待时间超时\r\n"); // 打印日志
  1233. result = overtime(); // 超时
  1234. }
  1235. else
  1236. {
  1237. // 接收数据
  1238. result = ec800m.recv(connectID, data, data_length);
  1239. if(result == Result_Success)
  1240. {
  1241. result = success(); // 成功
  1242. }
  1243. }
  1244. return result;
  1245. }
  1246. /**
  1247. * 接收数据。带计时
  1248. * 输入<<
  1249. * connectID Socket ID。范围0-11。
  1250. *
  1251. * 输出>>
  1252. * data 接收的数据。
  1253. * data_length 接收的数据长度。
  1254. *
  1255. **/
  1256. enum Result ec800m_recv_with_time_sync(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1257. {
  1258. enum Result result = Result_None;
  1259. while(1)
  1260. {
  1261. result = ec800m_recv_with_time(connectID, data, data_length, time_out);
  1262. if(result != Result_None)
  1263. {
  1264. // 重置
  1265. ec800m.reset();
  1266. break;
  1267. }
  1268. }
  1269. return result;
  1270. }
  1271. /**
  1272. * 解释:关闭模块
  1273. * 关闭模块,关闭后会自动重启。
  1274. * 输入<<
  1275. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1276. *
  1277. * activeID 69
  1278. **/
  1279. enum Result ec800m_power_down(uint8_t n)
  1280. {
  1281. enum Result result = Result_None;
  1282. int activeID = 69, time = 3000; // 活动ID, 超时时间
  1283. // 校验ID
  1284. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1285. // 判断状态
  1286. if(getStatus() == Status_None) // 空闲状态
  1287. {
  1288. sprintf(AT_CMD, "AT+QPOWD=%d\r\r\n", n); // 拼接AT指令
  1289. result = send_at(AT_CMD, activeID);
  1290. }
  1291. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1292. {
  1293. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1294. result = Result_Failed;
  1295. }
  1296. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1297. {
  1298. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1299. result = overtime();
  1300. }
  1301. else if(strstr((char * )AT_result(), "POWERED DOWN\r\n") != NULL) // 查询是否返回
  1302. {
  1303. // 发送日志
  1304. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1305. Log_SendArray_Debug(AT_result(), AT_result_length());
  1306. // 成功结果
  1307. result = success();
  1308. }
  1309. return result;
  1310. }
  1311. /**
  1312. * 解释:关闭模块。同步
  1313. * 关闭模块,关闭后会自动重启。
  1314. * 输入<<
  1315. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1316. *
  1317. * activeID 69
  1318. **/
  1319. enum Result ec800m_power_down_sync(uint8_t n)
  1320. {
  1321. enum Result result = Result_None;
  1322. while(1)
  1323. {
  1324. result = ec800m_power_down(n);
  1325. if(result != Result_None)
  1326. {
  1327. // 重置
  1328. ec800m.reset();
  1329. break;
  1330. }
  1331. }
  1332. return result;
  1333. }
  1334. /**
  1335. * 模块是否启动成功
  1336. * 输入<<
  1337. *
  1338. * 输出>>
  1339. *
  1340. **/
  1341. enum Result ec800m_ready(void)
  1342. {
  1343. if(AT_Get_Status() != AT_Status_None)
  1344. {
  1345. return Result_None;
  1346. }
  1347. enum Result result = Result_None;
  1348. // 判断是否接收到
  1349. uint8_t RDY[5]="RDY";
  1350. if(memmem(AT_result(),AT_result_length(),RDY,strlen((char *)RDY)) != 0)
  1351. {
  1352. // 发送日志
  1353. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1354. Log_SendArray_Debug(AT_result(), AT_result_length());
  1355. // 成功结果
  1356. result = Result_Success;
  1357. // 清理一下AT返回结果缓存
  1358. AT_Clear_Result();
  1359. }
  1360. return result;
  1361. }
  1362. /**
  1363. * 查询信号质量
  1364. * 输入<<
  1365. *
  1366. * 输出>>
  1367. * RSRP
  1368. * RSRQ
  1369. * RSSI
  1370. * SINR
  1371. **/
  1372. enum Result ec800m_qeng_servingcell(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1373. {
  1374. enum Result result = Result_None;
  1375. int activeID = 71, time = 500; // 活动ID, 超时时间
  1376. // 校验ID
  1377. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1378. // 判断状态
  1379. if(getStatus() == Status_None) // 空闲状态
  1380. {
  1381. sprintf(AT_CMD, "AT+QENG=\"servingcell\"\r\r\n"); // 拼接AT指令
  1382. result = send_at(AT_CMD, activeID);
  1383. }
  1384. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1385. {
  1386. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1387. result = failed(); // 失败
  1388. }
  1389. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1390. {
  1391. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1392. setStatus(Status_Overtime); // 超时
  1393. result = Result_Failed; // 结果
  1394. }
  1395. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1396. {
  1397. // 发送日志
  1398. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1399. Log_SendArray_Debug(AT_result(), AT_result_length());
  1400. // 处理返回结果
  1401. char * saveptr = NULL;
  1402. char * split = "\r\n";
  1403. // 第一行
  1404. strtok_r((char * )AT_result(), split, &saveptr);
  1405. // 第二行
  1406. char * Line2 = strtok_r(NULL, split, &saveptr);
  1407. // 拆解第二行
  1408. char * saveptr_inner = NULL;
  1409. char * split_inner = ": ,\"";
  1410. strtok_r(Line2, 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. strtok_r(NULL, split_inner, &saveptr_inner);
  1423. strtok_r(NULL, split_inner, &saveptr_inner);
  1424. * RSRP = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1425. * RSRQ = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1426. * RSSI = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1427. * SINR = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1428. // 打印
  1429. Log_Printf_Debug("RSRP: %d, RSRQ: %d, RSSI: %d, SINR: %d\r\n", * RSRP, * RSRQ, * RSSI, * SINR);
  1430. result = success(); // 成功
  1431. }
  1432. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1433. {
  1434. // 发送日志
  1435. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1436. Log_SendArray_Debug(AT_result(), AT_result_length());
  1437. result = failed(); // 失败
  1438. }
  1439. return result;
  1440. }
  1441. enum Result ec800m_qeng_servingcell_sync(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1442. {
  1443. enum Result result = Result_None;
  1444. while(1)
  1445. {
  1446. result = ec800m_qeng_servingcell(RSRP, RSRQ, RSSI, SINR);
  1447. if(result != Result_None)
  1448. {
  1449. // 重置
  1450. ec800m.reset();
  1451. break;
  1452. }
  1453. }
  1454. return result;
  1455. }
  1456. /**
  1457. * 查询ICCID
  1458. * 输入<<
  1459. *
  1460. * 输出>>
  1461. * iccid SIM卡卡号
  1462. **/
  1463. enum Result ec800m_query_qccid(char * iccid)
  1464. {
  1465. enum Result result = Result_None;
  1466. int activeID = 75, time = 500; // 活动ID, 超时时间
  1467. // 校验ID
  1468. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1469. // 判断状态
  1470. if(getStatus() == Status_None) // 空闲状态
  1471. {
  1472. sprintf(AT_CMD, "AT+QCCID\r\r\n"); // 拼接AT指令
  1473. result = send_at(AT_CMD, activeID);
  1474. }
  1475. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1476. {
  1477. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1478. result = failed(); // 失败
  1479. }
  1480. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1481. {
  1482. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1483. setStatus(Status_Overtime); // 超时
  1484. result = Result_Failed; // 结果
  1485. }
  1486. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1487. {
  1488. // 发送日志
  1489. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1490. Log_SendArray_Debug(AT_result(), AT_result_length());
  1491. // 处理返回结果
  1492. char * saveptr = NULL;
  1493. char * split = "\r\n";
  1494. // 第一行
  1495. strtok_r((char * )AT_result(), split, &saveptr);
  1496. // 第二行
  1497. char * Line2 = strtok_r(NULL, split, &saveptr);
  1498. // 拆解第二行
  1499. char * saveptr_inner = NULL;
  1500. char * split_inner = ": ,\"";
  1501. strtok_r(Line2, split_inner, &saveptr_inner);
  1502. // 字符串拷贝
  1503. strcpy(iccid, strtok_r(NULL, split_inner, &saveptr_inner));
  1504. // 打印
  1505. Log_Printf_Debug("ICCID: %s\r\n", iccid);
  1506. result = success(); // 成功
  1507. }
  1508. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1509. {
  1510. // 发送日志
  1511. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1512. Log_SendArray_Debug(AT_result(), AT_result_length());
  1513. result = failed(); // 失败
  1514. }
  1515. return result;
  1516. }
  1517. enum Result ec800m_query_qccid_sync(char * iccid)
  1518. {
  1519. enum Result result = Result_None;
  1520. while(1)
  1521. {
  1522. result = ec800m_query_qccid(iccid);
  1523. if(result != Result_None)
  1524. {
  1525. // 重置
  1526. ec800m.reset();
  1527. break;
  1528. }
  1529. }
  1530. return result;
  1531. }
  1532. #endif