AlarmModule/core/cmd.c

/******************************************************************
** Copyright (c) 2009  Wuhan xiyun Technology Co., Ltd .
** FileName:	cmd.c
** Author:	 	chw
** Mail:		
** Editor:		chw
** Date:		2020-12-03 13:34
** Version: 	2020-12-03
** File Description:  mqtt 服务发送业务指令实现
** Param explain: char* mac : 网关MAC地址
   char* subMac             ：子节点MAC地址
  MQTTAsync_message *pubmsg : 消息结构体
  MYSQL *_db                ：数据库连接
******************************************************************/

#include "core.h"
#include "cmd.h"

//时间同步
int  SendNTP(char *mac)
{
    //获取系统时间
    time_t timep;
    struct tm *p;
    time(&timep);
    p = gmtime(&timep);
    int year2 = (p->tm_year+1900)%100;
    int mon = p->tm_mon + 1;
    int day = p->tm_mday;
    int hour = p->tm_hour + 8;
    int minc = p->tm_min;
    int sec = p->tm_sec;

    //debug("%s 2时间同步发送结果",mac);

    //填充报文
    char buf[10] = {0};
    buf[0] = (char)year2;
    buf[1] = (char)mon;
    buf[2] = (char)day;
    buf[3] = (char)hour;
    buf[4] = (char)minc;
    buf[5] = (char)sec;
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    sendData.payload = buf;
    sendData.payloadlen = 6;
    sendData.qos = 0;
    sendData.retained = 0;

    //主题
    char topicName[256];
    if(strcmp(mac,"") == 0)
    {
        sprintf(topicName,"NTP");
    }
    else
    {
        sprintf(topicName,"PP/%s/CFG/NTP",mac);
    }

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送时间同步指令,结果:%d,时间:%d-%d-%d %d:%d:%d,主题:%s \n",ret,buf[0],buf[1],buf[2],buf[3],buf[4],buf[5],topicName);
    return ret;
}

//校验协议长度
int CheckMsgLength(char *topicName,MQTTAsync_message *pubmsg,int protocal_length)
{
    UNUSED(topicName);
    if(pubmsg->payloadlen != protocal_length)
    {
        unsigned char* p = pubmsg->payload;

        if(pubmsg->payloadlen < 512)
        {
            char pdata[1024] = {0};
            Hex2Str((const char*)p,pdata,pubmsg->payloadlen);
            elog("error len--topicName:%s payloadlen:%d,msg:%s\n",topicName,pubmsg->payloadlen,pdata);
        }
        else
        {
            elog("error len--topicName:%s payloadlen:%d,msg:数据大于512\n",topicName,pubmsg->payloadlen);
        }

        return 1;
    }

    return 0;
}

//备份服务器ip发送
int SendBakIP(char *mac , MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    char ip[20] = {0};
    int  bakport = 0;
    char buf[256] = {0};
    char sendPrint[256] = {0};

    
    //数据库查询
    sprintf(query,"select bak_ip,bak_port from dev_info_gateway where device_mac ='%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s bak_ip 或者 bak_port 为空 \n",mac);
        mysql_free_result(res);
        return 1;
    }
    strcpy(ip,row[0]);
    bakport = atoi(row[1]);
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/BKS",mac);

    //填充报文
    unsigned long lIP = inet_addr(ip);
    memcpy(buf,&lIP,4);
    buf[4] = ((char*)&bakport)[1];
    buf[5] = ((char*)&bakport)[0];
    sendData.payload = buf;
    sendData.payloadlen = 6;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    Hex2Str(buf,sendPrint,sendData.payloadlen);
    log(" ↓发送备份服务器ip指令,结果:%d,网关:%s,ip:%s,bakport:%d,报文:%s \n",ret,mac,ip,bakport,sendPrint);
    
    return ret;
}

