server1/Server/ThreadManager/ThreadCompareItemManager.h

#ifndef __THREADCOMPAREITEMMANAGER_H__
#define __THREADCOMPAREITEMMANAGER_H__


#include "GlobalVariable.h"
#include "spdlog/spdlog.h"
#include "FromWebAPI.h"
#include "CompareItemThread.h"

#include <QObject>
#include <QEventLoop>
#include <QTimer>
#include <string>

class FromMQTT;

/**
    对比项管理线程
    1、这个线程类定时获取数据库中对比项的信息，与正在运行的对比项线程对比，
       找出需要新增的对比项、需要更新的对比项和需要删除的对比项。
    2、在创建对比项线程的时候套了一层壳，在 thread_compareItem 函数中创建新的对比项线程实例，
       这样可以避免 Qt 报线程归属权错误。
    3、这个线程也会定时获取计划信息，更新给对比项
 */


#define CompareItemManager ThreadCompareItemManager::instance()

class ThreadCompareItemManager : public QObject
{
    Q_OBJECT

    ThreadCompareItemManager();
    ThreadCompareItemManager(const ThreadCompareItemManager&) = delete;
    ThreadCompareItemManager& operator=(const ThreadCompareItemManager&) = delete;
public:
    ~ThreadCompareItemManager();
    static ThreadCompareItemManager& instance()
    {
        static ThreadCompareItemManager instance;
        return instance;
    }

    /* 对比项管理器线程函数 */
    void thread_CompareItemManager();

    /* 通过对比项ID和通道ID获取声卡通道信息 */
    OneSoundCardPCMInfo_t getSoundCardRoadInfo(int compareItemID, int roadNum);
    

    /*  给对比项套一层壳，这个函数就是新的线程，在里面new出新的对比项实例，防止Qt报线程归属权错误，
        在函数中将对比项实例插入到线程管理器中 */
    static void thread_compareItem(CalculateThreadInfo_t threadInfo);

private slots:
    /* 定时器触发，处理对比项信息 */
    void do_task();

private:
    /* 添加对比项实例 */
    void addCompareItemThread(CompareItemThread* pThread);
    /* 更新基础设置信息，如数据库设置，噪音参数等 */
    bool updateBaseSettings();

    /* ---------------------- 对比项信息 ---------------------- */
    /* 更新对比项信息 */
    void processCompareItemInfo();
    /* 处理对比项信息，新获取的和已有的对比 */
    void checkCompareItemInfo(  QList<CompareItemInfo_t>& newList,
                                QList<CompareItemInfo_t>& createList,
                                // QList<CompareItemInfo_t>& updateList,
                                QList<int>& deleteList);

    /* 处理需要删除的对比项线程 */
    void processDeleteCompareItemThreads(const QList<int>& deleteList);
    /* 更新正在运行的线程信息 */
    void updateRunningThreads(const QList<CompareItemInfo_t>& updateList);
    /* 创建新的线程 */
    bool createNewCompareItemThreads(const QList<CompareItemInfo_t>& createList);

    /* ---------------------- 检测时段信息 ---------------------- */
    /* 处理检测时段信息 */
    void processDetectPeriodInfo();
    /* 检查获取出更新的对比项信息 */
    void checkDetectPeriodInfo(QMap<int, DetectPeriodConfig_t>& nowDetectInfo, QMap<int, DetectPeriodConfig_t> newDetectInfo, QMap<int, DetectPeriodConfig_t>& updateList);

    /* ---------------------- 向MQTT发送对比项信息 ---------------------- */
    /* 更新对比项信息到MQTT */
    void updateCompareItemInfoToMQTT();
    /* 发送到MQTT */
    void sendCompareItemInfoToMQTT(const QMap<int, CompareItemInfo_t>& mapCompareItem);
    /* 初始化MQTT */
    void initMQTT();

private:
    std::shared_ptr<spdlog::logger> m_logger = nullptr;
    QEventLoop* m_pEventLoop = nullptr; // 事件循环
    QTimer* m_pTimer = nullptr;         // 定时器
    FromMQTT* m_pFromMQTT = nullptr;    // MQTT处理发送类
    QString m_pubTopic;                 /* 发布的主题 */


    FromWebAPI m_fromWebAPI;                /* WebAPI处理类 */
    QString m_webAPIUrl;                    /* WebAPI地址 */
    QString m_webAPIID;                     /* WebAPI ID */
    QString m_webAPIAppType;                      /* WebAPI应用类型 */

    /* ---------------------- 对比项信息 ---------------------- */
    std::atomic_bool m_isOneSend = true;        /* 开启服务先发送一次 */
    std::mutex m_mutexCompareItemThreads;       /* 对比项线程的互斥锁 */
    // QList<CompareItemInfo_t> m_listNewItems;    /* 对比项列表，从数据库获取到的新的列表 */
    QMap<int, CompareItemInfo_t> m_mapNowCompareItem; /* 当前的对比项信息，在检查是否有对比项更新的时候更新该值 */
    QMap<int, CompareItemThread*> m_mapThreads; /* 对比项线程列表，key是对比项ID，value是对应的线程指针 */

    /* 临时变量 */
    QList<CompareItemInfo_t> m_listCreateItems; // 新创建的对比项列表
    QList<CompareItemInfo_t> m_listUpdateItems; // 更新的对比项列表
    QList<int> m_listDeleteItems; // 删除的对比项列表

    /* ---------------------- 检测时段信息 ---------------------- */
    /* 检测时段，int是对比项ID */
    QMap<int, DetectPeriodConfig_t> m_mapDetectPeriod;

    /* ---------------------- 向MQTT发送对比项信息 ---------------------- */
    QMap<int, CompareItemInfo_t> m_mapMQTTItemInfo;
};


#endif