HX711制作秤

王大富

其中HX711的DT连D5，SCK连D6，VCC连3.3v，GND链接GND。传感器的电源正接E+，电源负接E-，信号正接A+，信号负接A-。一般按红黑绿白接E+E-A+A-。
通过onenet平台远程清零，通过下发命令的形式调整数据采集时间，矫正系数需要调整。参考链接：https://www.yiboard.com/thread-1402-1-1.html。

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 "DHTesp.h"                              //温度DHT11模块函数库
   
9. #include "FastLED.h"                             //FastLED库用于调用随机函数库
   
10. #include <stdlib.h>                              //接收数据的转化
    
11. #include <stdio.h>
    
12. #include "HX711.h"
    
13. #define debugSerial Serial1
    
14. 
    
15. 
    
16. 
    
17. ////////////////////////////////////////////////////////
    
18. #define PRODUCT_ID "448207"                      //Onenote产品名(需修改)
    
19. #define API_KEY    "LHVGqRwz22HsF7h30cOF2bxh=3E="//"CDglbagwPMllUURDk9mO=qKTozU="//产品密钥(需修改)
    
20. #define DEVICE_ID  "773570218"                   //设备名(需修改)，与开发板没有关系，由平台生成的
    
21. const char* mqttServer = "183.230.40.39";        //onenet地址(不修改)
    
22. const uint16_t mqttPort = 6002;                  //mqtt接口端口(不修改)
    
23. #define TOPIC      "ceshitopic1"                 //订阅主题
    
24. ////////////////////////////////////////////////////////////
    
25. 
    
26. #define LED1 D4
    
27. #define LED2 D3
    
28. #define LVDT_pin A0
    
29. 
    
30. /////////////质量传感器/////////////
    
31. #define DT  D5 //将DT连D5
    
32. #define SCK  D6 //将SCK连D6
    
33. HX711 scale(DT, SCK);
    
34. float weight1,weight10;
    
35. long zero_factor;
    
36. float calibration_factor = -201525; // for me this vlaue works just perfect 419640
    
37. /////////////////////////////////
    
38. 
    
39. 
    
40. 
    
41. ESP8266WiFiMulti wifiMulti;                      //自动链接wifi
    
42. DHTesp dht;                                      //温度
    
43. WiFiClient wifiClient;                           //
    
44. PubSubClient mqttClient(wifiClient);             //
    
45. Ticker ticker;                                   //用于记录时间
    
46. 
    
47. //////////////////////////////////////////////
    
48. int count=0,aa =0,bt=0,ii=0,nn=5,n=20,m=1,j; //一分钟发nn=20
    
49. char msgJson[1000];//msgJson数据长度
    
50. char msgJson1[1000];//msgJson数据长度
    
51. char msg_buf[1000];//
    
52. char msg_buf1[1000];//
    
53. char dataTemplate[] = "{"rtWeight":%.4f,"m":%d}";
    
54. char dataTemplate1[]  = "{"Weight":%.4f}";
    
55.                
    
56. ////////////////////////////////////////////
    
57. 
    
58. void setup() {                                  //里面的函数只执行一次
    
59.   debugSerial.begin(9600);
    
60. ///////////////////////////////////////////////  
    
61.   wifiMulti.addAP("CMCC-PbWq","9bf07201");//添加多个wifi网络
    
62.   wifiMulti.addAP("4G-UFI-19DE","seuseucyd");
    
63.   wifiMulti.addAP("esp8266","esp82661");
    
64.   wifiMulti.addAP("4G-UFI-5FD6","onenetesp8266");
    
65.   wifiMulti.addAP("MERCURY_6A1A","datalogging");
    
66.   wifiMulti.addAP("4G-CPE-6CAA","12345678");
    
67.   wifiMulti.addAP("YWGCJD-WIFI","12345678");
    
68. /////////////////////////////////////////////////
    
69. 
    
70. //////////////////////质量传感器///////////////////////
    
71.   scale.set_scale();
    
72.   scale.tare(); //Reset the scale to 0
    
73.   zero_factor = scale.read_average(); //Get a baseline reading
    
74.   delay(2000);
    
75. //////////////////////////////////////////////////     
    
76. 
    
77.   WiFi.mode(WIFI_STA);                          //设置wifi模式
    
78.   connectWifi();                                //链接Wifi函数
    
79.   mqttClient.setServer(mqttServer, mqttPort);   //mqttServer是onenet地址，mqtt接口端口mqttPort
    
80.   mqttClient.setCallback(receiveCallback);      //设置MQTT订阅回调,函数
    
81.   connectMQTTServer();                          //链接MQTT服务器函数
    
82.   ticker.attach(1, tickerCount);  
    
83. }
    
84. 
    
85. void loop() {                                   //里面的函数无限循环执行
    
86.   if (mqttClient.connected()) {                 //如果开发板成功连接服务器                                         
    
87.       pubMQTTmsg();                             //调用pubMQTTmsg()函数发送数据到云端
    
88.       mqttClient.loop();                        //调用回调函数，接收平台下发的数据
    
89.   } else {                                      //如果开发板未能成功连接服务器
    
90.     connectMQTTServer();                        //则尝试连接服务器
    
91.   }
    
92. }
    
93. 
    
94. int tickerCount() {count++;}
    
95. 
    