//节点信息表发送
int SendSubInfo(char *mac , MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char buf[256] = {0};
    char topicName[256];
    char sendPrint[256] = {0};
    int row_count;
    int ret = 0;
    
    //数据库查询
    sprintf(query,"select device_mac,device_type from dev_info_node where gateway_mac ='%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    //获取行数
    row_count = mysql_num_rows(res);
    if(row_count<1)
    {
        log("%s 没有查询到子节点 \n",mac);
        mysql_free_result(res);
        return 1;
    }
    //循环取出
    int i = 0;
    buf[0] = row_count;
    for (i = 0; i < row_count; i++)
    {
        char subMac[30] = {0};
        unsigned char nodeMac[30] = {0};
        int noteType = 0;
        row = mysql_fetch_row(res);
        if(!row[0] || !row[1])
        {
            log("%s 节点mac或者类型为空 \n",mac);
            continue;    
        }
        strcpy(subMac,row[0]);//子节点
        HexStrToByte(subMac,nodeMac,12);
        noteType = atoi(row[1]);//节点类型
        memcpy(buf+1+7*i,nodeMac,6);
        buf[1+7*i+6] = noteType;
    }
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/NAT",mac);

    //填充报文
    sendData.payload = buf;
    sendData.payloadlen = row_count*7 + 1;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    ret = my_mqqta_sendmsg(topicName, &sendData);
    Hex2Str(buf,sendPrint,sendData.payloadlen);
    log(" ↓发送节点信息表指令,结果:%d,网关:%s,报文:%s \n",ret,mac,sendPrint);

    return ret;
}

//额定电压发送
int SendRatedVoltage(char *mac,char *subMac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    unsigned char buf[256] = {0};
    unsigned char nodeMac[30] = {0};
    char topicName[256];
    int rated_voltage;
    int device_type;

    //数据库查询
    if (strcmp(subMac,"") == 0) //网关
    {
        sprintf(query,"select rated_voltage,device_type from dev_info_gateway where device_mac ='%s'",mac);
        HexStrToByte("0F0000000001",nodeMac,12);
    }
    else
    {
        sprintf(query,"select rated_voltage,device_type from dev_info_node where device_mac ='%s'",subMac);
        HexStrToByte(subMac,nodeMac,12);
    }
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s 额定电压或者设备类型为空 \n",mac);
        mysql_free_result(res);
        return 1;
    }
    rated_voltage = (atof(row[0]))*100;
    if (strcmp(subMac,"") == 0) //网关
    {
        device_type = 2;
    }
    else
    {
        device_type = atoi(row[1]);
    }
    mysql_free_result(res);
    debug("数据库查询:rated_voltage:%d,device_type:%d \n",rated_voltage,device_type);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/SRV",mac);
    //填充报文
    memcpy(buf,nodeMac,6);
    buf[6] = device_type;
    buf[7] = ((char*)&rated_voltage)[1];
    buf[8] = ((char*)&rated_voltage)[0];
    sendData.payload = buf;
    sendData.payloadlen = 9;
    sendData.qos = 0;
    sendData.retained = 0;
    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送额定电压设置指令,结果:%d,网关:%s,节点:%s,额定电压:%d,设备类型:%d \n",ret,mac,subMac,rated_voltage,device_type);

    return ret;
}

//额定电流发送
int SendRatedCurrent(char *mac,char *subMac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    unsigned char buf[256] = {0};
    unsigned char nodeMac[30] = {0};
    char topicName[256];
    int rated_current;
    int device_type;

    //数据库查询
    if (strcmp(subMac,"") == 0) //网关
    {
        sprintf(query,"select rated_current,device_type from dev_info_gateway where device_mac ='%s'",mac);
        HexStrToByte("0F0000000001",nodeMac,12);
    }
    else
    {
        sprintf(query,"select rated_current,device_type from dev_info_node where device_mac ='%s'",subMac);
        HexStrToByte(subMac,nodeMac,12);
    }
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s 额定电流或者设备类型为空 \n",mac);
        mysql_free_result(res);
        return 1;
    }
    rated_current = (atof(row[0]))*10000;
    if (strcmp(subMac,"") == 0) //网关
    {
        device_type = 2;
    }
    else
    {
        device_type = atoi(row[1]);
    }
    mysql_free_result(res);
    debug("数据库查询:rated_current:%d,device_type:%d \n",rated_current,device_type);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/SRC",mac);
    //填充报文
    memcpy(buf,nodeMac,6);
    buf[6] = device_type;
    buf[7] = ((char*)&rated_current)[3];
    buf[8] = ((char*)&rated_current)[2];
    buf[9] = ((char*)&rated_current)[1];
    buf[10] = ((char*)&rated_current)[0];
    sendData.payload = buf;
    sendData.payloadlen = 11;
    sendData.qos = 0;
    sendData.retained = 0;
    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送额定电流设置指令,结果:%d,网关:%s,节点:%s,额定电流:%d,设备类型:%d \n",ret,mac,subMac,rated_current,device_type);
    
    return ret;
}

/*
//传感器阈值发送
int SendBakIP(char *mac)
{
    return 0;
} */

//远程重启
int SendRestart(char *mac)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    char topicName[256];

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RRS",mac);
    sendData.payload = NULL;
    sendData.payloadlen = 0;
    sendData.qos = 0;
    sendData.retained = 0;
    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送远程重启指令,结果:%d,网关:%s \n",ret,mac);
    
    return ret;
}

