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.domain.vo.healthscores.HealthscoresRegionVO;
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 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);


    /**
     * 柱状图
     * @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);

}