From 29f1afa5fff5440ad5ce7dd40dee1053ea0ff7bf Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期三, 02 九月 2026 12:14:46 +0800
Subject: [PATCH] 彻底删除补采完整性与断线恢复遗留代码
---
ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java | 68 ----------------------------------
1 files changed, 0 insertions(+), 68 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
index f610df5..0bd548a 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
@@ -11,11 +11,6 @@
import com.ruoyi.system.domain.TTestPlanStep;
import com.ruoyi.system.domain.TTestResult;
import com.ruoyi.system.domain.TTestWarningThreshold;
-import com.ruoyi.system.domain.TTestCollectorExceptionInterval;
-import com.ruoyi.system.domain.TTestCollectorSource;
-import com.ruoyi.system.domain.TTestBackfillCursor;
-import com.ruoyi.system.domain.TTestIntegrityIssue;
-import com.ruoyi.system.domain.TTestReceptionInterval;
import com.ruoyi.system.domain.TTestLogicStepMapping;
import com.ruoyi.system.domain.TDetectionChannel;
import com.ruoyi.system.domain.TTestDataRevisionAction;
@@ -158,67 +153,4 @@
int insertSampleConflict(@Param("testId") Long testId, @Param("channelId") Long channelId,
@Param("detail") String detail);
int countTestBatteryNo(@Param("testId") Long testId, @Param("batteryNo") String batteryNo);
- /** 兼容已移除的历史实现源码；当前运行链路不再调用这些方法。 */
- TTestChannelBinding selectChannelLeaseForUpdate(Long channelId);
- int insertChannelLease(@Param("channelId") Long channelId, @Param("testId") Long testId,
- @Param("bindingId") Long bindingId, @Param("acquiredBy") Long acquiredBy,
- @Param("acquiredAtUtc") Date acquiredAtUtc);
- int insertCollectorChannelLease(@Param("collectorId") Long collectorId, @Param("channelCode") String channelCode,
- @Param("testId") Long testId, @Param("bindingId") Long bindingId,
- @Param("acquiredBy") Long acquiredBy, @Param("acquiredAtUtc") Date acquiredAtUtc);
- int deleteChannelLeasesByTestId(Long testId);
- int deleteCollectorChannelLeasesByTestId(Long testId);
- List<TTestCollectorSource> selectReceivingCollectorSources();
- TTestCollectorExceptionInterval selectOpenCollectorException(@Param("testId") Long testId,
- @Param("batteryRelationId") Long batteryRelationId, @Param("collectorId") Long collectorId,
- @Param("channelCode") String channelCode);
- int insertCollectorExceptionInterval(TTestCollectorExceptionInterval interval);
- int closeCollectorExceptionInterval(@Param("intervalId") Long intervalId,
- @Param("recoveredAtUtc") Date recoveredAtUtc, @Param("missingToUtc") Date missingToUtc);
- List<TTestCollectorExceptionInterval> selectCollectorExceptionIntervals(Long testId);
- List<TTest> selectTestsForNaturalEnd();
- List<TTest> selectTestsForBackfill();
- TTestBackfillCursor selectBackfillCursorForUpdate(@Param("testId") Long testId,
- @Param("bindingId") Long bindingId, @Param("sourceType") String sourceType,
- @Param("sourceId") Long sourceId, @Param("sourceChannelCode") String sourceChannelCode);
- int insertBackfillCursor(TTestBackfillCursor cursor);
- int updateBackfillCursor(TTestBackfillCursor cursor);
- int updateTestBackfillStarted(@Param("testId") Long testId, @Param("updatedAtUtc") Date updatedAtUtc);
- int updateTestBackfillWaiting(@Param("testId") Long testId, @Param("updatedAtUtc") Date updatedAtUtc,
- @Param("error") String error);
- int updateTestBackfillCompleted(@Param("testId") Long testId, @Param("updatedAtUtc") Date updatedAtUtc);
- int updateTestCompleted(@Param("testId") Long testId, @Param("updatedAtUtc") Date updatedAtUtc);
- int updateTestNaturallyEnded(@Param("testId") Long testId, @Param("endedAtUtc") Date endedAtUtc);
- String selectSampleContentHash(@Param("channelId") Long channelId, @Param("btsTestId") String btsTestId,
- @Param("sequenceId") Long sequenceId);
- int insertBackfillConflict(@Param("testId") Long testId, @Param("channelId") Long channelId,
- @Param("detail") String detail);
- List<TTestIntegrityIssue> selectIntegrityIssues(Long testId);
- List<TTestIntegrityIssue> selectTestExceptionFacts(Long testId);
- List<Long> selectBtsSequencesByInterval(Long intervalId);
- List<Long> selectCollectorSequencesByInterval(Long intervalId);
- TTestIntegrityIssue selectOpenIntegrityIssue(@Param("intervalId") Long intervalId,
- @Param("sourceType") String sourceType, @Param("sourceId") Long sourceId,
- @Param("sourceChannelCode") String sourceChannelCode, @Param("missingFrom") Long missingFrom,
- @Param("missingTo") Long missingTo);
- List<TTestIntegrityIssue> selectOpenIntegrityIssues(@Param("intervalId") Long intervalId,
- @Param("sourceType") String sourceType, @Param("sourceId") Long sourceId,
- @Param("sourceChannelCode") String sourceChannelCode);
- int insertIntegrityIssue(TTestIntegrityIssue issue);
- int touchIntegrityIssue(@Param("issueId") Long issueId, @Param("retryCount") Integer retryCount,
- @Param("detail") String detail, @Param("detectedAtUtc") Date detectedAtUtc);
- int rewindBackfillCursor(@Param("testId") Long testId, @Param("bindingId") Long bindingId,
- @Param("sourceType") String sourceType, @Param("sourceId") Long sourceId,
- @Param("sourceChannelCode") String sourceChannelCode, @Param("nextPosition") Long nextPosition);
- int resolveIntegrityIssues(@Param("testId") Long testId, @Param("intervalId") Long intervalId,
- @Param("sourceType") String sourceType, @Param("sourceId") Long sourceId,
- @Param("sourceChannelCode") String sourceChannelCode, @Param("resolvedAtUtc") Date resolvedAtUtc);
- int resolveIntegrityIssue(@Param("issueId") Long issueId, @Param("resolvedAtUtc") Date resolvedAtUtc);
- int countOpenIntegrityIssues(Long testId);
- int countOpenExceptions(Long testId);
- int closeOpenReceptionIntervals(@Param("testId") Long testId, @Param("endBoundaryAtUtc") Date endBoundaryAtUtc,
- @Param("boundaryNote") String boundaryNote);
- List<TTestReceptionInterval> selectTestReceptionIntervals(Long testId);
-
- /** ����兼容旧源码的声明；Ticket28 运行链路不再调用。 */
}
--
Gitblit v1.7.1