package com.ruoyi.energymeter.mapper;
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import com.ruoyi.energymeter.pojo.EnergyMeterSyncCheckpoint;
|
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Select;
|
|
/**
|
* 同步进度 Mapper。
|
*/
|
@Mapper
|
public interface EnergyMeterSyncCheckpointMapper extends BaseMapper<EnergyMeterSyncCheckpoint> {
|
|
@Select("SELECT * FROM energy_meter_sync_checkpoint WHERE meter_id = #{meterId} "
|
+ "AND source_api = #{sourceApi} AND granularity = #{granularity} LIMIT 1")
|
EnergyMeterSyncCheckpoint selectUnit(@Param("meterId") Long meterId,
|
@Param("sourceApi") String sourceApi,
|
@Param("granularity") String granularity);
|
|
/**
|
* 幂等写入进度，只允许前进，不因最近几天回查而后退。
|
*/
|
int upsert(@Param("cp") EnergyMeterSyncCheckpoint cp);
|
}
|
