WLG/uart/uart.cpp

#include "uart.hpp"
#include <signal.h>
#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>
#include <termios.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <boost/thread/thread.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/algorithm/string.hpp>
#include <boost/bind.hpp>
#include <boost/timer/timer.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <zlog.h>
#include <json/json.h>
#include "mqttclient/mqtt_client.h"
#include "utility/serial.h"
#include "scheduler/schedule.hpp"

extern zlog_category_t *zct;
extern zlog_category_t *zbt;
extern std::map<std::string, compressWaveChannel> g_mapCompress;

int offSize = 0;
pTestRecvCallBack pTestRecv;

extern std::vector<RecvData> g_VecWaveDataX;
extern std::vector<RecvData> g_VecWaveDataY;
extern std::vector<RecvData> g_VecWaveDataZ;

int Uart::UartRecv(int fd, char srcshow, char *buffer) {
    char buff[BUF_LENGTH];
    int ret = 0;
    int maxSize = 0;
    int offSize = 0;
    int timeoutflag = 0;
    char head[] = {0xAA, 0x55, 0xAA};
#ifdef G2UL_GATEWAY
    char szbuffer[BUF_LENGTH] = {0x00};
#endif
    while (1) {
        if (now_task == WAVE_CMD) {
            memset(buff, 0, sizeof(buff));
            ret = read_data(fd, buff, BUF_LENGTH, 10);
            if (ret <= 0) {
                timeoutflag++;
                if (timeoutflag > 100) {
                    DealReviveDuration(wave_shortAddr);
                    zlog_warn(zct, "===============0x9999 timeout= %d offSize = %d===============shortAddr = %02x%02x", timeoutflag, offSize,UINT16_HIGH(wave_shortAddr),UINT16_LOW(wave_shortAddr));
                    zlog_warn(zct, "0x9999 timeout %d===============Size = %d", timeoutflag, offSize);
                    FindRecvPackage(offSize, mUartRecvTmpBuf, head);
                    now_task = -1;
                    timeoutflag = 0;
                    offSize = 0;
                    maxSize = 0;
                    tcflush(fd, TCIFLUSH);
                    mssleep(10000);
                    wave_trans_ = true;
                    memset(mUartRecvTmpBuf, 0, BUF_LENGTH);
                    zlog_warn(zct, "wave end");
                }
                mssleep(10000); 
            } else if (ret > 0) {
                maxSize += ret;
                timeoutflag = 0;             
                m_TimeStamp = 0;
                memcpy(mUartRecvTmpBuf + offSize, buff, ret);
                offSize = offSize + ret;
                if (offSize > BUF_LENGTH * 15) {
                    zlog_info(zct, "maxSize = %d", offSize);
                    memset(mUartRecvTmpBuf, 0, BUF_LENGTH);
                    timeoutflag = 0;
                    offSize = 0;
                    maxSize = 0;
                    tcflush(fd, TCIOFLUSH);
                }
                
            }

        } else {
            memset(buff, 0, sizeof(buff));
            ret = read_data(fd, buff, BUF_LENGTH, 50);
            if (ret <= 0) {
                continue;
            }
            if (srcshow) {
                zlog_info(zct, "0x8888 ===str_recv===,ret = %d", ret);
                for (int i = 0; i < ret; i++) {
                    printf("[%02x]", buff[i] & 0xff);
                }
                printf("\n");
                FindRecvPackage(ret, buff, head);
            }
        }
    }
}

Uart::Uart() : mUart(mIoSev), mStrand(mIoSev) {
    mRdLength = 0;
    m_TimeStamp = 0;
    mlastSize = 0;
    fd = 0;
    waittime = 0;
    mPackgeIndex = -1;
    bUpdate = false;
    m_strDestShortAddr = "";
    memset(mUartRecvBuf, 0, BUF_LENGTH);
    memset(mUartRecvTmpBuf, 0, BUF_LENGTH);
    bTest = false;
    TestFd = 0;
    wave_shortAddr = 0;
    DataNodeUpdateFile = "";
    strTimetamp = "";
    bZigbeeSinal = false;
    m_waveCountX = 0;
    m_waveCountY = 0;
    m_waveCountZ = 0;
    VecWaveDataX.reserve(1000);
    VecWaveDataY.reserve(1000);
    VecWaveDataZ.reserve(1500);
}

Uart::~Uart() {
    close(fd);
    close(TestFd);
    if (mUart.is_open()) mUart.close();
}

void Uart::InitUart(speed_t speed) {
    fd = config_uart("/dev/ttymxc4", speed);
    zlog_info(zct, "InitUart fd = %d", fd);
    if (fd < 0) {
        zlog_error(zct, "config_uart error");
    }
}

void Uart::Close() {
    close(fd);
    fd = 0;
}

void Uart::InitZigbeeHW() {
    InitUart(B115200);
    UpdateZigbeeInfoCtrl();
    sleep(2);
    int iRet = ReadFromUart();
    if (iRet <= 0) {
        Close();
        sleep(2);
        zlog_info(zct, "Speed error");
        InitUart(B57600);
        UpdateZigbeeInfoCtrl();
        sleep(2);
        ReadFromUart();
        zlog_info(zct, "modify speed");
        WriteSpeed2Zigbee();
        ReadFromUart();
    }
    Close();
    sleep(1);
}

void TestRecv(int status) {
    char szStatus[10] = {0x00};
    sprintf(szStatus, "%d", status);
    write_data(uart_inst::instance().TestFd, (char *)szStatus, strlen(szStatus));
}

void Regist(pTestRecvCallBack pTestRecv1) { pTestRecv = pTestRecv1; }

void Uart::InitTestUart(speed_t speed) {
    zlog_info(zct, "InitTestUart");
    TestFd = config_uart("/dev/ttymxc2", speed); // Test
    if (TestFd < 0) {
        zlog_error(zct, "Test config_uart error");
    }
    Regist(TestRecv);
}

void Uart::ReadTestUart() {
    char buff[BUF_LENGTH] = {0x00};
    zlog_info(zct, "ReadTestUart");
    while (1) {
        int ret = read_data(TestFd, buff, BUF_LENGTH, 10);
        if (ret > 0) {
            zlog_info(zct, "buff = %s", buff);
            if (!strcmp(buff, "0")) {
                char buf[256] = {0};
                sprintf(buf, "{\"dataNodeGatewayNo\":\"%s\",\"cmd\":\"12\",\"status\":\"REQ\"}", GlobalConfig::MacAddr_G.c_str());
                std::string str = std::string(buf);
                int iRet = data_publish(str.c_str(), GlobalConfig::Topic_G.mPubCmd.c_str());
                if (iRet < 0) {
                    pTestRecv(1);
                } else {
                    pTestRecv(0);
                }
                iRet = ZigbeeTest();
            } else if (!strcmp(buff, "1")) {
                std::string IP = GetGwIp_("eth0");
                write_data(TestFd, (char *)IP.c_str(), IP.size());
                IP = GetGwIp_("eth1");
                write_data(TestFd, (char *)"|", 1);
                write_data(TestFd, (char *)IP.c_str(), IP.size());
                write_data(TestFd, (char *)"|", 1);
            } else {
                ModifyMac(buff);
                pTestRecv(0);
            }
        }
        mssleep(20000);
    }
}

int Uart::ZigbeeTest() {
    modify_Localchannel(22);
    mssleep(100000);

    modify_LocalPanID(2222);

    mssleep(100000);
    modify_LocalAddr(6666);

    mssleep(100000);
    return 0;
}

void Uart::WriteToUart(const char *strSend, int pLen) {
    if (!bUpdate) 
    {
        printf( "Write To Uart Start:\n");
        for (int i = 0; i < pLen; i++) {
            printf("%02X ", *(strSend + i) & 0xFF);
        }
        printf( "\nWrite To Uart End.\n");
    }

    write_data(fd, (char *)strSend, pLen);
}

int Uart::ReadFromUart() {
    char buffer[100] = {0x00};
    int len = read_data(fd, (char *)buffer, 100, 10);
    for (int i = 0; i < len; i++) printf( "%02X ", buffer[i] & 0xFF);
    zlog_info(zct, "==========ReadFromUart========len = %d", len);

    if (len) {
        char head[] = {0xAA, 0x55, 0xAA};
        FindRecvPackage(len, buffer, head);
    }
    return len;
}

void Uart::Run() { mIoSev.run(); }

void Uart::Stop() {
    if (mUart.is_open()) mUart.close();
    mIoSev.stop();
}

void Uart::setCallBack(onReceiveUart _callback) { m_callback = _callback; }

