#include "stdafx.h"
#include "Common.h"
#include "AlarmManager.h"
#include <sstream>
#include <fstream>
#include <iostream>
#include <stdexcept>
#include <ctime>
#include <iomanip>
#include <random>

// ³£Á¿
const std::string DATABASE_FILE = R"(AlarmManager.db)";

// ¾²Ì¬³ÉÔ±³õʼ»¯
std::mutex AlarmManager::m_mutex;

// »ñÈ¡µ¥ÀýʵÀý
AlarmManager& AlarmManager::getInstance() {
    static AlarmManager instance;
    return instance;
}

// ¹¹Ô캯Êý
AlarmManager::AlarmManager() {
	m_pDB = new BL::SQLiteDatabase();
}

// Îö¹¹º¯Êý
AlarmManager::~AlarmManager() {
    if (m_pDB != nullptr) {
        delete m_pDB;
        m_pDB = nullptr;
    }
}

// ³õʼ»¯±¨¾¯±í
bool AlarmManager::initAlarmTable() {
    char path[MAX_PATH];
    GetModuleFileName(NULL, path, MAX_PATH);
    std::string exePath(path);
    std::string dbFileDir = exePath.substr(0, exePath.find_last_of("\\/")) + "\\DB";
	if (!CreateDirectory(dbFileDir.c_str(), NULL) && ERROR_ALREADY_EXISTS != GetLastError()) {
		throw std::runtime_error("Failed to create database directory.");
	}

    std::string dbFilePath = dbFileDir + "\\" + DATABASE_FILE;
    if (!m_pDB->connect(dbFilePath, true)) {
        throw std::runtime_error("Failed to connect to database.");
    }

    // ´´½¨É豸±í
    const std::string createDevicesTableQuery = R"(
        CREATE TABLE IF NOT EXISTS devices (
            device_id TEXT PRIMARY KEY NOT NULL,
            device_name TEXT NOT NULL
        )
    )";
    if (!m_pDB->executeQuery(createDevicesTableQuery)) {
        return false;
    }

    // ´´½¨µ¥Ôª±í£¬É豸IDºÍµ¥ÔªID×éºÏ×÷ΪÖ÷¼ü
    const std::string createUnitsTableQuery = R"(
        CREATE TABLE IF NOT EXISTS units (
            device_id TEXT NOT NULL,
            unit_id TEXT NOT NULL,
            unit_name TEXT NOT NULL,
            PRIMARY KEY (device_id, unit_id),
            FOREIGN KEY (device_id) REFERENCES devices(device_id)
        )
    )";
    if (!m_pDB->executeQuery(createUnitsTableQuery)) {
        return false;
    }

    // ´´½¨±¨¾¯±í£¬±¨¾¯¼Ç¼µÄalarm_event_idÊÇÖ÷¼ü
    const std::string createAlarmsTableQuery = R"(
        CREATE TABLE IF NOT EXISTS alarms (
            alarm_event_id INTEGER PRIMARY KEY AUTOINCREMENT,
            id TEXT NOT NULL,
            severity_level INTEGER NOT NULL DEFAULT 0,    
            device_id TEXT NOT NULL ,
            unit_id TEXT NOT NULL,
            description TEXT NOT NULL,
            start_time DATETIME NOT NULL,
            end_time DATETIME,
            FOREIGN KEY (device_id) REFERENCES devices(device_id),
            FOREIGN KEY (unit_id) REFERENCES units(unit_id)
        )
    )";
    if (!m_pDB->executeQuery(createAlarmsTableQuery)) {
        return false;
    }

    // É豸Áбí (ID -> Ãû³Æ)
    std::vector<std::pair<int, std::string>> devices = {
        {EQ_ID_LOADPORT1, EQ_NAME_LOADPORT1},
        {EQ_ID_LOADPORT2, EQ_NAME_LOADPORT2},
        {EQ_ID_LOADPORT3, EQ_NAME_LOADPORT3},
        {EQ_ID_LOADPORT4, EQ_NAME_LOADPORT4},
        {EQ_ID_ARM_TRAY1, EQ_NAME_ARM_TRAY1},
        {EQ_ID_ARM_TRAY2, EQ_NAME_ARM_TRAY2},
        {EQ_ID_ALIGNER, EQ_NAME_ALIGNER},
        {EQ_ID_FLIPER, EQ_NAME_FLIPER},
        {EQ_ID_VACUUMBAKE, EQ_NAME_VACUUMBAKE},
        {EQ_ID_Bonder1, EQ_NAME_BONDER1},
        {EQ_ID_Bonder2, EQ_NAME_BONDER2},
        {EQ_ID_BAKE_COOLING, EQ_NAME_BAKE_COOLING},
        {EQ_ID_MEASUREMENT, EQ_NAME_MEASUREMENT},
        {EQ_ID_EFEM, EQ_NAME_EFEM},
        {EQ_ID_ARM, EQ_NAME_ARM},
        {EQ_ID_OPERATOR_REMOVE, EQ_NAME_OPERATOR_REMOVE}
    };

    // ²åÈë devices ºÍ¶ÔÓ¦µÄĬÈÏ unit
    for (const auto& dev : devices) {
        int nDeviceId = dev.first;
        const std::string& strDeviceName = dev.second;

        // ²åÈëÉ豸
        std::ostringstream ossDev;
        ossDev << "INSERT OR IGNORE INTO devices (device_id, device_name) VALUES("
            << nDeviceId << ", '" << strDeviceName << "')";
        if (!m_pDB->executeQuery(ossDev.str())) {
            return false;
        }

        // ²åÈëĬÈϵ¥Ôª (unit_id = 0, unit_name = device_name)
        std::ostringstream ossUnit;
        ossUnit << "INSERT OR IGNORE INTO units (device_id, unit_id, unit_name) VALUES("
            << nDeviceId << ", 0, '" << strDeviceName << "')";
        if (!m_pDB->executeQuery(ossUnit.str())) {
            return false;
        }
    }

    return true;
}

