修改 脚本库存脚本

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

@@ -1094,10 +1094,12 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                         orderStr = orderTicketId + ",";
                     }
                     orderStr = orderStr.substring(0, orderStr.length() - 1);
-                    sqls.add(SqlMapping.get("UPDATE kylin_order_tickets SET updated_at = " + now + " WHERE order_tickets_id in (" + orderStr + ") "));
-                    sqls.add(SqlMapping.get("UPDATE kylin_order_ticket_status SET `status` = 2,updated_at = " + now + " WHERE order_id in (" + orderStr + ") "));
-                    sqls.add(SqlMapping.get("UPDATE kylin_order_ticket_relations SET updated_at = " + now + " WHERE order_id in (" + orderStr + ")"));
+                    sqls.add("UPDATE kylin_order_tickets SET updated_at = " + now + " WHERE order_tickets_id in (" + orderStr + ") ");
+                    sqls.add("UPDATE kylin_order_ticket_status SET `status` = 2,updated_at = " + now + " WHERE order_id in (" + orderStr + ") ");
+                    sqls.add("UPDATE kylin_order_ticket_relations SET updated_at = " + now + " WHERE order_id in (" + orderStr + ")");
                     rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE, MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, SqlMapping.gets(sqls));
+                    currentTime = System.currentTimeMillis() - currentTime;
+                    log.debug("mysql -> time:" + (currentTime) + "毫秒");
 
                     //mongo
                     mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
@@ -1107,6 +1109,10 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                     currentTime = System.currentTimeMillis() - currentTime;
                     log.debug("mongo -> time:" + (currentTime) + "毫秒");
 
+                    redisLockUtil.unlock(lock);
+
+                    Thread thread = new Thread(new Runnable(){
+                        public void run(){
                             //redis 列表
                             orderIdList.forEach(t -> {
                                 String orderTicketId = t.split(",")[0];
@@ -1120,8 +1126,8 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                                     dataUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
                                 }
                             });
-                    currentTime = System.currentTimeMillis() - currentTime;
-                    log.debug("redis 列表 限购 -> time:" + (currentTime) + "毫秒");
+                        }});
+                    thread.start();
                 }