From d68541dce155a682f65b7c3fbfbfbeef17ea5b8f Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期一, 12 五月 2025 12:00:41 +0800
Subject: [PATCH] 1.StoredJob, Fetched out Job实现; 2.CStep增加定制的Attribute, 以便通过的Step不使用getAttributeVector也能添加不一样的Attribute;

---
 SourceCode/Bond/Servo/CReadStep.cpp |   41 ++++++++++++++++++++++++++++++++++++-----
 1 files changed, 36 insertions(+), 5 deletions(-)

diff --git a/SourceCode/Bond/Servo/CReadStep.cpp b/SourceCode/Bond/Servo/CReadStep.cpp
index 7e05c00..d3c7747 100644
--- a/SourceCode/Bond/Servo/CReadStep.cpp
+++ b/SourceCode/Bond/Servo/CReadStep.cpp
@@ -22,6 +22,9 @@
 		m_hReadSignalOff = ::CreateEvent(NULL, TRUE, FALSE, NULL);
 		m_nSignalType = 0;
 		m_nCurStep = 0;
+		m_szReturnBuf[1024] = {0};
+		m_nReturnDataSize = 0;
+		m_nReturnDevNo = 0;
 	}
 
 	CReadStep::~CReadStep()
@@ -38,6 +41,11 @@
 	void CReadStep::setWriteSignalDev(int dev)
 	{
 		m_nWriteSignalDev = dev;
+	}
+	
+	void CReadStep::setReturnDev(int dev)
+	{
+		m_nReturnDevNo = dev;
 	}
 
 	void CReadStep::onReadSignal(int nSignalType)
@@ -88,16 +96,27 @@
 					m_pEquipment->onStepEvent(this, STEP_EVENT_READDATA);
 				}
 
+				// 0426新增
+				// 1.1,写return code or data
+				if (m_nReturnDataSize > 0) {
+					int nWriteRet = m_pCclink->WriteData(m_station, (short)DeviceType::W,
+						m_nReturnDevNo, m_nReturnDataSize, (short*)m_szReturnBuf);
+					if (0 != nWriteRet) {
+						onTimeout();
+						goto RESET;
+					}
+				}
+
 				// 2.给对方写ON
 				nextStep();
-				m_pCclink->SetBitDevice(m_station, DeviceType::B, m_nWriteSignalDev);
+				m_pCclink->SetBitDeviceEx(m_station, (long)DeviceType::B, m_nWriteSignalDev);
 
 
 				// 3.等待对方OFF
 				nextStep();
 				int nStep3Ret = ::WaitForSingleObject(m_hReadSignalOff, TIMEOUT * 1000);
 				if (nStep3Ret == WAIT_TIMEOUT) {
-					m_pCclink->ResetBitDevice(m_station, DeviceType::B, m_nWriteSignalDev);
+					m_pCclink->ResetBitDeviceEx(m_station, (long)DeviceType::B, m_nWriteSignalDev);
 					onTimeout();
 					goto RESET;
 				}
@@ -106,7 +125,7 @@
 
 				// 4.给对方写OFF
 				nextStep();
-				m_pCclink->ResetBitDevice(m_station, DeviceType::B, m_nWriteSignalDev);
+				m_pCclink->ResetBitDeviceEx(m_station, (long)DeviceType::B, m_nWriteSignalDev);
 
 
 				// 6.完成
@@ -115,6 +134,9 @@
 					ASSERT(m_pEquipment);
 					m_pEquipment->onStepEvent(this, STEP_EVENT_COMPLETE);
 				}
+
+				// 回复数据清空
+				m_nReturnDataSize = 0;
 			}
 		}
 
@@ -132,10 +154,11 @@
 		CStep::getAttributeVector(attrubutes);
 		std::string strTemp;
 
+		unsigned int weight = 21;
 		attrubutes.addAttribute(new CAttribute("Current Step",
-			std::to_string(m_nCurStep).c_str(), ""));
+			std::to_string(m_nCurStep).c_str(), "", weight++));
 		attrubutes.addAttribute(new CAttribute("Signal Dev",
-			("W" + CToolUnits::toHexString(m_nWriteSignalDev, strTemp)).c_str(), ""));
+			("W" + CToolUnits::toHexString(m_nWriteSignalDev, strTemp)).c_str(), "", weight++));
 	}
 
 	void CReadStep::init()
@@ -187,4 +210,12 @@
 	{
 		return 0;
 	}
+
+	int CReadStep::setReturnCode(short code)
+	{
+		memcpy(m_szReturnBuf, &code, sizeof(short));
+		m_nReturnDataSize = sizeof(short);
+
+		return 0;
+	}
 }

--
Gitblit v1.9.3