package com.qianwen.mdc.collect.mapper.iotdb;

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.qianwen.mdc.collect.dto.StateAggregateTimeDTO;
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;

import java.util.List;
import org.apache.ibatis.annotations.Param;

@DS("iotdb")
@InterceptorIgnore(tenantLine = "true")
public interface DeviceStateMapper extends BaseMapper<DeviceState> {
    //void createSuperTable();

    //void createTable(Long workstationId);

    //int insert(WorkstationState deviceState);

    //int batchInsert(List<WorkstationState> deviceStateList);

    //int batchSave(@Param("workstationId") Long workstationId, @Param("list") List<WorkstationState> list);

    List<DeviceState> getProcessingFeedbackState(@Param("workstationId") Long workstationId);

    DeviceState getLastIsSyncNoFixPointState(@Param("workstationId") Long workstationId);

    //DeviceState getLastWorkstationState(@Param("ew") Wrapper query);
    /**
     * 获取最新的已同步的非反馈点状态
     * @param workstationId
     * @return
     */
    DeviceState lastSyncedNoFeedbackPointState(Long workstationId);
    
    //DeviceState getFirstWorkstationState(@Param("ew") Wrapper query);
    /**
     * 获取第一个的未同步的非反馈点状态
     * @param workstationId
     * @return
     */
	DeviceState firstNotSyncedNofeedbackPointState(Long workstationId);

	/**
	 * 获取时间区间内的状态数据
	 * @param workstationId
	 * @param timeRange
	 * @return
	 */
	List<DeviceState> statesInTimeRange(@Param("workstationId")Long workstationId,@Param("timeRange") StateAggregateTimeDTO timeRange);

	/**
	 * 查询某天固定点数量
	 * @param factoryDate
	 * @return
	 */
	long fixPointCountByDate(int factoryDate);
}