| | |
| | | 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)); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("下发输送线任务失败:异常:" + e); |
| | | log.error("下发输送线任务失败:异常:offer:" + offer); |
| | |
| | | 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(); |