用GSM模块连接乐联网

肥猫不吃鱼

目前有一版本可以 稳定的上传数据，需要的朋友留下邮箱。
下面的这个程序有点问题，板子是mega2560，我设置定时器为50ms中断，在中断服务函数中读取串口的数据到buffer中。然后在loop里面循环查找字符串，出现的问题是只能找到一次，后面的就不行了。上图：代码如下：

1. 
   
2. #include <FlexiTimer2.h>
   
3. #include <avr/wdt.h>
   
4. 
   
5. #define BAUD 115200
   
6. 
   
7. #define BufferLength 256                                         //接收缓冲区长度//
   
8. char buffer[BufferLength];                                        //接收缓冲区//
   
9. int RecieveCount=0;                                                //接收缓冲区计数//
   
10. 
    
11. #define TIMERPERIOD  60                                         //定时器设置为每50ms中断一次
    
12. #define TIMERCOUNT (50000/TIMERPERIOD)                            //每50s发送一次心跳。
    
13. int SystemTimeCount=0;                  
    
14. 
    
15. #define TRYTIMES 100                                                //发送一条指令，循环检测返回值的次数//
    
16. 
    
17. #define SendCmdSpeed  3000
    
18. 
    
19. #define DEBUG
    
20. 
    
21. 
    
22. bool LED=0;
    
23. bool LWOnline=0;                                                //乐联网在线标志， LWOnline=1，乐联网在线
    
24. bool TCPOnline=0;                                                //TCP 在线标记     TCPOnline=1 TCP在线
    
25. 
    
26. int PresentBufferLength=0;
    
27. 
    
28. void setup()
    
29. {
    
30.   Serial.begin(BAUD);
    
31.   pinMode(13,OUTPUT);                                                //上电后需要11秒左右完成相关的网络注册
    
32.   Serial.println("ATE0");
    
33.   delay(2000);
    
34.   FlexiTimer2::set(TIMERPERIOD,TimerISR);                                // 中断设置函数，每 TIMERPERIOD ms 进入一次count
    
35.   FlexiTimer2::start();                                             //开始计
    
36.   wdt_enable(WDTO_120MS); //开启看门狗，并设置溢出时间为60MS
    
37.   interrupts();
    
38. }
    
39. 
    
40. void TimerISR()
    
41. {
    
42.   wdt_reset(); //喂狗操作，使看门狗定时器复位
    
43.   
    
44.   //-----------------------------------------------------------//
    
45.   //读取串口数据到缓冲区，一次性读完当前串口的所有数据//
    
46.    while(Serial.available()>0)
    
47.      {
    
48.        if(RecieveCount >= BufferLength )
    
49.          RecieveCount=0;
    
50.             buffer[RecieveCount++]=Serial.read();
    
51.         digitalWrite(13,(LED^=1));
    
52.      }
    
53.     // Serial.println("the buffer is:");
    
54.     // Serial.println(buffer);
    
55. //----------------------------------------------------------------//
    
56. }
    
57. 
    
58. void loop()
    
59. {   
    
60.     if(TCPOnline == 0)
    
61.       {
    
62.         InitGsm();
    
63.          if(TCPOnline)  
    
64.           Serial.println("TCPOnline");     
    
65.       }
    
66.     if(LWOnline == 0)
    
67.       {
    
68.          RegisterLewei();
    
69.          if(LWOnline)  
    
70.           Serial.println("LWOnline");
    
71.           TCPOnline=0;
    
72.       }
    
73. }
    
74. //-----------------------------------------------------------------------------------------------------------------//
    
75. /*
    
76. 函数作用：发送cmd给GSM模块，目标返回respond ,enter是否发送回车，enter=1发送回车，否则不发
    
77. 函数说明：如果在指定次数内没有得到
    
78. */
    
79. char SendCmd(String cmd,boolean enter,boolean mulrespond,char *respond,char *respond2,char *ErrorCode)
    
80. {
    
81.   bool SearchRusult=0;
    
82.   unsigned char i=0;
    
83.   char *add1=NULL;
    
84.   char *add2=NULL;
    
85.   char *add3=NULL;
    
86. //------------------------------------------------------------------//
    
87. //发送数据
    
88.   if(enter==1)
    
89.     {
    
90.       Serial.println(cmd);
    
91.     }
    
92.   else
    
93.     {
    
94.        Serial.print(cmd);
    
95.     }
    
96.    delay(SendCmdSpeed);
    
97.   //----------------------------------------------------------------//  
    
98.   //等待GSM模块返回响应//
    
99.    add1=add2=add3=NULL;
    
100.     for(i=0;i<TRYTIMES;i++)
     
101.       {
     
102.             add1 = strstr(buffer,respond);               
     
103.         if(mulrespond == 1)
     
104.                   add2 = strstr(buffer,respond2);
     
105.         add3 = strstr(buffer,ErrorCode);                                                                                        //等待缓冲区更新一次数据//
     
106.         if(add1 != NULL )
     
107.           {
     
108.             add1 = NULL;
     
109.             CleanBuffer1(buffer,respond);
     
110.             return 1;
     
111.           }
     
112.           if(add2 != NULL && mulrespond==1)
     
113.           {
     
114.             add2 = NULL;
     
115.             //CleanBuffer1(buffer,add2);
     
116.             CleanBuffer1(buffer,respond2);
     
117.             return 1;
     
118.           }
     
119.         if(add3 != NULL)
     
120.           {
     
121.             add3 = NULL;
     
122.            // SendCmd("ATE0",1,0,"OK",NULL,"ERROR");                        //发送ATE0 可以让整个系统重新，回归正常//
     
123.             CleanBuffer1(buffer,ErrorCode);
     
124.             return 0;
     
125.           }
     
126.          //delay(50);      
     
127.       }
     
128.     return 0;  
     
129.    //--------------------------------------------------------------//  
     
130. }
     
