Merge branch 'clh' into liuyang

mrDarker

6 天以前 829fe6c6bc33d53fda9c31fd45a37e1df87befff

 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
@@ -26,6 +27,8 @@
#define ER_UNLINK_EVENT_REPORT   -5
#define ER_NO_PPID_LIST         -6
#define ER_NOT_SUPPORTED      -7
#define ER_CREATED_MESSAGE      -8



/* CAACK */
@@ -76,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;
@@ -90,17 +92,17 @@
   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;
@@ -142,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);
@@ -222,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();
@@ -235,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);
@@ -250,6 +265,8 @@
   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);
@@ -259,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);

@@ -283,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;
@@ -299,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;