|
@ -79,7 +79,7 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
String querySql = """ |
|
|
String querySql = """ |
|
|
SELECT gtype, jwcode, free, core_jb, buy_jb, cz_time, cz_user, cz_bz, operation_platform, goods_name |
|
|
SELECT gtype, jwcode, free, core_jb, buy_jb, cz_time, cz_user, cz_bz, operation_platform, goods_name |
|
|
FROM hwhcGold.dbo.user_gold_records |
|
|
FROM hwhcGold.dbo.user_gold_records |
|
|
WHERE flag = 1 AND cz_time > ? |
|
|
|
|
|
|
|
|
WHERE flag = 1 AND cz_time > '2025-08-24 17:57:50' |
|
|
ORDER BY cz_time ASC |
|
|
ORDER BY cz_time ASC |
|
|
OFFSET ? ROWS FETCH NEXT ? ROWS ONLY |
|
|
OFFSET ? ROWS FETCH NEXT ? ROWS ONLY |
|
|
"""; |
|
|
"""; |
|
@ -92,9 +92,9 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
|
|
|
|
|
|
while (hasMoreData) { |
|
|
while (hasMoreData) { |
|
|
try (PreparedStatement sqlServerStmt = sqlServerConn.prepareStatement(querySql)) { |
|
|
try (PreparedStatement sqlServerStmt = sqlServerConn.prepareStatement(querySql)) { |
|
|
sqlServerStmt.setTimestamp(1, Timestamp.valueOf(LocalDateTime.now().minusHours(1))); // 获取最近一小时的数据 |
|
|
|
|
|
sqlServerStmt.setInt(2, offset); // 设置 OFFSET |
|
|
|
|
|
sqlServerStmt.setInt(3, pageSize); // 设置 FETCH NEXT |
|
|
|
|
|
|
|
|
// sqlServerStmt.setTimestamp(1, Timestamp.valueOf(LocalDateTime.now().minusHours(1))); // 获取最近一小时的数据 |
|
|
|
|
|
sqlServerStmt.setInt(1, offset); // 设置 OFFSET |
|
|
|
|
|
sqlServerStmt.setInt(2, pageSize); // 设置 FETCH NEXT |
|
|
|
|
|
|
|
|
ResultSet resultSet = sqlServerStmt.executeQuery(); |
|
|
ResultSet resultSet = sqlServerStmt.executeQuery(); |
|
|
|
|
|
|
|
@ -121,7 +121,8 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
String timestampPart = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS")); |
|
|
String timestampPart = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS")); |
|
|
String orderNumber = UUID.randomUUID().toString().replaceAll("-", ""); |
|
|
String orderNumber = UUID.randomUUID().toString().replaceAll("-", ""); |
|
|
|
|
|
|
|
|
if (StringUtils.isNumeric(name)) { |
|
|
|
|
|
|
|
|
if (StringUtils.isNumeric(name)) {; |
|
|
|
|
|
System.out.println("name是数字"+ name); |
|
|
Integer admin_id = Integer.valueOf(adminService.getId(name)); |
|
|
Integer admin_id = Integer.valueOf(adminService.getId(name)); |
|
|
mysqlStmt.setInt(14, admin_id); |
|
|
mysqlStmt.setInt(14, admin_id); |
|
|
} else { |
|
|
} else { |
|
|