diff --git a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/TrussCallAirShaftTask.java b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/TrussCallAirShaftTask.java index bf7167160..8940903ee 100644 --- a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/TrussCallAirShaftTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/slitter/TrussCallAirShaftTask.java @@ -56,6 +56,8 @@ public class TrussCallAirShaftTask extends AbstractAcsTask { private IBstIvtShafttubeivtService shafttubeivtService; @Autowired private TrussSendAirShaftTask trussSendAirShaftTask; + @Autowired + private SendNBJExceptionPointTask sendNBJExceptionPointTask; @Override public List addTask() { /* @@ -122,24 +124,34 @@ public class TrussCallAirShaftTask extends AbstractAcsTask { if (ObjectUtil.isEmpty(startPointObj.getQzz_no1()) && ObjectUtil.isEmpty(startPointObj.getQzz_no2())) { // 查找半条任务,并创建下发 List list = taskService.list(new LambdaQueryWrapper() - .eq(SchBaseTask::getTask_type, "010814") + .in(SchBaseTask::getTask_type, "010814", "010812") .eq(SchBaseTask::getTask_status, TaskStatusEnum.SURE_START.getCode()) .eq(SchBaseTask::getIs_delete, "0") .orderByAsc(SchBaseTask::getCreate_time)); if (list.size() > 0) { SchBaseTask schBaseTask = list.get(0); - JSONObject requestParam = JSONObject.parseObject(schBaseTask.getRequest_param()); - if (ObjectUtil.isNotEmpty(requestParam.getString("needPosition")) && "A".equals(requestParam.getString("needPosition"))) { - schBaseTask.setPoint_code2(task.getPoint_code1() + "_" + requestParam.getString("needPosition")); + if ("010814".equals(schBaseTask.getTask_type())) { + JSONObject requestParam = JSONObject.parseObject(schBaseTask.getRequest_param()); + if (ObjectUtil.isNotEmpty(requestParam.getString("needPosition")) && "A".equals(requestParam.getString("needPosition"))) { + schBaseTask.setPoint_code2(task.getPoint_code1() + "_" + requestParam.getString("needPosition")); + } + if (ObjectUtil.isNotEmpty(requestParam.getString("needPosition")) && "B".equals(requestParam.getString("needPosition"))) { + schBaseTask.setPoint_code2(task.getPoint_code1() + "_" + requestParam.getString("needPosition")); + } + schBaseTask.setRemark("AGV取货完成触发!"); + schBaseTask.setUpdate_time(DateUtil.now()); + schBaseTask.setTask_status(TaskStatusEnum.START_AND_POINT.getCode()); + taskService.updateById(schBaseTask); + trussSendAirShaftTask.immediateNotifyAcs(schBaseTask.getTask_id()); + } else if ("010812".equals(schBaseTask.getTask_type())) { + schBaseTask.setRemark("AGV取货完成触发!"); + schBaseTask.setPoint_code2(task.getPoint_code1() + "_A"); + schBaseTask.setUpdate_time(DateUtil.now()); + schBaseTask.setTask_status(TaskStatusEnum.START_AND_POINT.getCode()); + taskService.updateById(schBaseTask); + sendNBJExceptionPointTask.immediateNotifyAcs(schBaseTask.getTask_id()); } - if (ObjectUtil.isNotEmpty(requestParam.getString("needPosition")) && "B".equals(requestParam.getString("needPosition"))) { - schBaseTask.setPoint_code2(task.getPoint_code1() + "_" + requestParam.getString("needPosition")); - } - schBaseTask.setRemark("AGV取货完成触发!"); - schBaseTask.setUpdate_time(DateUtil.now()); - schBaseTask.setTask_status(TaskStatusEnum.START_AND_POINT.getCode()); - taskService.updateById(schBaseTask); - trussSendAirShaftTask.immediateNotifyAcs(schBaseTask.getTask_id()); + } } }