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


@@ -14,6 +14,8 @@


import com.ruoyi.system.domain.TTestCollectorSource;


import com.ruoyi.system.domain.TTestCollectorExceptionInterval;


import com.ruoyi.system.domain.TTestReceptionInterval;


import com.ruoyi.system.domain.TTestBackfillCursor;


import com.ruoyi.system.domain.TTestIntegrityIssue;


import com.ruoyi.system.domain.TDetectionChannel;


import com.ruoyi.system.domain.vo.TestBatteryOptionVo;


import com.ruoyi.system.domain.vo.TestChannelOptionVo;


@@ -59,6 +61,7 @@


    int countRegisteredChannel(Long channelId);


    int countCollectorEnabled(Long collectorId);


    Integer selectCollectorChannelCount(Long collectorId);


    String selectCollectorCode(Long collectorId);


    List<TestUserOptionVo> selectEnabledUserOptions();


    List<TestTypeOptionVo> selectEnabledTestTypeOptions();


    List<TestBatteryOptionVo> selectEnabledBatteryOptions();


@@ -111,4 +114,73 @@


    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 insertBtsSample(@Param("testId") Long testId, @Param("bindingId") Long bindingId,


            @Param("channelId") Long channelId, @Param("intervalId") Long intervalId,


            @Param("btsTestId") String btsTestId, @Param("sequenceId") Long sequenceId,


            @Param("deviceTimeUtc") Date deviceTimeUtc, @Param("deviceTimeRaw") String deviceTimeRaw,


            @Param("receivedAtUtc") Date receivedAtUtc, @Param("cycleNo") Integer cycleNo,


            @Param("stepNo") Integer stepNo, @Param("stepType") String stepType,


            @Param("testTimeMs") Long testTimeMs, @Param("voltageV") java.math.BigDecimal voltageV,


            @Param("currentA") java.math.BigDecimal currentA, @Param("capacityAh") java.math.BigDecimal capacityAh,


            @Param("energyWh") java.math.BigDecimal energyWh, @Param("contentSha256") byte[] contentSha256);


    int insertBtsMeasurement(@Param("sampleId") Long sampleId, @Param("metricCode") String metricCode,


            @Param("metricValue") java.math.BigDecimal metricValue, @Param("unit") String unit,


            @Param("sourceType") String sourceType);


    Long selectBtsSampleId(@Param("channelId") Long channelId, @Param("btsTestId") String btsTestId,


            @Param("sequenceId") Long sequenceId);


    int insertCollectorSample(@Param("testId") Long testId, @Param("bindingId") Long bindingId,


            @Param("intervalId") Long intervalId,


            @Param("collectorId") Long collectorId, @Param("channelCode") String channelCode,


            @Param("sequenceId") Long sequenceId, @Param("deviceTimeUtc") Date deviceTimeUtc,


            @Param("deviceTimeRaw") String deviceTimeRaw, @Param("receivedAtUtc") Date receivedAtUtc,


            @Param("metricCode") String metricCode, @Param("metricValue") java.math.BigDecimal metricValue,


            @Param("unit") String unit, @Param("contentSha256") byte[] contentSha256);


    Long selectCollectorSampleId(@Param("collectorId") Long collectorId, @Param("channelCode") String channelCode,


            @Param("sequenceId") Long sequenceId, @Param("metricCode") String metricCode);


    String selectCollectorSampleContentHash(@Param("collectorId") Long collectorId,


            @Param("channelCode") String channelCode, @Param("sequenceId") Long sequenceId,


            @Param("metricCode") String metricCode);


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


}