Merge branch 'test'

liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/constant/AdamRedisConst.java

@@ -38,6 +38,7 @@ public class AdamRedisConst {
 
     public static final String SWITCH = ADAM.concat("switch:");
     public static final String SWITCH_BUY_MEMBER = SWITCH.concat("buy:member");
+    public static final String SWITCH_GRAY_LOGIN_SMS = SWITCH.concat("gray:login:sms");
 
     /* ----------------------------------------------------------------- */
 

liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/constant/LnsEnum.java

+package com.liquidnet.commons.lang.constant;
+
+public final class LnsEnum {
+    public enum ENV {
+        dev,
+        test,
+        prod;
+    }
+
+    public static void main(String[] args) {
+        System.out.println(ENV.dev.name());
+    }
+}

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

@@ -3,11 +3,14 @@ package com.liquidnet.commons.lang.util;
 import org.apache.commons.lang3.StringUtils;
 
 import javax.servlet.http.HttpServletRequest;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
 import java.util.Map;
 
 public class CurrentUtil {
+    public static final String CK_ENV_ACTIVE = "spring.profiles.active";
+    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";

liquidnet-bus-config/liquidnet-config/liquidnet-service-adam-dev.yml

@@ -29,5 +29,8 @@ liquidnet:
   aliyun:
     accessKeyId: LTAI4FvoqxJUT5T1ydJSyhUn
     accessSecret: WNCgFn9dSjnoDdej2YTvR0v0216WWU
+  reviewer:
+    app-login:
+      mobile: 13724286255
 
 #以下为spring各环境个性配置

liquidnet-bus-config/liquidnet-config/liquidnet-service-adam-test.yml

@@ -29,5 +29,8 @@ liquidnet:
   aliyun:
     accessKeyId: LTAI4FvoqxJUT5T1ydJSyhUn
     accessSecret: WNCgFn9dSjnoDdej2YTvR0v0216WWU
+  reviewer:
+    app-login:
+      mobile: 13724286255
 
 #以下为spring各环境个性配置

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

@@ -9,8 +9,10 @@ import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.github.xiaoymin.knife4j.annotations.ApiSupport;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.common.cache.redisson.util.RedisLockUtil;
+import com.liquidnet.commons.lang.constant.LnsEnum;
 import com.liquidnet.commons.lang.core.JwtValidator;
 import com.liquidnet.commons.lang.util.*;
+import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.AdamThirdPartParam;
 import com.liquidnet.service.adam.dto.vo.AdamLoginInfoVo;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
@@ -26,6 +28,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.env.Environment;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.DigestUtils;
@@ -67,7 +70,8 @@ public class AdamLoginController {
     @Autowired
     IAdamUserService adamUserService;
 
-
+    @Value("${liquidnet.reviewer.app-login.mobile}")
+    private String reviewMobile;
     private static final String PHP_API_SMS_CODE_SEND = "/smsCode";
     private static final String PHP_API_SMS_CODE_VALID = "/smsValidation";
 
@@ -174,7 +178,7 @@ public class AdamLoginController {
         loginInfoVo.setUserInfo(userInfoVo);
         loginInfoVo.setToken(this.ssoProcess(userInfoVo));
         loginInfoVo.getUserInfo().setMobile(SensitizeUtil.custom(userInfoVo.getMobile(), 3, 4));
-        log.info(UserPathDto.setData(toRegister ? "注册":"登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
+        log.info(UserPathDto.setData(toRegister ? "注册" : "登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
         return ResponseDto.success(loginInfoVo);
     }
 
@@ -212,7 +216,7 @@ public class AdamLoginController {
         loginInfoVo.setUserInfo(userInfoVo);
         loginInfoVo.setToken(this.ssoProcess(userInfoVo));
         loginInfoVo.getUserInfo().setMobile(SensitizeUtil.custom(userInfoVo.getMobile(), 3, 4));
-        log.info(UserPathDto.setData(toRegister ? "注册":"登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
+        log.info(UserPathDto.setData(toRegister ? "注册" : "登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
         return ResponseDto.success(loginInfoVo);
     }
 
@@ -247,7 +251,7 @@ public class AdamLoginController {
         }
         loginInfoVo.setToken(this.ssoProcess(loginInfoVo.getUserInfo()));
         loginInfoVo.getUserInfo().setMobile(SensitizeUtil.custom(loginInfoVo.getUserInfo().getMobile(), 3, 4));
-        log.info(UserPathDto.setData(toRegister ? "注册":"登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
+        log.info(UserPathDto.setData(toRegister ? "注册" : "登录", ServletUtils.getRequest().getParameterMap(), loginInfoVo));
         return ResponseDto.success(loginInfoVo);
     }
 
@@ -283,8 +287,22 @@ public class AdamLoginController {
     /* ---------------------------- Internal Method ---------------------------- */
 
     private boolean checkSmsCode(String mobile, String code) {
-        if (Arrays.asList("dev", "test", "prod").contains(env.getProperty("spring.profiles.active")) && "111111".equals(code)) {
-            return true;
+        Integer switchGrayLoginSms = (Integer) redisUtil.get(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS);
+        if (null != switchGrayLoginSms) {
+            if (switchGrayLoginSms == 615243) {
+                if (CurrentUtil.GRAY_LOGIN_SMS_CODE.equals(code)) {
+                    return true;
+                }
+            }
+            if (switchGrayLoginSms == 612543) {
+                if (reviewMobile.equals(mobile) ||
+                        Arrays.asList(LnsEnum.ENV.dev.name(), LnsEnum.ENV.test.name()).contains(env.getProperty(CurrentUtil.CK_ENV_ACTIVE))
+                ) {
+                    if (CurrentUtil.GRAY_LOGIN_SMS_CODE.equals(code)) {
+                        return true;
+                    }
+                }
+            }
         }
 
         LinkedMultiValueMap<String, String> paramsMap = new LinkedMultiValueMap<>();
@@ -328,7 +346,6 @@ public class AdamLoginController {
     private String ssoProcess(AdamUserInfoVo userInfoVo) {
         Map<String, Object> claimsMap = new HashMap<>();
         claimsMap.put("sub", userInfoVo.getUid());
-        // TODO: 2021/5/25 修改手机号更新TOKEN
         claimsMap.put("mobile", userInfoVo.getMobile());
         claimsMap.put("nickname", userInfoVo.getNickname());
         claimsMap.put("type", "user");

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

@@ -5,6 +5,7 @@ import com.github.pagehelper.PageInfo;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.github.xiaoymin.knife4j.annotations.ApiSupport;
 import com.liquidnet.common.cache.redisson.util.RedisLockUtil;
+import com.liquidnet.commons.lang.constant.LnsEnum;
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
@@ -161,7 +162,7 @@ public class AdamMemberOrderController {
             return "fail";
         }
 
-        if (!"dev".equals(env.getProperty("spring.profiles.active"))) {
+        if (!LnsEnum.ENV.dev.name().equals(env.getProperty(CurrentUtil.CK_ENV_ACTIVE))) {
             ResponseDto<Integer> checkOrderResult = this.checkOrderResult(parameter.getOrderCode());
             if (!checkOrderResult.isSuccess() || checkOrderResult.getData() != 1) {
                 log.warn("###购买会员支付回调支付中心验证不通过，无法处理[{}]", JsonUtils.toJson(parameter));

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

@@ -2,6 +2,7 @@ package com.liquidnet.service.adam.controller;
 
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.github.xiaoymin.knife4j.annotations.ApiSupport;
+import com.liquidnet.commons.lang.constant.LnsEnum;
 import com.liquidnet.commons.lang.constant.LnsRegex;
 import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
@@ -304,8 +305,9 @@ public class AdamUserController {
     private static final String PHP_API_SMS_CODE_VALID = "/smsValidation";
 
     private boolean checkSmsCode(String mobile, String code) {
-        if (Arrays.asList("dev", "test", "prod").contains(env.getProperty("spring.profiles.active"))) {
-            return "111111".equals(code);
+        if (Arrays.asList(LnsEnum.ENV.dev.name(), LnsEnum.ENV.test.name()).contains(env.getProperty(CurrentUtil.CK_ENV_ACTIVE))
+                && CurrentUtil.GRAY_LOGIN_SMS_CODE.equals(code)) {
+            return true;
         }
 
         LinkedMultiValueMap<String, String> paramsMap = new LinkedMultiValueMap<>();

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

@@ -2,6 +2,7 @@ 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.*;
@@ -483,8 +484,8 @@ public class KylinStationController {
             }
             return ResponseDto.failure(ErrorMapping.get("20602"));
         } else {// 校验验证码
-            if (Arrays.asList("dev", "test").contains(environment.getProperty("spring.profiles.active"))) {
-                if ("111111".equals(identity)) {
+            if (Arrays.asList(LnsEnum.ENV.dev.name(), LnsEnum.ENV.test.name()).contains(environment.getProperty(CurrentUtil.CK_ENV_ACTIVE))) {
+                if (CurrentUtil.GRAY_LOGIN_SMS_CODE.equals(identity)) {
                     return this.loginAuthentication(checkUserVo);
                 }
                 return ResponseDto.failure(ErrorMapping.get("20002"));

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

@@ -307,7 +307,7 @@ public class DataImpl {
                             tickets.setPriceExpress(ticketData.getBigDecimal("price_express"));
                             tickets.setPriceDiscountMember(new BigDecimal("0.00"));
                             tickets.setPriceDiscount(new BigDecimal("0.00"));
-                            tickets.setDescribes(ticketData.getString("describe_express"));
+                            tickets.setDescribes(ticketData.getString("describe"));
                             tickets.setDescribeExpress(ticketData.getString("describe_express"));
                             tickets.setDescribeElectronic(ticketData.getString("describe_electronic"));
                             tickets.setAdvanceMinuteMember(5);
@@ -345,7 +345,7 @@ public class DataImpl {
                             ticketStatus.setSurplusExchange(ticketData.getInt("surplus_exchange"));
                             ticketStatus.setExpressType(ticketData.getInt("express_type"));
                             ticketStatus.setIsTrueName(ticketData.getString("need_id_card").equals("yes") ? 1 : 0);
-                            ticketStatus.setLimitCount(0);
+                            ticketStatus.setLimitCount(ticketData.getInt("num_limit_mobile"));
                             ticketStatus.setMemberLimitCount(1);
                             ticketStatus.setIsTransfer(0);
                             ticketStatus.setIsExclusive(ticketData.getInt("is_exclusive"));