From 1522564d7ddf949131641f220766a25d8d981751 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期日, 30 八月 2026 16:07:20 +0800
Subject: [PATCH] 收敛测试暂停继续与停止生命周期
---
ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 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 1f18933..76f31d2 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
@@ -12,7 +12,6 @@
import com.ruoyi.system.domain.TTestResult;
import com.ruoyi.system.domain.TTestWarningThreshold;
import com.ruoyi.system.domain.TDetectionChannel;
-import com.ruoyi.system.domain.TTestReceptionInterval;
import com.ruoyi.system.domain.vo.TestBatteryOptionVo;
import com.ruoyi.system.domain.vo.TestChannelOptionVo;
import com.ruoyi.system.domain.vo.TestCollectorOptionVo;
@@ -64,7 +63,7 @@
@Param("actorId") Long actorId, @Param("actorName") String actorName,
@Param("previousValue") String previousValue, @Param("newValue") String newValue);
- /** 锁定检测柜通道的最新可观测事实，供接收边界确认使用。 */
+ /** 锁定检测柜通道的最新可观测事实，供开始接收校验使用。 */
TDetectionChannel selectReceptionChannelForUpdate(Long channelId);
/** 锁定当前检测柜通道租约；返回空表示可接入。 */
TTestChannelBinding selectChannelLeaseForUpdate(Long channelId);
@@ -74,19 +73,18 @@
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);
+ int hasReceivingTestForAdapter(@Param("adapterCode") String adapterCode);
+ int hasPausedOrEndedTestForAdapter(@Param("adapterCode") String adapterCode);
+ List<TDetectionChannel> selectReceivingChannelsForAdapter(@Param("adapterCode") String adapterCode);
boolean collectorOnline(Long collectorId);
int updateReceptionStarted(@Param("testId") Long testId, @Param("startedAtUtc") Date startedAtUtc,
- @Param("updateBy") String updateBy);
- int insertReceptionInterval(TTestReceptionInterval interval);
- List<TTestReceptionInterval> selectOpenReceptionIntervalsForUpdate(Long testId);
- List<TTestReceptionInterval> selectReceptionIntervals(Long testId);
- TTestReceptionInterval selectLatestReceptionIntervalForUpdate(@Param("testId") Long testId,
- @Param("sourceType") String sourceType, @Param("sourceId") Long sourceId,
- @Param("sourceChannelCode") String sourceChannelCode);
- int closeReceptionInterval(@Param("intervalId") Long intervalId, @Param("endBoundaryAtUtc") Date endBoundaryAtUtc,
- @Param("boundaryNote") String boundaryNote);
+ @Param("runtimeAttach") boolean runtimeAttach, @Param("updateBy") String updateBy);
int updateReceptionPaused(@Param("testId") Long testId, @Param("updateBy") String updateBy,
@Param("updatedAtUtc") Date updatedAtUtc);
int updateReceptionResumed(@Param("testId") Long testId, @Param("updateBy") String updateBy,
@Param("updatedAtUtc") Date updatedAtUtc);
+ int updateReceptionStopped(@Param("testId") Long testId, @Param("updateBy") String updateBy,
+ @Param("endedAtUtc") Date endedAtUtc);
}
--
Gitblit v1.7.1