修复 限购未回滚的bug

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

@@ -237,7 +237,8 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
             HashMap<String, String[]> map = getMixMasterCode(orderCode);
             String[] nft = map.get("nft");
             String[] goblin = map.get("goblin");
-
+            String mixId = "";
+            String uid = "";
             for (String orderId : goblin) {
                 if ("".equals(orderId)) {
                     break;
@@ -257,8 +258,10 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                         setGoblinOrderSku(skuVo.getOrderSkuId(), skuVo);
                         //库存&限购&&待支付订单
                         int count = incrSkuStock(orderVo.getMixId(), skuVo.getSkuId(), skuVo.getNum());
-                        int limit = decrMixLimit(orderVo.getMixId(),orderVo.getUserId());
-                        log.debug("count {} limit {}",count,limit);
+                        if ("".equals(mixId) && "".equals(uid)) {
+                            mixId = orderVo.getMixId();
+                            uid = orderVo.getUserId();
+                        }
                         //mysql
                         sqlDataSku.add(new Object[]{
                                 skuVo.getStatus(), now, skuVo.getOrderSkuId(), now, now
@@ -293,9 +296,14 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                 if ("".equals(orderId)) {
                     break;
                 }
+                if ("".equals(mixId) && "".equals(uid)) {
+                    GoblinNftOrderVo nftOrder = goblinNftUtils.getNftOrder(orderId);
+                    mixId = nftOrder.getMixId();
+                    uid = nftOrder.getUserId();
+                }
                 checkNftOrderTime(orderId);
             }
-
+            int limit = decrMixLimit(mixId, uid);
 
         } catch (Exception e) {
             log.error("MIX库存回滚异常valueData={}", orderCode, e);