555 lines
25 KiB
C
555 lines
25 KiB
C
#include "lora.h"
|
||
|
||
|
||
LoRaParameter LoRaSetData = { //模块工作参数
|
||
0x00, //模块地址高字节
|
||
0x00, //模块地址低字节
|
||
0x01, //模块网络地址
|
||
LoRa_9600, //模块串口 波特率 9600
|
||
LoRa_8N1, //串口工作模式 8数据位 无校验 1停止位
|
||
LoRa_38_4, //模块空中速率 38.4K
|
||
LoRa_Data240, //数据分包大小 240字节
|
||
LoRa_RssiDIS, //关闭RSSI功能
|
||
LoRa_FEC_22DBM, //发射功率22dbm
|
||
LoRa_CH23, //模块信道
|
||
LoRa_RssiByteDIS, //禁用RSSI字节功能
|
||
LoRa_ModePOINT, //定点模式
|
||
LoRa_RelayDIS, //禁用中继模式
|
||
LoRa_LBTEN, //使能LBT
|
||
LoRa_WorTX, //Wor模式发送 只在模式1才有效
|
||
LoRa_Wor2000ms, //Wor周期2000毫秒 只在模式1才有效
|
||
0x22, //模块加密秘钥高字节
|
||
0x33, //模块加密秘钥低字节
|
||
};
|
||
|
||
|
||
//LoRA模块引脚初始化
|
||
void loraGpioInit(void) {
|
||
GPIO_InitTypeDef GPIO_InitStruct = {0};
|
||
|
||
__HAL_RCC_GPIOA_CLK_ENABLE();
|
||
|
||
GPIO_InitStruct.Pin = LORA_AUX_Pin; //忙检测引脚
|
||
GPIO_InitStruct.Mode = GPIO_MODE_INPUT;
|
||
GPIO_InitStruct.Pull = GPIO_PULLUP;
|
||
HAL_GPIO_Init(LORA_AUX_Port, &GPIO_InitStruct);
|
||
|
||
GPIO_InitStruct.Pin = LORA_POW_Pin ; //电源控制引脚
|
||
GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP;
|
||
GPIO_InitStruct.Pull = GPIO_NOPULL;
|
||
GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_LOW;
|
||
HAL_GPIO_Init(LORA_POW_Port, &GPIO_InitStruct);
|
||
|
||
GPIO_InitStruct.Pin = LORA_M0_Pin ; //M0引脚
|
||
GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP;
|
||
GPIO_InitStruct.Pull = GPIO_NOPULL;
|
||
GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_LOW;
|
||
HAL_GPIO_Init(LORA_M0_Port, &GPIO_InitStruct);
|
||
|
||
GPIO_InitStruct.Pin = LORA_M1_Pin ; //M1引脚
|
||
GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP;
|
||
GPIO_InitStruct.Pull = GPIO_NOPULL;
|
||
GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_LOW;
|
||
HAL_GPIO_Init(LORA_M1_Port, &GPIO_InitStruct);
|
||
|
||
LoRa_MODE2; //模块模式2
|
||
HAL_Delay(200); //适当延时
|
||
}
|
||
/*-------------------------------------------------*/
|
||
/*函数名：LoRa上电复位 */
|
||
/*参 数：timeout：超时时间 */
|
||
/*返回值：0：正确 其他：错误 */
|
||
/*-------------------------------------------------*/
|
||
uint8_t loraReset(int16_t timeout) {
|
||
LoRa_PowerOFF; //先关闭电源
|
||
HAL_Delay(200); //延时
|
||
LoRa_PowerON; //再打开电源
|
||
|
||
while(timeout--) { //等待复位成功
|
||
HAL_Delay(100); //延时100ms
|
||
if(LoRa_AUX==1) //需要等到高电平1，才能跳出while，表示复位完毕
|
||
break; //主动跳出while循环
|
||
u1_printf("%d ",timeout); //串口输出现在的超时时间
|
||
}
|
||
u1_printf("\r\n"); //串口输出信息
|
||
if(timeout<=0)return 1; //如果timeout<=0，说明超时时间到了，也没能等到LoRa_AUX高电平，返回1
|
||
return 0; //正确，返回0
|
||
}
|
||
/*-------------------------------------------------*/
|
||
/*函数名：初始化模块 */
|
||
/*参 数：无 */
|
||
/*返回值：无 */
|
||
/*-------------------------------------------------*/
|
||
void loraInit(void) {
|
||
loraGpioInit(); //Lora模块引脚初始化
|
||
u1_printf("准备复位Lora模块\r\n"); //串口输出信息
|
||
if(loraReset(100)) { //复位Lora模块，返回值如果非零，表示错误
|
||
u1_printf("复位Lora模块失败，重启\r\n"); //串口输出信息
|
||
NVIC_SystemReset(); //重启
|
||
} else u1_printf("Lora模块复位成功\r\n"); //串口输出信息
|
||
u1_printf("准备设置Lora模块\r\n"); //串口输出信息
|
||
loraSet(); //设置Lora模块
|
||
HAL_Delay(200); //延时
|
||
}
|
||
|
||
/*-------------------------------------------------*/
|
||
/*函数名：LoRa设置工作参数 */
|
||
/*参 数：无 */
|
||
/*返回值：无 */
|
||
/*-------------------------------------------------*/
|
||
void loraSet(void) {
|
||
uint8_t cmd[12]; //保存设置参数的数组缓冲区，命令共计12字节
|
||
|
||
cmd[0] = 0xC0; //设置参数指令的起始字节，固定值0xC0
|
||
cmd[1] = 0x00; //设置参数的起始寄存器地址，从寄存器0开始设置，一共9个
|
||
cmd[2] = 0x09; //一共设置9个寄存器
|
||
cmd[3] = LoRaSetData.LoRa_AddrH; //设置模块地址高字节
|
||
cmd[4] = LoRaSetData.LoRa_AddrL; //设置模块地址低字节
|
||
cmd[5] = LoRaSetData.LoRa_NetID; //设置模块网络地址
|
||
cmd[6] = LoRaSetData.LoRa_Baudrate | LoRaSetData.LoRa_UartMode | LoRaSetData.LoRa_airvelocity; //设置模块 波特率 串口模式 空中速率
|
||
cmd[7] = LoRaSetData.LoRa_DataLen | LoRaSetData.LoRa_Rssi | LoRaSetData.LoRa_TxPower; //设置模块 数据分包长度 RSSI噪声是否使能 发射功率
|
||
cmd[8] = LoRaSetData.LoRa_CH; //设置模块信道
|
||
cmd[9] = LoRaSetData.LoRa_RssiByte | LoRaSetData.LoRa_DateMode | LoRaSetData.LoRa_Relay | LoRaSetData.LoRa_LBT | LoRaSetData.LoRa_WORmode | LoRaSetData.LoRa_WORcycle; //设置模块 是否使用RSSI字节功能 传输方式 是否中继 是否使用LBT WOR模式收发控制 WOR周期
|
||
cmd[10] = LoRaSetData.LoRa_KeyH; //设置模块加密秘钥高字节
|
||
cmd[11] = LoRaSetData.LoRa_KeyL; //设置模块加密秘钥低字节
|
||
u3_TxDataBuf(cmd,12); //发送缓冲区加入数据
|
||
}
|
||
/*-------------------------------------------------*/
|
||
/*函数名：LoRa查询工作参数 */
|
||
/*参 数：data：工作参数数据 */
|
||
/*返回值：无 */
|
||
/*-------------------------------------------------*/
|
||
void loraGet(uint8_t *data) {
|
||
uint8_t ch; //保存信道的变量
|
||
|
||
u1_printf("模块地址:0x%02X%02X\r\n",data[3],data[4]); //串口输出信息
|
||
u1_printf("模块网络ID:0x%02X\r\n",data[5]); //串口输出信息
|
||
|
||
switch(data[6]&0xE0) { //判断串口波特率
|
||
case LoRa_1200 :
|
||
u1_printf("波特率 1200\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_2400 :
|
||
u1_printf("波特率 2400\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_4800 :
|
||
u1_printf("波特率 4800\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_9600 :
|
||
u1_printf("波特率 9600\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_19200 :
|
||
u1_printf("波特率 19200\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_38400 :
|
||
u1_printf("波特率 38400\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_57600 :
|
||
u1_printf("波特率 57600\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_115200:
|
||
u1_printf("波特率 115200\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[6]&0x18) { //判断串口参数
|
||
case LoRa_8N1 :
|
||
u1_printf("8数据位 无校验 1停止位\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_8O1 :
|
||
u1_printf("8数据位 奇校验 1停止位\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_8E1 :
|
||
u1_printf("8数据位 偶校验 1停止位\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[6]&0x07) { //判断空中速率
|
||
case LoRa_0_3 :
|
||
u1_printf("空中速率 0.3K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_1_2 :
|
||
u1_printf("空中速率 1.2K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_2_4 :
|
||
u1_printf("空中速率 2.4K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_4_8 :
|
||
u1_printf("空中速率 4.8K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_9_6 :
|
||
u1_printf("空中速率 9.6K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_19_2 :
|
||
u1_printf("空中速率 19.2K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_38_4 :
|
||
u1_printf("空中速率 38.4K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_62_5 :
|
||
u1_printf("空中速率 62.5K\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[7]&0xC0) { //判断数据分包大小
|
||
case LoRa_Data240 :
|
||
u1_printf("数据分包大小：240字节\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_Data128 :
|
||
u1_printf("数据分包大小：128字节\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_Data64 :
|
||
u1_printf("数据分包大小：64字节\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_Data32 :
|
||
u1_printf("数据分包大小：32字节\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[7]&0x20) { //判断是否启用RSSI功能
|
||
case LoRa_RssiEN :
|
||
u1_printf("启用RSSI功能\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_RssiDIS :
|
||
u1_printf("禁用RSSI功能\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[7]&0x03) { //判断发射功率
|
||
case LoRa_FEC_22DBM :
|
||
u1_printf("发射功率 22dbm\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_FEC_17DBM :
|
||
u1_printf("发射功率 17dbm\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_FEC_13DBM :
|
||
u1_printf("发射功率 13dbm\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_FEC_10DBM :
|
||
u1_printf("发射功率 10dbm\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
|
||
ch = data[8] & 0x7F; //保存信道
|
||
u1_printf("信道:0x%02X 对应频率%dMHz\r\n",ch,410+ch); //串口输出信息
|
||
|
||
switch(data[9]&0x80) { //判断RSSI字节功能
|
||
case LoRa_RssiByteEN :
|
||
u1_printf("启用RSSI字节功能\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_RssiByteDIS :
|
||
u1_printf("禁用RSSI字节功能\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[9]&0x40) { //判断传输模式
|
||
case LoRa_ModeTRANS :
|
||
u1_printf("透明传输\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_ModePOINT :
|
||
u1_printf("定点传输\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[9]&0x20) { //判断中继功能
|
||
case LoRa_RelayEN :
|
||
u1_printf("启用中继\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_RelayDIS :
|
||
u1_printf("禁用中继\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
switch(data[9]&0x10) { //判断LBT功能
|
||
case LoRa_LBTEN :
|
||
u1_printf("启用LBT\r\n"); //串口输出信息
|
||
break; //跳出
|
||
case LoRa_LBTDIS :
|
||
u1_printf("禁用LBT\r\n"); //串口输出信息
|
||
break; //跳出
|
||
}
|
||
// switch(data[9]&0x08){ //判断WOR模式
|
||
// case LoRa_WorTX : u1_printf("Wor模式发送\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_WorRX : u1_printf("Wor模式接收\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// }
|
||
// switch(data[9]&0x07){ //判断WOR周期
|
||
// case LoRa_Wor500ms : u1_printf("WOR周期时间 500毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor1000ms : u1_printf("WOR周期时间 1000毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor1500ms : u1_printf("WOR周期时间 1500毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor2000ms : u1_printf("WOR周期时间 2000毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor2500ms : u1_printf("WOR周期时间 2500毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor3000ms : u1_printf("WOR周期时间 3000毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor3500ms : u1_printf("WOR周期时间 3500毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// case LoRa_Wor4000ms : u1_printf("WOR周期时间 4000毫秒\r\n"); //串口输出信息
|
||
// break; //跳出
|
||
// }
|
||
}
|
||
|
||
|
||
/*-------------------------------------------------*/
|
||
/*函数名：串口3被动事件 */
|
||
/*参 数：data ：数据 */
|
||
/*参 数：datalen ：数据长度 */
|
||
/*返回值：无 */
|
||
/*-------------------------------------------------*/
|
||
uint8_t tempdata[512];
|
||
void u3PassiveEvent(uint8_t *data, uint16_t datalen) {
|
||
/*----------------------------------------------*/
|
||
/* 接收设置LoRa模块返回数据 */
|
||
/*----------------------------------------------*/
|
||
if((data[0]==0xC1)&&(datalen==12)) {
|
||
u1_printf("接收设置LoRa模块返回数据\r\n"); //串口输出信息
|
||
loraGet(data); //分析设置的参数
|
||
LoRa_MODE0; //切换到模式0
|
||
HAL_Delay(200); //延时
|
||
catReset(); //4G模块重启
|
||
}
|
||
|
||
|
||
/*----------------------------------------------*/
|
||
/* 接收到子设备x上发的证书信息 */
|
||
/*----------------------------------------------*/
|
||
if(datalen==(SUBMQTTINFO_STRUCT_LEN+1)) { //收到符合长度的数据
|
||
switch (data[0]) {
|
||
case CERT1_DATA:
|
||
subDeviceReportingCertificate(0,data);
|
||
break;
|
||
case CERT2_DATA:
|
||
subDeviceReportingCertificate(1,data);
|
||
break;
|
||
case CERT3_DATA:
|
||
subDeviceReportingCertificate(2,data);
|
||
break;
|
||
case CERT4_DATA:
|
||
subDeviceReportingCertificate(3,data);
|
||
break;
|
||
case CERT5_DATA:
|
||
subDeviceReportingCertificate(4,data);
|
||
break;
|
||
case CERT6_DATA:
|
||
subDeviceReportingCertificate(5,data);
|
||
break;
|
||
case CERT7_DATA:
|
||
subDeviceReportingCertificate(6,data);
|
||
break;
|
||
case CERT8_DATA:
|
||
subDeviceReportingCertificate(7,data);
|
||
break;
|
||
case CERT9_DATA:
|
||
subDeviceReportingCertificate(8,data);
|
||
break;
|
||
case CERT10_DATA:
|
||
subDeviceReportingCertificate(9,data);
|
||
break;
|
||
default :
|
||
break;
|
||
}
|
||
u1_printf("***收到子设备数据，线程结束...\r\n");
|
||
taskRunning = 0; //则退出
|
||
}
|
||
|
||
|
||
|
||
/*----------------------------------------------*/
|
||
/* 接收到子设备x上发的开关状态数据 */
|
||
/*----------------------------------------------*/
|
||
if(datalen==(ATTRIBUTE_STRUCT_LEN+1)) { //收到符合长度的数据
|
||
switch (data[0]) {
|
||
case SUB1_DATA:
|
||
subDeviceReportingSwitchStatus(0,data);
|
||
break;
|
||
case SUB2_DATA:
|
||
subDeviceReportingSwitchStatus(1,data);
|
||
break;
|
||
case SUB3_DATA:
|
||
subDeviceReportingSwitchStatus(2,data);
|
||
break;
|
||
case SUB4_DATA:
|
||
subDeviceReportingSwitchStatus(3,data);
|
||
break;
|
||
case SUB5_DATA:
|
||
subDeviceReportingSwitchStatus(4,data);
|
||
break;
|
||
case SUB6_DATA:
|
||
subDeviceReportingSwitchStatus(5,data);
|
||
break;
|
||
case SUB7_DATA:
|
||
subDeviceReportingSwitchStatus(6,data);
|
||
break;
|
||
case SUB8_DATA:
|
||
subDeviceReportingSwitchStatus(7,data);
|
||
break;
|
||
case SUB9_DATA:
|
||
subDeviceReportingSwitchStatus(8,data);
|
||
break;
|
||
case SUB10_DATA:
|
||
subDeviceReportingSwitchStatus(9,data);
|
||
break;
|
||
default :
|
||
break;
|
||
}
|
||
u1_printf("***收到子设备数据，线程结束...\r\n");
|
||
taskRunning = 0; //则退出
|
||
}
|
||
|
||
}
|
||
|
||
|
||
//子设备上报证书信息至云平台 推送 参数说明： sub_num 子设备序号 0表示设备1...
|
||
void subDeviceReportingCertificate(uint8_t sub_num,uint8_t *data) {
|
||
u1_printf("接收到子设备%d证书信息。\r\n",sub_num + 1);
|
||
memcpy(&SubMqttInfo_Struct[sub_num],&data[1],SUBMQTTINFO_STRUCT_LEN); //临时缓冲区全部清零
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/live/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.live.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22online\\22:[{\\22uid\\22:\\22%s\\22,\\22secret\\22:\\22%s\\22}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubMqttInfo_Struct[sub_num].Passward);
|
||
|
||
u1_printf("子设备%d的uid：%s,secret：%s\r\n",
|
||
sub_num + 1,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubMqttInfo_Struct[sub_num].Passward);
|
||
SUB_DEVICE_ON[sub_num] = 1;//子设备上线标志位置一
|
||
}
|
||
|
||
|
||
uint8_t massage_index = 0;
|
||
//子设备上报开关状态至云平台 推送 参数说明： sub_num 子设备序号 0表示设备1...
|
||
void subDeviceReportingSwitchStatus(uint8_t sub_num,uint8_t *data) {
|
||
uint8_t sub_sensor_online_count = 0;
|
||
if(massage_index > 9)
|
||
massage_index = 1;
|
||
|
||
sub_sensor_online_count = SubAttribute_Struct[sub_num].Water_PH_OnLine +
|
||
SubAttribute_Struct[sub_num].Envir_Press_OnLine +
|
||
SubAttribute_Struct[sub_num].Water_DissOxy_OnLine +
|
||
SubAttribute_Struct[sub_num].Envir_Byx_OnLine +
|
||
SubAttribute_Struct[sub_num].Leaf_TH_OnLine +
|
||
SubAttribute_Struct[sub_num].Soil_TH_OnLine +
|
||
SubAttribute_Struct[sub_num].Soil_NPK_OnLine +
|
||
SubAttribute_Struct[sub_num].Soil_PH_OnLine +
|
||
SubAttribute_Struct[sub_num].Soil_EC_OnLine;
|
||
|
||
u1_printf("接收到子设备%d的数据。\r\n",sub_num + 1);
|
||
|
||
memcpy(&SubAttribute_Struct[sub_num],&data[1],ATTRIBUTE_STRUCT_LEN); //拷贝数据
|
||
|
||
u1_printf("开关1：%d\r\n",SubAttribute_Struct[sub_num].Switch1Sta); //串口输出数据
|
||
u1_printf("开关2：%d\r\n",SubAttribute_Struct[sub_num].Switch2Sta); //串口输出数据
|
||
u1_printf("开关3：%d\r\n",SubAttribute_Struct[sub_num].Switch3Sta); //串口输出数据
|
||
u1_printf("开关4：%d\r\n",SubAttribute_Struct[sub_num].Switch4Sta); //串口输出数据
|
||
|
||
u1_printf("子设备%d的传感器在线数量：%d\r\n",sub_num + 1,sub_sensor_online_count);
|
||
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22BAT_VAL\\22:%d,\\22sw1\\22:%d,\\22sw2\\22:%d,\\22sw3\\22:%d,\\22sw4\\22:%d}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Sub_BAT,
|
||
SubAttribute_Struct[sub_num].Switch1Sta,
|
||
SubAttribute_Struct[sub_num].Switch2Sta,
|
||
SubAttribute_Struct[sub_num].Switch3Sta,
|
||
SubAttribute_Struct[sub_num].Switch4Sta);//回复数据
|
||
HAL_Delay(1000);
|
||
/*****************************************************************************/
|
||
/* 开始推送在线的传感器数据至云平台 */
|
||
/*****************************************************************************/
|
||
switch (massage_index){
|
||
|
||
case 1:
|
||
if(SubAttribute_Struct[sub_num].Water_PH_OnLine) { //如果在线则推送消息至云平台
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22PH\\22:%.2f,\\22DS_T\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Water_PH,
|
||
SubAttribute_Struct[sub_num].Water_Temp);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 2:
|
||
if(SubAttribute_Struct[sub_num].Envir_Press_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22BS_RH\\22:%.2f,\\22BS_T\\22:%.2f,\\22BS_DO\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Envir_PressHumi,
|
||
SubAttribute_Struct[sub_num].Envir_PressTemp,
|
||
SubAttribute_Struct[sub_num].Envir_Press);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 3:
|
||
if(SubAttribute_Struct[sub_num].Water_DissOxy_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22DO\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Water_DissOxy);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 4:
|
||
if(SubAttribute_Struct[sub_num].Envir_Byx_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22BY_CO2\\22:%.2f,\\22BY_HV\\22:%d,\\22BY_RH\\22:%.2f,\\22BY_TP\\22:%.2f,}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Envir_Co2,
|
||
SubAttribute_Struct[sub_num].Envir_Light,
|
||
SubAttribute_Struct[sub_num].Envir_Humi,
|
||
SubAttribute_Struct[sub_num].Envir_Temp);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 5:
|
||
if(SubAttribute_Struct[sub_num].Leaf_TH_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22YSMD_RH\\22:%.2f,\\22YSMD_TP\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Leaf_Humi,
|
||
SubAttribute_Struct[sub_num].Leaf_Temp);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 6:
|
||
if(SubAttribute_Struct[sub_num].Soil_TH_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22SOIL_RH\\22:%.2f,\\22SOIL_TP\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Soil_Humi,
|
||
SubAttribute_Struct[sub_num].Soil_Temp);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 7:
|
||
if(SubAttribute_Struct[sub_num].Soil_NPK_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22SOIL_NV\\22:%.2f,\\22SOIL_PV\\22:%.2f,\\22SOIL_KV\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Soil_NV,
|
||
SubAttribute_Struct[sub_num].Soil_PV,
|
||
SubAttribute_Struct[sub_num].Soil_KV);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 8:
|
||
if(SubAttribute_Struct[sub_num].Soil_PH_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22SOIL_PH\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Soil_PH);//回复数据
|
||
}
|
||
break;
|
||
|
||
case 9:
|
||
if(SubAttribute_Struct[sub_num].Soil_EC_OnLine){
|
||
CAT1_printf("AT+MPUB=\"/iot/sub/prop/post/%s\",0,0,\"{\\22header\\22:\\22iot.sub.prop.post\\22,\\22version\\22:\\221.0\\22,\\22body\\22:{\\22subs\\22:[{\\22uid\\22:\\22%s\\22,\\22props\\22:{\\22SOIL_RV\\22:%.2f}}]}}\"\r\n",
|
||
GwMqttInfo_Struct.ClientID,
|
||
SubMqttInfo_Struct[sub_num].ClientID,
|
||
SubAttribute_Struct[sub_num].Soil_EC);//回复数据
|
||
}
|
||
break;
|
||
|
||
default: break;
|
||
}
|
||
|
||
massage_index++;
|
||
}
|
||
|