server1/Server/ThreadCalculate/CompareItemThread.cpp

#include "CompareItemThread.h"

#include "FromMQTT.h"
#include "GlobalInfo.h"
#include "ThreadManager.h"
#include "CalculateDBThread.h"
#include "NoiseDetectThread.h"
#include "CompareDoubleThread.h"
#include "ThreadPool.h"
#include "commonDefine.h"
#include "ThreadAlarmManager.h"
#include "spdlog.h"
#include <qdatetime.h>



CompareItemThread::CompareItemThread(CalculateThreadInfo_t& threadInfo)
    : QObject(nullptr), BaseCalculateThread(threadInfo)
{

}

CompareItemThread::~CompareItemThread()
{

}

/* 重写父类的线程函数，这里重新实现 */
void CompareItemThread::threadTask()
{
    m_logBase = fmt::format("对比项: {}", m_threadInfo.compareItemInfo.strName.toStdString());
    SPDLOG_LOGGER_INFO(m_logger, "----------------------------------------------------------------");
    SPDLOG_LOGGER_INFO(m_logger, "{} 线程开始运行, 对比通道: ", m_logBase);
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        SPDLOG_LOGGER_INFO(m_logger, "      通道名称: {}, 通道编号: {}, 声卡通道: {}:{}",
                           road.strCompareRoadName.toStdString(), road.nCompareRoadNum, road.scRoadInfo.strSoundCardName.toStdString(), road.scRoadInfo.roadInfo.nRoadNum);
    }
    SPDLOG_LOGGER_INFO(m_logger, "----------------------------------------------------------------");

    /* 初始化数据 */
    if(!initData())
    {
        SPDLOG_LOGGER_ERROR(m_logger, "{} 初始化数据失败", m_logBase);
        return;
    }
    
    /* 更新线程状态标志 */
    m_threadInfo.threadState = EThreadState::State_Running;
    m_isStop = false;



    m_pTimer = new QTimer();
    if(m_pTimer == nullptr)
    {
        SPDLOG_LOGGER_ERROR(m_logger, "{} 创建定时器失败", m_logBase);
    }
    
        // SPDLOG_LOGGER_WARN(m_logger, "{} 创建定时器成功，开启定时器", m_logBase);
    m_pTimer->setTimerType(Qt::PreciseTimer);
    m_pTimer->setSingleShot(false); // 设置为非单次定时器
    m_pTimer->setInterval(50);
    m_eventLoop.connect(m_pTimer, &QTimer::timeout, this, &CompareItemThread::do_timeout);
    m_pTimer->start();
    

    /* 开启事件循环 */
    m_eventLoop.exec();

    /* 等待 */
    // std::this_thread::sleep_for(std::chrono::seconds(20));

    /* 线程结束，清理数据 */
    clearData();
    m_threadInfo.threadState = EThreadState::State_Stopped;
    m_isStop = true;
    SPDLOG_LOGGER_WARN(m_logger, "★ {} 线程结束运行", m_logBase);
}


/* 停止线程函数 */
void CompareItemThread::stopThread()
{
    if(m_pTimer != nullptr)
    {
        if(m_pTimer->isActive())
        {
            m_pTimer->stop();
        }
        disconnect(m_pTimer, &QTimer::timeout, this, &CompareItemThread::do_timeout);
        delete m_pTimer;
        m_pTimer = nullptr;
    }
    /* 停止事件循环 */
    m_eventLoop.quit();
    
}

void CompareItemThread::stopThreadBlock()
{
    stopThread();
    while(!m_isStop) // 等待线程停止
    {
        std::this_thread::sleep_for(std::chrono::milliseconds(1));
    }
}

/* 设置检测时段 */
void CompareItemThread::setDetectPeriod(const DetectPeriodConfig_t& detectPeriod)
{
    std::lock_guard<std::mutex> lock(m_mutexDetectPeriod);
    if(detectPeriod.nID != m_detectPeriod.nID)
    {
        SPDLOG_LOGGER_ERROR(m_logger, "{} 设置检测时段失败，ID不匹配: {}, 当前ID: {}", m_logBase, detectPeriod.nID, m_detectPeriod.nID);
        return;
    }
    m_detectPeriod = detectPeriod;
    // m_isDetectPeriodUpdated = true; // 标记检测时段已更新
}



