实现新威 7.6 直连取数与逐行接收

yeg

2026-09-28 147428971be43eed90a79f3849f15000d3855390

 battery-business/src/main/java/com/battery/business/mapper/TTestMapper.java

@@ -23,7 +23,7 @@
import com.battery.business.domain.vo.TestTypeOptionVo;
import com.battery.business.domain.vo.TestUserOptionVo;

/** 测试配置及其只追加审计的数据访问接口。 */
/** 读写测试配置、成功接收数据、修订记录和异常处理事实。 */
public interface TTestMapper
{
    int deleteTestWarningExceptionsByTestId(Long testId);
@@ -32,6 +32,8 @@
    int updateDataRecord(@Param("testId") Long testId, @Param("dataType") String dataType, @Param("recordId") Long recordId, @Param("values") java.util.Map<String, Object> values);
    int deleteDataRecord(@Param("testId") Long testId, @Param("dataType") String dataType, @Param("recordId") Long recordId);
    java.util.Map<String, Object> selectImportBinding(@Param("testId") Long testId, @Param("batteryNo") String batteryNo);
    /** 查询当前测试该类事实，供整页导入校验身份和内容冲突。 */
    List<java.util.Map<String, Object>> selectImportDataRecords(@Param("testId") Long testId, @Param("dataType") String dataType);
    int insertImportedDataRecord(@Param("dataType") String dataType, @Param("values") java.util.Map<String, Object> values);
    TTest selectTestById(Long testId);
    TTest selectTestByIdForUpdate(Long testId);
@@ -68,7 +70,12 @@
            @Param("metricCode") String metricCode, @Param("value") java.math.BigDecimal value,
            @Param("unit") String unit, @Param("ruleSnapshot") String ruleSnapshot,
            @Param("severity") String severity, @Param("occurredAt") Date occurredAt);
    /** 查询异常事实；不从设备状态或缺失数据推导异常。 */
    /** 查询绑定来源的离线事实，同一采集器的多通道绑定只返回一次。 */
    List<com.battery.business.domain.vo.OfflineTestSource> selectOfflineTestSources(Long testId);
    /** 以测试和来源身份聚合离线异常，不写入阈值或测量值。 */
    int upsertOfflineException(@Param("testId") Long testId, @Param("sourceType") String sourceType,
            @Param("sourceIdentity") String sourceIdentity, @Param("occurredAt") Date occurredAt);
    /** 查询已持久化的阈值及离线异常事实。 */
    List<TTestWarningException> selectWarningExceptions(@Param("testId") Long testId,
            @Param("status") String status);
    TTestWarningException selectWarningExceptionById(Long exceptionId);
@@ -82,6 +89,9 @@
    int insertRealtimeRecord(TTestRealtimeRecord record);
    String selectRealtimeRecordContentHash(@Param("testId") Long testId, @Param("testBatteryId") Long testBatteryId,
            @Param("captureSlotUtc") Date captureSlotUtc);
    /** 按来源行身份查询已保存的实时记录摘要；逐行接收据此做幂等与冲突判定。 */
    String selectRealtimeRecordHashBySourceRecord(@Param("testBatteryId") Long testBatteryId,
            @Param("sourceIdentity") String sourceIdentity, @Param("sourceRecordId") String sourceRecordId);
    int insertStepRecord(TTestStepRecord record);
    int insertCycleRecord(TTestCycleRecord record);
    String selectStepRecordContentHash(@Param("testBatteryId") Long testBatteryId,