Bond2
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
LAPTOP-SNT8I5JK\Boounion
2025-08-27 2d6d21b907ce6863f5794aa0d7ee6a7f21f86e20 
 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


@@ -22,7 +24,19 @@


#define ER_PARAM_ERROR         -3


#define ER_NO_EVENT            -4


#define ER_UNLINK_EVENT_REPORT   -5


#define ER_NO_PPID_LIST         -6


#define ER_NOT_SUPPORTED      -7






/* CAACK */




#define CAACK_0               0      /* ok */


#define CAACK_1               1      /* invalid command */


#define CAACK_2               2      /* cannot perform now */


#define CAACK_3               3      /* invalid data or argument */


#define CAACK_4               4      /* initiated for asynchronous completion */


#define CAACK_5               5      /* rejected - invalid state */


#define CAACK_6               6      /* command performed with errors */




/*


 * 常量数据结构


@@ -67,6 +81,15 @@


typedef std::function<void(void* pFrom, SYSTEMTIME& time)> DATETIMESYNC;


typedef std::function<void(void* pFrom, bool bEnable, std::vector<unsigned int>& ids)> EDEVENTREPORT;


typedef std::function<void(void* pFrom, bool bEnable, unsigned int id)> EDALARMREPORT;


typedef std::function<std::vector<std::string> (void* pFrom)> QUERYPPIDLIST;


typedef std::function<unsigned int (void* pFrom,


   unsigned int DATAID,


   const char* pszCarrierAction,


   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;


@@ -77,6 +100,10 @@


   DATETIMESYNC            onDatetimeSync;


   EDEVENTREPORT            onEnableDisableEventReport;


   EDALARMREPORT            onEnableDisableAlarmReport;


   QUERYPPIDLIST            onQueryPPIDList;


   CARRIERACTION            onCarrierAction;


   PRJOBMULTICREATE         onPRJobMultiCreate;


   CONTROLJOBCREATE         onControlJobCreate;


} SECSListener;






@@ -93,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);


@@ -115,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);


@@ -142,13 +178,26 @@


   void OnTimer(UINT nTimerid);


   void setActionTimeout(int nSecond);


   int init(CModel* pModel, const char* pszName, unsigned int port);


   int loadCacheFromFile(const char* pszFilepath);


   int saveCache();


   int term();


   int serialize(char* pszBuffer, int nBufferSize);


   int unserialize(const char* pszBuffer, int nBufferSize);




public:


   /* 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_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);


@@ -156,6 +205,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);


@@ -166,9 +216,13 @@


   int replyEanbleDisableEventReport(IMessage* pRecv);


   int replyCommand(IMessage* pRecv);


   int replyConfigureSpooling(IMessage* pRecv);


   int replyCarrierAction(IMessage* pRecv);


   int replyEanbleDisableAlarmReport(IMessage* pRecv);


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


@@ -189,6 +243,7 @@


   CRITICAL_SECTION m_criticalSection;


   std::list<CHsmsAction*> m_listAction;


   std::list<CHsmsAction*> m_listActionSent;


   std::list<CHsmsAction*> m_listActionSpooling;




private:


   SECSListener m_listener;


@@ -196,6 +251,8 @@


   HANDLE m_hCimWorkEvent;


   HANDLE m_hCimWorkThreadHandle;


   unsigned m_nCimWorkThrdaddr;


   std::string m_strCacheFilepath;


   CHsmsAction* m_pActiveAction;




private:


   // CVariable vector