// Ïú»Ù±¨¾¯±í
void AlarmManager::termAlarmTable() {
    if (m_pDB != nullptr) {
		m_pDB->disconnect();
    }
}

// Ïú»Ù±¨¾¯±í
bool AlarmManager::destroyAlarmTable() {
	if (!m_pDB) {
		throw std::runtime_error("Database connection is not set.");
	}
	const std::string dropTableQuery = "DROP TABLE IF EXISTS alarms";
	return m_pDB->executeQuery(dropTableQuery);
}

// ²åÈëÄ£ÄâÊý¾Ý
void AlarmManager::insertMockData() {
    // ²åÈëÉ豸Êý¾Ý
    for (int i = 1; i <= 3; ++i) {
        std::string deviceName = "Device" + std::to_string(i);
        std::stringstream query;
        query << "INSERT INTO devices (device_id, device_name) VALUES (" << i << ", '" << deviceName << "');";
        if (!m_pDB->executeQuery(query.str())) {
            std::cerr << "Failed to insert device: " << i << std::endl;
        }
    }

    // ²åÈëµ¥ÔªÊý¾Ý
    for (int i = 1; i <= 3; ++i) {
        for (int j = 0; j <= 3; ++j) {
            int unitId = j;
            std::string deviceId = std::to_string(i);
            std::string unitName = "Unit" + std::to_string(j);

            std::stringstream query;
            query << "INSERT INTO units (device_id, unit_id, unit_name) VALUES ('"
                << deviceId << "', '"   // ²åÈëÉ豸ID£¬È·±£ÊÇ×Ö·û´®
                << unitId << "', '"     // ²åÈëµ¥ÔªID£¬È·±£ÊÇ×Ö·û´®
                << unitName << "');";

            if (!m_pDB->executeQuery(query.str())) {
                std::cerr << "Failed to insert unit: " << unitId << std::endl;
            }
        }
    }

    /*
    // ³õʼ»¯Ëæ»úÊýÉú³ÉÆ÷
    std::random_device rd;
    std::mt19937 gen(rd());
    std::uniform_int_distribution<> deviceDis(1, 3);
    std::uniform_int_distribution<> unitDis(1, 3);
    std::uniform_int_distribution<> errorCodeDis(1, 100);
    std::uniform_int_distribution<> severityDis(0, 3);
    std::vector<std::string> descriptions = { "Overheat", "Sensor failure", "Power outage" };

    // ʱ¼äÏà¹Ø
    auto now = std::chrono::system_clock::now();
    auto start_time = std::chrono::system_clock::to_time_t(now);
    auto end_time = std::chrono::system_clock::to_time_t(now + std::chrono::minutes(10));

    std::tm start_tm = {};
    std::tm end_tm = {};
    localtime_s(&start_tm, &start_time);
    localtime_s(&end_tm, &end_time);

    // ²åÈëÄ£ÄâÊý¾Ý
    for (int i = 0; i < 10; ++i) {
        int deviceId = deviceDis(gen);          // Ëæ»úÉ豸ID
        int unitId = unitDis(gen);              // Ëæ»úµ¥ÔªID
        int errorCode = errorCodeDis(gen);      // Ëæ»ú´íÎóÂë
        int severityLevel = severityDis(gen);   // Ëæ»úÉú³É±¨¾¯µÈ¼¶
        std::string description = descriptions[errorCodeDis(gen) % descriptions.size()];  // Ëæ»ú±¨¾¯ÃèÊö

        std::stringstream query;
        query << "INSERT INTO alarms (id, severity_level, device_id, unit_id, description, start_time, end_time) "
            << "VALUES (" << errorCode << ", " << severityLevel << ", " << deviceId << ", " << unitId << ", '" << description << "', "
            << "'" << std::put_time(&start_tm, "%Y-%m-%d %H:%M:%S") << "', "
            << "'" << std::put_time(&end_tm, "%Y-%m-%d %H:%M:%S") << "');";

        if (!m_pDB->executeQuery(query.str())) {
            std::cerr << "Failed to insert alarm data." << std::endl;
        }
    }
    */
}