//设备恢复出厂设置
int SendFactoryReset(char *mac)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    char topicName[256];

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/SFR",mac);
    sendData.payload = NULL;
    sendData.payloadlen = 0;
    sendData.qos = 0;
    sendData.retained = 0;
    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送设备恢复出厂设置指令,结果:%d,网关:%s \n",ret,mac);

    return ret;
}

//服务器跳转
int SendServerJump(char *mac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    char jump_ip[20] = {0};
    int  jump_port = 0;
    char buf[256] = {0};

    
    //数据库查询
    sprintf(query,"select jump_ip,jump_port from dev_info_gateway where device_mac ='%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s jump_ip 或者 jump_port 为空",mac);
        mysql_free_result(res);
        return 1;
    }
    strcpy(jump_ip,row[0]);
    jump_port = atoi(row[1]);
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RS",mac);

    //填充报文
    unsigned long lIP = inet_addr(jump_ip);
    memcpy(buf,&lIP,4);
    buf[4] = ((char*)&jump_port)[1];
    buf[5] = ((char*)&jump_port)[0];
    sendData.payload = buf;
    sendData.payloadlen = 6;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送服务器跳转指令,结果:%d,网关:%s,jump_ip:%s,jump_port:%d \n",ret,mac,jump_ip,jump_port);
    
    return ret;
}


//ota升级
int SendRemoteUpgrade(char *mac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    char upgrade_ip[20] = {0};
    int  upgrade_port = 0;
    char ota_file[256] = {0};
    int  ota_mode = 0;
    char buf[256] = {0};
    
    //数据库查询
    sprintf(query,"select upgrade_ip,upgrade_port,file_name,ota_mode from dev_info_gateway where device_mac ='%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1] || !row[3] || !row[4])
    {
        log("%s upgrade_ip 或者 upgrade_port 为空 或者 file_name、ota_mode为空",mac);
        mysql_free_result(res);
        return 1;
    }
    strcpy(upgrade_ip,row[0]);
    upgrade_port = atoi(row[1]);
    strcpy(ota_file,row[2]);
    ota_mode = atoi(row[3]);
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/OTA",mac);

    //填充报文
    unsigned long lIP = inet_addr(upgrade_ip);
    memcpy(buf,&lIP,4);
    buf[4] = ((char*)&upgrade_port)[1];
    buf[5] = ((char*)&upgrade_port)[0];
    sendData.payload = buf;
    sendData.payloadlen = 6;
    sendData.qos = 0;
    sendData.retained = 0;

    //文件加入升级文件链表
    UpgradeFileAddFromDB(file_list,ota_file,_db,ota_mode);

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送服务器远程升级指令,结果:%d,网关:%s,upgrade_ip:%s,upgrade_port:%d,file_name:%s,ota_mode:%d \n",ret,mac,upgrade_ip,upgrade_port,ota_file,ota_mode);
    
    return ret;
}


//远程手动调光
int SendManualDimming(char* mac,int group,int luminance,int dimmingType)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    char topicName[256];
    char buf[256] = {0};

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RDC",mac);

    //填充报文
    buf[0] = group;
    buf[1] = luminance;
    buf[2] = dimmingType;
    sendData.payload = buf;
    sendData.payloadlen = 3;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送手动调光指令,结果:%d,网关:%s,组号:%d,亮度:%d,调光类型:%d \n",ret,mac,group,luminance,dimmingType);

    return ret;
}


//远程开关控制
int SendSwitchControl(char* mac,char* subMac,int type,int on_off)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    char topicName[256];
    char buf[256] = {0};
    unsigned char nodeMac[30] = {0};

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RSC",mac);

    //填充报文
    if(strcmp(subMac,"") == 0)
    {
        HexStrToByte("0F0000000001",nodeMac,12);
        memcpy(buf,nodeMac,6);
        buf[6] = 2;
        buf[7] = on_off;
    }
    else
    {
        HexStrToByte(subMac,nodeMac,12);
        memcpy(buf,nodeMac,6);
        buf[6] = type;
        buf[7] = on_off;
    }
    sendData.payload = buf;
    sendData.payloadlen = 8;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送远程开关控制指令,结果:%d,网关:%s,类型:%d,开关动作:%d\n",ret,mac,type,on_off);

    return ret;
}

//远程开关编组控制
int SendSwitchGroupControl(char* mac,int group,int type,int on_off)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    char topicName[256];
    char buf[256] = {0};

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RGC",mac);

    //填充报文
    buf[0] = group;
    buf[1] = type;
    buf[2] = on_off;
    sendData.payload = buf;
    sendData.payloadlen = 3;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送远程开关编组控制指令,结果:%d,网关:%s,组号:%d,类型:%d,开关动作:%d\n",ret,mac,group,type,on_off);

    return ret;
}