/* 线程功能函数 */
void CompareItemThread::task()
{
    m_logBase = fmt::format("对比项: {}", m_threadInfo.compareItemInfo.strName.toStdString());
    SPDLOG_LOGGER_INFO(m_logger, "----------------------------------------------------------------");
    SPDLOG_LOGGER_INFO(m_logger, "{} 线程开始运行, 对比通道: ", m_logBase);
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        SPDLOG_LOGGER_INFO(m_logger, "      通道名称: {}, 通道编号: {}, 声卡通道: {}:{}",
                           road.strCompareRoadName.toStdString(), road.nCompareRoadNum, road.scRoadInfo.strSoundCardName.toStdString(), road.scRoadInfo.roadInfo.nRoadNum);
    }
    SPDLOG_LOGGER_INFO(m_logger, "----------------------------------------------------------------");

    /* 初始化数据 */
    if(!initData())
    {
        SPDLOG_LOGGER_ERROR(m_logger, "{} 初始化数据失败", m_logBase);
        return;
    }
    // SPDLOG_LOGGER_WARN(m_logger, "{} 初始化数据完成，开始对比检测, isRunning: {}", m_logBase, m_isRunning.load());

    while (m_isRunning)
    {
        /* 睡眠100ms */
        std::this_thread::sleep_for(std::chrono::milliseconds(50));

        /* -------------------------------------------------------------------------------------
         * 更新对比项信息
         * ------------------------------------------------------------------------------------- */
        if(updateThreadInfoInternal())
        {
            SPDLOG_LOGGER_INFO(m_logger, "{} 暂停对比检测，更新对比项信息");
            m_threadInfo.compareItemInfo = m_threadInfoNew.compareItemInfo;
            initData();
            SPDLOG_LOGGER_INFO(m_logger, "{} 更新对比项信息完成，继续检测对比");
        }

        /* -------------------------------------------------------------------------------------
         * 更新数据
         * ------------------------------------------------------------------------------------- */
        if(!updateResultData())
        {
            continue;
            // return;
        }

        /* -------------------------------------------------------------------------------------
         * 处理数据，将报警信息给写报警数据的线程
         * ------------------------------------------------------------------------------------- */
        // processAlarmData();

        /* -------------------------------------------------------------------------------------
         * 将音量包数据发送到MQTT中
         * ------------------------------------------------------------------------------------- */
        sendResultData();

        /* 清除标志位 */
        clearUpdateFlags();
        SPDLOG_LOGGER_WARN(m_logger, "{} 发送对比项数据到MQTT中", m_logBase);
    }
    /* 清理数据 */
    clearData();
    SPDLOG_LOGGER_WARN(m_logger, "★ {} 线程结束运行", m_logBase);
}

/* 定时器任务 */
void CompareItemThread::timerTask()
{
    /* -------------------------------------------------------------------------------------
     * 更新对比项信息
     * ------------------------------------------------------------------------------------- */
    if(updateThreadInfoInternal())
    {
        SPDLOG_LOGGER_INFO(m_logger, "{} 暂停对比检测，更新对比项信息");
        m_threadInfo.compareItemInfo = m_threadInfoNew.compareItemInfo;
        initData();
        SPDLOG_LOGGER_INFO(m_logger, "{} 更新对比项信息完成，继续检测对比");
    }

    /* 判断检测时段 */
    if(!checkDetectPeriod())
    {
        // 不在检测时段内，不进行对比检测
        // SPDLOG_LOGGER_WARN(m_logger, "{} 当前不在检测时段内，停止对比检测", m_logBase);
        return;
    }
    /* -------------------------------------------------------------------------------------
     * 更新数据
     * ------------------------------------------------------------------------------------- */
    if(!updateResultData())
    {
        return;
    }
    /* -------------------------------------------------------------------------------------
     * 处理数据，将报警信息给写报警数据的线程，直接由各个计算线程直接写入
     * ------------------------------------------------------------------------------------- */
    // processAlarmData();
    
    /* -------------------------------------------------------------------------------------
     * 将音量包数据发送到MQTT中
     * ------------------------------------------------------------------------------------- */
    sendResultData();
    /* 清除标志位 */
    clearUpdateFlags();
    // SPDLOG_LOGGER_WARN(m_logger, "{} 发送对比项数据到MQTT中", m_logBase);
}

