From f2ec2ff2640e8f02507e6fa44cd1ba1487a303ea Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期五, 21 二月 2025 09:15:43 +0800
Subject: [PATCH] 1.定义派生于CStep的类CEqModeStep,用于处理设备模式改变的事件。

---
 SourceCode/Bond/Servo/ServoDlg.cpp |  137 +++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 135 insertions(+), 2 deletions(-)

diff --git a/SourceCode/Bond/Servo/ServoDlg.cpp b/SourceCode/Bond/Servo/ServoDlg.cpp
index f349071..39da8c6 100644
--- a/SourceCode/Bond/Servo/ServoDlg.cpp
+++ b/SourceCode/Bond/Servo/ServoDlg.cpp
@@ -9,7 +9,6 @@
 #include "Common.h"
 #include "Log.h"
 #include "SecsTestDlg.h"
-#include "AlarmManager.h"
 #include <chrono>
 #include <thread>
 #include <cmath>
@@ -35,6 +34,10 @@
 #define INDICATE_VACUUM_BAKE	11
 #define INDICATE_BAKE_COOLING	12
 #define INDICATE_MEASUREMENT	13
+
+
+/* 创建终端的定时器 */
+#define TIMER_ID_CREATE_TERMINAL		1
 
 
 // 用于应用程序“关于”菜单项的 CAboutDlg 对话框
@@ -83,6 +86,8 @@
 	m_bShowLogWnd = FALSE;
 	m_bIsRobotMoving = FALSE;
 	m_pLogDlg = nullptr;
+	m_pTerminalDisplayDlg = nullptr;
+	m_pObserver = nullptr;
 }
 
 void CServoDlg::DoDataExchange(CDataExchange* pDX)
@@ -115,11 +120,57 @@
 	ON_UPDATE_COMMAND_UI(ID_MENU_WND_LOG, &CServoDlg::OnUpdateMenuWndLog)
 	ON_COMMAND(ID_MENU_HELP_ABOUT, &CServoDlg::OnMenuHelpAbout)
 	ON_WM_INITMENUPOPUP()
+	ON_WM_TIMER()
 	ON_WM_ERASEBKGND()
 END_MESSAGE_MAP()
 
 
 // CServoDlg 消息处理程序
+
+void CServoDlg::InitRxWindows()
+{
+	/* code */
+	// 订阅数据
+	IRxWindows* pRxWindows = RX_GetRxWindows();
+	pRxWindows->enableLog(5);
+	if (m_pObserver == NULL) {
+		m_pObserver = pRxWindows->allocObserver([&](IAny* pAny) -> void {
+			// onNext
+			pAny->addRef();
+			int code = pAny->getCode();
+			if (RX_HSMS_TERMINAL_TEXT == code) {
+				const char* pszText;
+				if (pAny->getStringValue("text", pszText)) {
+					ShowTerminalText(pszText);
+				}
+			}
+			else if (RX_CODE_EQ_ALIVE == code) {
+				// 通知设备状态
+				SERVO::CEquipment* pEquipment = nullptr;
+				if (pAny->getPtrValue("ptr", (void*&)pEquipment)) {
+					if (pEquipment != nullptr) {
+						int nID = pEquipment->getID();
+						BOOL bAlive = pEquipment->isAlive();
+						if (EQ_ID_EFEM == nID) {
+							DeviceStatus status = bAlive ? DeviceStatus::ONLINE : DeviceStatus::OFFLINE;
+							UpdateDeviceStatus(INDICATE_ROBOT_ARM1, status);
+							UpdateDeviceStatus(INDICATE_ROBOT_ARM2, status);
+						}
+					}
+				}
+			}
+			pAny->release();
+		}, [&]() -> void {
+			// onComplete
+		}, [&](IThrowable* pThrowable) -> void {
+			// onErrorm
+			pThrowable->printf();
+		});
+
+		theApp.m_model.getObservable()->observeOn(pRxWindows->mainThread())
+			->subscribe(m_pObserver);
+	}
+}
 
 BOOL CServoDlg::OnInitDialog()
 {
@@ -252,8 +303,17 @@
 	theApp.m_model.init();
 
 
+	SetTimer(TIMER_ID_CREATE_TERMINAL, 3000, nullptr);
+	InitRxWindows();
+	OnBnClickedButtonLog();
 	UpdateLogBtn();
 	Resize();
+
+
+	// 相当于延时调用master的初始化
+	theApp.m_model.m_master.init();
+
+
 	return TRUE;  // 除非将焦点设置到控件,否则返回 TRUE
 }
 
@@ -462,10 +522,21 @@
 		delete m_pLogDlg;
 		m_pLogDlg = nullptr;
 	}
