package com.ruoyi.energymeter.mapper;
|
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import com.ruoyi.energymeter.pojo.EnergyMeterDevice;
|
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Select;
|
import org.apache.ibatis.annotations.Update;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* 水电表绑定设备 Mapper。
|
*/
|
@Mapper
|
public interface EnergyMeterDeviceMapper extends BaseMapper<EnergyMeterDevice> {
|
|
/**
|
* 扫描全部租户下已启用、已验证、且为第三方接入的设备，用于系统级自动同步。
|
* 手工抄表设备由用户录表，不参与定时采集。
|
*/
|
@Select("SELECT * FROM energy_meter_device WHERE enabled = 1 AND bind_status = 'VERIFIED' "
|
+ "AND source_type = 'PROVIDER' ORDER BY id")
|
List<EnergyMeterDevice> selectScannableDevices();
|
|
/**
|
* 记录采集成功并清空上次错误。
|
*/
|
@Update("UPDATE energy_meter_device SET last_success_at = #{now}, last_error_code = NULL, "
|
+ "last_error_message = NULL WHERE id = #{id}")
|
int markCollectSuccess(@Param("id") Long id, @Param("now") LocalDateTime now);
|
|
/**
|
* 记录采集失败的脱敏错误类别与摘要。
|
*/
|
@Update("UPDATE energy_meter_device SET last_error_code = #{code}, last_error_message = #{message} WHERE id = #{id}")
|
int markCollectFailure(@Param("id") Long id, @Param("code") String code, @Param("message") String message);
|
}
|
