修改 脚本库存脚本

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

@@ -1027,7 +1027,6 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                 HashMap<String, Object> mapMongo = new HashMap<>();
 
                 for (OrderScriptDto item : dtoData) {
-                    LinkedList<String> sqls = new LinkedList<>();
                     if (item.getStatus().equals(KylinTableStatusConst.ORDER_STATUS0)) {
                         try {
 //                            KylinOrderTicketVo vo = dataUtils.getOrderTicketVo(item.getOrderTicketsId());
@@ -1069,20 +1068,6 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
 //                                KylinOrderTicketEntitiesVo items = entities.get(i);
 //                                dataUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
 //                            }
-
-                            sqls.add(SqlMapping.get("kylin_order_ticket.close"));
-                            LinkedList<Object[]> sqlsDataA = new LinkedList<>();
-                            sqlsDataA.add(orderTickets.getCloseOrderObject());
-
-                            sqls.add(SqlMapping.get("kylin_order_ticket_status.close"));
-                            LinkedList<Object[]> sqlsDataB = new LinkedList<>();
-                            sqlsDataB.add(orderTicketStatus.getCloseOrderObject());
-
-                            sqls.add(SqlMapping.get("kylin_order_ticket_relation.close"));
-                            LinkedList<Object[]> sqlsDataC = new LinkedList<>();
-                            sqlsDataC.add(new Object[]{orderTickets.getUpdatedAt(), orderTickets.getOrderTicketsId()});
-
-                            rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE, MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC));
                         } catch (Exception e) {
                             log.debug("CHECK TIME SYNC = " + e.getMessage());
                             e.printStackTrace();
@@ -1101,6 +1086,19 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                 }
                 currentTime = System.currentTimeMillis() - currentTime;
                 log.debug("redis 库存 -> time:" + (currentTime) + "毫秒");
+                //mysql
+                LinkedList<String> sqls = new LinkedList<>();
+                String orderStr = "";
+                for (int i = 0; i < orderIdList.size(); i++) {
+                    String orderTicketId = orderIdList.get(i).split(",")[0];
+                    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 + ")"));
+                rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE, MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, SqlMapping.gets(sqls));
+
                 //mongo
                 mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("orderTicketsId").in(orderIdList)).getQueryObject(),