兰州理工大学后花园盐渍土参数

王大富

主程序

1. #include <ESP8266WiFi.h>                         //esp8266wifi模块库
   
2. #include <ESP8266WiFiMulti.h>                    //自动链接最强wifi库
   
3. #include <DNSServer.h>                           //WiFiManager库要用的
   
4. #include <PubSubClient.h>                        //MQTT协议中的库
   
5. #include <Ticker.h>                              //时间记录库
   
6. #include <ArduinoJson.h>                         //调用Json数据库
   
7. #include <Wire.h>
   
8. //#include <WiFiManager.h>                         //WiFiManager库
   
9. #include "DHTesp.h"                              //温度DHT11模块函数库
   
10. #include "FastLED.h"                             //FastLED库用于调用随机函数库
    
11. #include <stdlib.h>                              //接收数据的转化
    
12. #include <stdio.h>
    
13. 
    
14. #include "JXBS.h"                                //土壤湿度库
    
15. #define debugSerial Serial1
    
16. 
    
17. 
    
18. #define PRODUCT_ID ""//Onenote产品名(需修改)
    
19. #define API_KEY    ""//产品密钥(需修改)
    
20. #define DEVICE_ID  ""                   //设备名(需修改)，与开发板没有关系，由平台生成的
    
21. const char* mqttServer = "183.230.40.39";        //onenet地址(不修改)
    
22. const uint16_t mqttPort = 6002;                  //mqtt接口端口(不修改)
    
23. #define TOPIC      "ceshitopic1"                 //订阅主题
    
24. 
    
25. 
    
26. 
    
27. #define LED1 D2
    
28. #define LED2 D3
    
29. #define LVDT_pin A0
    
30. 
    
31. ESP8266WiFiMulti wifiMulti;                      //自动链接wifi
    
32. DHTesp dht;                                      //温度
    
33. WiFiClient wifiClient;                           //
    
34. PubSubClient mqttClient(wifiClient);             //
    
35. Ticker ticker;                                   //用于记录时间
    
36. 
    
37. int count=0,aa =0,bt=0;                               //定义参数变量
    
38. char msgJson[200];//msgJson数据长度
    
39. char msg_buf[200];//
    
40. char dataTemplate[] = "{"RH5":%.2f,"T5":%.2f,"EC5":%.2f,"pH5":%.2f}";//char dataTemplate[] = "{"temp":%.2f,"hum":%.2f,"rand":%d,"sin":%.2f,"butt":%2d}";
    
41. extern float  T2 = 0.0, RH2 = 0.0, EC2 = 0.0,pH2=0.0, T4 = 0.0, RH4 = 0.0, EC4 = 0.0,pH4=0.0;                                       
    
42. 
    
43. 
    
44. void setup() {                                  //里面的函数只执行一次
    
45.   JXBSInit();
    
46.   debugSerial.begin(9600);
    
47.   
    
48.   wifiMulti.addAP("CMCC-PbWq","9bf07201");//添加多个wifi网络
    
49.   wifiMulti.addAP("4G-UFI-19DE","seuseucyd");
    
50.   wifiMulti.addAP("esp8266","esp82661");
    
51.   wifiMulti.addAP("4G-UFI-5FD6","onenetesp8266");
    
52.         
    
53. 
    
54.   WiFi.mode(WIFI_STA);                          //设置wifi模式
    
55. // dht.setup(D4, DHTesp::DHT11);                 //温湿度模块DHT11初始化，D4脚位
    
56.   connectWifi();                                //链接Wifi函数
    
57.   mqttClient.setServer(mqttServer, mqttPort);   //mqttServer是onenet地址，mqtt接口端口mqttPort
    
58.   mqttClient.setCallback(receiveCallback);      //设置MQTT订阅回调,函数
    
59.   connectMQTTServer();                          //链接MQTT服务器函数
    
60.   ticker.attach(1, tickerCount);  
    
61. }
    
62. 
    