/* 初始化数据 */
bool CompareItemThread::initData()
{
    /* 创建录音通道线程 */
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        ThreadMan.createRecordThread(road.scRoadInfo, m_threadInfo.compareItemInfo.nID);
    }

    /* 创建计算音量报警信息的线程指针 */
    destroyCalculateDBThreads(); // 清理之前的线程
    createCalculateDBThreads();

    /* 创建两个对比线程，主通道是第一个通道，其他都需要和主通道进行对比 */
    destroyCompareThreads();
    createCompareThreads();

    /* 获取计算噪音的线程 */
    destroyNoiseDetectThreads();
    createNoiseDetectThreads();

    /* 初始化存储结果的数据结构 */
    m_compareResult = CompareResult_t();
    m_compareResult.compareItemID = m_threadInfo.compareItemInfo.nID;
    m_compareResult.compareItemName = m_threadInfo.compareItemInfo.strName.toStdString();
    m_compareResult.dateTime = QDateTime::currentDateTime();
    m_compareResult.isClientAlarm = false; // 默认不报警
    m_compareResult.mapRoadVolumes.clear(); // 清空之前的数据
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        OneRoadVolume_t oneRoadVolume;
        oneRoadVolume.roadInfo = road; // 设置通道信息
        oneRoadVolume.dateTime = QDateTime::currentDateTime(); // 初始化时间
        m_compareResult.mapRoadVolumes.insert({road.nCompareRoadNum, oneRoadVolume});
    }

    m_mapCDBUpdated.clear();
    for(auto it : m_threadInfo.compareItemInfo.mapRoad)
    {
        m_mapCDBUpdated.insert({it.nCompareRoadNum, false}); // 初始化更新标志位为false
    }

    /* 初始化报警信息 */
    // m_mapAlarmSilence.clear();
    // m_mapAlarmOverload.clear();
    // m_mapAlarmPhase.clear();
    // for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    // {
    //     m_mapAlarmSilence.insert({road.nCompareRoadNum, AlarmInfo_t()});
    //     m_mapAlarmOverload.insert({road.nCompareRoadNum, AlarmInfo_t()});
    //     m_mapAlarmPhase.insert({road.nCompareRoadNum, AlarmInfo_t()});
    // }

    // m_mapAlarmSilenceLast.clear();
    // m_mapAlarmOverloadLast.clear();
    // m_mapAlarmPhaseLast.clear();
    // for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    // {
    //     m_mapAlarmSilenceLast.insert({road.nCompareRoadNum, AlarmInfo_t()});
    //     m_mapAlarmOverloadLast.insert({road.nCompareRoadNum, AlarmInfo_t()});
    //     m_mapAlarmPhaseLast.insert({road.nCompareRoadNum, AlarmInfo_t()});
    // }
    

    return true;
}

/* 清理数据 */
void CompareItemThread::clearData()
{
    /* 停止所有的比对线程 */
    destroyCompareThreads();
    /* 销毁音量报警线程 */
    destroyCalculateDBThreads();
    /* 移除噪音检测线程 */
    // removeNoiseDetectThreads();
    destroyNoiseDetectThreads();

    /* 移除使用到的录音通道 */
    for(auto& it : m_threadInfo.compareItemInfo.mapRoad)
    {
        SoundCardRoadInfo_t roadInfo = it.scRoadInfo;
        if(!ThreadMan.removeRecordThread(roadInfo, m_threadInfo.compareItemInfo.nID))
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 移除录音通道 {}:{} 失败", m_logBase, roadInfo.strSoundCardName.toStdString(), roadInfo.roadInfo.nRoadNum);
        }
    }

    if(m_pFromMQTT != nullptr)
    {
        delete m_pFromMQTT; // 删除MQTT对象
        m_pFromMQTT = nullptr; // 设置为nullptr
    }
}

/* 定时器槽函数 */
void CompareItemThread::do_timeout()
{
    // SPDLOG_LOGGER_WARN(m_logger, "{} 定时器触发，开始执行定时任务", m_logBase);
    if(m_pFromMQTT == nullptr)
    {
        initMQTT();
    }
    timerTask();
}

