Arduino电量采集 TCP透传方式上传乐联

maker_lin

一、主要实现功能

     arduino 通过 软串口 连接方式读取 电量模块 的数据， 并将数据通过ESP8266 采用 TCP透传 方式上传至乐联。

二、主要配件：

   1. ocrobot HEKR物联网开发板（测试使用，稳定运行后会换 arduino mini + ESP8266 ,）
   2. LT-518 电量计量模块
   3. AC220-DC12 电源模块（非必要，手头有闲置，所以用上了）

三、数据查看地址

     http://www.lewei50.com/u/g/9131

四、相关资料说明及成品图片

拿吃完的巧克力盒子凑合先用着


直接挂办公室电箱旁


这个是电量计量模块



模块的一些数据格式要求



电量计量模块相对比较简单，就是发送一组数据向模块请求数据，然后模块会返回一组数据， 格式都差不多，按照资料解析下数据就好。


各部分功能（简易流程）
1.   Arduino            >>>查询数据>>> 电量模块>>>返回数据
      Arduino            >>>读取数据>>> 整理数据格式>>>发送到串口 ESP8266
2.   ESP8266         >>>读取串口数据>>>转发到乐联

ESP8266是使用 arduino的IDE 编写的代码，这个使用方法可以参考http://www.arduino.cn/thread-17895-1-1.html 这篇文章


五、代码部分
arduino 代码

1. 
   
2. #include <Wire.h>
   
3. #include<SoftwareSerial.h>
   
4. 
   
5. 
   
6. 
   
7. unsigned char  Tx_Buffer[8];
   
8. unsigned char  Rx_Buffer[40];
   
9. unsigned char  read_enable, receive_finished, reveive_number;
   
10. 
    
11. float  Voltage_data, Current_data, Power_data, Energy_data, Pf_data, CO2_data;
    
12. float  Voltage,Current,Power,Energy,Pf,CO2;
    
13. 
    
14. SoftwareSerial softSerial(10, 11);
    
15. 
    
16. 
    
17. void setup() {
    
18. 
    
19.   Serial.begin(115200);         
    
20.   softSerial.begin(4800);
    
21.   softSerial.listen();
    
22. }
    
23. 
    
24. void loop() {
    
25. 
    
26.   write_data();
    
27.   delay(100);
    
28.   read_data();
    
29.   delay(100);
    
30.    Analysis_data();
    
31.    delay(100);
    
32. 
    
33.     float Voltage= Voltage_data/10000;
    
34.     float Current= Current_data/10000;
    
35.     float Power= Power_data/10000;
    
36.     float Energy= Energy_data/10000;
    
37.     float Pf= Pf_data/1000;
    
38.     float CO2= CO2_data/10000;
    
39. 
    
40.   Serial.println("{"method": "update","gatewayNo": "01","userkey": "*****************************"}&^!");
    
41.     delay(20000);
    
42.   //向乐联注册
    
43.   
    
44. Serial.print("{"method": "upload","data":[{"Name":"DY","Value":"");
    
45. Serial.print(Voltage);
    
46. Serial.print(""},{"Name":"DL","Value":"");
    
47. Serial.print(Current);
    
48. Serial.print(""},{"Name":"GL","Value":"");
    
49. Serial.print(Power);
    
50. Serial.print(""},{"Name":"YDL","Value":"");
    
51. Serial.print(Energy);
    
52. Serial.print(""},{"Name":"GLYS","Value":"");
    
53. Serial.print(Pf);
    
54. Serial.print(""},{"Name":"WD","Value":"");
    
55. Serial.print(CO2);
    
56. Serial.println(""}]}&^!");  
    
57.   delay(30000);
    
58. 
    
59. }
    
60. 
    
61. unsigned int calccrc(unsigned char crcbuf, unsigned int crc)
    
62. {
    
63.   unsigned char i;
    
64.   unsigned char chk;
    
65.   crc = crc ^ crcbuf;
    
66.   for (i = 0; i < 8; i++)
    
67.   {
    
68.     chk = ( unsigned char)(crc & 1);
    
69.     crc = crc >> 1;
    
70.     crc = crc & 0x7fff;
    
71.     if (chk == 1)
    
72.       crc = crc ^ 0xa001;
    
73.     crc = crc & 0xffff;
    
74.   }
    
75.   return crc;
    
76. }
    
77. 
    
78. unsigned int chkcrc(unsigned char *buf, unsigned char len)
    
79. {
    
80.   unsigned char hi, lo;
    
81.   unsigned int i;
    
82.   unsigned int crc;
    
83.   crc = 0xFFFF;
    
84.   for (i = 0; i < len; i++)
    
85.   {
    
86.     crc = calccrc(*buf, crc);
    
87.     buf++;
    
88.   }
    
89.   hi = ( unsigned char)(crc % 256);
    
90.   lo = ( unsigned char)(crc / 256);
    
91.   crc = (((unsigned int)(hi)) << 8) | lo;
    
92.   return crc;
    
93. }
    
94. 
    
95. void write_data(void)
    
96. {
    
97.   union        crcdata
    
98.   {
    
99.     unsigned int word16;
    
100.     unsigned char  byte[2];
     
101.   } crcnow;
     
102.   read_enable = 1;
     
103.   if (read_enable == 1)
     
104.   {
     
105.     read_enable = 0;
     
106.     Tx_Buffer[0] = 0x01;
     
107.     Tx_Buffer[1] = 0x03;
     
108.     Tx_Buffer[2] = 0x00;
     
109.     Tx_Buffer[3] = 0x48;
     
110.     Tx_Buffer[4] = 0x00;
     
111.     Tx_Buffer[5] = 0x06;
     
112.     crcnow.word16 = chkcrc(Tx_Buffer, 6);
     
113.     Tx_Buffer[6] = crcnow.byte[1];  
     
114.     Tx_Buffer[7] = crcnow.byte[0];
     
115.     softSerial.write(Tx_Buffer, 8) ;            
     
116.   }
     
117. }
     
