From d5c8d6545efe0ab2026a4127fde0fa2bad659ccd Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期三, 06 八月 2025 14:45:52 +0800
Subject: [PATCH] 1.实现EAP中ProceedWithCarrier和CarrierRelease的功能模拟及测试;

---
 SourceCode/Bond/Servo/CMaster.h |   48 +++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 45 insertions(+), 3 deletions(-)

diff --git a/SourceCode/Bond/Servo/CMaster.h b/SourceCode/Bond/Servo/CMaster.h
index e6cf6fa..27d0973 100644
--- a/SourceCode/Bond/Servo/CMaster.h
+++ b/SourceCode/Bond/Servo/CMaster.h
@@ -16,11 +16,13 @@
 
 
 namespace SERVO {
-    enum MASTERSTATE {
+    enum class MASTERSTATE {
         READY = 0,
         STARTING,
         RUNNING,
-        STOPPING
+        RUNNING_CONTINUOUS_TRANSFER,
+        STOPPING,
+        MSERROR
     };
 
     typedef std::function<void(void* pMaster, MASTERSTATE state)> ONMASTERSTATECHANGED;
@@ -29,6 +31,8 @@
     typedef std::function<void(void* pMaster, CEquipment* pEquipment, int state, int alarmId, int unitId, int level)> ONEQALARM;
     typedef std::function<void(void* pMaster, CEquipment* pEquipment, CVcrEventReport* pReport)> ONEQVCREVENTREPORT;
     typedef std::function<void(void* pMaster, CEquipment* pEquipment, int code)> ONEQDATACHANGED;
+    typedef std::function<void(void* pMaster, CRobotTask* pTask, int code)> ONROBOTTASKEVENT;
+    typedef std::function<void(void* pMaster, CEquipment* pEquipment, short status, __int64 data)> ONLOADPORTSTATUSCHANGED;
     typedef struct _MasterListener
     {
         ONMASTERSTATECHANGED    onMasterStateChanged;
@@ -37,13 +41,15 @@
         ONEQALARM               onEqAlarm;
         ONEQVCREVENTREPORT	    onEqVcrEventReport;
         ONEQDATACHANGED         onEqDataChanged;
+        ONROBOTTASKEVENT        onRobotTaskEvent;
+        ONLOADPORTSTATUSCHANGED	onLoadPortStatusChanged;
     } MasterListener;
 
     class CMaster
     {
     public:
         CMaster();
-        ~CMaster();
+        virtual ~CMaster();
 
 
     public:
@@ -52,7 +58,9 @@
         int init();
         int term();
         int start();
+        int startContinuousTransfer();
         int stop();
+        void clearError();
         ULONGLONG getRunTime();
         MASTERSTATE getState();
         unsigned DispatchProc();
@@ -61,6 +69,20 @@
         std::list<CEquipment*>& getEquipmentList();
         CEquipment* getEquipment(int id);
         void setCacheFilepath(const char* pszFilepath);
+        int abortCurrentTask();
+        int restoreCurrentTask();
+        int resendCurrentTask();
+        void setPortType(unsigned int index, BOOL enable, int type, int mode,
+            int cassetteType, int transferMode, BOOL autoChangeEnable);
+        void setPortCassetteType(unsigned int index, SERVO::CassetteType type);
+        void setPortEnable(unsigned int index, BOOL bEnable);
+        void setCompareMapsBeforeProceeding(BOOL bCompare);
+        void datetimeSync(SYSTEMTIME& time);
+        void enableEventReport(bool bEnable);
+        void enableAlarmReport(bool bEnable);
+        bool isAlarmReportEnable();
+        int proceedWithCarrier(unsigned int port);
+        int carrierRelease(unsigned int port);
 
     private:
         inline void lock() { EnterCriticalSection(&m_criticalSection); }
@@ -82,6 +104,15 @@
         int readCache();
         void serialize(CArchive& ar);
         void setState(MASTERSTATE state);
+        CRobotTask* createTransferTask(CEquipment* pSrcEq, CEquipment* pTarEq,
+            MaterialsType primaryType = MaterialsType::G1, MaterialsType secondaryType = MaterialsType::G2,
+            int armNo = 1);
+        CRobotTask* createTransferTask_bonder_to_bakecooling(CEquipment* pSrcEq, CEquipment* pTarEq);
+        CRobotTask* createTransferTask_bake_to_cooling(CEquipment* pSrcEq);
+        CRobotTask* createTransferTask_bakecooling_to_measurement(CEquipment* pSrcEq, CEquipment* pTarEq);
+        CRobotTask* createTransferTask_restore(CEquipment* pEqSrc, CLoadPort** pPorts);
+        CRobotTask* createTransferTask_continuous_transfer(CEquipment* pSrcEq, int nSrcSlot,
+            CEquipment* pTarEq, int nTarSlot, int armNo = 1);
 
     private:
         CRITICAL_SECTION m_criticalSection;
@@ -90,6 +121,7 @@
         std::list<CEquipment*> m_listEquipment;
         std::string m_strFilepath;
         BOOL m_bDataModify;
+        bool m_bContinuousTransfer;
 
     private:
         /* 监控比特位的线程*/
@@ -111,6 +143,16 @@
         // 当前任务和已完成任务列表
         CRobotTask* m_pActiveRobotTask;
         std::list< CRobotTask* > m_listTask;
+
+        // 错误代码
+        int m_nLastError;
+        std::string m_strLastError;
+
+        // 在开始工艺前是否先需要先比较map
+        BOOL m_isCompareMapsBeforeProceeding;
+    private:
+        bool m_bEnableEventReport;
+        bool m_bEnableAlarmReport;
     };
 }
 

--
Gitblit v1.9.3