From daa697719eb0ddfd170f1ab94c5422a4f5b93951 Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <279049017@qq.com>
Date: Fri, 18 Sep 2020 14:36:54 +0800
Subject: [PATCH] Merge branch 'dev'
---
kidgrow-commons/kidgrow-ribbon-spring-boot-starter/src/main/java/com/kidgrow/ribbon/config/FeignHttpTenantInterceptorConfig.java | 108 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 108 insertions(+), 0 deletions(-)
diff --git a/kidgrow-commons/kidgrow-ribbon-spring-boot-starter/src/main/java/com/kidgrow/ribbon/config/FeignHttpTenantInterceptorConfig.java b/kidgrow-commons/kidgrow-ribbon-spring-boot-starter/src/main/java/com/kidgrow/ribbon/config/FeignHttpTenantInterceptorConfig.java
new file mode 100644
index 0000000..7f57d7e
--- /dev/null
+++ b/kidgrow-commons/kidgrow-ribbon-spring-boot-starter/src/main/java/com/kidgrow/ribbon/config/FeignHttpTenantInterceptorConfig.java
@@ -0,0 +1,108 @@
+package com.kidgrow.ribbon.config;
+
+import com.kidgrow.common.constant.CommonConstant;
+import com.kidgrow.common.constant.SecurityConstants;
+import feign.RequestInterceptor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.annotation.PostConstruct;
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+
+
+/**
+ * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
+ *
+ * @Description: feign拦截器，只包含http相关数据
+ * @Project: <br>
+ * @CreateDate: Created in 2020/2/21 13:31 <br>
+ * @Author: <a href="4345453@kidgrow.com">liuke</a>
+ */
+@Slf4j
+public class FeignHttpTenantInterceptorConfig {
+ protected List<String> requestHeaders = new ArrayList<>();
+
+ @PostConstruct
+ public void initialize() {
+ requestHeaders.add(SecurityConstants.USER_ID_HEADER);
+ requestHeaders.add(SecurityConstants.DOCTOR_ID_HEADER);
+ requestHeaders.add(SecurityConstants.USER_HEADER);
+ requestHeaders.add(SecurityConstants.USER_DEP_ID_HEADER);
+ requestHeaders.add(SecurityConstants.USER_DEP_NAME_HEADER);
+ requestHeaders.add(SecurityConstants.USER_ORG_ID_HEADER);
+ requestHeaders.add(SecurityConstants.USER_ORGS_HEADER);
+ requestHeaders.add(SecurityConstants.USER_ORG_NAME_HEADER);
+ requestHeaders.add(SecurityConstants.ROLE_HEADER);
+ requestHeaders.add(SecurityConstants.CLIENT_HEADER);
+ //requestHeaders.add(SecurityConstants.TENANT_HEADER);
+ requestHeaders.add(CommonConstant.KIDGROW_VERSION);
+ requestHeaders.add(CommonConstant.USER_AGENT_BROWSER);
+ requestHeaders.add(CommonConstant.USER_AGENT_IP);
+ requestHeaders.add(CommonConstant.USER_AGENT_SYSTEM_SCREEN);
+ requestHeaders.add(CommonConstant.USER_AGENT_SYSTEM);
+ requestHeaders.add(SecurityConstants.USER_HOSPITAL_ID_HEADER);
+ requestHeaders.add(SecurityConstants.USER_REAL_NAME);
+ }
+
+ /**
+ * 使用feign client访问别的微服务时，将上游传过来的access_token、clientid、tenantid、username、roles等信息放入header传递给下一个服务
+ */
+ @Bean
+ public RequestInterceptor httpFeignInterceptor() {
+ return template -> {
+ ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
+ .getRequestAttributes();
+ if (attributes != null) {
+ HttpServletRequest request = attributes.getRequest();
+ Enumeration<String> headerNames = request.getHeaderNames();
+ if (headerNames != null) {
+ String headerName;
+ String headerValue;
+ while(headerNames.hasMoreElements()) {
+ headerName = headerNames.nextElement();
+ if (requestHeaders.contains(headerName)) {
+ headerValue = request.getHeader(headerName);
+ template.header(headerName, headerValue);
+ }
+ }
+ }
+
+ //传递access_token，无网络隔离时需要传递
+ /*
+ String token = extractHeaderToken(request);
+ if (StrUtil.isEmpty(token)) {
+ token = request.getParameter(CommonConstant.ACCESS_TOKEN);
+ }
+ if (StrUtil.isNotEmpty(token)) {
+ template.header(CommonConstant.TOKEN_HEADER, CommonConstant.BEARER_TYPE + " " + token);
+ }
+ */
+ }
+ };
+ }
+
+ /**
+ * 解析head中的token
+ * @param request
+ */
+ private String extractHeaderToken(HttpServletRequest request) {
+ Enumeration<String> headers = request.getHeaders(CommonConstant.TOKEN_HEADER);
+ while (headers.hasMoreElements()) {
+ String value = headers.nextElement();
+ if ((value.toLowerCase().startsWith(CommonConstant.BEARER_TYPE))) {
+ String authHeaderValue = value.substring(CommonConstant.BEARER_TYPE.length()).trim();
+ int commaIndex = authHeaderValue.indexOf(',');
+ if (commaIndex > 0) {
+ authHeaderValue = authHeaderValue.substring(0, commaIndex);
+ }
+ return authHeaderValue;
+ }
+ }
+ return null;
+ }
+}
--
Gitblit v1.8.0