回滚库存 listid用购买藏品的 不管是普通还是盲盒

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/receiver/AbstractOrderCloseReceiver.java

@@ -170,7 +170,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                 // 库存购买数量回滚
                 goblinNftUtils.decrSkuCountByUid(nftOrder.getUserId(), nftOrder.getSkuId(), nftOrder.getNum());
                 LocalDateTime nowTime = LocalDateTime.now();
-                if (StringUtils.isEmpty(nftOrder.getBoxSkuId())) {// 购买藏品
+                /*if (StringUtils.isEmpty(nftOrder.getBoxSkuId())) {// 购买藏品
                     GoblinListCollectVo goblinListCollectVo = goblinNftUtils.getCollectByNowNext(nowTime, nftOrder.getSkuId());
                     String listId = (null == goblinListCollectVo) ? null : goblinListCollectVo.getListId();
                     log.debug("listId : {}",listId);
@@ -180,6 +180,14 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                     String listId = (null == goblinListCollectVo) ? null : goblinListCollectVo.getListId();
                     log.debug("listId : {}",listId);
                     goblinNftUtils.incrSkuStock(listId, nftOrder.getBoxSkuId(), nftOrder.getNum());
+                }*/
+                GoblinListCollectVo goblinListCollectVo = goblinNftUtils.getCollectByNowNext(nowTime, nftOrder.getSkuId());
+                String listId = (null == goblinListCollectVo) ? null : goblinListCollectVo.getListId();
+                log.debug("listId : {}",listId);
+                if (StringUtils.isEmpty(nftOrder.getBoxSkuId())) {// 购买藏品
+                    goblinNftUtils.incrSkuStock(listId, nftOrder.getSkuId(), nftOrder.getNum());
+                } else {// 购买盲盒
+                    goblinNftUtils.incrSkuStock(listId, nftOrder.getBoxSkuId(), nftOrder.getNum());
                 }
 
                 // 订单状态