Merge branch 'clh' into liuyang

mrDarker

2025-10-22 e8a27bb203fe2aff70390a5eca002d7438da9b0f

 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);
@@ -136,6 +145,12 @@

   // 取得指定Variable
   SERVO::CVariable* getVariable(int variableId);
   SERVO::CVariable* getVariable(const char* pszName);

   // 设置变量值
   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);
@@ -173,7 +188,19 @@
   /* request开头的函数为主动发送数据的函数 */
   int requestAreYouThere();
   int requestAlarmReport(int ALCD, int ALID, const char* ALTX);
   int requestEventReportSend(unsigned int DATAID, unsigned int CEID, const std::vector<std::string>& values);
   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);
@@ -181,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);
@@ -196,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); }