131. //---------------------------------------------------------------------------------------------------------------------//
     
132. /*
     
133. 函数作用：清除当前字符串占用的缓存
     
134. 函数说明：null
     
135. */
     
136. int CleanBuffer1(char *str,char const *substr)
     
137. {
     
138.   if(str == NULL || substr == NULL)
     
139.     {
     
140.       return 0;
     
141.     }
     
142.   //标记str中substr开始的位置
     
143.   char * begin = str;
     
144.   //标记str中substr结束的位置
     
145.   char * end = str;
     
146.   //substr用于比较的游标指针
     
147.   char const * index = substr;
     
148.   while(*begin != '\0' && *end != '\0')
     
149.     {
     
150.       //在str中寻找substr
     
151.       while(*begin != *index)
     
152.         {
     
153.           begin++;
     
154.         }
     
155.       end = begin + 1;
     
156.       index++;
     
157.       while(*index == *end && *index != '\0' && *end != '\0')
     
158.         {
     
159.           index++;
     
160.           end++;
     
161.         }
     
162.       //如果index和end同时到达各自的字符串尾部，substr子串在str中被找到
     
163.       //例如str："abcdeXYZ"，substr："XYZ"
     
164.       if(*index == '\0' && *end == '\0')
     
165.         {
     
166.           *begin = '\0';
     
167.           //printf(str);
     
168.           return 1;
     
169.         }
     
170.       /* 如果index到达substr字符串尾部，而end没有到达str的尾部，substr子串在str中被找到
     
171.        * 例如str："abcdeXYZmn"，substr："XYZ"
     
172.       */
     
173.       else
     
174.         if(*index == '\0' && *end != '\0')
     
175.           {
     
176.              while(*begin++ = *end++);
     
177.              //printf(str);
     
178.              return 1;
     
179.           }
     
180.       /* 如果index未到达substr字符串尾部，而end有到达str的尾部，substr子串在str中未被找到
     
181.        * 例如str："abcdeXYZmn"，substr："XYZmnST"
     
182.        */
     
183.       else
     
184.         if(*index != '\0' && *end == '\0')
     
185.           {
     
186.             //printf(str);
     
187.             return 0;
     
188.           }
     
189.         /*字符串匹配尚未完成
     
190.         * 例如str："XYZabcdeXYZmnSTghd"，substr："XYZmnST"
     
191.         */
     
192.           else
     
193.             {
     
194.               begin++;
     
195.               end = begin;
     
196.               index = substr;
     
197.              }
     
198.         }
     
199.     return 0;
     
200. }
     
201. //---------------------------------------------------------------------------------------------------------------------//
     
202. /*
     
203. 函数功能：注册乐联网，也是心跳//
     
204. 函数说明：注册成功，LWOnline=1 否则LWOnline=0//
     
205. */
     
206. void RegisterLewei()
     
207. {
     
208.   char i=0;
     
209.   if(TCPOnline==1)
     
210.     {
     
211.       i=SendCmd("AT+CIPSEND",1,0,"FAN",">","ERROR");
     
212.       if(i)
     
213.         LWOnline=SendCmd("{"method":"update","gatewayNo":"01","userkey":"b8ad506aa60a4326a4d1365fc75e07bc"}&^!32",0,0,"SEND OK"," ","ERROR");
     
214.     }
     
215. }
     
216. //---------------------------------------------------------------------------------------------------------------------//
     
217. /*
     
218. 函数功能：初始化GSM模块，使其进入TCP数据传输模式//
     
219. 函数说明：初始化成功 TCPOnline=1，否则TCPOnline=0
     
220. */
     
221. void  InitGsm()
     
222. {
     
223.   TCPOnline=SendCmd("AT+CIPSTART="TCP","42.121.128.216","9960"",1,1,"CONNECT","ALREADY CONNECT","ERROR");
     
224. // TCPOnline=SendCmd("AT+CIPSEND",1,1,">",">","ERROR");
     
225. }
     
226. //---------------------------------------------------------------------------------------------------------------------//
     

复制代码

ifanr

学习了，程序不错

一路向西

[email protected]    谢谢