// Ìí¼Ó±¨¾¯ÐÅÏ¢
bool AlarmManager::addAlarm(const AlarmData& alarmData, int& alarmEventId) {
    if (!m_pDB) {
        return false;
    }

    #if 0
        // ¿ªÊ¼ÊÂÎñ
        m_pDB->executeQuery("BEGIN TRANSACTION;");
    
        // ¹¹½¨²åÈë²éѯ
        std::ostringstream query;
        query << "INSERT INTO alarms (id, severity_level, device_id, unit_id, description, start_time, end_time) VALUES ("
            << alarmData.nId << ", "              // ´íÎóÂë
            << alarmData.nSeverityLevel << ", "   // ±¨¾¯µÈ¼¶
            << alarmData.nDeviceId << ", "        // É豸ID
            << alarmData.nUnitId << ", '"         // µ¥ÔªID
            << alarmData.strDescription << "', '" // ÃèÊö
            << alarmData.strStartTime << "', '"   // ¿ªÊ¼Ê±¼ä
            << alarmData.strEndTime << "')";      // ½áÊøʱ¼ä
    
        // ʹÓÃËø±£»¤¶àḬ̈߳²È«
        std::lock_guard<std::mutex> lock(m_mutex);
    
        // Ö´ÐвåÈë²éѯ
        bool result = m_pDB->executeQuery(query.str());
        if (result) {
            alarmEventId = getLastInsertId();
            m_alarmCache[alarmEventId] = alarmData;
        }
    
        // Ìá½»ÊÂÎñ
        m_pDB->executeQuery("COMMIT;");
    
        return result;
    #else
        for (AlarmDataMap::const_iterator it = m_mapCache.begin(); it != m_mapCache.end(); ++it) {
            const AlarmData& alarm = it->second;
            if (alarm.nId == alarmData.nId &&
                alarm.nDeviceId == alarmData.nDeviceId &&
                alarm.nUnitId == alarmData.nUnitId) {

                alarmEventId = it->first;
                return false;
            }
        }

        // ¹¹½¨²åÈë²éѯ²¢Ê¹Óà RETURNING »ñÈ¡²åÈëºóµÄ alarm_event_id
        std::ostringstream query;
        query << "INSERT INTO alarms (id, severity_level, device_id, unit_id, description, start_time, end_time) "
            << "VALUES (" << alarmData.nId << ", " << alarmData.nSeverityLevel << ", " << alarmData.nDeviceId << ", "
            << alarmData.nUnitId << ", '" << alarmData.strDescription << "', '" << alarmData.strStartTime << "', '"
            << alarmData.strEndTime << "') RETURNING alarm_event_id;";
    
        // ʹÓÃËø±£»¤¶àḬ̈߳²È«
        std::lock_guard<std::mutex> lock(m_mutex);
    
        // Ö´Ðвéѯ²¢»ñÈ¡½á¹û
        auto results = m_pDB->fetchResults(query.str());
        if (!results.empty() && !results[0].empty()) {
            try {
                // ÌáÈ¡²¢×ª»» alarm_event_id
                alarmEventId = std::stoi(results[0][0]);
                // ½«²åÈëµÄ±¨¾¯Êý¾ÝÌí¼Óµ½»º´æ
                m_mapCache[alarmEventId] = alarmData;
                return true;
            }
            catch (const std::exception& e) {
                std::cerr << "Error parsing alarm_event_id: " << e.what() << std::endl;
                return false;
            }
        }
    
        return false;
    #endif
}

