From e8a27bb203fe2aff70390a5eca002d7438da9b0f Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期三, 22 十月 2025 14:24:34 +0800
Subject: [PATCH] Merge branch 'clh' into liuyang

---
 SourceCode/Bond/Servo/CEquipment.h |   76 ++++++++++++++++++++++++++++++-------
 1 files changed, 61 insertions(+), 15 deletions(-)

diff --git a/SourceCode/Bond/Servo/CEquipment.h b/SourceCode/Bond/Servo/CEquipment.h
index 8807f13..36a05c9 100644
--- a/SourceCode/Bond/Servo/CEquipment.h
+++ b/SourceCode/Bond/Servo/CEquipment.h
@@ -35,6 +35,8 @@
 #include "CProcessData.h"
 #include "CPortStatusReport.h"
 #include "CSlot.h"
+#include "CParam.h"
+#include "CSVData.h"
 
 
 namespace SERVO {
@@ -43,7 +45,7 @@
 #define SIGNAL_UPSTREAM_TROUBLE	1
 #define SIGNAL_INTERLOCK		2
 #define SIGNAL_SEND_ABLE		3
-#define SIGNAL_RECEIVE_ABLE		4
+#define SIGNAL_RECEIVE_ABLE		3
 
 	typedef std::function<void(int writeCode, int retCode)> ONWRITEDRET;
 
@@ -51,9 +53,12 @@
 	typedef std::function<void(void* pEiuipment, int code)> ONDATACHANGED;
 	typedef std::function<void(void* pEiuipment, int state, int alarmId, int unitId, int level)> ONALARM;
 	typedef std::function<void(void* pEiuipment, void* pReport)> ONVCREVENTREPORT;
-	typedef std::function<BOOL(void* pEiuipment, CJobDataB* pJobDataB)> ONPREFETCHEDOUTJOB;
-	typedef std::function<BOOL(void* pEiuipment, CJobDataB* pJobDataB, short& putSlot)> ONPRESTOREDJOB;
-	typedef std::function<void(void* pEiuipment, PROCESS_STATE state)> ONPROCESSSTATE;
+	typedef std::function<BOOL(void* pEiuipment, int port, CJobDataB* pJobDataB)> ONPREFETCHEDOUTJOB;
+	typedef std::function<BOOL(void* pEiuipment, int port, CJobDataB* pJobDataB, short& putSlot)> ONPRESTOREDJOB;
+	typedef std::function<void(void* pEiuipment, int nSlotNo, PROCESS_STATE state)> ONPROCESSSTATE;
+	typedef std::function<void(void* pEiuipment, short scanMap, short downMap)> ONMAPMISMATCH;
+	typedef std::function<void(void* pEiuipment, short status, __int64 data)> ONPORTSTATUSCHANGED;
+	
 	typedef struct _EquipmentListener
 	{
 		ONALIVE				onAlive;
@@ -64,6 +69,10 @@
 		ONPREFETCHEDOUTJOB	onPreFethedOutJob;
 		ONPRESTOREDJOB		onPreStoredJob;
 		ONPROCESSSTATE		onProcessStateChanged;
+		ONMAPMISMATCH		onMapMismatch;
+		ONPORTSTATUSCHANGED	onPortStatusChanged;
+		ONVCREVENTREPORT	onSVDataReport;
+		ONVCREVENTREPORT	onPanelDataReport;
 	} EquipmentListener;
 
 
@@ -74,6 +83,8 @@
 		virtual ~CEquipment();
 
 	public:
+		void SetEnable(BOOL bEnable);
+		BOOL IsEnabled() const;
 		virtual const char* getClassName() = 0;
 		virtual void setListener(EquipmentListener listener);
 		void setCcLink(CCCLinkIEControl* pCcLink);
@@ -110,14 +121,16 @@
 		virtual void onReceiveLBData(const char* pszData, size_t size);
 		virtual int onStepEvent(CStep* pStep, int code);
 		virtual CPin* addPin(PinType type, char* pszName);
-		virtual short getSlotUnit(short slot) { return 0; };
+		virtual short getSlotUnit(short slotNo) { return 0; };
 		CPin* getPin(char* pszName);
 		std::vector<CPin*>& CEquipment::getInputPins();
 		std::vector<CPin*>& CEquipment::getOutputPins();
 		CRecipeList* getRecipeList(int unitNo);
+		bool saveRecipeList(int unitNo, std::string& strFilepath);
+		bool readRecipeList(int unitNo, std::string& strFilepath);
 		virtual int recvIntent(CPin* pPin, CIntent* pIntent);
-		virtual int fetchedOutJob(CJobDataB* pJobDataB);
-		virtual int storedJob(CJobDataB* pJobDataB, short putSlot);
+		virtual int fetchedOutJob(int port, CJobDataB* pJobDataB);
+		virtual int storedJob(int port, CJobDataB* pJobDataB, short putSlot);
 		virtual int onReceivedJob(int port, CJobDataS* pJobDataS);
 		virtual int onSentOutJob(int port, CJobDataS* pJobDataS);
 		virtual BOOL onPreFetchedOutJob(int port, CJobDataB* pJobDataB);
@@ -125,10 +138,11 @@
 		virtual BOOL onPreStoredJob(int port, CJobDataB* pJobDataB, short& putSlot);
 		virtual int onStoredJob(int port, CJobDataB* pJobDataB);
 		virtual int onProcessData(CProcessData* pProcessData);
-		virtual int onSendAble();
-		virtual int onRecieveAble();
-		virtual int onProcessStateChanged(PROCESS_STATE state);
+		virtual int onSendAble(int port);
+		virtual int onReceiveAble(int port);
+		virtual int onProcessStateChanged(int nSlotNo, PROCESS_STATE state);
 		virtual int getIndexerOperationModeBaseValue();
+		virtual bool isSlotProcessed(int slot) { return true; };
 		bool isAlarmStep(SERVO::CStep* pStep);
 		bool isVcrEventStep(SERVO::CStep* pStep);
 		bool isCassetteTransferStateStep(SERVO::CStep* pStep);
@@ -147,7 +161,7 @@
 		int setDispatchingMode(DISPATCHING_MODE mode, ONWRITED onWritedBlock = nullptr);
 		int indexerOperationModeChange(IDNEXER_OPERATION_MODE mode, ONWRITEDRET onWritedRetBlock);
 		void printDebugString001();
-
+		std::vector<SERVO::CSVData>& getSVDatas();
 
 		// 请求主配方列表
 		// unitNo: 0:local; Others:unit No
@@ -157,16 +171,25 @@
 		// masterRecipeId: 主配方id
 		// localRecipeId: 本地配方id
 		// unitNo: 0:local; Others:unit No
-		int recipeParameterRequest(short masterRecipeId, short localRecipeId, short unitNo);
+		int recipeParameterRequest(short masterRecipeId, short localRecipeId, short unitNo, ONSYNCINGSTATECHANGED block);
+
+		// 解析配方参数列表
+		virtual int parsingParams(const char* pszData, size_t size, std::vector<CParam>& params) { return 0;  };
+		virtual int parsingParams(const char* pszData, size_t size, std::string& strOut);
+		virtual int parsingProcessData(const char* pszData, size_t size, std::vector<CParam>& params) { return 0; };
+		virtual int parsingSVData(const char* pszData, size_t size, std::vector<CParam>& params) { return 0; };
 
 		// 获取指定的Slot
 		CSlot* getSlot(int index);
+		CSlot* getSlotWithNo(int slotNo);
 
 		// 获取一个可用的槽位
 		CSlot* getAvailableSlot();
 
 		// 获取一个指定物料类型(G1,G2,G1&G2)的空槽位
 		CSlot* getAvailableSlotForGlass(MaterialsType type);
+		CSlot* getAvailableSlotForGlassExcludeSignal(MaterialsType type);
+		CSlot* isSlotAvailable(unsigned int slot);
 
 		// 在指定的槽列表中,获取一个指定物料类型(G1,G2,G1&G2)的空槽位
 		CSlot* getAvailableSlotForGlass2(MaterialsType type, const std::vector<int>& candidates);
@@ -175,14 +198,17 @@
 		CSlot* getNonEmptySlot(MaterialsType type);
 
 		// 获取一个指定物料类型(G1,G2,G1&G2)的且已经加工处理的槽位
-		CSlot* getProcessedSlot(MaterialsType putSlotType);
+		CSlot* getProcessedSlot(MaterialsType putSlotType, BOOL bJobMode = FALSE);
 		CSlot* getProcessedSlot2(MaterialsType putSlotType, const std::vector<int>& candidates);
+		CSlot* getInspFailSlot();
+		CSlot* getProcessedSlotCt(unsigned int slot);
 
 		// 获取玻璃物料
 		CGlass* getGlassFromSlot(int slotNo);
 		CGlass* getGlassWithCassette(int cassetteSequenceNo, int jobSequenceNo);
 		CGlass* getAnyGlass();
 		CGlass* getGlass(const char* pszGlassId);
+		int getAllGlass(std::vector<CGlass*>& glasses);
 		CJobDataS* getJobDataSWithCassette(int cassetteSequenceNo, int jobSequenceNo);
 
 		// 验证玻璃和槽是否匹配
@@ -190,12 +216,19 @@
 
 		// 是否有玻璃
 		BOOL hasGlass();
+		BOOL slotHasGlass(int slotIndex = 0);
 
 		// 指定槽位是否可以放置玻璃
 		BOOL canPlaceGlassInSlot(const short slotIndex);
 
 		// 手动移除物料
 		int removeGlass(int slotNo);
+
+		// 字符串检测结果转换
+		InspResult judgeStringToInspResult(std::string& strJudge);
+
+
+
 
 	// 以下为从CC-Link读取到的Bit标志位检测函数
 	public:
@@ -231,10 +264,19 @@
 		int decodePanelDataReport(CStep* pStep, const char* pszData, size_t size);
 		int decodeFacDataReport(CStep* pStep, const char* pszData, size_t size);
 		int decodeJobDataRequest(CStep* pStep, const char* pszData, size_t size);
+		int decodeJobProcessStartReport(CStep* pStep, const char* pszData, size_t size);
+		int decodeJobProcessEndReport(CStep* pStep, const char* pszData, size_t size);
 		BOOL compareJobData(CJobDataB* pJobDataB, CJobDataS* pJobDataS);
-		void setProcessState(PROCESS_STATE state);
+		void setProcessState(int nSlotNo, PROCESS_STATE state);
+		float toFloat(const char* pszAddr);
 
 	protected:
+		// 部分优化/简化代码、暂实现部分,到时平铺开
+		void addFacDataReportStep(int dataDev, int writeSignalDev, int port);
+
+
+	protected:
+		BOOL m_bEnable;
 		EquipmentListener m_listener;
 		int m_nID;
 		std::string m_strName;
@@ -265,10 +307,14 @@
 		int m_nBaseAlarmId;
 		CRecipesManager m_recipesManager;
 		CSlot m_slot[SLOT_MAX];
-		PROCESS_STATE m_processState;
+		PROCESS_STATE m_processState[SLOT_MAX] = { PROCESS_STATE::Ready };
+		std::vector<SERVO::CSVData> m_svDatas;
 
 	private:
 		CEquipment* m_pArm;
+
+	public:
+		int m_nTestFlag;
 	};
 }
 

--
Gitblit v1.9.3