1.本地控件状态改变后上报EAP

chenluhua1980

2026-01-08 d7fbb147a1582e93c3028d8328b2e7eb3736d6e9

 SourceCode/Bond/Servo/Model.cpp

@@ -22,6 +22,33 @@
{
}

void CModel::refreshDerivedSVs()
{
   // CJobSpace: how many ControlJobs can be created (current implementation supports 0/1).
   m_hsmsPassive.setVariableValue("CJobSpace", (__int64)(m_master.canCreateControlJob() ? 1 : 0));

   // PJobSpace: how many ProcessJobs can be created (current implementation supports 0/1).
   m_hsmsPassive.setVariableValue("PJobSpace", (__int64)(m_master.isProcessJobsEmpty() ? 1 : 0));
}

void CModel::setControlState(ControlState newState)
{
   const auto prev = m_currentControlState;
   if (newState != m_currentControlState) {
      m_hsmsPassive.setVariableValue("PreviousControlState", (__int64)static_cast<uint8_t>(prev));
      m_currentControlState = newState;
   }

   // Always keep SV in sync (even if state didn't change or variables were just loaded).
   m_hsmsPassive.setVariableValue("CurrentControlState", (__int64)static_cast<uint8_t>(m_currentControlState));

   if (newState != prev) {
      // S6F11 (CEID=600): ControlStateChanged
      m_hsmsPassive.requestEventReportSend("ControlStateChanged");
      notifyInt(RX_CODE_CONTROL_STATE_CHANGED, static_cast<int>(m_currentControlState));
   }
}

IObservable* CModel::getObservable()
{
   if (m_pObservable == nullptr) {
@@ -108,22 +135,37 @@


   SECSListener listener;
   listener.onEQOffLine = [&](void* pFrom) -> void {
   listener.onEQOffLine = [this](void* pFrom) -> void {
      LOGI("远程请求OffLine");
      (void)pFrom;
      setControlState(ControlState::OfflineHost);
   };
   listener.onEQOnLine = [&](void* pFrom) -> void {
   listener.onEQOnLine = [this](void* pFrom) -> void {
      LOGI("远程请求OnLine");
      (void)pFrom;
      // Customer flow: S1F17 RequestOnline defaults to OnlineRemote.
      setControlState(ControlState::OnlineRemote);
   };
   listener.onCommand = [&](void* pFrom, const char* pszName, std::vector<CommandParameter>& params) -> void {
   listener.onCommand = [this](void* pFrom, const char* pszName, std::vector<CommandParameter>& params) -> void {
      LOGI("onCommand:%s", pszName);
      (void)pFrom;
      for (auto& item : params) {
         LOGI("param:%s,%s", item.szName, item.szValue);
      }

      if (pszName == nullptr) return;
      // S2F41 GoLocal / GoRemote (RCMD)
      if (_strcmpi(pszName, "GoLocal") == 0 || _strcmpi(pszName, "LOCAL") == 0 || _strcmpi(pszName, "GoLOCAL") == 0) {
         setControlState(ControlState::OnlineLocal);
      }
      else if (_strcmpi(pszName, "GoRemote") == 0 || _strcmpi(pszName, "REMOTE") == 0 || _strcmpi(pszName, "GoREMOTE") == 0) {
         setControlState(ControlState::OnlineRemote);
      }
   };
   listener.onEQConstantRequest = [&](void* pFrom, std::vector<EQConstant>& eqcs) -> void {
      // 在此填充常量值，目前仅是加1后返回
      for (auto& item : eqcs) {
         sprintf_s(item.szValue, 256, "Test%d", item.id + 1);
         sprintf_s(item.szValue, EQCONSTANT_VALUE_MAX, "Test%d", item.id + 1);
      }
   };
   listener.onEQConstantSend = [&](void* pFrom, std::vector<EQConstant>& eqcs) -> void {
@@ -175,11 +217,13 @@

         const unsigned int portIndex = PTN - 1;
         SERVO::CLoadPort* pLoadPort = (SERVO::CLoadPort*)m_master.getEquipment(EQ_ID_LOADPORT1 + portIndex);
         LOGI("<Model>onCarrierAction %d, %s, %d, %d", DATAID, pszCarrierAction, pszCarrierId, PTN);

         if (_strcmpi(pszCarrierAction, "ProceedWithCarrier") == 0) {
            // 文档流程：ProceedWithCarrier 之后设备进入 Check SlotMap（WFH），
            // 真正的“开始”由 ProceedWithSlotMap 决策触发。
            // 仅当未开启 CompareMapsBeforeProceeding 时，才沿用旧逻辑直接 Start。
            LOGI("<CModel>ProceedWithCarrier");
            if (pLoadPort == nullptr || !pLoadPort->isCompareMapsBeforeProceeding()) {
               m_master.proceedWithCarrier(portIndex);
            }
@@ -191,6 +235,7 @@
            // 当前 S3F17 解析结构仅支持 {DATAID, CarrierAction, CarrierID, PTN}，尚未实现上述扩展字段的解析/校验。
            // 未来若客户确认 SECS-II 结构，需要在 CHsmsPassive::replyCarrierAction() 扩展解析并在此处落库/校验。
            // 仅在 CompareMapsBeforeProceeding 启用（Host 模式）下允许此动作
            LOGI("<CModel>ProceedWithSlotMap");
            if (pLoadPort == nullptr || !pLoadPort->isCompareMapsBeforeProceeding()) {
               strErrorTxt = "rejected - SlotMap check disabled";
               return CAACK_5;
@@ -205,13 +250,13 @@
            return CAACK_0;
         }
         else if (_strcmpi(pszCarrierAction, "CarrierRelease") == 0) {
            LOGI("<CModel>CarrierRelease");
            m_master.carrierRelease(portIndex);
            return CAACK_0;
         }

         strErrorTxt = "rejected - invalid state";
         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) {
@@ -241,6 +286,8 @@
   CString strVarialbleFile;
   strVarialbleFile.Format(_T("%s\\VariableList.txt"), (LPTSTR)(LPCTSTR)m_strWorkDir);
   m_hsmsPassive.loadVarialbles((LPTSTR)(LPCTSTR)strVarialbleFile);
   setControlState(m_currentControlState);
   refreshDerivedSVs();
   m_hsmsPassive.init(this, "APP", 7000);
   strVarialbleFile.Format(_T("%s\\ReportList.txt"), (LPTSTR)(LPCTSTR)m_strWorkDir);
   m_hsmsPassive.loadReports((LPTSTR)(LPCTSTR)strVarialbleFile);
@@ -255,6 +302,10 @@
      LOGI("<CModel>Master state changed(%d)", (int)state);
      notify(RX_CODE_MASTER_STATE_CHANGED);
   };
   masterListener.onControlJobChanged = [this](void* pMaster) {
      (void)pMaster;
      this->refreshDerivedSVs();
      };
   masterListener.onEqAlive = [&](void* pMaster, SERVO::CEquipment* pEquipment, BOOL bAlive) -> void {
      LOGI("<CModel>Equipment onAlive:%s(%s).", pEquipment->getName().c_str(),
         bAlive ? _T("ON") : _T("OFF"));