1.EAP模拟器完善

chenluhua1980

2026-01-09 260b16a1debe7dbc33982768a37dfd48ca34b248

 SourceCode/Bond/EAPSimulator/EAPSimulatorDlg.cpp

@@ -9,6 +9,13 @@
#include "afxdialogex.h"
#include "Common.h"
#include <regex>
#include <string>
#include <vector>
#include "CTerminalDisplayDlg.h"
#include "CEDEventReportDlg.h"
#include "CDefineReportsDlg.h"
#include "CLinkReportDlg.h"
#include "CPJsDlg.h"


#ifdef _DEBUG
@@ -73,6 +80,29 @@
   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)
   ON_BN_CLICKED(IDC_BUTTON_ED_EVENT_REPORT, &CEAPSimulatorDlg::OnBnClickedButtonEdEventReport)
   ON_BN_CLICKED(IDC_BUTTON_ED_ALARM_REPORT, &CEAPSimulatorDlg::OnBnClickedButtonEdAlarmReport)
   ON_BN_CLICKED(IDC_BUTTON_DEFINE_REPORT, &CEAPSimulatorDlg::OnBnClickedButtonDefineReport)
   ON_BN_CLICKED(IDC_BUTTON_LINE_REPORT, &CEAPSimulatorDlg::OnBnClickedButtonLineReport)
   ON_BN_CLICKED(IDC_BUTTON_CONFIGURE_SPOOLING, &CEAPSimulatorDlg::OnBnClickedButtonConfigureSpooling)
   ON_BN_CLICKED(IDC_BUTTON_TRANSMIT_SPOOLED_DATA, &CEAPSimulatorDlg::OnBnClickedButtonTransmitSpooledData)
   ON_BN_CLICKED(IDC_BUTTON_PURGE_SPOOLED_DATA, &CEAPSimulatorDlg::OnBnClickedButtonPurgeSpooledData)
   ON_BN_CLICKED(IDC_BUTTON_QUERY_PPID_LIST, &CEAPSimulatorDlg::OnBnClickedButtonQueryPpidList)
   ON_BN_CLICKED(IDC_BUTTON_PROCEED_WITH_CARRIER, &CEAPSimulatorDlg::OnBnClickedButtonProceedWithCarrier)
   ON_BN_CLICKED(IDC_BUTTON_PROCEED_WITH_SLOTMAP, &CEAPSimulatorDlg::OnBnClickedButtonProceedWithSlotMap)
   ON_BN_CLICKED(IDC_BUTTON_CARRIER_RELEASE, &CEAPSimulatorDlg::OnBnClickedButtonCarrierRelease)
   ON_BN_CLICKED(IDC_BUTTON_QUERY_CJ_SPACE, &CEAPSimulatorDlg::OnBnClickedButtonQueryCjSpace)
   ON_BN_CLICKED(IDC_BUTTON_QUERY_PJ_SPACE, &CEAPSimulatorDlg::OnBnClickedButtonQueryPjSpace)
   ON_BN_CLICKED(IDC_BUTTON_CREATE_PJ, &CEAPSimulatorDlg::OnBnClickedButtonCreatePj)
   ON_BN_CLICKED(IDC_BUTTON_CREATE_CJ, &CEAPSimulatorDlg::OnBnClickedButtonCreateCj)
   ON_BN_CLICKED(IDC_BUTTON_CTRL_OFFLINE, &CEAPSimulatorDlg::OnBnClickedButtonCtrlOffline)
   ON_BN_CLICKED(IDC_BUTTON_CTRL_ONLINE_LOCAL, &CEAPSimulatorDlg::OnBnClickedButtonCtrlOnlineLocal)
   ON_BN_CLICKED(IDC_BUTTON_CTRL_ONLINE_REMOTE, &CEAPSimulatorDlg::OnBnClickedButtonCtrlOnlineRemote)
   ON_BN_CLICKED(IDC_BUTTON_QUERY_CONTROL_STATE, &CEAPSimulatorDlg::OnBnClickedButtonQueryControlState)
   ON_BN_CLICKED(IDC_BUTTON_QUERY_PROCESS_STATE, &CEAPSimulatorDlg::OnBnClickedButtonQueryProcessState)
END_MESSAGE_MAP()


