修改 库存回滚

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/goblin/DMCheckGoblinOrderTimeImpl.java

@@ -69,6 +69,7 @@ public class DMCheckGoblinOrderTimeImpl extends ServiceImpl<GoblinStoreOrderMapp
                     goblinRedisUtils.removeGoblinOrder(i + "", orderId);
                     continue;
                 }
+                log.debug("ORDERDATA = " + orderVo);
                 LocalDateTime expireTime = LocalDateTime.parse(orderVo.getCreatedAt(), DTF_YMD_HMS).plusMinutes(orderVo.getPayCountdownMinute() + 1);
                 if (now.isAfter(expireTime) && orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_0.getValue()) {//过期
                     LinkedList<String> sqls = CollectionUtil.linkedListString();
@@ -76,14 +77,20 @@ public class DMCheckGoblinOrderTimeImpl extends ServiceImpl<GoblinStoreOrderMapp
                     LinkedList<Object[]> sqlDataSku = CollectionUtil.linkedListObjectArr();
                     sqls.add(SqlMapping.get("goblin_order.close.order"));
                     sqls.add(SqlMapping.get("goblin_order.close.sku"));
-                    for (String skuId : orderVo.getOrderSkuVoIds()) {
-                        GoblinOrderSkuVo skuVo = goblinRedisUtils.getGoblinOrderSkuVo(skuId);
+                    for (String orderSkuId : orderVo.getOrderSkuVoIds()) {
+                        GoblinOrderSkuVo skuVo = goblinRedisUtils.getGoblinOrderSkuVo(orderSkuId);
                         //订单详情
                         skuVo.setStatus(GoblinStatusConst.Status.ORDER_STATUS_5.getValue());
                         updateGoblinOrderSkuVo(skuVo.getOrderSkuId(), skuVo);
                         goblinRedisUtils.setGoblinOrderSku(skuVo.getOrderSkuId(), skuVo);
                         //库存&限购&&待支付订单
-                        goblinRedisUtils.incrSkuStock("pre", skuVo.getSkuId(), skuVo.getNum());
+                        String pre = GoblinStatusConst.MarketPreStatus.getPre(skuVo.getSkuId());
+                        if (pre == null) {
+                            goblinRedisUtils.incrSkuStock(pre, skuVo.getSkuId(), skuVo.getNum());
+                        } else {
+                            goblinRedisUtils.incrSkuStock(pre, skuVo.getSkuId().split(pre)[0], skuVo.getNum());
+                        }
+
                         goblinRedisUtils.decrSkuCountByUid(orderVo.getUserId(), skuVo.getSkuId(), skuVo.getNum());
                         //mysql
                         sqlDataSku.add(new Object[]{
@@ -102,7 +109,7 @@ public class DMCheckGoblinOrderTimeImpl extends ServiceImpl<GoblinStoreOrderMapp
                     //执行sql
                     queueUtils.sendMsgByGoblinRedis(MQConst.KylinQueue.SQL_ORDER_CLOSE.getKey(),
                             SqlMapping.gets(sqls, sqlDataOrder, sqlDataSku));
-                }else if(orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_5.getValue()||orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_2.getValue()){
+                } else if (orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_5.getValue() || orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_2.getValue()) {
                     goblinRedisUtils.removeGoblinOrder(i + "", orderVo.getOrderId());
                 }
             }