1.终端信息显示模拟测试；

LAPTOP-SNT8I5JK\Boounion

2025-07-11 c96ec4c44d31e4df6da3ce904fd3c6d8f3548c2d

 SourceCode/Bond/EAPSimulator/EAPSimulatorDlg.cpp

@@ -7,6 +7,10 @@
#include "EAPSimulator.h"
#include "EAPSimulatorDlg.h"
#include "afxdialogex.h"
#include "Common.h"
#include <regex>
#include "CTerminalDisplayDlg.h"


#ifdef _DEBUG
#define new DEBUG_NEW
@@ -54,21 +58,78 @@
   : CDialogEx(IDD_EAPSIMULATOR_DIALOG, pParent)
{
   m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
   m_pObserver = nullptr;
}

void CEAPSimulatorDlg::DoDataExchange(CDataExchange* pDX)
{
   CDialogEx::DoDataExchange(pDX);
   DDX_Control(pDX, IDC_EDIT_LOG, m_logEdit);
}

BEGIN_MESSAGE_MAP(CEAPSimulatorDlg, CDialogEx)
   ON_WM_SYSCOMMAND()
   ON_WM_PAINT()
   ON_WM_QUERYDRAGICON()
   ON_WM_DESTROY()
   ON_BN_CLICKED(IDC_BUTTON_CONNECT, &CEAPSimulatorDlg::OnBnClickedButtonConnect)
   ON_BN_CLICKED(IDC_BUTTON_DISCONNECT, &CEAPSimulatorDlg::OnBnClickedButtonDisconnect)
   ON_BN_CLICKED(IDC_BUTTON_ARE_YOU_THERE, &CEAPSimulatorDlg::OnBnClickedButtonAreYouThere)
   ON_BN_CLICKED(IDC_BUTTON_DATETIME_SYNC, &CEAPSimulatorDlg::OnBnClickedButtonDatetimeSync)
   ON_BN_CLICKED(IDC_BUTTON_TERMINAL_DISPLAY, &CEAPSimulatorDlg::OnBnClickedButtonTerminalDisplay)
END_MESSAGE_MAP()


// CEAPSimulatorDlg 消息处理程序

void CEAPSimulatorDlg::InitRxWindow()
{
   /* 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_CODE_LOG == code && ::IsWindow(m_hWnd)) {
            const char* pszLogMsg;
            int level;
            if (pAny->getStringValue("text", pszLogMsg)
               && pAny->getIntValue("exCode", level)) {
               CString strText = pszLogMsg;
               strText.Replace("\n", "\r\n");
               AppendLog(level, (LPTSTR)(LPCTSTR)strText);
            }
         }
         else if (RX_CODE_ACTIVE_STATUS_CHANGED == code) {
            int state;
            if (pAny->getIntValue("exCode", state)) {
               if ((ACTIVESTATE)state == ACTIVESTATE::SELECTED) {
                  SetGroup2Enabled(TRUE);
               }
               if ((ACTIVESTATE)state == ACTIVESTATE::NOT_CONNECTED) {
                  SetGroup2Enabled(FALSE);
                  SetGroup1Enabled(TRUE);
               }
            }
         }

         pAny->release();
         }, [&]() -> void {
            // onComplete
         }, [&](IThrowable* pThrowable) -> void {
            // onErrorm
            pThrowable->printf();
         });

      theApp.m_model.getObservable()->observeOn(pRxWindows->mainThread())
         ->subscribe(m_pObserver);
   }

   theApp.m_model.init();
}

BOOL CEAPSimulatorDlg::OnInitDialog()
{
@@ -99,7 +160,16 @@
   SetIcon(m_hIcon, TRUE);         // 设置大图标
   SetIcon(m_hIcon, FALSE);      // 设置小图标

   // TODO: 在此添加额外的初始化代码
   SetDlgItemText(IDC_EDIT_IP, _T("127.0.0.1"));
   SetDlgItemInt(IDC_EDIT_PORT, 7000);
   SetGroup2Enabled(FALSE);
   SetGroup1Enabled(TRUE);


   // log edit
   m_logEdit.SetMaxLineCount(8000);
   m_logEdit.SetLimitText(-1);
   InitRxWindow();

   return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}
@@ -153,3 +223,67 @@
   return static_cast<HCURSOR>(m_hIcon);
}

void CEAPSimulatorDlg::AppendLog(int level, const char* pszText)
{
   if (!::IsWindow(m_logEdit.m_hWnd)) {
      return;
   }
   m_logEdit.AppendText(pszText);
}



void CEAPSimulatorDlg::OnDestroy()
{
   CDialogEx::OnDestroy();

   ASSERT(m_pObserver != NULL);
   m_pObserver->unsubscribe();
   m_pObserver = NULL;
}

void CEAPSimulatorDlg::SetGroup1Enabled(bool enabled)
{
   GetDlgItem(IDC_EDIT_IP)->EnableWindow(enabled);
   GetDlgItem(IDC_EDIT_PORT)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(enabled);
}

void CEAPSimulatorDlg::SetGroup2Enabled(bool enabled)
{
   GetDlgItem(IDC_BUTTON_DISCONNECT)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_ARE_YOU_THERE)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_DATETIME_SYNC)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_TERMINAL_DISPLAY)->EnableWindow(enabled);	
}

void CEAPSimulatorDlg::OnBnClickedButtonConnect()
{
   CString strIp;
   UINT port;
   GetDlgItemText(IDC_EDIT_IP, strIp);
   port = GetDlgItemInt(IDC_EDIT_PORT);
   theApp.m_model.connectEq((LPTSTR)(LPCTSTR)strIp, port);
   SetGroup1Enabled(FALSE);
}

void CEAPSimulatorDlg::OnBnClickedButtonDisconnect()
{
   theApp.m_model.disconnect();
}

void CEAPSimulatorDlg::OnBnClickedButtonAreYouThere()
{
   theApp.m_model.m_pHsmsActive->hsmsAreYouThere();
}

void CEAPSimulatorDlg::OnBnClickedButtonDatetimeSync()
{
   theApp.m_model.m_pHsmsActive->hsmsDatetimeSync();
}

void CEAPSimulatorDlg::OnBnClickedButtonTerminalDisplay()
{
   CTerminalDisplayDlg dlg;
   dlg.DoModal();
}