From ec3308617909c8d6280e0d00ffb18350e372fbdf Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期日, 30 八月 2026 17:36:29 +0800
Subject: [PATCH] 实现采集器断线恢复与来源异常持久化
---
ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java b/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java
index d3c6e01..5106b4b 100644
--- a/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java
+++ b/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java
@@ -128,6 +128,13 @@
assertTrue(v17.contains("AFTER ended_at_utc"));
assertFalse(v17.matches("(?s).*\\bDROP\\s+TABLE\\b.*"));
+ String v18 = resource("db/migration/V18__collector_disconnect_recovery.sql");
+ assertTrue(v18.contains("CREATE TABLE t_test_collector_exception_interval"));
+ assertTrue(v18.contains("missing_from_utc"));
+ assertTrue(v18.contains("recovered_at_utc"));
+ assertTrue(v18.contains("uk_collector_exception_open"));
+ assertFalse(v18.matches("(?s).*\\bDROP\\s+TABLE\\b.*"));
+
String testMapper = resource("mapper/system/TTestMapper.xml");
assertTrue(testMapper.contains("selectReceivingChannelsForAdapter"));
assertTrue(testMapper.contains("RECEPTION_RESUMED"));
--
Gitblit v1.7.1