【设备云】Arduino Leonardo+红外传感器+SIM900A 制作简易客流统计系统（二）

onenet

完整的实例代码如下：

1. 
   
2. #include //JSON 数据封装库
   
3. #include //HTTP报头封装库
   
4. 
   
5. #define DEVICE_ID "Your device id"
   
6. #define HOSTADD "api.heclouds.com"
   
7. #define API_KEY  "Your api key"
   
8. #define TRYTIMES 1
   
9. #define RET_OK   0
   
10. #define RET_ERR  1
    
11. 
    
12. unsigned long timer1 = 0, timer2 = 0, comeIn = 0, goOut = 0;
    
13. char flag1 = 0, flag2 = 0;
    
14. 
    
15. void setup()
    
16. {
    
17.   Serial1.begin(115200);//初始化硬件串口，该串口接SIM900A模块
    
18.   Serial.begin(115200);//初始化USB虚拟串口，该串口作为打印调试用
    
19. 
    
20.   while (!Serial1)
    
21.   {
    
22.     ; // wait for serial port to connect. Needed for Leonardo only
    
23.   }
    
24.   while (!Serial)
    
25.   {
    
26.     ; // wait for serial port to connect. Needed for Leonardo only
    
27.   }
    
28. 
    
29.   attachInterrupt(0, getEventTime1, FALLING);//设置外部中断1触发模式和中断处理函数
    
30.   attachInterrupt(1, getEventTime2, FALLING);/设置外部中断2触发模式和中断处理函数
    
31. 
    
32.   while (1)
    
33.   {
    
34.     Serial1.println("AT+COPS?\r");//查询运营商信号
    
35.     delay(200);
    
36. 
    
37.     if (Serial1.find("CHINA MOBILE") == true )//发现中国移动运营商信号
    
38.     {
    
39.       Serial.println("CHINA MOBILE");
    
40.       break;
    
41.     }
    
42.   }
    
43.   sendCmd("AT+CLPORT="TCP","2000"\r");//设置本地端口号为2000
    
44. }
    
45. 
    
46. void loop()
    
47. {
    
48. 
    
49.   establishTCPConnect("AT+CIPSTART="TCP","183.230.40.33","80"\r");//与服务器建立TCP连接
    
50.   startSendData("AT+CIPSEND\r");//开启数据头程模式
    
51. 
    
52.   /*运用SDK进行HTTP包封装*/
    
53.   StaticJsonBuffer<200> jsonBuffer;//建立JSON字符串BUFFER
    
54.   JsonObject& jsonData = jsonBuffer.createObject();
    
55. 
    
56.   JsonArray& data = jsonData.createNestedArray("datastreams");
    
57.   addJsonDataRecord("come_in", comeIn, data);//在JSON串中添加come_in数据流记录
    
58.   addJsonDataRecord("Go_out", goOut, data);//在JSON串中添加Go_out数据流记录
    
59. 
    
60.   HttpPacketHead packetHead;//HTTP报头
    
61. 
    
62.   packetHead.setHostAddress(HOSTADD);//包头主机地址设置
    
63.   packetHead.setDevId(DEVICE_ID);//设置报头设备ID
    
64.   packetHead.setAccessKey(API_KEY);//设置API KEY
    
65.   packetHead.createCmdPacket(POST, TYPE_DATAPOINT, jsonData);//生成HTTP报头，这里需要传入上面生成的JSON串对象，该函数会自动计算该JSON串的长度并设置content length字段。
    
66. 
    
67.   Serial1.print(packetHead.content);//先发送报头数据
    
68. 
    
69.   jsonData.printTo(Serial1);//再发送HTTP报所带的JSON内容
    
70.   Serial1.println("&#65533;32");//结束数据传输
    
71. 
    
72.   delay(200);
    
73.   closeTCPConnect("AT+CIPCLOSE\r");//关闭TCP连接
    
74. }
    
75. 
    
76. /*外部中断1的中断处理函数，主要是记录中断发生的时间，判断人的行进方向*/
    
77. void getEventTime1(void)
    
78. {
    
79.   timer1 = millis();//记录中断发生的时间
    
80.   Serial.println(timer1);
    
81.   flag1 = 1;
    
82. 
    
83.   if (flag2)//中断2是否发生
    
84.   {
    
85.     flag1 = 0;
    
86.     flag2 = 0;
    
87.     if (timer2 > timer1)//根据发生时间判断人的行进方向
    
88.     {
    
89.       comeIn ++;
    
90.     }
    
91.     else
    
92.     {
    
93.       goOut ++;
    
94.     }
    
95.   }
    
96. }
    