void Uart::UpdateZigbeeInfo(const char *pData) {
    zlog_info(zct, "update gateway zigbee info");
    GlobalConfig::Zigbee_G = *((ZIGBEE *)pData);
    char buff[8];
    sprintf(buff, "%02d", pData[36] & 0xFF);
    GlobalConfig::ZigbeeInfo_G.DevMode = atoi(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%02d", pData[37] & 0xFF);
    GlobalConfig::ZigbeeInfo_G.Channel = atoi(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%02x%02x", pData[38] & 0xFF, pData[39] & 0xFF);
    GlobalConfig::ZigbeeInfo_G.PanID = std::string(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%02x%02x", pData[40] & 0xFF, pData[41] & 0xFF);
    GlobalConfig::ZigbeeInfo_G.MyAddr = std::string(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%02x%02x", pData[50] & 0xFF, pData[51] & 0xFF);
    GlobalConfig::ZigbeeInfo_G.DstAddr = std::string(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%d", pData[62]);
    GlobalConfig::ZigbeeInfo_G.RetryNum = std::string(buff);

    memset(buff, 0, 8);
    sprintf(buff, "%d", pData[63]);
    GlobalConfig::ZigbeeInfo_G.TranTimeout = std::string(buff);

    zlog_info(zbt, "local zigbee module info Mode : %d Chan : %d PanID : %s MyAddr : %s DstAddr : %s,RetryNum:%s,TranTimeout:%s", GlobalConfig::ZigbeeInfo_G.DevMode, GlobalConfig::ZigbeeInfo_G.Channel, GlobalConfig::ZigbeeInfo_G.PanID.c_str(),
              GlobalConfig::ZigbeeInfo_G.MyAddr.c_str(), GlobalConfig::ZigbeeInfo_G.DstAddr.c_str(), GlobalConfig::ZigbeeInfo_G.RetryNum.c_str(), GlobalConfig::ZigbeeInfo_G.TranTimeout.c_str());

    zlog_info(zbt, "PanID = %s,MacAddr_G= %s", GlobalConfig::ZigbeeInfo_G.PanID.c_str(), GlobalConfig::MacAddr_G.c_str());

    std::string strchan = ReadStrByOpt(ZIGBEECONFIG, "Zigbee", "channel");
    zlog_info(zbt, "Channel = %d,strchan = %s", GlobalConfig::ZigbeeInfo_G.Channel, strchan.c_str());

    std::string strType = ReadStrByOpt(SYSTEMINFOFILE, "ZigbeeType", "type");
    zlog_info(zbt, "TranTimeout = %02x,strType = %s ", GlobalConfig::Zigbee_G.TranTimeout, strType.c_str());
    if (strType == "aw21") {
        unsigned short TranTimeout = 0x0A;
        WriteTranTimeout2Zigbee(TranTimeout);
    }
    if (strType == "zm5161") {
        unsigned short TranTimeout = 0x03;
        WriteTranTimeout2Zigbee(TranTimeout);
    }
}

void int2bytes(int i, unsigned char *bytes, int size) {
    memset(bytes, 0, sizeof(unsigned char) * size);
    bytes[0] = (unsigned char)(0xff & i);
    bytes[1] = (unsigned char)((0xff00 & i) >> 8);
    bytes[2] = (unsigned char)((0xff0000 & i) >> 16);
    bytes[3] = (unsigned char)((0xff000000 & i) >> 24);
}
void Uart::GetLocalZigbeeRSSI(uint16_t ushortAdd){
    zlog_info(zct, "Local Zigbee Signal !\n");
    mssleep(20000);
    getZigbeeSignal(ushortAdd);
    mssleep(10000);
}
int Uart::DealAskTask(uint16_t ushortAdd){
    char wherecon[50]={0};
    sprintf(wherecon, "zigbeeShortAddr='%02x%02x'", UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd));
    int sensor_count = sqlite_db_ctrl::instance().GetTableRows(T_SENSOR_INFO(TNAME), wherecon);

    if (sensor_count < 1) {
        zlog_warn(zct, "device info not found  %02x%02x ", UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd));
        return 1;
    }
    ModifyDistAddr(ushortAdd);
    int next_duration = 0;
    int taskID = scheduler::instance().StartSchedule(ushortAdd,next_duration);
    ScheduleTask scheduleTask;
    zlog_info(zct, "taskID = %d ", taskID);
    if (taskID == kScheduleEigenValue)      //1.特征值
    {
        char localtimestamp[32] = {0x00};
        int millisecond = 0;
        std::string rtcTime = GetRTC(localtimestamp, millisecond);
        scheduleTask.cmd = MEAS_EVAL;
        scheduleTask.shortAddr = ushortAdd;
        scheduleTask.timeStamp = atoi(localtimestamp);
        TaskResp(scheduleTask);
    }
    else if (taskID == kScheduleWaveForm)   //2.波形
    {
        wave_shortAddr = ushortAdd;
        GetLocalZigbeeRSSI(ushortAdd);
        scheduleTask.cmd = SIGNAL_STRENGTH;
        scheduleTask.shortAddr = ushortAdd;
        scheduleTask.duration = next_duration;
        TaskResp(scheduleTask);
        
    }
    else if (taskID == kScheduleUpgrade)    //3.升级
    {
        UpdateWirelessNode(ushortAdd);
    }else if (taskID == kScheduleConfigSensor) //4.更新配置
    {
        scheduleTask.cmd = CONFIG;
        scheduleTask.shortAddr = ushortAdd;
        mssleep(50000);
        TaskResp(scheduleTask);
        mssleep(50000);
        UpdateConfig(ushortAdd);
    }else if (taskID == kScheduleWrongTime) //5.异常连接
    {
        scheduleTask.cmd = REVIVE_DURATION;
        scheduleTask.shortAddr = ushortAdd;
        scheduleTask.duration = next_duration;
        zlog_info(zct, "next_duration = %d ", next_duration);
        TaskResp(scheduleTask);
    }else if (taskID == 13) //6.RSSI
    {
        scheduleTask.cmd = SIGNAL_STRENGTH;
        scheduleTask.shortAddr = ushortAdd;
        scheduleTask.duration = next_duration;
        TaskResp(scheduleTask);
    }
    
    return 0;
}

int Uart::DealException(const char* pData){
	return 0;
}

int Uart::DealReviveDuration(uint16_t ushortAdd){

    ScheduleTask scheduleTask;
    uint16_t next_duration = scheduler::instance().GetNextDuration(ushortAdd);
    zlog_info(zct, "next_duration = %d ", next_duration);
    scheduleTask.cmd = REVIVE_DURATION;
    scheduleTask.shortAddr = ushortAdd;
    scheduleTask.duration = next_duration;
    
    TaskResp(scheduleTask);
    return 0;
}

int Uart::DealConfig(uint16_t ushortAdd){

    char whereCon[1024] = {0};
    char updateSql[1024] = { 0 };
    sprintf(updateSql, "UpdateFlag = 1");
    sprintf(whereCon, "zigbeeShortAddr='%02x%02x'", UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd));
    sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql, whereCon);
    scheduler::instance().UpdateConfigResult(ushortAdd,0);
    return 0;
}
int Uart::DealWaveCompress(const char *pData,uint16_t ushortAdd){

    zlog_info(zct, "DealWaveCompress ");
    char buf[20] = {0x00};
    sprintf(buf, "%02x%02x", (ushortAdd >> 8) & 0xFF, ushortAdd & 0xFF);
    std::string strShortAddr = std::string(buf);
    compressWaveChannel tempchannel;
    tempchannel.compressChannelX = pData[7];
    tempchannel.compressChannelY = pData[8];
    tempchannel.compressChannelZ = pData[9];

    tempchannel.CountX = BUILD_UINT32(pData[13], pData[12],pData[11],pData[10]);
    tempchannel.CountY = BUILD_UINT32(pData[17], pData[16],pData[15],pData[14]);
    tempchannel.CountZ = BUILD_UINT32(pData[21], pData[20],pData[19],pData[18]);
    
    g_mapCompress[strShortAddr] = tempchannel;

    zlog_info(zct, "count X = %d,Y = %d,Z = %d ", tempchannel.CountX, tempchannel.CountY, tempchannel.CountZ);
    zlog_info(zct, "compress X = %d,Y = %d,Z = %d ", tempchannel.compressChannelX, tempchannel.compressChannelY, tempchannel.compressChannelZ);
    return 0;
}
int Uart::DealSensorRSSI(const char *pData,uint16_t ushortAdd){

    //传感器获取网关信号强度
    zlog_info(zct, "DealSensorRSSI ushortAdd = %02x%02x",UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd));
    mssleep(200000);
    ScheduleTask scheduleTask;
    now_task = WAVE_CMD;
    scheduleTask.cmd = WAVE_CMD;
    scheduleTask.shortAddr = ushortAdd;
    
    TaskResp(scheduleTask);

    char localtimestamp[32] = {0};
    GetTimeNet(localtimestamp, 1);
    char sensor_rssi[10] = {0x00};
    sprintf(sensor_rssi, "%02d", pData[7] & 0xFF);
    if (!strcmp(sensor_rssi, "00") || !strcmp(sensor_rssi, "0")) {
        char errorInfo[100] = {0x00};
        sprintf(errorInfo, "No RSSI %s", sensor_rssi);
        zlog_error(zct, errorInfo);
    } else {
        char tableName[100] = {0x00};
        char whereCon[100] = {0};
        char updateSql[100] = {0};
        sprintf(whereCon, "zigbeeShortAddr='%02x%02x'", UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd));
        vec_t vecDataNodeNo = sqlite_db_ctrl::instance().GetDataSingleLine(T_SENSOR_INFO(TNAME), " MeasurementID,RSSI ", whereCon);
        sprintf(tableName, "t_dataStatic_%s", (char *)vecDataNodeNo[0].c_str());
        memset(whereCon,0,sizeof(whereCon));
        sprintf(whereCon, "dataNodeNo='%s' order by timeStamp desc limit 1", vecDataNodeNo[0].c_str());
        std::string timestamp_last = sqlite_db_ctrl::instance().GetData(tableName, " timeStamp ", whereCon);
        sprintf(updateSql, "zigbeeSignalNode = '%02d' ",atoi(sensor_rssi));
        memset(whereCon,0,sizeof(whereCon));
        sprintf(whereCon, "dataNodeNo='%s' and timeStamp = '%s'", (char*)vecDataNodeNo[0].c_str(),timestamp_last.c_str());
        sqlite_db_ctrl::instance().UpdateTableData(tableName, updateSql, whereCon);

        std::vector<std::string> vParamRSSI;
        boost::split(vParamRSSI, vecDataNodeNo[1], boost::is_any_of(","), boost::token_compress_on);
        memset(updateSql,0,sizeof(updateSql));
        memset(whereCon,0,sizeof(whereCon));
        if (vParamRSSI.size() > 0) {
            sprintf(updateSql, "RSSI = '%s,%02d' ", vParamRSSI[0].c_str(), pData[7] & 0xFF);
            sprintf(whereCon, "dataNodeNo='%s'", (char *)vecDataNodeNo[0].c_str());
            sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql, whereCon);
        }
    }
    return 0;
}
int Uart::DealUpgrade(uint16_t ushortAdd,int status){

    char updateSql[100] = {0};
    char wherecon[100] = {0};
    memset(wherecon,0,sizeof(wherecon));
    memset(updateSql,0,sizeof(updateSql));
    sprintf(wherecon," zigbeeShortAddr =  '%02x%02x' ",UINT16_HIGH(ushortAdd), UINT16_LOW(ushortAdd));
    sprintf(updateSql, " upgradeStatus = %d", status);
    sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql,wherecon);

    memset(wherecon,0,sizeof(wherecon));
    sprintf(wherecon," short_addr = '%02x%02x' ORDER BY start_timestamp DESC LIMIT 1 ",UINT16_HIGH(ushortAdd), UINT16_LOW(ushortAdd));
    std::string start_timestamp = sqlite_db_ctrl::instance().GetData("firmware_upgrade ", " start_timestamp ", wherecon);

    memset(updateSql,0,sizeof(updateSql));
    memset(wherecon,0,sizeof(wherecon));
    sprintf(wherecon," short_addr = '%02x%02x' AND start_timestamp = '%s'",UINT16_HIGH(ushortAdd), UINT16_LOW(ushortAdd),start_timestamp.c_str());
    sprintf(updateSql, " status = %d",status);
    sqlite_db_ctrl::instance().UpdateTableData(" firmware_upgrade ", updateSql,wherecon);
    
    return 0;
}
void Uart::DealRecvData(const char *pData) {

    uint16_t ushortAdd = BUILD_UINT16(pData[3] & 0xFF, pData[4] & 0xFF);
    uint8_t command = pData[5] & 0xFF;
    uint8_t recvcode = pData[7] & 0xFF;
    
    zlog_info(zct, "shortAdd = %02x%02x,command = %d ",UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd),command);
    switch (command) {
        case DEVICE_INF: 
            DealDataNodeInfo(pData);
        break;
        case DEVICE_INF2: 
            DealDataNodeName(pData);
        break;
        case ASK_TASK:
            DealAskTask(ushortAdd);
        break;
        case DEVICE_EXCEPTION:
            DealException(pData);
        break;
        case MEAS_EVAL:
            DealDataNodeFeature(pData, 0);
            DealReviveDuration(ushortAdd);
        break;
        case UPGRADE:
            if (recvcode == 0){
                DealUpgrade(ushortAdd,2);
                scheduler::instance().UpgradeResult(ushortAdd,0);
                zlog_info(zbt, "[UPGRADE SUCCESS] shortAdd = %02x%02x,command = %d,recvcode = %d ",UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd),command,recvcode);
            }else{
                DealUpgrade(ushortAdd,3);
                scheduler::instance().UpgradeResult(ushortAdd,recvcode);
                zlog_warn(zbt, "[UPGRADE FAILED] shortAdd = %02x%02x,command = %d,recvcode = %d ",UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd),command,recvcode);
            }
        break;
        case CONFIG:
            if (recvcode == 0){
                DealReviveDuration(ushortAdd);
                DealConfig(ushortAdd);   
            }else{
                scheduler::instance().UpdateConfigResult(ushortAdd,recvcode);
                zlog_warn(zbt, "[CONFIG] shortAdd = %02x%02x,command = %d,recvcode = %d ",UINT16_HIGH(ushortAdd),UINT16_LOW(ushortAdd),command,recvcode);
            }
        break;
        case WAVE_COMPRESS:
            DealWaveCompress(pData,ushortAdd);
        break;
        case SIGNAL_STRENGTH:
            DealSensorRSSI(pData,ushortAdd);
        break;
        default: break;
    }
}