//删除子节点
int SendDeleteNode(char* mac,char* subMac,int nodeType)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    char topicName[256];
    char buf[256] = {0};
    unsigned char nodeMac[30] = {0};

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CTR/RCN",mac);

    //填充报文
    HexStrToByte(subMac,nodeMac,12);
    memcpy(buf,nodeMac,6);
    buf[6] = nodeType;
    sendData.payload = buf;
    sendData.payloadlen = 7;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送删除子节点指令,结果:%d,网关:%s,节点:%s,节点类型:%d \n",ret,mac,subMac,nodeType);

    return ret;
}


//设备数据上传间隔设置
int SendDataInterval(char* mac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int upload_interval_unit = 0;
    int upload_interval = 0;
    char buf[256] = {0};

    
    //数据库查询
    sprintf(query,"select upload_interval_unit,upload_interval from dev_info_gateway where device_mac ='%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s upload_interval_unit 或者 upload_interval 为空",mac);
        mysql_free_result(res);
        return 1;
    }
    upload_interval_unit = atoi(row[0]);
    upload_interval = atoi(row[1]);
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/ULI",mac);

    //填充报文
    buf[0] = upload_interval_unit;
    buf[1] = upload_interval;
    sendData.payload = buf;
    sendData.payloadlen = 2;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送设备数据上传间隔设置指令,结果:%d,网关:%s,上传间隔单位:%d,上传间隔:%d \n",ret,mac,upload_interval_unit,upload_interval);
    
    return ret;
}


//开关时间段设置
int SendOnOffTime(char* mac,char* subMac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int device_type = 0;
    char open_time[10] = {0};
    char close_time[10] = {0};
    int time1 = 0;
    int time2 = 0;
    int time3 = 0;
    int time4 = 0;
    char buf[256] = {0};
    unsigned char dMac[30] = {0};

    //判断网关 子节点
    if(strcmp(subMac,"") == 0) //网关
    {
        sprintf(query,"select device_type,open_time,close_time from dev_info_gateway where device_mac ='%s'",mac);
        HexStrToByte("0F0000000001",dMac,12);
    }
    else
    {
        sprintf(query,"select device_type,open_time,close_time from dev_info_node where device_mac ='%s'",subMac);
        HexStrToByte(subMac,dMac,12);
    }
    
    //数据库查询
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1] || !row[2])
    {
        log("%s device_type,open_time,close_time 为空",mac);
        mysql_free_result(res);
        return 1;
    }

    if (strcmp(subMac,"") == 0) //网关
    {
        device_type = 2;
    }
    else
    {
        device_type = atoi(row[0]);
    }
    strcpy(open_time,row[1]);
    strcpy(close_time,row[2]);
    mysql_free_result(res);
    time1 = atoi(strtok(open_time,":"));
    time2 = atoi(strtok(NULL,":"));
    time3 = atoi(strtok(close_time,":"));
    time4 = atoi(strtok(NULL,":"));

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/STS",mac);

    //填充报文
    memcpy(buf,dMac,6);
    buf[6] = device_type;
    buf[7] = time1;
    buf[8] = time2;
    buf[9] = time3;
    buf[10] = time4;
    sendData.payload = buf;
    sendData.payloadlen = 11;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送开关时间段设置指令,结果:%d,网关:%s,节点:%s,设备类型:%d,合闸时间: %02d:%02d,拉闸时间: %02d:%02d \n",ret,mac,subMac,device_type,time1,time2,time3,time4);
    
    return ret;
}