63. void loop() {                                   //里面的函数无限循环执行
    
64.   if (mqttClient.connected()) {                 //如果开发板成功连接服务器                                         
    
65.       pubMQTTmsg();                             //调用pubMQTTmsg()函数发送数据到云端
    
66.       delay(3000);
    
67.       mqttClient.loop();  
    
68.   } else {                                      //如果开发板未能成功连接服务器
    
69.     connectMQTTServer();                        //则尝试连接服务器
    
70.   }
    
71. }
    
72. 
    
73. int tickerCount() {
    
74.   count++;
    
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. //    Serial.println("MQTT Server Connected.");
    
82. //    Serial.println("Server Address: ");
    
83. //    Serial.println(mqttServer);
    
84. //    Serial.println("ClientId:");
    
85. //    Serial.println(clientId);
    
86.     subscribeTopic();                          //订阅指定主题
    
87.   } else {
    
88.     //Serial.print("MQTT Server Connect Failed. Client State:");
    
89.    // Serial.println(mqttClient.state());
    
90.     delay(3000);
    
91.   }
    
92. }
    
93.                                                
    
94. void subscribeTopic() {//订阅指定主题,主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址
    
95.   String topicString = "temperature"+ WiFi.macAddress();
    
96.   char subTopic[topicString.length() + 1];
    
97.   strcpy(subTopic, topicString.c_str());       //                                                
    
98.   if (mqttClient.subscribe(subTopic)){         //通过串口监视器输出是否成功订阅主题以及订阅的主题名称
    
99.     //Serial.println("Subscrib Topic:");
    
100.     //Serial.println(subTopic);
     
101.   } else {
     
102.     //Serial.print("Subscribe Fail...");
     
103.   }
     
104. }
     
105. 
     
106. void receiveCallback(char* topic, byte* payload, unsigned int length) {//反调函数用于接收平台下发的消息
     
107.   //Serial.print("Message Received [");
     
108. // Serial.print(topic);
     
109.   //Serial.print("]");               
     
110.   for (int i = 0; i < length; i++){  //按字符一个一个输出
     
111.    // Serial.print((char)payload[i]);
     
112.   }
     
113.   //Serial.println("");
     
114. // Serial.print("Message Length(Bytes)");
     
115. // Serial.println(length);
     
116.   payload[length] = '\0'; // 添加一个空值使其转化为字符数组
     
117.   String payload1=(char *)payload;
     
118.   int aNumber = atoi((char *)payload);//将字符数组转化为整型数组
     
119.   //analogWrite(LED2, aNumber);  
     
120.   if (payload1 == "21"){//测试下发数据,如果收到的信息以“1”为开始
     
121.     //digitalWrite(LED2, HIGH);  // 点亮LED。
     
122.   //  Serial.println("LED ON");
     
123.   } else if (payload1 == "20"){
     
124.    // digitalWrite(LED2, LOW);  //熄灭LED。
     
125.    // Serial.println("LED OFF");
     
126.   }   
     
127. }                                                                 
     
128.                                                                            
     
