energy-manage-analyse/src/main/java/com/energy/manage/analyse/mappers/anomaly/AnomalyWindfarmMapper.java

package com.energy.manage.analyse.mappers.anomaly;

import com.energy.manage.analyse.common.mapper.MyMapper;
import com.energy.manage.analyse.domain.vo.anomaly.*;
import com.energy.manage.analyse.po.anomaly.AnomalyModelPO;
import com.energy.manage.analyse.po.anomaly.AnomalyWindfarmPO;
import com.energy.manage.analyse.po.anomaly.BaseAnomalyDetectorPO;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * 异常检测mappser接口
 */
@Repository
public interface AnomalyWindfarmMapper extends MyMapper<AnomalyWindfarmPO> {

         /**
         * 数据完整度
         * 
         * @param fieldId
         * @param dataType
         * @param year
         * @param beginTime
         * @param endTime
         * @return
         */
        List<AnomalyModelPO>  selectDataCompleteness(@Param("fieldId") String fieldId,
                        @Param("dataType") String dataType,
                        @Param("year") String year,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 查询区域异常情况信息
         * 
         * @param fieldIds
         * @param beginTime
         * @param endTime
         * @return
         */
        AnomalyRegionVO getAnomalyListByFieldIds(@Param("fieldIds") List<String> fieldIds,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 异常检测统计
         * 
         * @param fieldId
         * @param beginTime
         * @param endTime
         * @return
         */
        // List<AnomalyOverviewVO> selectAnomalyWindfarmAndFieldId(@Param("fieldId")
        // String fieldId,
        // @Param("beginTime") String beginTime,
        // @Param("endTime") String endTime);
        List<AnomalyOverviewVO> selectAnomalyWindfarmAndFieldId(@Param("fieldIds") List<String> fieldIds,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 柱状图
         * 
         * @param fieldId
         * @param year
         * @param beginTime
         * @param endTime
         * @return
         */
        BarChartVO selectAnomalyModelCount(@Param("fieldId") String fieldId,
                        @Param("year") String year,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 检测器he传感器通用
         * 
         * @param fieldId
         * @param year
         * @param beginTime
         * @param endTime
         * @return
         */
        List<AnomalyModelPO> selectAllAnomalyModel(@Param("fieldId") String fieldId,
                        @Param("year") String year,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 异常检测器
         * 
         * @param fieldId
         * @param engineId
         * @param tableName
         * @param beginTime
         * @param endTime
         * @return
         */
        BaseAnomalyDetectorPO selectAnomalyDetectorAll(@Param("fieldId") String fieldId,
                        @Param("tableName") String tableName,
                        @Param("engineId") String engineId,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 单表统计：指定年度表
         * 
         * @param fieldId
         * @param engineId
         * @param tableName
         * @param beginTime
         * @param endTime
         * @return
         */
        List<AnomalyDailyVO> selectBySingleTable(@Param("fieldId") String fieldId,
                        @Param("engineId") String engineId,
                        @Param("tableName") String tableName,
                        @Param("startDate") String beginTime,
                        @Param("endDate") String endTime);

        /**
         * 跨表统计：指定年度表
         * 
         * @param fieldId
         * @param engineId
         * @param table1，table2
         * @param beginTime
         * @param endTime
         * @return
         */
        List<AnomalyDailyVO> selectByUnionTables(@Param("fieldId") String fieldId,
                        @Param("engineId") String engineId,
                        @Param("table1") String table1,
                        @Param("table2") String table2,
                        @Param("startDate") String beginTime,
                        @Param("endDate") String endTime);

        /**
         * 根据风场查询异常个数传感器
         * 
         * @param fieldId
         * @param year
         * @param beginTime
         * @param endTime
         * @return
         */
        AnomalySensorCountVO selectAnomalySensorCountVO(@Param("fieldId") String fieldId,
                        @Param("year") String year,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        /**
         * 异常检测模块统计异常风机台数
         * 
         * @param fieldId
         * @param year
         * @param beginTime
         * @param endTime
         * @return
         */
        AnomalyCount selectModeCount(@Param("fieldId") String fieldId,
                        @Param("year") String year,
                        @Param("beginTime") String beginTime,
                        @Param("endTime") String endTime);

        Integer selectEngineCountByCode(@Param("companyCode") String companyCode);

}