exit 修改头像保存逻辑，和sku和uid查询是否预约逻辑

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

@@ -19,6 +19,7 @@ import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.util.LinkedList;
+import java.util.List;
 
 /**
  * <p>
@@ -51,16 +52,13 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
             if (!anticipateValueVo.getState().equals(1)) {
                 return ResponseDto.failure("该商品预约尚未开始或已经结束，不可预约！");
             }
-            AdamUserInfoVo userInfo = goblinAnticipateUtils.getUserInfo();
-            if (userInfo==null){
-                return ResponseDto.failure("登陆信息有误");
-            }
             //查询该用户是否预
-            GoblinGoodAnticipateUserVo userVo = goblinRedisUtils.getUserAboutAut(skuId, userInfo.getUid());
+            String uid = CurrentUtil.getCurrentUid();
+            GoblinGoodAnticipateUserVo userVo = goblinRedisUtils.getUserAboutAut(skuId, uid);
             LinkedList<Object[]> sqlValue = CollectionUtil.linkedListObjectArr();
             if (userVo == null) {
                 GoblinGoodAnticipateUserVo user = new GoblinGoodAnticipateUserVo();
-                user.setUid(userInfo.getUid());
+                user.setUid(uid);
                 user.setSkuId(skuId);
                 String mobile = StringUtils.defaultString(((String) CurrentUtil.getTokenClaims().get(CurrentUtil.TOKEN_MOBILE)), "");
                 user.setPhone(mobile);
@@ -79,8 +77,13 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
                 });
                 sendRedis("goblin_goods_anticipate_user", sqlValue);
                 goblinRedisUtils.setSkuIdPeople(skuId);
-                //储存用户头像
-                goblinRedisUtils.setUserAvatar(skuId,userInfo.getAvatar());
+                //获取用户头像个数小于等于2则保存用户头像
+                List<String> userAvatar = goblinRedisUtils.getUserAvatar(skuId);
+                if (userAvatar != null && userAvatar.size() <= 2) {
+                    //查询用户信息获取用户头像并保存
+                    AdamUserInfoVo userInfo = goblinAnticipateUtils.getUserInfo();
+                    goblinRedisUtils.setUserAvatar(skuId, userInfo.getAvatar());
+                }
             }
             return ResponseDto.success();
         }
@@ -89,11 +92,8 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
 
     @Override
     public ResponseDto<Boolean> selectAnticipate(String skuId) {
-        AdamUserInfoVo userInfo = goblinAnticipateUtils.getUserInfo();
-        if (userInfo == null){
-            return ResponseDto.failure("登陆信息有误！");
-        }
-        return ResponseDto.success(goblinRedisUtils.getUserAboutAut(skuId,userInfo.getUid()) != null) ;
+        String uid = CurrentUtil.getCurrentUid();
+        return ResponseDto.success(goblinRedisUtils.getUserAboutAut(skuId, uid) != null);
     }
 
     public void sendRedis(String sqlKey, LinkedList<Object[]> sqlData) {

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinRedisUtils.java

@@ -53,21 +53,21 @@ public class GoblinRedisUtils {
     /**
      * 该skuId已开启预约
      */
