From a25fffe157ee044e65318998827398941e7a42a4 Mon Sep 17 00:00:00 2001
From: Darker <mr.darker@163.com>
Date: 星期一, 03 三月 2025 18:13:48 +0800
Subject: [PATCH] 1.修改添加报警记录的方法 2.添加获取最后一次添加的事件id的方法
---
SourceCode/Bond/Servo/AlarmDlg.cpp | 186 ++++++++++++++++++++++++++--------------------
1 files changed, 105 insertions(+), 81 deletions(-)
diff --git a/SourceCode/Bond/Servo/AlarmDlg.cpp b/SourceCode/Bond/Servo/AlarmDlg.cpp
index 4da1912..24721b8 100644
--- a/SourceCode/Bond/Servo/AlarmDlg.cpp
+++ b/SourceCode/Bond/Servo/AlarmDlg.cpp
@@ -5,7 +5,8 @@
#include "Servo.h"
#include "afxdialogex.h"
#include "AlarmDlg.h"
-#include "AlarmManager.h"
+#include "Common.h"
+#include <iomanip>
#define PAGE_SIZE 10
#define PAGE_BACKGROUND_COLOR RGB(252, 252, 255)
@@ -21,7 +22,9 @@
m_hbrBkgnd = nullptr;
m_pObserver = nullptr;
- m_strEqName = "";
+ m_nSeverityLevel = 0;
+ m_strDeviceName = "";
+ m_strUnitName = "";
m_strKeyword = "";
m_nCurPage = 0;
m_nTotalPages = 0;
@@ -48,18 +51,46 @@
// onNext
pAny->addRef();
int code = pAny->getCode();
- //if (RX_CODE_ALARM_ON == code) {
- // CAlarm* pAlarm;
- // if (pAny->getObject("obj", (IRxObject*&)pAlarm)) {
- // AddAlarm(nullptr, pAlarm);
- // }
- //}
- //else if (RX_CODE_ALARM_OFF == code) {
- // CAlarm* pAlarm;
- // if (pAny->getObject("obj", (IRxObject*&)pAlarm)) {
- // UpdateAlarm(nullptr, pAlarm);
- // }
- //}
+
+ if (RX_CODE_STEP_EVENT_READDATA == code) {
+ LOGI("<CAlarmDlg> Accept RX_CODE_STEP_EVENT_READDATA successfully!");
+ // 閫氱煡璁惧鐘舵��
+ SERVO::CEqAlarmStep* pStep = nullptr;
+ if (pAny->getPtrValue("ptr", (void*&)pStep)) {
+ if (pStep != nullptr) {
+ // 鑾峰彇 AlarmManager 鍗曚緥
+ AlarmManager& alarmManager = AlarmManager::getInstance();
+
+ // 浠� pStep 鑾峰彇闇�瑕佺殑鍙傛暟锛屽亣璁捐繖浜涘�兼槸浠� pStep 涓幏鍙栫殑
+ AlarmData alarmData;
+ alarmData.nId = pStep->getAlarmId();
+ alarmData.nSeverityLevel = pStep->getAlarmLevel();
+ alarmData.nDeviceId = pStep->getAlarmDev();
+ alarmData.nUnitId = pStep->getUnitId();
+ alarmData.strDeviceName = alarmManager.getDeviceNameById(alarmData.nDeviceId);
+ alarmData.strUnitName = alarmManager.getUnitNameById(alarmData.nDeviceId, alarmData.nUnitId);
+ alarmData.strDescription = pStep->getText();
+ alarmData.strStartTime = getCurrentTimeString();
+ alarmData.strEndTime = "2000-01-01 00:00";
+
+ // 鎻掑叆鍒楄〃鎺т欢
+ CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST_ALARM);
+ if (pListCtrl != nullptr) {
+ InsertAlarmData(pListCtrl, alarmData);
+ }
+
+ // 娣诲姞鏂扮殑 Alarm 鏁版嵁
+ int alarmEventId = 0;
+ bool result = alarmManager.addAlarm(alarmData, alarmEventId);
+ if (result) {
+ LOGI("<CAlarmDlg> Alarm added successfully!");
+ }
+ else {
+ LOGI("<CAlarmDlg> Failed to add alarm.");
+ }
+ }
+ }
+ }
pAny->release();
}, [&]() -> void {
@@ -69,8 +100,8 @@
pThrowable->printf();
});
- //theApp.m_model.getObservable()->observeOn(pRxWindows->mainThread())
- // ->subscribe(m_pObserver);
+ theApp.m_model.getObservable()->observeOn(pRxWindows->mainThread())
+ ->subscribe(m_pObserver);
}
}
@@ -86,57 +117,15 @@
void CAlarmDlg::LoadAlarms()
{
- //CAlarmMonitor* pMonitor = (CAlarmMonitor*)theApp.m_model.getBonder().GetComponent(ALARM_MONITOR);
-
- // 褰撳墠姝ｅ湪鍙戠敓鐨勬姤璀�
- //pMonitor->Lock();
- //std::map<int, CAlarm*>& alarmings = pMonitor->getAlarmingMap();
- //for (auto item : alarmings) {
- // AddAlarm(pMonitor, item.second);
- //}
- //pMonitor->Unlock();
-
// 鍒锋柊鍘嗗彶鎶ヨ鏁版嵁
m_nCurPage = 1;
UpdatePageData();
}
-//void CAlarmDlg::AddAlarm(CAlarmMonitor* pMonitor, CAlarm* pAlarm)
-//{
-// if (pMonitor == nullptr) {
-// pMonitor = (CAlarmMonitor*)theApp.m_model.getBonder().GetComponent(ALARM_MONITOR);
-// }
-// CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST_ALARM);
-// pListCtrl->InsertItem(0, _T(""));
-// pListCtrl->SetItemData(0, (DWORD_PTR)pAlarm);
-// pAlarm->addRef();
-// pListCtrl->SetItemText(0, 1, std::to_string(pAlarm->getId()).c_str());
-// pListCtrl->SetItemText(0, 2, pMonitor->getAlarmText(pAlarm->getId()));
-// pListCtrl->SetItemText(0, 3, CToolUnits::timeToString2(pAlarm->getOnTime()).c_str());
-// if (pAlarm->getOffTime() > 0) {
-// pListCtrl->SetItemText(0, 4, CToolUnits::timeToString2(pAlarm->getOffTime()).c_str());
-// }
-//}
-
-//void CAlarmDlg::UpdateAlarm(CAlarmMonitor* pMonitor, CAlarm* pAlarm)
-//{
-// if (pMonitor == nullptr) {
-// pMonitor = (CAlarmMonitor*)theApp.m_model.getBonder().GetComponent(ALARM_MONITOR);
-// }
-// CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST_ALARM);
-// for (int i = 0; i < pListCtrl->GetItemCount(); i++) {
-// if (pListCtrl->GetItemData(i) == (DWORD_PTR)pAlarm) {
-// if (pAlarm->getOffTime() > 0) {
-// pListCtrl->SetItemText(i, 4, CToolUnits::timeToString2(pAlarm->getOffTime()).c_str());
-// }
-// }
-// }
-//}
-
void CAlarmDlg::UpdatePageData()
{
// 鏍规嵁杩囨护鏉′欢鍔犺浇鏁版嵁锛屾彁渚涙弿杩板拰鏃堕棿鑼冨洿鏌ヨ
- auto vecData = AlarmManager::getInstance().getFilteredAlarms("", m_strEqName, m_strKeyword, m_szTimeStart, m_szTimeEnd, m_nCurPage, PAGE_SIZE);
+ auto vecData = AlarmManager::getInstance().getFilteredAlarms("", "", m_strDeviceName, m_strUnitName, m_strKeyword, m_szTimeStart, m_szTimeEnd, m_nCurPage, PAGE_SIZE);
// 濉厖鏁版嵁鍒版帶浠�
CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST_ALARM);
@@ -158,20 +147,61 @@
GetDlgItem(IDC_BUTTON_NEXT_PAGE)->EnableWindow(m_nCurPage < m_nTotalPages);
}
-void CAlarmDlg::FillDataToListCtrl(CListCtrl* pListCtrl, const std::vector<std::vector<std::string>>& vecData)
+void CAlarmDlg::FillDataToListCtrl(CListCtrl* pListCtrl, const std::vector<AlarmData>& vecData)
{
// 娓呯┖褰撳墠CListCtrl涓殑鎵�鏈夐」
pListCtrl->DeleteAllItems();
// 閬嶅巻鏁版嵁骞舵彃鍏ュ埌CListCtrl涓�
- for (const auto& item : vecData) {
- int nItem = pListCtrl->InsertItem(pListCtrl->GetItemCount(), _T("")); // 鎻掑叆鏂拌
- pListCtrl->SetItemText(nItem, 1, item[0].c_str()); // 璁剧疆绗竴鍒楃殑鏂囨湰锛圛D锛�
- pListCtrl->SetItemText(nItem, 2, item[1].c_str()); // 璁剧疆绗簩鍒楃殑鏂囨湰锛堣澶囧悕绉帮級
- pListCtrl->SetItemText(nItem, 3, item[2].c_str()); // 璁剧疆绗笁鍒楃殑鏂囨湰锛堟弿杩帮級
- pListCtrl->SetItemText(nItem, 4, item[3].c_str()); // 璁剧疆绗洓鍒楃殑鏂囨湰锛堝紑濮嬫椂闂达級
- pListCtrl->SetItemText(nItem, 5, item[4].c_str()); // 璁剧疆绗洓鍒楃殑鏂囨湰锛堣В闄ゆ椂闂达級
+ for (const auto& alarm : vecData) {
+ int nItem = pListCtrl->InsertItem(pListCtrl->GetItemCount(), _T("")); // 鎻掑叆鏂拌
+ CString str;
+ // 璁剧疆鍒楀唴瀹�
+ str.Format(_T("%d"), alarm.nId);
+ pListCtrl->SetItemText(nItem, 1, str); // 鎶ヨID
+ str.Format(_T("%d"), alarm.nSeverityLevel);
+ pListCtrl->SetItemText(nItem, 2, str); // 绛夌骇
+ pListCtrl->SetItemText(nItem, 3, alarm.strDeviceName.c_str()); // 璁惧鍚嶇О
+ pListCtrl->SetItemText(nItem, 4, alarm.strUnitName.c_str()); // 鍗曞厓鍚嶇О
+ pListCtrl->SetItemText(nItem, 5, alarm.strDescription.c_str()); // 鎻忚堪
+ pListCtrl->SetItemText(nItem, 6, alarm.strStartTime.c_str()); // 寮�濮嬫椂闂�
+ pListCtrl->SetItemText(nItem, 7, alarm.strEndTime.c_str()); // 缁撴潫鏃堕棿
}
+}
+
+void CAlarmDlg::InsertAlarmData(CListCtrl* pListCtrl, const AlarmData& alarmData)
+{
+ int nRowCount = pListCtrl->GetItemCount();
+ if (nRowCount >= PAGE_SIZE) {
+ pListCtrl->DeleteItem(nRowCount - 1);
+ }
+
+ int nNewItem = pListCtrl->InsertItem(0, _T(""));
+
+ // 璁剧疆姣忎竴鍒楃殑鏁版嵁
+ CString str;
+ str.Format(_T("%d"), alarmData.nId);
+ pListCtrl->SetItemText(nNewItem, 1, str); // 鎶ヨID
+ str.Format(_T("%d"), alarmData.nSeverityLevel);
+ pListCtrl->SetItemText(nNewItem, 2, str); // 绛夌骇
+ pListCtrl->SetItemText(nNewItem, 3, alarmData.strDeviceName.c_str()); // 璁惧鍚嶇О
+ pListCtrl->SetItemText(nNewItem, 4, alarmData.strUnitName.c_str()); // 鍗曞厓鍚嶇О
+ pListCtrl->SetItemText(nNewItem, 5, alarmData.strDescription.c_str()); // 鎻忚堪
+ pListCtrl->SetItemText(nNewItem, 6, alarmData.strStartTime.c_str()); // 寮�濮嬫椂闂�
+ pListCtrl->SetItemText(nNewItem, 7, alarmData.strEndTime.c_str()); // 缁撴潫鏃堕棿
+}
+
+std::string CAlarmDlg::getCurrentTimeString()
+{
+ auto now = std::chrono::system_clock::now();
+ auto time_t_now = std::chrono::system_clock::to_time_t(now);
+
+ std::tm tm_now = {};
+ localtime_s(&tm_now, &time_t_now);
+
+ std::stringstream ss;
+ ss << std::put_time(&tm_now, "%Y-%m-%d %H:%M:%S");
+ return ss.str();
}
void CAlarmDlg::DoDataExchange(CDataExchange* pDX)
@@ -225,13 +255,15 @@
ListView_SetImageList(pListCtrl->GetSafeHwnd(), imageList, LVSIL_SMALL);
pListCtrl->InsertColumn(0, _T(""), LVCFMT_RIGHT, 0);
pListCtrl->InsertColumn(1, _T("璀﹀憡ID"), LVCFMT_LEFT, 50);
- pListCtrl->InsertColumn(2, _T("璁惧鍚嶇О"), LVCFMT_LEFT, 120);
- pListCtrl->InsertColumn(3, _T("鎻忚堪"), LVCFMT_LEFT, 280);
- pListCtrl->InsertColumn(4, _T("鍙戠敓鏃堕棿"), LVCFMT_LEFT, 180);
- pListCtrl->InsertColumn(5, _T("瑙ｉ櫎鏃堕棿"), LVCFMT_LEFT, 180);
+ pListCtrl->InsertColumn(2, _T("鎶ヨ绛夌骇"), LVCFMT_LEFT, 50);
+ pListCtrl->InsertColumn(3, _T("璁惧鍚嶇О"), LVCFMT_LEFT, 120);
+ pListCtrl->InsertColumn(4, _T("鍗曞厓鍚嶇О"), LVCFMT_LEFT, 120);
+ pListCtrl->InsertColumn(5, _T("鎻忚堪"), LVCFMT_LEFT, 180);
+ pListCtrl->InsertColumn(6, _T("鍙戠敓鏃堕棿"), LVCFMT_LEFT, 180);
+ pListCtrl->InsertColumn(7, _T("瑙ｉ櫎鏃堕棿"), LVCFMT_LEFT, 180);
// 璁＄畻鎬婚〉鏁�
- int totalRecords = AlarmManager::getInstance().getTotalAlarmCount("", m_strEqName, m_strKeyword, m_szTimeStart, m_szTimeEnd);
+ int totalRecords = AlarmManager::getInstance().getTotalAlarmCount("", "", m_strDeviceName, m_strUnitName, m_strKeyword, m_szTimeStart, m_szTimeEnd);
m_nTotalPages = (totalRecords + PAGE_SIZE - 1) / PAGE_SIZE;
m_nCurPage = 1;
@@ -244,14 +276,6 @@
BOOL CAlarmDlg::DestroyWindow()
{
- //CListCtrl* pListCtrl = (CListCtrl*)GetDlgItem(IDC_LIST_ALARM);
- //for (int i = 0; i < pListCtrl->GetItemCount(); i++) {
- // CAlarm* pAlarm = (CAlarm*)pListCtrl->GetItemData(i);
- // if (pAlarm != nullptr) {
- // pAlarm->release();
- // }
- //}
-
return CDialogEx::DestroyWindow();
}
@@ -353,7 +377,7 @@
}
// 璁＄畻鎬婚〉鏁�
- int totalRecords = AlarmManager::getInstance().getTotalAlarmCount("", m_strEqName, m_strKeyword, m_szTimeStart, m_szTimeEnd);
+ int totalRecords = AlarmManager::getInstance().getTotalAlarmCount("", "", m_strDeviceName, m_strUnitName, m_strKeyword, m_szTimeStart, m_szTimeEnd);
m_nTotalPages = (totalRecords + PAGE_SIZE - 1) / PAGE_SIZE;
m_nCurPage = 1;
--
Gitblit v1.9.3