Merge branch 'clh'

LAPTOP-SNT8I5JK\Boounion

2025-03-10 19261d011387ec57d646decc945aadaf8913eeab

 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();
   }
}