void Uart::DealDataNodeName(const char *pData) {
    zlog_info(zct, "DealDataNodeName ");
    std::string strTime = GetLocalTimeWithMs();
    char szShortAdd[8] = {0x00};
    char shortAdd[8] = {0x00};
    char NodeName[128] = {0x00};
    sprintf(szShortAdd, "%02x%02x", pData[3] & 0xFF, pData[4] & 0xFF);
    memcpy(NodeName, &pData[7], 64);
    memcpy(shortAdd, &pData[3], 2);
    char whereCon[64] = {0};
    char uplCon[200] = {0x00};
    char nodeWaveSend[10] = {0x00};

    for (int i = 0; i < 64; i++) {
        sprintf(&NodeName[i * 2], "%02X", pData[7 + i] & 0xFF);
    }
    char MeasurementID[100] = {0x00};
    sprintf(MeasurementID, "%02x%02x%02x%02x%02x%02x%02x%02x", pData[71], pData[72], pData[73], pData[74], pData[75], pData[76], pData[77], pData[78]);
    sprintf(nodeWaveSend, "%d,%d,%d", GET_BIT(pData[79], 0), GET_BIT(pData[79], 1), GET_BIT(pData[79], 2));
    char gbkNodeName[128] = {0x00};
    sprintf(whereCon, "zigbeeShortAddr='%s'", szShortAdd);
    zlog_info(zct, "whereCon = %s", whereCon);
    array_t vecRes = sqlite_db_ctrl::instance().GetDataMultiLine(T_SENSOR_INFO(TNAME), " dataNodeNo, MeasurementID,hardVersion,softVersion", whereCon);
    if (vecRes.size() > 1) {
        for (size_t i = 0; i < vecRes.size(); i++) {
            if (vecRes[i][1] != "") {
                memset(whereCon,0,sizeof(whereCon));
                sprintf(whereCon, "%s= '%s'", T_SENSOR_INFO(DATANODENO), vecRes[i][0].c_str());
                sqlite_db_ctrl::instance().DeleteTableData(T_SENSOR_INFO(TNAME), whereCon);
                memset(whereCon,0,sizeof(whereCon));
                sprintf(whereCon, "%s= '%s'", T_SENSOR_INFO(DATANODENO), vecRes[i][1].c_str());
                sqlite_db_ctrl::instance().DeleteTableData(T_DATA_INFO(TNAME), whereCon);
                sqlite_db_ctrl::instance().DeleteTableData(T_DATASTATIC_INFO(TNAME), whereCon);
                sqlite_db_ctrl::instance().DeleteTableData(T_DATANODE_TIME(TNAME), whereCon);
                sqlite_db_ctrl::instance().DeleteTableData(T_BATTERY_INFO(TNAME), whereCon);
                sqlite_db_ctrl::instance().DeleteTableData(" t_battery_history ", whereCon);
                memset(whereCon,0,sizeof(whereCon));
                sprintf(whereCon, "channelID like'%s'", vecRes[i][1].c_str());
                sqlite_db_ctrl::instance().DeleteTableData(" t_data_waveSend ", whereCon);
                char szTableName[50] = {0x00};
                sprintf(szTableName, "DROP TABLE t_data_%s", vecRes[i][1].c_str());
                sqlite_db_ctrl::instance().CreateTable(szTableName);
                memset(szTableName, 0x00, sizeof(szTableName));
                sprintf(szTableName, "DROP TABLE t_dataStatic_%s", vecRes[i][1].c_str());
                sqlite_db_ctrl::instance().CreateTable(szTableName);
                scheduler::instance().ClearScheduleCfg(atoi(szShortAdd));

            }
        }
    }
    std::string hardVersion = vecRes[0][2];
    std::string softVersion = vecRes[0][3];
    if ((hardVersion == "3.0" && compareVersions(softVersion, "3.6") == -1) || (hardVersion == "4.0" && compareVersions(softVersion, "4.6") == -1)|| (hardVersion == "1.0" && compareVersions(softVersion,"1.2") == -1)) {
        memcpy(MeasurementID, vecRes[0][0].c_str(), sizeof(MeasurementID));
    }
    std::string strNodeName(NodeName);
    zlog_info(zct, "strNodeName = %s", strNodeName.c_str());
    solve(gbkNodeName, NodeName);
    zlog_info(zct, "gbkNodeName = %s", gbkNodeName);
    zlog_info(zct, "NodeName = %s", NodeName);
    zlog_info(zct, "whereCon = %s", whereCon);
    sprintf(uplCon, "dataNodeName = '%s' , MeasurementID = '%s',NodeWaveSend = '%s'", gbkNodeName, MeasurementID, nodeWaveSend);
    sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), uplCon, whereCon);
    std::string strData = sqlite_db_ctrl::instance().GetNodeConfigureInfor(whereCon);
    data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
}

