package com.jiayue.biz.mapper;

import cn.hutool.db.Entity;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.jiayue.biz.domain.EnvironmentalData;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

import java.sql.Timestamp;
import java.util.List;

@DS("tdengine")
public interface EnvironmentalDataMapper extends BaseMapper<EnvironmentalData> {

    @Select("insert into environmental_${weatherLookNo} USING environmental_data TAGS(#{weatherLookNo}) values(#{ts},#{ws},#{wd},#{t},#{rh},#{pa})")
    public void insertOne(EnvironmentalData environmentalData);

    @Select("select * from environmental_${weatherLookNo} where ts >= #{startTime} and ts <= #{endTime}")
    List<EnvironmentalData> selectEnvironmentalData(@Param("weatherLookNo") String weatherLookNo, @Param("startTime") Timestamp startTime, @Param("endTime") Timestamp endTime);


    @Select("select last (ts) from environmental_${weatherLookNo}")
    List<Entity> getLastData(@Param("weatherLookNo") String weatherLookNo);


    @Select("select * from environmental_${weatherLookNo}")
    List<EnvironmentalData> selectAll(@Param("weatherLookNo") String weatherLookNo);

    @Select("select * from environmental_${weatherLookNo} order by ts desc limit 1")
    EnvironmentalData selectLastTimeData(@Param("weatherLookNo") String weatherLookNo);

    @Select("CREATE TABLE IF NOT EXISTS environmental_${weatherLookNo} USING environmental_data TAGS (#{weatherLookNo})")
    void createTable(@Param("weatherLookNo") String weatherLookNo);

    @Delete("DROP TABLE IF EXISTS environmental_${weatherLookNo}")
    void deleteTable(@Param("weatherLookNo") String weatherLookNo);


}