8通道电导率采集器

王大富

1. 
   

复制代码

1. //这个为esp32的主机程序，硬件选择DOIT ESP32 DEVKIT V1
   
2. #include <WiFi.h>
   
3. #include <PubSubClient.h>                        //MQTT协议中的库
   
4. #include <ArduinoJson.h>                         //调用Json数据库
   
5. #include <Wire.h>
   
6. #include "FastLED.h"                             //FastLED库用于调用随机函数库
   
7. #include <stdlib.h>                              //接收数据的转化
   
8. #include <stdio.h>
   
9. 
   
10. #include "TD4027.h"
    
11. #include "SDCARD.h"
    
12. #include "HMI.h"
    
13. 
    
14. ////////////////////////////////////////////////////////
    
15. #define PRODUCT_ID "447665"                      //Onenote产品名(需修改)
    
16. #define API_KEY    "KOPgb=Mqy3OgfZf8SE2eGjpSMoY="//"CDglbagwPMllUURDk9mO=qKTozU="//产品密钥(需修改)
    
17. #define DEVICE_ID  "852782109"                   //设备名(需修改)，与开发板没有关系，由平台生成的
    
18. const char* mqttServer = "183.230.40.39";        //onenet地址(不修改)
    
19. const uint16_t mqttPort = 6002;                  //mqtt接口端口(不修改)
    
20. #define TOPIC      "ceshitopic1"                 //订阅主题
    
21. ////////////////////////////////////////////////////////////
    
22. #define RUNLED 22
    
23. unsigned char nowpage = 0;
    
24. ///////////////////////////////////////////////////////////                                 
    
25. WiFiClient wifiClient;                           //
    
26. PubSubClient mqttClient(wifiClient);             //
    
27. //////////////////////////////////////////////
    
28. int count=0,aa =0,bt=0,i=0,ii=0,j=0,jj=0,ij=0,nn=5,n=20,m=1,k=0,kk=0,N=0,NN=100;//一分钟发nn=20                              //定义参数变量
    
29. float kvalue[8] = {1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0},tt;
    
30. float rawEC[8];
    
31. float value[8] ;
    
32. float ecValue[8] ;
    
33. float advalue1[8];
    
34. float ecValue_aver[8];
    
35. float ecValue_sum[8];
    
36. 
    
37. float ecValue_t[100][8];
    
38. ///////////////////////////////////
    
39. char msgJson[1000];//msgJson数据长度
    
40. char msgJson1[1000];//msgJson数据长度
    
41. char msg_buf[1000];//
    
42. char msg_buf1[1000];//
    
43. char dataTemplate0[] = "{"rtCH1":%.3f,"rtCH2":%.3f,"rtCH3":%.3f,"rtCH4":%.3f,"rtCH5":%.3f,"rtCH6":%.3f,"rtCH7":%.3f,"rtCH8":%.3f,"m":%d}"; //rt代表real time 实时数据
    
44. char dataTemplate1[] = "{"CH1":%.3f,  "CH2":%.3f,  "CH3":%.3f,  "CH4":%.3f,  "CH5":%.3f,  "CH6":%.3f,  "CH7":%.3f,  "CH8":%.3f}"; //间隔指定时间的数据               
    
45. 
    
46. //////////////////////////////////////////////  
    
47. const char* ssid = "4G-UFI-5FD6";
    
48. const char* password =  "onenetesp8266";
    
49. /////////////////////////////////////////////////
    
50. 
    
51. void setup() {
    
52.   Serial.begin(9600);
    
53. 
    
54.   TDInit();
    
55.   pinMode(RUNLED, OUTPUT);
    
56.   hmiInit(9600);
    
57. 
    
58.   WiFi.mode(WIFI_STA);                          //设置wifi模式
    
59.   WiFi.begin(ssid, password);
    
60.   connectWiFi();                                //链接Wifi函数
    
61.   mqttClient.setServer(mqttServer, mqttPort);   //mqttServer是onenet地址，mqtt接口端口mqttPort
    
62.   mqttClient.setCallback(receiveCallback);      //设置MQTT订阅回调,函数
    
63.   connectMQTTServer();                          //链接MQTT服务器函数
    
64. }
    
