点灯APP、小爱同学、MQTT同时控制开关

qiuye88

前段时间一直在玩mqtt，感觉很方便、透明。最近又迷上了点灯科技，特别是它和小爱之间的关联，让我这样的懒人更有了动口不动手的理由。
虽然小爱好使唤，但我还是想把它集成到MQTT中，通过其他平台统一控制。可是找了好多帖子，没有找到使用MQTT的例子，只好自己研究了。
我买了个220V转5V模块，连接到一个继电器插座上，在上面插上esp8266-01。


大部分是示例中的语句，只不过是把mqtt示例和插座示例合起来了。

下面是我的源码，MQTT在主题homeassistant/zhuwodeng/kaiguan下，发布消息，内容为ON，即是控制开关打开，OFF为关闭。
每个操作执行后，均向状态主题homeassistant/zhuwodeng/zhuangtai发布开关状态消息。
HA平台收到消息后处理开关状态。

1. 
   
2. #define BLINKER_WIFI
   
3. #define BLINKER_MIOT_OUTLET
   
4. 
   
5. #include <Blinker.h>
   
6. 
   
7. int GPIO = 0; //定义继电器输入引脚为GPIO/0
   
8. //下面这3行一定要改为自己的
   
9. char auth[] = "888888888888";
   
10. char ssid[] = "ChinaNet-****";
    
11. char pswd[] = "1234567890";
    
12. bool oState = true;
    
13. 
    
14. /************************* Adafruit.io Setup *********************************/
    
15. #define AIO_SERVER      "192.168.2.100"
    
16. #define AIO_SERVERPORT  1883                   // use 8883 for SSL
    
17. #define AIO_USERNAME    "test"
    
18. #define AIO_KEY         "test2020"
    
19. Adafruit_MQTT_Client mqtt(&client, AIO_SERVER, AIO_SERVERPORT, AIO_USERNAME, AIO_KEY);
    
20. //下面定义了2个主题，1个是灯状态，1个是控制开关
    
21. Adafruit_MQTT_Publish zhuangtai = Adafruit_MQTT_Publish(&mqtt, "homeassistant/zhuwodeng/zhuangtai");
    
22. Adafruit_MQTT_Subscribe kaiguan = Adafruit_MQTT_Subscribe(&mqtt, "homeassistant/zhuwodeng/kaiguan");
    
23. 
    
24. 
    
25. // 新建组件对象（在点灯APP里的开关的名字）
    
26. BlinkerButton Button1("btn-abc");
    
27. 
    
28. // 按下按键即会执行该函数，在APP中按下按钮执行的程序
    
29. 
    
30. void button1_callback(const String & state)
    
31. {
    
32.     //digitalWrite(GPIO, !digitalRead(GPIO));
    
33.     BLINKER_LOG("get button state: ", state);
    
34.    
    
35.     if (state == BLINKER_CMD_ON) {
    
36.       oState = true;
    
37.     }
    
38.     else if (state == BLINKER_CMD_OFF) {
    
39.       oState = false;
    
40.     }
    
41.     turnonoff();//调用开关函数
    
42.     Blinker.vibrate();
    
43. }
    
44. //小爱控制
    
45. void miotPowerState(const String & state)
    
46. {
    
47.     BLINKER_LOG("need set power state: ", state);
    
48. 
    
49.     if (state == BLINKER_CMD_ON) {
    
50.         oState = true;
    
51.     }
    
52.     else if (state == BLINKER_CMD_OFF) {
    
53.         oState = false;
    
54.     }
    
55.     turnonoff();
    
56. }
    
57. //小爱查询状态
    
58. void miotQuery(int32_t queryCode)
    
59. {
    
60.     BLINKER_LOG("MIOT Query codes: ", queryCode);
    
61.     BlinkerMIOT.powerState(oState ? "on" : "off");
    
62.     BlinkerMIOT.print();
    
63. }
    
64. 
    
65. 
    
66. void setup()
    
67. {
    
68.     Serial.begin(115200);
    
69.     BLINKER_DEBUG.stream(Serial);
    
70.     pinMode(GPIO, OUTPUT);
    
71.     digitalWrite(GPIO, LOW);
    
72.     Blinker.begin(auth, ssid, pswd);
    
73.     Button1.attach(button1_callback);
    
74.     BlinkerMIOT.attachPowerState(miotPowerState);
    
75.     BlinkerMIOT.attachQuery(miotQuery);
    
76.     mqtt.subscribe(&kaiguan);
    
77. }
    
78. 
    
79. void loop()
    
