Mix商品列表JOB任务修改

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

@@ -71,14 +71,34 @@ public class GoblinJobServiceImpl {
 
         LocalDateTime nt = LocalDateTime.now();
         //筛选 活动中 和 活动中且售罄的
+        filterByStateAndEnd(nftDetailsList, mixNftStockList, mixNftStartList, nt);
+
+        filterByStateAndEnd(skuDetailsList, mixSkuStockList, mixSkuStartList, nt);
+
+
+        goblinRedisUtils.setGoblinMixNftStartList(mixNftStartList);
+        goblinRedisUtils.setGoblinMixNftStockList(mixNftStockList);
+        goblinRedisUtils.setGoblinMixSkuStartList(mixSkuStartList);
+        goblinRedisUtils.setGoblinMixSkuStockList(mixSkuStockList);
+
+        return ResponseDto.success();
+    }
+
+    private void filterByStateAndEnd(List<GoblinMixDetailsVo> nftDetailsList, List<String> mixNftStockList, List<String> mixNftStartList, LocalDateTime nt) {
         for (GoblinMixDetailsVo item : nftDetailsList) {
-            LocalDateTime st = LocalDateTime.parse(item.getTimeStart(), DTF_YMD_HMS);
+            //结束时间
             LocalDateTime et = LocalDateTime.parse(item.getTimeEnd(), DTF_YMD_HMS);
-            if (nt.isAfter(st) && nt.isBefore(et)) {//活动中
+
             int stock = 0;
+            //活动中按上架时间和结束时间算  没有上架时间按照开始时间算
+            if (item.getShelvesTime() != null) {
+                //上架时间
+                LocalDateTime ts = LocalDateTime.parse(item.getShelvesTime(), DTF_YMD_HMS);
+                //有上架时间
+                if (nt.isAfter(ts) && nt.isBefore(et)) {
                     for (GoblinMixDetailsItemVo itemVo : item.getItem()) {
                         GoblinGoodsSkuInfoVo skuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(itemVo.getSkuId());
-                    if (skuInfoVo.getUnbox().equals("1")) {
+                        if ("1".equals(skuInfoVo.getUnbox())) {
                             List<String> relationIds = goblinRedisUtils.getGoblinMixRelationBox(itemVo.getSkuId(), item.getMixId());
                             for (String skuId : relationIds) {
                                 stock += goblinRedisUtils.getSkuStock(item.getMixId(), skuId);
@@ -87,24 +107,15 @@ public class GoblinJobServiceImpl {
                             stock += goblinRedisUtils.getSkuStock(item.getMixId(), itemVo.getSkuId());
                         }
                     }
-                if (stock == 0) {//活动中 且 售罄
-                    mixNftStockList.add(item.getMixId());
-//                    goblinRedisUtils.addGoblinMixNftStockList(item.getMixId());
-                } else {//活动中 未售罄
-                    mixNftStartList.add(item.getMixId());
-//                    goblinRedisUtils.addGoblinMixNftStartList(item.getMixId());
-                }
-            }
                 }
-
-        for (GoblinMixDetailsVo item : skuDetailsList) {
+            } else {
+                //开始时间
                 LocalDateTime st = LocalDateTime.parse(item.getTimeStart(), DTF_YMD_HMS);
-            LocalDateTime et = LocalDateTime.parse(item.getTimeEnd(), DTF_YMD_HMS);
-            if (nt.isAfter(st) && nt.isBefore(et)) {//活动中
-                int stock = 0;
+                //没有上架时间
+                if (nt.isAfter(st) && nt.isBefore(et)) {
                     for (GoblinMixDetailsItemVo itemVo : item.getItem()) {
                         GoblinGoodsSkuInfoVo skuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(itemVo.getSkuId());
-                    if (skuInfoVo.getUnbox().equals("1")) {
+                        if ("1".equals(skuInfoVo.getUnbox())) {
                             List<String> relationIds = goblinRedisUtils.getGoblinMixRelationBox(itemVo.getSkuId(), item.getMixId());
                             for (String skuId : relationIds) {
                                 stock += goblinRedisUtils.getSkuStock(item.getMixId(), skuId);
@@ -113,22 +124,14 @@ public class GoblinJobServiceImpl {
                             stock += goblinRedisUtils.getSkuStock(item.getMixId(), itemVo.getSkuId());
                         }
                     }
-                if (stock == 0) {//活动中 且 售罄
-                    mixSkuStockList.add(item.getMixId());
-//                    goblinRedisUtils.addGoblinMixSkuStockList(item.getMixId());
-                } else {//活动中 未售罄
-                    mixSkuStartList.add(item.getMixId());
-//                    goblinRedisUtils.addGoblinMixSkuStartList(item.getMixId());
                 }
             }
+            //活动中 且 售罄
+            if (stock == 0) {
+                mixNftStockList.add(item.getMixId());
+            } else {//活动中 未售罄
+                mixNftStartList.add(item.getMixId());
+            }
         }
-
-
-        goblinRedisUtils.setGoblinMixNftStartList(mixNftStartList);
-        goblinRedisUtils.setGoblinMixNftStockList(mixNftStockList);
-        goblinRedisUtils.setGoblinMixSkuStartList(mixSkuStartList);
-        goblinRedisUtils.setGoblinMixSkuStockList(mixSkuStockList);
-
-        return ResponseDto.success();
     }
 }