修改 分批购 获取当前时间段 和 下一个时间段的bug

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/utils/GoblinNftUtils.java

@@ -87,7 +87,7 @@ public class GoblinNftUtils {
     }
 
     /**
-     * 根据时间获取当前分段购vo
+     * 根据时间获取当前分段购vo 如果当前没有返回下一个
      *
      * @param now
      * @param skuId
@@ -110,6 +110,8 @@ public class GoblinNftUtils {
                 if (collectNext == null || collectNext.getTimeStart().isAfter(collectNext.getTimeStart())) {
                     collectNext = collectVoItem;
                 }
+            }else if(collectVoItem.getTimeEnd() != null && now.isAfter(collectVoItem.getTimeEnd())){
+                collectTemp = null;
             }
         }
         if (collectVo == null && collectTemp != null) {
@@ -117,8 +119,6 @@ public class GoblinNftUtils {
         } else if (collectVo == null) {
             collectVo = collectNext;
         }
-
-//        lastStockToLastStock(1,collectVos, collectVo, skuId);
         return collectVo;
     }
 

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

@@ -863,6 +863,8 @@ public class GoblinRedisUtils {
             } else if (now.isAfter(collectVoItem.getTimeStart()) && now.isBefore(collectVoItem.getTimeEnd())) {
                 collectVo = collectVoItem;
                 break;
+            }else if(collectVoItem.getTimeEnd() != null && now.isAfter(collectVoItem.getTimeEnd())){
+                collectTemp = null;
             }
         }
         if (collectVo == null) {
@@ -905,6 +907,8 @@ public class GoblinRedisUtils {
                 if (collectNext == null || collectNext.getTimeStart().isAfter(collectNext.getTimeStart())) {
                     collectNext = collectVoItem;
                 }
+            }else if(collectVoItem.getTimeEnd() != null && now.isAfter(collectVoItem.getTimeEnd())){
+                collectTemp = null;
             }
         }
         if (collectVo == null && collectTemp != null) {

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/GoblinRedisUtils.java

@@ -231,6 +231,8 @@ public class GoblinRedisUtils {
             } else if (now.isAfter(collectVoItem.getTimeStart()) && now.isBefore(collectVoItem.getTimeEnd())) {
                 collectVo = collectVoItem;
                 break;
+            }else if(collectVoItem.getTimeEnd() != null && now.isAfter(collectVoItem.getTimeEnd())){
+                collectTemp = null;
             }
         }
         if (collectVo == null) {
@@ -264,6 +266,8 @@ public class GoblinRedisUtils {
                 if (collectNext == null || collectNext.getTimeStart().isAfter(collectNext.getTimeStart())) {
                     collectNext = collectVoItem;
                 }
+            }else if(collectVoItem.getTimeEnd() != null && now.isAfter(collectVoItem.getTimeEnd())){
+                collectTemp = null;
             }
         }
         if (collectVo == null && collectTemp != null) {