/* 初始化MQTT */
void CompareItemThread::initMQTT()
{
    if(m_pFromMQTT == nullptr)
    {
        m_pFromMQTT = new FromMQTT();
        if(m_pFromMQTT == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 创建MQTT对象失败", m_logBase);
            return; // 创建MQTT对象失败
        }
    }
    /* 登陆MQTT */
    m_pFromMQTT->setIPAndPort(GInfo.mqttIP(), GInfo.mqttPort());
    m_pFromMQTT->connectToServer();

    m_pubTopic = QString("%1/%2").arg(GInfo.mqttPubTopicDB()).arg(QString::number(m_threadInfo.compareItemInfo.nID));
    SPDLOG_LOGGER_INFO(m_logger, "☆ {} 连接MQTT服务器: {}:{}, 音量包订阅主题: {}", m_logBase, GInfo.mqttIP().toStdString(), GInfo.mqttPort(), m_pubTopic.toStdString());
}





/* 创建两个对比线程，主通道是第一个通道，其他都需要和主通道进行对比 */
bool CompareItemThread::createCompareThreads()
{
    auto it = m_threadInfo.compareItemInfo.mapRoad.begin();
    auto mainRoad = it.value(); // 主通道信息
    it++; // 移动到下一个通道
    // uint64_t size = m_threadInfo.compareItemInfo.mapRoad.size();
    for(; it != m_threadInfo.compareItemInfo.mapRoad.end(); it++)
    {
        CalculateThreadInfo_t compareThreadInfo;
        compareThreadInfo.compareItemInfo = m_threadInfo.compareItemInfo;
        compareThreadInfo.compareItemInfo.mapRoad.clear(); // 清空通道信息
        compareThreadInfo.compareItemInfo.mapRoad.insert(mainRoad.nCompareRoadNum, mainRoad);   // 添加主通道
        compareThreadInfo.compareItemInfo.mapRoad.insert(it.key(), it.value());                 // 添加当前通道
        compareThreadInfo.threadState = EThreadState::State_Inited;
        CompareDoubleThread* pThread = new CompareDoubleThread(compareThreadInfo);
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 创建对比线程 {} - {} 失败", m_logBase, mainRoad.strCompareRoadName.toStdString(), it.value().strCompareRoadName.toStdString());
            return false;
        }
        m_mapCompareDoubleThreads.insert({it.key(), pThread}); // 保存线程指针
        /* 开始运行 */
        CPPTP.add_task(&CompareDoubleThread::threadTask, pThread);
    }

    return true;
}

/* 销毁两两对比线程 */
void CompareItemThread::destroyCompareThreads()
{
    if(m_mapCompareDoubleThreads.size() == 0)
    {
        return; // 没有对比线程
    }
    SPDLOG_LOGGER_INFO(m_logger, "{} 销毁对比线程", m_logBase);
    for(auto& pair : m_mapCompareDoubleThreads)
    {
        if(pair.second != nullptr)
        {
            pair.second->stopThreadBlock(); // 停止线程
            delete pair.second;             // 删除线程
            pair.second = nullptr;          // 设置为nullptr
        }
    }
    m_mapCompareDoubleThreads.clear();
    m_mapCDBUpdated.clear(); // 清空更新标志位
    SPDLOG_LOGGER_INFO(m_logger, "{} 对比线程销毁完成", m_logBase);
}

/* 创建计算音量报警的线程 */
bool CompareItemThread::createCalculateDBThreads()
{
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        CalculateThreadInfo_t threadInfo;
        threadInfo.compareItemInfo.mapRoad.clear(); // 清空通道信息
        threadInfo.compareItemInfo.mapRoad.insert(road.nCompareRoadNum, road); // 添加当前通道
        threadInfo.threadState = EThreadState::State_Inited; // 初始化线程状态
        threadInfo.threadType = EThreadType::Type_CalculateDB;
        CalculateDBThread* pThread = new CalculateDBThread(threadInfo);
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 创建音量计算线程失败", m_logBase);
            // return false; // 获取线程失败
        }
        CPPTP.add_task(&CalculateDBThread::threadTask, pThread);
        m_mapCalculateDBThreads.insert({road.nCompareRoadNum, pThread}); // 保存线程指针
    }

    return true;
}

