// EAPSimulatorDlg.cpp: 实现文件
//

#include "pch.h"
#include "framework.h"
#include "EAPSimulator.h"
#include "EAPSimulatorDlg.h"
#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
#define new DEBUG_NEW
#endif


// 用于应用程序“关于”菜单项的 CAboutDlg 对话框

class CAboutDlg : public CDialogEx
{
public:
	CAboutDlg();

// 对话框数据
#ifdef AFX_DESIGN_TIME
	enum { IDD = IDD_ABOUTBOX };
#endif

	protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持

// 实现
protected:
	DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialogEx(IDD_ABOUTBOX)
{
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
END_MESSAGE_MAP()


// CEAPSimulatorDlg 对话框



CEAPSimulatorDlg::CEAPSimulatorDlg(CWnd* pParent /*=nullptr*/)
	: 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)
	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_DELETE_PPID, &CEAPSimulatorDlg::OnBnClickedButtonDeletePpid)
	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)
	ON_BN_CLICKED(IDC_BUTTON_QUERY_ALL_SVID, &CEAPSimulatorDlg::OnBnClickedButtonQueryAllSvid)
	ON_BN_CLICKED(IDC_BUTTON_QUERY_ALL_DVID, &CEAPSimulatorDlg::OnBnClickedButtonQueryAllDvid)
	ON_BN_CLICKED(IDC_BUTTON_QUERY_ALL_CEID, &CEAPSimulatorDlg::OnBnClickedButtonQueryAllCeid)
	ON_BN_CLICKED(IDC_BUTTON_QUERY_ALL_ECID, &CEAPSimulatorDlg::OnBnClickedButtonQueryAllEcid)
	ON_BN_CLICKED(IDC_BUTTON_SET_ECID, &CEAPSimulatorDlg::OnBnClickedButtonSetEcid)
	ON_BN_CLICKED(IDC_BUTTON_QUERY_CURRENT_RECIPE, &CEAPSimulatorDlg::OnBnClickedButtonQueryCurrentRecipe)
	ON_BN_CLICKED(IDC_BUTTON_PP_REQUEST, &CEAPSimulatorDlg::OnBnClickedButtonPpRequest)
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()
{
	CDialogEx::OnInitDialog();

	// 将“关于...”菜单项添加到系统菜单中。

	// IDM_ABOUTBOX 必须在系统命令范围内。
	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
	ASSERT(IDM_ABOUTBOX < 0xF000);

	CMenu* pSysMenu = GetSystemMenu(FALSE);
	if (pSysMenu != nullptr)
	{
		BOOL bNameValid;
		CString strAboutMenu;
		bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
		ASSERT(bNameValid);
		if (!strAboutMenu.IsEmpty())
		{
			pSysMenu->AppendMenu(MF_SEPARATOR);
			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
		}
	}

	// 设置此对话框的图标。  当应用程序主窗口不是对话框时，框架将自动
	//  执行此操作
	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 + 140 + 5, 136, 14 + 140 + 5 + 140, 136 + 14); // dialog units, same row offset
		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);
		}
	}
	// S1F11 QueryAllSVID
	{
		CRect rc(14 + 140 + 5 + 140 + 5, 136, 14 + 140 + 5 + 140 + 5 + 140, 136 + 14); // dialog units, next row
		MapDialogRect(&rc);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F11_QueryAllSVID"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rc.left, rc.top, rc.Width(), rc.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_QUERY_ALL_SVID, AfxGetInstanceHandle(), nullptr);
		if (hBtn != nullptr) {
			::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
		}
	}
	// S1F23 QueryAllCEID
	{
		CRect rc(14, 152, 14 + 140, 152 + 14); // dialog units, next row
		MapDialogRect(&rc);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F23_QueryAllCEID"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rc.left, rc.top, rc.Width(), rc.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_QUERY_ALL_CEID, AfxGetInstanceHandle(), nullptr);
		if (hBtn != nullptr) {
			::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
		}
	}
	// S1F21 QueryAllDVID
	{
		CRect rc(14 + 140 + 5, 152, 14 + 140 + 5 + 140, 152 + 14);
		MapDialogRect(&rc);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F21_QueryAllDVID"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rc.left, rc.top, rc.Width(), rc.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_QUERY_ALL_DVID, AfxGetInstanceHandle(), nullptr);
		if (hBtn != nullptr) {
			::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
		}
	}
	// S2F13 QueryAllECID
	{
		CRect rc(14 + 2 * (140 + 5), 192, 14 + 2 * (140 + 5) + 140, 192 + 14);
		MapDialogRect(&rc);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S2F13_QueryAllECID"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rc.left, rc.top, rc.Width(), rc.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_QUERY_ALL_ECID, AfxGetInstanceHandle(), nullptr);
		if (hBtn != nullptr) {
			::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
		}
	}
	// ECID edit + send (S2F15)
	{
		CRect rcEcid(14, 192, 14 + 60, 192 + 14);
		CRect rcEcv(14 + 60 + 4, 192, 14 + 60 + 4 + 60, 192 + 14);
		MapDialogRect(&rcEcid);
		MapDialogRect(&rcEcv);
		HWND hEditEcid = ::CreateWindow(_T("EDIT"), _T(""), WS_CHILD | WS_VISIBLE | WS_BORDER,
			rcEcid.left, rcEcid.top, rcEcid.Width(), rcEcid.Height(),
			m_hWnd, (HMENU)IDC_EDIT_ECID, AfxGetInstanceHandle(), nullptr);
		HWND hEditEcv = ::CreateWindow(_T("EDIT"), _T(""), WS_CHILD | WS_VISIBLE | WS_BORDER,
			rcEcv.left, rcEcv.top, rcEcv.Width(), rcEcv.Height(),
			m_hWnd, (HMENU)IDC_EDIT_ECV, AfxGetInstanceHandle(), nullptr);
		if (hEditEcid) ::SendMessage(hEditEcid, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
		if (hEditEcv) ::SendMessage(hEditEcv, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);

		CRect rcBtn(14 + 60 + 4 + 60 + 4, 192, 14 + 60 + 4 + 60 + 4 + 90, 192 + 14);
		MapDialogRect(&rcBtn);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S2F15_SetECID"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rcBtn.left, rcBtn.top, rcBtn.Width(), rcBtn.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_SET_ECID, AfxGetInstanceHandle(), nullptr);
		if (hBtn) ::SendMessage(hBtn, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
	}
	// S1F3 CurrentRecipe (EQ specific) combo + button
	{
		CRect rcCombo(14, 168, 14 + 120, 168 + 120); // dropdown height arbitrary
		MapDialogRect(&rcCombo);
		HWND hCombo = ::CreateWindow(_T("COMBOBOX"), _T(""),
			WS_CHILD | WS_VISIBLE | CBS_DROPDOWNLIST | WS_VSCROLL,
			rcCombo.left, rcCombo.top, rcCombo.Width(), rcCombo.Height(),
			m_hWnd, (HMENU)IDC_COMBO_EQ_FOR_RECIPE, AfxGetInstanceHandle(), nullptr);
		if (hCombo != nullptr) {
			::SendMessage(hCombo, WM_SETFONT, (WPARAM)GetFont()->GetSafeHandle(), TRUE);
			// 简单填充设备列表（可按需调整）
			std::vector<CString> eqs = { _T("Bonder1"), _T("Bonder2"), _T("EFEM"), _T("VacuumBake"), _T("BakeCooling"), _T("Measurement") };
			for (const auto& eq : eqs) {
				::SendMessage(hCombo, CB_ADDSTRING, 0, (LPARAM)(LPCTSTR)eq);
			}
			::SendMessage(hCombo, CB_SETCURSEL, 0, 0);
		}

		CRect rcBtn(140, 168, 14 + 140 + 118, 168 + 14);
		MapDialogRect(&rcBtn);
		HWND hBtn = ::CreateWindow(_T("BUTTON"), _T("S1F3_CurrentRecipe"),
			WS_CHILD | WS_VISIBLE | BS_PUSHBUTTON,
			rcBtn.left, rcBtn.top, rcBtn.Width(), rcBtn.Height(),
			m_hWnd, (HMENU)IDC_BUTTON_QUERY_CURRENT_RECIPE, 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
	m_logEdit.SetMaxLineCount(8000);
	m_logEdit.SetLimitText(-1);
	InitRxWindow();

	return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}

void CEAPSimulatorDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
	{
		CAboutDlg dlgAbout;
		dlgAbout.DoModal();
	}
	else
	{
		CDialogEx::OnSysCommand(nID, lParam);
	}
}

// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。

void CEAPSimulatorDlg::OnPaint()
{
	if (IsIconic())
	{
		CPaintDC dc(this); // 用于绘制的设备上下文

		SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);

		// 使图标在工作区矩形中居中
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;

		// 绘制图标
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialogEx::OnPaint();
	}
}

//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CEAPSimulatorDlg::OnQueryDragIcon()
{
	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);	
	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);	
	if (GetDlgItem(IDC_BUTTON_DELETE_PPID) != nullptr) {
		GetDlgItem(IDC_BUTTON_DELETE_PPID)->EnableWindow(enabled);
	}
	if (GetDlgItem(IDC_EDIT_DELETE_PPID) != nullptr) {
		GetDlgItem(IDC_EDIT_DELETE_PPID)->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);
	}
	if (GetDlgItem(IDC_BUTTON_QUERY_ALL_SVID) != nullptr) {
		GetDlgItem(IDC_BUTTON_QUERY_ALL_SVID)->EnableWindow(enabled);
	}
	if (GetDlgItem(IDC_BUTTON_QUERY_ALL_CEID) != nullptr) {
		GetDlgItem(IDC_BUTTON_QUERY_ALL_CEID)->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();
}

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();
}