65. 
    
66. void loop() {
    
67.   if (mqttClient.connected()) {                 //如果开发板成功连接服务器                                         
    
68.       pubMQTTmsg();                             //调用pubMQTTmsg()函数发送数据到云端
    
69.       mqttClient.loop();                        //调用回调函数，接收平台下发的数据
    
70.   } else {                                      //如果开发板未能成功连接服务器
    
71.     connectMQTTServer();                        //则尝试连接服务器
    
72.   }
    
73.   
    
74. }
    
75. 
    
76. void connectMQTTServer() {                     //通过MQTT协议链接Onenet
    
77.   String clientId = DEVICE_ID;
    
78.   String productId = PRODUCT_ID;
    
79.   String apiKey = API_KEY;
    
80.   if (mqttClient.connect(clientId.c_str(), productId.c_str(), apiKey.c_str())) {//连接MQTT服务器
    
81.     subscribeTopic();                          //订阅指定主题
    
82.   } else {
    
83.     delay(3000);
    
84.   }
    
85. }
    
86.                                                
    
87. void subscribeTopic() {//订阅指定主题,主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址
    
88.   String topicString = "temperature"+ WiFi.macAddress();
    
89.   char subTopic[topicString.length() + 1];
    
90.   strcpy(subTopic, topicString.c_str());       //                                                
    
91.   if (mqttClient.subscribe(subTopic)){         //通过串口监视器输出是否成功订阅主题以及订阅的主题名称
    
92.   } else {
    
93.   }
    
94. }
    
95. ///////////////////////////////////
    
96. void receiveCallback(char* topic, byte* payload, unsigned int length) {//反调函数用于接收平台下发的消息              
    
97.   for (int i = 0; i < length; i++){  //按字符一个一个输出
    
98.   }
    
99.   payload[length] = '\0'; // 添加一个空值使其转化为字符数组
    
100.   String payload1=(char *)payload;
     
101.   m = atoi((char *)payload);//将字符数组转化为整型数组
     
102.   n=nn*m;
     
103.   if (payload1 == "21")//测试下发数据,如果收到的信息以“21”为开始
     
104.   {}
     
105.   else if (payload1 == "20")
     
106.   {}   
     
107. }                                                                 
     
108. ////////////////////////////////////////                                                                          
     
