code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-18 08:55:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

添加硬件端固件示例代码

Browse Source
This commit is contained in:
kerwincui
2021-07-04 17:59:55 +08:00
parent e747bd935e
commit 224282d561
23 changed files with 5549 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
firmware/esp-idf/get-started/main/CMakeLists.txt Normal file
View File

@@ -0,0 +1,4 @@
set(COMPONENT_SRCS "main.c" "mqtt.c" "wifi.c")
set(COMPONENT_ADD_INCLUDEDIRS ". include")
register_component()

5
firmware/esp-idf/get-started/main/component.mk Normal file
View File

@@ -0,0 +1,5 @@
#
# "main" pseudo-component makefile.
#
# (Uses default behaviour of compiling all source files in directory, adding 'include' to include path.)

22
firmware/esp-idf/get-started/main/include/mqtt.h Normal file
View File

@@ -0,0 +1,22 @@
/******************************************************************************
* author: kerwincui
* create: 2021-06-08
* email：164770707@qq.com
* source:https://github.com/kerwincui/wumei-smart
******************************************************************************/
#ifndef _MQTT_H_
#define _MQTT_H_
#include <stdio.h>
#include <string.h>
#include "esp_log.h"
#include "mqtt_client.h"
#include "cJSON.h"
#include "cJSON_Utils.h"
char owner_id[64]; // 用户ID
char device_num[13]; // 设备编号，mac地址
void mqtt_start(void);
#endif

21
firmware/esp-idf/get-started/main/include/wifi.h Normal file
View File

@@ -0,0 +1,21 @@
/******************************************************************************
* author: kerwincui
* create: 2021-06-08
* email：164770707@qq.com
* source:https://github.com/kerwincui/wumei-smart
*****************************************************************************/
#ifndef _WIFI_H_
#define _WIFI_H_
#include "freertos/FreeRTOS.h"
#include "freertos/task.h"
#include "freertos/event_groups.h"
#include "esp_wifi.h"
#include "esp_log.h"
#include <string.h>
char ssid[33]; // wifi的SSID
char pwd[65]; // wifi的密码
void wifi_start(void);
#endif

35
firmware/esp-idf/get-started/main/main.c Normal file
View File

@@ -0,0 +1,35 @@
#include <stdio.h>
#include "nvs_flash.h"
#include "esp_event.h"
#include "example.h"
#include "mqtt.h"
#include "wifi.h"
/******************************************************************************
* FunctionName : app_main
* Description : entry of user application, init user function here
* Author : kerwincui
* SourceCode : https://gitee.com/kerwincui/wumei-smart
*******************************************************************************/
void app_main()
{
printf("Docking wumei-smart system demo \n");
// 初始化NVS
esp_err_t ret = nvs_flash_init();
if (ret == ESP_ERR_NVS_NO_FREE_PAGES || ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
ESP_ERROR_CHECK(nvs_flash_erase());
ret = nvs_flash_init();
}
ESP_ERROR_CHECK( ret );
// 创建默认时间循环
ESP_ERROR_CHECK(esp_event_loop_create_default());
//连接wifi
wifi_start();
// 启动mqtt
mqtt_start();
}

395
firmware/esp-idf/get-started/main/mqtt.c Normal file
View File

