修改 脚本库存脚本

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java

@@ -1016,7 +1016,7 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
 
     @Override
     public boolean checkOrderTime(String userId) {
-        String lock = "order_lock:checkOrderTime:" + userId;
+        String lock = "orders_lock:checkOrderTime:" + userId;
         if (redisLockUtil.tryLock(lock, 1, 3600)) {
             try {
                 List<OrderScriptDto> dtoData = orderTicketsMapper.orderScriptDto(userId);
@@ -1111,22 +1111,21 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
 
                     redisLockUtil.unlock(lock);
 
-                    Thread thread = new Thread(new Runnable(){
-                        public void run(){
-                            //redis 列表
-                            orderIdList.forEach(t -> {
-                                String orderTicketId = t.split(",")[0];
-                                String uid = t.split(",")[1];
-                                KylinOrderTicketVo vo = dataUtils.getOrderTicketVo(orderTicketId);
-                                redisUtil.set(KylinRedisConst.ORDER + orderTicketId, vo);
-                                mongoVoUtils.resetOrderListVo(uid, 2, orderTicketId, vo);
-                                // redis 限购
-                                for (int i = 0; i < vo.getEntitiesVoList().size(); i++) {
-                                    KylinOrderTicketEntitiesVo items = vo.getEntitiesVoList().get(i);
-                                    dataUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
-                                }
-                            });
-                        }});
+                    Thread thread = new Thread(() -> {
+                        //redis 列表
+                        orderIdList.forEach(t -> {
+                            String orderTicketId = t.split(",")[0];
+                            String uid = t.split(",")[1];
+                            KylinOrderTicketVo vo = dataUtils.getOrderTicketVo(orderTicketId);
+                            redisUtil.set(KylinRedisConst.ORDER + orderTicketId, vo);
+                            mongoVoUtils.resetOrderListVo(uid, 2, orderTicketId, vo);
+                            // redis 限购
+                            for (int i = 0; i < vo.getEntitiesVoList().size(); i++) {
+                                KylinOrderTicketEntitiesVo items = vo.getEntitiesVoList().get(i);
+                                dataUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
+                            }
+                        });
+                    });
                     thread.start();
                 }