/* 销毁音量计算的线程 */
void CompareItemThread::destroyCalculateDBThreads()
{
    if(m_mapCalculateDBThreads.size() == 0)
    {
        return; // 没有音量计算线程
    }
    SPDLOG_LOGGER_INFO(m_logger, "{} 销毁音量计算线程", m_logBase);
    for(auto& pair : m_mapCalculateDBThreads)
    {
        if(pair.second != nullptr)
        {
            pair.second->stopThreadBlock(); // 停止线程
            delete pair.second;             // 删除线程
            pair.second = nullptr;          // 设置为nullptr
        }
    }
    m_mapCalculateDBThreads.clear();
    m_mapCDBUpdated.clear(); // 清空更新标志位

    SPDLOG_LOGGER_INFO(m_logger, "{} 音量计算线程销毁完成", m_logBase);
}

/* 创建噪音检测线程 */
void CompareItemThread::createNoiseDetectThreads()
{
    for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
    {
        CalculateThreadInfo_t threadInfo;
        threadInfo.compareItemInfo.mapRoad.clear(); // 清空通道信息
        threadInfo.compareItemInfo.mapRoad.insert(road.nCompareRoadNum, road); // 添加当前通道
        threadInfo.threadState = EThreadState::State_Inited; // 初始化线程状态
        threadInfo.threadType = EThreadType::Type_CalculateDB;
        NoiseDetectThread* pThread = new NoiseDetectThread(threadInfo);
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 创建噪音检测线程失败", m_logBase);
            return; // 获取线程失败
        }
        m_mapNoiseDetectThreads.insert({road.nCompareRoadNum, pThread});
    }
}

/* 销毁噪音检测线程 */
void CompareItemThread::destroyNoiseDetectThreads()
{
    if(m_mapNoiseDetectThreads.size() == 0)
    {
        return; // 没有噪音检测线程
    }
    SPDLOG_LOGGER_INFO(m_logger, "{} 销毁噪音检测线程", m_logBase);
    for(auto& pair : m_mapNoiseDetectThreads)
    {
        if(pair.second != nullptr)
        {
            pair.second->stopThreadBlock(); // 停止线程
            delete pair.second;             // 删除线程
            pair.second = nullptr;          // 设置为nullptr
        }
    }
    m_mapNoiseDetectThreads.clear();
    SPDLOG_LOGGER_INFO(m_logger, "{} 噪音检测线程销毁完成", m_logBase);
}

/* 获取噪音检测的线程 */
// bool CompareItemThread::getNoiseDetectThreads()
// {
//     for(const auto& road : m_threadInfo.compareItemInfo.mapRoad)
//     {
//         NoiseDetectThread* pThread = ThreadMan.getNoiseDetectThread(road.scRoadInfo, m_threadInfo.compareItemInfo.nID);
//         if(pThread == nullptr)
//         {
//             SPDLOG_LOGGER_ERROR(m_logger, "{} 获取噪音检测线程失败", m_logBase);
//             return false; // 获取线程失败
//         }
//         /* 向噪音检测线程写入对比项通道信息 */
//         pThread->startCompareItemNoiseAlarm(m_threadInfo.compareItemInfo.nID, m_threadInfo.compareItemInfo.strName, road);
//         m_mapNoiseDetectThreads.insert({road.nCompareRoadNum, pThread});
//     }

//     return true;
// }

/* 移除噪音检测的线程 */
// void CompareItemThread::removeNoiseDetectThreads()
// {
//     if(m_mapNoiseDetectThreads.size() == 0)
//     {
//         return; // 没有噪音检测线程
//     }
//     SPDLOG_LOGGER_INFO(m_logger, "{} 移除噪音检测线程", m_logBase);
//     for(auto& pair : m_mapNoiseDetectThreads)
//     {
//         if(pair.second != nullptr)
//         {
//             ThreadMan.removeNoiseDetectThread(pair.second->getRoadInfo(), m_threadInfo.compareItemInfo.nID);
//         }
//     }
//     m_mapNoiseDetectThreads.clear();
//     SPDLOG_LOGGER_INFO(m_logger, "{} 噪音检测线程移除完成", m_logBase);
// }


/**
 * @brief 更新数据
 *          更新数据逻辑：
 *              1、先从音量计算线程获取最新的音量包信息，如果没有全部更新，则等待下次获取，不进行后面的操作
 *              2、获取噪音检测线程的噪音信息和获取一致性信息的线程的结果无需关系是否是最新的
 * 
 */
