nft商品列表

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

@@ -7,7 +7,6 @@ import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.goblin.dto.manage.vo.AnticipateValueVo;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.service.GoblinCouponService;
-import com.liquidnet.service.goblin.service.IGoblinGoodsAnticipateService;
 import com.liquidnet.service.goblin.service.IGoblinNftGoodsAppService;
 import com.liquidnet.service.goblin.service.manage.IGoblinGoodsAnticipateMgService;
 import com.liquidnet.service.goblin.util.GoblinMongoUtils;
@@ -29,7 +28,6 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.List;
-import java.util.Set;
 import java.util.stream.Collectors;
 
 @Service
@@ -56,24 +54,25 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
 
         int size = 40;
         //条件
-        Query query = Query.query(
-                Criteria.where("skuType").is(1)
-                        .and("delFlg").is("0")
-                        .and("status").is("3")
-                        .and("shelvesStatus").is("3")
-                        .and("skuAppear").is("0")
-        );
-        List<GoblinNftGoodsSkuListVo> skuList = goblinRedisUtils.getGoblinNftGoodsInfoListVo();
-        if (null == skuList || page > 1) {
-            skuList = new ArrayList<>();
+        List<String> skuIdList = goblinRedisUtils.getGoblinNftGoodsInfoListVo();
+        List<GoblinNftGoodsSkuListVo> skuList = new ArrayList<>();
+        if (null == skuIdList || page > 1) {
+            skuIdList = new ArrayList<>();
             // 分页 排序:按照开售时间
+            Query query = Query.query(
+                    Criteria.where("skuType").is(1)
+                            .and("delFlg").is("0")
+                            .and("status").is("3")
+                            .and("shelvesStatus").is("3")
+                            .and("skuAppear").is("0")
+            );
             Pageable pageable = PageRequest.of(page - 1, size, Sort.by(Sort.Direction.ASC, "saleStartTime"));
             query.with(pageable);
 
             List<GoblinGoodsSkuInfoVo> skuInfoVos = mongoTemplate.find(query, GoblinGoodsSkuInfoVo.class, GoblinGoodsSkuInfoVo.class.getSimpleName());
             for (GoblinGoodsSkuInfoVo info : skuInfoVos) {
                 //获取预约相关
-                AnticipateValueVo anticipateValueVo = goblinGoodsAnticipateMgService.getAnticipateValueBySkuId(info.getSkuId(),0);
+                AnticipateValueVo anticipateValueVo = goblinGoodsAnticipateMgService.getAnticipateValueBySkuId(info.getSkuId(), 0);
                 // sku信息
                 GoblinNftGoodsSkuListVo nftGoodsSkuInfoVo = GoblinNftGoodsSkuListVo.getNew().copy(info, anticipateValueVo);
                 // spu信息
@@ -82,9 +81,16 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
                 nftGoodsSkuInfoVo.setGoblinNftGoodsSpuInfoVo(nftGoodsSpuInfoVo);
                 // 写入列表
                 skuList.add(nftGoodsSkuInfoVo);
+                skuIdList.add(nftGoodsSkuInfoVo.getSkuId());
             }
             if (page <= 1) {
-                goblinRedisUtils.setGoblinNftGoodsInfoListVo(skuList);
+                goblinRedisUtils.setGoblinNftGoodsInfoListVo(skuIdList);
+            }
+        } else {
+            for (String skuId : skuIdList) {
+                GoblinGoodsSkuInfoVo goodsSkuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
+                GoblinNftGoodsSkuListVo goblinNftGoodsSkuListVo = GoblinNftGoodsSkuListVo.getNew().copy(goodsSkuInfoVo, null);
+                skuList.add(goblinNftGoodsSkuListVo);
             }
         }
         for (GoblinNftGoodsSkuListVo skuInfoVo : skuList) {
@@ -119,7 +125,7 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
         GoblinGoodsSkuInfoVo goodsSkuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
         if (goblinRedisUtils.getSkuAllStatusShow(goodsSkuInfoVo)) {
             //获取预约相关
-            AnticipateValueVo anticipateValueVo = goblinGoodsAnticipateMgService.getAnticipateValueBySkuId(skuId,1);
+            AnticipateValueVo anticipateValueVo = goblinGoodsAnticipateMgService.getAnticipateValueBySkuId(skuId, 1);
 
             GoblinNftGoodsSkuInfoVo nftGoodsSkuInfoVo = GoblinNftGoodsSkuInfoVo.getNew().copy(goodsSkuInfoVo, anticipateValueVo);
             // 限购数量

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

@@ -1525,17 +1525,17 @@ public class GoblinRedisUtils {
         }
     }
 
-    public List<GoblinNftGoodsSkuListVo> getGoblinNftGoodsInfoListVo() {
+    public List<String> getGoblinNftGoodsInfoListVo() {
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_GOODS_LIST;
         Object obj = redisUtil.get(redisKey);
         if (obj == null) {
             return null;
         } else {
-            return (List<GoblinNftGoodsSkuListVo>) obj;
+            return (List<String>) obj;
         }
     }
 
-    public void setGoblinNftGoodsInfoListVo(List<GoblinNftGoodsSkuListVo> spuList) {
+    public void setGoblinNftGoodsInfoListVo(List<String> spuList) {
         String redisKey = GoblinRedisConst.REDIS_GOBLIN_NFT_GOODS_LIST;
         redisUtil.set(redisKey, spuList);
     }