void CEAPSimulatorDlg::OnBnClickedButtonDeletePpid()
{
	CString strPPID;
	GetDlgItemText(IDC_EDIT_DELETE_PPID, strPPID);
	strPPID.Trim();
	std::vector<std::string> ppids;
	if (!strPPID.IsEmpty()) {
		CString upper = strPPID;
		upper.MakeUpper();
		if (upper != _T("ALL")) {
			int start = 0;
			CString token = strPPID.Tokenize(_T(","), start);
			while (!token.IsEmpty()) {
				token.Trim();
				if (!token.IsEmpty()) {
					ppids.push_back(std::string((LPTSTR)(LPCTSTR)token));
				}
				token = strPPID.Tokenize(_T(","), start);
			}
		}
	}
	// L:0 if ppids empty -> delete all
	theApp.m_model.m_pHsmsActive->hsmsDeletePPID(ppids);
}

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);
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryAllSvid()
{
	theApp.m_model.m_pHsmsActive->hsmsQueryAllStatusVariables();
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryAllDvid()
{
	theApp.m_model.m_pHsmsActive->hsmsQueryAllDataVariables();
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryAllCeid()
{
	theApp.m_model.m_pHsmsActive->hsmsQueryAllCollectionEvents();
}

void CEAPSimulatorDlg::OnBnClickedButtonQueryAllEcid()
{
	// empty list => all ECID
	std::vector<unsigned short> ecids;
	ecids.push_back(2000);
	theApp.m_model.m_pHsmsActive->hsmsEquipmentConstantRequest(ecids);
}

void CEAPSimulatorDlg::OnBnClickedButtonSetEcid()
{
	// simple demo: read ECID and value from edit boxes (reuse PPID edit)
	CString sEcid, sVal;
	GetDlgItemText(IDC_EDIT_ECID, sEcid);
	GetDlgItemText(IDC_EDIT_ECV, sVal);
	unsigned short id = static_cast<unsigned short>(_ttoi(sEcid));
	std::string val = CT2A(sVal);
	std::vector<std::pair<unsigned short, std::string>> kvs;
	if (id != 0) {
		kvs.push_back({ id, val });
		theApp.m_model.m_pHsmsActive->hsmsEquipmentConstantSend(kvs);
	}
}
void CEAPSimulatorDlg::OnBnClickedButtonQueryCurrentRecipe()
{
	CString sel;
	CComboBox* pCombo = (CComboBox*)GetDlgItem(IDC_COMBO_EQ_FOR_RECIPE);
	if (pCombo != nullptr) {
		int idx = pCombo->GetCurSel();
		if (idx != CB_ERR) {
			pCombo->GetLBText(idx, sel);
		}
	}
	unsigned int svid = SVID_EQPPExecName; // 默认全局
	CString upper = sel;
	upper.MakeUpper();
	if (upper.Find(_T("BONDER1")) != -1) svid = SVID_Bonder1CurrentRecipe;
	else if (upper.Find(_T("BONDER2")) != -1) svid = SVID_Bonder2CurrentRecipe;
	else if (upper.Find(_T("VACUUMBAKE")) != -1) svid = SVID_VacuumBakeCurrentRecipe;
	else if (upper.Find(_T("BAKECOOLING")) != -1) svid = SVID_BakeCoolingCurrentRecipe;
	else if (upper.Find(_T("MEASUREMENT")) != -1) svid = SVID_MeasurementCurrentRecipe;
	else if (upper.Find(_T("EFEM")) != -1) svid = SVID_EFEMCurrentRecipe;

	theApp.m_model.m_pHsmsActive->hsmsSelectedEquipmentStatusRequest(svid);
}

void CEAPSimulatorDlg::OnBnClickedButtonPpRequest()
{
	CString strPPID;
	GetDlgItemText(IDC_EDIT_PPID_REQ, strPPID);
	strPPID.Trim();
	std::string ppid = CT2A(strPPID);
	if (ppid.empty()) {
		AfxMessageBox(_T("请输入 PPID"));
		return;
	}
	theApp.m_model.m_pHsmsActive->hsmsProcessProgramRequest(ppid.c_str());
}