增加入库

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

@@ -422,6 +422,11 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
         if (adamEnters.size() != kylinOrderTicketEntitiesVoList.size()) {
             return ResponseDto.failure("入场人数量错误");
         }
+
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsData = CollectionUtil.linkedListObjectArr();
+        sqls.add(SqlMapping.get("kylin_order_refund_entities.supplementEnter"));
+
         for (int i = 0; i < kylinOrderTicketEntitiesVoList.size(); i++) {
             String orderTicketEntitiesId = kylinOrderTicketEntitiesVoList.get(i).getOrderTicketEntitiesId();
             AdamEntersVo adamEntersData = adamEnters.get(i);
@@ -433,7 +438,14 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
                             .append("enterIdCode", adamEntersData.getIdCard())
                             .append("updatedAt", DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now())))
             );
+
+            sqlsData.add(new Object[]{
+                    adamEntersData.getType(), adamEntersData.getName(), adamEntersData.getMobile(), adamEntersData.getIdCard(), LocalDateTime.now(), orderTicketEntitiesId
+            });
         }
+        //入库
+        queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getKey(),
+                SqlMapping.gets(sqls, sqlsData));
         dataUtils.delOrderTicketRedis(orderId);
         return ResponseDto.success();
     }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/sqlmap.properties

@@ -50,3 +50,5 @@ kylin_order_task.delete = DELETE FROM kylin_order_task WHERE order_id = ?;
 kylin_order_ticket_status.transfer.update = UPDATE kylin_order_ticket_status SET transfer_status = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 kylin_order_ticket_relation.transfer.update = UPDATE kylin_order_ticket_relations SET transfer_uid = ?, transfer_id = ? ,updated_at = ?  WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
 
+# ------------------------ 订单补充入场人 ----------------------------
+kylin_order_refund_entities.supplementEnter = UPDATE kylin_order_ticket_entities SET enter_type = ?,enter_name = ?,enter_mobile = ?,enter_id_code = ?,updated_at = ? WHERE order_ticket_entities_id = ?