wcs日志

warewms-ams/src/main/java/com/ruoyi/ams/xuankuang/service/WmsToWcsApiService.java

@@ -1,9 +1,11 @@
 package com.ruoyi.ams.xuankuang.service;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.ruoyi.ams.xuankuang.domain.form.*;
 import com.ruoyi.ams.xuankuang.domain.vo.WcsResponseVo;
 import com.ruoyi.base.constant.Constant;
+import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.http.HttpRequest;
 import com.ruoyi.common.utils.http.HttpUtils;
 import lombok.extern.slf4j.Slf4j;
@@ -34,11 +36,13 @@ public class WmsToWcsApiService {
     )
     public WcsResponseVo wmsOutTask(OutTaskForm outTaskForm) {
         String json = JSON.toJSONString(outTaskForm);
+        log.info("WmsToWcsApiService - wmsOutTask request is :{}, time is :{}", json, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpRequest.postData(Constant.WCS_TASK_URL1, json);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - wmsOutTask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("wms出库任务下发接口失败：", e);
         }
@@ -58,11 +62,13 @@ public class WmsToWcsApiService {
     )
     public WcsResponseVo wmsBillTask(BillTaskForm billTaskForm) {
         String json = JSON.toJSONString(billTaskForm);
+        log.info("WmsToWcsApiService - wmsBillTask request is :{}, time is :{}", json, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpRequest.postData(Constant.WCS_TASK_URL, json);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - wmsBillTask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("wms工单任务下发接口失败: ", e);
         }
@@ -82,11 +88,13 @@ public class WmsToWcsApiService {
     )
     public WcsResponseVo wmsCallbackBbmTask(CallbackBbmForm callbackBbmForm) {
         String json = JSON.toJSONString(callbackBbmForm);
+        log.info("WmsToWcsApiService - wmsCallbackBbmTask request is :{}, time is :{}", json, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpRequest.postData(Constant.WCS_TASK_URL2, json);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - wmsCallbackBbmTask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("wms开启破袋机回调接口失败: ", e);
         }
@@ -131,11 +139,13 @@ public class WmsToWcsApiService {
             backoff = @Backoff(delay = 5000, multiplier = 2)
     )
     public WcsResponseVo wmsAgvCallbackIntask(String taskNo) {
+        log.info("WmsToWcsApiService - wmsAgvCallbackIntask request is :{}, time is :{}", taskNo, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpUtils.sendGet(Constant.WCS_TASK_URL5, taskNo);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - wmsAgvCallbackIntask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("agv回调wcs卸货完成失败: ", e);
         }
@@ -154,11 +164,13 @@ public class WmsToWcsApiService {
             backoff = @Backoff(delay = 5000, multiplier = 2)
     )
     public WcsResponseVo wmsAgvCallbackOuttask(String wcsId) {
+        log.info("WmsToWcsApiService - wmsAgvCallbackOuttask request is :{}, time is :{}", wcsId, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpUtils.sendGet(Constant.WCS_TASK_URL6, wcsId);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - wmsAgvCallbackOuttask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("agv回调wcs货物取走接口失败: ", e);
         }
@@ -177,11 +189,13 @@ public class WmsToWcsApiService {
     )
     public WcsResponseVo cancelTheTask(TicketTaskCancellation ticketTaskCancellation){
         String json = JSON.toJSONString(ticketTaskCancellation);
+        log.info("WmsToWcsApiService - cancelTheTask request is :{}, time is :{}", json, DateUtils.getTime());
         String r = "";
         WcsResponseVo wcsResponseVo = new WcsResponseVo();
         try {
             r = HttpRequest.postData(Constant.WCS_TASK_URL3, json);
             wcsResponseVo = JSON.parseObject(r, WcsResponseVo.class);
+            log.info("WmsToWcsApiService - cancelTheTask response is :{}, time is :{}", JSONObject.toJSONString(wcsResponseVo), DateUtils.getTime());
         } catch (Exception e) {
             log.error("任务取消失败", e);
         }