server1/Server/ThreadCalculate/CompareItemThread.h

#ifndef _COMPAREITEMTHREAD_H_
#define _COMPAREITEMTHREAD_H_

#include <map>
#include <qt5/QtCore/qchar.h>

#include "BaseCalculateThread.h"
#include "CompareResult.h"
#include "AlarmInfo.h"
#include "FromMQTT.h"

class CalculateDBThread;
class NoiseDetectThread;
class CompareDoubleThread;


/**
    对比项功能线程
        功能：
            1、对比两个录音通道的数据，通道1是主通道，和其他通道挨个对比
            2、这里处理各个通道的报警信息，写入数据库
            3、从这里开启各个比对线程，获取比对结果信息，并组合
            4、这里创建的线程包含：两两对比线程、音量检测线程，这两个都和对比项相关联
            5、噪音检测线程从线程管理器中获取的，这里不负责创建和销毁
 
 */
class CompareItemThread : public BaseCalculateThread
{
public:
    CompareItemThread(CalculateThreadInfo_t& threadInfo);
    ~CompareItemThread() override;

protected:
    /* 线程功能函数 */
    void task() override;
    /* 初始化数据 */
    bool initData() override;
    /* 清理数据 */
    void clearData() override;

private:
    /* 创建两个对比线程，主通道是第一个通道，其他都需要和主通道进行对比 */
    bool createCompareThreads();
    /* 销毁两两对比线程 */
    void destroyCompareThreads();
    
    /* 创建计算音量报警的线程 */
    bool createCalculateDBThreads();
    /* 销毁音量计算的线程 */
    void destroyCalculateDBThreads();
    /* 获取噪音检测的线程 */
    bool getNoiseDetectThreads();
    /* 移除噪音检测的线程 */
    void removeNoiseDetectThreads();


    /* 更新数据 */
    bool updateResultData();
    /* 处理报警数据，写入数据库 */
    void processAlarmData();
    /* 发送数据 */
    void sendResultData();

    /* 清除标志更新位 */
    void clearUpdateFlags();
    /* 生成发送至MQTT的JSON数据 */
    bool generateMQTTJsonData(const CompareResult_t& compareResult, QByteArray& jsonData);

private:
    /* 发送音量包信息到mqtt中 */
    FromMQTT* m_pFromMQTT = nullptr;
    /* 发布的主题 */
    QString m_pubTopic;

    /* 计算音量信息的线程指针，第一个是主通道线程，int是对比项中的通道号 */
    std::map<int, CalculateDBThread*> m_mapCalculateDBThreads;
    std::map<int, bool> m_mapCDBUpdated;             /* 音量包更新标志位 */
    /* 计算噪音的线程指针 */
    std::map<int, NoiseDetectThread*> m_mapNoiseDetectThreads;
    /* 对比项信息线程，这个线程在这里创建，不会和其他对比项复用，int是第二路对比通道的编号 */
    std::map<int, CompareDoubleThread*> m_mapCompareDoubleThreads;


    /* 计算的数据结果 */
    CompareResult_t m_compareResult;

    /* 存储报警信息 */
    std::map<int, AlarmInfo_t> m_mapAlarmSilence;           /* 静音报警信息 */
    std::map<int, AlarmInfo_t> m_mapAlarmOverload;          /* 过载报警信息 */
    std::map<int, AlarmInfo_t> m_mapAlarmPhase;             /* 反相报警信息 */

    std::map<int, AlarmInfo_t> m_mapAlarmSilenceLast;       /* 上一次静音报警信息 */
    std::map<int, AlarmInfo_t> m_mapAlarmOverloadLast;      /* 上一次过载报警信息 */
    std::map<int, AlarmInfo_t> m_mapAlarmPhaseLast;         /* 上一次反相报警信息 */

    /* 要写入到数据库的报警信息 */
    std::list<AlarmInfo_t> m_listAlarm;;
};



#endif // _COMPAREITEMTHREAD_H_