129. void pubMQTTmsg() {                              //onenet数据点上传系统主题
     
130.   String topicString = "$dp";
     
131.   char publishTopic[topicString.length() + 1];
     
132.   strcpy(publishTopic, topicString.c_str());     //c_str()函数返回一个指向正规C字符串的指针, 内容与本string串相同,json数据转换为数组
     
133. 
     
134. ////////////////////////////////////////////////////////////
     
135. 
     
136. readJXBS20();
     
137. delay(1000);
     
138. JXBSListen20();
     
139. RH2=RH_2*0.1;   
     
140. T2=temper_2*0.1;  
     
141. 
     
142. delay(1000);
     
143.   
     
144. readJXBS21();
     
145. delay(1000);
     
146. JXBSListen21();  
     
147. EC2=EC_2;
     
148. 
     
149. delay(1000);
     
150.   
     
151. readJXBS22();
     
152. delay(1000);
     
153. JXBSListen22();  
     
154. pH2=pH_2*0.01;
     
155. ////////////////////////////////////////////////
     
156. 
     
157.   
     
158.   snprintf(msgJson, 130, dataTemplate,RH2,T2,EC2,pH2);//将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJson
     
159.   int json_len = strlen(msgJson);                //msgJson的长度
     
160.   msg_buf[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
     
161.   msg_buf[1] = char(json_len >> 8);              //数据第二位是要发送的数据长度的高八位
     
162.   msg_buf[2] = char(json_len & 0xff);            //数据第三位是要发送数据的长度的低八位
     
163.   memcpy(msg_buf + 3, msgJson, strlen(msgJson)); //从msg_buf的第四位开始,放入要传的数据msgJson
     
164.   msg_buf[3 + strlen(msgJson)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了
     
165.   //Serial.print("public message:");Serial.println(msgJson);//向串口发送订阅信息
     
166.   mqttClient.publish("$dp", (uint8_t *)msg_buf, 3 + strlen(msgJson)); //发送数据到主题$dp
     
167. // Serial.println(strlen(msgJson));
     
168. }
     
169. 
     
170. void connectWifi() {                              //wifi连接函数  
     
171.   //Serial.print("Connecting...");
     
172.   //WiFiManager wifiManager;// 建立WiFiManager对象
     
173.   //wifiManager.resetSettings();// 清除ESP8266所存储的WiFi连接信息以便测试WiFiManager工作效果
     
174.   //wifiManager.autoConnect("AutoConnectAP");// 自动连接WiFi。以下语句的参数是连接ESP8266时的WiFi名称  
     
175.   int ii=0;  
     
176.   while (wifiMulti.run() != WL_CONNECTED) {         //等待WiFi连接,成功连接后输出成功信息
     
177.   delay(1000);
     
178.   //Serial.print("ii++");Serial.print(" ");
     
179.   }
     
180.   //Serial.println('\n');                     // WiFi连接成功后
     
181.   //Serial.print("Connected to ");            // NodeMCU将通过串口监视器输出。
     
182.   //Serial.println(WiFi.SSID());              // 连接的WiFI名称
     
183.   //Serial.print("IP address:\t");            // 以及IP
     
184.   //Serial.println(WiFi.localIP());           // NodeMCU的IP地址  
     
185. }

复制代码

子程序

1. 
   
2. #define MYADRESS2 0x05  //485地址
   
3. 
   
4. //const unsigned char  readcmd20[8]={MYADRESS2,0x03,0x00,0x12,0x00,0x02,0x64,0x0E}; //读取温湿度指令
   
5. //const unsigned char  readcmd21[8]={MYADRESS2,0x03,0x00,0x15,0x00,0x01,0x95,0xCE}; //读取电导率指令
   
6. //const unsigned char  readcmd22[8]={MYADRESS2,0x03,0x00,0x06,0x00,0x01,0x64,0x0B}; //读取pH指令
   
7. 
   
8. //const unsigned char  readcmd20[8]={MYADRESS2,0x03,0x00,0x12,0x00,0x02,0x64,0x3D}; //读取温湿度指令
   
9. //const unsigned char  readcmd21[8]={MYADRESS2,0x03,0x00,0x15,0x00,0x01,0x95,0xFD}; //读取电导率指令
   
10. //const unsigned char  readcmd22[8]={MYADRESS2,0x03,0x00,0x06,0x00,0x01,0x64,0x38}; //读取pH指令
    
11. //
    
12. //const unsigned char  readcmd20[8]={MYADRESS2,0x03,0x00,0x12,0x00,0x02,0x65,0xEC}; //读取温湿度指令
    
13. //const unsigned char  readcmd21[8]={MYADRESS2,0x03,0x00,0x15,0x00,0x01,0x94,0x2C}; //读取电导率指令
    
14. //const unsigned char  readcmd22[8]={MYADRESS2,0x03,0x00,0x06,0x00,0x01,0x65,0xE9}; //读取pH指令
    
15. //
    
16. //const unsigned char  readcmd20[8]={MYADRESS2,0x03,0x00,0x12,0x00,0x02,0x64,0x5B}; //读取温湿度指令
    
17. //const unsigned char  readcmd21[8]={MYADRESS2,0x03,0x00,0x15,0x00,0x01,0x95,0x9B}; //读取电导率指令
    
18. //const unsigned char  readcmd22[8]={MYADRESS2,0x03,0x00,0x06,0x00,0x01,0x64,0x5E}; //读取pH指令
    
19. //
    
20. const unsigned char  readcmd20[8]={MYADRESS2,0x03,0x00,0x12,0x00,0x02,0x65,0x8A}; //读取温湿度指令
    
21. const unsigned char  readcmd21[8]={MYADRESS2,0x03,0x00,0x15,0x00,0x01,0x94,0x4A}; //读取电导率指令
    
22. const unsigned char  readcmd22[8]={MYADRESS2,0x03,0x00,0x06,0x00,0x01,0x65,0x8F}; //读取pH指令
    
23. 
    
24. 
    
25. unsigned int RH_2=0,temper_2=0,EC_2=0,pH_2=0.0,RH_4=0,temper_4=0,EC_4=0,pH_4=0.0;  //湿度
    
26. 
    
27. void JXBSInit()
    
28. {Serial.begin(9600);}
    
29. 
    
30. unsigned char com_buf[48]; //接收数据缓存变量
    
31. bool rec_flag=false;
    
32. bool rec_flag1=false;
    
33. bool receive_success_flag=false;
    
34. bool receive_success_flag1=false;
    
35. 
    
36. //////////////////////////////////////////////////////////////////////////////////
    
37. void readJXBS20()
    
38. {Serial.write(readcmd20,8);//发射数据
    
39. }
    
40. 
    
41. void JXBSListen20()
    
42. {unsigned char com_num = 0;
    
43. while (Serial.available())
    
44.    {char inChar = (char)Serial.read();
    
45.     com_buf[com_num] = inChar;
    
46.     com_num++;
    
47.     delay(2);
    
48.    }
    
49.     if(com_buf[0]==MYADRESS2 && com_buf[1]==0x03)
    
50.        {RH_2=com_buf[3]*256+com_buf[4];
    
51.        temper_2=com_buf[5]*256+com_buf[6];
    
52.        if (temper_2>32768){temper_2=temper_2-65536;}
    
53.        }  
    
54. }  
    
55. 
    
56. //---------------------------------------------------
    
57. void readJXBS21()
    
58. {Serial.write(readcmd21,8);//发射数据  
    
59. }
    
60. 
    
61. void JXBSListen21()
    
62. {unsigned char com_num = 0;
    
63. while (Serial.available())
    
64.     {char inChar = (char)Serial.read();//接收数据
    
65.      com_buf[com_num] = inChar;
    
66.      com_num++;
    
67.      delay(2);
    
68.     }
    
69. if(com_buf[0]==MYADRESS2 && com_buf[1]==0x03)
    
70.    {EC_2=com_buf[3]*256+com_buf[4];
    
71.    }     
    
72. }  
    
73. //---------------------------------------------------
    
74. void readJXBS22()
    
75. {Serial.write(readcmd22,8);//发射数据  
    
76. }
    
77. 
    
78. void JXBSListen22()
    
79. {unsigned char com_num = 0;
    
80. while (Serial.available())
    
81.     {char inChar = (char)Serial.read();//接收数据
    
82.      com_buf[com_num] = inChar;
    
83.      com_num++;
    
84.      delay(2);
    
85.     }
    
86. if(com_buf[0]==MYADRESS2 && com_buf[1]==0x03)
    
87.    {pH_2=com_buf[3]*256+com_buf[4];
    
88.    }     
    
89. }

复制代码

实物图

frankhan747

···于是乎？

hdku18

感谢分享！！！