void Uart::DealDataNodeInfo(const char *pData) {

    int res = 0;
    RecvData *pRecvData = (RecvData *)pData;
    zlog_warn(zct, "recv remote zigbee module info shortAddr %02x%02x", pRecvData->Data[46], pRecvData->Data[47]);
    char buf[32] = {0};
    char chTemp = pRecvData->Data[0]; //设备状态标志 1 byte
    DataNodeInfo dataNodeInfo;
    dataNodeInfo.EquipSta = GET_BIT(chTemp, 2);
    dataNodeInfo.TemTopFlag = GET_BIT(chTemp, 3);
    dataNodeInfo.TemBotFlag = GET_BIT(chTemp, 4);
    dataNodeInfo.ZigbeeFlag = GET_BIT(chTemp, 5);
    dataNodeInfo.AccFlag = GET_BIT(chTemp, 6);
    dataNodeInfo.InitFlag = GET_BIT(chTemp, 7);

    sprintf(buf, "%02x%02x%02x%02x%02x%02x%02x%02x", pRecvData->Data[1], pRecvData->Data[2], pRecvData->Data[3], pRecvData->Data[4], pRecvData->Data[5], pRecvData->Data[6], pRecvData->Data[7], pRecvData->Data[8]);
    dataNodeInfo.ZigbeeLongAddr = std::string(buf); // Zigbee MAC 8 byte

    chTemp = pRecvData->Data[9]; //硬件版本 1 byte
    memset(buf, 0, 32);
    sprintf(buf, "%.1f", 0.1 * chTemp);
    dataNodeInfo.HardVersion = std::string(buf);

    chTemp = pRecvData->Data[10]; //软件版本 1 byte
    memset(buf, 0, 32);
    sprintf(buf, "%.1f", 0.1 * chTemp);
    dataNodeInfo.SoftVersion = std::string(buf);

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT32(pRecvData->Data[11], pRecvData->Data[12], pRecvData->Data[13], pRecvData->Data[14]));
    dataNodeInfo.BpNo = std::string(buf); //生产批号 4 byte

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT32(pRecvData->Data[15], pRecvData->Data[16], pRecvData->Data[17], pRecvData->Data[18]));
    dataNodeInfo.SerialNo = std::string(buf); //生产序列号 4 byte

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT32(pRecvData->Data[19], pRecvData->Data[20], pRecvData->Data[21], pRecvData->Data[22]));
    dataNodeInfo.FirstPowerTime = std::string(buf); //首次上电日期 4 byte

    // 23 24 25 26     27 28 29 30    31 32 33 34   35 36   37 38=>序号13 无线信号强度

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT32(pRecvData->Data[23], pRecvData->Data[24], pRecvData->Data[25], pRecvData->Data[26]));
    dataNodeInfo.WakeupTime = atoi(buf); //唤醒次数 4 byte
    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT32(pRecvData->Data[27], pRecvData->Data[28], pRecvData->Data[29], pRecvData->Data[30]));
    dataNodeInfo.StaticTime = atoi(buf); //特征值发送次数 4 byte
    memset(buf, 0, 32);

    dataNodeInfo.WaveTime = BUILD_UINT32(pRecvData->Data[31], pRecvData->Data[32], pRecvData->Data[33], pRecvData->Data[34]); //原始波形发送次数 4 byte

    memset(buf, 0, 32);
    dataNodeInfo.BateryV = BUILD_UINT16(pRecvData->Data[35], pRecvData->Data[36]); //电池电压 2 byte

    memset(buf, 0, 32);
    sprintf(buf, "%02x", pRecvData->Data[37]);
    dataNodeInfo.ProductNo = std::string(buf); //产品型号 1 byte

    // 获取 RSSI
    chTemp = pRecvData->Data[38];
    memset(buf, 0, 32);
    sprintf(buf, "%d", chTemp);
    dataNodeInfo.RSSI = atoi(buf); //无线信号强度 1 byte

    chTemp = pRecvData->Data[39];
    memset(buf, 0, 32);
    sprintf(buf, "%02x", chTemp);
    dataNodeInfo.ConfigFlag = ((0 == std::string(buf).compare("aa")) ? 1 : 0); //配置标志 1 byte

    chTemp = pRecvData->Data[40];
    memset(buf, 0, 32);
    sprintf(buf, "%d", chTemp);
    dataNodeInfo.FeatureInterVal = atoi(buf); //唤醒周期 1 byte
    memset(buf, 0, 32);
    // yxq
    sprintf(buf, "%u%u", pRecvData->Data[41], pRecvData->Data[42]);
    dataNodeInfo.WaveInterVal = atoi(buf); //原始波形发送周期 2 byte
    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x", pRecvData->Data[43], pRecvData->Data[44]); // Zigbee PID 2 byte
    dataNodeInfo.ZigbeePanId = std::string(buf);

    chTemp = pRecvData->Data[45];
    memset(buf, 0, 32);
    sprintf(buf, "%d", chTemp);
    dataNodeInfo.ZigbeeChannel = atoi(buf); // Zigbee 信道 1 byte

    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x", pRecvData->Data[46], pRecvData->Data[47]); // Zigbee 本地地址 2 byte

    dataNodeInfo.ZigbeeShortAddr = std::string(buf);
    unsigned char shortAddr[2] = {0x00};
    memcpy(shortAddr, (unsigned char *)&pRecvData->Data[46], 2);
    modify_DistAddr(shortAddr); //修改目标地址
    std::string strTime = GetLocalTimeWithMs();

    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x", pRecvData->Data[48], pRecvData->Data[49]); // Zigbee 目标地址 2 byte
    dataNodeInfo.ZigbeeDesAddr = std::string(buf);
    // 50 51 52=》序号23 zigbee重试间隔

    memset(buf, 0, 32);
    sprintf(buf, "%02x", pRecvData->Data[50]); // Zigbee 发射功率 1 byte
    dataNodeInfo.ZigbeePower = atoi(buf);

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT16(00, pRecvData->Data[51])); // Zigbee   重试次数 1 byte
    dataNodeInfo.ZigbeeRetry = atoi(buf);

    memset(buf, 0, 32);
    sprintf(buf, "%d", BUILD_UINT16(00, pRecvData->Data[52])); // Zigbee 重试间隔 1 byte
    dataNodeInfo.ZigbeeRetryGap = atoi(buf);

    if (dataNodeInfo.ProductNo == "01") {
        chTemp = pRecvData->Data[53];
        unsigned char range = (chTemp >> 2) & 0x3;
        dataNodeInfo.Range = range;
        int SamplingRate = (chTemp & 0x3);
        if (SamplingRate == 0) {
            dataNodeInfo.SamplingRate = 3200;
        } else if (SamplingRate == 1) {
            dataNodeInfo.SamplingRate = 6400;
        } else if (SamplingRate == 2) {
            dataNodeInfo.SamplingRate = 12800;
        } else if (SamplingRate == 3) {
            dataNodeInfo.SamplingRate = 25600;
        }
    } else if (dataNodeInfo.ProductNo == "02") {
        chTemp = pRecvData->Data[53];
        unsigned char range = (chTemp >> 3) & 0x7;
        dataNodeInfo.Range = range;
        int SamplingRate = (chTemp & 0x7);
        if (SamplingRate == 0) {
            dataNodeInfo.SamplingRate = 8000;
        } else if (SamplingRate == 1) {
            dataNodeInfo.SamplingRate = 16000;
        } else if (SamplingRate == 2) {
            dataNodeInfo.SamplingRate = 24000;
        } else if (SamplingRate == 3) {
            dataNodeInfo.SamplingRate = 32000;
        } else if (SamplingRate == 4) {
            dataNodeInfo.SamplingRate = 48000;
        } else if (SamplingRate == 5) {
            dataNodeInfo.SamplingRate = 96000;
        } else if (SamplingRate == 6) {
            dataNodeInfo.SamplingRate = 192000;
        }
    }
    // 54=》序号25 ACC采样时间
    memset(buf, 0, 32);
    sprintf(buf, "%u", pRecvData->Data[54]); // ACC 采样时间 1 byte
    dataNodeInfo.ACCSampleTime = atoi(buf);

    int iTemp = 0;
    //使用了55 56 59 60 63 64 67 68 71 72
    for (int i = 0; i < 5; i++) {
        memset(buf, 0, 32);
        sprintf(buf, "%02x%02x", pRecvData->Data[55 + i * 4], pRecvData->Data[55 + i * 4 + 1]);
        iTemp = (int)strtol(buf, NULL, 16);
        if (0 == i) {
            dataNodeInfo.StartBrands = std::to_string(iTemp);
        } else {
            dataNodeInfo.StartBrands += ("," + std::to_string(iTemp));
        }
    }
    //使用了57 58    61 62 65 66  69 70  73 74
    for (int j = 0; j < 5; j++) {
        memset(buf, 0, 32);
        sprintf(buf, "%02x%02x", pRecvData->Data[57 + j * 4], pRecvData->Data[57 + j * 4 + 1]);
        iTemp = (int)strtol(buf, NULL, 16);
        if (0 == j) {
            dataNodeInfo.StopBrands = std::to_string(iTemp);
        } else {
            dataNodeInfo.StopBrands += ("," + std::to_string(iTemp));
        }
    }

    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x", pRecvData->Data[75], pRecvData->Data[76]);
    iTemp = (int)strtol(buf, NULL, 16);
    dataNodeInfo.EnvelopeBandPass = std::to_string(iTemp);

    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x", pRecvData->Data[77], pRecvData->Data[78]);
    iTemp = (int)strtol(buf, NULL, 16);
    dataNodeInfo.EnvelopeBandPass += ("," + std::to_string(iTemp));
    //使用了79 80 81 82 83 84 85 86
    for (int j = 0; j < 4; j++) {
        memset(buf, 0, 32);
        sprintf(buf, "%02x%02x", pRecvData->Data[79 + j * 2], pRecvData->Data[79 + j * 2 + 1]);
        iTemp = (int)strtol(buf, NULL, 16);

        if (0 == j) {
            dataNodeInfo.FaultFrequency = std::to_string(iTemp);
        } else {
            dataNodeInfo.FaultFrequency += ("," + std::to_string(iTemp));
        }
    }

    memset(buf, 0, 32);
    sprintf(buf, "%02x%02x%02x%02x", pRecvData->Data[87], pRecvData->Data[88], pRecvData->Data[89], pRecvData->Data[90]);
    long lTimeStamp = strtol(buf, NULL, 16);
    dataNodeInfo.ConfigDate = std::to_string(lTimeStamp);

    chTemp = pRecvData->Data[91];
    memset(buf, 0, 32);
    sprintf(buf, "%d", chTemp);
    dataNodeInfo.VIntegralFilterFrequency = atoi(buf);

    char whereCon[64] = {0};
    sprintf(whereCon, "dataNodeNo='%s'", dataNodeInfo.ZigbeeLongAddr.c_str());
    if (sqlite_db_ctrl::instance().GetTableRows(T_SENSOR_INFO(TNAME), whereCon) > 0) {
        char updateSql[1024] = {0};
        sprintf(updateSql, "  initFlag = '%d',accFlag = '%d',zigbeeFlag = '%d',temTopFlag = '%d',temBotFlag = '%d',equipSta = '%d',\
				hardVersion = '%s',softVersion = '%s',bpNo = '%s',serialNo = '%s',firstPowerTime = '%s',WakeupTime = '%d',\
				StaticTime = '%d',WaveTime = '%d',BateryV = '%d',ProductNo = '%s',configFlag = '%d',startBrands = '%s',\
				stopBrands = '%s',featureInterVal = '%u',waveInterVal = '%d',samplingRate = '%d',scope = '%s',range = '%d',envelopeBandPass = '%s',faultFrequency = '%s',\
				zigbeePanId = '%s',zigbeeChannel = '%d',zigbeeShortAddr = '%s',zigbeeLongAddr = '%s',zigbeeDesAddr = '%s',\
				ZigbeePower = '%d',ZigbeeRetry = '%d',ZigbeeRetryGap = '%d',ACCSampleTime = '%d',status = '%s',timeStamp = '%s',viff = '%d',RSSI = '0,%d',UpdateFlag = 1",
                dataNodeInfo.InitFlag, dataNodeInfo.AccFlag, dataNodeInfo.ZigbeeFlag, dataNodeInfo.TemTopFlag, dataNodeInfo.TemBotFlag, dataNodeInfo.EquipSta, dataNodeInfo.HardVersion.c_str(), dataNodeInfo.SoftVersion.c_str(), dataNodeInfo.BpNo.c_str(),
                dataNodeInfo.SerialNo.c_str(), dataNodeInfo.FirstPowerTime.c_str(), dataNodeInfo.WakeupTime, dataNodeInfo.StaticTime, dataNodeInfo.WaveTime, dataNodeInfo.BateryV, dataNodeInfo.ProductNo.c_str(), dataNodeInfo.ConfigFlag, dataNodeInfo.StartBrands.c_str(),
                dataNodeInfo.StopBrands.c_str(), dataNodeInfo.FeatureInterVal, dataNodeInfo.WaveInterVal, dataNodeInfo.SamplingRate, "", dataNodeInfo.Range, dataNodeInfo.EnvelopeBandPass.c_str(), dataNodeInfo.FaultFrequency.c_str(), dataNodeInfo.ZigbeePanId.c_str(),
                dataNodeInfo.ZigbeeChannel, dataNodeInfo.ZigbeeShortAddr.c_str(), dataNodeInfo.ZigbeeLongAddr.c_str(), dataNodeInfo.ZigbeeDesAddr.c_str(), dataNodeInfo.ZigbeePower, dataNodeInfo.ZigbeeRetry, dataNodeInfo.ZigbeeRetryGap, dataNodeInfo.ACCSampleTime, "1",
                dataNodeInfo.ConfigDate.c_str(), dataNodeInfo.VIntegralFilterFrequency, dataNodeInfo.RSSI);
        sprintf(whereCon, "dataNodeNo = '%s'", dataNodeInfo.ZigbeeLongAddr.c_str());
        res = sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql, whereCon);
        if(res !=0 ){
            zlog_error(zct, "res = %d", res);
        }
    } else {
        char insertSql[1024] = {0};
        sprintf(insertSql, " '%s','%s','%d','%d','%d','%d','%d','%d',\
				'%s','%s','%s','%s','%s','%d',\
				'%d','%d','%d','%s','%d','%s',\
				'%s','%u','%d','%d','%s','%d', '%s', '%s',\
				'%s','%d','%s','%s','%s',\
				'%d','%d','%d','%d','%s','%s', '%d', '0,%d','1','0,0','','','',0",
                dataNodeInfo.ZigbeeLongAddr.c_str(), " ", dataNodeInfo.InitFlag, dataNodeInfo.AccFlag, dataNodeInfo.ZigbeeFlag, dataNodeInfo.TemTopFlag, dataNodeInfo.TemBotFlag, dataNodeInfo.EquipSta, dataNodeInfo.HardVersion.c_str(), dataNodeInfo.SoftVersion.c_str(),
                dataNodeInfo.BpNo.c_str(), dataNodeInfo.SerialNo.c_str(), dataNodeInfo.FirstPowerTime.c_str(), dataNodeInfo.WakeupTime, dataNodeInfo.StaticTime, dataNodeInfo.WaveTime, dataNodeInfo.BateryV, dataNodeInfo.ProductNo.c_str(), dataNodeInfo.ConfigFlag,
                dataNodeInfo.StartBrands.c_str(), dataNodeInfo.StopBrands.c_str(), dataNodeInfo.FeatureInterVal, dataNodeInfo.WaveInterVal, dataNodeInfo.SamplingRate, "", dataNodeInfo.Range, dataNodeInfo.EnvelopeBandPass.c_str(), dataNodeInfo.FaultFrequency.c_str(),
                dataNodeInfo.ZigbeePanId.c_str(), dataNodeInfo.ZigbeeChannel, dataNodeInfo.ZigbeeShortAddr.c_str(), dataNodeInfo.ZigbeeLongAddr.c_str(), dataNodeInfo.ZigbeeDesAddr.c_str(), dataNodeInfo.ZigbeePower, dataNodeInfo.ZigbeeRetry, dataNodeInfo.ZigbeeRetryGap,
                dataNodeInfo.ACCSampleTime, "1", dataNodeInfo.ConfigDate.c_str(), dataNodeInfo.VIntegralFilterFrequency, dataNodeInfo.RSSI);
        res = sqlite_db_ctrl::instance().InsertData(T_SENSOR_INFO(TNAME), insertSql);
        if(res !=0 ){
            zlog_error(zct, "res = %d", res);
        }
    }
    char szTableName[50] = {0x00};
    sprintf(szTableName, "t_data_%s", dataNodeInfo.ZigbeeLongAddr.c_str());
    sqlite_db_ctrl::instance().Createtable(szTableName);
    memset(szTableName, 0x00, sizeof(szTableName));
    sprintf(szTableName, "t_dataStatic_%s", dataNodeInfo.ZigbeeLongAddr.c_str());
    sqlite_db_ctrl::instance().CreatedataStatictable(szTableName);
    Json::Value jsonVal;
    jsonVal.clear();
    jsonVal["cmd"] = "26";

    Json::Value jsBody;
    jsBody["dataNodeGatewayNo"] = GlobalConfig::MacAddr_G;
    jsBody["dataNodeNo"] = dataNodeInfo.ZigbeeLongAddr;
    jsBody["type"] = "insert";

    Json::Value jsSensorData;
    jsSensorData["dataNodeNo"] = dataNodeInfo.ZigbeeLongAddr;
    jsSensorData["dataNodeName"] = "";
    jsSensorData["initFlag"] = dataNodeInfo.InitFlag;
    jsSensorData["accFlag"] = dataNodeInfo.AccFlag;
    jsSensorData["zigbeeFlag"] = dataNodeInfo.ZigbeeFlag;
    jsSensorData["temTopFlag"] = dataNodeInfo.TemTopFlag;
    jsSensorData["temBotFlag"] = dataNodeInfo.TemBotFlag;
    jsSensorData["equipsta"] = dataNodeInfo.EquipSta;
    jsSensorData["hardVersion"] = dataNodeInfo.HardVersion;
    jsSensorData["softVersion"] = dataNodeInfo.SoftVersion;
    jsSensorData["bpNo"] = dataNodeInfo.BpNo;
    jsSensorData["serialNo"] = dataNodeInfo.SerialNo;
    jsSensorData["firstPowerTime"] = dataNodeInfo.FirstPowerTime;
    jsSensorData["configFlag"] = dataNodeInfo.ConfigFlag;
    jsSensorData["startBrands"] = dataNodeInfo.StartBrands;
    jsSensorData["stopBrands"] = dataNodeInfo.StopBrands;
    jsSensorData["featureInterVal"] = dataNodeInfo.FeatureInterVal;
    jsSensorData["waveInterVal"] = dataNodeInfo.WaveInterVal;
    jsSensorData["samplingRate"] = dataNodeInfo.SamplingRate;
    jsSensorData["range"] = dataNodeInfo.Range;
    jsSensorData["envelopeBandPass"] = dataNodeInfo.EnvelopeBandPass;
    jsSensorData["faultFrequency"] = dataNodeInfo.FaultFrequency;
    jsSensorData["zigbeePanId"] = dataNodeInfo.ZigbeePanId;
    jsSensorData["zigbeeChannel"] = dataNodeInfo.ZigbeeChannel;
    jsSensorData["zigbeeAddr"] = dataNodeInfo.ZigbeeLongAddr;
    jsSensorData["zigbeeDesAddr"] = dataNodeInfo.ZigbeeDesAddr;
    jsSensorData["status"] = 1;
    jsSensorData["timeStamp"] = dataNodeInfo.ConfigDate;
    jsSensorData["VIntegralFilterFrequency"] = dataNodeInfo.VIntegralFilterFrequency;
    jsSensorData["RSSI"] = dataNodeInfo.RSSI;

    jsBody["dataNodeInfo"] = jsSensorData;

    Json::FastWriter showValue;
    std::string dataBody = showValue.write(jsBody);
    jsonVal["cmdBody"] = dataBody;
    std::string strCmd26 = showValue.write(jsonVal);
    // 传感器发来的数据包中的表示设备信息的数据转化为json格式后，通过调用data_publish将数据传给mqttclient  ： Topic：wireless/cmd/60294D203717
    res = data_publish(strCmd26.c_str(), GlobalConfig::Topic_G.mPubCmd.c_str());
    if(res !=0 ){
        zlog_error(zct, "res = %d", res);
    }
    zlog_info(zct, "remote wireless sensor device info AccFlag : %d EquipSta : %d BpNo : %s ConfigFlag : %d EnvelopeBandPass : %s FaultFrequency : %s FeatureInterVal : %u FirstPowerTime : %s HardVersion : %s InitFlag : %d SamplingRate : %d range : %d SerialNo : %s\
    SoftVersion : %s StartBrands : %s StopBrands : %s TemBotFlag : %d TemTopFlag : %d WaveInterVal : %d ZigbeeChannel : %d ZigbeeDesAddr : %s ZigbeeFlag : %d ZigbeeLongAddr : %s panid : %s ZigbeeShortAddr : %s Configdate : %s vintegralfilterfrequency : %d RSSI : %d ",
              dataNodeInfo.AccFlag, dataNodeInfo.EquipSta, dataNodeInfo.BpNo.c_str(), dataNodeInfo.ConfigFlag, dataNodeInfo.EnvelopeBandPass.c_str(), dataNodeInfo.FaultFrequency.c_str(), dataNodeInfo.FeatureInterVal, dataNodeInfo.FirstPowerTime.c_str(),
              dataNodeInfo.HardVersion.c_str(), dataNodeInfo.InitFlag, dataNodeInfo.SamplingRate, dataNodeInfo.Range, dataNodeInfo.SerialNo.c_str(), dataNodeInfo.SoftVersion.c_str(), dataNodeInfo.StartBrands.c_str(), dataNodeInfo.StopBrands.c_str(), dataNodeInfo.TemBotFlag,
              dataNodeInfo.TemTopFlag, dataNodeInfo.WaveInterVal, dataNodeInfo.ZigbeeChannel, dataNodeInfo.ZigbeeDesAddr.c_str(), dataNodeInfo.ZigbeeFlag, dataNodeInfo.ZigbeeLongAddr.c_str(), dataNodeInfo.ZigbeePanId.c_str(), dataNodeInfo.ZigbeeShortAddr.c_str(),
              dataNodeInfo.ConfigDate.c_str(), dataNodeInfo.VIntegralFilterFrequency, dataNodeInfo.RSSI);

    if (g_mapCompress.find(dataNodeInfo.ZigbeeShortAddr) == g_mapCompress.end()) {
        compressWaveChannel tempchannel;
        g_mapCompress.insert(std::make_pair(dataNodeInfo.ZigbeeShortAddr, tempchannel));
        zlog_info(zct, "new Node,size = %d", g_mapCompress.size());
    }
    zlog_info(zct, "DealDataNodeInfo %s ", dataNodeInfo.ZigbeeShortAddr.c_str());
}

