提交 迁移 演出脚本

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

@@ -51,9 +51,9 @@ public class DataImpl {
     public boolean performance() {
         try {
             String driverClassName = "com.mysql.cj.jdbc.Driver";    //启动驱动
-            String url = "jdbc:mysql://39.106.122.201:3308/testmall";    //设置连接路径
-            String username = "testmall";    //数据库用户名
-            String password = "zhengzai!mYT";    //数据库连接密码
+            String url = "jdbc:mysql://zhengzai.mysql.polardb.rds.aliyuncs.com:3306/mall";    //设置连接路径
+            String username = "readonly";    //数据库用户名
+            String password = "ZWDsf8Fy";    //数据库连接密码
             Connection con = null;        //连接
             PreparedStatement pstmt = null;    //使用预编译语句
             ResultSet rs = null;    //获取的结果集
@@ -74,12 +74,12 @@ public class DataImpl {
             KylinTicketPartnerVo ticketPartnerVo = new KylinTicketPartnerVo();
 
             int count = 100;
-            int page = 0;
+            int page = 4;
 
             try {
                 Class.forName(driverClassName); //执行驱动
                 con = DriverManager.getConnection(url, username, password); //获取连接
-                String sqlAllCount = "select count(0) as 'allCount' from performances where status >= 3"; //设置的预编译语句格式
+                String sqlAllCount = "select count(0) as 'allCount' from performances where status >= 3 and created_at > '2021-01-01 00:00:01'"; //设置的预编译语句格式
                 pstmt = con.prepareStatement(sqlAllCount);
                 ResultSet allCount = pstmt.executeQuery();
                 ArrayList<String> performanceIds = new ArrayList<>();
@@ -91,7 +91,7 @@ public class DataImpl {
                 }
 
                 do {
-                    String sql = "select * from performances where status >= 3 limit " + count * page + " ," + count; //设置的预编译语句格式
+                    String sql = "select * from performances where status >= 3 and created_at > '2021-01-01 00:00:01' limit " + count * page + " ," + count; //设置的预编译语句格式
                     pstmt = con.prepareStatement(sql);
                     ResultSet resultData = pstmt.executeQuery();
                     int performanceId = 0;
@@ -119,7 +119,9 @@ public class DataImpl {
                         performances.setNoticeImage("[{\"id\":1,\"sort\":1,\"text\":\"因演出票品非普通商品，其背后承载的文化服务具有时效性、稀缺性等特征，故不适用7天无理由退货政策。因“不可抗力”导致的演出取消或延期除外。\",\"title\":\"门票退换\",\"type\":\"image\",\"url\":\"http://img-zhengzai-tv.oss-cn-hangzhou.aliyuncs.com/partner/2019/01/21/5c45722882a13.png\"},{\"id\":7,\"sort\":2,\"text\":\"凭订单二维码或手机号兑票入场，二维码或手机号请勿泄露，以免影响入场。个人原因导致的信息泄露，主办方/平台方不承担任何责任。\",\"title\":\"电子票\",\"type\":\"image\",\"url\":\"http://img-zhengzai-tv.oss-cn-hangzhou.aliyuncs.com/partner/2019/01/21/5c456d9482fb9.png\"},{\"id\":3,\"sort\":3,\"text\":\"本场演出不设座位，均为站席观演。\",\"title\":\"仅设站席\",\"type\":\"image\",\"url\":\"http://img-zhengzai-tv.oss-cn-hangzhou.aliyuncs.com/partner/2019/01/21/5c456e93db0b9.png\"},{\"id\":12,\"sort\":4,\"text\":\"每场现场票数量由场地方决定，具体请到现场询问。\",\"title\":\"现场票\",\"type\":\"image\",\"url\":\"http://img-zhengzai-tv.oss-cn-hangzhou.aliyuncs.com/partner/2019/06/17/5d07647eaa55f.png\"}]");
                         performances.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("time_start").toString()));
                         performances.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmssS.parse(resultData.getTimestamp("time_end").toString()));
-                        performances.setAuditTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(resultData.getString("audit_submit_time")));
+                        if(null!=resultData.getString("audit_submit_time")) {
+                            performances.setAuditTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(resultData.getString("audit_submit_time")));
+                        }
                         performances.setRejectTxt(resultData.getString("reject_text"));
                         performances.setSort(resultData.getInt("sort"));
                         performances.setComment("");
@@ -283,7 +285,9 @@ public class DataImpl {
                             tickets.setAdvanceMinuteMember(5);
                             tickets.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("time_start").toString()));
                             tickets.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("time_end").toString()));
-                            tickets.setTimeEndExpress(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("time_end_express").toString()));
+                            if(null!=ticketData.getTimestamp("time_end_express")) {
+                                tickets.setTimeEndExpress(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("time_end_express").toString()));
+                            }
                             tickets.setUseStart(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("use_start").toString()));
                             tickets.setUseEnd(DateUtil.Formatter.yyyyMMddHHmmssS.parse(ticketData.getTimestamp("use_end").toString()));
                             tickets.setPayCountdownMinute(5);
@@ -383,12 +387,12 @@ public class DataImpl {
 
                     resultData.last();
                     rowCount += resultData.getRow();
-                    if (allCountResult > rowCount) {
-                        isBreak = true;
-                        page+=1;
-                    } else {
-                        isBreak = false;
-                    }
+//                    if (allCountResult > rowCount) {
+//                        isBreak = true;
+//                        page+=1;
+//                    } else {
+//                        isBreak = false;
+//                    }
                 } while (isBreak);
                 return true;
             } catch (Exception e) {