zm/nuttyreading-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改

Browse Source
This commit is contained in:
wuchunlei
2025-07-24 17:02:43 +08:00
parent a38f23d21c
commit 707a01f96d
1 changed files with 38 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
src/main/java/com/peanut/common/utils/UserCourseBuyUtil.java
View File

@@ -13,7 +13,7 @@ public class UserCourseBuyUtil {
//批量开课 //批量开课
public static void main(String[] args) { public static void main(String[] args) {
userEbookBuy250410(); // userEbookBuy250410();
// userCourseBuy(); // userCourseBuy();
// userEbookBuy(); // userEbookBuy();
// userCourseBuyShopProductCourse(); // userCourseBuyShopProductCourse();
@@ -144,31 +144,45 @@ public class UserCourseBuyUtil {
Connection fzdsconn = DriverManager.getConnection( Connection fzdsconn = DriverManager.getConnection(
"jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true", "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true",
"nuttyreading", "Wu751019!"); "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"; PreparedStatement statement = fzdsconn.prepareStatement("" +
String[] tels = str.split(","); "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");
for (String tel : tels) { ResultSet resultSet = statement.executeQuery();
tel = tel.replace(" ",""); PreparedStatement addUserCourseBuyStatement = fzdsconn.prepareStatement(
PreparedStatement statement = fzdsconn.prepareStatement("select * from user where tel like '%"+tel+"%' and del_flag=0 "); "INSERT ignore INTO user_course_buy (user_id,course_id,catalogue_id,create_time,days,come,start_time,end_time) " +
ResultSet resultSet = statement.executeQuery(); "VALUES (?, ?, ?, ?, ?, ?, ?, ?)");
List<Object> list = new ArrayList<>(); while(resultSet.next()){
while(resultSet.next()){ PreparedStatement statement324 = fzdsconn.prepareStatement("" +
list.add(resultSet.getString("id")); "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");
if (list.size() == 0){ ResultSet resultSet324 = statement324.executeQuery();
System.out.println(tel+"-无账号"); while(resultSet324.next()){
}else if (list.size() > 1){ for (int i=325;i<331;i++){
System.out.println(tel+"-多账号"); addUserCourseBuyStatement.setInt(1,resultSet324.getInt("user_id"));
}else { addUserCourseBuyStatement.setInt(2,i);
PreparedStatement addUserCourseBuyStatement = fzdsconn.prepareStatement( if (i==325){
"INSERT ignore INTO user_course_buy (user_id,course_id,catalogue_id,days,come) VALUES (?, ?, ?, ?, ?)"); addUserCourseBuyStatement.setInt(3,357);
addUserCourseBuyStatement.setString(1,list.get(0).toString()); }else if (i==326){
addUserCourseBuyStatement.setInt(2,204); addUserCourseBuyStatement.setInt(3,358);
addUserCourseBuyStatement.setInt(3,277); }else if (i==327){
addUserCourseBuyStatement.setInt(4,180); addUserCourseBuyStatement.setInt(3,360);
addUserCourseBuyStatement.setString(5,"批量赠送"); }else if (i==328){
addUserCourseBuyStatement.execute(); 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) { } catch (Exception e) {
System.out.println(e); System.out.println(e);
} }