1.在stroedJob和Fetchout Job中增加Port的校验； 2.在物料调度中增加检测物料是否已经处理完成的校验；

LAPTOP-SNT8I5JK\Boounion

2025-06-28 2ee440d9e85eccd73d2c3d4cbfe42cb8c1c25ec0

 SourceCode/Bond/Servo/CEquipment.cpp

@@ -836,7 +836,7 @@
      return 0;
   }

   int CEquipment::fetchedOutJob(CJobDataB* pJobDataB)
   int CEquipment::fetchedOutJob(int port, CJobDataB* pJobDataB)
   {
      if (m_pArm == nullptr) {
         return -1;
@@ -844,24 +844,17 @@

      // 找到指定的glass id, 
      Lock();
      CGlass* pContext = nullptr;
      for (int i = 0; i < SLOT_MAX; i++) {
         CGlass* pGlass = (CGlass*)m_slot[i].getContext();
         if (pGlass != nullptr && compareJobData(pJobDataB, pGlass->getJobDataS())) {
            pContext = pGlass;
            if (pGlass != nullptr) pGlass->addRef();
            m_slot[i].setContext(nullptr);
            break;
         }
      }
      if (pContext == nullptr) {
      CGlass* pGlass = (CGlass*)m_slot[port - 1].getContext();
      if (pGlass == nullptr && !compareJobData(pJobDataB, pGlass->getJobDataS())) {
         Unlock();
         return -3;
      }

      if (pGlass != nullptr) pGlass->addRef();
      m_slot[port - 1].setContext(nullptr);

      ((CArm*)m_pArm)->tempStore(pContext);
      pContext->release();
      ((CArm*)m_pArm)->tempStore(pGlass);
      pGlass->release();
      Unlock();


@@ -876,7 +869,7 @@
      return 0;
   }

   int CEquipment::storedJob(CJobDataB* pJobDataB, short putSlot)
   int CEquipment::storedJob(int port, CJobDataB* pJobDataB)
   {
      if (m_pArm == nullptr) {
         return -1;
@@ -890,8 +883,8 @@

      ASSERT(pGlass);
      Lock();
      pGlass->addPath(m_nID, getSlotUnit(putSlot));
      m_slot[putSlot - 1].setContext(pGlass);
      pGlass->addPath(m_nID, port);
      m_slot[port - 1].setContext(pGlass);
      pGlass->release();            // tempFetchOut需要调用一次release
      Unlock();

@@ -1304,6 +1297,7 @@
         if (!m_slot[i].isEnable()) continue;
         if (m_slot[i].isLock()) continue;
         CGlass* pGlass = (CGlass*)m_slot[i].getContext();
         if (!isSlotProcessed(i+1)) continue;
         if (pGlass == nullptr) continue;
         int lsPath = m_slot[i].getLinkSignalPath();
         if(!m_bLinkSignalToUpstream[lsPath][SIGNAL_UPSTREAM_INLINE]
@@ -1330,6 +1324,7 @@
               if (m_slot[i].isLock()) continue;
               CGlass* pGlass = (CGlass*)m_slot[i].getContext();
               if (pGlass == nullptr) continue;
               if (!isSlotProcessed(i+1)) continue;
               int lsPath = m_slot[i].getLinkSignalPath();
               if (!m_bLinkSignalToUpstream[lsPath][SIGNAL_UPSTREAM_INLINE]
                  || m_bLinkSignalToUpstream[lsPath][SIGNAL_UPSTREAM_TROUBLE]
@@ -1434,6 +1429,17 @@
   int CEquipment::onReceivedJob(int port, CJobDataS* pJobDataS)
   {
      LOGI("<CEquipment-%s>onReceivedJob.", m_strName.c_str());

      // 可以在此更新JobDataS数据了
      CGlass* pGlass = getGlassFromSlot(port);
      if (pGlass == nullptr) {
         LOGE("<CEquipment-%s>onSentOutJob,没有找到对应的Glass(CassetteSequenceNo:%d, JobSequenceNo:%d, ID=%s)，请检查数据，注意风险。",
            m_strName.c_str(), pJobDataS->getCassetteSequenceNo(), pJobDataS->getJobSequenceNo(),
            pJobDataS->getGlass1Id().c_str());
         return -1;
      }
      pGlass->updateJobDataS(pJobDataS);

      return 0;
   }

@@ -1455,17 +1461,6 @@
   int CEquipment::onSentOutJob(int port, CJobDataS* pJobDataS)
   {
      LOGI("<CEquipment-%s>onSentOutJob.", m_strName.c_str());


      // 可以在此更新JobDataS数据了
      CGlass* pGlass = getGlass(pJobDataS->getGlass1Id().c_str());
      if (pGlass == nullptr) {
         LOGE("<CEquipment-%s>onSentOutJob,没有找到对应的Glass(CassetteSequenceNo:%d, JobSequenceNo:%d, ID=%s)，请检查数据，注意风险。",
            m_strName.c_str(), pJobDataS->getCassetteSequenceNo(), pJobDataS->getJobSequenceNo(),
            pJobDataS->getGlass1Id().c_str());
         return -1;
      }
      pGlass->updateJobDataS(pJobDataS);

      return 0;
   }
@@ -1517,7 +1512,7 @@
      LOGI("<CEquipment-%s>onPreFetchedOutJob:port:%d|GlassId:%s",
         m_strName.c_str(), port, pJobDataB->getGlassId().c_str());
      if (m_listener.onPreFethedOutJob != nullptr) {
         return m_listener.onPreFethedOutJob(this, pJobDataB);
         return m_listener.onPreFethedOutJob(this, port, pJobDataB);
      }

      return TRUE;
@@ -1530,7 +1525,7 @@

      BOOL bCheck = onPreFetchedOutJob(port, pJobDataB);
      if (bCheck) {
         return fetchedOutJob(pJobDataB);
         return fetchedOutJob(port, pJobDataB);
      }

      // 数据异常，处理或显示
@@ -1678,7 +1673,9 @@

   int CEquipment::decodeJobProcessStartReport(CStep* pStep, const char* pszData, size_t size)
   {
      LOGI("<CEquipment-%s>decodeJobProcessStartReport", getName().c_str());
      int port = (int)(__int64)pStep->getProp("Port");
      LOGI("<CEquipment-%s>decodeJobProcessStartReport, port:%d", getName().c_str(), port);

      short cassetteNo, jobSequenceNo, unitNo, subUnitNo, slotNo;
      int year, month, day, hour, minute, second;

@@ -1744,7 +1741,8 @@

   int CEquipment::decodeJobProcessEndReport(CStep* pStep, const char* pszData, size_t size)
   {
      LOGI("<CEquipment-%s>decodeJobProcessEndReport", getName().c_str());
      int port = (int)(__int64)pStep->getProp("Port");
      LOGI("<CEquipment-%s>decodeJobProcessEndReport, port:%d", getName().c_str(), port);

      short cassetteNo, jobSequenceNo, unitNo, subUnitNo, slotNo;
      int year, month, day, hour, minute, second;
@@ -1789,6 +1787,19 @@
      if (m_processState != PROCESS_STATE::Complete) {
         setProcessState(PROCESS_STATE::Complete);
      }
      CGlass* pGlass = getGlassFromSlot(port);
      if (pGlass == nullptr) {
         LOGE("<CEquipment-%s>decodeJobProcessEndReport, 找不到对应glass", getName().c_str());
      }
      else {
         pGlass->processEnd(m_nID, port);
         if (m_processState != PROCESS_STATE::Complete) {
            setProcessState(PROCESS_STATE::Complete);
         }
      }




      // 缓存Attribute，用于调试时显示信息
      unsigned int weight = 201;
@@ -1833,17 +1844,18 @@

      // 如果没有可用位置，报错
      Lock();
      CSlot* pSlot = getAvailableSlotForGlassExcludeSignal((MaterialsType)pJobDataS->getMaterialsType());
      if (pSlot == nullptr) {
      CSlot* pSlot = getSlot(port - 1);
      ASSERT(pSlot);
      if (pSlot->getContext() != nullptr) {
         Unlock();
         LOGE("<CEquipemnt-%s>onPreFetchedOutJob,找不到匹配的Slot，不能进料，请注意风险！", m_strName.c_str());
         LOGE("<CEquipemnt-%s>onPreStoredJob,指定slot(port:%d)有料，请注意风险！", m_strName.c_str(), port);
         return FALSE;
      }
      Unlock();


      if (m_listener.onPreStoredJob != nullptr) {
         if (!m_listener.onPreStoredJob(this, pJobDataB, putSlot)) {
         if (!m_listener.onPreStoredJob(this, port, pJobDataB, putSlot)) {
            return FALSE;
         }

@@ -1862,8 +1874,8 @@

      short putSlot = 0;
      BOOL bCheck = onPreStoredJob(port, pJobDataB, putSlot);
      if (bCheck) {
         return storedJob(pJobDataB, putSlot);
      if (bCheck && port == putSlot) {
         return storedJob(port, pJobDataB);
      }

      // 数据异常，处理或显示