1.接上，日志完善；

chenluhua1980

6 天以前 d400f022161ff47f02cd0ea95a5076d0187ecd4d

 SourceCode/Bond/Servo/HsmsPassive.h

@@ -1,11 +1,15 @@
#pragma once
#pragma once
#include <string>
#include <list>
#include "HsmsAction.h"
#include <functional>
#include <vector>
#include <map>
#include <set>
#include "CCollectionEvent.h"
#include "ProcessJob.h"
#include "CControlJob.h"
#include "CDataVariable.h"


#define EQCONSTANT_VALUE_MAX   64
@@ -15,14 +19,30 @@
#define VALUE_NAME_MAX         64


#define ER_NOERROR         0
#define ER_NOTSELECT      -1
#define ER_BUSY            -2
#define ER_PARAM_ERROR      -3
#define ER_NOERROR            0
#define ER_NOTSELECT         -1
#define ER_BUSY               -2
#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
#define ER_CREATED_MESSAGE      -8



/* 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 */

/*
 * 常量数据结构
 * 常量数据结构
 */
typedef struct _EQConstant
{
@@ -31,7 +51,7 @@
} EQConstant;

/*
 * Command 数据结构
 * Command 数据结构
 */
typedef struct _CommandParameter
{
@@ -40,7 +60,7 @@
} CommandParameter;

/*
 * Report 数据结构
 * Report 数据结构
 */
typedef struct _REPORT
{
@@ -49,7 +69,7 @@
} REPORT;

/*
 * Value 数据结构
 * Value 数据结构
 */
typedef struct _VALUE
{
@@ -59,21 +79,33 @@


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;
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 std::function<bool(void* pFrom, const std::vector<std::string>& ppids)> DELETEPPID;
typedef struct _SECSListener
{
   SECSEQOFFLINE            onEQOffLine;
   SECSEQOFFLINE            onEQOnLine;
   SECSEQCONSTANTREQUEST      onEQConstantRequest;
   SECSEQCONSTANTREQUEST      onEQConstantSend;
   SECSCommand               onCommand;
   DATETIMESYNC            onDatetimeSync;
   EDEVENTREPORT            onEnableDisableEventReport;
   EDALARMREPORT            onEnableDisableAlarmReport;
   QUERYPPIDLIST            onQueryPPIDList;
   DELETEPPID               onDeletePPID;
   CARRIERACTION            onCarrierAction;
   PRJOBMULTICREATE         onPRJobMultiCreate;
   CONTROLJOBCREATE         onControlJobCreate;
} SECSListener;


@@ -85,65 +117,140 @@
   ~CHsmsPassive();

public:
   /* 设置机器型号 最大长度 20 bytes */
   /* 设置机器型号 最大长度 20 bytes */
   void setEquipmentModelType(const char* pszMode);

   /* 设置软件版本号 最大长度 20 bytes */
   /* 设置软件版本号 最大长度 20 bytes */
   void setSoftRev(const char* pszRev);

   /* 添加Report */
   void addReport(unsigned int id, const char* pszName);
   /* 添加变量值到ISECS2Item */
   void addVariableValueToItem(ISECS2Item* pParent, SERVO::CVariable* pVariable);

   // 连接Report
   void linkEventReport(unsigned int RPTID, unsigned int CEID);
   // 连接Report
   void linkEventReport(unsigned int CEID, unsigned int RPTID);

   // 取消连接report
   // 取消连接report
   void unlinkEventReport(unsigned int CEID);

   unsigned int getCEID(int RPTID);

   // define Report
   void defineReport(unsigned int VID, unsigned int RPTID);
   SERVO::CReport* defineReport(unsigned int RPTID, std::vector<unsigned int>& vids);

   // 取消 define report
   void deleteReport(unsigned int RPTID);
   // 取消 define report
   bool removeReport(int rptid);
   int deleteReport(int rptid);
   int addReport(int rptid, const std::vector<unsigned int>& vids);
   int updateReport(int rptid, const std::vector<unsigned int>& vids);
   void clearAllReport(BOOL bSave = FALSE);

   // 取消/删除所有 define report
   void deleteAllReport();

   // 从文件中加载CVariable列表
   // 从文件中加载CVariable列表
   int loadVarialbles(const char* pszFilepath);
   // 从文件中加载CDataVariable列表
   int loadDataVarialbles(const char* pszFilepath);
   // 从文件中加载Equipment Constant列表
   int loadEquipmentConstants(const char* pszFilepath);

   // 取得CVariable列表
   // 取得CVariable列表
   std::vector<SERVO::CVariable*>& getVariables();
   unsigned int getMaxVariableId() const;
   std::vector<SERVO::CDataVariable*>& getDataVariables();
   unsigned int getMaxDataVariableId() const;

   // 取得指定Variable
   // 取得指定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);

   // 从文件中加载CReport表表
   // 设置变量值
   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);
   // 执行一段持锁的代码块，用于保证 set+send 的原子性
   void withVariableLock(const std::function<void()>& fn);

   // 从文件中加载CReport列表
   int loadReports(const char* pszFilepath);

   // 取得Report列表
   std::vector<SERVO::CReport*>& getReports();
   unsigned int getMaxReportId() const;

   // 从文件中加载CCollectionEvent列表
   int loadCollectionEvents(const char* pszFilepath);

   // 取得CCollectionEvent列表
   std::vector<SERVO::CCollectionEvent*>& getCollectionEvents();
   unsigned int getMaxCollectionEventId() const;

   // 取消/删除所有CollectionEvent
   void clearAllCollectionEvent();
   int deleteCollectionEvent(unsigned short CEID);
   int addCollectionEvent(unsigned int CEID, const char* name, const char* desc, const std::vector<unsigned int>& rptids);
   int updateCollectionEvent(unsigned int CEID, const char* name, const char* desc, const std::vector<unsigned int>& rptids);

   // 取得CCollectionEvent
   SERVO::CCollectionEvent* getEvent(unsigned short CEID);

   // 取得Report
   SERVO::CReport* getReport(int rptid);

   void setListener(SECSListener listener);
   unsigned OnCimWork();
   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开头的函数为主动发送数据的函数 */
   /* request开头的函数为主动发送数据的函数 */
   int requestAreYouThere();
   int requestAlarmReport(int ALCD, int ALID, const char* ALTX);
   int requestEventReportSend(unsigned int DATAID, unsigned int RPTID, const std::vector<std::string>& values);
   int requestEventReportSend(unsigned int CEID);
   int requestEventReportSend(const char* pszEventName);
   int requestEventReportSend_CarrierID_Readed();
   int requestEventReportSend_CheckSlotMap();
   int requestEventReportSend_SlotMapVerificationOK();
   int requestEventReportSend_SlotMapVerificationNG();
   int requestEventReportSend_Port_Unload_Ready();
   int requestEventReportSend_Port_Load_Ready();
   int requestEventReportSend_Port_Ready_To_Release();
   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();
   int requestEventReportSend_OCR_PanelID_Read_OK();
   int requestEventReportSend_OCR_PanelID_Read(short vcrResult);
   int requestEventReportSend_LoadPortNotAssoc();
   int requestEventReportSend_ProcessDataReport();
   int requestEventReportSend_SubEqpStart();
   int requestEventReportSend_SubEqpEnd();

