Merge branch 'dev' of http://gitlab.zhengzai.tv/dongjingwei/liquidnet-bus-v1 into dev

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinOrderRefundsServiceImpl.java

@@ -249,7 +249,7 @@ public class KylinOrderRefundsServiceImpl extends ServiceImpl<KylinOrderRefundsM
                 orderRefundStatus = new Integer[]{KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY, KylinTableStatusConst.ORDER_REFUND_STATUS_REFUSE};
                 break;
             case "reject":
-                orderRefundStatus = new Integer[]{KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY, KylinTableStatusConst.ORDER_REFUND_STATUS_APPROVED, KylinTableStatusConst.ORDER_REFUND_STATUS_REFUSE};
+                orderRefundStatus = new Integer[]{KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY, KylinTableStatusConst.ORDER_REFUND_STATUS_REFUSE};
                 break;
             case "unfilled":
                 orderRefundStatus = new Integer[]{KylinTableStatusConst.ORDER_REFUND_STATUS_APPROVED, KylinTableStatusConst.ORDER_REFUND_STATUS_ERROR};

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundsStatusServiceImpl.java

@@ -417,7 +417,7 @@ public class KylinRefundsStatusServiceImpl {
             params.add("paymentId", oderInfo.getPaymentId());
             params.add("paymentType", oderInfo.getPaymentType());
             params.add("price", String.valueOf(refundPrice));
-            params.add("priceTotal", String.valueOf(refundPrice));
+            params.add("priceTotal", String.valueOf(oderInfo.getPriceTotal()));
             params.add("reason", refund.getReason());
 
             /*String sign = StringUtils.Ksort(params);

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-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketEntitiesMapper.xml

@@ -33,6 +33,7 @@
         <where>
             AND a.order_tickets_id = #{orderTicketsId}
             AND a.status != ${orderRefundStatusCancel}
+            AND a.status != 5
             AND b.order_ticket_entities_id = #{orderTicketEntitiesId}
         </where>
     </select>

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/channel/wepay/resp/WePayRefundReturnDto.java

@@ -43,4 +43,8 @@ public class WePayRefundReturnDto {
     private String couponRefundCount;
     @XStreamAlias("cash_refund_fee")
     private String cashRefundFee;
+    @XStreamAlias("err_code")
+    private String errCode;
+    @XStreamAlias("err_code_des")
+    private String errCodeDes;
 }

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

@@ -104,11 +104,10 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
                 } else if (dto.getResult().equalsIgnoreCase("error")) {
                     //调用回调
                     log.error("");
+                    return ResponseDto.failure("退款失败:" + dto.getMessage());
                 } else if (dto.getResult().equalsIgnoreCase("exception")) {
                     log.error("");
                 }
-
-
                 DragonRefundAppDto refundAppDto = new DragonRefundAppDto();
                 refundAppDto.setOrderCode(orderCode);
                 refundAppDto.setCode(code);
@@ -167,6 +166,14 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
                     String jsonStr = EntityUtils.toString(entity, "UTF-8");
                     log.debug("JSONSTR = " + jsonStr);
                     WePayRefundReturnDto wePayRefundReturnDto = XmlUtil.toBean(jsonStr, WePayRefundReturnDto.class);
+                    if (wePayRefundReturnDto.getErrCodeDes() != null) {
+                        channelDto.setResult("error");
+                        channelDto.setMessage(paymentType + " refund error: " + wePayRefundReturnDto.getErrCodeDes());
+                        contentDto.setRequest(data);
+                        contentDto.setResponse(jsonStr);
+                        channelDto.setContent(contentDto);
+                        return channelDto;
+                    }
                     log.debug("BEAN  = " + wePayRefundReturnDto);
                     if (!wePayRefundReturnDto.getReturnCode().equalsIgnoreCase("SUCCESS") || wePayRefundReturnDto.getReturnCode() == null) {
                         try {
@@ -373,10 +380,10 @@ 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));
+                    log.debug("SEND WEPAY NOTIFTURL = " + JSON.toJSONString(dto));
                     sendNotifyUrl(dto);
 
                     mqHandleUtil.sendMySqlRedis(
@@ -432,7 +439,7 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
                     dto.setRefundAt(callBackDto.getGmtRefund());
                     dto.setRefundPrice(response.getRefundAmount());
                     dto.setRefundError("");
-                    log.debug("SEND ALIPAY NOTIFTURL = "+ JSON.toJSONString(dto));
+                    log.debug("SEND ALIPAY NOTIFTURL = " + JSON.toJSONString(dto));
                     sendNotifyUrl(dto);
 
                     mqHandleUtil.sendMySqlRedis(
@@ -473,7 +480,7 @@ public class DragonOrderRefundsServiceImpl implements IDragonOrderRefundsService
         params.add("refundError", notifyUrlDto.getRefundError());
         params.add("refundPrice", notifyUrlDto.getRefundPrice());
         params.add("status", notifyUrlDto.getStatus().toString());
-        String response = HttpUtil.post( dataUtils.getRefundNotifyUrl(DragonConstant.REFUND_REDIS_KET + notifyUrlDto.getOrderRefundCode()), params);
+        String response = HttpUtil.post(dataUtils.getRefundNotifyUrl(DragonConstant.REFUND_REDIS_KET + notifyUrlDto.getOrderRefundCode()), params);
         log.debug("RETURN RESPONSE=" + response);
         if (response.equals("success")) {
             mqHandleUtil.sendMySqlRedis(

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

 package com.liquidnet.service.kylin.controller;
 
-import com.github.pagehelper.PageInfo;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.constant.LnsEnum;
 import com.liquidnet.commons.lang.constant.LnsRegex;
 import com.liquidnet.commons.lang.core.JwtValidator;
 import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.base.ErrorMapping;
+import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.dto.param.CheckPerformanceRelationParam;
 import com.liquidnet.service.kylin.dto.param.KylinStationCheckOrderParam;
@@ -17,6 +17,7 @@ import com.liquidnet.service.kylin.dto.vo.mongo.*;
 import com.liquidnet.service.kylin.dto.vo.returns.*;
 import com.liquidnet.service.kylin.service.IKylinOrderTicketEntitiesService;
 import com.liquidnet.service.kylin.utils.DataUtils;
+import com.liquidnet.service.kylin.utils.ObjectUtil;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -124,13 +125,14 @@ public class KylinStationController {
             @ApiImplicitParam(type = "form", required = true, dataType = "Integer", name = "pageSize", value = "页记录数", example = "5"),
     })
     @GetMapping("performances")
-    public ResponseDto<PageInfo<KylinStationPerformanceVo>> performances(@Pattern(regexp = "\\b(recent|over)\\b", message = "模块参数无效")
+    public ResponseDto<PagedResult<KylinStationPerformanceVo>> performances(@Pattern(regexp = "\\b(recent|over)\\b", message = "模块参数无效")
                                                                          @RequestParam String mod,
                                                                             @RequestParam(required = false) String match,
                                                                             @RequestParam(defaultValue = "1", required = false) int pageNo,
                                                                             @RequestParam(defaultValue = "5", required = false) int pageSize) {
-        List<KylinStationPerformanceVo> voList = new ArrayList<>();
+        List<KylinStationPerformanceVo> voList = ObjectUtil.getKylinStationPerformanceVoArrayList();
         String currentUid = CurrentUtil.getCurrentUid();
+        PagedResult<KylinStationPerformanceVo> pagedResult = ObjectUtil.getKylinStationPerformanceVoPagedResult();
         long count = 0;
         try {
             // 查取当前用户下关联演出ID列表
@@ -159,7 +161,7 @@ public class KylinStationController {
                             break;
                         default:
                             log.info(":::performances/default:{}", currentUid);
-                            return ResponseDto.success(new PageInfo<>());
+                            return ResponseDto.success(pagedResult);
                     }
                     if (StringUtils.isNotBlank(match)) {
                         java.util.regex.Pattern pattern =
@@ -173,7 +175,7 @@ public class KylinStationController {
                     Query performancesVoQuery = Query.query(criteria);
                     count = mongoTemplate.count(performancesVoQuery, KylinPerformanceVo.class.getSimpleName());
 
-                    if (count <= 0) return ResponseDto.success(new PageInfo<>());
+                    if (count <= 0) return ResponseDto.success(pagedResult);
 
                     performancesVoQuery.with(PageRequest.of(pageNo - 1, pageSize));
                     performancesVoQuery.with(Sort.by(Sort.Order.asc("timeEnd"), Sort.Order.desc("sort")));
@@ -188,16 +190,6 @@ public class KylinStationController {
                     // 转换订单票明细结构为Map<performanceId, List<KylinOrderTicketEntitiesVo>>
                     Map<String, List<KylinOrderTicketEntitiesVo>> oteVoMap = oteVoList.stream().collect(Collectors.groupingBy(KylinOrderTicketEntitiesVo::getPerformanceId));
 
-//                    // 查取订单对应票种
-//                    Query performanceTicketVoQuery = Query.query(Criteria.where("ticketsId").in(
-//                            oteVoList.stream().filter(distinctByKey(KylinOrderTicketEntitiesVo::getTicketId)).map(KylinOrderTicketEntitiesVo::getTicketId).toArray()
-//                    ));
-//                    List<KylinTicketVo> performanceTicketVoList = mongoTemplate.find(performanceTicketVoQuery, KylinTicketVo.class, KylinPerformanceVo.class.getSimpleName());
-//                    log.debug("performanceTicketVoList:{}", JsonUtils.toJson(performanceTicketVoList));
-//                    // 转换票种信息结构为Map<ticketsId, ticketVo>
-//                    Map<String, KylinTicketVo> performanceTicketMap = performanceTicketVoList.stream().collect(Collectors.toMap(KylinTicketVo::getTicketsId, Function.identity(), (k1, k2) -> k2));
-//                    log.debug("performanceTicketMap:{}", JsonUtils.toJson(performanceTicketMap));
-
                     // 转换Map<performanceId, canDownTime>
                     Map<String, String> performanceRelationMap = performanceRelationList.stream().collect(Collectors.toMap(CheckPerformanceRelationParam::getPerformanceId, CheckPerformanceRelationParam::getCanDownTime));
                     log.debug("performanceRelationMap:{}", JsonUtils.toJson(performanceRelationMap));
@@ -210,7 +202,7 @@ public class KylinStationController {
 
                             if (!CollectionUtils.isEmpty(performanceTicketEntitiesVoList)) {
                                 // 提取演出对应票种信息
-                                List<KylinTicketVo> performanceTicketVoList = new ArrayList<>();
+                                List<KylinTicketVo> performanceTicketVoList = ObjectUtil.getKylinTicketVoArrayList();
                                 List<KylinTicketTimesVo> ticketTimeList = r.getTicketTimeList();
                                 ticketTimeList.forEach(tt -> {
                                     performanceTicketVoList.addAll(tt.getTicketList());
@@ -223,7 +215,7 @@ public class KylinStationController {
                                 Map<String, List<KylinOrderTicketEntitiesVo>> performanceTicketEntitiesVoMap =
                                         performanceTicketEntitiesVoList.stream().collect(Collectors.groupingBy(KylinOrderTicketEntitiesVo::getTicketId));
 
-                                List<KylinStationTicketVo> ticketVoList = new ArrayList<>();
+                                List<KylinStationTicketVo> ticketVoList = ObjectUtil.getKylinStationTicketVoArrayList();
 
                                 BigDecimal priceSum = BigDecimal.ZERO;
                                 int number = 0, checkedNum = 0, remainderNum = 0;
@@ -272,9 +264,10 @@ public class KylinStationController {
         } catch (Exception e) {
             log.error("验票:查取演出列表异常[station/performances]", e);
         }
-        PageInfo<KylinStationPerformanceVo> voPageInfo = PageInfo.of(voList);
-        voPageInfo.setTotal(count);
-        return ResponseDto.success(voPageInfo);
+
+        pagedResult.setList(voList).setTotal(count, pageSize);
+
+        return ResponseDto.success(pagedResult);
     }
 
     @ApiOperation(value = "下载验票数据")
@@ -329,19 +322,14 @@ public class KylinStationController {
             KylinStationPerformanceVo performanceVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)),
                     KylinStationPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
 
-//            // 查取订单对应票种
-//            Query performanceTicketVoQuery = Query.query(Criteria.where("ticketsId").in(
-//                    checkOrderVos.stream().filter(distinctByKey(KylinStationCheckOrderVo::getTicketId)).map(KylinStationCheckOrderVo::getTicketId).toArray()
-//            ));
-//            List<KylinTicketVo> performanceTicketVoList = mongoTemplate.find(performanceTicketVoQuery, KylinTicketVo.class, KylinTicketVo.class.getSimpleName());
             // 提取演出对应票种信息
-            List<KylinTicketVo> performanceTicketVoList = new ArrayList<>();
+            List<KylinTicketVo> performanceTicketVoList = ObjectUtil.getKylinTicketVoArrayList();
             List<KylinTicketTimesVo> ticketTimeList = performanceVo.getTicketTimeList();
             ticketTimeList.forEach(tt -> {
                 performanceTicketVoList.addAll(tt.getTicketList());
             });
 
-            List<KylinStationTicketVo> ticketVoList = new ArrayList<>();
+            List<KylinStationTicketVo> ticketVoList = ObjectUtil.getKylinStationTicketVoArrayList();
             for (KylinTicketVo r : performanceTicketVoList) {
                 KylinStationTicketVo stationTicketVo = KylinStationTicketVo.getNew();
                 stationTicketVo.setTicketId(r.getTicketsId());
@@ -438,19 +426,14 @@ public class KylinStationController {
             KylinStationPerformanceVo performanceVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)),
                     KylinStationPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
 
-//            // 查取订单对应票种
-//            Query performanceTicketVoQuery = Query.query(Criteria.where("ticketsId").in(
-//                    checkOrderVos.stream().filter(distinctByKey(KylinStationCheckOrderVo::getTicketId)).map(KylinStationCheckOrderVo::getTicketId).toArray()
-//            ));
-//            List<KylinTicketVo> performanceTicketVoList = mongoTemplate.find(performanceTicketVoQuery, KylinTicketVo.class, KylinTicketVo.class.getSimpleName());
             // 提取演出对应票种信息
-            List<KylinTicketVo> performanceTicketVoList = new ArrayList<>();
+            List<KylinTicketVo> performanceTicketVoList = ObjectUtil.getKylinTicketVoArrayList();
             List<KylinTicketTimesVo> ticketTimeList = performanceVo.getTicketTimeList();
             ticketTimeList.forEach(tt -> {
                 performanceTicketVoList.addAll(tt.getTicketList());
             });
 
-            List<KylinStationTicketVo> ticketVoList = new ArrayList<>();
+            List<KylinStationTicketVo> ticketVoList = ObjectUtil.getKylinStationTicketVoArrayList();
             for (KylinTicketVo r : performanceTicketVoList) {
                 KylinStationTicketVo stationTicketVo = KylinStationTicketVo.getNew();
                 stationTicketVo.setTicketId(r.getTicketsId());
@@ -488,42 +471,46 @@ public class KylinStationController {
                 if (CurrentUtil.GRAY_LOGIN_SMS_CODE.equals(identity)) {
                     return this.loginAuthentication(checkUserVo);
                 }
-                return ResponseDto.failure(ErrorMapping.get("20002"));
             }
 
-            try {
-                LinkedMultiValueMap<String, String> paramsMap = new LinkedMultiValueMap<>();
-                paramsMap.add("mobile", mobile);
-                paramsMap.add("code", identity);
-                LinkedMultiValueMap<String, String> headersMap = new LinkedMultiValueMap<>();
-                headersMap.add("token", null);
-
-                // TODO: 2021/5/12
-                String respStr = HttpUtil.get("https://service.zhengzai.tv/smsValidation", paramsMap, headersMap);
-                log.info("###PHP.API.RESP:{}", respStr);
-
-                Map respMap = JsonUtils.fromJson(respStr, Map.class);
-
-                if (StringUtils.equalsIgnoreCase("OK", (String) respMap.get("message"))) {
-                    return this.loginAuthentication(checkUserVo);
-                }
-                return ResponseDto.failure(ErrorMapping.get("20002"));
-            } catch (Exception e) {
-                log.error("验证码验证异常[mobile:{},code:{}]", mobile, identity, e);
+//            try {
+//                LinkedMultiValueMap<String, String> paramsMap = new LinkedMultiValueMap<>();
+//                paramsMap.add("mobile", mobile);
+//                paramsMap.add("code", identity);
+//                LinkedMultiValueMap<String, String> headersMap = new LinkedMultiValueMap<>();
+//                headersMap.add("token", null);
+//
+//                String respStr = HttpUtil.get("https://service.zhengzai.tv/smsValidation", paramsMap, headersMap);
+//                log.info("###PHP.API.RESP:{}", respStr);
+//
+//                Map respMap = JsonUtils.fromJson(respStr, Map.class);
+//
+//                if (StringUtils.equalsIgnoreCase("OK", (String) respMap.get("message"))) {
+//                    return this.loginAuthentication(checkUserVo);
+//                }
+//                return ResponseDto.failure(ErrorMapping.get("20002"));
+//            } catch (Exception e) {
+//                log.error("验证码验证异常[mobile:{},code:{}]", mobile, identity, e);
+//                return ResponseDto.failure(ErrorMapping.get("20002"));
+//            }
+            String smsCodeByMobile = (String) redisUtil.get("adam:valid:sms:code:mobile" + mobile);
+            if (null == smsCodeByMobile || !smsCodeByMobile.equals(identity)) {
                 return ResponseDto.failure(ErrorMapping.get("20002"));
             }
+            return this.loginAuthentication(checkUserVo);
         }
     }
 
     private ResponseDto<KylinStationLoginVo> loginAuthentication(KylinCheckUserVo checkUserVo) {
-        Map<String, Object> claimsMap = new HashMap<>();
-        claimsMap.put("sub", checkUserVo.getCheckUserId());
-        claimsMap.put("mobile", checkUserVo.getMobile());
-        claimsMap.put("nickname", checkUserVo.getName());
+        Map<String, Object> claimsMap = CollectionUtil.mapStringObject();
+        claimsMap.put(CurrentUtil.TOKEN_SUB, checkUserVo.getCheckUserId());
+        claimsMap.put(CurrentUtil.TOKEN_MOBILE, checkUserVo.getMobile());
+        claimsMap.put(CurrentUtil.TOKEN_NICKNAME, checkUserVo.getName());
+        claimsMap.put(CurrentUtil.TOKEN_TYPE, CurrentUtil.TOKEN_TYPE_VAL_STATION);
 
         String token = jwtValidator.create(claimsMap);
 
-        String ssoUidM5TokenKey = jwtValidator.getSsoRedisKey()
+        String ssoUidM5TokenKey = jwtValidator.getMsoRedisKey()
                 .concat(checkUserVo.getCheckUserId())
                 .concat(":").concat(DigestUtils.md5DigestAsHex(token.getBytes(StandardCharsets.UTF_8)));
 

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/service/impl/KylinOrderTicketsServiceImpl.java

@@ -193,13 +193,17 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
                 currentTime = System.currentTimeMillis() - currentTime;
                 log.debug("获取倒计时 -> time:" + (currentTime) + "毫秒");
 
-                //TODO 顺丰快递
                 Integer orderExpressStatus = dataUtils.getOrderExpressInfo(orderTicketVo.getOrderTicketsId());
                 vo.setExpressStatus(orderExpressStatus);
 
-                List<KylinOrderRefundsVo> orderRefundsVoList = dataUtils.getOrderRefundVoByOrderId(orderId);
+                List<KylinOrderRefundsVo> orderRefundsVoList;
+                if (orderTicketVo.getQrCode().equalsIgnoreCase("")) {
+                    orderRefundsVoList = new ArrayList<>();
+                } else {
+                    orderRefundsVoList = dataUtils.getOrderRefundVoByOrderId(orderId);
                     currentTime = System.currentTimeMillis() - currentTime;
                     log.debug("获取退款详情 -> time:" + (currentTime) + "毫秒");
+                }
 
                 List<OrderRefundListVo> orderRefundListVos = new ArrayList<>();
                 BigDecimal lockPrice = BigDecimal.valueOf(0.00);

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();
@@ -872,15 +873,15 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
                     adTemplate = ticketData.getIsShowCode() == 1 ? SmsEnum.ADTemplate.SMS_171358560 : SmsEnum.ADTemplate.SMS_181500419;
                 }
 
-                if (null != adTemplate) {
-                    queueUtils.sendMsgByRedis(MQConst.KylinQueue.SMS_NOTICE.getKey(),
-                            SmsMessage.builder().setPhone(orderTicketData.getUserMobile())
-                                    .setSignName(SmsEnum.ADSignName.M02.getVal())
-                                    .setTemplateCode(adTemplate.name())
-                                    .setTemplateParam("name", orderTicketData.getPerformanceTitle())
-                                    .setTemplateParam("time", time1 + " " + time2).toJson()
-                    );
-                }
+//                if (null != adTemplate) {
+//                    queueUtils.sendMsgByRedis(MQConst.KylinQueue.SMS_NOTICE.getKey(),
+//                            SmsMessage.builder().setPhone(orderTicketData.getUserMobile())
+//                                    .setSignName(SmsEnum.ADSignName.M02.getVal())
+//                                    .setTemplateCode(adTemplate.name())
+//                                    .setTemplateParam("name", orderTicketData.getPerformanceTitle())
+//                                    .setTemplateParam("time", time1 + " " + time2).toJson()
+//                    );
+//                }
 
                 // 大麦回调
                 sycDamaiOrder(orderTickets.getOrderTicketsId());

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;