-    public void setValue(GoblinGoodsAnticipateValueVo valueVo){
-        redisUtil.set(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(valueVo.getSkuId()),valueVo);
+    public void setValue(GoblinGoodsAnticipateValueVo valueVo) {
+        redisUtil.set(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(valueVo.getSkuId()), valueVo);
     }
 
     /**
      * 根据skuId获取valueVo
      */
-    public GoblinGoodsAnticipateValueVo getValueBySkuId(String skuId){
-        return (GoblinGoodsAnticipateValueVo)redisUtil.get(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(skuId));
+    public GoblinGoodsAnticipateValueVo getValueBySkuId(String skuId) {
+        return (GoblinGoodsAnticipateValueVo) redisUtil.get(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(skuId));
     }
 
     /**
      * 获取关联
      */
-    public boolean getSkuId(String skuId){
+    public boolean getSkuId(String skuId) {
         return redisUtil.get(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(skuId)) != null;
     }
 
@@ -75,7 +75,7 @@ public class GoblinRedisUtils {
     /**
      * 删除skuId已开启预约
      */
-    public void delSkuId(String skuId){
+    public void delSkuId(String skuId) {
         redisUtil.del(GoblinRedisConst.ANTICIPATE_VALUE_SKUID.concat(skuId));
     }
 
@@ -88,7 +88,7 @@ public class GoblinRedisUtils {
      */
     public void setUserAboutSku(GoblinGoodAnticipateUserVo user) {
         goblinMongoUtils.setGoblinGoodsAnticipateUserVo(user);
-        redisUtil.set(GoblinRedisConst.USER_ANTICIPATE_STATE.concat(user.getSkuId()).concat(user.getUid()),user,60*60*24*30);
+        redisUtil.set(GoblinRedisConst.USER_ANTICIPATE_STATE.concat(user.getSkuId()).concat(user.getUid()), user, 60 * 60 * 24 * 30);
     }
 
     /**
@@ -96,9 +96,9 @@ public class GoblinRedisUtils {
      */
     public void setSkuIdPeople(String skuId) {
         BigInteger num = (BigInteger) redisUtil.get(GoblinRedisConst.ANTICIPATE_PEOPLE.concat(skuId));
-        num =  num!=null?num: BigInteger.valueOf(0);
+        num = num != null ? num : BigInteger.valueOf(0);
         //新预约  +1
-        redisUtil.set(GoblinRedisConst.ANTICIPATE_PEOPLE.concat(skuId),num.add(BigInteger.valueOf(1)));
+        redisUtil.set(GoblinRedisConst.ANTICIPATE_PEOPLE.concat(skuId), num.add(BigInteger.valueOf(1)));
 
         //跟新valueVo
         GoblinGoodsAnticipateValueVo anticipateValueVo = getValueBySkuId(skuId);
@@ -116,24 +116,22 @@ public class GoblinRedisUtils {
     /**
      * 保存用户头像
      */
-    public void setUserAvatar(String skuId,String avatar) {
+    public void setUserAvatar(String skuId, String avatar) {
         Object list = redisUtil.get(GoblinRedisConst.ANTICIPATE_SKUID_AVATAR.concat(skuId));
-        List<String> urlList = list != null ? (List<String>)list : CollectionUtil.arrayListString();
-        if (urlList.size()<=2){
+        List<String> urlList = list != null ? (List<String>) list : CollectionUtil.arrayListString();
         urlList.add(avatar);
-            redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID_AVATAR.concat(skuId),urlList);
-        }
+        redisUtil.set(GoblinRedisConst.ANTICIPATE_SKUID_AVATAR.concat(skuId), urlList);
     }
 
     /**
      * 获取用户预约头像
      */
-    public List<String> getUserAvatar(String skuId){
+    public List<String> getUserAvatar(String skuId) {
         String rdk = GoblinRedisConst.ANTICIPATE_SKUID_AVATAR.concat(skuId);
         Object obj = redisUtil.get(rdk);
-        if(obj==null){
+        if (obj == null) {
             return CollectionUtil.arrayListString();
-        }else{
+        } else {
             return (List<String>) obj;
         }
     }
@@ -1643,15 +1641,15 @@ public class GoblinRedisUtils {
      * private String shelvesStatus 单品上架状态[0-待上架|1-下架|2-违规|3-上架];
      * private String skuAppear 是否隐藏[0-默认展示|1-隐藏];
      * private String delFlg 删除标记[0-未删除|1-删除];
-     *
+     * <p>
      * private LocalDateTime saleStartTime 开售时间;
      * private LocalDateTime saleStopTime 停售时间 预留 暂时不做处理;
      * private String soldoutStatus 是否售罄[0-否|1-是];
-     *
+     * <p>
      * private String skuCanbuy 是否购买[0-否|1-是] 这个用来预览 前端自己判断;
-     *
+     * <p>
      * Integer upchain NFT上传声明状态[0-待上传|1-已声明|2-声明失败|9-声明中]
-     *
+     * <p>
      * String unbox; 是否盲盒[0-否|1-是]
      */
     // 获取盲盒下藏品的库存 各种状态下不能算库存的排除掉
@@ -1668,6 +1666,7 @@ public class GoblinRedisUtils {
             return 0;
         }
     }
+
     // 各种状态下判断藏品是否可以展示
     public boolean getSkuAllStatusShow(GoblinGoodsSkuInfoVo info) {
         if (
@@ -1685,6 +1684,7 @@ public class GoblinRedisUtils {
             return false;
         }
     }
+
     // 各种状态下判断藏品总库存
     public Integer getSkuTotalStock(GoblinGoodsSkuInfoVo info) {
         if (