| | |
| | | |
| | | return 1; |
| | | } |
| | | else if (pStep->getName().compare(STEP_STATUS) == 0) { |
| | | SERVO::CEqStatusStep* pEqStatusStep = (SERVO::CEqStatusStep*)pStep; |
| | | if (m_listener.onEqStatusChanged != nullptr) { |
| | | const unsigned int unitId = pEqStatusStep->getUnitId(); |
| | | const int status = pEqStatusStep->getStatus(unitId); |
| | | const int reason = pEqStatusStep->getReasonCode(unitId); |
| | | m_listener.onEqStatusChanged(this, (int)unitId, status, reason); |
| | | } |
| | | return 1; |
| | | } |
| | | else if (isCimMessageConfirmStep(pStep)) { |
| | | SERVO::CEqReadIntStep* pEqReadIntStep = (SERVO::CEqReadIntStep*)pStep; |
| | | int value = pEqReadIntStep->getValue(); |
| | |
| | | for (int i = 0; i < SLOT_MAX; i++) { |
| | | CGlass* pGlass = (CGlass*)m_slot[i].getContext(); |
| | | if (pGlass != nullptr && compareJobData(pJobDataB, pGlass->getJobDataS())) { |
| | | // 取片成功后,回填当前路径节点的离开时间(优先匹配尚未离开的节点)。 |
| | | CPath* pPath = pGlass->getPath(); |
| | | if (pPath != nullptr) { |
| | | CPath* pScan = pPath->getHeadPath(); |
| | | CPath* pOpenNode = nullptr; |
| | | const unsigned int slotNo = (unsigned int)m_slot[i].getNo(); |
| | | const unsigned int unitNo = getSlotUnit((int)slotNo); |
| | | while (pScan != nullptr) { |
| | | if (pScan->getEqID() == m_nID |
| | | && pScan->getUnit() == unitNo |
| | | && pScan->getSlot() == slotNo |
| | | && pScan->getOutTime() == 0) { |
| | | pOpenNode = pScan; |
| | | } |
| | | pScan = pScan->getNext(); |
| | | } |
| | | if (pOpenNode != nullptr) { |
| | | pOpenNode->setOutTime(CToolUnits::getTimestamp()); |
| | | } |
| | | } |
| | | |
| | | pContext = pGlass; |
| | | if (pGlass != nullptr) pGlass->addRef(); |
| | | m_slot[i].setContext(nullptr); |
| | |
| | | } |
| | | } |
| | | if (pContext == nullptr) { |
| | | LOGE("<CEquipment-%s>fetchedOutJob, no glass for JobDataB(%d, %d)", m_strName.c_str(), |
| | | pJobDataB->getCassetteSequenceNo(), pJobDataB->getJobSequenceNo()); |
| | | Unlock(); |
| | | return -3; |
| | | } |
| | | LOGI("<CEquipment-%s>fetchedOutJob -> Arm: GlassId:%s, Cassette:%d, Job:%d", m_strName.c_str(), |
| | | pContext->getID().c_str(), pJobDataB->getCassetteSequenceNo(), pJobDataB->getJobSequenceNo()); |
| | | |
| | | ((CArm*)m_pArm)->tempStore(pContext); |
| | | pContext->release(); |
| | |
| | | |
| | | CGlass* pGlass = nullptr; |
| | | if (((CArm*)m_pArm)->tempFetchOut(pGlass) != 0) { |
| | | LOGE("<CEquipment-%s>storedJob, tempFetchOut failed (arm empty).", m_strName.c_str()); |
| | | return -2; |
| | | } |
| | | |
| | | |
| | | ASSERT(pGlass); |
| | | LOGI("<CEquipment-%s>storedJob <- Arm: GlassId:%s, Cassette:%d, Job:%d", m_strName.c_str(), |
| | | pGlass->getID().c_str(), pJobDataB->getCassetteSequenceNo(), pJobDataB->getJobSequenceNo()); |
| | | Lock(); |
| | | pGlass->addPath(m_nID, getSlotUnit(putSlot), putSlot); |
| | | CGlass* pBuddy = pGlass->getBuddy(); |
| | |
| | | { |
| | | LOGI("<CEquipment-%s>onSentOutJob.", m_strName.c_str()); |
| | | |
| | | if (m_listener.onSentOutJob != nullptr) { |
| | | m_listener.onSentOutJob(this, port, pJobDataS); |
| | | } |
| | | |
| | | return 0; |
| | | } |
| | | |
| | |
| | | // 当前要存片,之前肯定有拔片,因此片子在Arm那里 |
| | | CGlass* pGlass = ((CArm*)m_pArm)->getGlassFromSlot(1); |
| | | if (pGlass == nullptr) { |
| | | LOGE("<CFliper-%s>onPreStoredJob,缓存中没有找到对应的Glass(CassetteSequenceNo:%d, JobSequenceNo:%d),请检查数据,注意风险。", m_strName.c_str(), |
| | | LOGE("<CEquipment-%s>onPreStoredJob,缓存中没有找到对应的Glass(CassetteSequenceNo:%d, JobSequenceNo:%d),请检查数据,注意风险。", m_strName.c_str(), |
| | | pJobDataB->getCassetteSequenceNo(), pJobDataB->getJobSequenceNo()); |
| | | LOGE("<CEquipment-%s>onPreStoredJob, arm temp empty (arm:%s).", m_strName.c_str(), |
| | | (m_pArm != nullptr) ? ((CEquipment*)m_pArm)->getName().c_str() : "null"); |
| | | return FALSE; |
| | | } |
| | | |
| | | CJobDataS* pJobDataS = pGlass->getJobDataS(); |
| | | ASSERT(pJobDataS); |
| | | LOGI("<CEquipment-%s>onPreStoredJob, Arm has GlassId:%s, Cassette:%d, Job:%d", |
| | | m_strName.c_str(), pGlass->getID().c_str(), |
| | | pJobDataS->getCassetteSequenceNo(), pJobDataS->getJobSequenceNo()); |
| | | if (!compareJobData(pJobDataB, pJobDataS)) { |
| | | LOGE("<CEquipemnt-%s>onPreStoredJob,JobData数据不匹配(JobDataB(%d, %d),JobDataS(%d, %d)), 注意排查风险!", m_strName.c_str(), |
| | | pJobDataB->getCassetteSequenceNo(), pJobDataB->getJobSequenceNo(), |
| | | pJobDataS->getCassetteSequenceNo(), pJobDataS->getJobSequenceNo()); |
| | | return FALSE; |
| | | } |
| | | |
| | | // 如果没有可用位置,报错 |
| | | Lock(); |
| | | CSlot* pSlot = getSlot(putSlot - 1); |
| | | ASSERT(pSlot); |
| | | if (pSlot->getContext() != nullptr) { |
| | | Unlock(); |
| | | 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, port, pJobDataB, putSlot)) { |
| | |
| | | return FALSE; |
| | | } |
| | | } |
| | | |
| | | // 如果没有可用位置,报错(需在 listener 回调后拿到 putSlot) |
| | | if (putSlot <= 0) { |
| | | LOGE("<CEquipemnt-%s>onPreStoredJob, putSlot无效(port:%d).", m_strName.c_str(), port); |
| | | return FALSE; |
| | | } |
| | | Lock(); |
| | | CSlot* pSlot = getSlot(putSlot - 1); |
| | | ASSERT(pSlot); |
| | | if (pSlot->getContext() != nullptr) { |
| | | Unlock(); |
| | | LOGE("<CEquipemnt-%s>onPreStoredJob,指定slot(port:%d)有料,请注意风险!", m_strName.c_str(), port); |
| | | return FALSE; |
| | | } |
| | | Unlock(); |
| | | |
| | | return TRUE; |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | PROCESS_STATE CEquipment::getProcessState(int slotNo) const |
| | | { |
| | | if (slotNo <= 0 || slotNo > SLOT_MAX) { |
| | | return PROCESS_STATE::Ready; |
| | | } |
| | | return m_processState[slotNo - 1]; |
| | | } |
| | | |
| | | std::vector<SERVO::CSVData>& CEquipment::getSVDatas() |
| | | { |
| | | return m_svDatas; |