// ²éѯËùÓб¨¾¯Êý¾Ý
std::vector<AlarmData> AlarmManager::getAllAlarms() {
    if (!m_pDB) {
        return {};
    }

    // ²éѯËùÓб¨¾¯Êý¾Ý£¨°üÀ¨É豸Ãû³ÆºÍµ¥ÔªÃû³Æ£©
    const std::string query = R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
    )";

    auto results = m_pDB->fetchResults(query);

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ¸ù¾Ý±¨¾¯ID²éѯ±¨¾¯
std::vector<AlarmData> AlarmManager::getAlarmsById(const std::string& id) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE a.id = ')" << id << "'";

    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ¸ù¾ÝÃèÊö²éѯ±¨¾¯
std::vector<AlarmData> AlarmManager::getAlarmsByDescription(const std::string& description) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE a.description LIKE '%)" << description << R"(%')";

    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ¸ù¾Ýʱ¼ä·¶Î§²éѯ±¨¾¯
std::vector<AlarmData> AlarmManager::getAlarmsByTimeRange(const std::string& startTime, const std::string& endTime) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE 1=1)";

    if (!startTime.empty()) {
        query << " AND a.start_time >= '" << startTime << "'";
    }
    if (!endTime.empty()) {
        query << " AND a.end_time <= '" << endTime << "'";
    }

    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ¸ù¾ÝID¡¢¿ªÊ¼Ê±¼äºÍ½áÊøʱ¼ä²éѯ±¨¾¯
std::vector<AlarmData> AlarmManager::getAlarmsByIdAndTimeRange(const std::string& id, const std::string& startTime, const std::string& endTime) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE a.id = ')" << id << "'";

    if (!startTime.empty()) {
        query << " AND a.start_time >= '" << startTime << "'";
    }
    if (!endTime.empty()) {
        query << " AND a.end_time <= '" << endTime << "'";
    }

    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ·ÖÒ³²éѯ±¨¾¯Êý¾Ý
std::vector<AlarmData> AlarmManager::getAlarms(int startPosition, int count) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        LIMIT )" << count << " OFFSET " << startPosition;

    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);              // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);   // ±¨¾¯µÈ¼¶
        alarmData.nDeviceId = std::stoi(row[2]);        // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);          // µ¥ÔªID
        alarmData.strDeviceName = row[4];               // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                 // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];              // ÃèÊö
        alarmData.strStartTime = row[7];                // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                  // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// ɸѡ±¨¾¯Êý¾Ý
std::vector<AlarmData> AlarmManager::getFilteredAlarms(const std::string& keyword, const std::string& startTime, const std::string& endTime, int pageNumber, int pageSize) {
    if (!m_pDB) {
        return {};
    }

    std::ostringstream query;
    query << R"(
        SELECT a.id, a.severity_level, a.device_id, a.unit_id, d.device_name, u.unit_name, a.description, a.start_time, a.end_time
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u   ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE 1=1)";

    // ͳһ¹Ø¼ü×ÖÄ£ºý²éѯ
    if (!keyword.empty()) {
        query << " AND ("
            << "a.id LIKE '%" << keyword << "%' OR "
            << "a.severity_level LIKE '%" << keyword << "%' OR "
            << "d.device_name LIKE '%" << keyword << "%' OR "
            << "u.unit_name LIKE '%" << keyword << "%' OR "
            << "a.description LIKE '%" << keyword << "%')";
    }

    // ʱ¼äÌõ¼þ
    if (!startTime.empty()) {
        query << " AND a.start_time >= '" << startTime << "'";
    }
    if (!endTime.empty()) {
        query << " AND a.end_time <= '" << endTime << "'";
    }

    // ·ÖÒ³ÉèÖÃ
    int nOffset = (pageNumber - 1) * pageSize;
    query << " ORDER BY a.start_time DESC LIMIT " << pageSize << " OFFSET " << nOffset;

    // ²éѯ
    auto results = m_pDB->fetchResults(query.str());

    // ±éÀú²éѯ½á¹û£¬Ìî³ä AlarmData ½á¹¹Ìå
    std::vector<AlarmData> alarms;
    for (const auto& row : results) {
        AlarmData alarmData;
        alarmData.nId = std::stoi(row[0]);             // ´íÎóÂë
        alarmData.nSeverityLevel = std::stoi(row[1]);  // ±¨¾¯µÈ¼¶ (×Ö·û´®)
        alarmData.nDeviceId = std::stoi(row[2]);       // É豸ID
        alarmData.nUnitId = std::stoi(row[3]);         // µ¥ÔªID
        alarmData.strDeviceName = row[4];              // É豸Ãû³Æ
        alarmData.strUnitName = row[5];                // µ¥ÔªÃû³Æ
        alarmData.strDescription = row[6];             // ÃèÊö
        alarmData.strStartTime = row[7];               // ¿ªÊ¼Ê±¼ä
        alarmData.strEndTime = row[8];                 // ½áÊøʱ¼ä

        alarms.push_back(alarmData);
    }

    return alarms;
}