//多个开关时间段设置,新增20201228
int SendOnOffTimeMuilt(char* mac,char* subMac,MYSQL *_db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int device_type = 0;
    char switch_time1[10] = {0};
    char switch_time2[10] = {0};
    char switch_time3[10] = {0};
    char switch_time4[10] = {0};
    int time1 = 0;
    int time2 = 0;
    int time3 = 0;
    int time4 = 0;
    int time5 = 0;
    int time6 = 0;
    int time7 = 0;
    int time8 = 0;
    int swith_action1 = 0;
    int swith_action2 = 0;
    int swith_action3 = 0;
    int swith_action4 = 0;
    int t1 = 0;
    int t2 = 0;
    int t3 = 0;
    int t4 = 0;
    int time_count = 2;
    char buf[256] = {0};
    unsigned char dMac[30] = {0};

    //判断网关 子节点
    if(strcmp(subMac,"") == 0) //网关
    {
        sprintf(query,"select device_type,swith_time1,swith_time2,swith_time3,swith_time4,swith_action1,swith_action2,swith_action3,swith_action4 "
                    "from dev_info_gateway where device_mac ='%s'",mac);
        HexStrToByte("0F0000000001",dMac,12);
    }
    else
    {
        sprintf(query,"select device_type,swith_time1,swith_time2,swith_time3,swith_time4,swith_action1,swith_action2,swith_action3,swith_action4 "
                      "from dev_info_node where device_mac ='%s'",subMac);
        HexStrToByte(subMac,dMac,12);
    }
    
    //数据库查询
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    //优化 新增对查询字段长度的判断 20210930 chw
    if(!row[0] || !row[1] || !row[2] || !row[5] || !row[6] || strlen(row[1])!=5 || strlen(row[2])!=5 || strlen(row[5])!=1 || strlen(row[6])!=1)
    {
        log("%s,%s 设备类型,第一组时间点、开关动作字段为空 \n",mac,subMac);
        mysql_free_result(res);
        return 1;
    }

    strcpy(switch_time1,row[1]);
    strcpy(switch_time2,row[2]);
    swith_action1 = atoi(row[5]);
    swith_action2 = atoi(row[6]);
    time1 = atoi(strtok(switch_time1,":"));
    time2 = atoi(strtok(NULL,":"));
    time3 = atoi(strtok(switch_time2,":"));
    time4 = atoi(strtok(NULL,":"));
    sendData.payloadlen = 14;

    //处理时间前大后小问题 20230525
    if(time1 > time3 || (time1 == time3 && time2 > time4))
    {
        t1 = time1;
        t2 = time2;
        t3 = time3;
        t4 = time4;
        time1 = t3;
        time2 = t4;
        time3 = t1;
        time4 = t2;
        swith_action1 = 0;
        swith_action2 = 1;
    }

    //优化 新增对查询字段长度的判断 20210930 chw
    if(!row[3] || !row[4] || !row[7] || !row[8] || strlen(row[3])!=5 || strlen(row[4])!=5 || strlen(row[7])!=1 || strlen(row[8])!=1)
    {
        log("%s,%s 设备类型,第二组时间点、开关动作字段为空,只发送第一组 \n",mac,subMac);
    }
    else
    {
        time_count = 4;
        sendData.payloadlen = 20;
        strcpy(switch_time3,row[3]);
        strcpy(switch_time4,row[4]);
        swith_action3 = atoi(row[7]);
        swith_action4 = atoi(row[8]);
        time5 = atoi(strtok(switch_time3,":"));
        time6 = atoi(strtok(NULL,":"));
        time7 = atoi(strtok(switch_time4,":"));
        time8 = atoi(strtok(NULL,":"));

        buf[14] = time5;
        buf[15] = time6;
        buf[16] = swith_action3;
        buf[17] = time7;
        buf[18] = time8;
        buf[19] = swith_action4;
    }
    

    if (strcmp(subMac,"") == 0) //网关
    {
        device_type = 2;
    }
    else
    {
        device_type = atoi(row[0]);
    }
    mysql_free_result(res);
    

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/STS",mac);

    //填充报文
    memcpy(buf,dMac,6);
    buf[6] = device_type;
    buf[7] = time_count;
    buf[8] = time1;
    buf[9] = time2;
    buf[10] = swith_action1;
    buf[11] = time3;
    buf[12] = time4;
    buf[13] = swith_action2;
    
    sendData.payload = buf;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送开关时间段设置指令,结果:%d,网关:%s,节点:%s,设备类型:%d,时间点一:%02d:%02d,时间二:%02d:%02d,时间点三:%02d:%02d,时间点四:%02d:%02d,动作1:%d,动作2:%d,动作3:%d,动作4:%d \n",
        ret,mac,subMac,device_type,time1,time2,time3,time4,time5,time6,time7,time8,swith_action1,swith_action2,swith_action3,swith_action4);
    
    return ret;
}


//获取子节点版本号
int SendGetSubVersion(char* mac,char* subMac)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    char topicName[256];
    char buf[256] = {0};
    unsigned char nodeMac[30] = {0};

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/GNV",mac);

    //填充报文
    if(strcmp(subMac,"") == 0)
    {
        HexStrToByte("0F0000000001",nodeMac,12);
    }
    else
    {
        HexStrToByte(subMac,nodeMac,12);
    }
    memcpy(buf,nodeMac,6);
    sendData.payload = buf;
    sendData.payloadlen = 6;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送获取子节点版本号指令,结果:%d,网关:%s,节点:%s \n",ret,mac,subMac);

    return ret;
}


