SmartPDCode/Qt/Android/SmartPDU_QT/serialinfo.cpp

#include "serialinfo.h"

SerialInfo::SerialInfo()
{

}

void SerialInfo::on_startWork()
{
    timer = new QTimer(this);
    connect(timer, &QTimer::timeout, this, &SerialInfo::on_Check_PDUStatus);
    timer->start(2000); // Start the timer
}
void SerialInfo::on_closeWork()
{
    if(timer)timer->stop();
     deleteLater();
}


void SerialInfo::on_Check_PDUStatus()
{
    //轮询PDU信息
    char OrderArray[8];


    uint16_t crc=0;

    OrderArray[0]=0x01;
    OrderArray[1]=0x03;

    //查询设备类型及通道数
    OrderArray[2] =  (_SWITCH_T_AC_TYPE_CHN_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] =   _SWITCH_T_AC_TYPE_CHN_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x01;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_TYPE_CHN_INFO);
    QThread::msleep(QUERYSTAMP);


    //查询L1信息
    OrderArray[2] = (_SWITCH_T_AC_IN_L1_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] =  _SWITCH_T_AC_IN_L1_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x08;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_IN_L1_INFO);
    QThread::msleep(QUERYSTAMP);

    //查询L2信息
    OrderArray[2] = (_SWITCH_T_AC_IN_L2_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_IN_L2_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x08;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_IN_L2_INFO);
    QThread::msleep(QUERYSTAMP);

    //查询L3信息
    OrderArray[2] = (_SWITCH_T_AC_IN_L3_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_IN_L3_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x08;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_IN_L3_INFO);
    QThread::msleep(QUERYSTAMP);


    //查询相信息1
    OrderArray[2] = (_SWITCH_T_AC_CH_PHASE_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_CH_PHASE_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x96;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_CH_PHASE_INFO);
    QThread::msleep(QUERYSTAMP);

    //查询相信息2
    OrderArray[2] = ((_SWITCH_T_AC_CH_PHASE_INFO + _SWITCH_CH_DIV)>> 8) & 0xFF; // High byte
    OrderArray[3] = (_SWITCH_T_AC_CH_PHASE_INFO + _SWITCH_CH_DIV) & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x96;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_CH_PHASE_INFO+_SWITCH_CH_DIV);
    QThread::msleep(QUERYSTAMP);

    //查询相信息3
    OrderArray[2] = ((_SWITCH_T_AC_CH_PHASE_INFO + _SWITCH_CH_DIV*2 )>> 8) & 0xFF; // High byte
    OrderArray[3] = (_SWITCH_T_AC_CH_PHASE_INFO + _SWITCH_CH_DIV*2 ) & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x96;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_CH_PHASE_INFO+_SWITCH_CH_DIV*2);
    QThread::msleep(QUERYSTAMP);

    //查询通道状态
    OrderArray[2] = (_SWITCH_T_AC_CH_STATUS >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_CH_STATUS & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x0E;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_CH_STATUS);
    QThread::msleep(QUERYSTAMP);

    //查询modbus传感器
    OrderArray[2] = (_SWITCH_T_AC_SENSOR_INFO >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_SENSOR_INFO & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x10;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_SENSOR_INFO);
    QThread::msleep(QUERYSTAMP);

    //查询干节点传感器
    OrderArray[2] =(_SWITCH_T_AC_SENSOR_INFO1 >> 8) & 0xFF; // High byte
    OrderArray[3] = _SWITCH_T_AC_SENSOR_INFO1 & 0xFF; // Low byte
    OrderArray[4]=0x00;
    OrderArray[5]=0x04;
    crc = crc16_ccitt(OrderArray, 6);
    OrderArray[6] = crc & 0xFF; // Low byte
    OrderArray[7] = (crc >> 8) & 0xFF; // High byte
    SendString=on_SendInfo(OrderArray,8);
    RecString=on_Rec_PDUStatus();
    on_Parse_PDUStatus(SendString,RecString,_SWITCH_T_AC_SENSOR_INFO1);
    QThread::msleep(QUERYSTAMP);


}
void SerialInfo::on_Parse_PDUStatus(const QString &Sendstr,const QString &Recstr,uint16_t infoType)
{
    if(Recstr=="") return;

    if(_SWITCH_T_AC_TYPE_CHN_INFO==infoType)
    {
       QVector<quint16> pRecVector=parseModbusResponse(Recstr,1);
       if(pRecVector.size()<1) return;
       m_TotalCHTemp = pRecVector[0] & 0xFF; // Low byte
       m_PDUType = (pRecVector[0] >> 8) & 0xFF; // High byte

    }
    else if(_SWITCH_T_AC_IN_L1_INFO==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,8);
        if(pRecVector.size()<8) return;
        m_PDUAllInfo.AllVoltage_L1 = ((pRecVector[1] << 16) + pRecVector[0] )/1000.0f; // Low byte
        m_PDUAllInfo.AllCurrent_L1 = ((pRecVector[3] << 16) + pRecVector[2] )/1000.0f; // Low byte
        m_PDUAllInfo.AllPower_L1 = ((pRecVector[5] << 16) + pRecVector[4] )/1000.0f; // Low byte
        m_PDUAllInfo.AllConsumption_L1 = ((pRecVector[7] << 16)+ pRecVector[6])/1000.0f; // Low byte
    }
    else if(_SWITCH_T_AC_IN_L2_INFO==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,8);
        if(pRecVector.size()<8) return;
        m_PDUAllInfo.AllVoltage_L2 = ((pRecVector[1] << 16) + pRecVector[0] )/1000.0f; // Low byte
        m_PDUAllInfo.AllCurrent_L2 = ((pRecVector[3] << 16) + pRecVector[2] )/1000.0f; // Low byte
        m_PDUAllInfo.AllPower_L2 = ((pRecVector[5] << 16) + pRecVector[4] )/1000.0f; // Low byte
        m_PDUAllInfo.AllConsumption_L2 = ((pRecVector[7] << 16)+ pRecVector[6])/1000.0f; // Low byte
    }
    else if(_SWITCH_T_AC_IN_L3_INFO==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,8);
        if(pRecVector.size()<8) return;
        m_PDUAllInfo.AllVoltage_L3 = ((pRecVector[1] << 16) + pRecVector[0] )/1000.0f; // Low byte
        m_PDUAllInfo.AllCurrent_L3 = ((pRecVector[3] << 16) + pRecVector[2] )/1000.0f; // Low byte
        m_PDUAllInfo.AllPower_L3 = ((pRecVector[5] << 16) + pRecVector[4] )/1000.0f; // Low byte
        m_PDUAllInfo.AllConsumption_L3 = ((pRecVector[7] << 16)+ pRecVector[6])/1000.0f; // Low byte
    }
    else if(_SWITCH_T_AC_CH_PHASE_INFO==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,150);
        if(pRecVector.size()<150) return;
        for(int i=0;i<5;i++)
        {
             bool L1flag=pRecVector[i*30+9] & 0xFFFF; // Low byte
             bool L2flag=pRecVector[i*30+19] & 0xFFFF; // Low byte
             bool L3flag=pRecVector[i*30+29] & 0xFFFF; // Low byte

             if(L1flag)
             {
                  m_PDUCHInfo[i].CHVoltage=((pRecVector[1] << 16) + pRecVector[0] )/1000.0f;
                  m_PDUCHInfo[i].CHCurrent=((pRecVector[3] << 16) + pRecVector[2] )/1000.0f;
                  m_PDUCHInfo[i].CHPower=((pRecVector[5] << 16) + pRecVector[4] )/1000.0f;
                  m_PDUCHInfo[i].CHConsumption=((pRecVector[7] << 16) + pRecVector[6] )/1000.0f;
             }
             else if(L2flag)
             {
                  m_PDUCHInfo[i].CHVoltage=((pRecVector[11] << 16) + pRecVector[10] )/1000.0f;
                  m_PDUCHInfo[i].CHCurrent=((pRecVector[13] << 16) + pRecVector[12] )/1000.0f;
                  m_PDUCHInfo[i].CHPower=((pRecVector[15] << 16) + pRecVector[14] )/1000.0f;
                  m_PDUCHInfo[i].CHConsumption=((pRecVector[17] << 16) + pRecVector[16] )/1000.0f;
             }
             else if(L3flag)
             {
                  m_PDUCHInfo[i].CHVoltage=((pRecVector[21] << 16) + pRecVector[20] )/1000.0f;
                  m_PDUCHInfo[i].CHCurrent=((pRecVector[23] << 16) + pRecVector[22] )/1000.0f;
                  m_PDUCHInfo[i].CHPower=((pRecVector[25] << 16) + pRecVector[24] )/1000.0f;
                  m_PDUCHInfo[i].CHConsumption=((pRecVector[27] << 16) + pRecVector[26] )/1000.0f;
             }
        }
    }
    else if((_SWITCH_T_AC_CH_PHASE_INFO+_SWITCH_CH_DIV)==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,150);
        if(pRecVector.size()<150) return;
        for(int i=0;i<5;i++)
        {
             bool L1flag=pRecVector[i*30+9] & 0xFFFF; // Low byte
             bool L2flag=pRecVector[i*30+19] & 0xFFFF; // Low byte
             bool L3flag=pRecVector[i*30+29] & 0xFFFF; // Low byte

             if(L1flag)
             {
                  m_PDUCHInfo[i+5].CHVoltage=((pRecVector[1] << 16) + pRecVector[0] )/1000.0f;
                  m_PDUCHInfo[i+5].CHCurrent=((pRecVector[3] << 16) + pRecVector[2] )/1000.0f;
                  m_PDUCHInfo[i+5].CHPower=((pRecVector[5] << 16) + pRecVector[4] )/1000.0f;
                  m_PDUCHInfo[i+5].CHConsumption=((pRecVector[7] << 16) + pRecVector[6] )/1000.0f;
             }
             else if(L2flag)
             {
                  m_PDUCHInfo[i+5].CHVoltage=((pRecVector[11] << 16) + pRecVector[10] )/1000.0f;
                  m_PDUCHInfo[i+5].CHCurrent=((pRecVector[13] << 16) + pRecVector[12] )/1000.0f;
                  m_PDUCHInfo[i+5].CHPower=((pRecVector[15] << 16) + pRecVector[14] )/1000.0f;
                  m_PDUCHInfo[i+5].CHConsumption=((pRecVector[17] << 16) + pRecVector[16] )/1000.0f;
             }
             else if(L3flag)
             {
                  m_PDUCHInfo[i+5].CHVoltage=((pRecVector[21] << 16) + pRecVector[20] )/1000.0f;
                  m_PDUCHInfo[i+5].CHCurrent=((pRecVector[23] << 16) + pRecVector[22] )/1000.0f;
                  m_PDUCHInfo[i+5].CHPower=((pRecVector[25] << 16) + pRecVector[24] )/1000.0f;
                  m_PDUCHInfo[i+5].CHConsumption=((pRecVector[27] << 16) + pRecVector[26] )/1000.0f;
             }
        }
    }
    else if((_SWITCH_T_AC_CH_PHASE_INFO+_SWITCH_CH_DIV*2)==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,150);
        if(pRecVector.size()<150) return;
        for(int i=0;i<5;i++)
        {
             bool L1flag=pRecVector[i*30+9] & 0xFFFF; // Low byte
             bool L2flag=pRecVector[i*30+19] & 0xFFFF; // Low byte
             bool L3flag=pRecVector[i*30+29] & 0xFFFF; // Low byte

             if(L1flag)
             {
                  m_PDUCHInfo[i+10].CHVoltage=((pRecVector[1] << 16) + pRecVector[0] )/1000.0f;
                  m_PDUCHInfo[i+10].CHCurrent=((pRecVector[3] << 16) + pRecVector[2] )/1000.0f;
                  m_PDUCHInfo[i+10].CHPower=((pRecVector[5] << 16) + pRecVector[4] )/1000.0f;
                  m_PDUCHInfo[i+10].CHConsumption=((pRecVector[7] << 16) + pRecVector[6] )/1000.0f;
             }
             else if(L2flag)
             {
                  m_PDUCHInfo[i+10].CHVoltage=((pRecVector[11] << 16) + pRecVector[10] )/1000.0f;
                  m_PDUCHInfo[i+10].CHCurrent=((pRecVector[13] << 16) + pRecVector[12] )/1000.0f;
                  m_PDUCHInfo[i+10].CHPower=((pRecVector[15] << 16) + pRecVector[14] )/1000.0f;
                  m_PDUCHInfo[i+10].CHConsumption=((pRecVector[17] << 16) + pRecVector[16] )/1000.0f;
             }
             else if(L3flag)
             {
                  m_PDUCHInfo[i+10].CHVoltage=((pRecVector[21] << 16) + pRecVector[20] )/1000.0f;
                  m_PDUCHInfo[i+10].CHCurrent=((pRecVector[23] << 16) + pRecVector[22] )/1000.0f;
                  m_PDUCHInfo[i+10].CHPower=((pRecVector[25] << 16) + pRecVector[24] )/1000.0f;
                  m_PDUCHInfo[i+10].CHConsumption=((pRecVector[27] << 16) + pRecVector[26] )/1000.0f;
             }
        }
    }
    else if(_SWITCH_T_AC_CH_STATUS==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,14);
        if(pRecVector.size()<14) return;
        for(int i=0;i<14;i++)
        {
            m_PDUCHInfo[i].CHStatus=pRecVector[i] & 0xFFFF; // Low byte
        }
    }
    else if(_SWITCH_T_AC_SENSOR_INFO==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,16);
        if(pRecVector.size()<16) return;
        m_PDUAllInfo.Sensor_Temperature = ((pRecVector[1] << 16) + pRecVector[0] )/1000.0f;
        m_PDUAllInfo.Sensor_Humidity = ((pRecVector[3] << 16) + pRecVector[2] )/1000.0f;
        m_PDUAllInfo.Sensor_CO2 = ((pRecVector[5] << 16) + pRecVector[4] )/1000.0f;
        m_PDUAllInfo.Sensor_INTemperature = ((pRecVector[9] << 16)+ pRecVector[8])/1000.0f;
        m_PDUAllInfo.Sensor_OUTTemperature = ((pRecVector[13] << 16)+ pRecVector[12])/1000.0f;
    }
    else if(_SWITCH_T_AC_SENSOR_INFO1==infoType)
    {
        QVector<quint16> pRecVector=parseModbusResponse(Recstr,4);
        if(pRecVector.size()<4) return;
        m_PDUAllInfo.Sensor_WaterImmersion = pRecVector[0] & 0xFFFF; // Low byte
    }

    if(m_printflag) emit addPDUInfo(Sendstr, Recstr);
}

