From 7a60f2a3404220dcbc05e2e06fd7f3a6e51d5a4a Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期四, 19 六月 2025 15:37:20 +0800
Subject: [PATCH] 1.对Panel Data Request的响应;

---
 SourceCode/Bond/Servo/CEFEM.cpp |  116 ++++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 81 insertions(+), 35 deletions(-)

diff --git a/SourceCode/Bond/Servo/CEFEM.cpp b/SourceCode/Bond/Servo/CEFEM.cpp
index 3474d3e..8b5ec2a 100644
--- a/SourceCode/Bond/Servo/CEFEM.cpp
+++ b/SourceCode/Bond/Servo/CEFEM.cpp
@@ -22,6 +22,10 @@
 		m_pPort[3] = nullptr;
 		m_pAligner = nullptr;
 		m_pFliper = nullptr;
+		m_robotData.status = ROBOT_STATUS::Setup;
+		m_robotData.position = ROBOT_POSITION::Port1;
+		m_robotData.armState[0] = FALSE;
+		m_robotData.armState[1] = FALSE;
 	}
 
 	CEFEM::~CEFEM()
@@ -362,7 +366,7 @@
 			// Eq mode
 			CEqModeStep* pStep = new CEqModeStep();
 			pStep->setName(STEP_MODE);
-			pStep->setWriteSignalDev(0x50);
+			pStep->setWriteSignalDev(0x40);
 			pStep->setModeDev(0x5d7d);
 			if (addStep(STEP_ID_EQMODE_CHANGED, pStep) != 0) {
 				delete pStep;
@@ -373,7 +377,7 @@
 			// Eq Status
 			CEqStatusStep* pStep = new CEqStatusStep();
 			pStep->setName(STEP_STATUS);
-			pStep->setWriteSignalDev(0x51);
+			pStep->setWriteSignalDev(0x41);
 			pStep->setStatusDev(0x5d59);
 			if (addStep(STEP_ID_EQSTATUS_CHANGED, pStep) != 0) {
 				delete pStep;
@@ -384,7 +388,7 @@
 			// Eq Alarm
 			static char* pszName[] = { STEP_ALARM_BLOCK1, STEP_ALARM_BLOCK2, STEP_ALARM_BLOCK3, STEP_ALARM_BLOCK4, STEP_ALARM_BLOCK5 };
 			static int dev[] = { 0x5f0e , 0x5f3b, 0x5f68, 0x5f95, 0x5fc2 };
-			static int writeSignalDev[] = { 0x52, 0x53, 0x54, 0x55, 0x56 };
+			static int writeSignalDev[] = { 0x42, 0x43, 0x44, 0x45, 0x46 };
 			static int addr[] = { STEP_ID_EQALARM1, STEP_ID_EQALARM2, STEP_ID_EQALARM3, STEP_ID_EQALARM4, STEP_ID_EQALARM5 };
 
 			for (int i = 0; i < 5; i++) {
@@ -403,7 +407,7 @@
 			// eq process
 			CEqProcessStep* pStep = new CEqProcessStep();
 			pStep->setName(STEP_PROCESS);
-			pStep->setWriteSignalDev(0x57);
+			pStep->setWriteSignalDev(0x47);
 			pStep->setProcessDev(0x6b55);
 			if (addStep(STEP_ID_PROCESS_DATA_REPORT, pStep) != 0) {
 				delete pStep;
@@ -435,7 +439,7 @@
 
 		{
 			// CIM Message Confirm
-			CEqReadIntStep* pStep = new CEqReadIntStep(__INT32, 0x5f80);
+			CEqReadIntStep* pStep = new CEqReadIntStep(__INT32, 0x5d80);
 			pStep->setName(STEP_EQ_CIM_MESSAGE_CONFIRM);
 			pStep->setWriteSignalDev(0x49);
 			if (addStep(STEP_ID_CIM_MSG_CONFIRM_REPORT, pStep) != 0) {
@@ -498,7 +502,7 @@
 			// eq mode change
 			CEqModeChangeStep* pStep = new CEqModeChangeStep();
 			pStep->setName(STEP_EQ_MODE_CHANGE);
-			pStep->setWriteSignalDev(0x65);
+			pStep->setWriteSignalDev(0x40);
 			pStep->setEqModeDev(0x1E);
 			if (addStep(STEP_ID_EQMODE_CHANGE_CMD_REPLY, pStep) != 0) {
 				delete pStep;
@@ -527,25 +531,49 @@
 			}
 		}
 
+		// 使用CEqReadStep替换CEqJobEventStep
 		{
-			// Received Job Report Upstream#1~9
+			// Received Job Report Upstream #1~9
 			char szBuffer[256];
-			for (int i = 0; i < 9; i++) {
+			for (int i = 0; i < 8; i++) {
 				CEqReadStep* pStep = new CEqReadStep(0x4c90 + 320 * i, 320 * 2,
 					[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
 						if (code == ROK && pszData != nullptr && size > 0) {
 							int port = (int)(__int64)((CEqReadStep*)pFrom)->getProp("Port");
 							if (port > 0) {
-								decodeFetchedOutJobReport((CStep*)pFrom, port, pszData, size);
+								decodeReceivedJobReport((CStep*)pFrom, port, pszData, size);
 							}
 						}
 						return -1;
 					});
-				sprintf_s(szBuffer, "%s%d", STEP_EQ_RECEIVED_JOBn, i + 1);
+				sprintf_s(szBuffer, "%s%d", STEP_EQ_RECEIVED_JOB_UPSn, i + 1);
 				pStep->setName(szBuffer);
-				pStep->setProp("Upstream", (void*)(__int64)(i + 1));
+				pStep->setProp("Port", (void*)(__int64)(i + 1));
 				pStep->setWriteSignalDev(0x0 + i);
-				if (addStep(STEP_ID_FETCHED_OUT_JOB_REPORT1 + i, pStep) != 0) {
+				if (addStep(STEP_ID_RECIVE_JOB_UPS1 + i, pStep) != 0) {
+					delete pStep;
+				}
+			}
+		}
+		{
+			// Sent Out Job Report Downstream #1~9
+			char szBuffer[256];
+			for (int i = 0; i < 8; i++) {
+				CEqReadStep* pStep = new CEqReadStep(0x4000 + 320 * i, 320 * 2,
+					[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
+						if (code == ROK && pszData != nullptr && size > 0) {
+							int port = (int)(__int64)((CEqReadStep*)pFrom)->getProp("Port");
+							if (port > 0) {
+								decodeSentOutJobReport((CStep*)pFrom, port, pszData, size);
+							}
+						}
+						return -1;
+					});
+				sprintf_s(szBuffer, "%s%d", STEP_EQ_SENT_OUT_JOB_DOWNSn, i + 1);
+				pStep->setName(szBuffer);
+				pStep->setProp("Port", (void*)(__int64)(i + 1));
+				pStep->setWriteSignalDev(0x00a + i);
+				if (addStep(STEP_ID_SENT_OUT_JOB_DOWNS1 + i, pStep) != 0) {
 					delete pStep;
 				}
 			}
@@ -554,7 +582,7 @@
 		{
 			// Fetched Out Job Report #1~15
 			char szBuffer[256];
-			for (int i = 0; i < 15; i++) {
+			for (int i = 0; i < 8; i++) {
 				CEqReadStep* pStep = new CEqReadStep(0x5c31 + 18 * i, 18 * 2,
 					[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
 						if (code == ROK && pszData != nullptr && size > 0) {
@@ -565,7 +593,7 @@
 						}
 						return -1;
 					});
-				sprintf_s(szBuffer, "%s%d", STEP_EQ_FETCHED_OUT_JOBn, i+1);
+				sprintf_s(szBuffer, "%s%d", STEP_EQ_FETCHED_OUT_JOBn, i + 1);
 				pStep->setName(szBuffer);
 				pStep->setProp("Port", (void*)(__int64)(i + 1));
 				pStep->setWriteSignalDev(0x023 + i);
@@ -576,9 +604,9 @@
 		}
 
 		{
-			// Store Job Report #1~15
+			// Stored Job Report #1~15
 			char szBuffer[256];
-			for (int i = 0; i < 15; i++) {
+			for (int i = 0; i < 8; i++) {
 				CEqReadStep* pStep = new CEqReadStep(0x5b23 + 18 * i, 18 * 2,
 					[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
 						if (code == ROK && pszData != nullptr && size > 0) {
@@ -599,6 +627,7 @@
 			}
 		}
 
+
 		{
 			// Dispatching Mode Change Command
 			CEqWriteStep* pStep = new CEqWriteStep();
@@ -615,7 +644,7 @@
 			CEqWriteStep* pStep = new CEqWriteStep();
 			pStep->setName(STEP_EFEM_ROBOT_CMD);
 			pStep->setWriteSignalDev(0x14D);
-			pStep->setDataDev(0x90a);
+			pStep->setDataDev(0x5c7);
 			if (addStep(STEP_ID_ROBOT_CMD_REPLY, pStep) != 0) {
 				delete pStep;
 			}
@@ -624,9 +653,10 @@
 		{
 			// Indexer Operation Mode Change
 			CEqWriteStep* pStep = new CEqWriteStep();
-			pStep->setName(STEP_EFEM_IN_OP_MODE_CHANGE);
+			pStep->setName(STEP_EQ_IN_OP_MODE_CHANGE);
 			pStep->setWriteSignalDev(0x070);
 			pStep->setDataDev(0x023);
+			pStep->setRetDataDev(0x600e, 2);
 			if (addStep(STEP_ID_IN_OP_CMD_REPLY, pStep) != 0) {
 				delete pStep;
 			}
@@ -654,7 +684,7 @@
 			CEqReadStep* pStep = new CEqReadStep(0x6301, 108 * 2,
 				[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
 					if (code == ROK && pszData != nullptr && size > 0) {
-						decodePanelDataReport((CStep*)pFrom, pszData, size);
+						decodePanelDataRequest((CStep*)pFrom, pszData, size);
 					}
 					return -1;
 				});
@@ -662,6 +692,24 @@
 			pStep->setProp("Port", (void*)1);
 			pStep->setWriteSignalDev(0x04d);
 			if (addStep(STEP_ID_FAC_DATA_REPORT, pStep) != 0) {
+				delete pStep;
+			}
+		}
+
+		{
+			// Panel Data Request
+			CEqReadStep* pStep = new CEqReadStep(0x617d, 2 * 2,
+				[&](void* pFrom, int code, const char* pszData, size_t size) -> int {
+					if (code == ROK && pszData != nullptr && size > 0) {
+						decodePanelDataRequest((CStep*)pFrom, pszData, size);
+					}
+					return -1;
+				});
+			pStep->setName(STEP_EFEM_PANEL_DATA_REQUEST);
+			pStep->setProp("Port", (void*)1);
+			pStep->setWriteSignalDev(0x15d);
+			pStep->setReturnDev(0x73a);
+			if (addStep(STEP_ID_PANEL_DATA_REQUEST, pStep) != 0) {
 				delete pStep;
 			}
 		}
@@ -738,28 +786,26 @@
 
 	int CEFEM::onReceivedJob(int port, CJobDataS* pJobDataS)
 	{
-		m_pPort[0]->onReceivedJob(port, pJobDataS);
-		m_pPort[1]->onReceivedJob(port, pJobDataS);
-		m_pPort[2]->onReceivedJob(port, pJobDataS);
-		m_pPort[3]->onReceivedJob(port, pJobDataS);
-		m_pArmTray[0]->onReceivedJob(port, pJobDataS);
-		m_pArmTray[1]->onReceivedJob(port, pJobDataS);
-		m_pAligner->onReceivedJob(port, pJobDataS);
-		m_pFliper->onReceivedJob(port, pJobDataS);
+		// 转发到子单元设备
+		CEquipment* pEqs[] = { m_pPort[0], m_pPort[1], m_pPort[2], m_pPort[3], m_pArmTray[0], m_pArmTray[1],
+			m_pAligner, m_pFliper };
+		if (1 <= port && port <= 8) {
+			pEqs[port - 1]->onReceivedJob(port, pJobDataS);
+		}
+
 
 		return 0;
 	}
 
 	int CEFEM::onSentOutJob(int port, CJobDataS* pJobDataS)
 	{
-		m_pPort[0]->onSentOutJob(port, pJobDataS);
-		m_pPort[1]->onSentOutJob(port, pJobDataS);
-		m_pPort[2]->onSentOutJob(port, pJobDataS);
-		m_pPort[3]->onSentOutJob(port, pJobDataS);
-		m_pArmTray[0]->onSentOutJob(port, pJobDataS);
-		m_pArmTray[1]->onSentOutJob(port, pJobDataS);
-		m_pAligner->onSentOutJob(port, pJobDataS);
-		m_pFliper->onSentOutJob(port, pJobDataS);
+		// 转发到子单元设备
+		CEquipment* pEqs[] = { m_pPort[0], m_pPort[1], m_pPort[2], m_pPort[3], m_pArmTray[0], m_pArmTray[1],
+			m_pAligner, m_pFliper };
+		if (1 <= port && port <= 8) {
+			pEqs[port - 1]->onSentOutJob(port, pJobDataS);
+		}
+
 
 		return 0;
 	}

--
Gitblit v1.9.3