From 7ddca21fdb798123239eab9daa390e2702afdff7 Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期五, 10 十月 2025 18:02:19 +0800
Subject: [PATCH] 1.ProcessStart和ProcessEnd加调上层时加上SlotNo, 状态也关联到SlotNo, 因为多腔可能 并行工作。 2.加入曲线采集服务端到项目中。

---
 SourceCode/Bond/Servo/CEquipment.cpp |   39 ++++++++++++++++++++++-----------------
 1 files changed, 22 insertions(+), 17 deletions(-)

diff --git a/SourceCode/Bond/Servo/CEquipment.cpp b/SourceCode/Bond/Servo/CEquipment.cpp
index d725241..f9d930a 100644
--- a/SourceCode/Bond/Servo/CEquipment.cpp
+++ b/SourceCode/Bond/Servo/CEquipment.cpp
@@ -26,7 +26,6 @@
 		m_pCclink = nullptr;
 		m_nBaseAlarmId = 0;
 		m_pArm = nullptr;
-		m_processState = PROCESS_STATE::Ready;
 		m_blockReadBit = { 0 };
 		m_nTestFlag = 0;
 		InitializeCriticalSection(&m_criticalSection);
@@ -144,13 +143,15 @@
 		return 0;
 	}
 
-	void CEquipment::setProcessState(PROCESS_STATE state)
+	void CEquipment::setProcessState(int nSlotNo, PROCESS_STATE state)
 	{
-		m_processState = state;
-		onProcessStateChanged(m_processState);
+		if (nSlotNo <= 0 || nSlotNo > 8) return;
+
+		m_processState[nSlotNo - 1] = state;
+		onProcessStateChanged(nSlotNo, m_processState[nSlotNo - 1]);
 
 		if (m_listener.onProcessStateChanged != nullptr) {
-			m_listener.onProcessStateChanged(this, m_processState);
+			m_listener.onProcessStateChanged(this, nSlotNo, m_processState[nSlotNo - 1]);
 		}
 	}
 
@@ -909,8 +910,8 @@
 		Unlock();
 
 
-		if (m_processState != PROCESS_STATE::Ready) {
-			setProcessState(PROCESS_STATE::Ready);
+		if (m_processState[port] != PROCESS_STATE::Ready) {
+			setProcessState(port, PROCESS_STATE::Ready);
 		}
 
 		if (m_listener.onDataChanged != nullptr) {
@@ -941,9 +942,11 @@
 		pGlass->release();				// tempFetchOut需要调用一次release
 		Unlock();
 
+		/*
 		if (m_processState != PROCESS_STATE::Processing) {
 			setProcessState(PROCESS_STATE::Processing);
 		}
+		*/
 
 		if (m_listener.onDataChanged != nullptr) {
 			m_listener.onDataChanged(this, EDCC_STORED_JOB);
@@ -1929,12 +1932,17 @@
 			year, month, day, hour, minute, second
 			);
 
+		CGlass* pGlass = getGlassFromSlot(slotNo);
+		if (pGlass == nullptr) {
+			LOGE("<CEquipment-%s>decodeJobProcessStartReport, 找不到对应glass", getName().c_str());
+		}
+		if (slotNo <= 0 || slotNo > 8) return -1;
 
-		if (m_processState != PROCESS_STATE::Processing) {
+		if (m_processState[slotNo -1] != PROCESS_STATE::Processing) {
 			Lock();
 			m_svDatas.clear();
 			Unlock();
-			setProcessState(PROCESS_STATE::Processing);
+			setProcessState(slotNo, PROCESS_STATE::Processing);
 		}
 
 
@@ -2002,11 +2010,11 @@
 		);
 
 
-		if (m_processState != PROCESS_STATE::Complete) {
-			setProcessState(PROCESS_STATE::Complete);
-		}
-		
 		CGlass* pGlass = getGlassFromSlot(slotNo);
+		if (m_processState[slotNo - 1] != PROCESS_STATE::Complete) {
+			setProcessState(slotNo, PROCESS_STATE::Complete);
+		}
+	
 		if (pGlass == nullptr) {
 			LOGE("<CEquipment-%s>decodeJobProcessEndReport, 找不到对应glass", getName().c_str());
 		}
@@ -2015,9 +2023,6 @@
 			if (pJs->getCassetteSequenceNo() == cassetteNo
 				&& pJs->getJobSequenceNo() == jobSequenceNo) {
 				pGlass->processEnd(m_nID, getSlotUnit(slotNo));
-				if (m_processState != PROCESS_STATE::Complete) {
-					setProcessState(PROCESS_STATE::Complete);
-				}
 			}
 			else {
 				LOGE("<CEquipment-%s>decodeJobProcessEndReport, jobSequenceNo或jobSequenceNo不匹配",
@@ -2136,7 +2141,7 @@
 		return 0;
 	}
 
-	int CEquipment::onProcessStateChanged(PROCESS_STATE state)
+	int CEquipment::onProcessStateChanged(int nSlotNo, PROCESS_STATE state)
 	{
 		return 0;
 	}

--
Gitblit v1.9.3