Merge branch 'clh' into liuyang

mrDarker

2025-05-06 cacea2da59a3acd73f3161d819a10e0060762616

 SourceCode/Bond/Servo/CEquipment.cpp

@@ -1,6 +1,7 @@
#include "stdafx.h"
#include "CEquipment.h"
#include "ToolUnits.h"
#include <regex>


#define CHECK_READ_STEP_SIGNAL(addr, data, size) {                     \
@@ -131,6 +132,7 @@
   void CEquipment::init()
   {
      initPins();
      initSteps();
      for (auto item : m_mapStep) {
         item.second->init();
      }
@@ -141,6 +143,11 @@
      for (auto item : m_mapStep) {
         item.second->term();
      }
   }

   void CEquipment::initSteps()
   {

   }

   void CEquipment::setID(int nID)
@@ -363,7 +370,7 @@
         m_bAutoRecipeChange = bFlag;
      }

      // AutoRecipeChange
      // VCR Enable
      bFlag = isBitOn(pszData, size, ++index);
      if (!equalBool(m_bVCREnable[0], bFlag)) {
         m_bVCREnable[0] = bFlag;
@@ -394,6 +401,9 @@
      // EQ mode change cmd reply
      CHECK_WRITE_STEP_SIGNAL(STEP_ID_EQMODE_CHANGE_CMD_REPLY, pszData, size);

      // EQ Master recipe request cmd reply
      CHECK_WRITE_STEP_SIGNAL(STEP_ID_MASTER_RECIPE_LIST_CMD_REPLY, pszData, size);

      // CIM Message Confirm
      CHECK_READ_STEP_SIGNAL(STEP_ID_CIM_MSG_CONFIRM_REPORT, pszData, size);

@@ -406,31 +416,6 @@
      CHECK_READ_STEP_SIGNAL(STEP_ID_SENT_OUT_JOB_DOWNS1, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_SENT_OUT_JOB_DOWNS2, pszData, size);

      // Port1 ~ Port4
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_CASSETTE_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_CASSETTE_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_CASSETTE_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_CASSETTE_TYPE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_TRANSFER_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_TRANSFER_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_TRANSFER_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_TRANSFER_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_ENABLE_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_ENABLE_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_ENABLE_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_ENABLE_MODE_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_TYPE_AUTO_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT2_TYPE_AUTO_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT3_TYPE_AUTO_CHANGE, pszData, size);
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT4_TYPE_AUTO_CHANGE, pszData, size);

      // CEqCassetteTranserStateStep
      CHECK_READ_STEP_SIGNAL(STEP_ID_PORT1_CASSETTIE_EMPTY, pszData, size);
@@ -543,6 +528,8 @@
               m_listener.onVcrEventReport(this, pVcrEventReport);
            }

            // 0426, 先固定返回1(OK)
            pEqVcrEventStep->setReturnCode(1);		
            return 1;
         }
      }
@@ -787,10 +774,46 @@
      return CToolUnits::startsWith(pStep->getName(), STEP_ALARM_START);
   }

   bool CEquipment::isPortTypeStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+Type$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isPortModeStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+Mode$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isPortCassetteTypeStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+CassetteType$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isPortTransferModeStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+TransferMode$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isPortEnableStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+Enable$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isPortTypeAutoChangeEnableStep(SERVO::CStep* pStep)
   {
      std::regex pattern("^EQPort\\d+CassetteType$");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isCassetteTransferStateStep(SERVO::CStep* pStep)
   {
      return CToolUnits::startsWith(pStep->getName(), "EQPort")
         && pStep->getName().find("Cassette") != std::string::npos;
      std::regex pattern("^EQPort\\d+Cassette.*");
      return std::regex_match(pStep->getName(), pattern);
   }

   bool CEquipment::isCimMessageConfirmStep(SERVO::CStep* pStep)
@@ -855,4 +878,34 @@

      return pStep->setDateTime(year, month, day, hour, minute, second);
   }

   int CEquipment::masterRecipeListRequest(short unitNo)
   {
      SERVO::CEqWriteStep* pStep = (SERVO::CEqWriteStep*)getStepWithName(STEP_EQ_MASTER_RECIPE_LIST_REQ);
      if (pStep == nullptr) {
         return -1;
      }

      LOGI("<CEquipment-%s>正在请求单元<%d>主配方列表", m_strName.c_str(), unitNo);
      if (m_recipesManager.syncing() != 0) {
         return -2;
      }
      pStep->writeShort(unitNo, [&, unitNo](int code) -> int {
         if (code == WOK) {
            LOGI("<CEquipment-%s>请求单元<%d>主配方列表成功，正在等待数据.", m_strName.c_str(), unitNo);
         }
         else {
            m_recipesManager.syncFailed();
            LOGI("<CEquipment-%s>请求单元<%d>主配方列表失败，code:%d", m_strName.c_str(), unitNo, code);
         }

         return 0;
      });
      return 0;
   }

   short CEquipment::decodeRecipeListReport(const char* pszData, size_t size)
   {
      return m_recipesManager.decodeRecipeListReport(pszData, size);
   }
}