From e8a27bb203fe2aff70390a5eca002d7438da9b0f Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期三, 22 十月 2025 14:24:34 +0800
Subject: [PATCH] Merge branch 'clh' into liuyang

---
 SourceCode/Bond/Servo/HsmsPassive.h |   23 +++++++++++++++++++++++
 1 files changed, 23 insertions(+), 0 deletions(-)

diff --git a/SourceCode/Bond/Servo/HsmsPassive.h b/SourceCode/Bond/Servo/HsmsPassive.h
index f542cf7..1863abd 100644
--- a/SourceCode/Bond/Servo/HsmsPassive.h
+++ b/SourceCode/Bond/Servo/HsmsPassive.h
@@ -7,6 +7,8 @@
 #include <map>
 #include <set>
 #include "CCollectionEvent.h"
+#include "ProcessJob.h"
+#include "CControlJob.h"
 
 
 #define EQCONSTANT_VALUE_MAX	64
@@ -86,6 +88,8 @@
 	const char* pszCarrierId,
 	unsigned char PTN, 
 	std::string& strErrorTxt)> CARRIERACTION;
+typedef std::function<int(void* pFrom, std::vector<SERVO::CProcessJob*>& pjs)> PRJOBMULTICREATE;
+typedef std::function<int(void* pFrom, SERVO::CControlJob& controlJob)> CONTROLJOBCREATE;
 typedef struct _SECSListener
 {
 	SECSEQOFFLINE				onEQOffLine;
@@ -98,6 +102,8 @@
 	EDALARMREPORT				onEnableDisableAlarmReport;
 	QUERYPPIDLIST				onQueryPPIDList;
 	CARRIERACTION				onCarrierAction;
+	PRJOBMULTICREATE			onPRJobMultiCreate;
+	CONTROLJOBCREATE			onControlJobCreate;
 } SECSListener;
 
 
@@ -114,6 +120,9 @@
 
 	/* 设置软件版本号 最大长度 20 bytes */
 	void setSoftRev(const char* pszRev);
+
+	/* 添加变量值到ISECS2Item */
+	void addVariableValueToItem(ISECS2Item* pParent, SERVO::CVariable* pVariable);
 
 	// 连接Report
 	void linkEventReport(unsigned int CEID, unsigned int RPTID);
@@ -141,6 +150,7 @@
 	// 设置变量值
 	void setVariableValue(const char* pszName, __int64 value);
 	void setVariableValue(const char* pszName, const char* value);
+	void setVariableValue(const char* pszName, std::vector<SERVO::CVariable>& vars);
 
 	// 从文件中加载CReport列表
 	int loadReports(const char* pszFilepath);
@@ -181,6 +191,16 @@
 	int requestEventReportSend(unsigned int CEID);
 	int requestEventReportSend(const char* pszEventName);
 	int requestEventReportSend_CarrierID_Readed();
+	int requestEventReportSend_Port_Unload_Ready();
+	int requestEventReportSend_Port_Load_Ready();
+	int requestEventReportSend_Port_Blocked();
+	int requestEventReportSend_PJ_Queued();
+	int requestEventReportSend_PJ_Start();
+	int requestEventReportSend_PJ_End();
+	int requestEventReportSend_CJ_Start();
+	int requestEventReportSend_CJ_End();
+	int requestEventReportSend_Panel_Start();
+	int requestEventReportSend_Panel_End();
 
 private:
 	void replyAck(int s, int f, unsigned int systemBytes, BYTE ack, const char* pszAckName);
@@ -188,6 +208,7 @@
 	/* reply开头的函数为回复函数 */
 	int replyAreYouThere(IMessage* pRecv);
 	int replyEstablishCommunications(IMessage* pRecv);
+	int replySelectedEquipmentStatusData(IMessage* pRecv);
 	int replyOnLine(IMessage* pRecv);
 	int replyOffLine(IMessage* pRecv);
 	int replyEquipmentConstantRequest(IMessage* pRecv);
@@ -203,6 +224,8 @@
 	int replyPurgeSpooledData(IMessage* pRecv);
 	int replyQueryPPIDList(IMessage* pRecv);
 	int replyTerminalDisplay(IMessage* pRecv);
+	int replyCreateObj(IMessage* pRecv);
+	int replyPRJobMultiCreate(IMessage* pRecv);
 
 private:
 	inline void Lock() { EnterCriticalSection(&m_criticalSection); }

--
Gitblit v1.9.3