src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/TaskReportScheduler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -255,10 +255,12 @@ boolean offer = false; try { offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); staProtocol.setMp(taskWrk.getMp()); staProtocol.setLx(taskWrk.getLx()); staProtocol.setLev(taskWrk.getLev()); MessageQueue.offer(SlaveType.Devp, 1, new Task(3, 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)); } } catch (Exception e) { log.error("下发输送线任务失败:异常:" + e); log.error("下发输送线任务失败:异常:offer:" + offer); src/main/java/com/zy/asrs/task/TaskReportScheduler.java
@@ -99,7 +99,7 @@ short mpCompletedFlag = staProtocol.getMpCompletedFlag(); if (mpCompletedFlag == 1) { TaskWrk taskWrk = taskWrkMapper.selectByWrkNo(Integer.valueOf(staProtocol.getWorkNo())); if (taskWrk != null) { if (taskWrk != null && taskWrk.getMp() == 1) { // 请求体 JSONObject request = new JSONObject();