| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 设置数据库连接 |
|---|
| | | void AlarmManager::setDatabase(BL::Database* db) { |
|---|
| | | std::lock_guard<std::mutex> lock(m_mutex); |
|---|
| | | m_pDB = db; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 初始化报警表 |
|---|
| | | bool AlarmManager::initAlarmTable() { |
|---|
| | | char path[MAX_PATH]; |
|---|
| | |
|---|
| | | |
|---|
| | | 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) " |
|---|
