检测室
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yeg
2026-08-30 c2eefadb8239df552ef43d7ba55d5735bb603ed1 
 ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java


@@ -1,16 +1,18 @@


package com.ruoyi.system.mapper;




import java.util.List;


import java.util.Date;


import org.apache.ibatis.annotations.Param;


import com.ruoyi.system.domain.TTest;


import com.ruoyi.system.domain.TTestBattery;


import com.ruoyi.system.domain.TTestBatteryField;


import com.ruoyi.system.domain.TTestChannelBinding;


import com.ruoyi.system.domain.TTestCollectorChannel;


import com.ruoyi.system.domain.TTestFieldSnapshot;


import com.ruoyi.system.domain.TTestPlanStep;


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;


@@ -23,13 +25,13 @@


    TTest selectTestById(Long testId);


    TTest selectTestByIdForUpdate(Long testId);


    List<TTest> selectTestList(TTest test);


    List<TTestBattery> selectBatteryNosByTestIds(@Param("testIds") List<Long> testIds);


    TTest selectTestByName(String testName);


    int insertTest(TTest test);


    int updateTest(TTest test);


    int deleteTestById(@Param("testId") Long testId, @Param("updateBy") String updateBy);


    int deleteTestBindingsByTestId(Long testId);


    int deleteTestCollectorChannelsByTestId(Long testId);


    int deleteTestFieldSnapshotsByTestId(Long testId);


    int deleteTestPlanStepsByTestId(Long testId);


    int deleteTestBatteriesByTestId(Long testId);


    int deleteTestFieldsByTestId(Long testId);


@@ -39,14 +41,12 @@


    int insertTestBatteryField(TTestBatteryField field);


    int insertTestChannelBinding(TTestChannelBinding binding);


    int insertTestCollectorChannel(TTestCollectorChannel mapping);


    int insertTestFieldSnapshot(TTestFieldSnapshot snapshot);


    int insertTestThreshold(TTestWarningThreshold threshold);


    List<TTestPlanStep> selectTestPlanSteps(Long testId);


    List<TTestBattery> selectTestBatteries(Long testId);


    List<TTestBatteryField> selectTestBatteryFields(Long testId);


    List<TTestChannelBinding> selectTestChannelBindings(Long testId);


    List<TTestCollectorChannel> selectTestCollectorChannels(Long testId);


    List<TTestFieldSnapshot> selectTestFieldSnapshots(Long testId);


    List<TTestWarningThreshold> selectTestThresholds(Long testId);


    List<TTestResult> selectTestResults(TTestResult result);


    int countTestTypeEnabled(Long testTypeId);


@@ -63,4 +63,30 @@


    int insertTestAudit(@Param("testId") Long testId, @Param("eventType") String eventType,


            @Param("actorId") Long actorId, @Param("actorName") String actorName,


            @Param("previousValue") String previousValue, @Param("newValue") String newValue);




    /** 锁定检测柜通道的最新可观测事实，供接收边界确认使用。 */


    TDetectionChannel selectReceptionChannelForUpdate(Long channelId);


    /** 锁定当前检测柜通道租约；返回空表示可接入。 */


    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);


    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);


    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);


}