@@ -103,13 +133,11 @@
            int state;
            if (pAny->getIntValue("exCode", state)) {
               if ((ACTIVESTATE)state == ACTIVESTATE::SELECTED) {
                  GetDlgItem(IDC_BUTTON_DISCONNECT)->EnableWindow(TRUE);
                  SetGroup2Enabled(TRUE);
               }
               if ((ACTIVESTATE)state == ACTIVESTATE::NOT_CONNECTED) {
                  GetDlgItem(IDC_BUTTON_DISCONNECT)->EnableWindow(FALSE);
                  GetDlgItem(IDC_EDIT_IP)->EnableWindow(TRUE);
                  GetDlgItem(IDC_EDIT_PORT)->EnableWindow(TRUE);
                  GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(TRUE);
                  SetGroup2Enabled(FALSE);
                  SetGroup1Enabled(TRUE);
               }
            }
         }
@@ -125,6 +153,8 @@
      theApp.m_model.getObservable()->observeOn(pRxWindows->mainThread())
         ->subscribe(m_pObserver);
   }

   theApp.m_model.init();
}

BOOL CEAPSimulatorDlg::OnInitDialog()
@@ -156,8 +186,75 @@
   SetIcon(m_hIcon, TRUE);         // 设置大图标
   SetIcon(m_hIcon, FALSE);      // 设置小图标

   // Add missing test button at runtime (resource file is UTF-16, keep it unchanged)
   {
      CRect rc(126, 120, 126 + 108, 120 + 14); // dialog units
      MapDialogRect(&rc);
      HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S3F17_ProceedWithSlotMap"),
         WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
         rc.left, rc.top, rc.Width(), rc.Height(),
         m_hWnd, (HMENU)IDC_BUTTON_PROCEED_WITH_SLOTMAP, AfxGetInstanceHandle(), nullptr);
      if (hBtn != nullptr) {
         ::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
      }
   }
   // ControlState test buttons at runtime (resource file is UTF-16, keep it unchanged)
   {
      const int y = 120;
      const int w = 70;
      const int h = 14;
      const int gap = 3;

      struct BtnDef { int x; int id; const TCHAR* text; };
      BtnDef defs[] = {
         { 238, IDC_BUTTON_CTRL_OFFLINE, _T("Ctrl Offline") },
         { 238 + (w + gap), IDC_BUTTON_CTRL_ONLINE_LOCAL, _T("Ctrl Local") },
         { 238 + 2 * (w + gap), IDC_BUTTON_CTRL_ONLINE_REMOTE, _T("Ctrl Remote") },
      };

      for (const auto& d : defs) {
         CRect rc(d.x, y, d.x + w, y + h); // dialog units
         MapDialogRect(&rc);
         HWND hBtn = ::CreateWindow(_T("BUTTON"), d.text,
            WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
            rc.left, rc.top, rc.Width(), rc.Height(),
            m_hWnd, (HMENU)d.id, AfxGetInstanceHandle(), nullptr);
         if (hBtn != nullptr) {
            ::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
         }
      }
   }
   // S1F3 Query ControlState (SVID=600) button (runtime add to avoid touching UTF-16 RC)
   {
      // Place on its own row to avoid overlapping with control-mode buttons.
      CRect rc(14, 136, 14 + 140, 136 + 14); // dialog units
      MapDialogRect(&rc);
      HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F3_QueryControlState"),
         WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
         rc.left, rc.top, rc.Width(), rc.Height(),
         m_hWnd, (HMENU)IDC_BUTTON_QUERY_CONTROL_STATE, AfxGetInstanceHandle(), nullptr);
      if (hBtn != nullptr) {
         ::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
      }
   }
   // S1F3 Query ProcessState (SVID=700) button
   {
      CRect rc(14, 152, 14 + 140, 152 + 14); // dialog units, new row
      MapDialogRect(&rc);
      HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F3_QueryProcessState"),
         WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
         rc.left, rc.top, rc.Width(), rc.Height(),
         m_hWnd, (HMENU)IDC_BUTTON_QUERY_PROCESS_STATE, AfxGetInstanceHandle(), nullptr);
      if (hBtn != nullptr) {
         ::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
      }
   }

   SetDlgItemText(IDC_EDIT_IP, _T("127.0.0.1"));
   SetDlgItemInt(IDC_EDIT_PORT, 7000);
   SetGroup2Enabled(FALSE);
   SetGroup1Enabled(TRUE);
   ::SetProp(GetDlgItem(IDC_BUTTON_ED_ALARM_REPORT)->m_hWnd, _T("Enable"), (void*)1);


   // log edit
