diff --git a/src/main/java/com/peanut/common/utils/UserCourseBuyUtil.java b/src/main/java/com/peanut/common/utils/UserCourseBuyUtil.java index f7c508ef..326b213a 100644 --- a/src/main/java/com/peanut/common/utils/UserCourseBuyUtil.java +++ b/src/main/java/com/peanut/common/utils/UserCourseBuyUtil.java @@ -13,7 +13,7 @@ public class UserCourseBuyUtil { //批量开课 public static void main(String[] args) { - userEbookBuy250410(); +// userEbookBuy250410(); // userCourseBuy(); // userEbookBuy(); // userCourseBuyShopProductCourse(); @@ -144,31 +144,45 @@ public class UserCourseBuyUtil { Connection fzdsconn = DriverManager.getConnection( "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true", "nuttyreading", "Wu751019!"); - String str = "18026280912,18923221117,138999715789,13789860595,13958112970,18042322840,18822180212,18801800626,18182488636,13920824009,13810947856,15957915900,15704601021,13537736958,13130437779,18280337034,13608010972,13930682183,13304711384,15332055786,13524355516,13774496157,15389046616,15290224386,18924056976 ,13370556764,18681436632,15201163340,13858961234,15721570509,15972800166,13934534511,13560350715,13335013906,13623631189,15333566532,424023981,0410317573,13631384127,13533531792,15129799293,18035115008,13851639824,15022443770,13869945456,13570817083,6043741898,15999972127"; - String[] tels = str.split(","); - for (String tel : tels) { - tel = tel.replace(" ",""); - PreparedStatement statement = fzdsconn.prepareStatement("select * from user where tel like '%"+tel+"%' and del_flag=0 "); - ResultSet resultSet = statement.executeQuery(); - List list = new ArrayList<>(); - while(resultSet.next()){ - list.add(resultSet.getString("id")); - } - if (list.size() == 0){ - System.out.println(tel+"-无账号"); - }else if (list.size() > 1){ - System.out.println(tel+"-多账号"); - }else { - PreparedStatement addUserCourseBuyStatement = fzdsconn.prepareStatement( - "INSERT ignore INTO user_course_buy (user_id,course_id,catalogue_id,days,come) VALUES (?, ?, ?, ?, ?)"); - addUserCourseBuyStatement.setString(1,list.get(0).toString()); - addUserCourseBuyStatement.setInt(2,204); - addUserCourseBuyStatement.setInt(3,277); - addUserCourseBuyStatement.setInt(4,180); - addUserCourseBuyStatement.setString(5,"批量赠送"); - addUserCourseBuyStatement.execute(); + PreparedStatement statement = fzdsconn.prepareStatement("" + + "select user_id from user_course_buy where del_flag = 0 and (course_id = 324 or course_id = 217) and user_id not in (select user_id from user_vip where type = 8 and state = 0 and del_flag = 0 ) group by user_id"); + ResultSet resultSet = statement.executeQuery(); + PreparedStatement addUserCourseBuyStatement = fzdsconn.prepareStatement( + "INSERT ignore INTO user_course_buy (user_id,course_id,catalogue_id,create_time,days,come,start_time,end_time) " + + "VALUES (?, ?, ?, ?, ?, ?, ?, ?)"); + while(resultSet.next()){ + PreparedStatement statement324 = fzdsconn.prepareStatement("" + + "select * from user_course_buy where del_flag = 0 and (course_id = 324 or course_id = 217) " + + "and user_id = "+resultSet.getInt("user_id")+" order by end_time desc"); + ResultSet resultSet324 = statement324.executeQuery(); + while(resultSet324.next()){ + for (int i=325;i<331;i++){ + addUserCourseBuyStatement.setInt(1,resultSet324.getInt("user_id")); + addUserCourseBuyStatement.setInt(2,i); + if (i==325){ + addUserCourseBuyStatement.setInt(3,357); + }else if (i==326){ + addUserCourseBuyStatement.setInt(3,358); + }else if (i==327){ + addUserCourseBuyStatement.setInt(3,360); + }else if (i==328){ + addUserCourseBuyStatement.setInt(3,361); + }else if (i==329){ + addUserCourseBuyStatement.setInt(3,362); + }else{ + addUserCourseBuyStatement.setInt(3,363); + } + addUserCourseBuyStatement.setTimestamp(4,resultSet324.getTimestamp("create_time")); + addUserCourseBuyStatement.setInt(5,resultSet324.getInt("days")); + addUserCourseBuyStatement.setString(6,resultSet324.getString("come")); + addUserCourseBuyStatement.setTimestamp(7,resultSet324.getTimestamp("start_time")); + addUserCourseBuyStatement.setTimestamp(8,resultSet324.getTimestamp("end_time")); + addUserCourseBuyStatement.addBatch(); } + break; + } } + addUserCourseBuyStatement.executeBatch(); } catch (Exception e) { System.out.println(e); }