From f0ed98d11b3aed4846dc73e6a8eae2ba2678e6ac Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Fri, 27 Sep 2024 14:20:34 +0800 Subject: [PATCH] =?UTF-8?q?add:=E5=A2=9E=E5=8A=A0=E5=B7=A5=E5=8E=82?= =?UTF-8?q?=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../interceptor/LocalServerLoginAccountsInterceptor.java | 2 +- .../java/com/logpm/factory/receiver/DealWithDataHandler.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/interceptor/LocalServerLoginAccountsInterceptor.java b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/interceptor/LocalServerLoginAccountsInterceptor.java index 1fb696878..89915f9cf 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/interceptor/LocalServerLoginAccountsInterceptor.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-jinpai/src/main/java/com/logpm/factorydata/jinpai/interceptor/LocalServerLoginAccountsInterceptor.java @@ -64,7 +64,7 @@ public class LocalServerLoginAccountsInterceptor extends HandlerInterceptorAdapt // 修改或添加header // 发送登录请求 - log.info("##########preHandle: request={}", request); + log.info("##########preHandle: request={}", data); wrappedRequest.addHeader("Blade-Auth", "bearer "+data.getString("access_token")); HttpHeaders httpHeaders = new HttpHeaders(); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java index ea46e7d34..c9213cff5 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/DealWithDataHandler.java @@ -44,6 +44,7 @@ public class DealWithDataHandler { // 如果手动ACK,消息会被监听消费,但是消息在队列中依旧存在,如果 未配置 acknowledge-mode 默认是会在消费完毕后自动ACK掉 OrderStatusDTO orderStatusDTO = (OrderStatusDTO) map.get("messageData"); + log.info("############dealWithDataHandler: 处理在库订单数据到新系统 {}",orderStatusDTO); String status = orderStatusDTO.getStatus(); String unitNo = orderStatusDTO.getUnitNo(); String operationTime = orderStatusDTO.getOperationTime(); @@ -55,7 +56,7 @@ public class DealWithDataHandler { sourceName = "汇通"; } log.info("##################dealWithDataHandler: 处理在库订单数据到新系统 来源：{} 品牌：{}",sourceName,orderStatusDTO.getBrandName()); - if("汇通".equals(orderStatusDTO.getSourceName())){ + if("汇通".equals(sourceName)){ factoryCommonService.extracted(status, unitNo, currentWarehouseId, operationTime, trayId); }else{ log.warn(">>>> 不是汇通的数据 不进入汇通入库数据");