@@ -236,6 +333,53 @@
   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);	
   GetDlgItem(IDC_BUTTON_ED_EVENT_REPORT)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_ED_ALARM_REPORT)->EnableWindow(enabled);	
   GetDlgItem(IDC_BUTTON_DEFINE_REPORT)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_LINE_REPORT)->EnableWindow(enabled);	
   GetDlgItem(IDC_BUTTON_CONFIGURE_SPOOLING)->EnableWindow(enabled);	
   GetDlgItem(IDC_BUTTON_TRANSMIT_SPOOLED_DATA)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_PURGE_SPOOLED_DATA)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_QUERY_PPID_LIST)->EnableWindow(enabled);	
   GetDlgItem(IDC_BUTTON_PROCEED_WITH_CARRIER)->EnableWindow(enabled);	
   if (GetDlgItem(IDC_BUTTON_PROCEED_WITH_SLOTMAP) != nullptr) {
      GetDlgItem(IDC_BUTTON_PROCEED_WITH_SLOTMAP)->EnableWindow(enabled);
   }
   GetDlgItem(IDC_BUTTON_CARRIER_RELEASE)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_QUERY_CJ_SPACE)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_QUERY_PJ_SPACE)->EnableWindow(enabled);
   GetDlgItem(IDC_BUTTON_CREATE_PJ)->EnableWindow(enabled);	
   GetDlgItem(IDC_BUTTON_CREATE_CJ)->EnableWindow(enabled);	
   if (GetDlgItem(IDC_BUTTON_CTRL_OFFLINE) != nullptr) {
      GetDlgItem(IDC_BUTTON_CTRL_OFFLINE)->EnableWindow(enabled);
   }
   if (GetDlgItem(IDC_BUTTON_CTRL_ONLINE_LOCAL) != nullptr) {
      GetDlgItem(IDC_BUTTON_CTRL_ONLINE_LOCAL)->EnableWindow(enabled);
   }
   if (GetDlgItem(IDC_BUTTON_CTRL_ONLINE_REMOTE) != nullptr) {
      GetDlgItem(IDC_BUTTON_CTRL_ONLINE_REMOTE)->EnableWindow(enabled);
   }
   if (GetDlgItem(IDC_BUTTON_QUERY_CONTROL_STATE) != nullptr) {
      GetDlgItem(IDC_BUTTON_QUERY_CONTROL_STATE)->EnableWindow(enabled);
   }
   if (GetDlgItem(IDC_BUTTON_QUERY_PROCESS_STATE) != nullptr) {
      GetDlgItem(IDC_BUTTON_QUERY_PROCESS_STATE)->EnableWindow(enabled);
   }
}

void CEAPSimulatorDlg::OnBnClickedButtonConnect()
{
   CString strIp;
@@ -243,12 +387,168 @@
   GetDlgItemText(IDC_EDIT_IP, strIp);
   port = GetDlgItemInt(IDC_EDIT_PORT);
   theApp.m_model.connectEq((LPTSTR)(LPCTSTR)strIp, port);
   GetDlgItem(IDC_EDIT_IP)->EnableWindow(FALSE);
   GetDlgItem(IDC_EDIT_PORT)->EnableWindow(FALSE);
   GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(FALSE);
   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();
}

void CEAPSimulatorDlg::OnBnClickedButtonEdEventReport()
{
   CEDEventReportDlg dlg;
   dlg.DoModal();
}

void CEAPSimulatorDlg::OnBnClickedButtonEdAlarmReport()
{
   int enable = (int)::GetProp(GetDlgItem(IDC_BUTTON_ED_ALARM_REPORT)->m_hWnd, _T("Enable"));
   enable = enable == 0 ? 1 : 0;
   theApp.m_model.m_pHsmsActive->hsmsEDAlarmReport(enable == 1, 0);

   SetDlgItemText(IDC_BUTTON_ED_ALARM_REPORT, 
      enable == 1 ? _T("Disable Alarm Report") : _T("Enable Alarm Report"));
   ::SetProp(GetDlgItem(IDC_BUTTON_ED_ALARM_REPORT)->m_hWnd, _T("Enable"), (void*)enable);
}

void CEAPSimulatorDlg::OnBnClickedButtonDefineReport()
{
   CDefineReportsDlg dlg;
   dlg.DoModal();
}

void CEAPSimulatorDlg::OnBnClickedButtonLineReport()
{
   CLinkReportDlg dlg;
   dlg.DoModal();
}

