import java.nio.charset.StandardCharsets;
|
import java.nio.file.Files;
|
import java.nio.file.Path;
|
import java.sql.Connection;
|
import java.sql.DriverManager;
|
import java.sql.ResultSet;
|
import java.sql.ResultSetMetaData;
|
import java.sql.SQLException;
|
import java.sql.Statement;
|
|
/**
|
* 一次性只读探针：定位 2026-09-24 那笔支付创建 409 的通道原始回执。
|
*
|
* <p>只跑 select，不写库。输出同时打到 stdout 与 UTF-8 文件（Git Bash 控制台编码不可靠）。
|
*/
|
public class Payment409Probe {
|
|
private static final String[] DATABASES = {
|
"talent_card2", "talent_card", "talent_card_verify1", "talent_card_dryrun"
|
};
|
|
public static void main(String[] args) throws Exception {
|
Path out = Path.of(args.length > 0 ? args[0] : ".scratch/payment-409-probe/out.txt");
|
Files.createDirectories(out.getParent());
|
StringBuilder text = new StringBuilder();
|
String base = "jdbc:mysql://127.0.0.1:8134/?useUnicode=true&characterEncoding=utf8"
|
+ "&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&useSSL=false";
|
try (Connection connection = DriverManager.getConnection(base, "root", "123456")) {
|
for (String database : DATABASES) {
|
section(text, "===== " + database + " =====");
|
try (Statement statement = connection.createStatement()) {
|
statement.execute("use `" + database + "`");
|
} catch (SQLException exception) {
|
text.append("数据库不可用：").append(exception.getMessage()).append('\n');
|
continue;
|
}
|
dump(text, connection, "最近的支付流水",
|
"select payment_no, order_no, amount, status, provider_huifu_id, "
|
+ "provider_response_code, provider_response_message, created_at, paid_at "
|
+ "from payment_transaction order by id desc limit 15");
|
dump(text, connection, "今天创建的支付流水（金额/状态/回执）",
|
"select payment_no, order_no, amount, status, provider_response_code, provider_response_message, created_at "
|
+ "from payment_transaction where created_at >= '2026-09-24 00:00:00' order by id desc limit 20");
|
dump(text, connection, "最近的对账问题记录",
|
"select issue_type, business_no, status, expected_value, actual_value, amount, description, created_at "
|
+ "from payment_reconciliation_issue order by id desc limit 15");
|
dump(text, connection, "商户微信阶段快照",
|
"select application_id, sync_owner, last_synced_at, sync_error, stages_json "
|
+ "from merchant_onboarding_progress order by id desc limit 8");
|
}
|
}
|
System.out.println(text);
|
Files.writeString(out, text.toString(), StandardCharsets.UTF_8);
|
System.out.println("\nwritten to " + out.toAbsolutePath());
|
}
|
|
private static void section(StringBuilder text, String title) {
|
text.append('\n').append(title).append('\n');
|
}
|
|
private static void dump(StringBuilder text, Connection connection, String title, String sql) {
|
text.append("\n--- ").append(title).append(" ---\n");
|
try (Statement statement = connection.createStatement(); ResultSet rs = statement.executeQuery(sql)) {
|
ResultSetMetaData meta = rs.getMetaData();
|
int columns = meta.getColumnCount();
|
int rows = 0;
|
while (rs.next()) {
|
rows++;
|
for (int i = 1; i <= columns; i++) {
|
text.append(meta.getColumnLabel(i)).append('=').append(value(rs.getObject(i))).append(" ");
|
}
|
text.append('\n');
|
}
|
if (rows == 0) text.append("(空)\n");
|
} catch (SQLException exception) {
|
text.append("查询失败：").append(exception.getMessage()).append('\n');
|
}
|
}
|
|
private static String value(Object raw) {
|
if (raw == null) return "NULL";
|
String text = String.valueOf(raw).trim();
|
return text.isEmpty() ? "\"\"" : text;
|
}
|
}
|