@@ -0,0 +1,395 @@
/******************************************************************************
* author: kerwincui
* create: 2021-06-08
* email：164770707@qq.com
* source:https://github.com/kerwincui/wumei-smart
******************************************************************************/
#include "mqtt.h"
// 配置连接mqtt的broken
#define BROKEN_URL "mqtt://wumei.live:1884"
#define BROKEN_ADMIN "admin"
#define BROKEN_PWD "admin123"
char owner_id[64]="1"; // 用户ID,后端查看，默认为amdin,ID为1
char device_num[13]="7EAFA1049ADA"; // 设备编号，唯一标识
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;
// 发布设备状态
static void publishStatus(void){
cJSON *status = cJSON_CreateObject();
cJSON_AddStringToObject(status,"deviceNum","7CDFA1049ADA");
cJSON_AddNumberToObject(status,"relayStatus",1);
cJSON_AddNumberToObject(status,"lightStatus",1);
cJSON_AddNumberToObject(status,"isOnline",1);
cJSON_AddNumberToObject(status,"rssi",-80);
cJSON_AddNumberToObject(status,"deviceTemperature",0.0);
cJSON_AddNumberToObject(status,"airTemperature",0.0);
cJSON_AddNumberToObject(status,"airHumidity",0.0);
cJSON_AddNumberToObject(status,"triggerSource",0);
cJSON_AddNumberToObject(status,"brightness",100);
cJSON_AddNumberToObject(status,"lightInterval",300);
cJSON_AddNumberToObject(status,"lightMode",0);
cJSON_AddNumberToObject(status,"fadeTime",300);
cJSON_AddNumberToObject(status,"red",255);
cJSON_AddNumberToObject(status,"green",255);
cJSON_AddNumberToObject(status,"blue",255);
char *status_msg = cJSON_Print(status);
//释放内存
cJSON_Delete(status);
ESP_LOGI(TAG,"public 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);
}
//发布设备配置
static void publishSetting(void){
cJSON *setting = cJSON_CreateObject();
cJSON_AddStringToObject(setting,"deviceNum",device_num);
cJSON_AddNumberToObject(setting,"isAlarm",1);
cJSON_AddNumberToObject(setting,"isRadar",1);
cJSON_AddNumberToObject(setting,"isHost",0);
cJSON_AddNumberToObject(setting,"isRfControl",1);
cJSON_AddNumberToObject(setting,"rfOneFunc",1);
cJSON_AddNumberToObject(setting,"rfTwoFunc",2);
cJSON_AddNumberToObject(setting,"rfThreeFunc",3);
cJSON_AddNumberToObject(setting,"rfFourFunc",4);
cJSON_AddStringToObject(setting,"ownerId",owner_id);
cJSON_AddNumberToObject(setting,"isReset",0);
cJSON_AddNumberToObject(setting,"isAp",0);
cJSON_AddNumberToObject(setting,"isRfLearn",0);
cJSON_AddNumberToObject(setting,"isRfClear",0);
cJSON_AddNumberToObject(setting,"isSmartConfig",0);
cJSON_AddNumberToObject(setting,"radarInterval",15);
cJSON_AddNumberToObject(setting,"isWifiOffline",0);
cJSON_AddNumberToObject(setting,"isOpenCertifi",0);
char *setting_msg = cJSON_Print(setting);
//释放内存
cJSON_Delete(setting);
ESP_LOGI(TAG,"publish 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);
uint8_t relay_status=atoi(relay);
//继电器
if(relay_status==1){
//TODO 打开继电器
}else{
//TODO 关闭继电器
}
free(relay);
cJSON *value_light = cJSON_GetObjectItem(root, "lightStatus");
char *light = cJSON_Print(value_light);
uint8_t light_status=atoi(light);
//彩灯
if(light_status==1){
//TODO 打开灯
}else{
//TODO 关闭灯
}
free(light);
cJSON *value_trigger = cJSON_GetObjectItem(root, "triggerSource");
char *trigger = cJSON_Print(value_trigger);
free(trigger);
cJSON *value_brightness = cJSON_GetObjectItem(root, "brightness");
char *bright = cJSON_Print(value_brightness);
free(bright);
cJSON *value_interval = cJSON_GetObjectItem(root, "lightInterval");
char *interval = cJSON_Print(value_interval);
free(interval);
cJSON *value_mode = cJSON_GetObjectItem(root, "lightMode");
char *mode = cJSON_Print(value_mode);
free(mode);
cJSON *value_fade = cJSON_GetObjectItem(root, "fadeTime");
char *fade = cJSON_Print(value_fade);
free(fade);
cJSON *value_red = cJSON_GetObjectItem(root, "red");
char *red_string = cJSON_Print(value_red);
free(red_string);
cJSON *value_green = cJSON_GetObjectItem(root, "green");
char *green_string = cJSON_Print(value_green);
free(green_string);
cJSON *value_blue = cJSON_GetObjectItem(root, "blue");
char *blue_string = cJSON_Print(value_blue);
free(blue_string);
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_reset = cJSON_GetObjectItem(root, "isReset");
char *reset = cJSON_Print(value_reset);
if(strcmp(reset, "1") == 0){
// 设备重启
fflush(stdout);
esp_restart();
}
free(reset);
cJSON *value_rf_learn = cJSON_GetObjectItem(root, "isRfLearn");
char *rf_learning = cJSON_Print(value_rf_learn);
if(strcmp(rf_learning, "1") == 0){
//TODO 遥控配对
}
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){
//TODO 遥控清码
}
free(rf_clear);
cJSON *value_ap = cJSON_GetObjectItem(root, "isAp");
char *ap = cJSON_Print(value_ap);
if(strcmp(ap, "1") == 0){
//TODO 打开AP
}
free(ap);
cJSON *value_alarm = cJSON_GetObjectItem(root, "isAlarm");
char *alarm = cJSON_Print(value_alarm);
free(alarm);
cJSON *value_radar = cJSON_GetObjectItem(root, "isRadar");
char *radar = cJSON_Print(value_radar);
free(radar);
cJSON *value_host = cJSON_GetObjectItem(root, "isHost");
char *host = cJSON_Print(value_host);
free(host);
cJSON *value_rf = cJSON_GetObjectItem(root, "isRfControl");
char *rf = cJSON_Print(value_rf);
free(rf);
cJSON *value_rf_one = cJSON_GetObjectItem(root, "rfOneFunc");
char *rf_one = cJSON_Print(value_rf_one);
free(rf_one);
cJSON *value_rf_two = cJSON_GetObjectItem(root, "rfTwoFunc");
char *rf_two = cJSON_Print(value_rf_two);
free(rf_two);
cJSON *value_rf_three = cJSON_GetObjectItem(root, "rfThreeFunc");
char *rf_three = cJSON_Print(value_rf_three);
free(rf_three);
cJSON *value_rf_four = cJSON_GetObjectItem(root, "rfFourFunc");
char *rf_four = cJSON_Print(value_rf_four);
free(rf_four);
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",1);
cJSON_AddStringToObject(device_info,"firmwareVersion","1.0");
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);
}
//启动mqtt
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);
}

