1.CIM Message set（下发CIM消息到PLC），测试成功 2.CIM Message clear(清除PLC中的指定CIM消息)， 测试...

LAPTOP-SNT8I5JK\Boounion

2025-04-12 87c5da242b0502626deac934d75579559032c2c8

 SourceCode/Bond/Servo/CEquipment.cpp

@@ -23,8 +23,8 @@

   CEquipment::CEquipment() : m_nID(0), m_strName(""), m_strDescription(""), m_station(0, 255)
   {
      m_listener = { nullptr, nullptr, nullptr };
      m_alive = {FALSE, 0, FALSE};
      m_listener = { nullptr, nullptr, nullptr, nullptr };
      m_alive = { FALSE, 0, FALSE };
      m_bCimState = FALSE;
      m_bUpstreamInline = FALSE;
      m_bDownstreamInline = FALSE;
@@ -65,6 +65,7 @@
   {
      m_listener.onAlive = listener.onAlive;
      m_listener.onCimStateChanged = listener.onCimStateChanged;
      m_listener.onAlarm = listener.onAlarm;
      m_listener.onDataChanged = listener.onDataChanged;
   }

@@ -120,6 +121,7 @@
      auto iter = m_mapStep.find(addr);
      if (iter != m_mapStep.end()) return -1;
      pStep->setEquipment(this);
      pStep->setID(addr);
      pStep->setCcLink(m_pCclink);
      m_mapStep[addr] = pStep;
      return 0;
@@ -326,7 +328,7 @@
            }
         }
      }
	

      // CIM State
      bFlag = isBitOn(pszData, size, ++index);
      if (!equalBool(m_bCimState, bFlag)) {
@@ -381,6 +383,18 @@
      // CIM Mode
      CHECK_WRITE_STEP_SIGNAL(0x350, pszData, size);

      // CIM Message Set
      CHECK_WRITE_STEP_SIGNAL(0x351, pszData, size);

      // CIM Message Clear
      CHECK_WRITE_STEP_SIGNAL(0x352, pszData, size);

      // CIM Message Confirm
      CHECK_READ_STEP_SIGNAL(0x369, pszData, size);


      // EQ Mode
      CHECK_WRITE_STEP_SIGNAL(0x355, pszData, size);

      // Port1 ~ Port4
      CHECK_READ_STEP_SIGNAL(0x3e0, pszData, size);
@@ -483,6 +497,38 @@
   {
      if (index >= VCR_MAX) return FALSE;
      return m_bVCREnable[index];
   }

   int CEquipment::onStepEvent(CStep* pStep, int code)
   {
      if (code == STEP_EVENT_READDATA) {
         if (isAlarmStep(pStep)) {
            SERVO::CEqAlarmStep* pEqAlarmStep = (SERVO::CEqAlarmStep*)pStep;
            int state = pEqAlarmStep->getAlarmState();
            ASSERT(state == 0 || state == 1);
            if (m_listener.onAlarm != nullptr) {
               m_listener.onAlarm(this, state,
                  pEqAlarmStep->getAlarmId(),
                  pEqAlarmStep->getUnitId(),
                  pEqAlarmStep->getAlarmLevel());
            }

            return 1;
         }
         else if (isCimMessageConfirmStep(pStep)) {
            SERVO::CEqReadIntStep* pEqReadIntStep = (SERVO::CEqReadIntStep*)pStep;
            int value = pEqReadIntStep->getValue();
            // 此处将value按高低位拆分为message id和panel no.
            // 可能还需要上报到cim
            short msgId, panelNo;
            msgId = (value & 0xffff0000 >> 16);
            panelNo = (value & 0xffff);
            LOGI("Cim Message Confirm(msgID = %d, panel no.=%d).", msgId, panelNo);
         }
      }


      return 0;
   }

   CPin* CEquipment::addPin(PinType type, char* pszName)
@@ -715,4 +761,73 @@

      return pGlass;
   }
}

   bool CEquipment::isAlarmStep(SERVO::CStep* pStep)
   {
      return CToolUnits::startsWith(pStep->getName(), STEP_ALARM_START);
   }

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

   bool CEquipment::isCimMessageConfirmStep(SERVO::CStep* pStep)
   {
      return pStep->getName().compare(STEP_EQ_CIM_MESSAGE_CONFIRM) == 0;
   }

   int CEquipment::setEqMode(short mode)
   {
      SERVO::CEqModeChangeStep* pStep = (SERVO::CEqModeChangeStep*)getStepWithName(STEP_EQ_MODE_CHANGE);
      if (pStep == nullptr) {
         return -1;
      }

      return pStep->setEqMode(mode);
   }

   int CEquipment::setCimMode(BOOL bOn)
   {
      SERVO::CEqCimModeChangeStep* pStep = (SERVO::CEqCimModeChangeStep*)getStepWithName(STEP_CIM_MODE_CHANGE);
      if (pStep == nullptr) {
         return -1;
      }

      if (bOn)
         return pStep->cimOn();
      else 
         return pStep->cimOff();
   }

   int CEquipment::setCimMessage(const char* pszMessage, short id, short nTouchPanelNo)
   {
      SERVO::CEqCimMessageCmdStep* pStep = (SERVO::CEqCimMessageCmdStep*)getStepWithName(STEP_CIM_MESSAGE_CMD);
      if (pStep == nullptr) {
         return -1;
      }

      return pStep->setCimMessage(pszMessage, id, nTouchPanelNo);
   }

   int CEquipment::clearCimMessage(short id, short nTouchPanelNo)
   {
      SERVO::CEqCimMessageClearStep* pStep = (SERVO::CEqCimMessageClearStep*)getStepWithName(STEP_CIM_MESSAGE_CLEAR);
      if (pStep == nullptr) {
         return -1;
      }

      return pStep->clearCimMessage(id, nTouchPanelNo);
   }

   int CEquipment::setDateTime(short year, short month, short day, short hour, short minute, short second)
   {
      SERVO::CEqDateTimeSetCmdStep* pStep = (SERVO::CEqDateTimeSetCmdStep*)getStepWithName(STEP_DATETIME_SET_CMD);
      if (pStep == nullptr) {
         return -1;
      }

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