97. 
    
98. /*外部中断2的中断处理函数，主要是记录中断发生的时间，判断人的行进方向*/
    
99. void getEventTime2(void)
    
100. {
     
101.   timer2 = millis();
     
102.   Serial.println(timer2);
     
103.   flag2 = 1;
     
104. 
     
105.   if (flag1)
     
106.   {
     
107.     flag1 = 0;
     
108.     flag2 = 0;
     
109.     if (timer2 > timer1)
     
110.     {
     
111.       comeIn ++;
     
112.     }
     
113.     else
     
114.     {
     
115.       goOut ++;
     
116.     }
     
117.   }
     
118. }
     
119. 
     
120. /*添加一条JSON数据流记录的处理函数*/
     
121. void addJsonDataRecord(char key[], int value, JsonArray& array)
     
122. {
     
123.   JsonObject& root = array.createNestedObject();
     
124.   root.add("id", key);
     
125.   JsonArray& data = root.createNestedArray("datapoints");
     
126.   JsonObject& root1 = data.createNestedObject();
     
127.   root1.add("value", value);
     
128. }
     
129. 
     
130. /*开启数据传送的处理函数*/
     
131. char startSendData(String data)
     
132. {
     
133.   int i = 0;
     
134.   Serial1.println(data);
     
135.   while (1)
     
136.   {
     
137.     delay(200);
     
138.     if ((Serial1.find(">") == true) || i > TRYTIMES)
     
139.     {
     
140.       Serial.println(data);
     
141.       break;
     
142.     }
     
143.     Serial1.println(data);
     
144.     i++;
     
145.   }
     
146.   return RET_OK;
     
147. }
     
148. 
     
149. /*向SIM900A发生AT指令的函数*/
     
150. char sendCmd(String data)
     
151. {
     
152.   int i = 0;
     
153.   Serial1.println(data);
     
154.   while (1)
     
155.   {
     
156.     delay(200);
     
157.     if ((Serial1.find("OK") == true) || i > TRYTIMES)
     
158.     {
     
159.       Serial.println(data);
     
160.       break;
     
161.     }
     
162.     Serial1.println(data);
     
163.     i++;
     
164.   }
     
165.   return RET_OK;
     
166. }
     
167. 
     
168. /*和服务器建立TCP连接得函数*/
     
169. char establishTCPConnect(String data)
     
170. {
     
171.   int i = 0;
     
172.   Serial1.println(data);
     
173.   while (1)
     
174.   {
     
175.     delay(200);
     
176.     if ((Serial1.find("CONNECT OK") == true) || i > TRYTIMES)
     
177.     {
     
178.       Serial.println("CONNECT OK");
     
179.       break;
     
180.     }
     
181.     Serial1.println(data);
     
182.     i++;
     
183.   }
     
184.   return RET_OK;
     
185. }
     
186. 
     
187. /*关闭和服务器的TCP连接*/
     
188. char closeTCPConnect(String data)
     
189. {
     
190.   int i = 0;
     
191.   Serial1.println(data);
     
192.   while (1)
     
193.   {
     
194.     delay(200);
     
195.     if ((Serial1.find("CLOSE OK") == true) || i > TRYTIMES)
     
196.     {
     
197.       Serial.println("CLOSE OK");
     
198.       break;
     
199.     }
     
200.     Serial1.println(data);
     
201.     i++;
     
202.   }
     
203.   return RET_OK;
     
204. }
     

复制代码

将代码写入Ardiuno Leonardo开发板，就按照好红外传感器就可以进行简单客流统计了，本实例中的客流统计功能只针对简单的统计场合，由于原理所限，对多种复杂的情况未做特殊处理，会产生误差。比如：两人并排通过的情况，系统计数为加1。在此处不做过多研究。开发板启动以后可以通过OneNeT平台查看客流统计情况。如题：
注意：运用SDK封装HTTP包时，占用内存比不用SDK封装要多，由于Ardiuno Leonardo比较小，在编程时对内存使用要小心，内存占用过大会造成开发板程序崩溃或者死机。

迷你强

文件头貌似缺东西

方恨少

谢谢提供湖码，相当不错的设计