1.整理完善物流控制框架，各种虚函数处理。

LAPTOP-SNT8I5JK\Boounion

2025-03-21 d1fd8f9e1f5a012b301a6ce93c2ce7eb3c927e31

 SourceCode/Bond/Servo/CEquipment.cpp

@@ -190,6 +190,21 @@
         attrubutes.addAttribute(new CAttribute(szTemp,
            m_bVCREnable[i] ? _T("Enable") : _T("Disable"), ""));
      }

      for (auto item : m_inputPins) {
         attrubutes.addAttribute(new CAttribute(item->getName().c_str(),
            std::to_string((int)item->getType()).c_str(), ""));
      }

      for (auto item : m_outputPins) {
         attrubutes.addAttribute(new CAttribute(item->getName().c_str(),
            std::to_string((int)item->getType()).c_str(), ""));
      }

      for (auto item : m_panelList) {
         attrubutes.addAttribute(new CAttribute("Panel",
            item->getID().c_str(), ""));
      }
   }

   void CEquipment::setReadBitBlock(unsigned int start, unsigned int end)
@@ -435,9 +450,113 @@

   int CEquipment::recvIntent(CPin* pPin, CIntent* pIntent)
   {
      ASSERT(pPin);
      CPin* pFromPin = pPin->getConnectedPin();
      ASSERT(pFromPin);
      CEquipment* pFromEq = pFromPin->getEquipment();
      ASSERT(pFromEq);

      LOGI("<CEquipment><%s-%s>收到来自<%s.%s>的Intent<%d,%s,0x%x>",
         this->getName().c_str(),
         pPin->getName().c_str(),
         pFromEq->getName().c_str(),
         pFromPin->getName().c_str(),
         pIntent->getCode(),
         pIntent->getMsg(),
         pIntent->getContext());



      // 以下解释处理数据
      int code = pIntent->getCode();


      // 测试
      if (code == FLOW_TEST) {
         AfxMessageBox(pIntent->getMsg());
         return FLOW_ACCEPT;
      }


      // 信号
      if (code == FLOW_SIGNAL) {
         return FLOW_ACCEPT;
      }


      // 数据
      if (code == FLOW_SIGNAL) {
         return FLOW_ACCEPT;
      }


      // 物料
      if (code == FLOW_MOVE_MATERIAL) {
         CPanel* pPanel = (CPanel*)pIntent->getContext();
         ASSERT(pPanel);
         if (!glassWillArrive(pPanel)) {
            return FLOW_REJECT;
         }
         return glassArrived(pPanel);
      }



      return FLOW_ACCEPT;
   }

   int CEquipment::outputGlass(int port)
   {
      CPin* pOutPin = nullptr;
      if (port == 0) {
         pOutPin = getPin("Out");
         if (pOutPin == nullptr) {
            pOutPin = getPin("Out1");
         }
      }
      else if (port == 1) {
         pOutPin = getPin("Out2");
      }
      if (pOutPin == nullptr) {
         return -1;
      }


      // 模拟取出第一张Panel,传送到下一环节
      Lock();
      CPanel* pContext = m_panelList.front();
      pContext->addRef();

      CIntent intent(FLOW_MOVE_MATERIAL, "", pContext);
      int nRet = pOutPin->sendIntent(&intent);
      if (nRet == FLOW_REJECT) {
         LOGE("<CEquipment>对方拒绝接收Intent.");
      }
      else if (nRet == FLOW_ACCEPT) {
         m_panelList.pop_front();
         pContext->release();      // 添加到列队时addRef, 取出时release
      }

      pContext->release();
      Unlock();

      return 0;
   }

   BOOL CEquipment::glassWillArrive(CPanel* pPanel)
   {
      return TRUE;
   }

   int CEquipment::glassArrived(CPanel* pPanel)
   {
      Lock();
      pPanel->addRef();
      m_panelList.push_back(pPanel);
      Unlock();
      return FLOW_ACCEPT;
   }

   void CEquipment::addPanelToList(CPanel* pPanel)
   {
      ASSERT(pPanel);