96
firmware/esp-idf/get-started/main/wifi.c Normal file
View File

@@ -0,0 +1,96 @@
/******************************************************************************
* author: kerwincui
* create: 2021-06-08
* email：164770707@qq.com
* source:https://github.com/kerwincui/wumei-smart
******************************************************************************/
#include "wifi.h"
#define LISTEN_INTERVAL 3 //站监听AP信标的间隔。监听间隔的单位是一个信标间隔。例如，如果信标间隔为100 ms，侦听间隔为3，则站侦听信标的间隔为300 ms。
#define WIFI_CONNECTED_BIT BIT0
#define WIFI_FAIL_BIT BIT1
char ssid[33]="tp-six"; // wifi的SSID
char pwd[65]="clh15108665817"; // wifi的密码
static const char *TAG = "WIFI";
static EventGroupHandle_t s_wifi_event_group;
static esp_event_handler_instance_t instance_any_id;
static esp_event_handler_instance_t instance_got_ip;
// 回调函数
static void station_event_handler(void* arg, esp_event_base_t event_base, int32_t event_id, void* event_data)
{
printf("station event handler begin \n\n\n");
if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_START) {
esp_wifi_connect();
} else if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_DISCONNECTED) {
esp_wifi_connect();
} else if (event_base == IP_EVENT && event_id == IP_EVENT_STA_GOT_IP) {
ip_event_got_ip_t* event = (ip_event_got_ip_t*) event_data;
ESP_LOGI(TAG, "got ip: " IPSTR, IP2STR(&event->ip_info.ip));
xEventGroupSetBits(s_wifi_event_group, WIFI_CONNECTED_BIT);
}
}
//站点模式初始化
static void wifi_station_init(void)
{
esp_netif_create_default_wifi_sta();
ESP_ERROR_CHECK(esp_event_handler_instance_register(WIFI_EVENT, ESP_EVENT_ANY_ID, &station_event_handler, NULL, &instance_any_id));
ESP_ERROR_CHECK(esp_event_handler_instance_register(IP_EVENT, IP_EVENT_STA_GOT_IP, &station_event_handler, NULL, &instance_got_ip));
wifi_config_t wifi_config = {
.sta = {
.listen_interval = LISTEN_INTERVAL,
/* 设置密码意味着工作站将连接到包括WEP/WPA在内的所有安全模式。但是，这些模式已被弃用，不建议使用。
* 如果您的接入点不支持WPA2，可以通过在下面的行注释来启用这些模式 */
//.threshold.authmode = WIFI_AUTH_WPA2_PSK,
//PMF功能
.pmf_cfg = {
.capable = true,
.required = false
},
},
};
// wifi配置赋值
strcpy((char *)wifi_config.sta.ssid,(char *)ssid);
strcpy((char *)wifi_config.sta.password,(char *)pwd);
ESP_ERROR_CHECK(esp_wifi_set_config(ESP_IF_WIFI_STA, &wifi_config));
}
//启动wifi站点
void wifi_start(void)
{
s_wifi_event_group = xEventGroupCreate();
ESP_ERROR_CHECK(esp_netif_init());
wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();
ESP_ERROR_CHECK(esp_wifi_init(&cfg));
ESP_ERROR_CHECK(esp_wifi_set_mode(WIFI_MODE_STA));
ESP_LOGI(TAG, "ESP_WIFI_MODE_STA");
wifi_station_init();
ESP_ERROR_CHECK(esp_wifi_start());
//STATION模式，等待建立连接或者超过连接最大次数后连接失败，比特位是通过事件处理程序设置
EventBits_t bits = xEventGroupWaitBits(s_wifi_event_group,
WIFI_CONNECTED_BIT | WIFI_FAIL_BIT,
pdFALSE,
pdFALSE,
portMAX_DELAY);
if (bits & WIFI_CONNECTED_BIT) {
ESP_LOGI(TAG, "connected to ap SSID:%s password:%s",ssid, pwd);
} else if (bits & WIFI_FAIL_BIT) {
ESP_LOGI(TAG, "Failed to connect to SSID:%s, password:%s", ssid, pwd);
} else {
ESP_LOGE(TAG, "UNEXPECTED EVENT");
}
}