【Arrow 有好料】DFR0654智能取暖器之成品篇

eefocus_3914144

这段时间降温好大呀，好冷，为此做一款智能取暖器，是不是很实用呀。
1、材料
(1)报废取暖器一个（加热丝没有坏）
(2)开关电源（220V转5V）
(3)固态继电器1个
(4)DRF0654开发板一个。
(5)Sh30温湿度传感器
2、开发环境
(1)Win10
(2)Arduino
(3)Python11
(4)Pycharm
3、DRF0564工作流程
[size=10.5000pt]
[size=10.5000pt]4、远程桌面工作流程

软件源代码】
DRF0654

1. // This example uses an ESP32 Development Board
   
2. // to connect to shiftr.io.
   
3. //
   
4. // You can check on your device after a successful
   
5. // connection here: https://www.shiftr.io/try.
   
6. //
   
7. // by Joël Gähwiler
   
8. // https://github.com/256dpi/arduino-mqtt
   
9. 
   
10. #include <WiFi.h>
    
11. #include <MQTT.h>
    
12. #include "Wire.h"
    
13. #include "SHT31.h"
    
14. 
    
15. #define HAETPIN  D9  //加热开关
    
16. #define SHT31_ADDRESS   0x44
    
17. 
    
18. 
    
19. #define defultWorkValue 25;
    
20. 
    
21. SHT31 sht;
    
22. char buffer[80];
    
23. const char ssid[] = "SSID";
    
24. const char pass[] = "pwd";
    
25. 
    
26. int temperUpValue;   //最高值
    
27. int temperDownValue; //最低值
    
28. float thisTemperValud;
    
29. int temperSetValue;   //设置目标值
    
30. 
    
31. int swtickState = 0;  //开关状态
    
32. int onoff = 0;     //是否打开取暖器
    
33. WiFiClient net;
    
34. MQTTClient client;
    
35. 
    
36. unsigned long lastMillis = 0;
    
37. 
    
38. void hearContrl(void)
    
39. {
    
40.   if(onoff == 1)
    
41.   {
    
42.     if(thisTemperValud > temperSetValue +1)
    
43.     {
    
44.       digitalWrite(HAETPIN, LOW);
    
45.     }
    
46.     else if(thisTemperValud < temperSetValue -1)
    
47.     {
    
48.       digitalWrite(HAETPIN, HIGH);
    
49.     }
    
50.   }
    
51.   else
    
52.   {
    
53.     digitalWrite(HAETPIN, LOW);
    
54.   }
    
55. }
    
56. void connect() {
    
57.   Serial.print("checking wifi...");
    
58.   while (WiFi.status() != WL_CONNECTED) {
    
59.     Serial.print(".");
    
60.     delay(1000);
    
61.   }
    
62. 
    
63.   Serial.print("\nconnecting...");
    
64.   while (!client.connect("clietid", "username", "pwd")) {
    
65.     Serial.print(".");
    
66.     delay(1000);
    
67.     //连接后，发送获取状态：
    
68. 
    
69.   }
    
70. 
    
71.   Serial.println("\nconnected!");
    
72. 
    
73.   client.subscribe("/topic/#");
    
74.   //连接后发送远程状态
    
75. 
    
76. }
    
77. 
    
78. void messageReceived(String &topic, String &payload) {
    
79. 
    
80.   //如果是开机，
    
81.   //设置目标温度值
    
82.   //如果小于温度值测发出开机信号
    
83. 
    
84.   //如果是设置温度值测更新温度值
    
85.   if(topic == "/topic/hearset")
    
86.   {
    
87.     Serial.println("incoming: " + topic + " - " + payload);
    
88.     temperSetValue = payload.toInt();
    
89.   }
    
90.   else if(topic == "/topic/heartonoff")
    
91.   {
    
92.     Serial.println("incoming: " + topic + " - " + payload);
    
93.     if(payload == "on")
    
94.     {
    
95.       //对应的IO高电平
    
96.       onoff = 1;
    
97. 
    
98.     }
    
99.     else if(payload == "off")
    
100.     {
     
101.         //对应的IO低电平
     
102.         onoff = 0;
     
103. 
     
104.     }
     
105.   }
     
106.   // Note: Do not use the client in the callback to publish, subscribe or
     
107.   // unsubscribe as it may cause deadlocks when other things arrive while
     
108.   // sending and receiving acknowledgments. Instead, change a global variable,
     
109.   // or push to a queue and handle it in the loop after calling `client.loop()`.
     
110. }
     
111. 
     
112. void setup() {
     
113.   pinMode(HAETPIN,OUTPUT);
     
114.   digitalWrite(HAETPIN, LOW);
     
115.   onoff = 0;
     
116.   Wire.begin();
     
117.   Wire.setClock(100000);
     
118.   sht.begin();
     
119. 
     
120.   uint16_t stat = sht.readStatus();
     
121.   Serial.print(stat, HEX);
     
122.   Serial.println();
     
123. 
     
124.   Serial.begin(115200);
     
125.   WiFi.begin(ssid, pass);
     
126. 
     
127.   // Note: Local domain names (e.g. "Computer.local" on OSX) are not supported
     
128.   // by Arduino. You need to set the IP address directly.
     
129.   client.begin("域名", net);
     
130.   client.onMessage(messageReceived);
     
131. 
     
132.   connect();
     
133. }
     
134. 
     