109. void pubMQTTmsg() {                              //onenet数据点上传系统主题
     
110.   String topicString = "$dp";
     
111.   char publishTopic[topicString.length() + 1];
     
112.   strcpy(publishTopic, topicString.c_str());     //c_str()函数返回一个指向正规C字符串的指针, 内容与本string串相同,json数据转换为数组
     
113. 
     
114. /////////////////////////////////////////////////////////////
     
115. for(ii=1;ii<=n;ii++){                                       
     
116. connectMQTTServer();
     
117. mqttClient.loop();                        //则尝试连接服务器
     
118. ledFlash();
     
119. ////////采集电导率数据/////////////////
     
120.   readDataOntimer();
     
121.   TDRListen();  
     
122.   //ECdata();
     
123.   
     
124.   for (k = 0; k < NN; k++)
     
125.   {readDataOntimer();//发送问询帧
     
126.    TDRListen();//接收问询帧
     
127.    ECdata();//根据测试电压计算电导率
     
128.    
     
129.    
     
130.    for (i = 0; i < 8; i++)
     
131.         {ecValue_t[k][i]=ecValue[i];
     
132.         
     
133.         }//行是读取次数，列是通道数        
     
134.        delay(10);//间隔10ms采集一个数据
     
135.   }
     
136.   
     
137.   sort();//数据排序
     
138.    
     
139.   for (j = 0; j < 8; j++)
     
140.       {ecValue_sum[j]=0;N=0;
     
141.       for (k = 20; k < 80; k++)
     
142.           {ecValue_sum[j]+=ecValue_t[k][j];N++;         
     
143.           }//去掉前后各20个数据
     
144.       ecValue[j]=ecValue_sum[j]/N;//取剩下数据平均值
     
145.       }
     
146. 
     
147.   hmiListen();
     
148.   showToHMI();
     
149. 
     
150. //////////////////////////////////////////////////////////////  
     
151. snprintf(msgJson, 800, dataTemplate0,ecValue[0],ecValue[1],ecValue[2],ecValue[3],ecValue[4],ecValue[5],ecValue[6],ecValue[7],m);//将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJson   
     
152.   int json_len = strlen(msgJson);                //msgJson的长度
     
153.   msg_buf[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
     
154.   msg_buf[1] = char(json_len >> 8);              //数据第二位是要发送的数据长度的高八位
     
155.   msg_buf[2] = char(json_len & 0xff);            //数据第三位是要发送数据的长度的低八位
     
156.   memcpy(msg_buf + 3, msgJson, strlen(msgJson)); //从msg_buf的第四位开始,放入要传的数据msgJson
     
157.   msg_buf[3 + strlen(msgJson)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了
     
158.   mqttClient.publish("$dp", (uint8_t *)msg_buf, 3 + strlen(msgJson)); //发送数据到主题$dp
     
159. }
     
160. //////////////////////////////////////////////////
     
161. snprintf(msgJson1, 800, dataTemplate1,ecValue[0],ecValue[1],ecValue[2],ecValue[3],ecValue[4],ecValue[5],ecValue[6],ecValue[7]);//将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJson   
     
162.   int json_len1 = strlen(msgJson1);                //msgJson的长度
     
163.   msg_buf1[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
     
164.   msg_buf1[1] = char(json_len1 >> 8);              //数据第二位是要发送的数据长度的高八位
     
165.   msg_buf1[2] = char(json_len1 & 0xff);            //数据第三位是要发送数据的长度的低八位
     
166.   memcpy(msg_buf1 + 3, msgJson1, strlen(msgJson1)); //从msg_buf的第四位开始,放入要传的数据msgJson
     
167.   msg_buf1[3 + strlen(msgJson1)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了  
     
168.   mqttClient.publish("$dp", (uint8_t *)msg_buf1, 3 + strlen(msgJson1)); //发送数据到主题$dp         
     
169. }
     
170. 
     
171. void connectWiFi() {                              //wifi连接函数   
     
172.   int ii=0;  
     
173.   while (WiFi.status()!= WL_CONNECTED) {         //等待WiFi连接,成功连接后输出成功信息
     
174.   delay(1000);
     
175.   }
     
176.   Serial.println('\n');                     // WiFi连接成功后
     
177.   Serial.print("Connected to ");            // NodeMCU将通过串口监视器输出。
     
178.   Serial.println(WiFi.SSID());              // 连接的WiFI名称
     
179.   Serial.print("IP address:\t");            // 以及IP
     
180.   Serial.println(WiFi.localIP());           // NodeMCU的IP地址  
     
181. }
     
182. /////////////////////////////////////////////////////////////////////////
     
183. void ECdata()
     
184. { for (kk = 0; kk < 8; kk++)
     
185.   {rawEC[kk] = (double)advalue[kk]*1000/820/196;//需要数据类型转换
     
186.   value[kk] = rawEC[kk]*kvalue[kk];
     
187.   ecValue[kk]=value[kk]/(1.0+0.0185*(25-25.0));
     
188.   }
     
189. }
     
190. 
     
191. 
     
192. float sort()
     
193. {
     
194. float temp1;
     
195. for(ij=0;ij<8;ij++)
     
196.     {for(ii=0;ii<NN-1;ii++)
     
197.       {for(jj=0;jj<NN-1-ii;jj++)
     
198.         {if(ecValue_t[jj][ij]>ecValue_t[jj+1][ij])
     
199.             {temp1=ecValue_t[jj][ij];
     
200.              ecValue_t[jj][ij]=ecValue_t[jj+1][ij];
     
201.              ecValue_t[jj+1][ij]=temp1;
     
202.             }
     
203.         }
     
204.       }
     
205.     }
     
206. 
     
207. }
     
208. ///////////////////////////////////////////////////////////////
     
209. void ledFlash()
     
210. {
     
211.   static unsigned long ledtimer;
     
212.   static bool output;
     
213.   if (millis() - ledtimer >= 1000)
     
214.   {
     
215.     ledtimer = millis();
     
216.     digitalWrite(RUNLED, output);
     
217.     output = !output;
     
218.   }
     
219. 
     
220. 
     
221. }
     
222. 
     
223. /*  HMI按键回调函数
     
224.    使用方法：如果在HMI端的按键勾选了“发送键值”，则可以在case 后添加 0x页面+按键+事件
     
225.    如果自定义 printh 65 03 12 01  则case 后面是 0x031201
     
226.    所有按键的动作都在这个函数里写
     
227. */
     
228. 
     
229. void keyEventCallBack(unsigned long keyvalue)
     
230. {
     
231. 
     
232.   switch (keyvalue)
     
233.   {
     
234.     case 0x000100: //进入主菜单
     
235.       nowpage = 1;
     
236.       break;
     
237. 
     
238.     case 0x010100: //进入通道电压监视
     
239.       nowpage = 2;
     
240.       delay(500); //页面滑动，最好阻塞一下
     
241.       break;
     
242.   }
     
243.   keyvalue = 0;
     
244. }
     
245. 
     
246. void showToHMI()
     
247. {
     
248.   if ( nowpage == 2)
     
249.   {
     
250.     String texttemp = "";
     
251.     texttemp = advalue[0];
     
252.     writeTextbox("t0", texttemp);
     
253.     delay(2);  //指令间加点延时，不至于两条指令混了
     
254.     texttemp = advalue[1];
     
255.     writeTextbox("t1", texttemp);
     
256.     delay(2);
     
257.     texttemp = advalue[2];
     
258.     writeTextbox("t2", texttemp);
     
259.     delay(2);
     
260.     texttemp = advalue[3];
     
261.     writeTextbox("t3", texttemp);
     
262.     delay(2);
     
263.     texttemp = advalue[4];
     
264.     writeTextbox("t4", texttemp);
     
265.     delay(2);
     
266.     texttemp = advalue[5];
     
267.     writeTextbox("t5", texttemp);
     
268.     delay(2);
     
269.     texttemp = advalue[6];
     
270.     writeTextbox("t6", texttemp);
     
271.     delay(2);
     
272.     texttemp = advalue[7];
     
273.     writeTextbox("t7", texttemp);
     
274.     delay(2);
     
275.   }
     
276. }

复制代码

HMI.h

1. /*
   
2. * 这是HMI的头文件，有些功能可能并没有用到
   
3. */
   
4. #define  hmiSerial Serial2
   
5. 
   
6. unsigned char hmi_done_flag = false;
   
7. //unsigned char  key_page = 0;
   
8. //unsigned char  key_id = 0;   
   
9. //unsigned char  key_event = 0; //按键事件，00
   
10. unsigned char  string_return_flag=false;
    
11. unsigned char  page_switch_flag = false;
    
12. unsigned char page_id=0;
    
13. unsigned char hmiBuf[32];
    
14. String textbox_text="";
    
15. 
    
16. extern void keyEventCallBack(unsigned long keyvalue);
    
17. void sendEnd(void) {
    
18.   hmiSerial.write(0xff);
    
19.   hmiSerial.write(0xff);
    
20.   hmiSerial.write(0xff);
    
21. }
    
22. void  hmiInit(unsigned int bandrate) {
    
23.   
    
24.   hmi_done_flag = false;
    
25. //  key_page = 0;
    
26. //  key_id = 0;
    
27. //  key_event = 0; //按键事件，00
    
28.   string_return_flag=false;
    
29.   page_switch_flag = false;
    
30.   hmiSerial.begin(bandrate);
    
31. }
    
32. 
    
33. void writeTextbox(String textbox_name, String textbox_text) {
    
34.   hmiSerial.print(textbox_name);
    
35.   hmiSerial.print(".txt=");
    
36.   hmiSerial.print(""");
    
37.   hmiSerial.print(textbox_text);
    
38.   hmiSerial.print(""");
    
39.   sendEnd();
    
40. }
    
41. 
    
42. void selectPage(unsigned char page_id) {
    
43.   String page = "";
    
44.   page = page_id;
    
45.   hmiSerial.print("page");
    
46.   hmiSerial.write(0x20);  //空格
    
47.   hmiSerial.print(page);
    
48.   sendEnd();
    
49. }
    
50. 
    
51. void writePicturebox(String picturebox_name, unsigned char picture_id) {
    
52.   String pic = "";
    
53.   pic = picture_id;
    
54.   hmiSerial.print(picturebox_name);
    
55.   hmiSerial.print(".pic=");
    
56.   hmiSerial.print(pic);
    
57.   sendEnd();
    
58. }
    
59. 
    
60. void writeNumbox(String numbox_name, int num) {
    
61.    hmiSerial.print(numbox_name);
    
62.   
    
63.   if(num<0)
    
64.   {hmiSerial.print(".val=-");
    
65.   hmiSerial.print(abs(num));
    
66.   }else
    
67.   {hmiSerial.print(".val=");
    
68.   hmiSerial.print(num);}
    
69.   sendEnd();
    
70. }
    
71. 
    
72. void setCombox(String Combox_name,unsigned char cbval) //设置下拉框
    
73. {
    
74.    hmiSerial.print(Combox_name);
    
75.   hmiSerial.print(".val=");
    
76.   hmiSerial.print(cbval);
    
77.   sendEnd();
    
78.   }
    
79. 
    
80. 
    
81. void writefloat(String floatname, unsigned int floatval) //写入虚拟浮点数，小数点在HMI端设定
    
82. {
    
83.   hmiSerial.print(floatname);
    
84.   hmiSerial.print(".val=");
    
85.   hmiSerial.print(floatval, DEC);
    
86.   sendEnd();
    
87. }
    
88. 
    
89. int key_data_return1=0;  //数值返回后合成的int
    
90. int key_data_return2=0;  //数值返回后合成的int
    
91. 
    
92. void hmiListen(void) {
    
93.   unsigned char hmi_num = 0;
    
94.   while (hmiSerial.available()) {
    
95.     char inChar = (char)hmiSerial.read();
    
96.     hmiBuf[hmi_num] = inChar;
    
97.     hmi_num++;
    
98.     hmi_done_flag = true;
    
99.     delay(2);//一定要加这个延时，否则串口最后一个字节可能收不到
    
100.   }
     
101. 
     
102.   if (hmi_done_flag == true)
     
103.   {
     
104.     if (hmiBuf[0] == 0x65) //按键事件
     
105.     {
     
106.       unsigned long keyvalue=hmiBuf[1]*0x10000+hmiBuf[2]*0x100+hmiBuf[3];   
     
107.    //   key_page = hmiBuf[1];
     
108.    //   key_id = hmiBuf[2];
     
109.    //   key_event = hmiBuf[3];
     
110.       key_data_return1=hmiBuf[5]*0x100+hmiBuf[4];
     
111.       key_data_return2=hmiBuf[9]*0x100+hmiBuf[8];
     
112.      if(key_data_return2>=32768)
     
113.     {
     
114.       key_data_return2=-1*(65536-key_data_return2);
     
115.       }
     
116.       keyEventCallBack(keyvalue);
     
117.   
     
118.     }
     
119.     if (hmiBuf[0] == 0x66) //页面切换事件，在HMI端前初始化事件中加入 printh 66 02 FF FF FF，02代表页面ID
     
120.     {
     
121.       page_id = hmiBuf[1];
     
122.     }
     
123.     if(hmiBuf[0]==0x70)  //get返回
     
124.     {
     
125.       unsigned char i=1;
     
126.       textbox_text="";
     
127.       while(hmiBuf[i]!=0xff)
     
128.       {
     
129.         textbox_text+=char(hmiBuf[i]);
     
130.         i=i+1;
     
131.       }
     
132.      string_return_flag=true;
     
133.      }
     
134.     hmi_done_flag = false;
     
135.   }
     
136. }
     
137. 
     
138. void clearBuf(void) {
     
139.   hmiSerial.print("code_c");
     
140.   sendEnd();
     
141. }
     
142. 
     
143. void resetHmi()  //重启
     
144. {
     
145.    hmiSerial.print("rest");
     
146.    sendEnd();
     
147. }

复制代码

SDCARD.h

1. /*
   
2.   依赖外部库：esp32-micro-sdcard-master.zip
   
3. */
   
4. #include <SPI.h>
   
5. #include <mySD.h>
   
6. File root;
   
7. 
   
8. bool SD_init()
   
9. {
   
10.   bool initflag = false;
    
11.   // Serial.begin(115200);
    
12.   // Serial.print("Initializing SD card...");
    
13.   /*初始化SD库SPI引脚*/
    
14.   if (!SD.begin(5, 23, 19, 18)) {
    
15.     initflag = false;
    
16.   } else
    
17.   {
    
18.     initflag = true;
    
19.   }
    
20.   return initflag;
    
21.   Serial.println("initialization done.");
    
22. 
    
23. }
    
24. /*从根目录root“/”*/
    
25. bool SD_openFileToWriteOnce(char *filepath,String text)
    
26. {
    
27.      root = SD.open(filepath, FILE_WRITE);
    
28.      if(root)
    
29.      {
    
30.      root.println(text);
    
31.      root.flush();
    
32.      /*关闭文件 */
    
33.      root.close();
    
34.      return 1;
    
35.      }else
    
36.      return 0;
    
37. }

复制代码

TD4027.h

1. 
   
2. HardwareSerial mySerial(1);
   
3. 
   
4. #define TDSerial Serial
   
5. #define DebugSerial mySerial
   
6. #define RS485DIR 21 //RS485的方向引脚
   
7. 
   
8. bool TDflag = false;
   
9. #define SLAVE_ARRDESS 0x01
   
10. 
    
11. const unsigned char readcmd[8] = {SLAVE_ARRDESS, 0x03, 0x00, 0x08, 0x00, 0x08, 0xC5, 0xCE};
    
12. unsigned char combuf[32];
    
13. int advalue[8] = {0, 0, 0, 0, 0, 0, 0, 0};
    
14. /*********
    
15.    //将两个字节转为16位的有符号int,因为esp32是32位机，单纯转为会出错。
    
16.    输入（高字节，低字节）
    
17.    输出，16位有符号整数
    
18. */
    
19. int byteToInt16(unsigned char highbyte, unsigned char lowbyte)
    
20. {
    
21.   int a;
    
22.   a = highbyte * 0x100 + lowbyte;
    
23.   if (a >= 32768)
    
24.   {
    
25.     a = -1 * (65536 - a);
    
26.   }
    
27.   return a;
    
28. }
    
29. 
    
30. 
    
31. void DebugOutput()
    
32. {
    
33. 
    
34.   DebugSerial.print("AD0：");
    
35.   DebugSerial.println(advalue[0], DEC);
    
36.   DebugSerial.print("AD1：");
    
37.   DebugSerial.println(advalue[1], DEC);
    
38.   DebugSerial.print("AD2：");
    
39.   DebugSerial.println(advalue[2], DEC);
    
40.   DebugSerial.print("AD3：");
    
41.   DebugSerial.println(advalue[3], DEC);
    
42.   DebugSerial.print("AD4：");
    
43.   DebugSerial.println(advalue[4], DEC);
    
44.   DebugSerial.print("AD5：");
    
45.   DebugSerial.println(advalue[5], DEC);
    
46.   DebugSerial.print("AD6：");
    
47.   DebugSerial.println(advalue[6], DEC);
    
48.   DebugSerial.print("AD7：");
    
49.   DebugSerial.println(advalue[7], DEC);
    
50. 
    
51. 
    
52. }
    
53. 
    
54. void TDInit()
    
55. {
    
56.   TDSerial.begin(9600);
    
57.   DebugSerial.begin(9600);
    
58. //33脚：RXD
    
59. //25脚：TXD
    
60.   mySerial.begin(9600,SERIAL_8N1,33,25);
    
61.   DebugSerial.println("debug");
    
62.   pinMode(RS485DIR, OUTPUT);
    
63.   digitalWrite(RS485DIR, LOW);
    
64. }
    
65. 
    
66. 
    
67. 
    
68. void readDataOntimer() //定时读取,放在loop中
    
69. {
    
70.   static unsigned char read_status;
    
71.   static unsigned long read_timer;
    
72. 
    
73.   switch (read_status)
    
74.   {
    
75.     case 0:
    
76.       digitalWrite(RS485DIR, HIGH);
    
77.       delay(2);
    
78.       TDSerial.write(readcmd, 8);
    
79.       delay(8); //延时20ms,等待数据发送完毕，波特率是9600，使用10位异步通信，则每秒可传960个字节，每个字节(字符)1.04毫秒。
    
80.       digitalWrite(RS485DIR, LOW);
    
81.       read_timer = millis();
    
82.       read_status++;
    
83.       break;
    
84. 
    
85.     case 1:
    
86.       if (millis() - read_timer >= 1000)
    
87.       {
    
88.         read_status = 0;
    
89.       }
    
90.       break;
    
91.       default:
    
92.       break;
    
93.   }
    
94. 
    
95. }
    
96. 
    
97. 
    
98. void TDRListen()  //放在loop中
    
99. {
    
100.   unsigned char num = 0;
     
101.   while (TDSerial.available()) {
     
102.     char inChar = (char)TDSerial.read();
     
103.     combuf[num] = inChar;
     
104.     num++;
     
105.     TDflag = true;
     
106.     delay(2);//一定要加这个延时，否则串口最后一个字节可能收不到
     
107.   }
     
108. 
     
109.   if (TDflag == true)
     
110.   {
     
111.     if (combuf[0] == SLAVE_ARRDESS and combuf[1] == 0x03) //并没有验证CRC,所以这方式不是最可靠的
     
112.     {
     
113.       advalue[0] = byteToInt16(combuf[3], combuf[4]);
     
114.       advalue[1] = byteToInt16(combuf[5], combuf[6]);
     
115.       advalue[2] = byteToInt16(combuf[7], combuf[8]);
     
116.       advalue[3] = byteToInt16(combuf[9], combuf[10]);
     
117.       advalue[4] = byteToInt16(combuf[11], combuf[12]);
     
118.       advalue[5] = byteToInt16(combuf[13], combuf[14]);
     
119.       advalue[6] = byteToInt16(combuf[15], combuf[16]);
     
120.       advalue[7] = byteToInt16(combuf[17], combuf[18]);
     
121.       combuf[0] = 0;
     
122.       combuf[1] = 0;
     
123.       //DebugOutput();  ///调试输出，可以去掉此句
     
124.     }
     
125.     TDflag = false;
     
126.   }
     
127. 
     
128. 
     
129. }

复制代码