//开关控制模式设置从数据库info表
int SendSwitchModeFromDB(char* mac,char* subMac,MYSQL* _db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int device_type = 0;
    int control_mode = 0;
    char buf[256] = {0};
    unsigned char dMac[30] = {0};

    //判断网关 子节点
    if(strcmp(subMac,"") == 0) //网关
    {
        sprintf(query,"select device_type,control_mode from dev_info_gateway where device_mac ='%s'",mac);
        HexStrToByte("0F0000000001",dMac,12);
    }
    else
    {
        sprintf(query,"select device_type,control_mode from dev_info_node where device_mac ='%s'",subMac);
        HexStrToByte(subMac,dMac,12);
    }
    
    //数据库查询
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1])
    {
        log("%s device_type,control_mode 为空",dMac);
        mysql_free_result(res);
        return 1;
    }

    if (strcmp(subMac,"") == 0) //网关
    {
        device_type = 2;
    }
    else
    {
        device_type = atoi(row[0]);
    }
    control_mode = atoi(row[1]);
    mysql_free_result(res);

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/SCM",mac);

    //填充报文
    memcpy(buf,dMac,6);
    buf[6] = device_type;
    buf[7] = control_mode;
    sendData.payload = buf;
    sendData.payloadlen = 8;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送开关控制模式指令,结果:%d,网关:%s,节点:%s,节点类型:%d,控制模式:%d \n",ret,mac,subMac,device_type,control_mode);
    
    return ret;
}

//调光节点分组设置
int SendDimmingNodeGroup(char* mac,char* subMac,MYSQL* _db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int device_type = 0;
    int device_group = 0;
    char time_seg1[10] = {0};
    char time_seg2[10] = {0};
    char time_seg3[10] = {0};
    char time_seg4[10] = {0};
    int time1[2] = {0};
    int time2[2] = {0};
    int time3[2] = {0};
    int time4[2] = {0};
    int dimming_seg1 = 0;
    int dimming_seg2 = 0;
    int dimming_seg3 = 0;
    int dimming_seg4 = 0;
    int dimming_mode = 0;
    int dimming_type = 0;
    char buf[256] = {0};
    unsigned char nodeMac[30] = {0};


    sprintf(query,"select device_type,device_group,time_seg1,time_seg2,time_seg3,time_seg4,dimming_seg1,dimming_seg2,dimming_seg3,dimming_seg4,"
                  "dimming_mode,dimming_type from dev_info_node where device_mac ='%s'",subMac);

    
    //数据库查询
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        log("%s 调光节点分组 NULL == res \n",subMac);
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        log("%s 调光节点分组 NULL == row \n",subMac);
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1] || !row[2] || !row[3] || !row[4] || !row[5] || !row[6] || !row[7] || !row[8] || !row[9] || !row[10] || !row[11])
    {
        log("%s 调光节点分组有字段设置为空! \n",subMac);
        mysql_free_result(res);
        return 1;
    }

    if(strlen(row[0]) == 0 || strlen(row[1]) == 0 || strlen(row[2]) == 0 || strlen(row[3]) == 0 || strlen(row[4]) == 0 \
        || strlen(row[5]) == 0 || strlen(row[6]) == 0 || strlen(row[7]) == 0 || strlen(row[8]) == 0 || strlen(row[9]) == 0 || strlen(row[10]) == 0 || strlen(row[11]) == 0)
    {
        log("%s 调光节点分组有时间设置为空白! \n",subMac);
        mysql_free_result(res);
        return 1;
    }
    device_type = atoi(row[0]);
    device_group = atoi(row[1]);
    strcpy(time_seg1,row[2]);
    strcpy(time_seg2,row[3]);
    strcpy(time_seg3,row[4]);
    strcpy(time_seg4,row[5]);
    dimming_seg1 = atoi(row[6]);
    dimming_seg2 = atoi(row[7]);
    dimming_seg3 = atoi(row[8]);
    dimming_seg4 = atoi(row[9]);
    dimming_mode = atoi(row[10]);
    dimming_type = atoi(row[11]);
    mysql_free_result(res);
    time1[0] = atoi(strtok(time_seg1,":"));
    time1[1] = atoi(strtok(NULL,":"));
    time2[0] = atoi(strtok(time_seg2,":"));
    time2[1] = atoi(strtok(NULL,":"));
    time3[0] = atoi(strtok(time_seg3,":"));
    time3[1] = atoi(strtok(NULL,":"));
    time4[0] = atoi(strtok(time_seg4,":"));
    time4[1] = atoi(strtok(NULL,":"));

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/DGS",mac);

    //填充报文
    HexStrToByte(subMac,nodeMac,12);
    memcpy(buf,nodeMac,6);
    buf[6] = device_type;
    buf[7] = device_group;
    buf[8] = time1[0];
    buf[9] = time1[1];
    buf[10] = dimming_seg1;
    buf[11] = time2[0];
    buf[12] = time2[1];
    buf[13] = dimming_seg2;
    buf[14] = time3[0];
    buf[15] = time3[1];
    buf[16] = dimming_seg3;
    buf[17] = time4[0];
    buf[18] = time4[1];
    buf[19] = dimming_seg4;
    buf[20] = dimming_mode;
    buf[21] = dimming_type;
    sendData.payload = buf;
    sendData.payloadlen = 22;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送调光节点分组设置指令,结果:%d,网关:%s,节点:%s,节点类型:%d,组号:%d,时间1: %02d:%02d,时间2: %02d:%02d,时间3: %02d:%02d,时间4: %02d:%02d,亮度1:%d,,亮度2:%d,"
          "亮度3:%d,亮度4:%d,调光模式:%d,调光类型:%d \n",ret,mac,subMac,device_type,device_group,time1[0],time1[1],time2[0],time2[1],time3[0],time3[1],
          time4[0],time4[1],dimming_seg1,dimming_seg2,dimming_seg3,dimming_seg4,dimming_mode,dimming_type);
    usleep(500000);
    return ret;
}

