Merge branch 'dev' into test

liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/core/JwtValidator.java

@@ -18,6 +18,7 @@ import java.util.Map;
 @ConfigurationProperties(prefix = "jwt")
 public class JwtValidator {
     private String ssoRedisKey = "adam:identity:sso:";
+    private String msoRedisKey = "adam:identity:mso:";
     private String secret;
     // 分钟
     private Long expireTtl;

liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/util/CurrentUtil.java

@@ -10,14 +10,19 @@ public class CurrentUtil {
     public static final String GRAY_LOGIN_SMS_CODE = "111111";
 
     /* ======================================================= | */
-
-    public static final String uID = "sub";
-    public static final String uTag = "u-tag";
     public static final String uToken = "authorization";
+    public static final String uTag = "u-tag";
+
+    public static final String TOKEN_SUB = "sub";
+    public static final String TOKEN_MOBILE = "mobile";
+    public static final String TOKEN_NICKNAME = "nickname";
+    public static final String TOKEN_TYPE = "type";
+    public static final String TOKEN_TYPE_VAL_USER = "user";
+    public static final String TOKEN_TYPE_VAL_STATION = "station";
 
-    public static final String CLI_SOURCE = "source";
-    public static final String CLI_VERSION = "version";
-    public static final String CLI_UNKNOWN = "unknown";
+    public static final String HEADER_CLI_SOURCE = "source";
+    public static final String HEADER_CLI_VERSION = "version";
+    public static final String HEADER_CLI_UNKNOWN = "unknown";
 
     private static final String IP_UTILS_FLAG = ",";
     private static final String LOCALHOST_IP = "0:0:0:0:0:0:0:1";
@@ -32,33 +37,33 @@ public class CurrentUtil {
     }
 
     public static String getCurrentUid() {
-        return (String) ServletUtils.getRequest().getAttribute(uID);
+        return (String) ServletUtils.getRequest().getAttribute(TOKEN_SUB);
     }
 
-    public static String getCliSource() {
-        return ServletUtils.getRequest().getHeader(CLI_SOURCE);
+    public static String getHeaderCliSource() {
+        return ServletUtils.getRequest().getHeader(HEADER_CLI_SOURCE);
     }
 
-    public static String getCliVersion() {
-        return ServletUtils.getRequest().getHeader(CLI_VERSION);
+    public static String getHeaderCliVersion() {
+        return ServletUtils.getRequest().getHeader(HEADER_CLI_VERSION);
     }
 
     public static String getCliIpAddr() {
         HttpServletRequest request = ServletUtils.getRequest();
         String ip = request.getHeader("x-forwarded-for");
-        if (ip == null || ip.length() == 0 || CLI_UNKNOWN.equalsIgnoreCase(ip)) {
+        if (ip == null || ip.length() == 0 || HEADER_CLI_UNKNOWN.equalsIgnoreCase(ip)) {
             ip = request.getHeader("Proxy-Client-IP");
         }
-        if (ip == null || ip.length() == 0 || CLI_UNKNOWN.equalsIgnoreCase(ip)) {
+        if (ip == null || ip.length() == 0 || HEADER_CLI_UNKNOWN.equalsIgnoreCase(ip)) {
             ip = request.getHeader("X-Forwarded-For");
         }
-        if (ip == null || ip.length() == 0 || CLI_UNKNOWN.equalsIgnoreCase(ip)) {
+        if (ip == null || ip.length() == 0 || HEADER_CLI_UNKNOWN.equalsIgnoreCase(ip)) {
             ip = request.getHeader("WL-Proxy-Client-IP");
         }
-        if (ip == null || ip.length() == 0 || CLI_UNKNOWN.equalsIgnoreCase(ip)) {
+        if (ip == null || ip.length() == 0 || HEADER_CLI_UNKNOWN.equalsIgnoreCase(ip)) {
             ip = request.getHeader("X-Real-IP");
         }
-        if (ip == null || ip.length() == 0 || CLI_UNKNOWN.equalsIgnoreCase(ip)) {
+        if (ip == null || ip.length() == 0 || HEADER_CLI_UNKNOWN.equalsIgnoreCase(ip)) {
             ip = request.getRemoteAddr();
 //            if (LOCALHOST_IP1.equalsIgnoreCase(ip) || LOCALHOST_IP.equalsIgnoreCase(ip)) {
 //                // 根据网卡取本机配置的IP

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/SqlMapping.java

 package com.liquidnet.service.base;
 
+import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 
 import java.io.IOException;
@@ -88,9 +89,9 @@ public class SqlMapping {
     /* ---------------------- ---------------------- ---------------------- */
 
     public static String get(String sqlKey, Object... params) {
-        LinkedList<String> sqls = new LinkedList<>();
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
         sqls.add((String) sqlsProperties.get(sqlKey));
-        LinkedList<Object[]> paramsList = new LinkedList<>();
+        LinkedList<Object[]> paramsList = CollectionUtil.linkedListObjectArr();
         paramsList.add(params);
         LinkedList<Object[]>[] args = new LinkedList[]{paramsList};
 
@@ -101,7 +102,7 @@ public class SqlMapping {
     }
 
     public static String get(String sqlKey, LinkedList<Object[]> paramsList) {
-        LinkedList<String> sqls = new LinkedList<>();
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
         sqls.add((String) sqlsProperties.get(sqlKey));
         LinkedList<Object[]>[] args = new LinkedList[]{paramsList};
 

liquidnet-bus-common/liquidnet-common-web/src/main/java/com/liquidnet/common/web/filter/GlobalAuthorityInterceptor.java

@@ -11,7 +11,6 @@ import io.jsonwebtoken.ExpiredJwtException;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
-import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.core.env.Environment;
@@ -39,10 +38,7 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
     private static final String TOKEN_KICK = "40002";
     private static final String TOKEN_INVALID = "40003";
 
-    private static final String ENV_PROD = "prod";
-    private static final String ENV_ACTIVE = "spring.profiles.active";
-
-    private static final String KYLIN_STATION_JWT_VALID = "/*/station/**";
+//    private static final String KYLIN_STATION_JWT_VALID = "/*/station/**";
 
     private final static AntPathMatcher antPathMatcher = new AntPathMatcher();
 
@@ -58,16 +54,17 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
         String authorization = request.getHeader(CurrentUtil.uToken), uri = request.getRequestURI(),
                 responseCode = null, token = null, currentUid = null;
 
+        Claims claims = null;
         if (StringUtils.isNotBlank(authorization) && StringUtils.length(authorization) > 7) {
             token = authorization.substring(7);
             try {
                 // 解析没有异常则表示token验证通过，如有必要可根据自身需求增加验证逻辑
-                Claims claims = jwtValidator.parse(token);
+                claims = jwtValidator.parse(token);
 
-                currentUid = (String) claims.get(CurrentUtil.uID);
+                currentUid = (String) claims.get(CurrentUtil.TOKEN_SUB);
 
                 request.setAttribute(CurrentUtil.uToken, token);
-                request.setAttribute(CurrentUtil.uID, currentUid);
+                request.setAttribute(CurrentUtil.TOKEN_SUB, currentUid);
                 request.setAttribute(CurrentUtil.uTag, JsonUtils.toJson(claims));
 
             } catch (ExpiredJwtException expiredJwtEx) {
@@ -95,7 +92,7 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
             this.responseHandler(response, TOKEN_ILLEGAL);
             return false;
         }
-        if (this.authorityHandler(response, uri, token, currentUid)) {
+        if (this.authorityHandler(response, uri, token, currentUid, claims)) {
             return true;
         }
         return false;
@@ -109,18 +106,60 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
         response.getWriter().write(JsonUtils.toJson(responseDto));
     }
 
-    private boolean authorityHandler(HttpServletResponse response, String uri, String token, String currentUid) throws IOException {
-        if (antPathMatcher.match(KYLIN_STATION_JWT_VALID, uri)) {// 专业版APP
-            // adam:identity:sso:${uid}:MD5(${token})=${1-在线|0-离线}
-//            String ssoUidM5TokenKey = jwtValidator.getSsoRedisKey()
-//                    .concat(uid).concat(":").concat(DigestUtils.md5DigestAsHex(uToken.getBytes(StandardCharsets.UTF_8)));
+    private boolean authorityHandler(HttpServletResponse response, String uri, String token, String currentUid, Claims claims) throws IOException {
+//        if (antPathMatcher.match(KYLIN_STATION_JWT_VALID, uri)) {// 专业版APP
+//            // adam:identity:sso:${uid}:MD5(${token})=${1-在线|0-离线}
+//            String ssoUidM5TokenKey = jwtValidator.getMsoRedisKey()
+//                    .concat(currentUid).concat(":").concat(DigestUtils.md5DigestAsHex(token.getBytes(StandardCharsets.UTF_8)));
 //            Integer online = (Integer) redisUtil.get(ssoUidM5TokenKey);
 //            if (null == online || online != 1) {
-//                this.respHandler(ctx, TOKEN_INVALID);
+//                // 已离线
+//                this.responseHandler(response, TOKEN_INVALID);
+//
+//                return false;
 //            } else {
-            return true;
+//                return true;
+//            }
+//        } else {
+//            // adam:identity:sso:${uid}=MD5(${token})
+//            String ssoKey = jwtValidator.getSsoRedisKey().concat(currentUid), md5Token;
+//
+//            if (StringUtils.isEmpty(md5Token = (String) redisUtil.get(ssoKey))) {
+//                // 已离线
+//                this.responseHandler(response, TOKEN_INVALID);
+//
+//                return false;
+//            } else {
+//                // 与在线TOKEN比对
+//                if (md5Token.equals(DigestUtils.md5DigestAsHex(token.getBytes(StandardCharsets.UTF_8)))) {
+//                    // 一致则放行
+//                    return true;
+//                } else {
+//                    // 不一致则被踢下线
+//                    this.responseHandler(response, TOKEN_KICK);
+//
+//                    return false;
+//                }
 //            }
+//        }
+
+
+        String tokenType = (String) claims.get(CurrentUtil.TOKEN_TYPE);
+        switch (tokenType) {
+            case CurrentUtil.TOKEN_TYPE_VAL_STATION:// 专业版APP
+                // adam:identity:sso:${uid}:MD5(${token})=${1-在线|0-离线}
+                String ssoUidM5TokenKey = jwtValidator.getMsoRedisKey()
+                        .concat(currentUid).concat(":").concat(DigestUtils.md5DigestAsHex(token.getBytes(StandardCharsets.UTF_8)));
+                Integer online = (Integer) redisUtil.get(ssoUidM5TokenKey);
+                if (null == online || online != 1) {
+                    // 已离线
+                    this.responseHandler(response, TOKEN_INVALID);
+
+                    return false;
                 } else {
+                    return true;
+                }
+            case CurrentUtil.TOKEN_TYPE_VAL_USER:
                 // adam:identity:sso:${uid}=MD5(${token})
                 String ssoKey = jwtValidator.getSsoRedisKey().concat(currentUid), md5Token;
 
@@ -141,6 +180,10 @@ public class GlobalAuthorityInterceptor extends HandlerInterceptorAdapter {
                         return false;
                     }
                 }
+            default:
+                log.warn("Authority failed:{} (Unknown token type).uri:[{}],token:{}", TOKEN_ILLEGAL, uri, token);
+                this.responseHandler(response, TOKEN_ILLEGAL);
+                return false;
         }
     }
 }

liquidnet-bus-common/liquidnet-common-web/src/main/java/com/liquidnet/common/web/filter/GlobalLogTrackInterceptor.java

 package com.liquidnet.common.web.filter;
 
-import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.slf4j.MDC;
 import org.springframework.stereotype.Component;
@@ -10,7 +9,6 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
 @Slf4j
-@Data
 @Component
 public class GlobalLogTrackInterceptor extends HandlerInterceptorAdapter {
     private static final String LNS_TRANCE_ID = "lnsTranceId";

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamLoginController.java

@@ -442,10 +442,10 @@ public class AdamLoginController {
 
     private String ssoProcess(AdamUserInfoVo userInfoVo) {
         Map<String, Object> claimsMap = CollectionUtil.mapStringObject();
-        claimsMap.put("sub", userInfoVo.getUid());
-        claimsMap.put("mobile", userInfoVo.getMobile());
-        claimsMap.put("nickname", userInfoVo.getNickname());
-        claimsMap.put("type", "user");
+        claimsMap.put(CurrentUtil.TOKEN_SUB, userInfoVo.getUid());
+        claimsMap.put(CurrentUtil.TOKEN_MOBILE, userInfoVo.getMobile());
+        claimsMap.put(CurrentUtil.TOKEN_NICKNAME, userInfoVo.getNickname());
+        claimsMap.put(CurrentUtil.TOKEN_TYPE, CurrentUtil.TOKEN_TYPE_VAL_USER);
 
         String token = jwtValidator.create(claimsMap);
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamMemberOrderServiceImpl.java

@@ -132,8 +132,9 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
         memberOrderVo.setUid(CurrentUtil.getCurrentUid());
         memberOrderVo.setPrice(param.getPrice());
         memberOrderVo.setClientIp(clientIp);
-        memberOrderVo.setVersion(CurrentUtil.getCliVersion());
-        memberOrderVo.setSource(CurrentUtil.getCliSource());
+        String headerCliVersion = CurrentUtil.getHeaderCliVersion(), headerCliSource = CurrentUtil.getHeaderCliSource();
+        memberOrderVo.setSource(null == headerCliSource ? "" : headerCliSource);
+        memberOrderVo.setVersion(null == headerCliVersion ? "" : headerCliVersion);
 
         if (!adamRdmService.setShotMemberOrderVoByOrderNo(orderNo, memberOrderVo)) {
             log.warn("###购买会员创建订单失败[memberOrderVo:{}]", JsonUtils.toJson(memberOrderVo));
@@ -255,7 +256,7 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
         if (1 == handleMemberOrderVo.getMode()) {// 购买会员码回调
             String memberNo = adamUserMemberService.getNextMemberNo(handleMemberOrderVo.getMemberId());
 
-            AdamMemberCodeVo initMemberCodeVo = new AdamMemberCodeVo();
+            AdamMemberCodeVo initMemberCodeVo = AdamMemberCodeVo.getNew();
             initMemberCodeVo.setCode(MemberUtil.buyCode());
             initMemberCodeVo.setMemberId(handleMemberOrderVo.getMemberId());
             initMemberCodeVo.setMemberPriceId(handleMemberOrderVo.getMemberPriceId());
@@ -347,8 +348,9 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
         initMemberOrderVo.setPaymentAt(now);
         initMemberOrderVo.setCreatedAt(now);
         initMemberOrderVo.setClientIp(CurrentUtil.getCliIpAddr());
-        initMemberOrderVo.setSource(CurrentUtil.getCliSource());
-        initMemberOrderVo.setVersion(CurrentUtil.getCliVersion());
+        String headerCliVersion = CurrentUtil.getHeaderCliVersion(), headerCliSource = CurrentUtil.getHeaderCliSource();
+        initMemberOrderVo.setSource(null == headerCliSource ? "" : headerCliSource);
+        initMemberOrderVo.setVersion(null == headerCliVersion ? "" : headerCliVersion);
 
         LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
         LinkedList<Object[]> updateMemberCodeObjs = CollectionUtil.linkedListObjectArr(),

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/service/impl/DragonOrderRefundsServiceImpl.java

@@ -380,7 +380,7 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
                     }
                     dto.setOrderRefundCode(info.getOutRefundNo());
                     dto.setRefundCode(info.getOutTradeNo());
-                    dto.setRefundPrice(info.getRefundFee());
+                    dto.setRefundPrice(new BigDecimal(info.getRefundFee()).divide(BigDecimal.valueOf(100)).toString());
                     dto.setRefundAt(refundAt);
                     dto.setRefundError(callBackDto.getReturnMsg());
                     log.debug("SEND WEPAY NOTIFTURL = " + JSON.toJSONString(dto));

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketEntitiesServiceImpl.java

 package com.liquidnet.service.kylin.service.impl;
 
+import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.SqlMapping;
@@ -7,6 +8,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.kylin.dto.param.KylinStationUploadParam;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.service.IKylinOrderTicketEntitiesService;
+import com.liquidnet.service.kylin.utils.ObjectUtil;
 import com.liquidnet.service.kylin.utils.QueueUtils;
 import com.mongodb.bulk.BulkWriteResult;
 import com.mongodb.client.model.UpdateOneModel;
@@ -55,8 +57,8 @@ public class KylinOrderTicketEntitiesServiceImpl  implements IKylinOrderTicketEn
 
         LocalDateTime nowDt = LocalDateTime.now();
         String nowDtStr = DateUtil.format(nowDt, DateUtil.Formatter.yyyyMMddHHmmss);
-        LinkedList<Object[]> paramsList = new LinkedList<>();
-        List<WriteModel<Document>> list = new ArrayList<>();
+        LinkedList<Object[]> paramsList = CollectionUtil.linkedListObjectArr();
+        List<WriteModel<Document>> list = ObjectUtil.getWriteModelDocumentArrayList();
         parameter.getCheckOrderParamList().forEach(r -> {
             KylinOrderTicketEntitiesVo updateVo = KylinOrderTicketEntitiesVo.getNew();
             updateVo.setStatus(1);// 出票状态: 0未出票 1已出票

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/ObjectUtil.java

+package com.liquidnet.service.kylin.utils;
+
+import com.liquidnet.service.base.PagedResult;
+import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinStationPerformanceVo;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinStationTicketVo;
+import com.mongodb.client.model.WriteModel;
+import org.bson.Document;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class ObjectUtil {
+    private static final ArrayList<KylinStationPerformanceVo> kylinStationPerformanceVoArrayList = new ArrayList<>();
+    private static final ArrayList<KylinTicketVo> kylinTicketVoArrayList = new ArrayList<>();
+    private static final ArrayList<KylinStationTicketVo> kylinStationTicketVoArrayList = new ArrayList<>();
+    private static final ArrayList<WriteModel<Document>> writeModelDocumentArrayList = new ArrayList<>();
+
+    private static final PagedResult<KylinStationPerformanceVo> kylinStationPerformanceVoPagedResult = new PagedResult<>();
+
+    public static List<KylinStationPerformanceVo> getKylinStationPerformanceVoArrayList() {
+        return (List<KylinStationPerformanceVo>) kylinStationPerformanceVoArrayList.clone();
+    }
+
+    public static List<KylinTicketVo> getKylinTicketVoArrayList() {
+        return (List<KylinTicketVo>) kylinTicketVoArrayList.clone();
+    }
+
+    public static List<KylinStationTicketVo> getKylinStationTicketVoArrayList() {
+        return (List<KylinStationTicketVo>) kylinStationTicketVoArrayList.clone();
+    }
+
+    public static List<WriteModel<Document>> getWriteModelDocumentArrayList() {
+        return (List<WriteModel<Document>>) writeModelDocumentArrayList.clone();
+    }
+
+    public static PagedResult<KylinStationPerformanceVo> getKylinStationPerformanceVoPagedResult() {
+        return kylinStationPerformanceVoPagedResult.clone();
+    }
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/errors.properties

@@ -5,7 +5,7 @@
 
 #APP ERROR
 20001=验证码发送失败
-20002=验证码无效
+20002=验证码错误，请重新输入
 20003=无权查看
 20004=参数错误
 20005=手机号获取失败，请更换登录方式

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java

@@ -328,8 +328,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
 
     private ResponseDto<PayInnerResultVo> order(PayOrderParam payOrderParam, String uid, boolean isMember, int isTrueName, KylinPerformanceVo performanceData, KylinTicketVo ticketData, List<AdamEntersVo> entersVoList, Integer isStudent, KylinTicketTimesVo ticketTimesData, Long currentTime) {
         LinkedList<String> sqls = ObjectUtil.cloneLinkedListStr();
-        String source = CurrentUtil.getCliSource() == null ? "" : CurrentUtil.getCliSource();
-        String version = CurrentUtil.getCliVersion() == null ? "" : CurrentUtil.getCliVersion();
+        String headerCliSource = CurrentUtil.getHeaderCliSource(), headerCliVersion = CurrentUtil.getHeaderCliVersion();
+        String source = headerCliSource == null ? "" : headerCliSource;
+        String version = headerCliVersion == null ? "" : headerCliVersion;
         LocalDateTime now = LocalDateTime.now();
         //生成订单 order_ticket
         KylinOrderTickets orderTickets = KylinOrderTickets.getNew();

liquidnet-bus-support/liquidnet-support-zuul/src/main/java/com/liquidnet/support/zuul/filter/GlobalAuthFilter.java

@@ -11,12 +11,9 @@ import com.netflix.zuul.ZuulFilter;
 import com.netflix.zuul.context.RequestContext;
 import io.jsonwebtoken.Claims;
 import io.jsonwebtoken.ExpiredJwtException;
-import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.stereotype.Component;
 import org.springframework.util.DigestUtils;
 
 import javax.servlet.http.HttpServletRequest;
@@ -74,7 +71,7 @@ public class GlobalAuthFilter extends ZuulFilter {
                 // 解析没有异常则表示token验证通过，如有必要可根据自身需求增加验证逻辑
                 Claims claims = jwtValidator.parse(token);
 
-                ctx.addZuulRequestHeader(CurrentUtil.uID, (String) claims.get(CurrentUtil.uID));
+                ctx.addZuulRequestHeader(CurrentUtil.TOKEN_SUB, (String) claims.get(CurrentUtil.TOKEN_SUB));
                 ctx.addZuulRequestHeader(CurrentUtil.uTag, JsonUtils.toJson(claims));
             } catch (ExpiredJwtException expiredJwtEx) {
                 ctx.addZuulRequestHeader(TOKEN_STATUS, TOKEN_INVALID);
@@ -115,7 +112,7 @@ public class GlobalAuthFilter extends ZuulFilter {
         log.debug("lns.headers:{}", zuulRequestHeaders);
 
         String uToken = zuulRequestHeaders.get(CurrentUtil.uToken), uid;
-        if (StringUtils.isEmpty(uToken) || StringUtils.isEmpty(uid = zuulRequestHeaders.get(CurrentUtil.uID))) {
+        if (StringUtils.isEmpty(uToken) || StringUtils.isEmpty(uid = zuulRequestHeaders.get(CurrentUtil.TOKEN_SUB))) {
             this.respHandler(ctx, zuulRequestHeaders.get(TOKEN_STATUS));
 
             return null;