修改 代码分段购库存回滚逻辑

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

@@ -295,27 +295,42 @@ public class GoblinRedisUtils {
             }
         } else if (vo != null && type == 1) {
             LocalDateTime st = vo.getTimeStart().minusSeconds(1);
-            GoblinListCollectVo collectVo = null;
-            GoblinListCollectVo collectTemp = null;
+//            GoblinListCollectVo collectVo = null;
+//            GoblinListCollectVo collectTemp = null;
             //获取上个分配购的vo
+            List<GoblinListCollectVo> collectVosList = ObjectUtil.getGoblinListCollectVo();
             for (GoblinListCollectVo collectVoItem : collectVos) {
                 if (st.isAfter(collectVoItem.getTimeStart()) && collectVoItem.getTimeEnd() == null) {
-                    collectTemp = collectVoItem;
+//                    collectTemp = collectVoItem;
+                    collectVosList.add(collectVoItem);
                 } else if (st.isAfter(collectVoItem.getTimeStart()) && st.isBefore(collectVoItem.getTimeEnd())) {
-                    collectVo = collectVoItem;
+//                    collectVo = collectVoItem;
+                    collectVosList.add(collectVoItem);
                     break;
                 }
             }
-            if (collectVo == null) {
-                collectVo = collectTemp;
-            }
-            if (collectVo != null) {
+//            if (collectVo == null) {
+//                collectVo = collectTemp;
+//            }
+//            if (collectVo != null) {
+//                //减少上个时间段sku库存
+//                int lastStock = getSkuStock(collectVo.getListId(), skuId);
+//                int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
+//                if (restStock < 0) {
+//                    //库存超过销售量 操作失败回滚库存
+//                    incrSkuStock(collectVo.getListId(), skuId, lastStock);
+//                } else {
+//                    //上个时间段的库存增加到当前时间段
+//                    incrSkuStock(vo.getListId(), skuId, lastStock);
+//                }
+//            }
+            for (GoblinListCollectVo itemVo : collectVosList){
                 //减少上个时间段sku库存
-                int lastStock = getSkuStock(collectVo.getListId(), skuId);
-                int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
+                int lastStock = getSkuStock(itemVo.getListId(), skuId);
+                int restStock = decrSkuStock(itemVo.getListId(), skuId, lastStock);
                 if (restStock < 0) {
                     //库存超过销售量 操作失败回滚库存
-                    incrSkuStock(collectVo.getListId(), skuId, lastStock);
+                    incrSkuStock(itemVo.getListId(), skuId, lastStock);
                 } else {
                     //上个时间段的库存增加到当前时间段
                     incrSkuStock(vo.getListId(), skuId, lastStock);
@@ -324,6 +339,7 @@ public class GoblinRedisUtils {
         }
     }
 
+
     /**
      * 分段购获取
      *