From 847a34f02bfe00475735fb5bfbefea2db28c8ad6 Mon Sep 17 00:00:00 2001
From: chenluhua1980 <Chenluhua@qq.com>
Date: 星期六, 24 一月 2026 17:15:48 +0800
Subject: [PATCH] 1.修复前烘-b, 后烘-b没有进入b分支导致数据没有推送到显示端的问题;

---
 SourceCode/Bond/Servo/CMaster.cpp |   43 +++++++++++++++++++++++++++++++++++--------
 1 files changed, 35 insertions(+), 8 deletions(-)

diff --git a/SourceCode/Bond/Servo/CMaster.cpp b/SourceCode/Bond/Servo/CMaster.cpp
index bf1ff4b..f51c969 100644
--- a/SourceCode/Bond/Servo/CMaster.cpp
+++ b/SourceCode/Bond/Servo/CMaster.cpp
@@ -119,6 +119,14 @@
 			m_hEventDispatchThreadExit[1] = nullptr;
 		}
 
+		// 閲婃斁浜哄伐鎼嚭缂撳啿鍖洪噷鐨勭幓鐠�
+		for (auto* pGlass : m_bufGlass) {
+			if (pGlass != nullptr) {
+				pGlass->release();
+			}
+		}
+		m_bufGlass.clear();
+
 		DeleteCriticalSection(&m_criticalSection);
 	}
 
@@ -1785,18 +1793,23 @@
 					int paramIndex = mapping.first;
 					int channel = mapping.second;
 
-					if (paramIndex < params.size() && channel - 1 < vacuumbakeTypes.size()) {
+					if (paramIndex < params.size()) {
 						auto& param = params.at(paramIndex);
 						double value = param.getDoubleValue();
-						const std::string& dataType = vacuumbakeTypes[channel - 1];
 						const std::string& paramName = param.getName();
 						const char slotTag = !paramName.empty() ? paramName[0] : '\0';
+						const int typeIndex = (slotTag == 'B') ? (channel - 8) : (channel - 1);
+						if (typeIndex < 0 || typeIndex >= (int)vacuumbakeTypes.size()) {
+							continue;
+						}
+						const int pushChannel = typeIndex + 1;
+						const std::string& dataType = vacuumbakeTypes[typeIndex];
 
 						if (m_pCollector != nullptr) {
 							if (slotTag == 'A')
-								m_pCollector->buffersPush(SlotToMid(eqid, 1), channel, ts, value);
+								m_pCollector->buffersPush(SlotToMid(eqid, 1), pushChannel, ts, value);
 							else if (slotTag == 'B')
-								m_pCollector->buffersPush(SlotToMid(eqid, 2), channel, ts, value);
+								m_pCollector->buffersPush(SlotToMid(eqid, 2), pushChannel, ts, value);
 						}
 
 						// 鏍规嵁鑵斾綋鍓嶇紑鍐欏叆瀵瑰簲 Slot 鐨勭幓鐠�
@@ -1830,20 +1843,25 @@
 					int paramIndex = mapping.first;
 					int channel = mapping.second;
 
-					if (paramIndex < params.size() && channel - 1 < coolingTypes.size()) {
+					if (paramIndex < params.size()) {
 						auto& param = params.at(paramIndex);
 						double value = param.getDoubleValue();
-						const std::string& dataType = coolingTypes[channel - 1];
 						const std::string& paramName = param.getName();
 						const char slotTag = !paramName.empty() ? paramName[0] : '\0';
 						const bool paramIsBake = paramName.find("鐑樼儰") != std::string::npos;
 						const bool paramIsCooling = paramName.find("鍐峰嵈") != std::string::npos;
+						const int typeIndex = (slotTag == 'B') ? (channel - 7) : (channel - 1);
+						if (typeIndex < 0 || typeIndex >= (int)coolingTypes.size()) {
+							continue;
+						}
+						const int pushChannel = typeIndex + 1;
+						const std::string& dataType = coolingTypes[typeIndex];
 
 						if (m_pCollector != nullptr && paramIsBake) {
 							if (slotTag == 'A')
-								m_pCollector->buffersPush(SlotToMid(eqid, 1), channel, ts, value);
+								m_pCollector->buffersPush(SlotToMid(eqid, 1), pushChannel, ts, value);
 							else if (slotTag == 'B')
-								m_pCollector->buffersPush(SlotToMid(eqid, 3), channel, ts, value);
+								m_pCollector->buffersPush(SlotToMid(eqid, 3), pushChannel, ts, value);
 						}
 
 						if (!dataType.empty()) {
@@ -3551,6 +3569,15 @@
 		if (pSlot == nullptr) return false;
 
 		CGlass* pGlass = (CGlass*)pSlot->getContext();
+		if (pGlass == nullptr) return false;
+
+		// Buffer 涓婇檺涓� 1锛氭柊鎼嚭鏃朵涪寮冩棫鐨�
+		if (!m_bufGlass.empty()) {
+			for (auto* oldGlass : m_bufGlass) {
+				if (oldGlass != nullptr) oldGlass->release();
+			}
+			m_bufGlass.clear();
+		}
 		m_bufGlass.push_back(pGlass);
 		pGlass->addRef();
 		pSlot->setContext(nullptr);

--
Gitblit v1.9.3