From 829fe6c6bc33d53fda9c31fd45a37e1df87befff Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期五, 30 一月 2026 11:16:24 +0800
Subject: [PATCH] Merge branch 'clh' into liuyang

---
 SourceCode/Bond/Servo/HsmsPassive.h |   38 +++++++++++++++++++++++++++++++++++---
 1 files changed, 35 insertions(+), 3 deletions(-)

diff --git a/SourceCode/Bond/Servo/HsmsPassive.h b/SourceCode/Bond/Servo/HsmsPassive.h
index d9e7e96..81c5188 100644
--- a/SourceCode/Bond/Servo/HsmsPassive.h
+++ b/SourceCode/Bond/Servo/HsmsPassive.h
@@ -9,6 +9,7 @@
 #include "CCollectionEvent.h"
 #include "ProcessJob.h"
 #include "CControlJob.h"
+#include "CDataVariable.h"
 
 
 #define EQCONSTANT_VALUE_MAX	64
@@ -78,7 +79,6 @@
 
 
 typedef std::function<void(void* pFrom)> SECSEQOFFLINE;
-typedef std::function<void(void* pFrom, std::vector<EQConstant>&)> SECSEQCONSTANTREQUEST;
 typedef std::function<void(void* pFrom, const char*, std::vector<CommandParameter>&)> SECSCommand;
 typedef std::function<void(void* pFrom, SYSTEMTIME& time)> DATETIMESYNC;
 typedef std::function<void(void* pFrom, bool bEnable, std::vector<unsigned int>& ids)> EDEVENTREPORT;
@@ -97,8 +97,6 @@
 {
 	SECSEQOFFLINE				onEQOffLine;
 	SECSEQOFFLINE				onEQOnLine;
-	SECSEQCONSTANTREQUEST		onEQConstantRequest;
-	SECSEQCONSTANTREQUEST		onEQConstantSend;
 	SECSCommand					onCommand;
 	DATETIMESYNC				onDatetimeSync;
 	EDEVENTREPORT				onEnableDisableEventReport;
@@ -146,19 +144,30 @@
 
 	// 浠庢枃浠朵腑鍔犺浇CVariable鍒楄〃
 	int loadVarialbles(const char* pszFilepath);
+	// 浠庢枃浠朵腑鍔犺浇CDataVariable鍒楄〃
+	int loadDataVarialbles(const char* pszFilepath);
+	// 浠庢枃浠朵腑鍔犺浇Equipment Constant鍒楄〃
+	int loadEquipmentConstants(const char* pszFilepath);
 
 	// 鍙栧緱CVariable鍒楄〃
 	std::vector<SERVO::CVariable*>& getVariables();
 	unsigned int getMaxVariableId() const;
+	std::vector<SERVO::CDataVariable*>& getDataVariables();
+	unsigned int getMaxDataVariableId() const;
 
 	// 鍙栧緱鎸囧畾Variable
 	SERVO::CVariable* getVariable(int variableId);
 	SERVO::CVariable* getVariable(const char* pszName);
+	SERVO::CDataVariable* getDataVariable(int dvid);
+	SERVO::CDataVariable* getDataVariable(const char* pszName);
 	int getCurrentControlState();
 	bool isHostCommandAllowed();
 	int deleteVariable(int variableId);
 	int addVariable(const char* pszName, const char* pszFormat, const char* pszRemark, int& outId);
 	int updateVariable(int variableId, const char* pszName, const char* pszFormat, const char* pszRemark);
+	int deleteDataVariable(int dvid);
+	int addDataVariable(const char* pszName, const char* pszFormat, const char* pszRemark, int& outId);
+	int updateDataVariable(int dvid, const char* pszName, const char* pszFormat, const char* pszRemark);
 
 	// 璁剧疆鍙橀噺鍊�
 	void setVariableValue(const char* pszName, __int64 value);
@@ -226,6 +235,7 @@
 	int requestEventReportSend_Panel_Start();
 	int requestEventReportSend_Panel_End();
 	int requestEventReportSend_OCR_PanelID_Read_OK();
+	int requestEventReportSend_OCR_PanelID_Read(short vcrResult);
 	int requestEventReportSend_LoadPortNotAssoc();
 	int requestEventReportSend_ProcessDataReport();
 	int requestEventReportSend_SubEqpStart();
@@ -239,6 +249,7 @@
 	int replyEstablishCommunications(IMessage* pRecv);
 	int replySelectedEquipmentStatusData(IMessage* pRecv);
 	int replyStatusVariableNamelistRequest(IMessage* pRecv);  // S1F11/S1F12
+	int replyDataVariableNamelistRequest(IMessage* pRecv);    // S1F21/S1F22
 	int replyCollectionEventNamelistRequest(IMessage* pRecv); // S1F23/S1F24
 	int replyOnLine(IMessage* pRecv);
 	int replyOffLine(IMessage* pRecv);
@@ -255,6 +266,7 @@
 	int replyPurgeSpooledData(IMessage* pRecv);
 	int replyQueryPPIDList(IMessage* pRecv);
 	int replyDeletePPID(IMessage* pRecv); // S7F17/S7F18
+	int replyProcessProgramRequest(IMessage* pRecv); // S7F5/S7F6
 	int replyTerminalDisplay(IMessage* pRecv);
 	int replyCreateObj(IMessage* pRecv);
 	int replyPRJobMultiCreate(IMessage* pRecv);
@@ -264,8 +276,11 @@
 	inline void Unlock() { LeaveCriticalSection(&m_criticalSection); }
 	int onRecvMsg(IMessage* pMessage);
 	void clearAllVariabel();
+	void clearAllDataVariabel();
 	std::vector<unsigned int> parseVidList(CString& strNums);
 	int writeVariablesToFile(const std::string& filepath);
+	int writeDataVariablesToFile(const std::string& filepath);
+	int writeEquipmentConstantsToFile(const std::string& filepath);
 	int writeReportsToFile(const std::string& filepath);
 	int writeCollectionEventsToFile(const std::string& filepath);
 
@@ -288,12 +303,18 @@
 	std::string m_strVariableFilepath;
 	bool m_bVariableUtf8{ false };
 	bool m_bVariableUtf8Bom{ false };
+	std::string m_strDataVariableFilepath;
+	bool m_bDataVariableUtf8{ false };
+	bool m_bDataVariableUtf8Bom{ false };
 	std::string m_strReportFilepath;
 	bool m_bReportUtf8{ false };
 	bool m_bReportUtf8Bom{ false };
 	std::string m_strCollectionEventFilepath;
 	bool m_bCollectionUtf8{ false };
 	bool m_bCollectionUtf8Bom{ false };
+	std::string m_strEquipmentConstantFilepath;
+	bool m_bEquipmentConstantUtf8{ false };
+	bool m_bEquipmentConstantUtf8Bom{ false };
 	BOOL m_bCimWorking;
 	HANDLE m_hCimWorkEvent;
 	HANDLE m_hCimWorkThreadHandle;
@@ -304,6 +325,17 @@
 private:
 	// CVariable vector
 	std::vector<SERVO::CVariable*> m_variabels;
+	// CDataVariable vector
+	std::vector<SERVO::CDataVariable*> m_dataVariabels;
+	// Equipment constants
+	struct EquipmentConstantEntry {
+		unsigned int id{ 0 };
+		std::string name;
+		std::string format;
+		std::string remark;
+		std::string value;
+	};
+	std::vector<EquipmentConstantEntry> m_equipmentConstants;
 
 	// CReport vector
 	std::vector<SERVO::CReport*> m_reports;

--
Gitblit v1.9.3