bc260y.c 50 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065
  1. #include "CONFIG.h"
  2. #if BC260Y
  3. /**
  4. ******************************************************************************
  5. * 版 本 :V1.0.0
  6. * 作 者 :liuyanbin,helomgxiang
  7. * 版权所有,盗版必究。
  8. * Copyright(C) All rights reserved
  9. ******************************************************************************
  10. * 历史记录
  11. * 序号 版本 变更内容 作者 日期
  12. * 1 V0.0.1 实现4GAT指令 何龙翔 2023/12/10
  13. * 2 V0.0.2 基于4实现NB指令 刘艳斌 2024/1/10
  14. * 3 V0.0.3 整合4g和nb代码 刘艳斌 2024/1/24
  15. * 4 V0.0.4 修改send函数添加sendrai 刘艳斌 2024/2/18
  16. ******************************************************************************
  17. */
  18. #include "stm32f10x.h"
  19. #include <stdio.h>
  20. #include <stdarg.h>
  21. #include <string.h>
  22. #include <stdlib.h>
  23. #include "CONFIG.h"
  24. #include "bc260y.h"
  25. #include "Log_Module.h"
  26. #include "At_Module.h"
  27. #include "Common_Util.h"
  28. // 方法声明
  29. void bc260y_reset(void); // 重置状态。该文件中的方法共用状态,在使用下面的方法前需要重置一下状态。
  30. enum Result bc260y_exit_sleep(void); // 退出休眠
  31. enum Result bc260y_exit_sleep_sync(void); // 退出休眠
  32. enum Result bc260y_exit_sleep_2(void); // 退出休眠
  33. enum Result bc260y_exit_sleep_2_sync(void); // 退出休眠
  34. void bc260y_enter_sleep(void); // 进入休眠
  35. /**
  36. * 查询休眠模式
  37. * 输入<<
  38. *
  39. * 输出>>
  40. * n 睡眠模式。0 禁用,默认;1 启用。
  41. **/
  42. enum Result bc260y_query_sleep(uint8_t * n); // 查询休眠模式。
  43. enum Result bc260y_query_sleep_sync(uint8_t * n); // 查询休眠模式。同步
  44. /**
  45. * 设置休眠模式
  46. * 输入<<
  47. * n 参数。0 禁用;1启用。
  48. * 输出>>
  49. *
  50. **/
  51. enum Result bc260y_set_sleep(uint8_t n); // 设置休眠模式。
  52. enum Result bc260y_set_sleep_sync(uint8_t n); // 设置休眠模式。同步
  53. /**
  54. * 设置功能模式
  55. * 输入<<
  56. * fun 0 最小功能模式;1 全功能模式。
  57. * 输出>>
  58. *
  59. **/
  60. enum Result bc260y_query_cfun(uint8_t * n); // 查询功能模式。
  61. enum Result bc260y_query_cfun_sync(uint8_t * n); // 查询功能模式。
  62. enum Result bc260y_set_cfun(uint8_t fun);
  63. enum Result bc260y_set_cfun_sync(uint8_t fun); // 同步
  64. /**
  65. * 设置ps域网络注册状态
  66. * 输入<<
  67. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  68. * 输出>>
  69. *
  70. **/
  71. enum Result bc260y_set_cereg(uint8_t n);
  72. enum Result bc260y_set_cereg_sync(uint8_t n); // 同步
  73. /**
  74. * 查询ps域网络注册状态
  75. * 输入<<
  76. *
  77. * 输出>>
  78. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  79. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  80. * lac 基站位置区号。用于基站定位,2个字节。
  81. * ci 基站小区ID。用于基站定位,4个字节。
  82. *
  83. **/
  84. enum Result bc260y_query_cereg(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci);
  85. enum Result bc260y_query_cereg_sync(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci); // 同步
  86. /**
  87. * 查询socket服务状态
  88. * 输入<<
  89. * connectID Socket ID。范围1-11
  90. *
  91. * 输出>>
  92. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  93. *
  94. *
  95. **/
  96. enum Result bc260y_query_socket_state(uint8_t connectID, uint8_t * state);
  97. enum Result bc260y_query_socket_state_sync(uint8_t connectID, uint8_t * state); // 同步
  98. /**
  99. * 打开socket服务
  100. * 输入<<
  101. * connectID Socket ID。范围1-11
  102. * service_type Socket服务类型。取值为"UDP", "TCP"。
  103. * IP_address 远程服务器地址
  104. * remote_port 远程服务器端口
  105. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  106. *
  107. * 输出>>
  108. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  109. *
  110. **/
  111. enum Result bc260y_open_socket(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err);
  112. enum Result bc260y_open_socket_sync(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err); // 同步
  113. /**
  114. * 关闭socket服务
  115. * 输入<<
  116. * connectID Socket ID。范围1-11
  117. *
  118. * 输出>>
  119. *
  120. **/
  121. enum Result bc260y_close_socket(uint8_t connectID);
  122. enum Result bc260y_close_socket_sync(uint8_t connectID); // 同步
  123. /**
  124. * 解释:控制是否回显AT+QISEND要发送的数据
  125. * 为了便于处理返回,发送数据时需要关闭回显。
  126. * 输入<<
  127. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  128. *
  129. * 输出>>
  130. *
  131. **/
  132. enum Result bc260y_set_qisde(uint8_t echo);
  133. enum Result bc260y_set_qisde_sync(uint8_t echo); // 同步
  134. /**
  135. * 发送数据
  136. * 输入<<
  137. * connectID Socket ID。范围1-11。
  138. * send_length 发送长度。
  139. * data 待发送的数据。
  140. *
  141. *
  142. **/
  143. enum Result bc260y_send(uint8_t connectID, uint8_t * data, uint16_t data_length);
  144. enum Result bc260y_send_sync(uint8_t connectID, uint8_t * data, uint16_t data_length); // 同步
  145. enum Result bc260y_send_rai(uint8_t connectID, uint8_t * data, uint16_t data_length,uint8_t rai);
  146. enum Result bc260y_send_rai_sync(uint8_t connectID, uint8_t * data, uint16_t data_length,uint8_t rai);
  147. /**
  148. * 接收数据
  149. * 输入<<
  150. * connectID Socket ID。范围0-11。
  151. *
  152. * 输出>>
  153. * data 接收的数据。
  154. * data_length 接收的数据长度。
  155. **/
  156. enum Result bc260y_recv(uint8_t connectID, uint8_t * data, uint16_t * data_length); // 接收数据
  157. /**
  158. * 接收数据。带计时
  159. * 输入<<
  160. * connectID Socket ID。范围0-11。
  161. *
  162. * 输出>>
  163. * data 接收的数据。
  164. * data_length 接收的数据长度。
  165. *
  166. **/
  167. enum Result bc260y_recv_with_time(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out);
  168. enum Result bc260y_recv_with_time_sync(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out); // 同步
  169. /**
  170. * 解释:关闭模块
  171. * 关闭模块,关闭后会自动重启。
  172. * 输入<<
  173. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  174. *
  175. *
  176. **/
  177. enum Result bc260y_power_down(uint8_t n);
  178. enum Result bc260y_power_down_sync(uint8_t n); // 同步
  179. /**
  180. * 模块是否启动成功
  181. * 输入<<
  182. *
  183. * 输出>>
  184. *
  185. **/
  186. enum Result bc260y_ready(void);
  187. /**
  188. * 查询信号质量
  189. * 输入<<
  190. *
  191. * 输出>>
  192. * RSRP
  193. * RSRQ
  194. * RSSI
  195. * SINR
  196. **/
  197. enum Result bc260y_qeng_servingcell(int * RSRP, int * RSRQ, int * RSSI, int * SINR);
  198. enum Result bc260y_qeng_servingcell_sync(int * RSRP, int * RSRQ, int * RSSI, int * SINR);
  199. /**
  200. * 查询ICCID
  201. * 输入<<
  202. *
  203. * 输出>>
  204. * iccid SIM卡卡号
  205. **/
  206. enum Result bc260y_query_qccid(char * iccid);
  207. enum Result bc260y_query_qccid_sync(char * iccid);
  208. /**
  209. * 配置发送数据格式
  210. * 输入<<
  211. *n 0数据格式为文本字符串,1为十六进制字符串
  212. *
  213. **/
  214. enum Result bc260y_dataformat(uint8_t n);
  215. enum Result bc260y_dataformat_sync(uint8_t n);
  216. //
  217. // AT指令
  218. static char AT_CMD[1024];
  219. // EC800M提供的一些方法
  220. struct BC260Y_Struct bc260y =
  221. {
  222. .timer = {
  223. .time = 0,
  224. .flag = 0
  225. },
  226. .reset = bc260y_reset,
  227. .exit_sleep = bc260y_exit_sleep,
  228. .exit_sleep_sync = bc260y_exit_sleep_sync,
  229. .exit_sleep_2 = bc260y_exit_sleep_2,
  230. .exit_sleep_2_sync = bc260y_exit_sleep_2_sync,
  231. .enter_sleep = bc260y_enter_sleep,
  232. .query_sleep = bc260y_query_sleep,
  233. .query_sleep_sync = bc260y_query_sleep_sync,
  234. .set_sleep = bc260y_set_sleep,
  235. .set_sleep_sync = bc260y_set_sleep_sync,
  236. .query_cfun = bc260y_query_cfun,
  237. .query_cfun_sync = bc260y_query_cfun_sync,
  238. .set_cfun = bc260y_set_cfun,
  239. .set_cfun_sync = bc260y_set_cfun_sync,
  240. .set_cereg = bc260y_set_cereg,
  241. .set_cereg_sync = bc260y_set_cereg_sync,
  242. .query_cereg = bc260y_query_cereg,
  243. .query_cereg_sync = bc260y_query_cereg_sync,
  244. .query_socket_state = bc260y_query_socket_state,
  245. .query_socket_state_sync = bc260y_query_socket_state_sync,
  246. .open_socket = bc260y_open_socket,
  247. .open_socket_sync = bc260y_open_socket_sync,
  248. .close_socket = bc260y_close_socket,
  249. .close_socket_sync = bc260y_close_socket_sync,
  250. .set_qisde = bc260y_set_qisde,
  251. .set_qisde_sync = bc260y_set_qisde_sync,
  252. .send = bc260y_send,
  253. .send_sync = bc260y_send_sync,
  254. .send_rai = bc260y_send_rai,
  255. .send_rai_sync = bc260y_send_rai_sync,
  256. .recv = bc260y_recv,
  257. .recv_with_time = bc260y_recv_with_time,
  258. .recv_with_time_sync = bc260y_recv_with_time_sync,
  259. .power_down = bc260y_power_down,
  260. .power_down_sync = bc260y_power_down_sync,
  261. .ready = bc260y_ready,
  262. .qeng_servingcell = bc260y_qeng_servingcell,
  263. .qeng_servingcell_sync = bc260y_qeng_servingcell_sync,
  264. .query_qccid = bc260y_query_qccid,
  265. .query_qccid_sync = bc260y_query_qccid_sync,
  266. .dataformat= bc260y_dataformat,
  267. .dataformat_sync= bc260y_dataformat_sync
  268. };
  269. // 发送AT指令
  270. static void send_data(uint8_t * data, uint16_t length)
  271. {
  272. // 发送AT指令
  273. AT_Send_Bytes(data, length);
  274. }
  275. // 发送AT指令
  276. static uint8_t send_at_string(char * cmd)
  277. {
  278. uint8_t state = 0;
  279. if(AT_Get_Status() == AT_Status_None)
  280. {
  281. // 发送AT指令
  282. AT_Send_String(cmd);
  283. state = 1;
  284. }
  285. return state;
  286. }
  287. // 获取状态
  288. static enum STATUS getStatus(void)
  289. {
  290. return bc260y.status;
  291. }
  292. // 设置状态
  293. static void setStatus(enum STATUS status)
  294. {
  295. bc260y.status = status;
  296. }
  297. // 获取定时
  298. static uint32_t getTimerMs(void)
  299. {
  300. return time_get_delay(&bc260y.timer);
  301. }
  302. // 清除定时
  303. static void clearTimer(void)
  304. {
  305. time_clear(&bc260y.timer);
  306. }
  307. // 设置定时
  308. //static void setTimerMs(uint32_t time)
  309. //{
  310. // bc260y.timer_ms = time;
  311. //}
  312. // 获取ID
  313. static uint8_t getActiveID(void)
  314. {
  315. return bc260y.activeID;
  316. }
  317. static void setActiveID(uint8_t activeID)
  318. {
  319. bc260y.activeID = activeID;
  320. }
  321. // 验证ID
  322. static uint8_t verifyActiveID(uint8_t activeID)
  323. {
  324. if(getActiveID() == 0 || getActiveID() == activeID){ return 1; }
  325. else
  326. {
  327. Log_Printf_Debug("activeID repetition!\r\n");
  328. return 0;
  329. }
  330. }
  331. // 返回超时结果
  332. static enum Result overtime(void)
  333. {
  334. setStatus(Status_Overtime); // 超时
  335. return Result_Failed; // 结果
  336. }
  337. // 返回成功结果
  338. static enum Result success(void)
  339. {
  340. // 成功
  341. setStatus(Status_Success);
  342. // 结果
  343. return Result_Success;
  344. }
  345. // 返回失败结果
  346. static enum Result failed(void)
  347. {
  348. // 失败
  349. setStatus(Status_Failed);
  350. // 失败结果
  351. return Result_Failed;
  352. }
  353. // 重置状态。该文件中的方法共用状态,在使用方法前需要重置一下状态。
  354. void bc260y_reset(void)
  355. {
  356. setStatus(Status_None); // 重置状态
  357. setActiveID(0); // 重置ID
  358. clearTimer(); // 重置计时
  359. AT_Clear(); // 清除AT指令
  360. }
  361. // 发送指令并改变状态
  362. enum Result send_at(char * cmd, uint8_t activeID)
  363. {
  364. Log_Printf_Debug(cmd); // 打印AT指令
  365. if(send_at_string(cmd)) // 发送AT指令
  366. {
  367. setActiveID(activeID); // 活动ID
  368. setStatus(Status_Sending); // 设置已发送
  369. clearTimer(); // 重置计时
  370. return Result_None; // 未知结果
  371. }
  372. else
  373. {
  374. Log_Printf_Debug("AT指令发送失败\r\n"); // 打印日志
  375. return Result_Failed; // 失败结果
  376. }
  377. }
  378. // 退出休眠
  379. enum Result bc260y_exit_sleep(void)
  380. {
  381. //GPIO_SetBits(WAKE_GPIO, WAKE_GPIO_Pin);// nb拉高io口,唤醒模组
  382. enum Result result = Result_None;
  383. int activeID = 1, time = 500; // 活动ID, 超时时间
  384. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  385. // 判断状态
  386. if(getStatus() == Status_None) // 空闲状态
  387. {
  388. sprintf(AT_CMD, "AT\r\n"); // 拼接AT指令
  389. result = send_at(AT_CMD, activeID);
  390. }
  391. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  392. {
  393. Log_Printf_Debug("返回结果过期1,请重置状态\r\n"); // 打印日志
  394. result = failed(); // 失败
  395. }
  396. else if(getTimerMs() > time) // 正在发送状态。判断超时
  397. {
  398. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  399. Log_SendArray_Debug(AT_result(), AT_result_length());
  400. result = overtime(); // 超时
  401. }
  402. if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  403. {
  404. // 发送日志
  405. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  406. Log_SendArray_Debug(AT_result(), AT_result_length());
  407. result = success(); // 成功
  408. }
  409. else if(strstr((char * )AT_result(), "+QNBIOTEVENT:") != NULL)
  410. {
  411. // 发送日志
  412. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  413. Log_SendArray_Debug(AT_result(), AT_result_length());
  414. result = success(); // 成功
  415. }
  416. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  417. {
  418. // 发送日志
  419. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  420. Log_SendArray_Debug(AT_result(), AT_result_length());
  421. result = failed(); // 失败
  422. }
  423. return result;
  424. }
  425. enum Result bc260y_exit_sleep_sync()
  426. {
  427. enum Result result = Result_None;
  428. while(1)
  429. {
  430. result = bc260y_exit_sleep();
  431. if(result != Result_None)
  432. {
  433. // 重置
  434. bc260y.reset();
  435. break;
  436. }
  437. }
  438. return result;
  439. }
  440. // 退出休眠
  441. enum Result bc260y_exit_sleep_2(void)
  442. {
  443. enum Result result = Result_None;
  444. int activeID = 123, time = 100; // 活动ID, 超时时间
  445. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  446. // 判断状态
  447. if(getStatus() == Status_None) // 空闲状态
  448. {
  449. sprintf(AT_CMD, "AT\r\n"); // 拼接AT指令
  450. result = send_at(AT_CMD, activeID);
  451. }
  452. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  453. {
  454. Log_Printf_Debug("返回结果过期1,请重置状态\r\n"); // 打印日志
  455. result = failed(); // 失败
  456. }
  457. else if(getTimerMs() > time) // 正在发送状态。判断超时
  458. {
  459. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  460. Log_SendArray_Debug(AT_result(), AT_result_length());
  461. result = success(); // 成功
  462. }
  463. if(strstr((char * )AT_result(), "OK\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 = success(); // 成功
  469. }
  470. else if(strstr((char * )AT_result(), "+QNBIOTEVENT:") != NULL)
  471. {
  472. // 发送日志
  473. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  474. Log_SendArray_Debug(AT_result(), AT_result_length());
  475. result = success(); // 成功
  476. }
  477. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  478. {
  479. // 发送日志
  480. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  481. Log_SendArray_Debug(AT_result(), AT_result_length());
  482. result = failed(); // 失败
  483. }
  484. return result;
  485. }
  486. enum Result bc260y_exit_sleep_2_sync()
  487. {
  488. enum Result result = Result_None;
  489. while(1)
  490. {
  491. result = bc260y_exit_sleep_2();
  492. if(result != Result_None)
  493. {
  494. // 重置
  495. bc260y.reset();
  496. break;
  497. }
  498. }
  499. return result;
  500. }
  501. // 进入休眠
  502. void bc260y_enter_sleep(void)
  503. {
  504. // GPIO_ResetBits(WAKE_GPIO, WAKE_GPIO_Pin); // nb拉低io口,进入睡眠
  505. }
  506. /**
  507. * 查询休眠模式
  508. * 输入<<
  509. *
  510. * 输出>>
  511. * n 睡眠模式。0 禁用,默认;1 启用。
  512. *
  513. **/
  514. enum Result bc260y_query_sleep(uint8_t * n)
  515. {
  516. enum Result result = Result_None;
  517. int activeID = 1, time = 500; // 活动ID, 超时时间
  518. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  519. // 判断状态
  520. if(getStatus() == Status_None) // 空闲状态
  521. {
  522. sprintf(AT_CMD, "AT+QSCLK?\r\n"); // 拼接AT指令
  523. result = send_at(AT_CMD, activeID);
  524. }
  525. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  526. {
  527. Log_Printf_Debug("返回结果过期1,请重置状态\r\n"); // 打印日志
  528. result = failed(); // 失败
  529. }
  530. else if(getTimerMs() > time) // 正在发送状态。判断超时
  531. {
  532. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  533. result = overtime(); // 超时
  534. Log_SendArray_Debug(AT_result(), AT_result_length());
  535. }
  536. if(strstr((char * )AT_result(), "OK\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. // 处理返回结果
  542. char * saveptr = NULL;
  543. char * split = "\r\n";
  544. // 第一行
  545. char * Line1 = strtok_r((char * )AT_result(), split, &saveptr);
  546. // 第二行
  547. char * Line2 = strtok_r(NULL, split, &saveptr);
  548. // 拆解第二行
  549. char * saveptr_inner = NULL;
  550. char * split_inner = ": ";
  551. strtok_r(Line2, split_inner, &saveptr_inner);
  552. // 获取mode
  553. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  554. result = success(); // 成功
  555. }
  556. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  557. {
  558. // 发送日志
  559. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  560. Log_SendArray_Debug(AT_result(), AT_result_length());
  561. result = failed(); // 失败
  562. }
  563. return result;
  564. }
  565. /**
  566. * 查询休眠模式。同步方法
  567. * 输入<<
  568. *
  569. * 输出>>
  570. * n 睡眠模式。0 禁用,默认;1 启用。
  571. *
  572. **/
  573. enum Result bc260y_query_sleep_sync(uint8_t * n)
  574. {
  575. enum Result result = Result_None;
  576. while(1)
  577. {
  578. result = bc260y_query_sleep(n);
  579. if(result != Result_None)
  580. {
  581. // 重置
  582. bc260y.reset();
  583. break;
  584. }
  585. }
  586. return result;
  587. }
  588. /**
  589. * 设置休眠模式
  590. * n 参数。0 禁用;1启用允许进入Deep Sleep 模式,2允许模块进入入Light Sleep 模式。
  591. **/
  592. enum Result bc260y_set_sleep(uint8_t n)
  593. {
  594. enum Result result = Result_None;
  595. int activeID = 2, time = 500; // 活动ID, 超时时间
  596. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  597. // 判断状态
  598. if(getStatus() == Status_None) // 空闲状态
  599. {
  600. sprintf(AT_CMD, "AT+QSCLK=%d\r\n", n); // 拼接AT指令
  601. result = send_at(AT_CMD, activeID);
  602. }
  603. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  604. {
  605. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  606. result = failed(); // 失败
  607. }
  608. else if(getTimerMs() > time) // 正在发送状态。判断超时
  609. {
  610. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  611. result = overtime(); // 超时
  612. }
  613. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  614. {
  615. // 发送日志
  616. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  617. Log_SendArray_Debug(AT_result(), AT_result_length());
  618. result = success(); // 成功
  619. }
  620. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  621. {
  622. // 发送日志
  623. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  624. Log_SendArray_Debug(AT_result(), AT_result_length());
  625. result = failed(); // 失败
  626. }
  627. return result;
  628. }
  629. /**
  630. * 设置休眠模式。同步
  631. * n 参数。0 禁用;1启用。
  632. **/
  633. enum Result bc260y_set_sleep_sync(uint8_t n)
  634. {
  635. enum Result result = Result_None;
  636. while(1)
  637. {
  638. result = bc260y_set_sleep(n);
  639. if(result != Result_None)
  640. {
  641. // 重置
  642. bc260y.reset();
  643. break;
  644. }
  645. }
  646. return result;
  647. }
  648. /**
  649. * 查询功能模式
  650. * 输入<<
  651. *
  652. * 输出>>
  653. * n 功能模式。0 最小功能模式,默认;1 全功能模式。
  654. *
  655. **/
  656. enum Result bc260y_query_cfun(uint8_t * n)
  657. {
  658. enum Result result = Result_None;
  659. int activeID = 100, time = 500; // 活动ID, 超时时间
  660. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  661. // 判断状态
  662. if(getStatus() == Status_None) // 空闲状态
  663. {
  664. sprintf(AT_CMD, "AT+CFUN?\r\n"); // 拼接AT指令
  665. result = send_at(AT_CMD, activeID);
  666. }
  667. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  668. {
  669. Log_Printf_Debug("返回结果过期1,请重置状态\r\n"); // 打印日志
  670. result = failed(); // 失败
  671. }
  672. else if(getTimerMs() > time) // 正在发送状态。判断超时
  673. {
  674. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  675. result = overtime(); // 超时
  676. Log_SendArray_Debug(AT_result(), AT_result_length());
  677. }
  678. if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  679. {
  680. // 发送日志
  681. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  682. Log_SendArray_Debug(AT_result(), AT_result_length());
  683. // 处理返回结果
  684. char * saveptr = NULL;
  685. char * split = "\r\n";
  686. // 第一行
  687. strtok_r((char * )AT_result(), split, &saveptr);
  688. // 第二行
  689. char * Line2 = strtok_r(NULL, split, &saveptr);
  690. // 拆解第二行
  691. char * saveptr_inner = NULL;
  692. char * split_inner = ": ";
  693. strtok_r(Line2, split_inner, &saveptr_inner);
  694. // 获取mode
  695. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  696. result = success(); // 成功
  697. }
  698. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  699. {
  700. // 发送日志
  701. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  702. Log_SendArray_Debug(AT_result(), AT_result_length());
  703. result = failed(); // 失败
  704. }
  705. return result;
  706. }
  707. enum Result bc260y_query_cfun_sync(uint8_t * n)
  708. {
  709. enum Result result = Result_None;
  710. while(1)
  711. {
  712. result = bc260y_query_cfun(n);
  713. if(result != Result_None)
  714. {
  715. // 重置
  716. bc260y.reset();
  717. break;
  718. }
  719. }
  720. return result;
  721. }
  722. /**
  723. * 设置功能模式
  724. * fun 0 最小功能模式;1 全功能模式。
  725. **/
  726. enum Result bc260y_set_cfun(uint8_t fun)
  727. {
  728. enum Result result = Result_None;
  729. int activeID = 4, time; // 活动ID, 超时时间
  730. // 校验参数
  731. if(fun == 0){ time = 3000; }
  732. else if(fun == 1){ time = 7000; }
  733. else
  734. {
  735. Log_Printf_Debug("set_cfun params error!\r\n");
  736. return Result_Failed;
  737. }
  738. // 校验ID
  739. if(!verifyActiveID(activeID)){ return Result_Failed; }
  740. // 判断状态
  741. if(getStatus() == Status_None) // 空闲状态
  742. {
  743. sprintf(AT_CMD, "AT+CFUN=%d\r\n", fun); // 拼接AT指令
  744. result = send_at(AT_CMD, activeID);
  745. }
  746. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  747. {
  748. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  749. result = failed(); // 失败
  750. }
  751. else if(getTimerMs() > time) // 正在发送状态。判断超时
  752. {
  753. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  754. Log_SendArray_Debug(AT_result(), AT_result_length());
  755. result = overtime(); // 超时
  756. }
  757. else if(fun == 1 && strstr((char * )AT_result(), "+IP:") != NULL) // 查询是否返回
  758. {
  759. // 防止接收不完整
  760. if(AT_wait_time() > 10) // 过10ms之后再取数据,避免数据截断。
  761. {
  762. // 发送日志
  763. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  764. Log_SendArray_Debug(AT_result(), AT_result_length());
  765. result = success(); // 成功
  766. }
  767. }
  768. else if(fun == 0 && strstr((char * )AT_result(), "+CPIN: NOT READY") != NULL) // 查询是否返回
  769. {
  770. // 防止接收不完整
  771. if(AT_wait_time() > 10) // 过10ms之后再取数据,避免数据截断。
  772. {
  773. // 发送日志
  774. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  775. Log_SendArray_Debug(AT_result(), AT_result_length());
  776. result = success(); // 成功
  777. }
  778. }
  779. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  780. {
  781. // 发送日志
  782. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  783. Log_SendArray_Debug(AT_result(), AT_result_length());
  784. result = failed(); // 失败
  785. }
  786. return result;
  787. }
  788. /**
  789. * 设置功能模式
  790. * 输入<<
  791. * fun 0 最小功能模式;1 全功能模式。
  792. * 输出>>
  793. *
  794. **/
  795. enum Result bc260y_set_cfun_sync(uint8_t fun)
  796. {
  797. enum Result result = Result_None;
  798. while(1)
  799. {
  800. result = bc260y_set_cfun(fun);
  801. if(result != Result_None)
  802. {
  803. // 重置
  804. bc260y.reset();
  805. break;
  806. }
  807. }
  808. return result;
  809. }
  810. /**
  811. * 设置ps域网络注册状态
  812. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  813. **/
  814. enum Result bc260y_set_cereg(uint8_t n)
  815. {
  816. enum Result result = Result_None;
  817. int activeID = 6, time = 500; // 活动ID, 超时时间
  818. // 校验参数
  819. if(n > 2)
  820. {
  821. Log_Printf_Debug("set_cgreg params error!\r\n");
  822. return Result_Failed;
  823. }
  824. // 校验ID
  825. if(!verifyActiveID(activeID)){ return Result_Failed; }
  826. // 判断状态
  827. if(getStatus() == Status_None) // 空闲状态
  828. {
  829. sprintf(AT_CMD, "AT+CEREG=%d\r\n", n); // 拼接AT指令
  830. result = send_at(AT_CMD, activeID);
  831. }
  832. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  833. {
  834. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  835. result = failed(); // 失败
  836. }
  837. else if(getTimerMs() > time) // 正在发送状态。判断超时
  838. {
  839. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  840. result = overtime(); // 超时
  841. }
  842. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  843. {
  844. // 发送日志
  845. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  846. Log_SendArray_Debug(AT_result(), AT_result_length());
  847. result = success(); // 成功
  848. }
  849. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  850. {
  851. // 发送日志
  852. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  853. Log_SendArray_Debug(AT_result(), AT_result_length());
  854. result = failed(); // 失败
  855. }
  856. return result;
  857. }
  858. /**
  859. * 设置ps域网络注册状态
  860. * 输入<<
  861. * n 0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  862. * 输出>>
  863. *
  864. **/
  865. enum Result bc260y_set_cereg_sync(uint8_t n)
  866. {
  867. enum Result result = Result_None;
  868. while(1)
  869. {
  870. result = bc260y_set_cereg(n);
  871. if(result != Result_None)
  872. {
  873. // 重置
  874. bc260y.reset();
  875. break;
  876. }
  877. }
  878. return result;
  879. }
  880. /**
  881. * 查询ps域网络注册状态
  882. * 输入<<
  883. *
  884. * 输出>>
  885. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  886. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  887. * lac 基站位置区号。用于基站定位,2个字节。
  888. * ci 基站小区ID。用于基站定位,4个字节。
  889. *
  890. **/
  891. enum Result bc260y_query_cereg(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci)
  892. {
  893. enum Result result = Result_None;
  894. int activeID = 9, time = 500; // 活动ID, 超时时间
  895. // 校验ID
  896. if(!verifyActiveID(activeID)){ return Result_Failed; }
  897. // 判断状态
  898. if(getStatus() == Status_None) // 空闲状态
  899. {
  900. sprintf(AT_CMD, "AT+CEREG?\r\n"); // 拼接AT指令
  901. result = send_at(AT_CMD, activeID);
  902. }
  903. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  904. {
  905. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  906. result = failed(); // 失败
  907. }
  908. else if(getTimerMs() > time) // 正在发送状态。判断超时
  909. {
  910. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  911. setStatus(Status_Overtime); // 超时
  912. result = Result_Failed; // 结果
  913. }
  914. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  915. {
  916. // 发送日志
  917. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  918. Log_SendArray_Debug(AT_result(), AT_result_length());
  919. // 处理返回结果
  920. char * saveptr = NULL;
  921. char * split = "\r\n";
  922. // 第一行
  923. strtok_r((char * )AT_result(), split, &saveptr);
  924. // 第二行
  925. char * Line2 = strtok_r(NULL, split, &saveptr);
  926. char * saveptr_inner = NULL;
  927. char * split_inner = ": ,\"";
  928. strtok_r(Line2, split_inner, &saveptr_inner);
  929. * n = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  930. * stat = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  931. // Log_Printf_Debug("saveptr_inner: %s\r\n", Line2);
  932. * lac = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  933. * ci = strtoul(strtok_r(NULL, split_inner, &saveptr_inner), NULL, 16);
  934. // 打印
  935. Log_Printf_Debug("mode: %d, stat: %d, lac: %d, ci: %d\r\n", * n, * stat, * lac, * ci);
  936. result = success(); // 成功
  937. }
  938. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  939. {
  940. // 发送日志
  941. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  942. Log_SendArray_Debug(AT_result(), AT_result_length());
  943. result = failed(); // 失败
  944. }
  945. return result;
  946. }
  947. /**
  948. * 查询ps域网络注册状态
  949. * 输入<<
  950. *
  951. * 输出>>
  952. * n 控制指定URC的上报。0 禁止上报网络注册;1 允许上报网络注册;2 允许上报网络注册和位置信息
  953. * stat 网络注册状态。0 未注册;1 已注册,归属地网络; 2 未注册;3 注册被拒绝;4 未知;5 已注册,漫游。
  954. * lac 基站位置区号。用于基站定位,2个字节。
  955. * ci 基站小区ID。用于基站定位,4个字节。
  956. *
  957. **/
  958. enum Result bc260y_query_cereg_sync(uint8_t * n, uint8_t * stat, uint16_t * lac, uint32_t * ci)
  959. {
  960. enum Result result = Result_None;
  961. while(1)
  962. {
  963. result = bc260y_query_cereg(n, stat, lac, ci);
  964. if(result != Result_None)
  965. {
  966. // 重置
  967. bc260y.reset();
  968. break;
  969. }
  970. }
  971. return result;
  972. }
  973. /**
  974. * 查询socket服务状态
  975. * connectID Socket ID。范围1-11
  976. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  977. *
  978. * activeID 9
  979. **/
  980. enum Result bc260y_query_socket_state(uint8_t connectID, uint8_t * state)
  981. {
  982. enum Result result = Result_None;
  983. int activeID = 9, time = 500; // 活动ID, 超时时间
  984. // 校验ID
  985. if(!verifyActiveID(activeID)){ return Result_Failed; }
  986. // 判断状态
  987. if(getStatus() == Status_None) // 空闲状态
  988. {
  989. sprintf(AT_CMD, "AT+QISTATE=1,%d\r\n", connectID); // 拼接AT指令
  990. result = send_at(AT_CMD, activeID);
  991. }
  992. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  993. {
  994. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  995. result = failed(); // 失败
  996. }
  997. else if(getTimerMs() > time) // 正在发送状态。判断超时
  998. {
  999. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1000. result = overtime(); // 超时
  1001. }
  1002. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1003. {
  1004. // 发送日志
  1005. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1006. Log_SendArray_Debug(AT_result(), AT_result_length());
  1007. // 处理返回结果
  1008. char * saveptr = NULL;
  1009. char * split = "\r\n";
  1010. // 第一行
  1011. strtok_r((char * )AT_result(), split, &saveptr);
  1012. // 第二行
  1013. char * Line2 = strtok_r(NULL, split, &saveptr);
  1014. // 查询结果为空
  1015. if(strcmp(Line2, "OK") == 0){ * state = 0; }
  1016. else
  1017. {
  1018. // 拆解第二行
  1019. char * saveptr_inner = NULL;
  1020. char * split_inner = ": ,\"";
  1021. strtok_r(Line2, split_inner, &saveptr_inner);
  1022. strtok_r(NULL, split_inner, &saveptr_inner);
  1023. strtok_r(NULL, split_inner, &saveptr_inner);
  1024. strtok_r(NULL, split_inner, &saveptr_inner);
  1025. strtok_r(NULL, split_inner, &saveptr_inner);
  1026. strtok_r(NULL, split_inner, &saveptr_inner);
  1027. * state = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1028. }
  1029. // 打印
  1030. Log_Printf_Debug("result: %d\r\n", * state);
  1031. result = success(); // 成功
  1032. }
  1033. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1034. {
  1035. // 发送日志
  1036. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1037. Log_SendArray_Debug(AT_result(), AT_result_length());
  1038. result = failed(); // 失败
  1039. }
  1040. return result;
  1041. }
  1042. /**
  1043. * 查询socket服务状态
  1044. * connectID Socket ID。范围1-11
  1045. * state Socket服务状态。0 未连接;1 正在连接;2 已建立连接;3 服务正在监听;4 连接断开。
  1046. *
  1047. * activeID 9
  1048. **/
  1049. enum Result bc260y_query_socket_state_sync(uint8_t connectID, uint8_t * state)
  1050. {
  1051. enum Result result = Result_None;
  1052. while(1)
  1053. {
  1054. result = bc260y_query_socket_state(connectID, state);
  1055. if(result != Result_None)
  1056. {
  1057. // 重置
  1058. bc260y.reset();
  1059. break;
  1060. }
  1061. }
  1062. return result;
  1063. }
  1064. /**
  1065. * 打开socket服务
  1066. * 输入<<
  1067. * connectID Socket ID。范围1-11
  1068. * service_type Socket服务类型。取值为"UDP", "TCP"。
  1069. * IP_address 远程服务器地址
  1070. * remote_port 远程服务器端口
  1071. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  1072. *
  1073. * 输出>>
  1074. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  1075. *
  1076. * activeID 19
  1077. **/
  1078. enum Result bc260y_open_socket(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err)
  1079. {
  1080. enum Result result = Result_None;
  1081. int activeID = 19, time = 3000; // 活动ID, 超时时间
  1082. // 校验ID
  1083. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1084. // 判断状态
  1085. if(getStatus() == Status_None) // 空闲状态
  1086. {
  1087. sprintf(AT_CMD, "AT+QIOPEN=0,%d,\"%s\",\"%s\",%d,%d,%d\r\n", connectID, service_type, IP_address, remote_port, 0, access_mode); // 拼接AT指令
  1088. result = send_at(AT_CMD, activeID);
  1089. }
  1090. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1091. {
  1092. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1093. result = failed(); // 失败
  1094. }
  1095. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1096. {
  1097. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1098. result = overtime(); // 超时
  1099. }
  1100. else if(strstr((char * )AT_result(), "+QIOPEN: ") != NULL) // 查询是否返回
  1101. {
  1102. // 发送日志
  1103. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1104. Log_SendArray_Debug(AT_result(), AT_result_length());//
  1105. // 处理返回结果
  1106. char * saveptr = NULL;
  1107. char * split = "\r\n";
  1108. // 第一行
  1109. strtok_r((char * )AT_result(), split, &saveptr);
  1110. // 第二行
  1111. char * Line2 = strtok_r(NULL, split, &saveptr);
  1112. // 第三行
  1113. char * Line3 = strtok_r(NULL, split, &saveptr);
  1114. // 查询结果为空
  1115. if(strcmp(Line2, "OK") == 0)
  1116. {
  1117. // 拆解第三行
  1118. char * saveptr_inner = NULL;
  1119. char * split_inner = ": ,\"";
  1120. strtok_r(Line3, split_inner, &saveptr_inner);
  1121. uint8_t connID = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1122. * err = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1123. Log_Printf_Debug("result: %d, %d\r\n", connID, * err);
  1124. }
  1125. result = success(); // 成功
  1126. }
  1127. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1128. {
  1129. // 发送日志
  1130. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1131. Log_SendArray_Debug(AT_result(), AT_result_length());
  1132. result = failed(); // 失败
  1133. }
  1134. return result;
  1135. }
  1136. /**
  1137. * 打开socket服务
  1138. * 输入<<
  1139. * connectID Socket ID。范围1-11
  1140. * service_type Socket服务类型。取值为"UDP", "TCP"。
  1141. * IP_address 远程服务器地址
  1142. * remote_port 远程服务器端口
  1143. * access_mode Socket服务的数据访问模式。0 缓存模式;1 直吐模式;2 透传模式。
  1144. *
  1145. * 输出>>
  1146. * err 操作错误代码。0 表示没有错误;其余参考移远文档。
  1147. *
  1148. * activeID 19
  1149. **/
  1150. enum Result bc260y_open_socket_sync(uint8_t connectID, char * service_type, char * IP_address, uint16_t remote_port, uint8_t access_mode, uint16_t * err)
  1151. {
  1152. enum Result result = Result_None;
  1153. while(1)
  1154. {
  1155. result = bc260y_open_socket(connectID, service_type, IP_address, remote_port, access_mode, err);
  1156. if(result != Result_None)
  1157. {
  1158. // 重置
  1159. bc260y.reset();
  1160. break;
  1161. }
  1162. }
  1163. return result;
  1164. }
  1165. /**
  1166. * 关闭socket服务
  1167. * 输入<<
  1168. * connectID Socket ID。范围1-11
  1169. *
  1170. * activeID 29
  1171. **/
  1172. enum Result bc260y_close_socket(uint8_t connectID)
  1173. {
  1174. enum Result result = Result_None;
  1175. int activeID = 29, time = 500; // 活动ID, 超时时间
  1176. // 校验ID
  1177. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1178. // 判断状态
  1179. if(getStatus() == Status_None) // 空闲状态
  1180. {
  1181. sprintf(AT_CMD, "AT+QICLOSE=%d\r\n", connectID); // 拼接AT指令
  1182. result = send_at(AT_CMD, activeID);
  1183. }
  1184. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1185. {
  1186. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1187. result = Result_Failed;
  1188. }
  1189. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1190. {
  1191. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1192. result = overtime(); // 超时
  1193. }
  1194. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1195. {
  1196. // 发送日志
  1197. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1198. Log_SendArray_Debug(AT_result(), AT_result_length());
  1199. result = success(); // 成功
  1200. }
  1201. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1202. {
  1203. // 发送日志
  1204. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1205. Log_SendArray_Debug(AT_result(), AT_result_length());
  1206. result = failed(); // 失败
  1207. }
  1208. return result;
  1209. }
  1210. /**
  1211. * 关闭socket服务
  1212. * 输入<<
  1213. * connectID Socket ID。范围1-11
  1214. *
  1215. * activeID 29
  1216. **/
  1217. enum Result bc260y_close_socket_sync(uint8_t connectID)
  1218. {
  1219. enum Result result = Result_None;
  1220. while(1)
  1221. {
  1222. result = bc260y_close_socket(connectID);
  1223. if(result != Result_None)
  1224. {
  1225. // 重置
  1226. bc260y.reset();
  1227. break;
  1228. }
  1229. }
  1230. return result;
  1231. }
  1232. /**
  1233. * 解释:控制是否回显AT+QISEND要发送的数据
  1234. * 为了便于处理返回,发送数据时需要关闭回显。
  1235. * 输入<<
  1236. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  1237. *
  1238. * activeID 45
  1239. **/
  1240. enum Result bc260y_set_qisde(uint8_t echo)
  1241. {
  1242. enum Result result = Result_None;
  1243. int activeID = 45, time = 1000; // 活动ID, 超时时间
  1244. // 校验ID
  1245. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1246. // 判断状态
  1247. if(getStatus() == Status_None) // 空闲状态
  1248. {
  1249. sprintf(AT_CMD, "ATE%d\r\n", echo); // 拼接AT指令
  1250. result = send_at(AT_CMD, activeID);
  1251. }
  1252. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1253. {
  1254. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1255. result = Result_Failed;
  1256. }
  1257. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1258. {
  1259. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1260. result = overtime(); // 超时
  1261. }
  1262. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1263. {
  1264. // 发送日志
  1265. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1266. Log_SendArray_Debug(AT_result(), AT_result_length());
  1267. result = success(); // 成功
  1268. }
  1269. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1270. {
  1271. // 发送日志
  1272. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1273. Log_SendArray_Debug(AT_result(), AT_result_length());
  1274. result = failed(); // 失败
  1275. }
  1276. return result;
  1277. }
  1278. /**
  1279. * 解释:控制是否回显AT+QISEND要发送的数据
  1280. * 为了便于处理返回,发送数据时需要关闭回显。
  1281. * 输入<<
  1282. * echo 是否回显AT+QISEND要发送的数据。0 不回显;1 回显。默认是回显
  1283. *
  1284. * activeID 45
  1285. **/
  1286. enum Result bc260y_set_qisde_sync(uint8_t echo)
  1287. {
  1288. enum Result result = Result_None;
  1289. while(1)
  1290. {
  1291. result = bc260y_set_qisde(echo);
  1292. if(result != Result_None)
  1293. {
  1294. // 重置
  1295. bc260y.reset();
  1296. break;
  1297. }
  1298. }
  1299. return result;
  1300. }
  1301. /**
  1302. * 发送数据
  1303. * 输入<<
  1304. * connectID Socket ID。范围1-11。
  1305. * send_length 发送长度。
  1306. * data 待发送的数据。
  1307. *
  1308. * activeID 49
  1309. **/
  1310. enum Result bc260y_send(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1311. {
  1312. enum Result result = Result_None;
  1313. int activeID = 49, time = 10000; // 活动ID, 超时时间
  1314. // 校验ID
  1315. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1316. // 判断状态
  1317. if(getStatus() == Status_None) // 空闲状态
  1318. {
  1319. sprintf(AT_CMD, "AT+QISEND=%d,%d\r\n", connectID, data_length); // 拼接AT指令
  1320. result = send_at(AT_CMD, activeID);
  1321. }
  1322. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1323. {
  1324. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1325. result = Result_Failed;
  1326. }
  1327. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1328. {
  1329. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1330. result = overtime(); // 超时
  1331. }
  1332. else if(strstr((char * )AT_result(), ">") != NULL) // 有响应
  1333. {
  1334. // 发送日志
  1335. Log_Printf_Debug("AT6返回: %d\r\n", AT_result_length());
  1336. Log_SendArray_Debug(AT_result(), AT_result_length());
  1337. // Log_Printf_Debug("coap:\r\n");
  1338. // Log_SendHex(data, data_length);
  1339. // Log_Printf_Debug("\r\n");
  1340. // 发送数据
  1341. send_data(data, data_length);
  1342. // 清理一下AT返回结果缓存
  1343. AT_Clear_Result();
  1344. }
  1345. else if(strstr((char * )AT_result(), "SEND OK\r\n") != NULL) // 查询是否返回
  1346. {
  1347. // 发送日志
  1348. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1349. Log_SendArray_Debug(AT_result(), AT_result_length());
  1350. result = success(); // 成功
  1351. }
  1352. else if(strstr((char * )AT_result(), "SEND FALL\r\n") != NULL) // 查询是否返回
  1353. {
  1354. // 发送日志
  1355. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1356. Log_SendArray_Debug(AT_result(), AT_result_length());
  1357. result = failed(); // 失败
  1358. }
  1359. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1360. {
  1361. // 发送日志
  1362. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1363. Log_SendArray_Debug(AT_result(), AT_result_length());
  1364. result = failed(); // 失败
  1365. }
  1366. return result;
  1367. }
  1368. /**
  1369. * 发送数据
  1370. * 输入<<
  1371. * connectID Socket ID。范围1-11。
  1372. * send_length 发送长度。
  1373. * data 待发送的数据。
  1374. *
  1375. * activeID 49
  1376. **/
  1377. enum Result bc260y_send_sync(uint8_t connectID, uint8_t * data, uint16_t data_length)
  1378. {
  1379. enum Result result = Result_None;
  1380. while(1)
  1381. {
  1382. result = bc260y_send(connectID, data, data_length);
  1383. if(result != Result_None)
  1384. {
  1385. // 重置
  1386. bc260y.reset();
  1387. break;
  1388. }
  1389. }
  1390. return result;
  1391. }
  1392. /**
  1393. * 发送数据
  1394. * 输入<<
  1395. * connectID Socket ID。范围1-11。
  1396. * send_length 发送长度。
  1397. * data 待发送的数据。
  1398. *rai 发送模式,0发送不释放RRC,1发送立即释放RRC,2发送返回释放RRC
  1399. * activeID 49
  1400. **/
  1401. enum Result bc260y_send_rai(uint8_t connectID, uint8_t * data, uint16_t data_length,uint8_t rai)
  1402. {
  1403. enum Result result = Result_None;
  1404. int activeID = 50, time = 10000; // 活动ID, 超时时间
  1405. // 校验ID
  1406. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1407. // 判断状态
  1408. if(getStatus() == Status_None) // 空闲状态
  1409. {
  1410. memset(AT_CMD, 0, sizeof(AT_CMD));
  1411. sprintf(AT_CMD + strlen(AT_CMD), "AT+QISEND=%d,%d,", connectID, data_length); // 拼接AT指令
  1412. for(uint16_t i = 0; i < data_length; i++)
  1413. {
  1414. sprintf(AT_CMD + strlen(AT_CMD), "%02X", data[i]);
  1415. }
  1416. sprintf(AT_CMD + strlen(AT_CMD), ",%d\r\n", rai); // 拼接AT指令
  1417. result = send_at(AT_CMD, activeID);
  1418. }
  1419. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1420. {
  1421. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1422. result = Result_Failed;
  1423. }
  1424. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1425. {
  1426. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1427. result = overtime(); // 超时
  1428. }
  1429. else if(strstr((char * )AT_result(), "SEND OK\r\n") != NULL) // 查询是否返回
  1430. {
  1431. // 发送日志
  1432. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1433. Log_SendArray_Debug(AT_result(), AT_result_length());
  1434. result = success(); // 成功
  1435. }
  1436. else if(strstr((char * )AT_result(), "SEND FALL\r\n") != NULL) // 查询是否返回
  1437. {
  1438. // 发送日志
  1439. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1440. Log_SendArray_Debug(AT_result(), AT_result_length());
  1441. result = failed(); // 失败
  1442. }
  1443. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1444. {
  1445. // 发送日志
  1446. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1447. Log_SendArray_Debug(AT_result(), AT_result_length());
  1448. result = failed(); // 失败
  1449. }
  1450. return result;
  1451. }
  1452. /**
  1453. * 发送数据
  1454. * 输入<<
  1455. * connectID Socket ID。范围1-11。
  1456. * send_length 发送长度。
  1457. * data 待发送的数据。
  1458. *
  1459. * activeID 49
  1460. **/
  1461. enum Result bc260y_send_rai_sync(uint8_t connectID, uint8_t * data, uint16_t data_length,uint8_t rai)
  1462. {
  1463. enum Result result = Result_None;
  1464. while(1)
  1465. {
  1466. result = bc260y_send_rai(connectID, data, data_length, rai);
  1467. if(result != Result_None)
  1468. {
  1469. // 重置
  1470. bc260y.reset();
  1471. break;
  1472. }
  1473. }
  1474. return result;
  1475. }
  1476. /**
  1477. * 接收数据
  1478. * 输入<<
  1479. * connectID Socket ID。范围0-11。
  1480. *
  1481. * 输出>>
  1482. * data 接收的数据。
  1483. * data_length 接收的数据长度。
  1484. *
  1485. **/
  1486. enum Result bc260y_recv(uint8_t connectID, uint8_t * data, uint16_t * data_length)
  1487. {
  1488. // 设置AT为使用中,防止被其他程序占用
  1489. AT_Set_Status(AT_Status_Using);
  1490. enum Result result = Result_None;
  1491. // 校验参数
  1492. if(connectID > 11)
  1493. {
  1494. Log_Printf_Debug("recv params error!\r\n");
  1495. return Result_Failed;
  1496. }
  1497. char cmp[20];
  1498. sprintf(cmp, "+QIURC: \"recv\",%d", connectID); // 拼接AT指令
  1499. // 判断是否接收到
  1500. if(strstr((char * )AT_result(), cmp) != NULL)
  1501. {
  1502. // 防止接收不完整
  1503. uint32_t last_time = AT_wait_time();
  1504. if(last_time > 10) // 过10ms之后再取数据,避免数据截断。
  1505. {
  1506. // 发送日志
  1507. Log_Printf_Debug("AT返回: %d, time_diff: %d\r\n", AT_result_length(), last_time);
  1508. // 分割结果,获取报文长度
  1509. char * saveptr = NULL;
  1510. char * split = ",";
  1511. strtok_r((char * )AT_result(), split, &saveptr);
  1512. strtok_r(NULL, split, &saveptr);
  1513. * data_length = strtoul(strtok_r(NULL, split, &saveptr), NULL, 10);
  1514. // 内存拷贝
  1515. memcpy(data,saveptr+1, *data_length);
  1516. // 成功
  1517. result = Result_Success;
  1518. // 清理一下AT返回结果缓存
  1519. AT_Clear_Result();
  1520. }
  1521. }
  1522. return result;
  1523. }
  1524. /**
  1525. * 接收数据。带计时
  1526. * 输入<<
  1527. * connectID Socket ID。范围0-11。
  1528. *
  1529. * 输出>>
  1530. * data 接收的数据。
  1531. * data_length 接收的数据长度。
  1532. *
  1533. **/
  1534. enum Result bc260y_recv_with_time(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1535. {
  1536. enum Result result = Result_None;
  1537. int activeID = 59, time = time_out; // 活动ID, 超时时间
  1538. // 校验ID
  1539. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1540. // 判断状态
  1541. if(getStatus() == Status_None) // 空闲状态
  1542. {
  1543. setStatus(Status_Sending);
  1544. }
  1545. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1546. {
  1547. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1548. result = Result_Failed;
  1549. }
  1550. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1551. {
  1552. Log_Printf_Debug("等待时间超时\r\n"); // 打印日志
  1553. result = overtime(); // 超时
  1554. Log_SendArray_Debug(AT_result(), AT_result_length());
  1555. }
  1556. else
  1557. {
  1558. // 接收数据
  1559. result = bc260y.recv(connectID, data, data_length);
  1560. if(result == Result_Success)
  1561. {
  1562. result = success(); // 成功
  1563. }
  1564. }
  1565. return result;
  1566. }
  1567. /**
  1568. * 接收数据。带计时
  1569. * 输入<<
  1570. * connectID Socket ID。范围0-11。
  1571. *
  1572. * 输出>>
  1573. * data 接收的数据。
  1574. * data_length 接收的数据长度。
  1575. *
  1576. **/
  1577. enum Result bc260y_recv_with_time_sync(uint8_t connectID, uint8_t * data, uint16_t * data_length, uint32_t time_out)
  1578. {
  1579. enum Result result = Result_None;
  1580. while(1)
  1581. {
  1582. result = bc260y_recv_with_time(connectID, data, data_length, time_out);
  1583. if(result != Result_None)
  1584. {
  1585. // 重置
  1586. bc260y.reset();
  1587. break;
  1588. }
  1589. }
  1590. return result;
  1591. }
  1592. /**
  1593. * 解释:关闭模块
  1594. * 关闭模块,关闭后会自动重启。
  1595. * 输入<<
  1596. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1597. *
  1598. * activeID 69
  1599. **/
  1600. enum Result bc260y_power_down(uint8_t n)
  1601. {
  1602. enum Result result = Result_None;
  1603. int activeID = 69, time = 3000; // 活动ID, 超时时间
  1604. // 校验ID
  1605. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1606. // 判断状态
  1607. if(getStatus() == Status_None) // 空闲状态
  1608. {
  1609. sprintf(AT_CMD, "AT+QPOWD=%d\r\n", n); // 拼接AT指令
  1610. result = send_at(AT_CMD, activeID);
  1611. }
  1612. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1613. {
  1614. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1615. result = Result_Failed;
  1616. }
  1617. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1618. {
  1619. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1620. result = overtime();
  1621. }
  1622. else if(strstr((char * )AT_result(), "POWERED DOWN\r\n") != NULL) // 查询是否返回
  1623. {
  1624. // 发送日志
  1625. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1626. Log_SendArray_Debug(AT_result(), AT_result_length());
  1627. // 成功结果
  1628. result = success();
  1629. }
  1630. return result;
  1631. }
  1632. /**
  1633. * 解释:关闭模块。同步
  1634. * 关闭模块,关闭后会自动重启。
  1635. * 输入<<
  1636. * n 模块关机方式。0 立即关机;1 正常关机。默认是1
  1637. *
  1638. * activeID 69
  1639. **/
  1640. enum Result bc260y_power_down_sync(uint8_t n)
  1641. {
  1642. enum Result result = Result_None;
  1643. while(1)
  1644. {
  1645. result = bc260y_power_down(n);
  1646. if(result != Result_None)
  1647. {
  1648. // 重置
  1649. bc260y.reset();
  1650. break;
  1651. }
  1652. }
  1653. return result;
  1654. }
  1655. /**
  1656. * 模块是否启动成功
  1657. * 输入<<
  1658. *
  1659. * 输出>>
  1660. *
  1661. **/
  1662. enum Result bc260y_ready(void)
  1663. {
  1664. if(AT_Get_Status() != AT_Status_None)
  1665. {
  1666. return Result_None;
  1667. }
  1668. enum Result result = Result_None;
  1669. // 判断是否接收到
  1670. uint8_t RDY[5]="RDY";
  1671. if(memmem(AT_result(),AT_result_length(),RDY,strlen((char *)RDY)) != 0)
  1672. {
  1673. // 发送日志
  1674. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1675. Log_SendArray_Debug(AT_result(), AT_result_length());
  1676. // 成功结果
  1677. result = Result_Success;
  1678. // 清理一下AT返回结果缓存
  1679. AT_Clear_Result();
  1680. }
  1681. return result;
  1682. }
  1683. /**
  1684. * 查询信号质量
  1685. * 输入<<
  1686. *
  1687. * 输出>>
  1688. * RSRP
  1689. * RSRQ
  1690. * RSSI
  1691. * SINR
  1692. **/
  1693. enum Result bc260y_qeng_servingcell(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1694. {
  1695. enum Result result = Result_None;
  1696. int activeID = 71, time = 500; // 活动ID, 超时时间
  1697. // 校验ID
  1698. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1699. // 判断状态
  1700. if(getStatus() == Status_None) // 空闲状态
  1701. {
  1702. //sprintf(AT_CMD, "AT+QENG=\"servingcell\"\r\n"); // 拼接AT指令
  1703. sprintf(AT_CMD, "AT+QENG=0\r\n"); // 拼接AT指令
  1704. result = send_at(AT_CMD, activeID);
  1705. }
  1706. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1707. {
  1708. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1709. result = failed(); // 失败
  1710. }
  1711. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1712. {
  1713. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1714. setStatus(Status_Overtime); // 超时
  1715. result = Result_Failed; // 结果
  1716. }
  1717. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1718. {
  1719. // 发送日志
  1720. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1721. Log_SendArray_Debug(AT_result(), AT_result_length());
  1722. // 处理返回结果
  1723. // char * saveptr = NULL;
  1724. // char * split = "\r\n";
  1725. char * saveptr_inner = NULL;
  1726. char * split_inner = ",\"";
  1727. strtok_r((char * )AT_result(), split_inner, &saveptr_inner);
  1728. strtok_r(NULL, split_inner, &saveptr_inner);
  1729. strtok_r(NULL, split_inner, &saveptr_inner);
  1730. strtok_r(NULL, split_inner, &saveptr_inner);
  1731. strtok_r(NULL, split_inner, &saveptr_inner);
  1732. * RSRP = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1733. * RSRQ = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1734. * RSSI = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1735. * SINR = atoi(strtok_r(NULL, split_inner, &saveptr_inner));
  1736. // 打印
  1737. Log_Printf_Debug("RSRP: %d, RSRQ: %d, RSSI: %d, SINR: %d\r\n", * RSRP, * RSRQ, * RSSI, * SINR);
  1738. result = success(); // 成功
  1739. }
  1740. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1741. {
  1742. // 发送日志
  1743. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1744. Log_SendArray_Debug(AT_result(), AT_result_length());
  1745. result = failed(); // 失败
  1746. }
  1747. return result;
  1748. }
  1749. enum Result bc260y_qeng_servingcell_sync(int * RSRP, int * RSRQ, int * RSSI, int * SINR)
  1750. {
  1751. enum Result result = Result_None;
  1752. while(1)
  1753. {
  1754. result = bc260y_qeng_servingcell(RSRP, RSRQ, RSSI, SINR);
  1755. if(result != Result_None)
  1756. {
  1757. // 重置
  1758. bc260y.reset();
  1759. break;
  1760. }
  1761. }
  1762. return result;
  1763. }
  1764. /**
  1765. * 查询ICCID
  1766. * 输入<<
  1767. *
  1768. * 输出>>
  1769. * iccid SIM卡卡号
  1770. **/
  1771. enum Result bc260y_query_qccid(char * iccid)
  1772. {
  1773. enum Result result = Result_None;
  1774. int activeID = 75, time = 500; // 活动ID, 超时时间
  1775. // 校验ID
  1776. if(!verifyActiveID(activeID)){ return Result_Failed; }
  1777. // 判断状态
  1778. if(getStatus() == Status_None) // 空闲状态
  1779. {
  1780. sprintf(AT_CMD, "AT+QCCID\r\n"); // 拼接AT指令
  1781. result = send_at(AT_CMD, activeID);
  1782. }
  1783. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1784. {
  1785. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1786. result = failed(); // 失败
  1787. }
  1788. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1789. {
  1790. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1791. setStatus(Status_Overtime); // 超时
  1792. result = Result_Failed; // 结果
  1793. }
  1794. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1795. {
  1796. // 发送日志
  1797. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1798. Log_SendArray_Debug(AT_result(), AT_result_length());
  1799. // 处理返回结果
  1800. char * saveptr = NULL;
  1801. char * split = "\r\n";
  1802. // 第一行
  1803. char * Line1 =strtok_r((char * )AT_result(), split, &saveptr);
  1804. // // 第二行
  1805. // char * Line2 = strtok_r(NULL, split, &saveptr);
  1806. // 拆解第二行
  1807. char * saveptr_inner = NULL;
  1808. char * split_inner = ": ,\"";
  1809. strtok_r(Line1, split_inner, &saveptr_inner);
  1810. // 字符串拷贝
  1811. strcpy(iccid, strtok_r(NULL, split_inner, &saveptr_inner));
  1812. // 打印
  1813. Log_Printf_Debug("ICCID: %s\r\n", iccid);
  1814. result = success(); // 成功
  1815. }
  1816. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1817. {
  1818. // 发送日志
  1819. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1820. Log_SendArray_Debug(AT_result(), AT_result_length());
  1821. result = failed(); // 失败
  1822. }
  1823. return result;
  1824. }
  1825. enum Result bc260y_query_qccid_sync(char * iccid)
  1826. {
  1827. enum Result result = Result_None;
  1828. while(1)
  1829. {
  1830. result = bc260y_query_qccid(iccid);
  1831. if(result != Result_None)
  1832. {
  1833. // 重置
  1834. bc260y.reset();
  1835. break;
  1836. }
  1837. }
  1838. return result;
  1839. }
  1840. /**
  1841. * 配置发送数据格式
  1842. * 输入<<
  1843. *n 0数据格式为文本字符串,1为十六进制字符串
  1844. *
  1845. **/
  1846. enum Result bc260y_dataformat(uint8_t n)
  1847. {
  1848. enum Result result = Result_None;
  1849. int activeID = 2, time = 500; // 活动ID, 超时时间
  1850. if(!verifyActiveID(activeID)){ return Result_Failed; } // 校验ID
  1851. // 判断状态
  1852. if(getStatus() == Status_None) // 空闲状态
  1853. {
  1854. sprintf(AT_CMD, "AT+QICFG=dataformat,%d,%d\r\n", n,0); // 拼接AT指令
  1855. result = send_at(AT_CMD, activeID);
  1856. }
  1857. else if(getStatus() != Status_Sending) // 上一次的结果没有清除,返回错误,为了保证时效性,需要重置状态。重新调用
  1858. {
  1859. Log_Printf_Debug("返回结果过期,请重置状态\r\n"); // 打印日志
  1860. result = failed(); // 失败
  1861. }
  1862. else if(getTimerMs() > time) // 正在发送状态。判断超时
  1863. {
  1864. Log_Printf_Debug("AT指令返回超时\r\n"); // 打印日志
  1865. result = overtime(); // 超时
  1866. }
  1867. else if(strstr((char * )AT_result(), "OK\r\n") != NULL) // 查询是否返回
  1868. {
  1869. // 发送日志
  1870. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1871. Log_SendArray_Debug(AT_result(), AT_result_length());
  1872. result = success(); // 成功
  1873. }
  1874. else if(strstr((char * )AT_result(), "ERROR\r\n") != NULL) // 查询是否返回
  1875. {
  1876. // 发送日志
  1877. Log_Printf_Debug("AT返回: %d\r\n", AT_result_length());
  1878. Log_SendArray_Debug(AT_result(), AT_result_length());
  1879. result = failed(); // 失败
  1880. }
  1881. return result;
  1882. }
  1883. /**
  1884. * 配置发送数据格式
  1885. * 输入<<
  1886. *n 0数据格式为文本字符串,1为十六进制字符串
  1887. *
  1888. **/
  1889. enum Result bc260y_dataformat_sync(uint8_t n)
  1890. {
  1891. enum Result result = Result_None;
  1892. while(1)
  1893. {
  1894. result =bc260y_dataformat(n);
  1895. if(result != Result_None)
  1896. {
  1897. // 重置
  1898. bc260y.reset();
  1899. break;
  1900. }
  1901. }
  1902. return result;
  1903. }
  1904. #endif