// »ñÈ¡·ûºÏÌõ¼þµÄ±¨¾¯×ÜÊý
int AlarmManager::getTotalAlarmCount(const std::string& keyword, const std::string& startTime, const std::string& endTime) {
    if (!m_pDB) {
        return 0;
    }

    std::ostringstream query;
    query << R"(
        SELECT COUNT(*)
        FROM alarms a
        JOIN devices d ON a.device_id = d.device_id
        JOIN units u   ON a.device_id = u.device_id AND a.unit_id = u.unit_id
        WHERE 1=1)";

    // ͳһ¹Ø¼ü×ÖÄ£ºý²éѯ
    if (!keyword.empty()) {
        query << " AND ("
            << "a.id LIKE '%" << keyword << "%' OR "
            << "a.severity_level LIKE '%" << keyword << "%' OR "
            << "d.device_name LIKE '%" << keyword << "%' OR "
            << "u.unit_name LIKE '%" << keyword << "%' OR "
            << "a.description LIKE '%" << keyword << "%')";
    }

    // ʱ¼äÌõ¼þ
    if (!startTime.empty()) {
        query << " AND a.start_time >= '" << startTime << "'";
    }
    if (!endTime.empty()) {
        query << " AND a.end_time <= '" << endTime << "'";
    }

    auto results = m_pDB->fetchResults(query.str());
    return (!results.empty() && !results[0].empty()) ? std::stoi(results[0][0]) : 0;
}

// ¸üб¨¾¯µÄ½áÊøʱ¼ä
bool AlarmManager::updateAlarmEndTime(
    const std::string& id,
    const std::string& severityLevel,
    const std::string& deviceId,
    const std::string& unitId,
    const std::string& description,
    const std::string& startTime,
    const std::string& newEndTime) {

    if (!m_pDB) {
        return false;
    }

    // ¸üб¨¾¯½áÊøʱ¼ä
    std::ostringstream updateQuery;
    updateQuery << "UPDATE alarms SET end_time = '" << newEndTime << "'"
        << " WHERE id = '" << id << "'"
        << " AND severity_level = '" << severityLevel << "'"
        << " AND device_id = '" << deviceId << "'"
        << " AND unit_id = '" << unitId << "'"
        << " AND description = '" << description << "'"
        << " AND start_time = '" << startTime << "'";

    return m_pDB->executeQuery(updateQuery.str());
}

// ÇåÀí¾É±¨¾¯Êý¾Ý
void AlarmManager::cleanOldAlarms(int daysToKeep, const std::string& deviceId, const std::string& unitId) {
    if (!m_pDB) {
        return;
    }

    std::ostringstream query;
    query << "DELETE FROM alarms WHERE end_time < datetime('now', '-" << daysToKeep << " days')";

    if (!deviceId.empty()) {
        query << " AND device_id = '" << deviceId << "'";
    }
    if (!unitId.empty()) {
        query << " AND unit_id = '" << unitId << "'";
    }

    m_pDB->executeQuery(query.str());
}