135. void loop() {
     
136.   client.loop();
     
137.   delay(10);  // <- fixes some issues with WiFi stability
     
138. 
     
139.   if (!client.connected()) {
     
140.     connect();
     
141.   }
     
142. 
     
143.   // publish a message roughly every second.
     
144.   if (millis() - lastMillis > 1000) {
     
145.     lastMillis = millis();
     
146.     sht.read();   
     
147.     thisTemperValud = sht.getTemperature();
     
148.     snprintf(buffer, sizeof(buffer), "{"Temperature":"%.1f", "Humidity":"%.1f%", "WorkState":"%d"}", thisTemperValud , sht.getHumidity(), onoff);
     
149.     Serial.println(buffer);
     
150.     client.publish("/topic/heart", buffer);
     
151.     hearContrl();
     
152.   }
     
153. 
     
154. }

复制代码

【控制界面】
采用QT来制作

[size=10.5000pt]控制端程序：

1. import sys
   
2. import time
   
3. import json
   
4. import re
   
5. from paho.mqtt import client as mqtt
   
6. from PyQt5.QtWidgets import QWidget, QApplication
   
7. from PyQt5.QtCore import QTime, QTimer
   
8. from electriheater import Ui_MainWindow
   
9. from PyQt5.QtWidgets import QApplication, QMainWindow
   
10. class AppGui(QMainWindow,Ui_MainWindow):
    
11.     def __init__(self):
    
12.         super(AppGui,self).__init__()
    
13.         self.setupUi(self)
    
14. 
    
15.         self.lcdNumberThishTemp.display(10.233)
    
16.         self.pushButton_client_sever.clicked.connect(self.connect_mqtt)
    
17.         self.horizontalSliderSetting.valueChanged.connect(self.setLcdShow)
    
18.         self.horizontalSliderSetting.sliderReleased.connect(self.temperSet)
    
19.         self.pushButtonOnOff.clicked.connect(self.openoffHeart)
    
20. 
    
21.     def openoffHeart(self):
    
22.         if self.pushButtonOnOff.text() == "开启取暖器":
    
23.             self.on_publish("/topic/heartonoff", "on", 1)
    
24.             # self.pushButtonOnOff.setText("关闭取暖器")
    
25.         else:
    
26.             self.on_publish("/topic/heartonoff", "off", 1)
    
27.             # self.pushButtonOnOff.setText("开启取暖器")
    
28. 
    
29.     def mqttlj(self):
    
30.         client_id = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time()))
    
31.         self.client = mqtt.Client(client_id)
    
32.         self.client.username_pw_set(self.Username,self.Password)
    
33.         self.client.on_connect = self.on_connect
    
34.         self.client.on_message = self.on_message
    
35.         self.client.connect(self.HOST,self.PORT,600)
    
36.         self.client.loop_start()
    
37.         print(self.Username, self.Password, self.HOST, self.PORT)
    
38. 
    
39.     def setLcdShow(self):
    
40.         self.lcdNumberSetTemp.display(self.horizontalSliderSetting.value())
    
41.     def temperSet(self):
    
42.         tempSetValue = self.horizontalSliderSetting.value()
    
43.         print("设置温度")
    
44.         self.on_publish("/topic/hearset",str(tempSetValue),1)
    
45.         # 发送publissh
    
46.     def conn_Ck(self):
    
47.         self.Username = "username"
    
48.         self.Password = "pwd"
    
49.         self.HOST = "域名"
    
50.         self.PORT = 1883
    
51.         self.SubTopic = "/topic/heart"
    
52.         self.PubTopic = "/topic/hearset"
    
53.         self.mqttlj()
    
54.     def on_connect(self,client,userdata,flags,rc):
    
55.         if rc == 0:
    
56.             print(rc)
    
57.             self.pushButton_client_sever.setText("断开服务器")
    
58.         client.subscribe(self.SubTopic)
    
59.     def on_message(self, client, userdata,msg):
    
60.         try:
    
61.             mm = json.loads(msg.payload)
    
62.             print(mm)
    
63.             if re.match(r"^\d+(\.\d+)?[        DISCUZ_CODE_1        ]quot;, mm['Temperature']):
    
64.                 float_value = float(mm['Temperature'])
    
65.                 # print(f"转换后的浮点数为: {mm.Temperature}")
    
66.             else:
    
67.                 print("字符串不是有效的数字格式")
    
68.             self.lcdNumberThishTemp.display(float_value)
    
69.             if mm['WorkState'] == '1':
    
70.                 self.pushButtonOnOff.setText("关闭取暖器")
    
71.             else:
    
72.                 self.pushButtonOnOff.setText("开启取暖器")
    
73.         except Exception as e:
    
74.             print("err " +str(e))
    
75. 
    
76.     def on_publish(self, topic, payload, qos = 1):
    
77.         self.client.publish(topic, payload, qos)
    
78. 
    
79.     def connect_mqtt(self):
    
80.         if self.pushButton_client_sever.text() == "连接服务器":
    
81.             self.conn_Ck();
    
82.         elif self.pushButton_client_sever.text() == "断开服务器":
    
83.             self.client.loop_stop()
    
84.             self.pushButton_client_sever.setText("连接服务器")
    
85. if __name__ =='__main__':
    
86.      app = QApplication(sys.argv)
    
87.      window = AppGui()
    
88.      window.show()
    
89.      sys.exit(app.exec_())

复制代码

【实验效果】

[size=10.5000pt]安装好的图片：

【总结】
这次参与【Arrow 有好料】使用DRF0654制作了一个智能取暖器，非常好的一个活动。希望论坛能多举办这样的活动。
【视频介绍】

[size=10.5000pt]