root/rongLiJiaNai
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码修改

Browse Source
This commit is contained in:
ludj
2023-05-04 14:28:14 +08:00
parent 993b2c6944
commit 345d7f620b
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/AcsUtil.java
View File

@@ -5,6 +5,7 @@ import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.nl.modules.system.service.impl.ParamServiceImpl; import org.nl.modules.system.service.impl.ParamServiceImpl;
import org.nl.utils.SpringContextHolder; import org.nl.utils.SpringContextHolder;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
@@ -12,6 +13,7 @@ import org.springframework.http.HttpStatus;
/** /**
* ACS连接工具类: * ACS连接工具类:
*/ */
@Slf4j
public class AcsUtil { public class AcsUtil {
public static JSONObject notifyAcs(String api, JSONArray list) { public static JSONObject notifyAcs(String api, JSONArray list) {
//判断是否连接ACS系统 //判断是否连接ACS系统
@@ -27,6 +29,7 @@ public class AcsUtil {
String acsUrl = SpringContextHolder.getBean(ParamServiceImpl.class).findByCode("ACS_URL").getValue(); String acsUrl = SpringContextHolder.getBean(ParamServiceImpl.class).findByCode("ACS_URL").getValue();
String url = acsUrl + api; String url = acsUrl + api;
log.info("下发acs任务的参数为:{}", list.toString());
try { try {
String resultMsg = HttpRequest.post(url) String resultMsg = HttpRequest.post(url)
.body(String.valueOf(list)) .body(String.valueOf(list))

6
wms/hd/nladmin-system/src/main/java/org/nl/wms/sch/task/AutoCreateTask.java
View File

@@ -77,7 +77,7 @@ public class AutoCreateTask {
}); });
String api = "api/wms/task"; String api = "api/wms/task";
log.info("下发acs任务的参数为:{}", arr.toString());
JSONObject result = AcsUtil.notifyAcs(api, arr); JSONObject result = AcsUtil.notifyAcs(api, arr);
log.info("下发acs任务的返回结果为:{}", result.toString()); log.info("下发acs任务的返回结果为:{}", result.toString());
@@ -103,8 +103,8 @@ public class AutoCreateTask {
JSONObject taskObj = new JSONObject(); JSONObject taskObj = new JSONObject();
taskObj.put("task_id", item.getExt_task_uuid()); taskObj.put("task_id", item.getExt_task_uuid());
//下发失败,改状态为了重新下发 //下发失败,改状态为了重新下发
taskObj.put("task_status", TaskStatusEnum.START_AND_POINT.getCode()); // taskObj.put("task_status", TaskStatusEnum.START_AND_POINT.getCode());
// taskObj.put("task_status", TaskStatusEnum.ISSUE.getCode()); taskObj.put("task_status", TaskStatusEnum.ISSUE.getCode());
taskObj.put("remark", "下发失败:" + message); taskObj.put("remark", "下发失败:" + message);
taskObj.put("update_time", DateUtil.now()); taskObj.put("update_time", DateUtil.now());
taskTab.update(taskObj); taskTab.update(taskObj);