详情增加总库存

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

@@ -27,6 +27,7 @@ import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.util.Comparator;
+import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -77,8 +78,8 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
                 GoblinNftGoodsSpuInfoVo nftGoodsSpuInfoVo = GoblinNftGoodsSpuInfoVo.getNew().copy(goodsInfoVo);
                 nftGoodsSkuInfoVo.setGoblinNftGoodsSpuInfoVo(nftGoodsSpuInfoVo);
                 // 库存
-                int isStock = getIsStock(skuInfoVo.getSkuId(), skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
-                nftGoodsSkuInfoVo.setIsStock(isStock);
+                HashMap<String, Integer> stockHashMap = getIsStock(skuInfoVo.getSkuId(), skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
+                nftGoodsSkuInfoVo.setIsStock(stockHashMap.get("isStock"));
                 // 写入列表
                 skuList.add(nftGoodsSkuInfoVo);
                 skuIdList.add(nftGoodsSkuInfoVo.getSkuId());
@@ -98,8 +99,8 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
                 GoblinNftGoodsSpuInfoVo nftGoodsSpuInfoVo = GoblinNftGoodsSpuInfoVo.getNew().copy(goodsInfoVo);
                 goblinNftGoodsSkuListVo.setGoblinNftGoodsSpuInfoVo(nftGoodsSpuInfoVo);
                 // 库存
-                int isStock = getIsStock(skuId, skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
-                goblinNftGoodsSkuListVo.setIsStock(isStock);
+                HashMap<String, Integer> stockHashMap = getIsStock(skuId, skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
+                goblinNftGoodsSkuListVo.setIsStock(stockHashMap.get("isStock"));
                 // 写入列表
                 skuList.add(goblinNftGoodsSkuListVo);
             }
@@ -134,8 +135,12 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
             GoblinNftGoodsDetailSpuInfoVo nftGoodsDetailSpuInfoVo = GoblinNftGoodsDetailSpuInfoVo.getNew().copy(goodsInfoVo);
             nftGoodsSkuInfoVo.setGoblinNftGoodsDetailSpuInfoVo(nftGoodsDetailSpuInfoVo);
             // 库存
-            int isStock = getIsStock(skuId, skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
-            nftGoodsSkuInfoVo.setIsStock(isStock);
+            HashMap<String, Integer> stockHashMap = getIsStock(skuId, skuInfoVo.getUnbox(), skuInfoVo.getSoldoutStatus(), goodsInfoVo.getSkuIdList());
+            nftGoodsSkuInfoVo.setIsStock(stockHashMap.get("isStock"));
+            // 总库存
+            if (skuInfoVo.getUnbox().equals("1")) {
+                nftGoodsSkuInfoVo.setSkuStock(stockHashMap.get("totalStock"));
+            }
             // 系统时间
             nftGoodsSkuInfoVo.setSystime(LocalDateTime.now());
             return nftGoodsSkuInfoVo;
@@ -145,28 +150,31 @@ public class GoblinNftGoodsAppServiceImpl implements IGoblinNftGoodsAppService {
     }
 
     // 判断是否售罄
-    private int getIsStock(String skuId, String unbox, String soldoutStatus, List<String> skuIdList) {
+    private HashMap<String, Integer> getIsStock(String skuId, String unbox, String soldoutStatus, List<String> skuIdList) {
+        HashMap<String, Integer> returnMap = CollectionUtil.mapStringInteger();
+        Integer isStock = 0;
+        Integer totalStock = 0;
         if (null == soldoutStatus || soldoutStatus.equals("0")) {// 未设置售罄 查询库存
-            int stock = 0;
+            int surplusStock = 0;
             if (unbox.equals("0")) {// 不是盲盒
-                stock = goblinRedisUtils.getSkuStock(null, skuId);
+                surplusStock = goblinRedisUtils.getSkuStock(null, skuId);
             } else {
                 for (String skuIdItem : skuIdList) {// 盲盒计算所有sku库存总数
                     if (skuIdItem.equals(skuId)) {// 过滤自己
                         continue;
                     }
                     GoblinGoodsSkuInfoVo itemVo = goblinRedisUtils.getGoodsSkuInfoVo(skuIdItem);
-                    stock += goblinRedisUtils.getSkuAllStatusStock(itemVo);
+                    surplusStock += goblinRedisUtils.getSkuAllStatusStock(itemVo);
+                    totalStock += goblinRedisUtils.getSkuTotalStock(itemVo);
                 }
             }
-            if (stock <= 0) {
-                return 0;
-            } else {
-                return 1;
+            if (surplusStock > 0) {
+                isStock = 1;
             }
-        } else {
-            return 0;
         }
+        returnMap.put("isStock", isStock);
+        returnMap.put("totalStock", totalStock);
+        return returnMap;
     }
 
     @Override

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

@@ -1661,6 +1661,19 @@ public class GoblinRedisUtils {
             return false;
         }
     }
+    // 各种状态下判断藏品总库存
+    public Integer getSkuTotalStock(GoblinGoodsSkuInfoVo info) {
+        if (
+            info != null
+            && LocalDateTime.now().isAfter(info.getSaleStartTime())
+            && (null == info.getSoldoutStatus() || info.getSoldoutStatus().equals("0"))
+            && (null == info.getHitRatio() || info.getHitRatio().compareTo(BigDecimal.ZERO) > 0)
+        ) {// 可以返回库存
+            return info.getSkuStock();
+        } else {// 不计入库存
+            return 0;
+        }
+    }
 
     /* ----------------------------------------  ---------------------------------------- */
     /* ----------------------------------------  ---------------------------------------- */