/*发送数据*/
QString SerialInfo::on_SendInfo(char* OrderArray,int sendsize)
{
    if(!m_openflag) return "";
    QString hexString="";
    // 创建一个JNI环境并调用Java静态方法
    QAndroidJniEnvironment env;
    jbyteArray byteArray = env->NewByteArray(sendsize);
    env->SetByteArrayRegion(byteArray, 0, sendsize, reinterpret_cast<const jbyte*>(OrderArray));
    QAndroidJniObject sendbacktring = QAndroidJniObject::callStaticObjectMethod(
        "usb/USBListActivity",
        "writeData",
        "([B)Ljava/lang/String;", // 方法签名：接收字节数组并返回字符串
        byteArray              // 参数
        );

    QString recsendinfo=sendbacktring.toString();
    // 发送字节计数并显示
    if(recsendinfo!="")
    {
        QByteArray byteArray = recsendinfo.toLatin1(); // 将 QString 转换为 QByteArray，使用 UTF-8 编码
        for (unsigned char byte : byteArray) {
            // 使用 printf 格式化输出或 qDebug() 输出每个字节的十六进制表示
             hexString += QString("%1 ").arg(static_cast<unsigned char>(byte), 2, 16, QChar('0'));
        }
    }

    return hexString;
}


QString SerialInfo::on_Rec_PDUStatus()
{
    if(!m_openflag) return "";
    // 如接收成功，会返回接收的字符串，失败返回空字符串
    QString Allrecinfo="";
    for (int i=0;i<10;i++)
    {
        QAndroidJniObject  recbacktring = QAndroidJniObject::callStaticObjectMethod(
            "usb/USBListActivity",
            "readData",
            "()Ljava/lang/String;");

        QString recinfo=recbacktring.toString();
        // 发送字节计数并显示
        if(recinfo!="")
        {
            QString hexString;
            QByteArray byteArray = recinfo.toLatin1(); // 将 QString 转换为 QByteArray，使用 UTF-8 编码
            for (char byte : byteArray) {
                // 使用 printf 格式化输出或 qDebug() 输出每个字节的十六进制表示
                 hexString += QString("%1 ").arg(static_cast<unsigned char>(byte), 2, 16, QChar('0'));
                }
            Allrecinfo+=hexString;
        }
        else
        {
            break;
        }
    }
    return Allrecinfo;
}

