| | |
| | | boolean offer = false; |
| | | try { |
| | | offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
| | | if(taskWrk.getMp() == 1) { |
| | | staProtocol.setMp(taskWrk.getMp()); |
| | | staProtocol.setLx(taskWrk.getLx()); |
| | | staProtocol.setLev(taskWrk.getLev()); |
| | | MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); |
| | | } |
| | | // staProtocol.setMp(taskWrk.getMp()); |
| | | // staProtocol.setLx(taskWrk.getLx()); |
| | | // staProtocol.setLev(taskWrk.getLev()); |
| | | // MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); |
| | | } catch (Exception e) { |
| | | log.error("下发输送线任务失败:异常:" + e); |
| | | log.error("下发输送线任务失败:异常:offer:" + offer); |
| | |
| | | taskWrk.setWrkSts(14); |
| | | taskWrk.setCompleteTime(new Date()); |
| | | taskWrkService.updateById(taskWrk); |
| | | |
| | | // 侧面出库完成 上报执行状态 |
| | | toWmsService.executionStatusReport(taskWrk.getTaskNo(), taskWrk.getWrkSts()); |
| | | } else { |
| | | log.error("下发输送线任务失败:taskWrk:" + JSON.toJSONString(taskWrk)); |
| | | } |