| | |
|---|
| | | } |
|---|
| | | storageEscalationParam.setBarcode(BoxNo); |
|---|
| | | storageEscalationParam.setMatIdList(staProtocol.getMatIdList()); |
|---|
| | | storageEscalationParam.setFullPlt(staProtocol.isFullPlt() ? 1 : 0); |
|---|
| | | log.info("组托入库={}", storageEscalationParam); |
|---|
| | | TaskWrk taskWrk = toWmsService.getLocNoFromWms(storageEscalationParam); |
|---|
| | | if (taskWrk == null) { |
|---|
| | | log.error("入库请求wms创建任务工作档为空：{}", storageEscalationParam); |
|---|
| | | continue; |
|---|
| | | } else { |
|---|
| | | if (-1 == taskWrk.getWrkNo()) { |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (back) { |
|---|
| | | staProtocol.setStaNo(inSta.getBackSta().shortValue()); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | log.info("组托入库托盘退回命令推送输送线队列成功==>{}，{}", BoxNo, errMsg); |
|---|
| | | log.info("组托入库托盘退回命令推送输送线队列成功==>{}，{}，{}", BoxNo, errMsg, taskWrk.getWrkNo()); |
|---|
| | | } else { |
|---|
| | | StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() |
|---|
| | | .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); |
|---|