//调光节点分组数据修改
int SendDimmingNodeGroupModify(char* mac,int group,MYSQL* _db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer; 
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    int device_group = 0;
    char time_seg1[10] = {0};
    char time_seg2[10] = {0};
    char time_seg3[10] = {0};
    char time_seg4[10] = {0};
    int time1[2] = {0};
    int time2[2] = {0};
    int time3[2] = {0};
    int time4[2] = {0};
    int dimming_seg1 = 0;
    int dimming_seg2 = 0;
    int dimming_seg3 = 0;
    int dimming_seg4 = 0;
    int dimming_mode = 0;
    int dimming_type = 0;
    char buf[256] = {0};


    sprintf(query,"select device_group,time_seg1,time_seg2,time_seg3,time_seg4,dimming_seg1,dimming_seg2,dimming_seg3,dimming_seg4,"
                  "dimming_mode,dimming_type from dev_dimming_group where gateway_mac ='%s' and device_group = %d",mac,group);

    
    //数据库查询
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        log("%s 调光节点分组记录为空! \n",mac);
        mysql_free_result(res);
        return 1;
    }
    
    if(!row[0] || !row[1] || !row[2] || !row[3] || !row[4] || !row[5] || !row[6] || !row[7] || !row[8] || !row[9] || !row[10])
    {
        log("%s 调光节点分组有节点为空! \n",mac);
        mysql_free_result(res);
        return 1;
    }
    device_group = atoi(row[0]);
    strcpy(time_seg1,row[1]);
    strcpy(time_seg2,row[2]);
    strcpy(time_seg3,row[3]);
    strcpy(time_seg4,row[4]);
    dimming_seg1 = atoi(row[5]);
    dimming_seg2 = atoi(row[6]);
    dimming_seg3 = atoi(row[7]);
    dimming_seg4 = atoi(row[8]);
    dimming_mode = atoi(row[9]);
    dimming_type = atoi(row[10]);
    mysql_free_result(res);
    time1[0] = atoi(strtok(time_seg1,":"));
    time1[1] = atoi(strtok(NULL,":"));
    time2[0] = atoi(strtok(time_seg2,":"));
    time2[1] = atoi(strtok(NULL,":"));
    time3[0] = atoi(strtok(time_seg3,":"));
    time3[1] = atoi(strtok(NULL,":"));
    time4[0] = atoi(strtok(time_seg4,":"));
    time4[1] = atoi(strtok(NULL,":"));

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/DGM",mac);

    //填充报文
    buf[0] = device_group;
    buf[1] = time1[0];
    buf[2] = time1[1];
    buf[3] = dimming_seg1;
    buf[4] = time2[0];
    buf[5] = time2[1];
    buf[6] = dimming_seg2;
    buf[7] = time3[0];
    buf[8] = time3[1];
    buf[9] = dimming_seg3;
    buf[10] = time4[0];
    buf[11] = time4[1];
    buf[12] = dimming_seg4;
    buf[13] = dimming_mode;
    buf[14] = dimming_type;
    sendData.payload = buf;
    sendData.payloadlen = 15;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    log(" ↓发送调光节点分组数据修改指令,结果:%d,网关:%s,组号:%d,时间1: %02d:%02d,时间2: %02d:%02d,时间3: %02d:%02d,时间4: %02d:%02d,亮度1:%d,,亮度2:%d,"
          "亮度3:%d,亮度4:%d,调光模式:%d,调光类型:%d \n",ret,mac,device_group,time1[0],time1[1],time2[0],time2[1],
          time3[0],time3[1],time4[0],time4[1],dimming_seg1,dimming_seg2,dimming_seg3,dimming_seg4,dimming_mode,dimming_type);
    
    return ret;
}