bool CompareItemThread::updateResultData()
{
    /* -------------------------------------------------------------------------------------
     * 先从音量计算数据中获取音量包信息和报警信息（静音、过载、反相）
     * ------------------------------------------------------------------------------------- */
    for(auto& pair : m_mapCDBUpdated)
    {
        if(pair.second == true)
        {
            /* 已经更新过了 */
            continue;
        }
        CalculateDBThread* pThread = m_mapCalculateDBThreads[pair.first];
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 音量计算线程失效", m_logBase);
            continue;
        }
        /* 获取最新的音量数据，包括静音、过载、反向等报警信息 */
        if(!pThread->getlastVolumeInfo(m_compareResult.mapRoadVolumes[pair.first]))
        {
            continue; // 没有获取到最新数据，继续等待
        }
        /* 更新报警信息 */
        // m_mapAlarmSilence[pair.first] = pThread->getAlarm(EAlarmType::EAT_Silent);
        // m_mapAlarmOverload[pair.first] = pThread->getAlarm(EAlarmType::EAT_Overload);
        // m_mapAlarmPhase[pair.first] = pThread->getAlarm(EAlarmType::EAT_Reversed);

        pair.second = true; // 设置更新标志位为true
    }
    /* 判断是否全部更新，如果没有则返回，等待下次再次获取 */
    for(auto& pair : m_mapCDBUpdated)
    {
        if(false == pair.second)
        {
            // SPDLOG_LOGGER_DEBUG(m_logger, "{} 音量计算线程数据未全部更新，等待下次获取", m_logBase);
            return false;
        }
    }


    /* -------------------------------------------------------------------------------------
     * 获取噪音计算的结果(从噪音对比线程中获取)
     * ------------------------------------------------------------------------------------- */
    for(auto& pair : m_mapNoiseDetectThreads)
    {
        NoiseDetectThread* pThread = pair.second;
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 噪音检测线程失效", m_logBase);
            continue; // 跳过这个线程
        }
        /* 获取最新的噪音数据，噪音报警那个标志位貌似没用到 */
        m_compareResult.mapRoadVolumes[pair.first].isNoise = pThread->isNoise();
    }

    /* -------------------------------------------------------------------------------------
     * 从对比项中获取核对过后的一致性结果
     * ------------------------------------------------------------------------------------- */
    for(auto& pair : m_mapCompareDoubleThreads)
    {
        CompareDoubleThread* pThread = pair.second;
        if(pThread == nullptr)
        {
            SPDLOG_LOGGER_ERROR(m_logger, "{} 一致性对比线程失效", m_logBase);
            continue;
        }
        /* 获取最新的一致性结果 */
        OneRoadVolume_t roadVolume;
        if(pThread->getlastResult(roadVolume))
        {
            m_compareResult.mapRoadVolumes[pair.first].isConsistency = roadVolume.isConsistency;
            m_compareResult.mapRoadVolumes[pair.first].isNotConsistencyWarning = roadVolume.isNotConsistencyWarning;
        }
    }

    return true;
}



/**
    处理报警数据，现在的报警信息都是实时的，不再是报警结束后得到的数据了
    处理逻辑：
        1、如果是开始报警了，将报警信息发送给录制报警文件的线程，开始录音
        2、如果是结束报警了，将报警结束信息再次通知录制报警文件的线程，结束录音
           然后将报警信息发送给写入数据库的线程，写入到数据库中
        3、静音、过载、反相报警信息直接从计算音量的线程中获取，一致性报警从对比项线程中获取，
            噪音报警从噪音检测线程中获取
 */
// void CompareItemThread::processAlarmData()
// {
//     m_listWriteAlarm.clear();
//     /* 处理静音报警数据 */
//     for(auto& pair : m_mapAlarmSilence)
//     {
//         auto& nowAlarm = pair.second;
//         auto& lastAlarm = m_mapAlarmSilenceLast[pair.first];
//         if(nowAlarm.isAlarm)
//         {
//             if(lastAlarm == nowAlarm)
//             {
//                 continue; // 和上次的报警信息一样，不需要处理
//             }else {
//                 nowAlarm.CompareItemID = m_threadInfo.compareItemInfo.nID;
//                 nowAlarm.strCompareItemName = m_threadInfo.compareItemInfo.strName.toStdString();
//                 m_listWriteAlarm.push_back(nowAlarm);
//                 m_mapAlarmSilenceLast[pair.first] = nowAlarm;
//             }
//         }
//     }