void Uart::ZigbeeParameterConfig() {
    std::string strPanId = sqlite_db_ctrl::instance().GetData("t_gateway_info", "zigbeePanID", NULL);
    {
        unsigned short shortAddr = 0x8888;
        WriteShortAddr2Zigbee(shortAddr);
        mssleep(100000);
    }

    zlog_info(zct, "strPanId : %s", strPanId.c_str());
    zlog_info(zct, "MacAddr_G : %s", GlobalConfig::MacAddr_G.c_str());
    std::string strchan = ReadStrByOpt(ZIGBEECONFIG, "Zigbee", "channel");

    unsigned short Chan = (unsigned short)strtol(strchan.c_str(), NULL, 10);
    zlog_info(zct, "the chan = %d", Chan);
    zlog_info(zct, "ZigbeeInfo_G.Channel=%d", GlobalConfig::ZigbeeInfo_G.Channel);
    if (Chan > 10 && Chan < 27) {
        WriteChanl2Zigbee(Chan);
        mssleep(100000);
    }
    zlog_info(zct, "PanID1 = %s,strPanId = %s", GlobalConfig::ZigbeeInfo_G.PanID.c_str(), strPanId.c_str());

    long lShortAddr = strtol(strPanId.c_str(), NULL, 16);
    unsigned short panid = lShortAddr & 0xffff;

    WritePanId2Zigbee(panid);
    mssleep(100000);

    zlog_info(zct, "ZigbeeInfo_G.MyAddr=%s", GlobalConfig::ZigbeeInfo_G.MyAddr.c_str());
}

