#include "FrequencyTuning.h"
#include <iostream>
#include <QDateTime>

FrequencyTuning::FrequencyTuning(QObject *parent) : QObject(parent)
{
    connect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
            this, &FrequencyTuning::dataReceivedHandler);

    kafkaUtil.setBrokers(SettingConfig::getInstance().KAFKA_BROKERS);
    kafkaUtil.setTopic(SettingConfig::getInstance().KAFKA_DATA_TOPIC);
    kafkaUtil.createProducer();
}

FrequencyTuning::~FrequencyTuning()
{
    disconnect(&this->serialUtil, &QSerialPortUtil::dataRecieved,
               this, &FrequencyTuning::dataReceivedHandler);
}

void FrequencyTuning::setComName(QString comName)
{
    this->comName = comName;
}
void FrequencyTuning::setBaudRate(int baudRate)
{
    this->baudRate = baudRate;
}
QString FrequencyTuning::getDevCode()
{
    return this->devCode;
}
void FrequencyTuning::setDevCode(QString devCode)
{
    this->devCode = devCode;
}

bool FrequencyTuning::isSerialOpen()
{
    return this->serialUtil.isOpen();
}

void FrequencyTuning::initSerialPort()
{
    this->serialUtil.openSerialPort(this->comName, this->baudRate);
}

void FrequencyTuning::dataReceivedHandler(QByteArray data)
{
    this->dataBuff.append(data);

    std::cout << dataBuff.toStdString() << std::endl;

    QList<QByteArray> frameList = FrequencyTuningProtocolBM::extractFrameList(this->dataBuff);

    if (frameList.size() > 0)
    {
        for (int i = 0; i < frameList.size(); i++)
        {
            QByteArray frameByte = frameList.at(i);

            int frameType = FrequencyTuningProtocolBM::checkFrame(frameByte);
            FrequencyTuningStatusDto * ftFrameDto = FrequencyTuningProtocolBM::ftFrameFactory(frameType);
            if (ftFrameDto != nullptr)
            {
                // ★解析成数据对象
                bool parse = FrequencyTuningProtocolBM::parseFrequencyTuningData(frameByte, ftFrameDto, frameType);

                // 解析成功
                if (parse == true)
                {
                    QDateTime now = QDateTime::currentDateTime();
                    ftFrameDto->timestamp = now.toString("yyyy-MM-dd HH:mm:ss.zzz");
                    ftFrameDto->milisecond = now.toMSecsSinceEpoch();
                    ftFrameDto->rawFrame = frameByte;

                    this->afterFramePhase(ftFrameDto);
                }

                // 在此处释放内存，不影响后续显示
                // 不在此处释放内存则会导致内存持续增加
                // 具体原因不明
                delete ftFrameDto;
            }
        }
    }
}

void FrequencyTuning::afterFramePhase(FrequencyTuningStatusDto * frameDto)
{
    std::cout << "frame type: " << typeid(* frameDto).name() << std::endl;
    std::cout << frameDto->rawFrame.toStdString() << std::endl;

    // 3. 输出到中间件，执行后续处理过程
    if (SettingConfig::getInstance().NEED_KAFKA == 1)
    {
        QJsonObject jsonObj = frameDto->toJSON();
        jsonObj.insert("clientId", SettingConfig::getInstance().CLIENT_ID);
        jsonObj.insert("deviceId", devCode);
        kafkaUtil.produceMessage(QString(QJsonDocument(jsonObj).toJson(QJsonDocument::Compact)));
    }
}