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 { /** * 查询区域异常情况信息 * * @param fieldIds * @param beginTime * @param endTime * @return */ AnomalyRegionVO getAnomalyListByFieldIds(@Param("fieldIds") List fieldIds, @Param("beginTime") String beginTime, @Param("endTime") String endTime); /** * 异常检测统计 * @param fieldId * @param beginTime * @param endTime * @return */ List 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 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 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 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); }