Merge branch 'clh' into liuyang

mrDarker

2025-08-26 43c7dc211f10851480352b12bd01f3443079bb01

 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,7 @@
   int requestEventReportSend(unsigned int CEID);
   int requestEventReportSend(const char* pszEventName);
   int requestEventReportSend_CarrierID_Readed();
   int requestEventReportSend_PJ_Queued();

private:
   void replyAck(int s, int f, unsigned int systemBytes, BYTE ack, const char* pszAckName);
@@ -188,6 +199,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 +215,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); }