From 19261d011387ec57d646decc945aadaf8913eeab Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期一, 10 三月 2025 09:05:54 +0800
Subject: [PATCH] Merge branch 'clh'
---
SourceCode/Bond/Servo/CEqProcessStep.cpp | 160 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 160 insertions(+), 0 deletions(-)
diff --git a/SourceCode/Bond/Servo/CEqProcessStep.cpp b/SourceCode/Bond/Servo/CEqProcessStep.cpp
new file mode 100644
index 0000000..f566e43
--- /dev/null
+++ b/SourceCode/Bond/Servo/CEqProcessStep.cpp
@@ -0,0 +1,160 @@
+#include "stdafx.h"
+#include "Common.h"
+#include "CEqProcessStep.h"
+#include "Log.h"
+#include "ToolUnits.h"
+
+
+namespace SERVO {
+ CEqProcessStep::CEqProcessStep() : CReadStep()
+ {
+ m_nProcessDev = 0;
+ m_nTotalParameter = 0;
+ }
+
+ CEqProcessStep::~CEqProcessStep()
+ {
+
+ }
+
+ void CEqProcessStep::getAttributeVector(CAttributeVector& attrubutes)
+ {
+ CReadStep::getAttributeVector(attrubutes);
+
+ attrubutes.addAttribute(new CAttribute("Glass ID",
+ m_strGlassId.c_str(), ""));
+ attrubutes.addAttribute(new CAttribute("Start Time",
+ m_strStartTime.c_str(), ""));
+ attrubutes.addAttribute(new CAttribute("End Time",
+ m_strEndTime.c_str(), ""));
+ attrubutes.addAttribute(new CAttribute("Total Parameter",
+ std::to_string(m_nTotalParameter).c_str(), ""));
+ attrubutes.addAttribute(new CAttribute("Total Group",
+ std::to_string(m_nTotalGroup).c_str(), ""));
+ attrubutes.addAttribute(new CAttribute("Current Group",
+ std::to_string(m_nCurrentGroup).c_str(), ""));
+
+ char szName[256];
+ int index = 0;
+ for (auto item : m_params) {
+ sprintf_s(szName, 256, "Parameter %d", ++index);
+ attrubutes.addAttribute(new CAttribute(szName,
+ item.c_str(), ""));
+ }
+ }
+
+#define PROGRESS_BUF_SIZE (1024 + 64)
+ int CEqProcessStep::onReadData()
+ {
+ CReadStep::onReadData();
+
+ // W1864 ~ W1A74, 529个word, 1058 bytes
+ char szBuffer[PROGRESS_BUF_SIZE];
+ int nRet = m_pCclink->ReadData2(m_station, DeviceType::W,
+ m_nProcessDev, PROGRESS_BUF_SIZE, szBuffer);
+ if (0 != nRet) {
+ return -1;
+ }
+
+ // 解释数据
+ // Glass ID(1864~186D)
+ int index = 0;
+ convertString(&szBuffer[index], (0x186d - 0x1864 + 1) * 2, m_strStartTime);
+ index += (0x186d - 0x1864 + 1) * 2;
+
+ // Process Start Time(186e~1875)
+ convertString(&szBuffer[index], (0x1875 - 0x186e + 1) * 2, m_strStartTime);
+ index += (0x1875 - 0x186e + 1) * 2;
+
+ // Process End Time(1876~187d)
+ convertString(&szBuffer[index], (0x187d - 0x1876 + 1) * 2, m_strEndTime);
+ index += (0x187d - 0x1876 + 1) * 2;
+
+ // parameter count
+ m_nTotalParameter = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
+ index += 2;
+
+ // total group
+ m_nTotalGroup = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
+ index += 2;
+
+ // current group
+ m_nCurrentGroup = (unsigned int)CToolUnits::toInt16(&szBuffer[index]);
+ index += 2;
+
+ // param list(0x1881~0x1a74), 共1000 bytes, 20个字符为一个参数, 50组
+ // 最后一group可能不满足50, 以m_nTotalParameter为依据
+ int size = (m_nCurrentGroup == m_nTotalGroup) ? m_nTotalParameter % 50 : 50;
+ for (int i = 0; i < size; i++) {
+ std::string strParam;
+ convertString(&szBuffer[index], 20, strParam);
+ if (!strParam.empty()) {
+ m_params.push_back(strParam);
+ }
+ index += 20;
+ }
+
+ if (m_nCurrentGroup == m_nTotalGroup && m_listener.onEvent != nullptr) {
+ m_listener.onEvent(this, STEP_EVENT_PROCESS_DATA, nullptr);
+ }
+
+
+ LOGI("<CEqProcessStep> Process Data<GlassId:%s>\n",
+ m_strGlassId.c_str());
+
+ return 0;
+ }
+
+ int CEqProcessStep::onComplete()
+ {
+ CReadStep::onComplete();
+ LOGI("<CEqProcessStep> onComplete.");
+
+ return 0;
+ }
+
+ int CEqProcessStep::onTimeout()
+ {
+ CReadStep::onTimeout();
+ LOGI("<CEqProcessStep> onTimeout.");
+
+ return 0;
+ }
+
+ void CEqProcessStep::setProcessDev(int nDev)
+ {
+ m_nProcessDev = nDev;
+ }
+
+ std::string& CEqProcessStep::getGlassId()
+ {
+ return m_strGlassId;
+ }
+
+ std::string& CEqProcessStep::getStartTime()
+ {
+ return m_strStartTime;
+ }
+
+ std::string& CEqProcessStep::getEndTime()
+ {
+ return m_strEndTime;
+ }
+
+ unsigned int CEqProcessStep::getTotalParameter()
+ {
+ return m_nTotalParameter;
+ }
+
+ const std::list<std::string> CEqProcessStep::getParameters()
+ {
+ return m_params;
+ }
+
+ void CEqProcessStep::getParameters(std::list<std::string>& list)
+ {
+ Lock();
+ std::copy(m_params.begin(), m_params.end(), std::back_inserter(list));
+ Unlock();
+ }
+}
--
Gitblit v1.9.3