From 6062e826f1b1acde1bfe2887353c1214f2af12d6 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期四, 30 四月 2026 17:07:58 +0800
Subject: [PATCH] #上报 打印
---
rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java | 15 +++++++++++++++
1 files changed, 15 insertions(+), 0 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java
index 8fd8bab..3fbab03 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/CloudWmsReportServiceImpl.java
@@ -8,6 +8,7 @@
import com.vincent.rsf.server.api.feign.CloudWmsErpFeignClient;
import com.vincent.rsf.server.api.integration.dap.DapIlcwmsResponseNormalizer;
import com.vincent.rsf.server.api.service.CloudWmsReportService;
+import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -31,6 +32,8 @@
@Autowired
private CloudWmsErpFeignClient cloudWmsErpFeignClient;
+ @Autowired
+ private ObjectMapper objectMapper;
@Override
public Map<String, Object> syncMatnrsToCloud(Object body) {
@@ -57,6 +60,7 @@
boolean inbound = param.getInbound() == null || Boolean.TRUE.equals(param.getInbound());
DapIlcwmsCompletionRequest req = new DapIlcwmsCompletionRequest()
.setData(Collections.singletonList(buildInOutLine(param, inbound)));
+ logOutboundPayload("IN_OUT_RESULT", inbound ? "stockInCompleted" : "stockOutCompleted", req);
Map<String, Object> raw = inbound
? cloudWmsErpFeignClient.cusInventoryCompletionReport(req)
: cloudWmsErpFeignClient.cusOutboundCompletionReport(req);
@@ -94,6 +98,7 @@
} else {
return resultMap(400, "涓嶆敮鎸佺殑 changeType锛�" + changeType, null);
}
+ logOutboundPayload("INVENTORY_ADJUST", changeType == 3 ? "stockTransferCompleted" : "reportInventoryAdjust", req);
Map<String, Object> raw = changeType == 3
? cloudWmsErpFeignClient.stockTransferCompleted(req)
: cloudWmsErpFeignClient.reportInventoryAdjust(req);
@@ -275,4 +280,14 @@
map.put("data", data);
return map;
}
+
+ private void logOutboundPayload(String reportType, String endpoint, DapIlcwmsCompletionRequest req) {
+ try {
+ log.info("浜戜粨鐪熷疄璇锋眰鎶ユ枃锛宺eportType={}锛宔ndpoint={}锛宲ayload={}",
+ reportType, endpoint, objectMapper.writeValueAsString(req));
+ } catch (Exception e) {
+ log.warn("浜戜粨鐪熷疄璇锋眰鎶ユ枃搴忓垪鍖栧け璐ワ紝reportType={}锛宔ndpoint={}锛歿}",
+ reportType, endpoint, e.getMessage());
+ }
+ }
}
--
Gitblit v1.9.1