GitHub/zTC1
1
0
Fork 0
mirror of https://github.com/oopuuu/zTC1.git synced 2025-12-12 13:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

没有警告了~

Browse Source
This commit is contained in:
zogodo
2019-09-25 21:03:59 +08:00
parent b0c64670c9
commit cc64a3aa17
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
TC1/user_mqtt_client.c
View File

@@ -307,7 +307,7 @@ void mqtt_client_thread(mico_thread_arg_t arg)
micoWlanGetLinkStatus(&LinkStatus); micoWlanGetLinkStatus(&LinkStatus);
if (LinkStatus.is_connected != 1) if (LinkStatus.is_connected != 1)
{ {
mqtt_log("ERROR:WIFI not connection , waiting 3s for connecting and then connecting MQTT ", rc); mqtt_log("ERROR:WIFI not connection , waiting 3s for connecting and then connecting MQTT ");
mico_rtos_thread_sleep(3); mico_rtos_thread_sleep(3);
continue; continue;
} }
@@ -506,19 +506,21 @@ OSStatus user_mqtt_send(char *arg)
//更新ha开关状态 //更新ha开关状态
OSStatus user_mqtt_send_plug_state(char plug_id) OSStatus user_mqtt_send_plug_state(char plug_id)
{ {
char *send_buf = NULL; char *send_buf = NULL;
char *topic_buf = NULL; char *topic_buf = NULL;
send_buf = malloc(64); // send_buf = malloc(64);
topic_buf = malloc(64); // topic_buf = malloc(64);
OSStatus oss_status = kUnknownErr;
if (send_buf != NULL && topic_buf != NULL) if (send_buf != NULL && topic_buf != NULL)
{ {
sprintf(topic_buf, "homeassistant/switch/%s/plug_%d/state", strMac, (int)plug_id); sprintf(topic_buf, "homeassistant/switch/%s/plug_%d/state", strMac, (int)plug_id);
sprintf(send_buf, "{\"mac\":\"%s\",\"plug_%d\":{\"on\":%d}}", strMac, plug_id, (int)user_config->plug[(int)plug_id].on); sprintf(send_buf, "{\"mac\":\"%s\",\"plug_%d\":{\"on\":%d}}", strMac, plug_id, (int)user_config->plug[(int)plug_id].on);
user_mqtt_send_topic(topic_buf, send_buf, 1); oss_status = user_mqtt_send_topic(topic_buf, send_buf, 1);
} }
if (send_buf) free(send_buf); if (send_buf) free(send_buf);
if (topic_buf) free(topic_buf); if (topic_buf) free(topic_buf);
return oss_status;
} }
//hass mqtt自动发现数据开关发送 //hass mqtt自动发现数据开关发送