80. {
    
81.     Blinker.run();
    
82.     MQTT_connect();
    
83.   Adafruit_MQTT_Subscribe *subscription;
    
84.   subscription = mqtt.readSubscription();
    
85.     // Check if its the onoff button feed
    
86.     if (subscription == &kaiguan) {
    
87.       Serial.print(F("On-Off button: "));
    
88.       Serial.println((char *)kaiguan.lastread);
    
89.       if (strcmp((char *)kaiguan.lastread, "ON") == 0) {
    
90.         oState = true;
    
91.       }
    
92.       if (strcmp((char *)kaiguan.lastread, "OFF") == 0) {
    
93.         oState = false;
    
94.       }
    
95.       turnonoff();
    
96.     }
    
97. }
    
98. 
    
99. void MQTT_connect() {
    
100.   int8_t ret;
     
101. 
     
102.   // Stop if already connected.
     
103.   if (mqtt.connected()) {
     
104.     return;
     
105.   }
     
106. 
     
107.   Serial.print("Connecting to MQTT... ");
     
108. 
     
109.   uint8_t retries = 5;
     
110.   ret = mqtt.connect();
     
111.   while (ret != 0) { // connect will return 0 for connected
     
112.        Serial.println(mqtt.connectErrorString(ret));
     
113.        Serial.println("Retrying MQTT connection in 10 seconds...");
     
114.        mqtt.disconnect();
     
115.        delay(10000);  // wait 5 seconds
     
116.        retries--;
     
117.        ret = mqtt.connect();
     
118.        if (retries == 0) {
     
119.          // basically die and wait for WDT to reset me
     
120.          while (1);
     
121.        }
     
122.   }
     
123.   Serial.println("MQTT Connected!");
     
124.   turnonoff();
     
125. }
     
126. //这是自己增加的一个统一控制开关的函数，不管通过哪种方式控制设备，都在这里执行。
     
127. void turnonoff(){
     
128.   if (oState){
     
129.         digitalWrite(GPIO, LOW);
     
130.         Button1.color("#f7dc05");
     
131.         Button1.print("on");
     
132.         Serial.println("kaiguan is set to ON");
     
133.         BlinkerMIOT.powerState("on");
     
134.         BlinkerMIOT.print();
     
135.         zhuangtai.publish("ON");
     
136.   }
     
137.   else{
     
138.         digitalWrite(GPIO, HIGH);
     
139.         Button1.color("#000000");
     
140.         Button1.print("off");
     
141.         Serial.println("kaiguan is set to OFF");
     
142.         BlinkerMIOT.powerState("off");
     
143.         BlinkerMIOT.print();
     
144.         zhuangtai.publish("OFF");
     
145.   }
     
146. }
     

复制代码

附：源文件 zhuwodeng.zip (2.48 KB, 下载次数: 63)

2021-5-24 21:45 上传

点击文件名下载附件

mafeikeji

老哥可以加个好友交流一下不 想知道可不可以接入物理开关并同步 wx： ohwmf666

qiuye88

mafeikeji 发表于 2021-6-3 21:18
老哥可以加个好友交流一下不 想知道可不可以接入物理开关并同步 wx： ohwmf666 ...

在官方一个AP配网的示例中发现了使用物理按钮的方法，需要引用一个库OneButton，地址https://github.com/mathertel/OneButton。
这里的按钮是会反弹的那种只能点按的开关，不是我们家里一般装修用的上下按键的翘板开关。可以这么说——不是switch，是button。
在上贴第6行处，插入下列2句。
#include "OneButton.h"  //引用此库文件
#define BLINKER_BUTTON_PIN 2 //这里是8266的GPIO2引脚，我的NodeMcu是D4。

在上贴第13行处插入下1句
OneButton button(BLINKER_BUTTON_PIN, true); //按钮按下，输入低电平时此按钮触发，所以把GPIO2与GND之间用一个按钮连接起来。

在上贴第27行处插入以下函数
void buttonswitch(){
  oState = !oState; //按钮按下执行开关命令，把控制灯状态的变量置为相反状态。
  turnonoff();
}

在上贴第76行后插入下1句
button.attachClick(buttonswitch); //物理按钮单击时调用此函数
在上贴第96行后插入下1句button.tick(); //时刻关注是否按下按钮

就这样，当短按GPIO2上的按钮再松开时，就会触发灯的开关状态。
根据OneButton的说明文档，按钮还有双击、长按等事件。
关于翘板开关的使用，等找时间再试试。

mafeikeji

射射大佬，我发现在安装函数段有写    digitalWrite(GPIO, LOW);  但是上电还是高电平这个有办法解决么