// ͨ¹ýÉ豸ID»ñÈ¡É豸Ãû³Æ
std::string AlarmManager::getDeviceNameById(int deviceId) {
    if (!m_pDB) {
        return "";
    }

    std::ostringstream query;
    query << "SELECT device_name FROM devices WHERE device_id = " << deviceId;

    auto result = m_pDB->fetchResults(query.str());
    if (result.empty()) {
        return "";
    }

    return result[0][0];  // ·µ»Ø²éѯµ½µÄÉ豸Ãû³Æ
}

// ͨ¹ýÉ豸IDºÍµ¥ÔªID»ñÈ¡µ¥ÔªÃû³Æ
std::string AlarmManager::getUnitNameById(int deviceId, int unitId) {
    if (!m_pDB) {
        return "";
    }

    std::ostringstream query;
    query << "SELECT unit_name FROM units WHERE device_id = " << deviceId
        << " AND unit_id = " << unitId;

    auto result = m_pDB->fetchResults(query.str());
    if (result.empty()) {
        return "";
    }

    return result[0][0];  // ·µ»Ø²éѯµ½µÄµ¥ÔªÃû³Æ
}

// »ñÈ¡×î½ü²åÈëµÄ alarm_event_id
int AlarmManager::getLastInsertId() {
    std::string query = "SELECT last_insert_rowid();";
    auto results = m_pDB->fetchResults(query);

    if (results.empty() || results[0].empty()) {
        return -1;
    }

    // ´Ó²éѯ½á¹ûÖлñÈ¡×îºó²åÈëµÄ ID
    int lastInsertId = std::stoi(results[0][0]);
    return lastInsertId;
}

// ͨ¹ý alarm_event_id ½â³ý±¨¾¯£¨¸üнáÊøʱ¼ä£©
bool AlarmManager::clearAlarmByEventId(int alarmEventId, const std::string& endTime) {
    if (!m_pDB) {
        return false;
    }

    bool result = true;
    auto it = m_mapCache.find(alarmEventId);
    if (it != m_mapCache.end()) {
        std::lock_guard<std::mutex> lock(m_mutex);

        std::ostringstream query;
        query << "UPDATE alarms SET end_time = '" << endTime << "' WHERE alarm_event_id = " << alarmEventId << ";";
        bool result = m_pDB->executeQuery(query.str());
        if (result) {
            m_mapCache.erase(it);
        }
    }

    return result;
}

// ͨ¹ý¶à¸öÊôÐÔ²éÕÒ²¢½â³ý±¨¾¯£¨¸üнáÊøʱ¼ä£©
bool AlarmManager::clearAlarmByAttributes(int nId, int nDeviceId, int nUnitId, const std::string& endTime) {
    if (!m_pDB) {
        return false;
    }

    std::lock_guard<std::mutex> lock(m_mutex);

    // ÏÈÔÚ»º´æÖвéÕÒÆ¥ÅäµÄ alarm_event_id
    int alarmEventId = -1;
    for (AlarmDataMap::const_iterator it = m_mapCache.begin(); it != m_mapCache.end(); ++it) {
        const AlarmData& alarm = it->second;
        if (alarm.nId == nId &&
            alarm.nDeviceId == nDeviceId &&
            alarm.nUnitId == nUnitId) {

            alarmEventId = it->first;
            break;
        }
    }

    // Èç¹ûûÕÒµ½Æ¥ÅäµÄ¼Ç¼£¬ÔòÖ±½Ó·µ»Ø false
    if (alarmEventId == -1) {
        return false;
    }

    // ¹¹½¨ SQL Óï¾ä£¬Ê¹ÓÃÕÒµ½µÄ alarm_event_id À´¸üнáÊøʱ¼ä
    std::ostringstream query;
    query << "UPDATE alarms SET end_time = '" << endTime << "' WHERE alarm_event_id = " << alarmEventId << ";";
    bool result = m_pDB->executeQuery(query.str());
    if (result) {
        m_mapCache.erase(alarmEventId);
    }

    return result;
}

