LAPTOP-SNT8I5JK\Boounion
2025-09-08 3f000671e15acd2de87c8588d7f09c0dc103bd7b
SourceCode/Bond/Servo/CEquipment.cpp
@@ -490,11 +490,19 @@
      // process data report
      CHECK_READ_STEP_SIGNAL(STEP_ID_PROCESS_DATA_REPORT, pszData, size);
      // FAC Data report
      CHECK_READ_STEP_SIGNAL(STEP_ID_FAC_DATA_REPORT, pszData, size);
      // 配方改变
      CHECK_READ_STEP_SIGNAL(STEP_ID_CURRENT_RECIPE_CHANGE_REPORT, pszData, size);
      
      // 主配方上报
      CHECK_READ_STEP_SIGNAL(STEP_ID_MASTER_RECIPE_LIST_REPORT, pszData, size);
      // 配方参数
      CHECK_WRITE_STEP_SIGNAL(STEP_ID_RECIPE_PARAMETER_CMD_REPLY, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_RECIPE_PARAMETER_REPORT, pszData, size);
      // CIM Mode
      CHECK_WRITE_STEP_SIGNAL(STEP_ID_CIMMODE_CHANGED_CMD_REPLY, pszData, size);
@@ -811,6 +819,16 @@
   CRecipeList* CEquipment::getRecipeList(int unitNo)
   {
      return m_recipesManager.getRecipeList(unitNo);
   }
   bool CEquipment::saveRecipeList(int unitNo, std::string& strFilepath)
   {
      return m_recipesManager.saveRecipeList(unitNo, strFilepath);
   }
   bool CEquipment::readRecipeList(int unitNo, std::string& strFilepath)
   {
      return m_recipesManager.readRecipeList(unitNo, strFilepath);
   }
   int CEquipment::recvIntent(CPin* pPin, CIntent* pIntent)
@@ -1513,6 +1531,24 @@
      processData.getAttributeVector(attrubutes, weight);
      onProcessData(&processData);
      // 找到玻璃,关联数据
      CGlass* pGlass = this->getGlassWithCassette(processData.getCassetteSequenceNo(),
         processData.getJobSequenceNo());
      if (pGlass == nullptr) {
         LOGE("<CEquipment-%s>找不到对应Glass, 关联工艺参数失败。", this->getName().c_str(),
            processData.getCassetteSequenceNo(),
            processData.getJobSequenceNo());
         return -1;
      }
      auto rawData = processData.getParamsRawData();
      std::vector<CParam> params;
      this->parsingParams((const char*)rawData.data(), rawData.size(), params);
      pGlass->addParams(params);
      return nRet;
   }
@@ -1740,21 +1776,14 @@
   int CEquipment::decodeFacDataReport(CStep* pStep, const char* pszData, size_t size)
   {
      int index = 0;
      std::string strSvTimeRecord, strSvData;
      CToolUnits::convertString(&pszData[index], 8 * 2, strSvTimeRecord);
      index += 128 * 2;
      CToolUnits::convertString(&pszData[index], 100 * 2, strSvData);
      index += 256 * 2;
      CSVData svData;
      int nRet = svData.unserialize(&pszData[0], (int)size);
      if (nRet < 0) return nRet;
      m_svDatas.push_back(svData);
      // 缓存Attribute,用于调试时显示信息
      unsigned int weight = 201;
      pStep->addAttribute(new CAttribute("SV Time Record",
         strSvTimeRecord.c_str(), "", weight++));
      pStep->addAttribute(new CAttribute("SV Data",
         strSvData.c_str(), "", weight++));
      if (m_listener.onSVDataReport != nullptr) {
         m_listener.onSVDataReport(this, &svData);
      }
      return 0;
   }
@@ -1828,6 +1857,9 @@
      if (m_processState != PROCESS_STATE::Processing) {
         Lock();
         m_svDatas.clear();
         Unlock();
         setProcessState(PROCESS_STATE::Processing);
      }
@@ -2099,4 +2131,47 @@
      return f;
   }
   int CEquipment::parsingParams(const char* pszData, size_t size, std::string& strOut)
   {
      std::vector<CParam> params;
      int nRet = parsingParams(pszData, size, params);
      if (nRet <= 0) return nRet;
      char szBuffer[256];
      for (auto p : params) {
         if(!strOut.empty()) strOut.append(",");
         if (p.getValueType() == PVT_INT) {
            sprintf_s(szBuffer, 256, "%s:%d", p.getName().c_str(), p.getIntValue());
         }
         else if (p.getValueType() == PVT_DOUBLE) {
            sprintf_s(szBuffer, 256, "%s:%f", p.getName().c_str(), p.getDoubleValue());
         }
         strOut.append(szBuffer);
      }
      return 0;
   };
   void CEquipment::addFacDataReportStep(int dataDev, int writeSignalDev, int port)
   {
      CEqReadStep* pStep = new CEqReadStep(dataDev, 133 * 2,
         [&](void* pFrom, int code, const char* pszData, size_t size) -> int {
            if (code == ROK && pszData != nullptr && size > 0) {
               decodeFacDataReport((CStep*)pFrom, pszData, size);
            }
            return -1;
         });
      pStep->setName(STEP_EQ_FAC_DATA_REPORT);
      pStep->setProp("Port", (void*)port);
      pStep->setWriteSignalDev(writeSignalDev);
      if (addStep(STEP_ID_FAC_DATA_REPORT, pStep) != 0) {
         delete pStep;
      }
   }
   std::vector<SERVO::CSVData>& CEquipment::getSVDatas()
   {
      return m_svDatas;
   }
}