//传感器报警阈值设置
int SendSensorThreshold(char* mac,MYSQL* _db)
{
    MQTTAsync_message sendData = MQTTAsync_message_initializer;
    MYSQL_RES* res = NULL;
    MYSQL_ROW row;
    char query[1024] = {0};
    char topicName[256];
    char buf[256] = {0};
    int temperature_min = 0;
    int temperature_max = 100;
    int humidity_min = 0;
    int humidity_max = 100;
    double x_offset_max = 5.0;
    double y_offset_max = 5.0;
    double z_offset_max = 5.0;
    int line_temperature_max = 100;
    int step = 0;
    char sendPrint[256] = {0};
    char vlog[512] = {0};

    sprintf(query,"select temperature_min,temperature_max,humidity_min,humidity_max,x_offset_max,y_offset_max,z_offset_max,line_temperature_max "
            "from dev_info_gateway where device_mac = '%s'",mac);
    excuteSql(_db,query);
    res = mysql_store_result(_db);
    if (NULL == res)
    {
        return 1;
    }
    row = mysql_fetch_row(res);
    if (NULL == row)
    {
        mysql_free_result(res);
        return 1;
    }

    //读取到温湿度配置
    if(row[0] && row[1] && row [2] && row [3])
    {
        temperature_min = atoi(row[0]);
        temperature_max = atoi(row[1]);
        humidity_min = atoi(row[2]);
        humidity_max = atoi(row[3]);
        buf[step] = 1;
        buf[step+1] = temperature_min;
        buf[step+2] = temperature_max;
        buf[step+3] = humidity_min;
        buf[step+4] = humidity_max;
        step += 5;

        sprintf(vlog,"%s温度最小值:%d,温度最大值:%d,湿度最小值:%d,湿度最大值:%d;",vlog,temperature_min,temperature_max,humidity_min,humidity_max);
    }

    //读取陀螺仪配置
    if(row[4] && row[5] && row [6])
    {
        x_offset_max = atof(row[4]);
        y_offset_max = atof(row[5]);
        z_offset_max = atof(row[6]);
        int x_offset_max_i = (int)(x_offset_max*10);
        int y_offset_max_i = (int)(y_offset_max*10);
        int z_offset_max_i = (int)(z_offset_max*10);
        buf[step] = 2;
        buf[step+1] = ((char*)&x_offset_max_i)[1];
        buf[step+2] = ((char*)&x_offset_max_i)[0];
        buf[step+3] = ((char*)&y_offset_max_i)[1];
        buf[step+4] = ((char*)&y_offset_max_i)[0];
        buf[step+5] = ((char*)&z_offset_max_i)[1];
        buf[step+6] = ((char*)&z_offset_max_i)[0];
        step += 7;

        sprintf(vlog,"%sx倾斜角最大值:%f,y倾斜角最大值:%f,z倾斜角最大值:%f;",vlog,x_offset_max,y_offset_max,z_offset_max);
    }

    //读取线温阈值配置
    if(row[7])
    {
        buf[step] = 4;
        line_temperature_max = atoi(row[7]);
        buf[step+1] = line_temperature_max;
        step += 2;

        sprintf(vlog,"%s线温最大值:%d;",vlog,line_temperature_max);
    }

    mysql_free_result(res);

    if(strlen(vlog) == 0)
    {
        log("数据库没有读取到传感器阈值!网关:%s",mac);
        return 1;
    }

    //主题
    if(strcmp(mac,"") == 0)
    {
        return 1;
    }
    sprintf(topicName,"PP/%s/CFG/SAT",mac);

    //填充报文
    sendData.payload = buf;
    sendData.payloadlen = step;
    sendData.qos = 0;
    sendData.retained = 0;

    //发送
    int ret = my_mqqta_sendmsg(topicName, &sendData);
    Hex2Str(buf,sendPrint,sendData.payloadlen);
    log(" ↓发送传感器阈值指令,结果:%d,网关:%s,sendPrint:%s,%s \n",ret,mac,sendPrint,vlog);
    return ret;
}


//电表节点分组设置
//int ()