int Uart::FindRecvPackage(int bytesRead, char *mUartRecvBuf, char *head) {
    char localtimestamp[32] = {0};
    GetTimeNet(localtimestamp, 1);
    char head1[] = {0xAB, 0xBC, 0xCD};
    char head2[] = {0xDE, 0xDF, 0xEF};
    int lastSize = 0;
    char UartRecvBuf[BUF_LENGTH * 15] = {0x00};
    char RecvBuf[200] = {0x00};
    if (mlastSize > 0) {
        zlog_info(zct, "mlastSize = %d", mlastSize);
        memcpy(UartRecvBuf, mUartRecvTmpBuf, mlastSize);
        for (int i = 0; i < mlastSize; i++) {
            zlog_info(zct, "%02x ", UartRecvBuf[i]);
        }
        memset(mUartRecvTmpBuf, 0x00, sizeof(mUartRecvTmpBuf));
    }
    memcpy(UartRecvBuf + mlastSize, mUartRecvBuf, bytesRead);

    bytesRead = bytesRead + mlastSize;
    for (int i = 0; i < bytesRead; i++) {
        if (UartRecvBuf[i] == head[0]) {
            char buf[12] = {0x00};
            char ShortAddr[8] = {0x00};
            sprintf(buf, "%02X%02X%02X", UartRecvBuf[i] & 0xFF,UartRecvBuf[i + 1] & 0xFF,UartRecvBuf[i + 2] & 0xFF);
            sprintf(ShortAddr, "%02x%02x", UartRecvBuf[i + 3] & 0xFF, UartRecvBuf[i + 4] & 0xFF);
            std::string strShortAddr(ShortAddr);
            std::string strHeadFlag(buf);
            if (0 == strHeadFlag.compare("AA55AA")) {
                char buf[8] = {0x00};
                sprintf(buf, "%02d", UartRecvBuf[i + 5]);
                int command = atoi(buf);
                //zlog_info(zct, "command = %d ShortAddr :%s", command, strShortAddr.c_str());
                if ((mPackgeIndex == -1 || (unsigned int)UartRecvBuf[i + 6] == 0) ) {
                    mPackgeIndex = UartRecvBuf[i + 6] & 0xFF;
                } else if ((unsigned int)mPackgeIndex == (unsigned int)UartRecvBuf[i + 6] && mPackgeIndex != -1  && command != 2) {
                    zlog_warn(zct, "mPackgeIndex same index1:%d,index2:%02d ShortAddr :%s ", mPackgeIndex, UartRecvBuf[i + 6] & 0xff, strShortAddr.c_str());
                    continue;

                } else if ((unsigned int)mPackgeIndex + 1 != (unsigned int)UartRecvBuf[i + 6] && mPackgeIndex != -1 && command != 2) {
                    m_TimeStamp = 0;

                    zlog_warn(zct, "mPackgeIndex error index1:%d,index2:%02d ShortAddr :%s ", mPackgeIndex, UartRecvBuf[i + 6] & 0xff, strShortAddr.c_str());
                    mPackgeIndex = -1;
                    zlog_warn(zct, "mPackgeIndex error  ShortAddr :%s", strShortAddr.c_str());

                    char tmp[10] = {0x00};
                    char tmp2[10] = {0x00};
                    for (int j = 0; j < 100; j++) {
                        sprintf(tmp, "%02x ", UartRecvBuf[i + j] & 0xff);
                        strcat(tmp2, tmp);
                    }
                    zlog_warn(zct, "error str = %s", tmp2);

                    char insertSql[100] = {0x00};
                    char whereCon[50] = {0x00};
                    char error_msg[50] = {0x00};
                    sprintf(whereCon, "zigbeeShortAddr='%s'",strShortAddr.c_str());
                    std::string strDataNodeNo = sqlite_db_ctrl::instance().GetData(T_SENSOR_INFO(TNAME), " dataNodeNo ", whereCon);
                    memset(whereCon, 0x00, sizeof(whereCon));
                    if (command == WAVE_X){
                        sprintf(error_msg,"Index error,wave X");
                    }else if (command == WAVE_Y){
                        sprintf(error_msg,"Index error,wave Y");
                    }else if (command == WAVE_Z){
                        sprintf(error_msg,"Index error,wave Z");
                    }

                    sprintf(insertSql, "'%s','%s','%s',%d,'%d','%s' ", strDataNodeNo.c_str(),strShortAddr.c_str(),localtimestamp,bytesRead,0,error_msg);
                    sqlite_db_ctrl::instance().InsertData(" receive_wave_status ", insertSql);

                    break;
                }

                if (now_task == WAVE_CMD && (command == WAVE_X || command == WAVE_Y || command == WAVE_Z)) {
                    if (!CheckCrc(&UartRecvBuf[i], 99)) {
                        m_TimeStamp = 0;
                        mPackgeIndex = -1;
                        zlog_warn(zct, "CheckCrc error  ShortAddr :%s command = %d", strShortAddr.c_str(), command);
                        char tmp[10] = {0x00};
                        char tmp2[10] = {0x00};
                        for (int j = 0; j < 100; j++) {
                            sprintf(tmp, "%02x ", UartRecvBuf[i + j] & 0xff);
                            strcat(tmp2, tmp);
                        }
                        zlog_error(zct, "error str = %s", tmp2);
                        m_waveCountX = 0;
                        m_waveCountY = 0;
                        m_waveCountZ = 0;
                        g_VecWaveDataX.clear();
                        g_VecWaveDataY.clear();
                        g_VecWaveDataZ.clear();
                        char insertSql[100] = {0x00};
                        char whereCon[50] = {0x00};
                        char error_msg[50] = {0x00};
                        sprintf(whereCon, "zigbeeShortAddr='%s'",strShortAddr.c_str());
                        std::string strDataNodeNo = sqlite_db_ctrl::instance().GetData(T_SENSOR_INFO(TNAME), " dataNodeNo ", whereCon);
                        memset(whereCon, 0x00, sizeof(whereCon));
                        if (command == WAVE_X){
                            sprintf(error_msg,"Crc error,wave X");
                        }else if (command == WAVE_Y){
                            sprintf(error_msg,"Crc error,wave Y");
                        }else if (command == WAVE_Z){
                            sprintf(error_msg,"Crc error,wave Z");
                        }
                        sprintf(insertSql, "'%s','%s','%s',%d,'%d','%s' ", strDataNodeNo.c_str(),strShortAddr.c_str(),localtimestamp,bytesRead,0,error_msg);
                        sqlite_db_ctrl::instance().InsertData(" receive_wave_status ", insertSql);

                        break;
                    }
                    mlastSize = 0;
                    lastSize = bytesRead - i;

                    if (lastSize < 100 && lastSize > 0) {
                        memcpy(mUartRecvTmpBuf, (char *)&UartRecvBuf[bytesRead - lastSize], lastSize);
                        mlastSize = lastSize;
                        break;
                    }
                    memcpy(RecvBuf, (char *)&UartRecvBuf[i], 100);
                    DealDataNodeWave(RecvBuf, command);
                } else if (now_task != WAVE_CMD && (command == ASK_TASK || command == DEVICE_INF || command == MEAS_EVAL || command == CONFIG || command == UPGRADE || command == DEVICE_INF2 || command == SIGNAL_STRENGTH || command == DEVICE_EXCEPTION || command == WAVE_COMPRESS)) {
                    char RecvBuf[100] = {0x00};
                    if (command == ASK_TASK )
                    {
                       memcpy(RecvBuf, &UartRecvBuf[i], 8);
                        if (!CheckCrc(RecvBuf, 7)) {
                            zlog_warn(zct, "CheckCrc error  ShortAddr :%s command = %d ", strShortAddr.c_str(), command);
                            break;
                        }
                    }
                    if (command == CONFIG || command == CONFIG_INF2 || command == UPGRADE || command == SIGNAL_STRENGTH || command == DEVICE_EXCEPTION || command == WAVE_COMPRESS)
                    {
                        memcpy(RecvBuf, &UartRecvBuf[i], 9);
                        if (!CheckCrc(RecvBuf, 8)) {
                            zlog_warn(zct, "CheckCrc error  ShortAddr :%s command = %d ", strShortAddr.c_str(), command);
                            break;
                        }
                    }
                    if (command == DEVICE_INF || command == MEAS_EVAL || command == DEVICE_INF2)
                    {
                        memcpy(RecvBuf, &UartRecvBuf[i], 100);
                        if (!CheckCrc(RecvBuf, 99)) {
                            zlog_warn(zct, "CheckCrc error  ShortAddr :%s command = %d ", strShortAddr.c_str(), command);
                            break;
                        }
                    }
                    DealRecvData(RecvBuf);

                }else if(now_task == WAVE_CMD && command == WAVE_COMPRESS){
                    memcpy(RecvBuf, &UartRecvBuf[i], 23);
                    if (!CheckCrc(RecvBuf, 22)) {
                        zlog_warn(zct, "CheckCrc error  ShortAddr :%s command = %d ", strShortAddr.c_str(), command);
                        break;
                    }
                    char tmp[23] = {0x00};
                    char tmp2[23] = {0x00};
                    for (int j = 0; j < 23; j++) {
                        sprintf(tmp, "%02x ", UartRecvBuf[i + j] & 0xff);
                        strcat(tmp2, tmp);
                    }
                    zlog_info(zct, "str = %s", tmp2);
                    DealRecvData(RecvBuf);
                }  else if (command == 35) {
                    char signalNode[10] = {0x00};
                    sprintf(signalNode, "%02d", UartRecvBuf[i + 14] & 0xFF);
                    if (!strcmp(signalNode, "00") || !strcmp(signalNode, "0")) {
                        char errorInfo[100] = {0x00};
                        sprintf(errorInfo, "No RSSI %s", signalNode);
                        zlog_warn(zct, errorInfo);
                    } else {
                        char whereCon[1024] = {0};
                        char updateSql[1024] = {0};
                        char tableName[100] = {0x00};
                        sprintf(whereCon, "zigbeeShortAddr='%s'", strShortAddr.c_str());
                        vec_t vecDataNodeNo = sqlite_db_ctrl::instance().GetDataSingleLine(T_SENSOR_INFO(TNAME), " dataNodeNo,RSSI ", whereCon);
                        memset(whereCon, 0x00, sizeof(whereCon));
                        sprintf(updateSql, "zigbeeSignalNode = '%02d' ", UartRecvBuf[i + 14] & 0xFF); // zigbeeRSSIType = 0 传感器获取网关信号强度
                        sprintf(whereCon, "dataNodeNo='%s' and timeStamp = '%s'", (char *)vecDataNodeNo[0].c_str(), strTimetamp.c_str());
                        sprintf(tableName, "t_dataStatic_%s", (char *)vecDataNodeNo[0].c_str());
                        sqlite_db_ctrl::instance().UpdateTableData(tableName, updateSql, whereCon);

                        std::vector<std::string> vParamRSSI;
                        boost::split(vParamRSSI, vecDataNodeNo[1], boost::is_any_of(","), boost::token_compress_on);
                        if (vParamRSSI.size() > 0) {
                            sprintf(updateSql, "RSSI = '%s,%02d' ", vParamRSSI[0].c_str(), UartRecvBuf[i + 14] & 0xFF);
                            sprintf(whereCon, "dataNodeNo='%s'", (char *)vecDataNodeNo[0].c_str());
                            sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql, whereCon);
                        }
                    }
                }
                mPackgeIndex = (unsigned int)UartRecvBuf[i + 6];

            } else {
                continue;
            }
        } else if (UartRecvBuf[i] == head1[0]) {
            char buf[12] = {0x00};
            sprintf(buf, "%02X%02X%02X", UartRecvBuf[i] & 0xFF,UartRecvBuf[i + 1] & 0xFF,UartRecvBuf[i + 2] & 0xFF);
            std::string strHeadFlag(buf);
            if (0 == strHeadFlag.compare("ABBCCD")) {
                char buf[8] = {0x00};
                sprintf(buf, "%02d", UartRecvBuf[i + 3] & 0xFF);
                int command = atoi(buf);
                zlog_info(zct, "command = %d", command);
                if (command == 209) {
                    UpdateZigbeeInfo(&UartRecvBuf[i]);
                } else if (command == 220) { // DC
                    zlog_info(zct, "zigbeeShortAddr = %s , ret = %02d", m_strDestShortAddr.c_str(), UartRecvBuf[i + 6] & 0xFF);
                    if ((UartRecvBuf[i + 6] & 0xFF) != 0) {
                        modify_LocalAddr(0x8888);
                    }
                }
            }
        } else if (UartRecvBuf[i] == head2[0]) {
            char buf[12] = {0x00};
            sprintf(buf, "%02X%02X%02X", UartRecvBuf[i] & 0xFF,UartRecvBuf[i + 1] & 0xFF,UartRecvBuf[i + 2] & 0xFF);
            std::string strHeadFlag(buf);
            if (0 == strHeadFlag.compare("DEDFEF")) {
                char buf[8] = {0x00};
                sprintf(buf, "%02d", UartRecvBuf[i + 3] & 0xFF);
                int command = atoi(buf);
                zlog_info(zct, "command = %d", command);
                if (command == 209) { // D1
                    pTestRecv(command);
                } else if (command == 219) { // DB
                    pTestRecv(command);
                } else if (command == 220) { // DC
                    zlog_info(zct, "%02x,%02x,%02x,%02x,%02x ", UartRecvBuf[i], UartRecvBuf[i + 1], UartRecvBuf[i + 2], UartRecvBuf[i + 3], UartRecvBuf[i + 4]);
                    zlog_info(zct, "zigbeeShortAddr = %s , ret = %02d", m_strDestShortAddr.c_str(), UartRecvBuf[i + 4] & 0xFF);

                } else if (command == 218) { // DA 网关获取传感器信号强度
                    char localtimestamp[32] = {0};
                    GetTimeNet(localtimestamp, 1);
                    char whereCon[1024] = {0};
                    char updateSql[1024] = {0};
                    char tableName[100] = {0x00};
                    bZigbeeSinal = false;
                    sprintf(whereCon, "zigbeeShortAddr='%02x%02x'", UINT16_HIGH(wave_shortAddr),UINT16_LOW(wave_shortAddr));
                    vec_t vecDataNodeNo = sqlite_db_ctrl::instance().GetDataSingleLine(T_SENSOR_INFO(TNAME), " MeasurementID,LooseValue,RSSI ", whereCon);
                    memset(whereCon, 0x00, sizeof(whereCon));
                    sprintf(tableName,"t_dataStatic_%s",(char*)vecDataNodeNo[0].c_str());
                    memset(whereCon,0,sizeof(whereCon));
                    sprintf(whereCon, "dataNodeNo='%s' order by timeStamp desc limit 1", vecDataNodeNo[0].c_str());
                    std::string timestamp_last = sqlite_db_ctrl::instance().GetData(tableName, " timeStamp ", whereCon);
                    sprintf(updateSql, "zigbeeSignal = '%02d' ",UartRecvBuf[i+6]&0xFF);
					sprintf(whereCon, "dataNodeNo='%s' and timeStamp = '%s'", (char*)vecDataNodeNo[0].c_str(),timestamp_last.c_str());
					
					sqlite_db_ctrl::instance().UpdateTableData(tableName, updateSql, whereCon);

                    // zigbeeRSSIType = 1 网关获取传感器信号强度

                    Json::Value jsBody, jsonVal;
                    Json::FastWriter showValue;
                    char looseValue[10] = {0x00};
                    readStringValue("config", (char *)"loose", looseValue, GlobalConfig::Config_G.c_str());
                    if (atof(looseValue) < atof(vecDataNodeNo[1].c_str())) {
                        jsBody["looseStatus"] = "1";
                    } else {
                        jsBody["looseStatus"] = "0";
                    }
                    std::vector<std::string> vParamRSSI;
                    boost::split(vParamRSSI, vecDataNodeNo[2], boost::is_any_of(","), boost::token_compress_on);
                    memset(updateSql,0,sizeof(updateSql));
                    memset(whereCon,0,sizeof(whereCon));
                    if (vParamRSSI.size() == 1) {
                        sprintf(updateSql, "RSSI = '%02d,%s' ", UartRecvBuf[i + 6] & 0xFF, vParamRSSI[0].c_str());

                    } else if (vParamRSSI.size() == 2) {
                        sprintf(updateSql, "RSSI = '%02d,%s' ", UartRecvBuf[i + 6] & 0xFF, vParamRSSI[1].c_str());
                    }
                    sprintf(whereCon, "dataNodeNo='%s'", (char *)vecDataNodeNo[0].c_str());
                    sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), updateSql, whereCon);

                    jsonVal["cmd"] = "52";
                    jsBody["timeStamp"] = strTimetamp;
                    jsBody["dataNodeNo"] = vecDataNodeNo[0];
                    jsBody["zigbeeSignal"] = UartRecvBuf[i + 6] & 0xFF;
                    std::string dataBody = showValue.write(jsBody);
                    jsonVal["cmdBody"] = dataBody;
                    data_publish(showValue.write(jsonVal).c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
                }
            }
        }
    }
    return 0;
}

bool Uart::CheckCrc(char *pCheckBuff, int No) {
    unsigned char tmp = 0x00;
    for (int i = 0; i < No; i++) {
        tmp += (unsigned char)pCheckBuff[i];
    }

    if ((unsigned char)pCheckBuff[No] != (unsigned char)tmp) return false;
    return true;
}