118. 
     
119. void read_data()
     
120. {
     
121. 
     
122.   if ( softSerial.available() > 0 )
     
123.   {
     
124.    softSerial.readBytes(Rx_Buffer,34) ;
     
125.     delay(10);
     
126.    
     
127.   }
     
128. 
     
129. }
     
130. 
     
131. void Analysis_data(void)
     
132. {
     
133.   unsigned char i;
     
134.   union        crcdata
     
135.   {
     
136.     unsigned int word16;
     
137.     unsigned char  byte[2];
     
138.   } crcnow;
     
139.   receive_finished=1;
     
140.   if (receive_finished == 1)
     
141.   {
     
142.     receive_finished = 0;
     
143.     unsigned char reveive_numbe = 34;
     
144.     if (Rx_Buffer[0] == 0x01);
     
145.     {
     
146.       crcnow.word16 = chkcrc(Rx_Buffer, reveive_numbe - 2);
     
147.       if ((crcnow.byte[0] == Rx_Buffer[reveive_numbe - 1]) && (crcnow.byte[1] == Rx_Buffer[reveive_numbe - 2]))
     
148.       {
     
149.         Voltage_data = (((unsigned long)(Rx_Buffer[3])) << 24) | (((unsigned long)(Rx_Buffer[4])) << 16) | (((unsigned long)(Rx_Buffer[5])) << 8) | Rx_Buffer[6];
     
150.         Current_data = (((unsigned long)(Rx_Buffer[7])) << 24) | (((unsigned long)(Rx_Buffer[8])) << 16) | (((unsigned long)(Rx_Buffer[9])) << 8) | Rx_Buffer[10];
     
151.         Power_data = (((unsigned long)(Rx_Buffer[11])) << 24) | (((unsigned long)(Rx_Buffer[12])) << 16) | (((unsigned long)(Rx_Buffer[13])) << 8) | Rx_Buffer[14];
     
152.         Energy_data = (((unsigned long)(Rx_Buffer[15])) << 24) | (((unsigned long)(Rx_Buffer[16])) << 16) | (((unsigned long)(Rx_Buffer[17])) << 8) | Rx_Buffer[18];
     
153.         Pf_data = (((unsigned long)(Rx_Buffer[19])) << 24) | (((unsigned long)(Rx_Buffer[20])) << 16) | (((unsigned long)(Rx_Buffer[21])) << 8) | Rx_Buffer[22];
     
154.         CO2_data = (((unsigned long)(Rx_Buffer[23])) << 24) | (((unsigned long)(Rx_Buffer[24])) << 16) | (((unsigned long)(Rx_Buffer[25])) << 8) | Rx_Buffer[26];
     
155.    
     
156.       }
     
157.     }
     
158.   }
     
159. }
     
160. 
     

复制代码

esp8266 透传代码

1. 
   
2. #include <ESP8266WiFi.h>
   
3. const char *ssid     = "wifi ssid";//这里是我的wifi，你使用时修改为你要连接的wifi ssid
   
4. const char *password = "password";//你要连接的wifi密码
   
5. const char *host = "42.121.128.216";//修改为手机的的tcpServer服务端的IP地址，即手机在路由器上的ip
   
6. WiFiClient client;
   
7. const int tcpPort = 9960;//修改为你建立的Server服务端的端口号
   
8. 
   
9. 
   
10. void setup()
    
11. {
    
12.   Serial.begin(115200);
    
13.   delay(10);
    
14. 
    
15.   Serial.println();
    
16.   Serial.print("Connecting to ");
    
17.   Serial.println(ssid);
    
18. 
    
19.   WiFi.begin(ssid, password);
    
20. 
    
21.   while (WiFi.status() != WL_CONNECTED)//WiFi.status() ，这个函数是wifi连接状态，返回wifi链接状态
    
22.    
    
23.   {
    
24.     delay(500);
    
25.     Serial.print(".");
    
26.   }//如果没有连通向串口发送.....
    
27. 
    
28.   Serial.println("");
    
29.   Serial.println("WiFi connected");
    
30.   Serial.println("IP address: ");
    
31.   Serial.println(WiFi.localIP());//WiFi.localIP()返回8266获得的ip地址
    
32. }
    
33. 
    
34. 
    
35. void loop()
    
36. {
    
37.   while (!client.connected())//几个非连接的异常处理
    
38.   {
    
39.     if (!client.connect(host, tcpPort))
    
40.     {
    
41.       Serial.println("connection....");
    
42.       //client.stop();
    
43.       delay(500);
    
44. 
    
45.     }
    
46.   }
    
47. 
    
48. while (client.available())//无线读取到的数据转发到到串口
    
49.     {
    
50.         uint8_t c = client.read();
    
51.         Serial.write(c);
    
52.     }
    
53. 
    
54. 
    
55.     if (Serial.available())//串口读取到的转发到wifi，因为串口是一位一位的发送所以在这里缓存完再发送
    
56.     {
    
57.         size_t counti = Serial.available();
    
58.         uint8_t sbuf[counti];
    
59.         Serial.readBytes(sbuf, counti);
    
60.         client.write(sbuf, counti);
    
61. 
    
62.     }
    
63. 
    
64.   }
    
65. 
    
66. 
    
67. 
    

复制代码

爱上即可

赞  用的MODBUS  协议啊，楼主 留个QQ吧，有问题请教