|
@@ -1,168 +0,0 @@
|
|
|
-package com.platform.mapper;
|
|
|
|
|
-
|
|
|
|
|
-import com.baomidou.dynamic.datasource.annotation.DS;
|
|
|
|
|
-import com.platform.api.request.VehicleDataSaveRequest;
|
|
|
|
|
-import com.platform.entity.VehicleTimeSeriesData;
|
|
|
|
|
-import org.apache.ibatis.annotations.Mapper;
|
|
|
|
|
-import org.apache.ibatis.annotations.Param;
|
|
|
|
|
-
|
|
|
|
|
-import java.time.LocalDateTime;
|
|
|
|
|
-import java.util.List;
|
|
|
|
|
-
|
|
|
|
|
-/**
|
|
|
|
|
- * @Author: donglang
|
|
|
|
|
- * @CreateTime: 2025-10-09
|
|
|
|
|
- * @Description: taosMapper
|
|
|
|
|
- * @Version: 1.0
|
|
|
|
|
- */
|
|
|
|
|
-
|
|
|
|
|
-@Mapper
|
|
|
|
|
-@DS("td")
|
|
|
|
|
-public interface TaosMapper {
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 插入车辆数据超级表
|
|
|
|
|
- * @return 插入成功的行数
|
|
|
|
|
- */
|
|
|
|
|
- int createVehicleDataTable();
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 插入车辆数据到时序子表
|
|
|
|
|
- * 子表名规则:vehicle_${tenantId}_${deviceId}(基于租户ID+设备ID,确保唯一)
|
|
|
|
|
- * @param vehicleDataList 车辆数据实体
|
|
|
|
|
- * @return 插入成功的行数
|
|
|
|
|
- */
|
|
|
|
|
- int batchInsertVehicleData(List<VehicleDataSaveRequest> vehicleDataList);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 批量删除时序库数据
|
|
|
|
|
- * @param uniqueKeys 唯一标识列表(carNo_ts)
|
|
|
|
|
- */
|
|
|
|
|
- void batchDelete(@Param("uniqueKeys") List<String> uniqueKeys);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 通过运单号查询时序数据
|
|
|
|
|
-
|
|
|
|
|
- * @param wOrderNo 车辆数据实体
|
|
|
|
|
- * @return 返回的车辆数据
|
|
|
|
|
- */
|
|
|
|
|
- List<VehicleTimeSeriesData> selectByWOrderNo(@Param("wOrderNo") String wOrderNo,
|
|
|
|
|
- @Param("startTime") LocalDateTime startTime,
|
|
|
|
|
- @Param("endTime") LocalDateTime endTime);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 通过车牌查询时序数据
|
|
|
|
|
-
|
|
|
|
|
- * @param carNo 车辆数据实体
|
|
|
|
|
- * @return 返回的车辆数据
|
|
|
|
|
- */
|
|
|
|
|
- List<VehicleTimeSeriesData> selectByCarNo(@Param("subTableName") String subTableName,
|
|
|
|
|
- @Param("carNo") String carNo,
|
|
|
|
|
- @Param("startTime") LocalDateTime startTime,
|
|
|
|
|
- @Param("endTime") LocalDateTime endTime);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 通过车牌查询时序数据
|
|
|
|
|
-
|
|
|
|
|
- * @param carNo 车辆数据实体
|
|
|
|
|
- * @return 返回的车辆数据
|
|
|
|
|
- */
|
|
|
|
|
- VehicleTimeSeriesData selectRealTimeLocation(@Param("subTableName") String subTableName,
|
|
|
|
|
- @Param("carNo") String carNo);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建水表子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createWaterMeterSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建电表子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createElectricMeterSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建边坡检测子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createSlopeMonitorSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建视频监控子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createDeviceMonitorSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建矿卡子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createMineTruckMonitorSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建皮带称重数据子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createBeltScaleDataSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建环境检查子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createEnvironmentCheckSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建无人地磅子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createWeighbridgeDataSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建排放检测数据子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createEmissionDataSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建车辆数据子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createVehicleDataSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
- /**
|
|
|
|
|
- * 创建装载机械数据子表
|
|
|
|
|
- * @param code 产品编码
|
|
|
|
|
- * @param deviceId 设备id
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- int createLoadingEquipmentDataSubTable(@Param("code") String code, @Param("deviceId") String deviceId);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
-}
|
|
|