//     /* 处理过载报警数据 */
//     for(auto& pair : m_mapAlarmOverload)
//     {
//         auto& nowAlarm = pair.second;
//         auto& lastAlarm = m_mapAlarmOverloadLast[pair.first];
//         if(nowAlarm.isAlarm)
//         {
//             if(lastAlarm == nowAlarm)
//             {
//                 continue; // 和上次的报警信息一样，不需要处理
//             }else {
//                 nowAlarm.CompareItemID = m_threadInfo.compareItemInfo.nID;
//                 nowAlarm.strCompareItemName = m_threadInfo.compareItemInfo.strName.toStdString();
//                 m_listWriteAlarm.push_back(nowAlarm);
//                 m_mapAlarmOverloadLast[pair.first] = nowAlarm;
//             }
//         }
//     }

//     /* 处理反相报警数据 */
//     for(auto& pair : m_mapAlarmPhase)
//     {
//         auto& nowAlarm = pair.second;
//         auto& lastAlarm = m_mapAlarmPhaseLast[pair.first];
//         if(nowAlarm.isAlarm)
//         {
//             if(lastAlarm == nowAlarm)
//             {
//                 continue; // 和上次的报警信息一样，不需要处理
//             }else {
//                 nowAlarm.CompareItemID = m_threadInfo.compareItemInfo.nID;
//                 nowAlarm.strCompareItemName = m_threadInfo.compareItemInfo.strName.toStdString();
//                 m_listWriteAlarm.push_back(nowAlarm);
//                 m_mapAlarmPhaseLast[pair.first] = nowAlarm;
//             }
//         }
//     }

//     /* 处理一致性报警信息 */

//     /* 处理噪音报警信息 */

    
//     /* 将报警列表写入到处理报警数据的线程中 */
//     AlarmManager.addAlarmInfo(m_listWriteAlarm);
// }

/* 发送数据 */
void CompareItemThread::sendResultData()
{
    if(m_pFromMQTT == nullptr)
    {
        SPDLOG_LOGGER_WARN(m_logger, "{} MQTT连接未初始化，无法发送数据", m_logBase);
        return;
    }
    /* 生成json数据 */
    QByteArray jsonData;
    if(!generateMQTTJsonData(m_compareResult, jsonData))
    {
        SPDLOG_LOGGER_WARN(m_logger, "{} 生成音量包 JSON数据失败", m_logBase);
        return;
    }
    /* 发送到mqtt中 */
    int errorCode = 0;
    if(!m_pFromMQTT->sendMessage(m_pubTopic, jsonData, 0, errorCode))
    {
        SPDLOG_LOGGER_ERROR(m_logger, "{} 发送音量包数据到 {} 失败，错误代码: {}", m_logBase, m_pubTopic.toStdString(), errorCode);
    }else {
        SPDLOG_LOGGER_DEBUG(m_logger, "{} 发送音量包数据到 {} 成功", m_logBase, m_pubTopic.toStdString());
    }
}

/* 清除标志更新位 */
void CompareItemThread::clearUpdateFlags()
{
    for(auto& pair : m_mapCDBUpdated)
    {
        pair.second = false; // 清除更新标志位
    }
}

/* 生成发送至MQTT的JSON数据 */
bool CompareItemThread::generateMQTTJsonData(const CompareResult_t& compareResult, QByteArray& jsonData)
{
    try 
    {
        /* 生成基础信息 */
        nJson json0;
        json0["compareItem_id"] = compareResult.compareItemID;
        json0["compareItem_name"] = compareResult.compareItemName.c_str();
        json0["date_time"] = compareResult.dateTime.toString("yyyy-MM-dd hh:mm:ss").toStdString();
        json0["is_client_alarm"] = compareResult.isClientAlarm;
        
        for(const auto& roadVolume : compareResult.mapRoadVolumes)
        {
            nJson json1;
            json1["soundCard_id"] = roadVolume.second.roadInfo.scRoadInfo.strSoundCardID.toStdString(); /* 声卡id和声卡通道id */
            json1["soundCard_road_id"] = roadVolume.second.roadInfo.scRoadInfo.roadInfo.nRoadNum;
            /* 对比项通道编号和名称 */
            json1["item_road_num"] = roadVolume.second.roadInfo.nCompareRoadNum;
            json1["item_road_name"] = roadVolume.second.roadInfo.strCompareRoadName.toStdString();
            json1["similarity"] = roadVolume.second.similarity;
            json1["is_silence"] = roadVolume.second.isSilence;
            json1["is_overload"] = roadVolume.second.isOverload;
            json1["is_reversed"] = roadVolume.second.isReversed;
            json1["is_noise"] = roadVolume.second.isNoise;
            json1["is_noise_warning"] = roadVolume.second.isNoiseWarning;
            json1["is_consistency"] = roadVolume.second.isConsistency;
            json1["is_not_consistency_warning"] = roadVolume.second.isNotConsistencyWarning;
            json1["left_real_time_db"] = roadVolume.second.leftRealTimeDB;
            json1["right_real_time_db"] = roadVolume.second.rightRealTimeDB;
            /* 添加音量包信息 */
            for(const auto& db : roadVolume.second.vecleftDB)
            {
                json1["left_db_array"].push_back(db);
            }
            for(const auto& db : roadVolume.second.vecrightDB)
            {
                json1["right_db_array"].push_back(db);
            }

            /* 添加到基础信息中 */
            json0["road_volumes"].push_back(json1);
        }

        /* 转换为字符串 */
        jsonData.clear();
        jsonData = QByteArray::fromStdString(json0.dump());

    }nJsonCatch

    return true;
}


