ec800m.c 39 KB

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