96. void connectMQTTServer() {                     //通过MQTT协议链接Onenet
    
97.   String clientId = DEVICE_ID;
    
98.   String productId = PRODUCT_ID;
    
99.   String apiKey = API_KEY;
    
100.   if (mqttClient.connect(clientId.c_str(), productId.c_str(), apiKey.c_str())) {//连接MQTT服务器
     
101.     subscribeTopic();                          //订阅指定主题
     
102.   } else {
     
103.     delay(3000);
     
104.   }
     
105. }
     
106.                                                
     
107. void subscribeTopic() {//订阅指定主题,主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址
     
108.   String topicString = "temperature"+ WiFi.macAddress();
     
109.   char subTopic[topicString.length() + 1];
     
110.   strcpy(subTopic, topicString.c_str());       //                                                
     
111.   if (mqttClient.subscribe(subTopic)){         //通过串口监视器输出是否成功订阅主题以及订阅的主题名称
     
112.   } else {
     
113.   }
     
114. }
     
115. ///////////////////////////////////
     
116. void receiveCallback(char* topic, byte* payload, unsigned int length) {//反调函数用于接收平台下发的消息            
     
117.   for (int i = 0; i < length; i++){  //按字符一个一个输出
     
118.   }
     
119.   payload[length] = '\0'; // 添加一个空值使其转化为字符数组
     
120.   String payload1=(char *)payload;
     
121.   
     
122.   m = atoi((char *)payload);//将字符数组转化为整型数组  
     
123.   if (payload1 == "31000"){//测试下发数据,如果收到的信息以“1”为开始
     
124.     j=0;//用于清零
     
125.     } else if (payload1 == "30000"){}
     
126.     else { n=nn*m; }   
     
127. }                                                                 
     
128. ////////////////////////////////////////
     
129.                                                                           
     
130. void pubMQTTmsg() {                              //onenet数据点上传系统主题
     
131.   String topicString = "$dp";
     
132.   char publishTopic[topicString.length() + 1];
     
133.   strcpy(publishTopic, topicString.c_str());     //c_str()函数返回一个指向正规C字符串的指针, 内容与本string串相同,json数据转换为数组
     
134. 
     
135. /////////////////////////////////////////////////////////////
     
136. for(ii=1;ii<=n;ii++){                                       
     
137. connectMQTTServer();                        //则尝试连接服务器
     
138. mqttClient.loop();
     
139. 
     
140. ////////////////质量传感器///////////////////////
     
141.   scale.set_scale(calibration_factor); //Adjust to this calibration factor
     
142.   delay(1000);
     
143.   weight1 = 1000*scale.get_units(5);//
     
144. if(j==0){
     
145.   weight10=weight1;weight1=0; //DATA10用于储存清零前的质量
     
146.   j=1;
     
147.   }
     
148. else {
     
149.   weight1=weight1-weight10;;//清零后显示的就是真实质量
     
150.   }
     
151. 
     
152.   weight1=-weight1;
     
153.   snprintf(msgJson, 100, dataTemplate,weight1,m);//将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJson
     
154. ////////////////////////////////////////////////////
     
155. 
     
156.   int json_len = strlen(msgJson);                //msgJson的长度
     
157.   msg_buf[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
     
158.   msg_buf[1] = char(json_len >> 8);              //数据第二位是要发送的数据长度的高八位
     
159.   msg_buf[2] = char(json_len & 0xff);            //数据第三位是要发送数据的长度的低八位
     
160.   memcpy(msg_buf + 3, msgJson, strlen(msgJson)); //从msg_buf的第四位开始,放入要传的数据msgJson
     
161.   msg_buf[3 + strlen(msgJson)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了
     
162.   mqttClient.publish("$dp", (uint8_t *)msg_buf, 3 + strlen(msgJson)); //发送数据到主题$dp
     
163. }
     
164. //////////////////////////////////////////////////
     
165. snprintf(msgJson1, 100, dataTemplate1,weight1);
     
166.   int json_len1 = strlen(msgJson1);                //msgJson的长度
     
167.   msg_buf1[0] = char(0x03);                       //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3
     
168.   msg_buf1[1] = char(json_len1 >> 8);              //数据第二位是要发送的数据长度的高八位
     
169.   msg_buf1[2] = char(json_len1 & 0xff);            //数据第三位是要发送数据的长度的低八位
     
170.   memcpy(msg_buf1 + 3, msgJson1, strlen(msgJson1)); //从msg_buf的第四位开始,放入要传的数据msgJson
     
171.   msg_buf1[3 + strlen(msgJson1)] = 0;              //添加一个0作为最后一位, 这样要发送的msg_buf准备好了  
     
172.   mqttClient.publish("$dp", (uint8_t *)msg_buf1, 3 + strlen(msgJson1)); //发送数据到主题$dp
     
173.          
     
174. }
     
175. 
     
176. void connectWifi() {                              //wifi连接函数   
     
177.   int ii=0;  
     
178.   while (wifiMulti.run() != WL_CONNECTED) {         //等待WiFi连接,成功连接后输出成功信息
     
179.   delay(1000);
     
180.   }
     
181.   Serial.println('\n');                     // WiFi连接成功后
     
182.   Serial.print("Connected to ");            // NodeMCU将通过串口监视器输出。
     
183.   Serial.println(WiFi.SSID());              // 连接的WiFI名称
     
184.   Serial.print("IP address:\t");            // 以及IP
     
185.   Serial.println(WiFi.localIP());           // NodeMCU的IP地址  
     
186. }

复制代码