/* 检查是否在检测时间段内，返回false，不开启检测 */
bool CompareItemThread::checkDetectPeriod()
{
    std::lock_guard<std::mutex> lock(m_mutexDetectPeriod);
    
    /* 先判断是否启用了该对比项，这个设置在对比项中设置 */
    if(!m_threadInfo.compareItemInfo.isEnable)
    {
        return false; // 对比项未启用，不进行检测
    }

    QDateTime currentTime = QDateTime::currentDateTime();
    int currentWeekday = currentTime.date().dayOfWeek(); // 获取当前星期几，1-7表示周日到周六
    /* 判断时段 */
    bool isInDetectPeriod = false;
    for(const auto& period : m_detectPeriod.listDetect)
    {
        /* 先判断是否有符合的周几 */
        if(static_cast<int>(period.weekType) == currentWeekday)
        {
            /* 判断当前时间是否在检测时段内 */
            if(currentTime.time() >= period.timeStart && currentTime.time() <= period.timeEnd)
            {
                isInDetectPeriod = true;
                break;
            }
        }
    }

    /* 再判断是否在非检测时间段内 */
    for(const auto& period : m_detectPeriod.listNoDetect)
    {
        /* 先判断日期 */
        if(period.date == currentTime.date())
        {
            /* 判断当前时间是否在非检测时段内 */
            if(currentTime.time() >= period.timeStart && currentTime.time() <= period.timeEnd)
            {
                isInDetectPeriod = false; // 在非检测时段内，不进行检测
                break;
            }
        }
    }

    /* 应用于对比项检测，对比项不设置日期不会进行检测 */
    for(auto& pThread : m_mapCompareDoubleThreads)
    {
        pThread.second->setInDetectPeriod(isInDetectPeriod);
    }

    /* 判断是否应用于静音、过载、反相检测 */
    for(auto& pThread : m_mapCalculateDBThreads)
    {
        if(m_detectPeriod.isApplySlient)
        {
            pThread.second->setSilenceInDetectPeriod(isInDetectPeriod);
        }else {
            /* 没有应用于静音检测，就一直检测 */
            pThread.second->setSilenceInDetectPeriod(true);
        }
        if(m_detectPeriod.isApplyOverload)
        {
            pThread.second->setOverloadInDetectPeriod(isInDetectPeriod);
        } else {
            /* 没有应用于过载检测，就一直检测 */
            pThread.second->setOverloadInDetectPeriod(true);
        }
        if(m_detectPeriod.isApplyPhase)
        {
            pThread.second->setPhaseInDetectPeriod(isInDetectPeriod);
        }else 
        {
            /* 没有应用于反相检测，就一直检测 */
            pThread.second->setPhaseInDetectPeriod(true);
        }
    }
    /* 应用于噪音检测 */
    for(auto& pThread : m_mapNoiseDetectThreads)
    {
        if(m_detectPeriod.isApplyNoise)
        {
            pThread.second->setInDetectPeriod(isInDetectPeriod);
        }else 
        {
            /* 没有应用于噪音检测，就一直检测 */
            pThread.second->setInDetectPeriod(true);
        }
    }

    return true;
}