void CEAPSimulatorDlg::OnBnClickedButtonConfigureSpooling()
{
   std::map<unsigned int, std::set<unsigned int>> spoolingConfig;

   // test clear all
   // theApp.m_model.m_pHsmsActive->hsmsConfigureSpooling(spoolingConfig);


   // test add s2[1,3,5];
   // spoolingConfig[2].insert(1);
   // spoolingConfig[2].insert(3);
   // spoolingConfig[2].insert(5);
   // spoolingConfig[3].insert(2);
   // spoolingConfig[3].insert(4);
   // spoolingConfig[3].insert(6);
   // theApp.m_model.m_pHsmsActive->hsmsConfigureSpooling(spoolingConfig);

   // test clear S2
   // spoolingConfig[2].clear();
   // theApp.m_model.m_pHsmsActive->hsmsConfigureSpooling(spoolingConfig);

   spoolingConfig[5].insert(66);
   theApp.m_model.m_pHsmsActive->hsmsConfigureSpooling(spoolingConfig);
}

void CEAPSimulatorDlg::OnBnClickedButtonTransmitSpooledData()
{
   theApp.m_model.m_pHsmsActive->hsmsTransmitSpooledData();
}

void CEAPSimulatorDlg::OnBnClickedButtonPurgeSpooledData()
{
   theApp.m_model.m_pHsmsActive->hsmsPurgeSpooledData();
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryCjSpace()
{
   theApp.m_model.m_pHsmsActive->hsmsSelectedEquipmentStatusRequest(SVID_CJobSpace);
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryPjSpace()
{
   theApp.m_model.m_pHsmsActive->hsmsSelectedEquipmentStatusRequest(SVID_PJobQueued);
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryPpidList()
{
   theApp.m_model.m_pHsmsActive->hsmsQueryPPIDList();
}

static int DATAID = 1;
void CEAPSimulatorDlg::OnBnClickedButtonProceedWithCarrier()
{
   theApp.m_model.m_pHsmsActive->hsmsProceedWithCarrier(DATAID++, "CSX 52078", 1);
}

void CEAPSimulatorDlg::OnBnClickedButtonProceedWithSlotMap()
{
   // Example payload (edit as needed)
   std::vector<std::string> panelIds = {
      "PANEL_01","PANEL_02","PANEL_03","PANEL_04",
      "PANEL_05","PANEL_06","PANEL_07","PANEL_08"
   };
   std::vector<unsigned char> slotMap = {
      3,3,1,1,1,1,1,1 // 1=Empty, 3=Exist
   };
   theApp.m_model.m_pHsmsActive->hsmsProceedWithSlotMap(DATAID++, "CSX 52078", 1, "LOT_0001", panelIds, slotMap);
}

void CEAPSimulatorDlg::OnBnClickedButtonCarrierRelease()
{
   theApp.m_model.m_pHsmsActive->hsmsCarrierRelease(DATAID++, "CSX 52078", 2);
}

void CEAPSimulatorDlg::OnBnClickedButtonCreatePj()
{
   CPJsDlg dlg;
   dlg.DoModal();
}

void CEAPSimulatorDlg::OnBnClickedButtonCreateCj()
{
   std::vector<std::string> processJobIds = {"PJ0001"};
   theApp.m_model.m_pHsmsActive->hsmsCreateControlJob("CJ5007", processJobIds);
}

void CEAPSimulatorDlg::OnBnClickedButtonCtrlOffline()
{
   theApp.m_model.m_pHsmsActive->hsmsRequestOffline();
}

void CEAPSimulatorDlg::OnBnClickedButtonCtrlOnlineLocal()
{
   theApp.m_model.m_pHsmsActive->hsmsRequestOnline();
   theApp.m_model.m_pHsmsActive->hsmsGoLocal();
}

void CEAPSimulatorDlg::OnBnClickedButtonCtrlOnlineRemote()
{
   theApp.m_model.m_pHsmsActive->hsmsRequestOnline();
   theApp.m_model.m_pHsmsActive->hsmsGoRemote();
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryControlState()
{
   theApp.m_model.m_pHsmsActive->hsmsSelectedEquipmentStatusRequest(SVID_ControlState);
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryProcessState()
{
   theApp.m_model.m_pHsmsActive->hsmsSelectedEquipmentStatusRequest(SVID_CurrentProcessState);
}