| | |
|---|
| | | #include "AlarmManager.h" |
|---|
| | | #include "CGlassPool.h" |
|---|
| | | #include "TransferManager.h" |
|---|
| | | #include "RecipeManager.h" |
|---|
| | | |
|---|
| | | |
|---|
| | | CModel::CModel() |
|---|
| | |
|---|
| | | if (id == 0) { |
|---|
| | | m_master.enableAlarmReport(bEnable); |
|---|
| | | } |
|---|
| | | }; |
|---|
| | | listener.onQueryPPIDList = [&](void* pFrom) ->std::vector<std::string> { |
|---|
| | | std::vector<std::string> ppids; |
|---|
| | | auto temp = RecipeManager::getInstance().getAllPPID(); |
|---|
| | | for (auto item : temp) { |
|---|
| | | if (item.length() > PPID_NAME_MAX) { |
|---|
| | | ppids.push_back(item.substr(0, PPID_NAME_MAX)); |
|---|
| | | } |
|---|
| | | else { |
|---|
| | | ppids.push_back(item); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return ppids; |
|---|
| | | }; |
|---|
| | | listener.onCarrierAction = [&](void* pFrom, |
|---|
| | | unsigned int DATAID, |
|---|
| | | const char* pszCarrierAction, |
|---|
| | | const char* pszCarrierId, |
|---|
| | | unsigned char PTN, |
|---|
| | | std::string& strErrorTxt) -> unsigned int { |
|---|
| | | if (PTN < 1 || 4 < PTN) { |
|---|
| | | strErrorTxt = "invalid data or argument"; |
|---|
| | | return CAACK_3; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (_strcmpi(pszCarrierAction, "ProceedWithCarrier") == 0) { |
|---|
| | | m_master.proceedWithCarrier(PTN); |
|---|
| | | return CAACK_0; |
|---|
| | | } |
|---|
| | | else if (_strcmpi(pszCarrierAction, "CarrierRelease") == 0) { |
|---|
| | | m_master.carrierRelease(PTN); |
|---|
| | | return CAACK_0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | strErrorTxt = "rejected - invalid state"; |
|---|
| | | return CAACK_5; |
|---|
| | | LOGI("<Model>onCarrierAction %d, %s, %d, %d", DATAID, pszCarrierAction, pszCarrierId, PTN); |
|---|
| | | }; |
|---|
| | | m_hsmsPassive.setListener(listener); |
|---|
| | | m_hsmsPassive.setEquipmentModelType((LPTSTR)(LPCTSTR)strModeType); |
|---|
| | |
|---|
| | | }; |
|---|
| | | masterListener.onLoadPortStatusChanged = [&] (void* pMaster, SERVO::CEquipment* pEquipment, short status, __int64 data) { |
|---|
| | | LOGE("<CModel>onLoadPortStatusChanged. status = %d", status); |
|---|
| | | if (status == PORT_INUSE) { |
|---|
| | | SERVO::CLoadPort* pLoadPort = dynamic_cast<SERVO::CLoadPort*>(pEquipment); |
|---|
| | | if (pLoadPort != nullptr) { |
|---|
| | | m_hsmsPassive.setVariableValue("CarrierID", pLoadPort->getCassetteId().c_str()); |
|---|
| | | } |
|---|
| | | m_hsmsPassive.requestEventReportSend_CarrierID_Readed(); |
|---|
| | | } |
|---|
| | | notifyPtr(RX_CODE_LOADPORT_STATUS_CHANGED, pEquipment); |
|---|
| | | }; |
|---|
| | | masterListener.onCTRoundEnd = [&](void* pMaster, int round) { |
|---|
| | | m_configuration.setContinuousTransferCount(round); |
|---|
| | | }; |
|---|
| | | m_master.setListener(masterListener); |
|---|
| | | m_master.setContinuousTransferCount(m_configuration.getContinuousTransferCount()); |
|---|
| | | |
|---|
| | | |
|---|
| | | // master 设置缓存文件 |
|---|
