数据迁移修改(订单维度)

修改订单超时时间

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinOrderTicketRelationsService.java

+package com.liquidnet.service.kylin.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketRelations;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketStatus;
+
+/**
+ * <p>
+ * 订单 服务类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-20
+ */
+public interface IKylinOrderTicketRelationsService extends IService<KylinOrderTicketRelations> {
+
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinOrderTicketStatusService.java

+package com.liquidnet.service.kylin.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.github.pagehelper.PageInfo;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.dto.param.PayAgainParam;
+import com.liquidnet.service.kylin.dto.param.PayOrderParam;
+import com.liquidnet.service.kylin.dto.param.SyncOrderParam;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
+import com.liquidnet.service.kylin.dto.vo.returns.OrderDetailsVo;
+import com.liquidnet.service.kylin.dto.vo.returns.PayResultVo;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketStatus;
+import com.liquidnet.service.kylin.entity.KylinOrderTickets;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 订单 服务类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-20
+ */
+public interface IKylinOrderTicketStatusService extends IService<KylinOrderTicketStatus> {
+
+}

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

@@ -28,7 +28,7 @@ public class DataController {
 
     @PostMapping("order")
     @ApiOperation("订单数据迁移")
-    public ResponseDto<Boolean> order(int month) {
+    public ResponseDto<Boolean> order(String month) {
         Boolean result = data.order(month);
         return ResponseDto.success(result);
     }

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

@@ -7,22 +7,22 @@ import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
-import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketEntitiesService;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketRelationsService;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketStatusService;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketsService;
 import com.liquidnet.service.kylin.timerTask.PerformanceVoTask;
 import com.liquidnet.service.kylin.utils.DataUtils;
-import com.liquidnet.service.kylin.utils.MongoVoUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
-import org.springframework.data.mongodb.core.convert.MongoConverter;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.sql.*;
-import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -52,13 +52,13 @@ public class DataImpl {
     private PerformanceVoTask performanceVoTask;
 
     @Autowired
-    private KylinOrderTicketsMapper orderTicketsMapper;
+    private IKylinOrderTicketsService kylinOrderTicketsService;
     @Autowired
-    private KylinOrderTicketStatusMapper orderTicketStatusMapper;
+    private IKylinOrderTicketStatusService kylinOrderTicketStatusService;
     @Autowired
-    private KylinOrderTicketRelationsMapper orderTicketRelationsMapper;
+    private IKylinOrderTicketRelationsService kylinOrderTicketRelationsService;
     @Autowired
-    private KylinOrderTicketEntitiesMapper orderTicketEntitiesMapper;
+    private IKylinOrderTicketEntitiesService kylinOrderTicketEntitiesService;
 
     @Autowired
     private DataUtils dataUtils;
@@ -437,7 +437,7 @@ public class DataImpl {
         }
     }
 
-    public boolean order(int month) {
+    public boolean order(String month) {
 
         String driverClassName = "com.mysql.cj.jdbc.Driver";    //启动驱动
         String url = "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/mall";    //设置连接路径
@@ -447,22 +447,17 @@ public class DataImpl {
         PreparedStatement pstmt = null;    //使用预编译语句
         ResultSet rs = null;    //获取的结果集
 
-        KylinOrderTickets orderTickets = new KylinOrderTickets();
-        KylinOrderTicketStatus orderTicketStatus = new KylinOrderTicketStatus();
-        KylinOrderTicketRelations orderTicketRelations = new KylinOrderTicketRelations();
-        KylinOrderTicketEntities orderTicketEntities = new KylinOrderTicketEntities();
-
         KylinOrderTicketVo orderTicketVo = new KylinOrderTicketVo();
-        ArrayList<KylinOrderTicketEntitiesVo> entitiesVosList = new ArrayList<>();
         try {
 
-            int count = 200;
+            int count = 1000;
             int page = 0;
 
             Class.forName(driverClassName); //执行驱动
             con = DriverManager.getConnection(url, username, password); //获取连接
-//            String sqlAllCount = "select count(0) as 'allCount' from order_tickets where performance_id  > 5721 and status != 2 and created_at like '2021-" + month + "%'"; //设置的预编译语句格式
-            String sqlAllCount = "select count(0) as 'allCount' from order_tickets where performance_id = "+month + " and status != 2 and status !=-1"; //设置的预编译语句格式
+            String sqlAllCount = "select count(0) as 'allCount' from order_tickets where performance_id  > 5721 and status != 2 and created_at like '2021-" + month + "%'"; //设置的预编译语句格式
+//            String sqlAllCount = "select count(0) as 'allCount' from order_tickets where performance_id = "+month + " and status != 2 and status !=-1"; //设置的预编译语句格式
+            System.out.println(" SQL COUNT = "+sqlAllCount);
             pstmt = con.prepareStatement(sqlAllCount);
             ResultSet allCount = pstmt.executeQuery();
             int allCountResult = 0;//共多少条
@@ -473,12 +468,27 @@ public class DataImpl {
             }
 
             do {
+                ArrayList<KylinOrderTickets> orderList = new ArrayList();
+                ArrayList<KylinOrderTicketStatus> orderStatusList = new ArrayList();
+                ArrayList<KylinOrderTicketRelations> orderRelationList = new ArrayList();
+                ArrayList<KylinOrderTicketEntities> orderEntitiesList = new ArrayList();
+
+                ArrayList<KylinOrderTicketVo> orderListVo = new ArrayList();
+                ArrayList<KylinOrderTicketEntitiesVo> orderEntitiesListVo = new ArrayList();
                 //订单
-//                String sql = "select * from order_tickets where performance_id  > 5721 and status != 2 and created_at like '2021-" + month + "%' limit " + count * page + " ," + count; //设置的预编译语句格式
-                String sql = "select *  from order_tickets where performance_id = "+month +" and status != 2 limit " + count * page + " ," + count;
+                String sql = "select * from order_tickets where performance_id  > 5721 and status != 2 and created_at like '2021-" + month + "%' limit " + count * page + " ," + count; //设置的预编译语句格式
+//                String sql = "select *  from order_tickets where performance_id = "+month +" and status != 2 limit " + count * page + " ," + count;
+                System.out.println(" SQL DATA = "+sql);
                 pstmt = con.prepareStatement(sql);
                 ResultSet orderData = pstmt.executeQuery();
                 while (orderData.next()) {
+
+                    KylinOrderTickets orderTickets = new KylinOrderTickets();
+                    KylinOrderTicketStatus orderTicketStatus = new KylinOrderTicketStatus();
+                    KylinOrderTicketRelations orderTicketRelations = new KylinOrderTicketRelations();
+                    KylinOrderTicketEntities orderTicketEntities = new KylinOrderTicketEntities();
+
+                    ArrayList<KylinOrderTicketEntitiesVo> entitiesVosList = new ArrayList<>();
                     String ticketSql = "select student,use_end,use_start,title,type from tickets where id = " + orderData.getInt("ticket_id"); //设置的预编译语句格式
                     pstmt = con.prepareStatement(ticketSql);
                     ResultSet ticketData = pstmt.executeQuery();
@@ -581,9 +591,12 @@ public class DataImpl {
                     orderTicketRelations.setCreatedAt(orderTickets.getCreatedAt());
                     orderTicketRelations.setUpdatedAt(orderTickets.getUpdatedAt());
 
-                    orderTicketsMapper.insert(orderTickets);
-                    orderTicketStatusMapper.insert(orderTicketStatus);
-                    orderTicketRelationsMapper.insert(orderTicketRelations);
+                    orderList.add(orderTickets);
+                    orderStatusList.add(orderTicketStatus);
+                    orderRelationList.add(orderTicketRelations);
+//                    orderTicketsMapper.insert(orderTickets);
+//                    orderTicketStatusMapper.insert(orderTicketStatus);
+//                    orderTicketRelationsMapper.insert(orderTicketRelations);
                     //vo
                     orderTicketVo.setMid(0);
                     orderTicketVo.setOrderTicketsId(orderTickets.getOrderTicketsId());
@@ -641,8 +654,6 @@ public class DataImpl {
                     orderTicketVo.setTicketType(ticketType);
                     orderTicketVo.setFieldName((String) redisUtil.hget(KylinRedisConst.FIELDS + ":" + orderTicketRelations.getPerformanceId(), "name"));
 
-                    mongoTemplate.insert(orderTicketVo, KylinOrderTicketVo.class.getSimpleName());
-
                     //入场人
                     String enterSql = "select * from order_ticket_entities where order_id = " + orderTickets.getOrderTicketsId(); //设置的预编译语句格式
                     pstmt = con.prepareStatement(enterSql);
@@ -686,7 +697,8 @@ public class DataImpl {
                             orderTicketEntities.setUpdatedAt(DateUtil.Formatter.yyyyMMddHHmmssS.parse(orderData.getTimestamp("updated_at").toString()));
                         }
 
-                        orderTicketEntitiesMapper.insert(orderTicketEntities);
+                        orderEntitiesList.add(orderTicketEntities);
+//                        orderTicketEntitiesMapper.insert(orderTicketEntities);
                         //vo
                         entitiesVo.setMid(0);
                         entitiesVo.setOrderTicketEntitiesId(orderTicketEntities.getOrderTicketEntitiesId());
@@ -712,12 +724,23 @@ public class DataImpl {
                         entitiesVo.setTicketsmId(0);
                         entitiesVo.setTimemId(0);
                         entitiesVo.setChangeDate(orderTicketEntities.getUpdatedAt() == null ? orderTicketEntities.getUpdatedAt() : orderTicketEntities.getCreatedAt());
-                        mongoTemplate.insert(entitiesVo, KylinOrderTicketEntitiesVo.class.getSimpleName());
+//                        mongoTemplate.insert(entitiesVo, KylinOrderTicketEntitiesVo.class.getSimpleName());
                         entitiesVosList.add(entitiesVo);
+                        orderEntitiesListVo.add(entitiesVo);
                     }
                     orderTicketVo.setEntitiesVoList(entitiesVosList);
+                    orderListVo.add(orderTicketVo);
+//                    mongoTemplate.insert(orderTicketVo, KylinOrderTicketVo.class.getSimpleName());
                 }
 
+                kylinOrderTicketsService.saveBatch(orderList);
+                kylinOrderTicketStatusService.saveBatch(orderStatusList);
+                kylinOrderTicketRelationsService.saveBatch(orderRelationList);
+                kylinOrderTicketEntitiesService.saveBatch(orderEntitiesList);
+
+                mongoTemplate.insert(orderListVo, KylinOrderTicketVo.class.getSimpleName());
+                mongoTemplate.insert(orderEntitiesListVo,KylinOrderTicketEntitiesVo.class.getSimpleName());
+
                 orderData.last();
                 rowCount += orderData.getRow();
                 if (allCountResult > rowCount) {

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

+package com.liquidnet.service.kylin.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketRelations;
+import com.liquidnet.service.kylin.entity.KylinTickets;
+import com.liquidnet.service.kylin.mapper.KylinOrderTicketRelationsMapper;
+import com.liquidnet.service.kylin.mapper.KylinTicketsMapper;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketRelationsService;
+import com.liquidnet.service.kylin.service.IKylinTicketsService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 票 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-06
+ */
+@Service
+public class KylinOrderTicketRelationsImpl extends ServiceImpl<KylinOrderTicketRelationsMapper, KylinOrderTicketRelations> implements IKylinOrderTicketRelationsService {
+
+}

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

+package com.liquidnet.service.kylin.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.service.kylin.entity.KylinOrderTicketStatus;
+import com.liquidnet.service.kylin.entity.KylinTickets;
+import com.liquidnet.service.kylin.mapper.KylinOrderTicketStatusMapper;
+import com.liquidnet.service.kylin.mapper.KylinTicketsMapper;
+import com.liquidnet.service.kylin.service.IKylinOrderTicketStatusService;
+import com.liquidnet.service.kylin.service.IKylinTicketsService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 票 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-06
+ */
+@Service
+public class KylinOrderTicketStatusImpl extends ServiceImpl<KylinOrderTicketStatusMapper, KylinOrderTicketStatus> implements IKylinOrderTicketStatusService {
+
+}

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

@@ -605,7 +605,7 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
         orderTicketVo.setTicketTitle(ticketData.getTitle());
         orderTicketVo.setUseStart(ticketData.getUseStart());
         orderTicketVo.setTimeStart(performanceData.getTimeStart());
-        orderTicketVo.setOverdueAt(orderTickets.getCreatedAt().plusMinutes(performanceData.getPayCountdownMinute()).plusSeconds(15).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+        orderTicketVo.setOverdueAt(orderTickets.getCreatedAt().plusMinutes(performanceData.getPayCountdownMinute()).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
         orderTicketVo.setCreatedAt(orderTickets.getCreatedAt().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
         orderTicketVo.setChangeDate(orderTickets.getCreatedAt());
         currentTime = System.currentTimeMillis();