mirror of
https://gitee.com/beecue/fastbee.git
synced 2025-12-18 17:05:55 +08:00
433 lines
16 KiB
C
433 lines
16 KiB
C
/******************************************************************************
|
||
* author: kerwincui
|
||
* create: 2021-06-08
|
||
* email：164770707@qq.com
|
||
* source:https://github.com/kerwincui/wumei-smart
|
||
******************************************************************************/
|
||
#include "mqtt.h"
|
||
#include "led.h"
|
||
#include "common.h"
|
||
#include "cJSON.h"
|
||
#include "cJSON_Utils.h"
|
||
#include "nvs_storage.h"
|
||
#include "driver/temp_sensor.h"
|
||
#include "i2c_temp.h"
|
||
#include "wifi.h"
|
||
|
||
static const char *TAG = "MQTT";
|
||
static esp_mqtt_client_handle_t mqtt_client=NULL;
|
||
static char *update_status_topic;
|
||
static char *get_status_topic;
|
||
static char *update_setting_topic;
|
||
static char *get_setting_topic;
|
||
|
||
// 发布设备状态
|
||
void publishStatus(void){
|
||
// temp_sensor_read_celsius(&device_temp); //获取设备温度
|
||
// get_temp_humi(); // 获取空气温湿度
|
||
get_ap_info(); //获取wifi信号
|
||
|
||
cJSON *status = cJSON_CreateObject();
|
||
cJSON_AddStringToObject(status,"deviceNum",device_num);
|
||
cJSON_AddNumberToObject(status,"relayStatus",relay_status);
|
||
cJSON_AddNumberToObject(status,"lightStatus",light_status);
|
||
cJSON_AddNumberToObject(status,"isOnline",1);
|
||
cJSON_AddNumberToObject(status,"rssi",rssi);
|
||
cJSON_AddNumberToObject(status,"deviceTemperature",device_temp);
|
||
cJSON_AddNumberToObject(status,"airTemperature",air_temperature);
|
||
cJSON_AddNumberToObject(status,"airHumidity",air_humidity);
|
||
cJSON_AddNumberToObject(status,"triggerSource",trigger_source);
|
||
cJSON_AddNumberToObject(status,"brightness",brightness);
|
||
cJSON_AddNumberToObject(status,"lightInterval",light_interval);
|
||
cJSON_AddNumberToObject(status,"lightMode",light_mode);
|
||
cJSON_AddNumberToObject(status,"fadeTime",fade_time);
|
||
cJSON_AddNumberToObject(status,"red",red);
|
||
cJSON_AddNumberToObject(status,"green",green);
|
||
cJSON_AddNumberToObject(status,"blue",blue);
|
||
char *status_msg = cJSON_Print(status);
|
||
//释放内存
|
||
cJSON_Delete(status);
|
||
ESP_LOGI(TAG,"status msg: %s",status_msg);
|
||
int msg_id=esp_mqtt_client_publish(mqtt_client,"status",status_msg,0,1,0);
|
||
ESP_LOGI(TAG, "sent publish device status, msg_id=%d",msg_id);
|
||
}
|
||
|
||
//发布设备配置
|
||
void publishSetting(void){
|
||
cJSON *setting = cJSON_CreateObject();
|
||
cJSON_AddStringToObject(setting,"deviceNum",device_num);
|
||
cJSON_AddNumberToObject(setting,"isAlarm",is_alarm);
|
||
cJSON_AddNumberToObject(setting,"isRadar",is_radar);
|
||
cJSON_AddNumberToObject(setting,"isHost",is_host);
|
||
cJSON_AddNumberToObject(setting,"isRfControl",is_rf_control);
|
||
cJSON_AddNumberToObject(setting,"rfOneFunc",rf_one_func);
|
||
cJSON_AddNumberToObject(setting,"rfTwoFunc",rf_two_func);
|
||
cJSON_AddNumberToObject(setting,"rfThreeFunc",rf_three_func);
|
||
cJSON_AddNumberToObject(setting,"rfFourFunc",rf_four_func);
|
||
cJSON_AddStringToObject(setting,"ownerId",owner_id);
|
||
cJSON_AddNumberToObject(setting,"isReset",is_reset);
|
||
cJSON_AddNumberToObject(setting,"isAp",is_ap);
|
||
cJSON_AddNumberToObject(setting,"isRfLearn",is_rf_learn);
|
||
cJSON_AddNumberToObject(setting,"isRfClear",is_rf_clear);
|
||
cJSON_AddNumberToObject(setting,"isSmartConfig",is_smart_config);
|
||
cJSON_AddNumberToObject(setting,"radarInterval",radar_interval);
|
||
cJSON_AddNumberToObject(setting,"isWifiOffline",is_wifi_offline);
|
||
cJSON_AddNumberToObject(setting,"isOpenCertifi",is_open_certifi);
|
||
char *setting_msg = cJSON_Print(setting);
|
||
//释放内存
|
||
cJSON_Delete(setting);
|
||
ESP_LOGI(TAG,"setting msg: %s",setting_msg);
|
||
int msg_id=esp_mqtt_client_publish(mqtt_client,"setting",setting_msg,0,1,0);
|
||
ESP_LOGI(TAG, "sent publish device setting, msg_id=%d",msg_id);
|
||
}
|
||
|
||
// 更新设备状态
|
||
static void updateStatus(esp_mqtt_event_handle_t event,char *topic){
|
||
//将字符串格式的json数据转化为JSON对象格式
|
||
cJSON *root = cJSON_Parse(event->data);
|
||
if(root == NULL) { printf("parse error\n"); }
|
||
|
||
cJSON *value_relay = cJSON_GetObjectItem(root, "relayStatus");
|
||
char *relay = cJSON_Print(value_relay);
|
||
relay_status=atoi(relay);
|
||
//打开关闭继电器
|
||
if(relay_status==1){
|
||
open_relay();
|
||
}else{
|
||
close_relay();
|
||
}
|
||
free(relay);
|
||
|
||
cJSON *value_trigger = cJSON_GetObjectItem(root, "triggerSource");
|
||
char *trigger = cJSON_Print(value_trigger);
|
||
trigger_source=atoi(trigger);
|
||
free(trigger);
|
||
|
||
cJSON *value_brightness = cJSON_GetObjectItem(root, "brightness");
|
||
char *bright = cJSON_Print(value_brightness);
|
||
brightness=atoi(bright);
|
||
free(bright);
|
||
|
||
cJSON *value_interval = cJSON_GetObjectItem(root, "lightInterval");
|
||
char *interval = cJSON_Print(value_interval);
|
||
light_interval=atoi(interval);
|
||
free(interval);
|
||
|
||
cJSON *value_mode = cJSON_GetObjectItem(root, "lightMode");
|
||
char *mode = cJSON_Print(value_mode);
|
||
light_mode=atoi(mode);
|
||
free(mode);
|
||
|
||
cJSON *value_fade = cJSON_GetObjectItem(root, "fadeTime");
|
||
char *fade = cJSON_Print(value_fade);
|
||
fade_time=atoi(fade);
|
||
free(fade);
|
||
|
||
cJSON *value_red = cJSON_GetObjectItem(root, "red");
|
||
char *red_string = cJSON_Print(value_red);
|
||
red=atoi(red_string);
|
||
free(red_string);
|
||
|
||
cJSON *value_green = cJSON_GetObjectItem(root, "green");
|
||
char *green_string = cJSON_Print(value_green);
|
||
green=atoi(green_string);
|
||
free(green_string);
|
||
|
||
cJSON *value_blue = cJSON_GetObjectItem(root, "blue");
|
||
char *blue_string = cJSON_Print(value_blue);
|
||
blue=atoi(blue_string);
|
||
free(blue_string);
|
||
|
||
cJSON *value_light = cJSON_GetObjectItem(root, "lightStatus");
|
||
char *light = cJSON_Print(value_light);
|
||
light_status=atoi(light);
|
||
//打开关闭彩灯
|
||
free(light);
|
||
|
||
//更新灯状态并存储
|
||
led_status();
|
||
write_config_data();
|
||
cJSON_Delete(root);
|
||
}
|
||
|
||
//更新设备配置
|
||
static void updateSetting(esp_mqtt_event_handle_t event,char *topic){
|
||
//将字符串格式的json数据转化为JSON对象格式
|
||
cJSON *root = cJSON_Parse(event->data);
|
||
if(root == NULL) { printf("parse error\n"); }
|
||
|
||
cJSON *value_alarm = cJSON_GetObjectItem(root, "isAlarm");
|
||
char *alarm = cJSON_Print(value_alarm);
|
||
is_alarm=atoi(alarm);
|
||
free(alarm);
|
||
|
||
cJSON *value_radar = cJSON_GetObjectItem(root, "isRadar");
|
||
char *radar = cJSON_Print(value_radar);
|
||
is_radar=atoi(radar);
|
||
free(radar);
|
||
|
||
cJSON *value_host = cJSON_GetObjectItem(root, "isHost");
|
||
char *host = cJSON_Print(value_host);
|
||
is_host=atoi(host);
|
||
free(host);
|
||
|
||
cJSON *value_rf = cJSON_GetObjectItem(root, "isRfControl");
|
||
char *rf = cJSON_Print(value_rf);
|
||
is_rf_control=atoi(rf);
|
||
free(rf);
|
||
|
||
cJSON *value_rf_one = cJSON_GetObjectItem(root, "rfOneFunc");
|
||
char *rf_one = cJSON_Print(value_rf_one);
|
||
rf_one_func=atoi(rf_one);
|
||
free(rf_one);
|
||
|
||
cJSON *value_rf_two = cJSON_GetObjectItem(root, "rfTwoFunc");
|
||
char *rf_two = cJSON_Print(value_rf_two);
|
||
rf_two_func=atoi(rf_two);
|
||
free(rf_two);
|
||
|
||
cJSON *value_rf_three = cJSON_GetObjectItem(root, "rfThreeFunc");
|
||
char *rf_three = cJSON_Print(value_rf_three);
|
||
rf_three_func=atoi(rf_three);
|
||
free(rf_three);
|
||
|
||
cJSON *value_rf_four = cJSON_GetObjectItem(root, "rfFourFunc");
|
||
char *rf_four = cJSON_Print(value_rf_four);
|
||
rf_four_func=atoi(rf_four);
|
||
free(rf_four);
|
||
|
||
cJSON *value_rf_learn = cJSON_GetObjectItem(root, "isRfLearn");
|
||
char *rf_learning = cJSON_Print(value_rf_learn);
|
||
if(strcmp(rf_learning, "1") == 0){
|
||
// 遥控配对
|
||
rf_learn();
|
||
}
|
||
free(rf_learning);
|
||
|
||
cJSON *value_rf_clear = cJSON_GetObjectItem(root, "isRfClear");
|
||
char *rf_clear = cJSON_Print(value_rf_clear);
|
||
if(strcmp(rf_clear, "1") == 0){
|
||
// 遥控清码
|
||
rf_clear_code();
|
||
}
|
||
free(rf_clear);
|
||
|
||
cJSON *value_ap = cJSON_GetObjectItem(root, "isAp");
|
||
char *ap = cJSON_Print(value_ap);
|
||
if(strcmp(ap, "1") == 0){
|
||
// 打开AP
|
||
if(is_ap!=1){
|
||
// 打开ap
|
||
ESP_LOGI(TAG, "open access point \n");
|
||
is_ap=1;
|
||
ap_start();
|
||
}
|
||
}
|
||
free(ap);
|
||
|
||
//写入配置
|
||
write_config_data();
|
||
|
||
cJSON *value_reset = cJSON_GetObjectItem(root, "isReset");
|
||
char *reset = cJSON_Print(value_reset);
|
||
if(strcmp(reset, "1") == 0){
|
||
// 设备重启
|
||
device_restart();
|
||
}
|
||
free(reset);
|
||
|
||
cJSON_Delete(root);
|
||
}
|
||
|
||
static void mqtt_subscribe_event(esp_mqtt_event_handle_t event)
|
||
{
|
||
char topic[32];
|
||
ESP_LOGI(TAG,"event topic:%.*s\r", event->topic_len, event->topic);
|
||
ESP_LOGI(TAG,"event data:%.*s\r\n",event->data_len, event->data);
|
||
sprintf(topic,"%.*s", event->topic_len, event->topic);
|
||
if (strcmp(topic, update_status_topic) == 0)
|
||
{
|
||
//更新设备状态
|
||
updateStatus(event,topic);
|
||
// 发布设备状态
|
||
publishStatus();
|
||
|
||
} else if (strcmp(topic, get_status_topic) == 0)
|
||
{
|
||
publishStatus();
|
||
|
||
}else if(strcmp(topic,update_setting_topic) == 0){
|
||
// 更新设备配置
|
||
updateSetting(event,topic);
|
||
// 发布设备配置
|
||
publishSetting();
|
||
|
||
}
|
||
else if(strcmp(topic, get_setting_topic) == 0)
|
||
{
|
||
publishSetting();
|
||
}
|
||
}
|
||
|
||
|
||
static esp_err_t mqtt_event_handler_cb(esp_mqtt_event_handle_t event)
|
||
{
|
||
int msg_id;
|
||
switch (event->event_id) {
|
||
case MQTT_EVENT_CONNECTED:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED");
|
||
//-----------------------------------订阅消息----------------------------------------
|
||
// 订阅更新设备状态
|
||
msg_id = esp_mqtt_client_subscribe(mqtt_client, update_status_topic, 1);
|
||
ESP_LOGI(TAG, "sent subscribe set status successful, msg_id=%d,topic=%s", msg_id,update_status_topic);
|
||
|
||
// 订阅获取设备状态
|
||
msg_id = esp_mqtt_client_subscribe(mqtt_client, get_status_topic, 1);
|
||
ESP_LOGI(TAG, "sent subscribe get status successful, msg_id=%d,topic=%s", msg_id,get_status_topic);
|
||
|
||
// 订阅更新设备配置
|
||
msg_id = esp_mqtt_client_subscribe(mqtt_client, update_setting_topic, 1);
|
||
ESP_LOGI(TAG, "sent subscribe set setting successful, msg_id=%d,topic=%s", msg_id,update_setting_topic);
|
||
|
||
// 订阅获取设备配置
|
||
msg_id = esp_mqtt_client_subscribe(mqtt_client, get_setting_topic, 1);
|
||
ESP_LOGI(TAG, "sent subscribe get setting successful, msg_id=%d,topic=%s", msg_id,get_setting_topic);
|
||
|
||
//-----------------------------------发布消息--------------------------------------
|
||
//发布设备信息
|
||
cJSON *device_info = cJSON_CreateObject();
|
||
cJSON_AddStringToObject(device_info,"deviceNum",device_num);
|
||
cJSON_AddNumberToObject(device_info,"categoryId",CATEGORY);
|
||
cJSON_AddStringToObject(device_info,"firmwareVersion",VERSION);
|
||
cJSON_AddStringToObject(device_info,"ownerId",owner_id);
|
||
char *device_msg = cJSON_Print(device_info);
|
||
//释放内存
|
||
cJSON_Delete(device_info);
|
||
ESP_LOGI(TAG,"device msg: %s",device_msg);
|
||
msg_id=esp_mqtt_client_publish(mqtt_client,"device_info",device_msg,0,1,0);
|
||
ESP_LOGI(TAG, "sent publish device info, msg_id=%d",msg_id);
|
||
break;
|
||
case MQTT_EVENT_DISCONNECTED:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED");
|
||
break;
|
||
case MQTT_EVENT_SUBSCRIBED:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);
|
||
break;
|
||
case MQTT_EVENT_UNSUBSCRIBED:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);
|
||
break;
|
||
case MQTT_EVENT_PUBLISHED:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
|
||
break;
|
||
case MQTT_EVENT_DATA:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_DATA");
|
||
//订阅事件处理
|
||
mqtt_subscribe_event(event);
|
||
break;
|
||
case MQTT_EVENT_ERROR:
|
||
ESP_LOGI(TAG, "MQTT_EVENT_ERROR");
|
||
break;
|
||
default:
|
||
ESP_LOGI(TAG, "Other event id:%d", event->event_id);
|
||
break;
|
||
}
|
||
return ESP_OK;
|
||
}
|
||
|
||
static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) {
|
||
ESP_LOGD(TAG, "Event dispatched from event loop base=%s, event_id=%d", base, event_id);
|
||
mqtt_event_handler_cb(event_data);
|
||
}
|
||
|
||
// 配置订阅主题
|
||
static void config_topic(){
|
||
static char *update_status_path="status/set/";
|
||
static char *get_status_path="status/get/";
|
||
static char *update_setting_path="setting/set/";
|
||
static char *get_setting_path="setting/get/";
|
||
// 更新状态
|
||
update_status_topic=(char *)malloc(strlen(update_status_path)+strlen(device_num)+1);
|
||
if(update_status_topic==NULL){
|
||
ESP_LOGD(TAG, "failed to apply for memory");
|
||
}
|
||
strcpy(update_status_topic,update_status_path);
|
||
strcat(update_status_topic,device_num);
|
||
ESP_LOGI(TAG,"update_status_topic:%s",update_status_topic);
|
||
// 获取状态
|
||
get_status_topic=(char *)malloc(strlen(get_status_path)+strlen(device_num)+1);
|
||
if(get_status_topic==NULL){
|
||
ESP_LOGD(TAG, "failed to apply for memory");
|
||
}
|
||
strcpy(get_status_topic,get_status_path);
|
||
strcat(get_status_topic,device_num);
|
||
ESP_LOGI(TAG,"get_status_topic:%s",get_status_topic);
|
||
// 更新配置
|
||
update_setting_topic=(char *)malloc(strlen(update_setting_path)+strlen(device_num)+1);
|
||
if(update_setting_topic==NULL){
|
||
ESP_LOGD(TAG, "failed to apply for memory");
|
||
}
|
||
strcpy(update_setting_topic,update_setting_path);
|
||
strcat(update_setting_topic,device_num);
|
||
ESP_LOGI(TAG,"update_setting_topic:%s",update_setting_topic);
|
||
// 获取配置
|
||
get_setting_topic=(char *)malloc(strlen(get_setting_path)+strlen(device_num)+1);
|
||
if(get_setting_topic==NULL){
|
||
ESP_LOGD(TAG, "failed to apply for memory");
|
||
}
|
||
strcpy(get_setting_topic,get_setting_path);
|
||
strcat(get_setting_topic,device_num);
|
||
ESP_LOGI(TAG,"get_setting_topic:%s",get_setting_topic);
|
||
}
|
||
|
||
void mqtt_start(void)
|
||
{
|
||
// esp_log_level_set("*", ESP_LOG_INFO);
|
||
esp_log_level_set("MQTT_CLIENT", ESP_LOG_VERBOSE);
|
||
esp_log_level_set("MQTT", ESP_LOG_VERBOSE);
|
||
esp_log_level_set("TRANSPORT_TCP", ESP_LOG_VERBOSE);
|
||
esp_log_level_set("TRANSPORT_SSL", ESP_LOG_VERBOSE);
|
||
esp_log_level_set("TRANSPORT", ESP_LOG_VERBOSE);
|
||
esp_log_level_set("OUTBOX", ESP_LOG_VERBOSE);
|
||
|
||
// 配置订阅的主题
|
||
config_topic();
|
||
|
||
// 遗嘱消息内容
|
||
cJSON *root = cJSON_CreateObject();
|
||
cJSON_AddStringToObject(root,"deviceNum",device_num);
|
||
cJSON_AddNumberToObject(root,"isOnline",0);
|
||
char *will_msg = cJSON_Print(root);
|
||
//释放内存
|
||
cJSON_Delete(root);
|
||
|
||
ESP_LOGI(TAG,"last will: %s", will_msg);
|
||
esp_mqtt_client_config_t mqtt_cfg = {
|
||
.uri = BROKEN_URL,
|
||
.username = BROKEN_ADMIN,
|
||
.password = BROKEN_PWD,
|
||
//设置遗嘱
|
||
.lwt_topic="offline",
|
||
.lwt_msg=will_msg,
|
||
.lwt_msg_len=strlen(will_msg),
|
||
.lwt_qos=1,
|
||
.lwt_retain=0,
|
||
//断开前等待的时间,3秒
|
||
.keepalive=3,
|
||
};
|
||
|
||
mqtt_client = esp_mqtt_client_init(&mqtt_cfg);
|
||
esp_mqtt_client_register_event(mqtt_client, ESP_EVENT_ANY_ID, mqtt_event_handler, mqtt_client);
|
||
esp_mqtt_client_start(mqtt_client);
|
||
}
|
||
|
||
void mqtt_stop(void){
|
||
if(mqtt_client!=NULL){
|
||
esp_mqtt_client_stop(mqtt_client);
|
||
}
|
||
}
|
||
void mqtt_continue(void){
|
||
if(mqtt_client!=NULL){
|
||
esp_mqtt_client_start(mqtt_client);
|
||
}
|
||
}
|