~api:替换Mysql->Redis查取UID；

liquidnet-bus-do/liquidnet-service-adam-do/src/main/java/com/liquidnet/service/adam/mapper/AdamUserMapper.java

@@ -5,7 +5,6 @@ import com.liquidnet.service.adam.dto.AdamUserInfoDto;
 import com.liquidnet.service.adam.entity.AdamUser;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
-import org.springframework.stereotype.Repository;
 
 import java.util.List;
 
@@ -17,7 +16,6 @@ import java.util.List;
  * @author liquidnet
  * @since 2021-05-10
  */
-@Repository
 public interface AdamUserMapper extends BaseMapper<AdamUser> {
 
     int executeForDM(@Param("tn") String tn);
@@ -47,13 +45,13 @@ public interface AdamUserMapper extends BaseMapper<AdamUser> {
     })
     List<AdamUserInfoDto> selectMultiForUserInfoDto(@Param("rows") int rows, @Param("offset") int offset);
 
-    /**
-     * 根据手机号获取 用户信息
-     *
-     * @param mobile
-     * @return
-     */
-    AdamUserInfoDto selectByPhone(@Param("mobile") String mobile);
+//    /**
+//     * 根据手机号获取 用户信息
+//     *
+//     * @param mobile
+//     * @return
+//     */
+//    AdamUserInfoDto selectByPhone(@Param("mobile") String mobile);
 
     /**
      * 根据手机号批量获取

liquidnet-bus-do/liquidnet-service-adam-do/src/main/resources/com/liquidnet/service/adam/mapper/AdamUserMapper.xml

@@ -6,11 +6,11 @@
         <result column="mobile" property="mobile" jdbcType="VARCHAR"/>
     </resultMap>
 
-    <select id="selectByPhone" resultMap="BaseResult">
-        select uid, mobile
-        from adam_user
-        where mobile = #{mobile,jdbcType=VARCHAR}
-    </select>
+<!--    <select id="selectByPhone" resultMap="BaseResult">-->
+<!--        select uid, mobile-->
+<!--        from adam_user-->
+<!--        where mobile = #{mobile,jdbcType=VARCHAR}-->
+<!--    </select>-->
 
     <select id="selectByPhones" resultMap="BaseResult">
         select uid,mobile from adam_user where mobile in

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/goblin/GoblinNftExCodeServiceImpl.java

@@ -5,15 +5,14 @@ import com.alibaba.excel.read.listener.PageReadListener;
 import com.alibaba.excel.support.ExcelTypeEnum;
 import com.alibaba.excel.write.metadata.style.WriteCellStyle;
 import com.alibaba.excel.write.style.HorizontalCellStyleStrategy;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.github.pagehelper.PageHelper;
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.*;
+import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.AdamUserInfoDto;
 import com.liquidnet.service.adam.mapper.AdamUserMapper;
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.goblin.dto.vo.CodeExcelVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinNftExCodeFetchExcelVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinNftExCodeVo;
@@ -30,6 +29,7 @@ import com.liquidnet.service.platform.utils.GoblinRedisUtils;
 import com.liquidnet.service.platform.utils.ObjectUtil;
 import com.liquidnet.service.platform.utils.QueueUtils;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.ss.usermodel.HorizontalAlignment;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -44,7 +44,10 @@ import java.io.OutputStream;
 import java.net.URLEncoder;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
 
 /**
  * @Author: wll
@@ -54,7 +57,8 @@ import java.util.*;
 @Service
 @Slf4j
 public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
-
+    @Autowired
+    private RedisDataSourceUtil redisDataSourceUtil;
     @Autowired
     private GoblinGoodsSkuMapper goblinGoodsSkuMapper;
     @Autowired
@@ -201,11 +205,10 @@ public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
         String code = goblinNftExCodeParam.getCode();
         String phone = goblinNftExCodeParam.getPhone();
 
-        AdamUserInfoDto adamUserInfoDto = adamUserMapper.selectByPhone(phone);
-        if (adamUserInfoDto == null) {
-            return ResponseDto.failure("用户不存在!");
-        }
-
+//        AdamUserInfoDto adamUserInfoDto = adamUserMapper.selectByPhone(phone);
+//        if (adamUserInfoDto == null) {
+//            return ResponseDto.failure("用户不存在!");
+//        }
         // 根据兑换code查询兑换码信息
         GoblinNftExCode goblinNftExCode = goblinNftExCodeMapper.selectGoblinNftCodeByCode(code);
         if (goblinNftExCode == null) {
@@ -225,12 +228,17 @@ public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
             return ResponseDto.failure("兑换码已领取!");
         }
 
+        String uid = (String) redisDataSourceUtil.getRedisAdamUtil().get(AdamRedisConst.IDENTITY_MOBILE.concat(phone));
+        if (StringUtils.isEmpty(uid)) {
+            return ResponseDto.failure("用户不存在!");
+        }
 
         // 验证吗时间校验
         try {
             MultiValueMap<String, String> params = new LinkedMultiValueMap();
             params.add("code", code);
-            params.add("userId", adamUserInfoDto.getUid());
+//            params.add("userId", adamUserInfoDto.getUid());
+            params.add("userId", uid);
             MultiValueMap<String, String> headers = CollectionUtil.linkedMultiValueMapStringString();
             headers.add("Accept", "application/json;charset=UTF-8");
             headers.add("Authorization", "Bearer " + CurrentUtil.getToken());