diff --git a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/DjqToKzjhcwTask.java b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/DjqToKzjhcwTask.java index ec0b144bc..a7801c5aa 100644 --- a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/DjqToKzjhcwTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/DjqToKzjhcwTask.java @@ -55,6 +55,26 @@ public class DjqToKzjhcwTask extends AbstractAcsTask { private IbstIvtPackageinfoivtService packageinfoivtService; + @Override + public List addTask(SchBaseTask r) { + ArrayList resultList = new ArrayList<>(); + AcsTaskDto dto = AcsTaskDto.builder() + .ext_task_id(r.getTask_id().toString()) + .task_code(r.getTask_code()) + .task_type(r.getAcs_task_type()) + .start_device_code(r.getPoint_code1()) + .next_device_code(r.getPoint_code2()) + .vehicle_code(r.getVehicle_code()) + .priority(r.getPriority()) + .remark(r.getRemark()) + .product_area(r.getProduct_area()) + .agv_action_type(r.getVehicle_code2()) + .agv_system_type(PackageInfoIvtEnum.AGV_SYSTEM_TYPE.code("1楼诺宝任务")) + .interaction_json(JSON.parseObject(r.getRequest_param())) + .build(); + resultList.add(dto); + return resultList; + } @Override public List addTask() { @@ -188,7 +208,7 @@ public class DjqToKzjhcwTask extends AbstractAcsTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.immediateNotifyAcs(null); + this.immediateTaskNotifyAcs(task); } return task.getTask_id(); } diff --git a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/MzhcwTask.java b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/MzhcwTask.java index 9bb253166..ca80ab320 100644 --- a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/MzhcwTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/MzhcwTask.java @@ -336,7 +336,7 @@ public class MzhcwTask extends AbstractAcsTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.immediateNotifyAcs(task,""); + this.immediateTaskNotifyAcs(task); } return task.getTask_id(); } diff --git a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/SendDjqKzjTask.java b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/SendDjqKzjTask.java index 3533872bc..c1b176d42 100644 --- a/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/SendDjqKzjTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/SendDjqKzjTask.java @@ -164,7 +164,7 @@ public class SendDjqKzjTask extends AbstractAcsTask { taskService.save(task); //如果目标点位没有空位先创建不下发 if (isSend) { - this.immediateNotifyAcs(task,""); + this.immediateTaskNotifyAcs(task); } return task.getTask_id(); } diff --git a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AbstractAcsTask.java b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AbstractAcsTask.java index b7521127f..4ec78b54f 100644 --- a/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AbstractAcsTask.java +++ b/lms/nladmin-system/src/main/java/org/nl/wms/sch/manage/AbstractAcsTask.java @@ -37,23 +37,13 @@ public abstract class AbstractAcsTask { return addTask(); } - public List schedule(String taskId) { - return addTask(taskId); - } - - public List schedule(SchBaseTask task) { - return addTask(task); - } - /** * 添加任务进行下发 * * @return */ public abstract List addTask(); - public List addTask(String taskId){ - throw new BadRequestException("当前类没有重写addTask(taskId)方法"); - }; + public List addTask(SchBaseTask task){ throw new BadRequestException("当前类没有重写addTask(taskId)方法"); }; @@ -128,34 +118,28 @@ public abstract class AbstractAcsTask { /** * */ - public JSONObject immediateNotifyAcs(Object task_id) { + public JSONObject immediateNotifyAcs(String task_id) { try { Thread.sleep(1000); }catch (Exception ex){ } - List taskList; - if (ObjectUtil.isEmpty(task_id)){ - taskList = this.schedule(); + List taskList = this.schedule(); + if (ObjectUtil.isNotEmpty(taskList)) { + JSONArray arr = JSONArray.parseArray(JSON.toJSONString(taskList)); + if (acsUtil == null){ + return AcsUtil.notifyAcs("api/wms/task", arr); }else { - taskList = this.schedule((String) task_id); - } - if (ObjectUtil.isNotEmpty(taskList)) { - JSONArray arr = JSONArray.parseArray(JSON.toJSONString(taskList)); - if (acsUtil == null){ - return AcsUtil.notifyAcs("api/wms/task", arr); - }else { - return acsUtil.notifyAcs3("api/wms/task", arr); - } + return acsUtil.notifyAcs3("api/wms/task", arr); } + } return null; - } - public JSONObject immediateNotifyAcs(SchBaseTask task,String taskId) { + public JSONObject immediateTaskNotifyAcs(SchBaseTask task) { if (task==null){ throw new BadRequestException("任务下发参数不能为空"); } - List taskList = this.schedule(task); + List taskList = this.addTask(task); if (ObjectUtil.isNotEmpty(taskList)) { JSONArray arr = JSONArray.parseArray(JSON.toJSONString(taskList)); if (acsUtil == null){