uint16_t SerialInfo::crc16_ccitt(char* data, size_t length) {
    uint16_t crc = 0xFFFF;
       uint16_t i, j;
       for (i = 0; i < length; i++) {
           crc ^= data[i];
           for (j = 0; j < 8; j++) {
               if (crc & 0x0001) {
                   crc >>= 1;
                   crc ^= 0xA001;
               } else {
                   crc >>= 1;
               }
           }
       }

   // data[7] = crc & 0xFF; // Low byte
    //data[6] = (crc >> 8) & 0xFF; // High byte


    return crc; // No final XOR value for CRC16-CCITT (XMODEM)
}


QVector<quint16> SerialInfo::parseModbusResponse(const QString &hexString, int registerCount) {
    QVector<quint16> registers;

    QString  TempHexString=hexString;
    // Remove spaces from the input string for easier parsing
    QString cleanHexString = TempHexString.remove(QRegularExpression("\\s"));

    // Verify the length of the cleaned string matches what we expect
    if (cleanHexString.length() != (registerCount * 4 + 5 * 2)) { // +5*2 for the modubus 03 code head 3 byte +tail 2 byte = 5 byte
        qWarning() << "Invalid response length.";
        return registers; // Return empty vector on error
    }

    // Skip the first byte which is the byte count in a Modbus TCP response
    QTextStream stream(&cleanHexString);
    stream.skipWhiteSpace();
    stream.seek(6); // Skip the head byte count

    for (int i = 0; i < registerCount; ++i) {
        QString byteStr = stream.read(4); // Each register is represented by 4 hex chars (2 bytes)
        if (byteStr.length() != 4) {
            qWarning() << "Unexpected end of data at register" << i;
            break;
        }

        // Convert the 4 hex chars into a quint16 value
        bool ok1, ok2;
        quint8 byte1 = byteStr.left(2).toInt(&ok1, 16); // 前两位转换为整数
        quint8 byte2 = byteStr.right(2).toInt(&ok2, 16); // 后两位转换为整数
        quint16 regValue = (byte1 << 8) | byte2;
        registers.append(regValue);
    }

    return registers;
}