From 345d7f620b1cd6c39899e58b231e797948e1b1b0 Mon Sep 17 00:00:00 2001 From: ludj Date: Thu, 4 May 2023 14:28:14 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/org/nl/wms/sch/AcsUtil.java | 3 +++ .../src/main/java/org/nl/wms/sch/task/AutoCreateTask.java | 6 +++--- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/AcsUtil.java b/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/AcsUtil.java index 951e05b..cd0dde9 100644 --- a/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/AcsUtil.java +++ b/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/AcsUtil.java @@ -5,6 +5,7 @@ import cn.hutool.core.util.StrUtil; import cn.hutool.http.HttpRequest; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; import org.nl.modules.system.service.impl.ParamServiceImpl; import org.nl.utils.SpringContextHolder; import org.springframework.http.HttpStatus; @@ -12,6 +13,7 @@ import org.springframework.http.HttpStatus; /** * ACS连接工具类: */ +@Slf4j public class AcsUtil { public static JSONObject notifyAcs(String api, JSONArray list) { //判断是否连接ACS系统 @@ -27,6 +29,7 @@ public class AcsUtil { String acsUrl = SpringContextHolder.getBean(ParamServiceImpl.class).findByCode("ACS_URL").getValue(); String url = acsUrl + api; + log.info("下发acs任务的参数为:{}", list.toString()); try { String resultMsg = HttpRequest.post(url) .body(String.valueOf(list)) diff --git a/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/task/AutoCreateTask.java b/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/task/AutoCreateTask.java index 60ac502..ab36dfc 100644 --- a/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/task/AutoCreateTask.java +++ b/wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/task/AutoCreateTask.java @@ -77,7 +77,7 @@ public class AutoCreateTask { }); String api = "api/wms/task"; - log.info("下发acs任务的参数为:{}", arr.toString()); + JSONObject result = AcsUtil.notifyAcs(api, arr); log.info("下发acs任务的返回结果为:{}", result.toString()); @@ -103,8 +103,8 @@ public class AutoCreateTask { JSONObject taskObj = new JSONObject(); taskObj.put("task_id", item.getExt_task_uuid()); //下发失败,改状态为了重新下发 - taskObj.put("task_status", TaskStatusEnum.START_AND_POINT.getCode()); -// taskObj.put("task_status", TaskStatusEnum.ISSUE.getCode()); +// taskObj.put("task_status", TaskStatusEnum.START_AND_POINT.getCode()); + taskObj.put("task_status", TaskStatusEnum.ISSUE.getCode()); taskObj.put("remark", "下发失败:" + message); taskObj.put("update_time", DateUtil.now()); taskTab.update(taskObj);