+	if (m_pTerminalDisplayDlg != nullptr) {
+		m_pTerminalDisplayDlg->DestroyWindow();
+		delete m_pTerminalDisplayDlg;
+		m_pTerminalDisplayDlg = nullptr;
+	}
 
 	if (m_hbrBkgnd != nullptr) {
 		::DeleteObject(m_hbrBkgnd);
 	}
+
+	if (m_pObserver != nullptr) {
+		m_pObserver->unsubscribe();
+		m_pObserver = NULL;
+	}
+
 }
 
 void CServoDlg::OnBnClickedButtonLog()
@@ -596,6 +667,38 @@
 	Invalidate();
 }
 
+void CServoDlg::UpdateDeviceStatus(int id, DeviceStatus status)
+{
+	// 根据状态设置颜色
+	COLORREF newBackgroundColor;
+	COLORREF newFrameColor1;
+	COLORREF newFrameColor2;
+
+	switch (status) {
+	case ONLINE:
+		newBackgroundColor = RGB(255, 0, 0);
+		newFrameColor1 = RGB(22, 22, 22);
+		newFrameColor2 = RGB(255, 127, 39);
+		break;
+	case OFFLINE:
+		newBackgroundColor = RGB(0, 255, 0);
+		newFrameColor1 = RGB(22, 22, 22);
+		newFrameColor2 = RGB(255, 127, 39);
+		break;
+	default:
+		newBackgroundColor = RGB(255, 255, 255); // 默认白色背景
+		newFrameColor1 = RGB(0, 0, 0);           // 默认黑色框架1
+		newFrameColor2 = RGB(0, 0, 0);           // 默认黑色框架2
+		break;
+	}
+
+	m_pGraph->UpdateIndicateBox1Colors(id, newBackgroundColor, newFrameColor1, newFrameColor2);
+
+	// 刷新界面
+	Invalidate();
+	UpdateWindow();
+}
+
 void CServoDlg::OnSize(UINT nType, int cx, int cy)
 {
 	CDialogEx::OnSize(nType, cx, cy);
@@ -608,6 +711,7 @@
 	CRect rcClient, rcItem;
 	CWnd* pItem = nullptr;
 	int x, y;
+	GetClientRect(&rcClient);
 
 	x = 0;
 	y = 0;
@@ -620,7 +724,7 @@
 	x = 8;
 	pItem = GetDlgItem(IDC_BUTTON_LOG);
 	pItem->GetClientRect(&rcItem);
-	pItem->MoveWindow(x, y, rcItem.Width(), rcItem.Height());
+	pItem->MoveWindow(x, rcClient.bottom - 8 - rcItem.Height(), rcItem.Width(), rcItem.Height());
 }
 
 void CServoDlg::OnClose()
@@ -635,6 +739,14 @@
 	m_bShowLogWnd = FALSE;
 	UpdateLogBtn();
 	LOGE("OnLogDlgHide");
+
+	unsigned int DATAID, RPTID;
+	DATAID = 111;
+	RPTID = 1001;
+	std::vector<std::string> v;
+	v.push_back("abc");
+	v.push_back("def");
+	theApp.m_model.m_hsmsPassive.requestEventReportSend(DATAID, RPTID, v);
 
 	return 0;
 }
@@ -655,6 +767,27 @@
 	CDialogEx::OnMove(x, y);
 }
 
+void CServoDlg::ShowTerminalText(const char* pszText, unsigned int duration/* = -1*/)
+{
+	ASSERT(m_pTerminalDisplayDlg);
+	m_pTerminalDisplayDlg->ShowText(pszText, duration);
+}
+
+void CServoDlg::OnTimer(UINT_PTR nIDEvent)
+{
+	if (TIMER_ID_CREATE_TERMINAL == nIDEvent) {
+		// 预先创建终端窗口
+		KillTimer(TIMER_ID_CREATE_TERMINAL);
+		char szBuffer[MAX_PATH];
+		sprintf_s(szBuffer, MAX_PATH, "%s\\RES\\TeminalMsg.html", (LPTSTR)(LPCTSTR)theApp.m_strAppDir);
+		m_pTerminalDisplayDlg = new CTerminalDisplayDlg();
+		m_pTerminalDisplayDlg->SetTemplateHtml(szBuffer);
+		m_pTerminalDisplayDlg->Create(IDD_DIALOG_TERMINAL_DISPLAY, this);
+	}
+
+	CDialogEx::OnTimer(nIDEvent);
+}
+
 
 BOOL CServoDlg::OnEraseBkgnd(CDC* pDC)
 {

--
Gitblit v1.9.3