From 67e7b8c3584aa5363ada4bfa7630e5156173663a Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 22 二月 2022 11:26:35 +0800
Subject: [PATCH] 改造框架层 api 层加入 store-id 并且将 storeId 和userId 转 json 报文中
---
service-api/src/main/java/com/java110/api/listener/system/CmdListener.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/listener/system/CmdListener.java b/service-api/src/main/java/com/java110/api/listener/system/CmdListener.java
index d55ba2c..93bbfd6 100644
--- a/service-api/src/main/java/com/java110/api/listener/system/CmdListener.java
+++ b/service-api/src/main/java/com/java110/api/listener/system/CmdListener.java
@@ -6,14 +6,15 @@
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.core.log.LoggerFactory;
import com.java110.dto.order.OrderDto;
import com.java110.entity.center.AppService;
import com.java110.intf.job.IDataBusInnerServiceSMO;
+import com.java110.utils.constant.CommonConstant;
import com.java110.utils.constant.ServiceCodeConstant;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
-import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.*;
import org.springframework.web.client.HttpStatusCodeException;
@@ -49,6 +50,12 @@
for (String key : context.getRequestCurrentHeaders().keySet()) {
header.add(key, reqHeader.get(key));
}
+ if (reqHeader.containsKey(CommonConstant.USER_ID)) {
+ reqJson.put("userId", reqHeader.get(CommonConstant.USER_ID));
+ }
+ if (reqHeader.containsKey(CommonConstant.STORE_ID)) {
+ reqJson.put("storeId", reqHeader.get(CommonConstant.STORE_ID));
+ }
HttpEntity<String> httpEntity = new HttpEntity<String>(reqJson.toJSONString(), header);
String orgRequestUrl = context.getRequestHeaders().get("REQUEST_URL");
--
Gitblit v1.8.0