修改消费

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

@@ -199,6 +199,11 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                 GoblinListCollectVo goblinListCollectVo = goblinNftUtils.getCollectByNowNext(nowTime, nftOrder.getSkuId());
                 String listId = (null == goblinListCollectVo) ? null : goblinListCollectVo.getListId();
                 log.debug("listId : {}", listId);
+                String mixId = nftOrder.getMixId();
+                if(mixId!=null && !mixId.equals("")){
+                    listId = mixId;
+                    log.debug("mixId : {}", listId);
+                }
                 if (StringUtils.isEmpty(nftOrder.getBoxSkuId())) {// 购买藏品
                     goblinNftUtils.incrSkuStock(listId, nftOrder.getSkuId(), nftOrder.getNum());
                 } else {// 购买盲盒
@@ -250,8 +255,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                         updateGoblinOrderSkuVo(skuVo.getOrderSkuId(), skuVo);
                         setGoblinOrderSku(skuVo.getOrderSkuId(), skuVo);
                         //库存&限购&&待支付订单
-                        String pre = GoblinStatusConst.MarketPreStatus.getPre(skuVo.getSkuId());
-                        incrSkuStock(pre, skuVo.getSkuId(), skuVo.getNum());
+                        incrSkuStock(orderVo.getMixId(), skuVo.getSkuId(), skuVo.getNum());
                         decrSkuCountByUid(orderVo.getUserId(), skuVo.getSkuId(), skuVo.getNum());
                         //mysql
                         sqlDataSku.add(new Object[]{