Bond2
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
LAPTOP-SNT8I5JK\Boounion
2025-10-10 7ddca21fdb798123239eab9daa390e2702afdff7 
 SourceCode/Bond/Servo/CMaster.h


@@ -15,6 +15,7 @@


#include "CRobotTask.h"


#include "ProcessJob.h"


#include "CControlJob.h"


#include "../DAQBridge/core/Collector.h"






#define CTStep_Unknow                   0


@@ -33,6 +34,10 @@


#define CTStep_begin                    CTStep_LoadPort_Aligner


#define CTStep_end                      CTStep_Measurement_LoadPort




#define ER_CODE_NOERROR                0


#define ER_CODE_OPERATION_MODE_FAIL    -1


#define ER_CODE_AOI_NG                 -2




namespace SERVO {


    enum class MASTERSTATE {


        READY = 0,


@@ -41,7 +46,8 @@


        RUNNING_CONTINUOUS_TRANSFER,


        RUNNING_BATCH,


        STOPPING,


        MSERROR


        MSERROR,


        ATHERERROR


    };




    typedef std::function<void(void* pMaster, MASTERSTATE state)> ONMASTERSTATECHANGED;


@@ -88,7 +94,7 @@


        int start();


        int startContinuousTransfer();


        int startBatch();


        int stop();


        int stop(int nErCode = ER_CODE_NOERROR);


        void clearError();


        ULONGLONG getRunTime();


        MASTERSTATE getState();


@@ -102,8 +108,9 @@


        int abortCurrentTask();


        int restoreCurrentTask();


        int resendCurrentTask();


        void setPortType(unsigned int index, BOOL enable, int type, int mode,


        void setPortTypeEx(unsigned int index, BOOL enable, int type, int mode,


            int cassetteType, int transferMode, BOOL autoChangeEnable);


        void setPortType(unsigned int index, int type);


        void setPortCassetteType(unsigned int index, SERVO::CassetteType type);


        void setPortEnable(unsigned int index, BOOL bEnable);


        void setCompareMapsBeforeProceeding(BOOL bCompare);


@@ -123,7 +130,15 @@


        CControlJob* getControlJob();


        CLoadPort* getPortWithCarrierId(const std::string& carrierId) const;


        bool saveState() const;


        bool loadState(const std::string& path);


        bool loadState();


        void setStateFile(const std::string& path);


        int getWipGlasses(std::vector<CGlass*>& glasses);


        void test();


        bool moveGlassToBuf(int eqid, int slotNo);


        bool moveGlassToSlot(int eqid, int slotNo);


        int getPortCassetteSnSeed(int port);


        void setPortCassetteSnSeed(int port, int seed);


        CGlass* getGlass(int scrPort, int scrSlot);




    private:


        inline void lock() { EnterCriticalSection(&m_criticalSection); }


@@ -164,6 +179,10 @@


        bool ceidDefined(uint32_t ceid) const override;




    public:


        int getLastError();


        std::string& getLastErrorText();




    public:


        // 新增函数


        CProcessJob* acquireNextProcessJob();


        CGlass* acquireNextGlass();


@@ -175,7 +194,11 @@


        bool checkAndUpdatePjComplete(CProcessJob* pJob);


        bool checkAndUpdateCjComplete(CControlJob* pJob);


        CProcessJob* getGlassProcessJob(CGlass* pGlass);




        bool completeControlJob();


        bool forceCompleteControlJob(std::string description);


        bool canCreateControlJob();


        bool canCompleteControlJob();


        bool canDeleteControlJob();




    private:


        CRITICAL_SECTION m_criticalSection;


@@ -220,6 +243,8 @@


        // 千传圈数计数


        int m_nContinuousTransferCount;


        int m_nContinuousTransferStep;


        int m_nContinuousWorkingPort;


        int m_nContinuousWorkingSlot;




        // 新增已经开始处理的ProcessJob列表


        std::vector<CProcessJob*> m_inProcesJobs;


@@ -236,6 +261,11 @@


        std::string m_strStatePath;




        int m_nTestFlag;


        std::list<CGlass*> m_bufGlass;




    private:


        Collector* m_pCollector = nullptr;


        void CreateDAQBridgeServer();


    };


}