LAPTOP-SNT8I5JK\Boounion
2025-08-15 697fa6b857fe202fe2e5f50d4ecf2c7268e527cc
SourceCode/Bond/Servo/Model.cpp
@@ -175,6 +175,23 @@
         return CAACK_5;
         LOGI("<Model>onCarrierAction %d, %s, %d, %d", DATAID, pszCarrierAction, pszCarrierId, PTN);
   };
   listener.onPRJobMultiCreate = [&](void* pFrom, std::vector<SERVO::CProcessJob*>& pjs) -> int {
      for (auto p : pjs) {
         LOGI("<Model>onPRJobMultiCreate %s %s", p->id().c_str(), p->recipeSpec().c_str());
      }
      int nRet = m_master.setProcessJobs(pjs);
      auto processJobs = m_master.getProcessJobs();
      std::vector<SERVO::CVariable> vars;
      for (auto pj : processJobs) {
         SERVO::CVariable var("", "PRJOBID", "A50", "PRJOBID");
         var.setValue(pj->id().c_str());
         vars.push_back(var);
      }
      m_hsmsPassive.setVariableValue("PJQueued", vars);
      m_hsmsPassive.requestEventReportSend_PJ_Queued();
      return nRet;
   };
   m_hsmsPassive.setListener(listener);
   m_hsmsPassive.setEquipmentModelType((LPTSTR)(LPCTSTR)strModeType);
   m_hsmsPassive.setSoftRev((LPTSTR)(LPCTSTR)strSoftRev);
@@ -353,9 +370,20 @@
   };
   masterListener.onLoadPortStatusChanged = [&] (void* pMaster, SERVO::CEquipment* pEquipment, short status, __int64 data) {
      LOGE("<CModel>onLoadPortStatusChanged. status = %d", status);
      if (status == PORT_INUSE) {
         SERVO::CLoadPort* pLoadPort = dynamic_cast<SERVO::CLoadPort*>(pEquipment);
         if (pLoadPort != nullptr) {
            m_hsmsPassive.setVariableValue("CarrierID", pLoadPort->getCassetteId().c_str());
         }
         m_hsmsPassive.requestEventReportSend_CarrierID_Readed();
      }
      notifyPtr(RX_CODE_LOADPORT_STATUS_CHANGED, pEquipment);
   };
   masterListener.onCTRoundEnd = [&](void* pMaster, int round) {
      m_configuration.setContinuousTransferCount(round);
   };
   m_master.setListener(masterListener);
   m_master.setContinuousTransferCount(m_configuration.getContinuousTransferCount());
   // master 设置缓存文件