From 1d723c3fe9787ae6f079f3e94cd9a53f20cac985 Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期二, 18 三月 2025 17:55:07 +0800
Subject: [PATCH] 1.开始编写流程控件模块,添加LoadPort, 烘烤等其它机器。 2.实现pin接口,准备加入到各个机器中;

---
 SourceCode/Bond/Servo/CEquipment.cpp |   60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 59 insertions(+), 1 deletions(-)

diff --git a/SourceCode/Bond/Servo/CEquipment.cpp b/SourceCode/Bond/Servo/CEquipment.cpp
index afd0c0e..deaee05 100644
--- a/SourceCode/Bond/Servo/CEquipment.cpp
+++ b/SourceCode/Bond/Servo/CEquipment.cpp
@@ -72,6 +72,17 @@
 		return iter->second;
 	}
 
+	CStep* CEquipment::getStepWithName(const char* pszName)
+	{
+		for (auto item : m_mapStep) {
+			if (item.second->getName().compare(pszName) == 0) {
+				return item.second;
+			}
+		}
+
+		return nullptr;
+	}
+
 	int CEquipment::addStep(unsigned int addr, CStep* pStep)
 	{
 		auto iter = m_mapStep.find(addr);
@@ -84,6 +95,7 @@
 
 	void CEquipment::init()
 	{
+		initPins();
 		for (auto item : m_mapStep) {
 			item.second->init();
 		}
@@ -135,6 +147,39 @@
 	const StationIdentifier& CEquipment::getStation()
 	{
 		return m_station;
+	}
+
+	void CEquipment::getAttributeVector(CAttributeVector& attrubutes)
+	{
+		attrubutes.clear();
+		attrubutes.addAttribute(new CAttribute("Network",
+			std::to_string(m_station.nNetNo).c_str(), ""));
+		attrubutes.addAttribute(new CAttribute("Station",
+			std::to_string(m_station.nStNo).c_str(), ""));
+		attrubutes.addAttribute(new CAttribute("ID",
+			std::to_string(m_nID).c_str(), ""));
+		attrubutes.addAttribute(new CAttribute("Name",
+			m_strName.c_str(), ""));
+		attrubutes.addAttribute(new CAttribute("Description",
+			m_strDescription.c_str(), ""));
+		attrubutes.addAttribute(new CAttribute("Alive",
+			this->isAlive() ? _T("TRUE") : _T("FALSE"), ""));
+		attrubutes.addAttribute(new CAttribute("CIM State",
+			m_bCimState ? _T("ON") : _T("OFF"), ""));
+		attrubutes.addAttribute(new CAttribute("Upstream",
+			m_bUpstreamInline ? _T("Inline") : _T("Offline"), ""));
+		attrubutes.addAttribute(new CAttribute("Downstream",
+			m_bDownstreamInline ? _T("Inline") : _T("Offline"), ""));
+		attrubutes.addAttribute(new CAttribute("Local Alarm",
+			m_bLocalAlarm ? _T("TRUE") : _T("FALSE"), ""));
+		attrubutes.addAttribute(new CAttribute("Auto Recipe Change",
+			m_bAutoRecipeChange ? _T("TRUE") : _T("FALSE"), ""));
+		char szTemp[256];
+		for (int i = 0; i < VCR_MAX; i++) {
+			sprintf_s(szTemp, 256, "VCR-%d", i + 1);
+			attrubutes.addAttribute(new CAttribute(szTemp,
+				m_bVCREnable[i] ? _T("Enable") : _T("Disable"), ""));
+		}
 	}
 
 	void CEquipment::setReadBitBlock(unsigned int start, unsigned int end)
@@ -267,8 +312,15 @@
 			bFlag = isBitOn(pszData, size, index);
 			pStep = getStep(index);
 			if (pStep != nullptr) {
-				pStep->onSignal(bFlag);
+				((CReadStep*)pStep)->onReadSignal(bFlag);
 			}
+		}
+
+		index = 0x350;
+		bFlag = isBitOn(pszData, size, index);
+		pStep = getStep(index);
+		if (pStep != nullptr) {
+			((CWriteStep*)pStep)->onRecvSignal(bFlag);
 		}
 	}
 
@@ -321,4 +373,10 @@
 		if (index >= VCR_MAX) return FALSE;
 		return m_bVCREnable[index];
 	}
+
+	int CEquipment::recvSample(CPin* pPin, CSample* pSample)
+	{
+		LOGI("<CEquipment>recvSample, pin:%s", pPin->getName().c_str());
+		return 0;
+	}
 }

--
Gitblit v1.9.3