package com.znzn.project.dc.dtdata.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.znzn.project.dc.dtdata.entity.WindTurbineData;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;

import java.util.Map;

/**
 * <p>
 * 风力发电机数据表 Mapper 接口
 * </p>
 *
 * @author 魏志亮
 * @since 2026-01-08
 */
@Mapper
public interface WindTurbineDataMapper extends BaseMapper<WindTurbineData> {

    @Select("select  * from  wind_turbine_data where turbine_id = #{turbineId} and data_time > #{dataTime} order by data_time desc limit 1 ")
    Map<String, Object> getLastHourLatestData(String dataTime,String turbineId);

    void addMonthlyPartition(String partitionName, String partitionEndDate);

    void dropExpiredPartition(String expiredPartitionName);

    int checkPartitionExists(String partitionName);

}