From 56cddf53e7e71afad29885d7fcf773a222b95f6c Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期日, 30 八月 2026 19:38:18 +0800
Subject: [PATCH] 修复采集器断线区间重复关闭
---
ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java | 8 ++++++++
1 files changed, 8 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 5106b4b..0473fd3 100644
--- a/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java
+++ b/ruoyi-admin/src/test/java/com/ruoyi/config/FlywayMigrationContractTest.java
@@ -135,6 +135,14 @@
assertTrue(v18.contains("uk_collector_exception_open"));
assertFalse(v18.matches("(?s).*\\bDROP\\s+TABLE\\b.*"));
+ String v19 = resource("db/migration/V19__collector_disconnect_open_dedupe.sql");
+ assertTrue(v19.contains("DROP INDEX uk_collector_exception_open"));
+ assertTrue(v19.contains("open_dedupe_key VARCHAR(320)"));
+ assertTrue(v19.contains("interval_status = 'OPEN'"));
+ assertTrue(v19.contains("ELSE NULL"));
+ assertTrue(v19.contains("ADD UNIQUE KEY uk_collector_exception_open (open_dedupe_key)"));
+ assertFalse(v19.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