285 lines
7.9 KiB
C
285 lines
7.9 KiB
C
#include <string.h>
|
||
#include <stdio.h>
|
||
#include "esp8266.h"
|
||
#include "main.h"
|
||
#include "onenet.h"
|
||
#include "mqttkit.h"
|
||
#include "oled.h"
|
||
#include "stm32f1xx_hal_gpio.h"
|
||
#include "cJSON.h"
|
||
|
||
#define PRODUCT_ID "zzS53oqy5l"
|
||
#define DEVICE_ID "ESP_67EAF3"
|
||
#define SIGNATURE "version=2018-10-31&res=products%2FzzS53oqy5l%2Fdevices%2FESP_67EAF3&et=1766658508&method=md5&sign=r2rPhQdTZ3vpkxJTbgN5NQ%3D%3D"
|
||
|
||
|
||
extern unsigned char esp8266_buf[128];
|
||
|
||
|
||
//==========================================================
|
||
// 函数名称： OneNet_DevLink
|
||
//
|
||
// 函数功能： 与onenet创建连接
|
||
//
|
||
// 入口参数： 无
|
||
//
|
||
// 返回参数： 1-成功 0-失败
|
||
//
|
||
// 说明： 与onenet平台建立连接
|
||
//==========================================================
|
||
_Bool OneNet_DevLink(void)
|
||
{
|
||
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
|
||
|
||
unsigned char* dataPtr;
|
||
|
||
_Bool status = 1;
|
||
|
||
// printf("OneNet_DevLink\r\nPROID: %s\tAUIF: %s\tDEVID:%s\r\n", PRODUCT_ID, SIGNATURE, DEVICE_ID);
|
||
|
||
if (MQTT_PacketConnect(PRODUCT_ID, SIGNATURE, DEVICE_ID, 256, 1, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0)
|
||
{
|
||
ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传平台
|
||
|
||
dataPtr = ESP8266_GetIPD(250); //等待平台响应
|
||
if (dataPtr != NULL)
|
||
{
|
||
if (MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK)
|
||
{
|
||
switch (MQTT_UnPacketConnectAck(dataPtr))
|
||
{
|
||
case 0:
|
||
status = 0;
|
||
break;
|
||
|
||
// case 1: printf("WARN: 连接失败：协议错误\r\n");
|
||
// break;
|
||
// case 2: printf("WARN: 连接失败：非法的clientid\r\n");
|
||
// break;
|
||
// case 3: printf("WARN: 连接失败：服务器失败\r\n");
|
||
// break;
|
||
// case 4: printf("WARN: 连接失败：用户名或密码错误\r\n");
|
||
// break;
|
||
// case 5: printf("WARN: 连接失败：非法链接(比如token非法)\r\n");
|
||
// break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
MQTT_DeleteBuffer(&mqttPacket); //删包
|
||
}
|
||
// else
|
||
// printf("WARN: MQTT_PacketConnect Failed\r\n");
|
||
|
||
return status;
|
||
}
|
||
|
||
|
||
unsigned char OneNet_FillBuf(char* buf)
|
||
{
|
||
char text[48];
|
||
|
||
strcpy(buf, "{\"id\":\"1743082944\",\"params\":{");
|
||
|
||
memset(text, 0, sizeof(text));
|
||
sprintf(text, "\"volt\":{\"value\":%.2f},", IM_Volt * 0.0001);
|
||
strcat(buf, text);
|
||
|
||
memset(text, 0, sizeof(text));
|
||
sprintf(text, "\"current\":{\"value\":%.2f},", IM_Curr * 0.0001);
|
||
strcat(buf, text);
|
||
|
||
memset(text, 0, sizeof(text));
|
||
sprintf(text, "\"watt_P\":{\"value\":%.2f},", IM_Power * 0.0001);
|
||
strcat(buf, text);
|
||
|
||
memset(text, 0, sizeof(text));
|
||
sprintf(text, "\"energy\":{\"value\":%.3f},", IM_Energy * 0.0001);
|
||
strcat(buf, text);
|
||
|
||
memset(text, 0, sizeof(text));
|
||
sprintf(text, "\"output\":{\"value\":%s}",
|
||
HAL_GPIO_ReadPin(RELAY1_GPIO_Port, RELAY1_Pin) == GPIO_PIN_RESET ? "true" : "false");
|
||
strcat(buf, text);
|
||
|
||
strcat(buf, "}}");
|
||
return strlen(buf);
|
||
}
|
||
|
||
//==========================================================
|
||
// 函数名称： OneNet_SendData
|
||
//
|
||
// 函数功能： 上传数据到平台
|
||
//
|
||
// 入口参数： type：发送数据的格式
|
||
//
|
||
// 返回参数： 无
|
||
//
|
||
// 说明：
|
||
//==========================================================
|
||
|
||
void OneNet_SendData(void)
|
||
{
|
||
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
|
||
|
||
char buf[256];
|
||
|
||
short body_len = 0, i = 0;
|
||
memset(buf, 0, sizeof(buf)); //清空数组内容
|
||
|
||
body_len = OneNet_FillBuf(buf); //获取当前需要发送的数据流的总长度
|
||
|
||
if (body_len)
|
||
{
|
||
if (MQTT_PacketSaveData(DEVICE_ID, body_len, NULL, 5, &mqttPacket) == 0) //封包
|
||
{
|
||
for (; i < body_len; i++)
|
||
{
|
||
mqttPacket._data[mqttPacket._len++] = buf[i];
|
||
}
|
||
ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传数据到平台
|
||
MQTT_DeleteBuffer(&mqttPacket); //删包
|
||
}
|
||
else;
|
||
// printf( "WARN:EDP_NewBuffer Failed\r\n");
|
||
}
|
||
}
|
||
|
||
void OneNET_Subscribe(void)
|
||
{
|
||
MQTT_PACKET_STRUCTURE mqtt_packet = {NULL, 0, 0, 0}; //协议包
|
||
|
||
char topic_buf[56];
|
||
const char* topic = topic_buf;
|
||
|
||
snprintf(topic_buf, sizeof(topic_buf), "$sys/%s/%s/thing/property/set", PRODUCT_ID, DEVICE_ID);
|
||
|
||
// printf("Subscribe Topic: %s\r\n", topic_buf);
|
||
|
||
if (MQTT_PacketSubscribe(MQTT_SUBSCRIBE_ID, MQTT_QOS_LEVEL0, &topic, 1, &mqtt_packet) == 0)
|
||
{
|
||
ESP8266_SendData(mqtt_packet._data, mqtt_packet._len); //向平台发送订阅请求
|
||
|
||
MQTT_DeleteBuffer(&mqtt_packet); //删包
|
||
}
|
||
}
|
||
|
||
|
||
//==========================================================
|
||
// 函数名称： OneNet_RevPro
|
||
//
|
||
// 函数功能： 平台返回数据检测
|
||
//
|
||
// 入口参数： dataPtr：平台返回的数据
|
||
//
|
||
// 返回参数： 无
|
||
//
|
||
// 说明：
|
||
//==========================================================
|
||
void OneNet_RevPro(unsigned char* cmd)
|
||
{
|
||
char* req_payload = NULL;
|
||
char* cmdid_topic = NULL;
|
||
|
||
unsigned short topic_len = 0;
|
||
unsigned short req_len = 0;
|
||
|
||
unsigned char qos = 0;
|
||
static unsigned short pkt_id = 0;
|
||
|
||
unsigned char type = 0;
|
||
|
||
short result = 0;
|
||
|
||
type = MQTT_UnPacketRecv(cmd);
|
||
switch (type)
|
||
{
|
||
case MQTT_PKT_PUBLISH:
|
||
|
||
result = MQTT_UnPacketPublish(cmd, &cmdid_topic, &topic_len, &req_payload, &req_len, &qos, &pkt_id);
|
||
if (result == 0)
|
||
{
|
||
cJSON* root = cJSON_Parse(req_payload);
|
||
if (root == NULL) return;
|
||
|
||
const cJSON* id = cJSON_GetObjectItem(root, "id");
|
||
if (id == NULL) return;
|
||
|
||
cJSON* params = cJSON_GetObjectItem(root, "params");
|
||
if (params == NULL)
|
||
{
|
||
cJSON_Delete(root);
|
||
return;
|
||
}
|
||
|
||
// params process
|
||
const cJSON* energy = cJSON_GetObjectItem(params, "energy");
|
||
const cJSON* output = cJSON_GetObjectItem(params, "output");
|
||
|
||
if (energy != NULL)
|
||
{
|
||
char disp[64];
|
||
sprintf(disp, "set eng=%d", energy->valueint);
|
||
OLED_ShowString(0, 8, disp, 12);
|
||
}
|
||
|
||
if (output != NULL)
|
||
{
|
||
HAL_GPIO_WritePin(RELAY1_GPIO_Port, RELAY1_Pin, output->valueint ? GPIO_PIN_RESET : GPIO_PIN_SET);
|
||
}
|
||
|
||
MQTT_PACKET_STRUCTURE mqtt_packet = {NULL, 0, 0, 0};
|
||
|
||
cJSON* reply = cJSON_CreateObject();
|
||
cJSON_AddItemToObject(reply, "id", cJSON_CreateString(id->valuestring));
|
||
cJSON_AddItemToObject(reply, "code", cJSON_CreateNumber(200));
|
||
cJSON_AddItemToObject(reply, "msg", cJSON_CreateString("success"));
|
||
|
||
const char* reply_str = cJSON_Print(reply);
|
||
if (MQTT_PacketPublish(MQTT_PUBLISH_ID, strcat(cmdid_topic, "_reply"),
|
||
reply_str,
|
||
strlen(reply_str), MQTT_QOS_LEVEL0, 0, 1, &mqtt_packet) == 0)
|
||
{
|
||
ESP8266_SendData(mqtt_packet._data, mqtt_packet._len);
|
||
MQTT_DeleteBuffer(&mqtt_packet);
|
||
}
|
||
|
||
cJSON_Delete(reply);
|
||
cJSON_Delete(root);
|
||
}
|
||
break;
|
||
|
||
case MQTT_PKT_PUBACK: //发送Publish消息，平台回复的Ack
|
||
|
||
if (MQTT_UnPacketPublishAck(cmd) == 0)
|
||
break;
|
||
|
||
case MQTT_PKT_SUBACK: //发送Subscribe消息的Ack
|
||
|
||
if (MQTT_UnPacketSubscribe(cmd) == 0)
|
||
break;
|
||
|
||
default:
|
||
result = -1;
|
||
break;
|
||
}
|
||
|
||
ESP8266_Clear(); //清空缓存
|
||
|
||
if (result == -1)
|
||
return;
|
||
|
||
if (type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
|
||
{
|
||
MQTT_FreeBuffer(cmdid_topic);
|
||
MQTT_FreeBuffer(req_payload);
|
||
}
|
||
}
|
||
|
||
uint8_t onenet_state()
|
||
{
|
||
return OneNet_DevLink();
|
||
}
|