private:
   void replyAck(int s, int f, unsigned int systemBytes, BYTE ack, const char* pszAckName);

   /* reply开头的函数为回复函数 */
   /* reply开头的函数为回复函数 */
   int replyAreYouThere(IMessage* pRecv);
   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);
   int replyEquipmentConstantRequest(IMessage* pRecv);
@@ -153,17 +260,29 @@
   int replyLinkEventReport(IMessage* pRecv);
   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 replyDeletePPID(IMessage* pRecv); // S7F17/S7F18
   int replyProcessProgramRequest(IMessage* pRecv); // S7F5/S7F6
   int replyTerminalDisplay(IMessage* pRecv);
   int replyCreateObj(IMessage* pRecv);
   int replyPRJobMultiCreate(IMessage* pRecv);

private:
   inline void Lock() { EnterCriticalSection(&m_criticalSection); }
   inline void Unlock() { LeaveCriticalSection(&m_criticalSection); }
   int onRecvMsg(IMessage* pMessage);
   void clearAllVariabel();
   std::vector<int> parseVidList(CString& strNums);
   void clearAllReport();
   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);

private:
   CModel* m_pModel;
@@ -177,31 +296,60 @@
   CRITICAL_SECTION m_criticalSection;
   std::list<CHsmsAction*> m_listAction;
   std::list<CHsmsAction*> m_listActionSent;
   std::list<CHsmsAction*> m_listActionSpooling;

private:
   SECSListener m_listener;
   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;
   unsigned m_nCimWorkThrdaddr;
   std::string m_strCacheFilepath;
   CHsmsAction* m_pActiveAction;

private:
   // RPTID to CEID
   std::map<unsigned int, unsigned int> m_mapReportIdToCEID;
	
   // RPTID to Report
   std::map<unsigned int, REPORT> m_mapReport;

   // VID to RPTID
   std::map<unsigned int, unsigned int> m_mapValueIdToPRTID;

   // VID to Report
   std::map<unsigned int, VALUE> m_mapValue;

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

   // CollectionEvent vector
   std::vector<SERVO::CCollectionEvent*> m_collectionEvents;

   // Spooling blacklist: StreamId -> {FunctionId...}
   // In this map means DO NOT spool/cache.
   // Special case: stream 1 is not spooled regardless of config.
   // If a stream key exists with empty set => blacklist ALL functions in that stream.
   std::map<uint16_t, std::set<uint16_t>> m_spoolBlacklistByStream;
   bool m_spoolingEnabled{ true };

private:
   bool shouldSpool(uint8_t streamId, uint8_t functionId) const;
};