// ¶ÁÈ¡±¨¾¯Îļþ
bool AlarmManager::readAlarmFile(const std::string& filename) {
    std::ifstream file(filename, std::ios::binary);
    if (!file.is_open()) {
        std::cerr << "Error opening file!" << std::endl;
        return false;
    }

    auto getline_cross = [](std::ifstream& f, std::string& out) -> bool {
        out.clear();
        char ch;
        while (f.get(ch)) {
            if (ch == '\r') {
                // ´¦Àí \r\n »ò µ¥¶À \r
                if (f.peek() == '\n') f.get();
                break;
            }
            else if (ch == '\n') {
                break;
            }
            out.push_back(ch);
        }
        return !out.empty() || !f.eof();
    };

    std::string line;
    bool first_line = true;

    while (getline_cross(file, line)) {
        if (first_line) {
            first_line = false;
            continue;
        }

        std::stringstream ss(line);
        std::string cell;
        AlarmInfo alarm;

        try {
            if (!std::getline(ss, cell, ',')) throw std::runtime_error("Missing field: No");
            if (!std::getline(ss, alarm.strUnitID, ',')) throw std::runtime_error("Missing field: UnitID");
            if (!std::getline(ss, alarm.strUnitNo, ',')) throw std::runtime_error("Missing field: UnitNo");
            if (!std::getline(ss, cell, ',')) throw std::runtime_error("Missing field: AlarmLevel");
            alarm.nAlarmLevel = std::stoi(cell);
            if (!std::getline(ss, cell, ',')) throw std::runtime_error("Missing field: AlarmCode");
            alarm.nAlarmCode = std::stoi(cell);
            if (!std::getline(ss, cell, ',')) throw std::runtime_error("Missing field: AlarmID");
            alarm.nAlarmID = std::stoi(cell);
            if (!std::getline(ss, alarm.strAlarmText, ',')) throw std::runtime_error("Missing field: AlarmText");
            if (!std::getline(ss, alarm.strDescription, ',')) throw std::runtime_error("Missing field: Description");

            if (m_mapAlarm.find(alarm.nAlarmID) == m_mapAlarm.end()) {
                m_mapAlarm[alarm.nAlarmID] = alarm;
            }
            else {
                std::cerr << "Duplicate AlarmID: " << alarm.nAlarmID << std::endl;
            }
        }
        catch (const std::exception& e) {
            std::cerr << "Error parsing line: " << line << " - " << e.what() << std::endl;
            continue;
        }
    }

    file.close();
    return true;
}

// ½«±¨¾¯Êý¾Ý±£´æµ½Îļþ
bool AlarmManager::saveAlarmFile(const std::string& filename) {
    std::ofstream file(filename);

    if (!file.is_open()) {
        std::cerr << "´ò¿ªÎļþдÈëʧ°Ü!" << std::endl;
        return false;
    }

    // дÈë±êÌâÐÐ
    file << "No,UNIT ID,UNIT NO,Alarm Level,Alarm Code,AlarmID,Alarm Text,Description\n";

    // дÈ뱨¾¯Êý¾Ý
    int nIndex = 1;
    for (const auto& pair : m_mapAlarm) {
        const AlarmInfo& alarm = pair.second;
        file << nIndex++ << ","
            << alarm.strUnitID << ","
            << alarm.strUnitNo << ","
            << alarm.nAlarmLevel << ","
            << alarm.nAlarmCode << ","
            << alarm.nAlarmID << ","
            << alarm.strAlarmText << ","
            << alarm.strDescription << "\n";
    }

    file.close();
    return true;
}

// ͨ¹ý AlarmID ²éѯ¶ÔÓ¦µÄ±¨¾¯ÐÅÏ¢
const AlarmInfo* AlarmManager::getAlarmInfoByID(int nAlarmID) const {
    auto it = m_mapAlarm.find(nAlarmID);
    if (it != m_mapAlarm.end()) {
        return &(it->second);
    }
    else {
        std::cerr << "δÕÒµ½ AlarmID: " << nAlarmID << std::endl;
        return nullptr;
    }
}

// ͨ¹ý¶à¸ö AlarmID ²éѯ¶ÔÓ¦µÄ±¨¾¯ÐÅÏ¢
std::vector<AlarmInfo> AlarmManager::getAlarmsInfoByIDs(const std::vector<int>& alarmIDs) const {
    std::vector<AlarmInfo> alarms;

    for (int alarmID : alarmIDs) {
        auto it = m_mapAlarm.find(alarmID);
        if (it != m_mapAlarm.end()) {
            alarms.push_back(it->second);
        } 
        else {
            std::cerr << "δÕÒµ½ AlarmID: " << alarmID << std::endl;
        }
    }

    return alarms;
}