server1/Server/ThreadManager/ThreadAlarmManager.h

#ifndef __THREADALARMMANAGER_H__
#define __THREADALARMMANAGER_H__

/**
 * @file ThreadAlarmManager.h
 * @author your name (you@domain.com)
 * @brief 
 * @version 0.1
 * @date 2025-07-19
 * 
 * @copyright Copyright (c) 2025
 *
 * 处理报警信息 
 */

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

#include <list>
#include <atomic>
#include <memory>
#include <mutex>



/**
    处理报警信息，所有的报警信息都由这个线程写入数据库
    
    1、报警信息列表分为两种，一种是静音、过载、反相、噪音等单个录音通道的报警信息，一种是一致性报警需要
        两个通道的关联的报警信息，这两种分别写入数据库，不相关联。
 */



#define AlarmManager ThreadAlarmManager::instance()

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

    /* 线程工作函数 */
    void thread_task();
    /* 停止线程 */
    void thread_stop();
    void thread_stopBlock();
    /* 获取线程状态 */
    EThreadState getThreadState() const { return m_threadState; }


    /* 添加报警内容 */
    void addAlarmInfo(const AlarmInfo_t& alarmInfo);
    void addAlarmInfo(const std::list<AlarmInfo_t>& listAlarm);
    
    /* 添加一致性报警信息，键为主通道信息，值为次通道信息 */
    void addAlarmInfo(const AlarmInfo_t& mainAlarm, const AlarmInfo_t& subAlarm);
    

private:
    /* 线程工作函数 */
    void task();
    /* 初始化数据 */
    bool initData();
    /* 清理数据 */
    void clearData();


private:
    std::shared_ptr<spdlog::logger> m_logger = nullptr;
    /* 线程基础信息 */
    std::atomic_bool m_isRunning = false;           /* 线程运行标志位 */
    std::atomic_bool m_isStop = false;              /* 线程停止标志位 */
    EThreadState m_threadState = EThreadState::State_None; /* 线程状态 */

    FromWebAPI m_fromWebAPI;

    /* 存储一般的报警信息 */
    std::mutex m_mutexListAlarm;                    /* 报警信息列表的互斥锁 */
    std::list<AlarmInfo_t> m_listAlarm;             /* 报警信息列表 */
    
    /* 存储一致性报警信息 */
    std::mutex m_mutexListAlarmConsistency;         /* 一致性报警信息列表的互斥锁 */
    /* 一致性报警信息列表，键是主通道信息，值是次通道信息 */
    std::list<std::pair<AlarmInfo_t, AlarmInfo_t>> m_listAlarmConsistency;
};



#endif // __THREADALARMMANAGER_H__