1.调度兼容pg库修改

2.新增报警导出接口

schedule-job/alarm-schedule/src/main/java/com/gyee/wisdom/alarm/schedule/job/TablesManagerHandler.java

@@ -31,7 +31,7 @@ public class TablesManagerHandler {
     public void AddAlarmHistoryTable(){
         Calendar instance = Calendar.getInstance();
         //查看当前时间的下月是否有表,没有就创建
-        instance.add(Calendar.MONTH,1);
+        //instance.add(Calendar.MONTH,1);
         String yearmonth=null;
         int year=instance.get(Calendar.YEAR);
         int month=instance.get(Calendar.MONTH)+1;

schedule-job/alarm-schedule/src/main/resources/mappers-postgresql/AlarmHistoryMapper.xml

@@ -208,7 +208,8 @@
         create index IX_AH_${stationname}_${yearmonth}_snapid on alarmhistory_${stationname}_${yearmonth} ("snapid")
     </update>
     <select id="isHasTable" resultType="java.lang.Integer">
-        select count(*) from information_schema.TABLES where table_name =upper('alarmhistory_{stationname}_${yearmonth}')
+        select count(*) from information_schema.tables where table_schema='public' and table_type='BASE TABLE' and
+            table_name=LOWER('alarmhistory_{stationname}_${yearmonth}');
     </select>
 
 </mapper>

schedule-job/alarm-schedule/src/main/resources/mappers-postgresql/WindturbineAlarmIdCountMapper.xml

@@ -7,7 +7,7 @@
         <foreach collection="list" item="item" index="index" separator="union all" >
             ( select
             #{item.id}, #{item.alarmDate},#{item.parts},#{item.partsName},#{item.rulesId},#{item.count},#{item.windturbineId},#{item.windpowerstationId}
-            from dual )
+            )
         </foreach>
     </insert>
 

schedule-job/alarm-schedule/src/main/resources/mappers-postgresql/WindturbineAlarmPartsCountMapper.xml

@@ -7,7 +7,7 @@
         <foreach collection="list" item="item" index="index" separator="union all" >
             ( select
             #{item.id}, #{item.alarmDate},#{item.parts},#{item.count},#{item.windturbineId},#{item.windpowerstationId},#{item.partsName}
-            from dual )
+            )
         </foreach>
     </insert>
 

warning-web/src/main/java/com/gyee/wisdom/alarm/sharding/controller/AlarmHistoryController.java

@@ -2,17 +2,29 @@ package com.gyee.wisdom.alarm.sharding.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.google.common.collect.Lists;
 import com.gyee.wisdom.alarm.sharding.config.AjaxResult;
 import com.gyee.wisdom.alarm.sharding.entity.AlarmHistory;
 import com.gyee.wisdom.alarm.sharding.entity.AlarmSnap;
 import com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo;
 import com.gyee.wisdom.alarm.sharding.service.AlarmHistoryService;
+import com.gyee.wisdom.alarm.sharding.util.ExcelExportUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.hssf.usermodel.HSSFSheet;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.HashMap;
-import java.util.Map;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.net.URLEncoder;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
 
 
 @Slf4j
@@ -24,6 +36,7 @@ public class AlarmHistoryController {
     @Autowired
     private AlarmHistoryService alarmHistoryService;
 
+
     @GetMapping(value = "/history/{historyId}")
     public AlarmHistory queryById(@PathVariable("historyId")  Long historyId ){
             return alarmHistoryService.queryById(historyId);
@@ -57,6 +70,110 @@ public class AlarmHistoryController {
 
     }
 
+
+    @GetMapping(value = "/history/export")
+    @ResponseBody
+    public void queryExport(
+            HttpServletResponse response,
+            @RequestParam(value = "stationid", required = false) String stId,
+            @RequestParam(value = "windturbineid",required = false) String wtId,
+            @RequestParam(value = "category1",required = false) String category1,
+            @RequestParam(value = "category2",required = false) String category2,
+            @RequestParam(value = "rank",required = false) String rank,
+            @RequestParam(value = "modelid",required = false) String modelId,
+            @RequestParam(value = "snapid",required = false) Long snapId,
+            @RequestParam(value = "messagetype",required = false) Integer messageType,
+            @RequestParam(value = "keyword",required = false) String keyWord,
+            @RequestParam(value = "starttime", required = false) String startTime,
+            @RequestParam(value = "endtime", required = false) String endTime
+    ) throws IOException {
+        OutputStream out = response.getOutputStream();
+        //压缩输出流
+        ZipOutputStream zipOutputStream = new ZipOutputStream(out);
+        String[] title = {"时间", "场站", "机组", "报警信息", "级别", "类型"};
+        String filename = "报警记录.Zip";
+        String sheetName = "报警记录";
+        List<AlarmHistoryInfo> list = alarmHistoryService.queryAllExport(stId,wtId,category1,category2,rank,modelId,snapId,messageType,keyWord,startTime,endTime);
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat ("yyyy-MM-dd hh:mm:ss");
+        try {
+            List<List<AlarmHistoryInfo>> lists = Lists.partition(list, 50000);
+            for (int j = 0; j < lists.size(); j++){
+                List<AlarmHistoryInfo> alarmHistoryInfoList = lists.get(j);
+                String[][] content = new String[alarmHistoryInfoList.size()][6];
+                for (int i = 0; i < alarmHistoryInfoList.size(); i++) {
+                    content[i][0] = simpleDateFormat.format(alarmHistoryInfoList.get(i).getAlertTime());
+                    content[i][1] = alarmHistoryInfoList.get(i).getStationName();
+                    content[i][2] = alarmHistoryInfoList.get(i).getWindturbineId();
+                    content[i][3] = alarmHistoryInfoList.get(i).getAlertText();
+                    switch (alarmHistoryInfoList.get(i).getRank()){
+                        case "1":
+                            content[i][4] = "低级";
+                            break;
+                        case "2":
+                            content[i][4] = "中低级";
+                            break;
+                        case "3":
+                            content[i][4] = "中级";
+                            break;
+                        case "4":
+                            content[i][4] = "中高级";
+                            break;
+                        case "5":
+                            content[i][4] = "高级";
+                            break;
+                    }
+
+                    if (alarmHistoryInfoList.get(i).getMessageType() == 1){
+                        content[i][5] = "触发";
+                    }else {
+                        content[i][5] = "解除";
+                    }
+                }
+                XSSFWorkbook wb = ExcelExportUtil.getHSSFWorkbook(sheetName, title, content, null);
+                this.setResponseHeader(response, filename);
+                //重点开始,创建压缩文件
+                int x = j + 1;
+                ZipEntry z = new ZipEntry("第"+ x + "份报警记录.xls");
+                zipOutputStream.putNextEntry(z);
+                ByteArrayOutputStream bos = new ByteArrayOutputStream();
+                //写入一个压缩文件
+                wb.write(bos);
+                bos.writeTo(zipOutputStream);
+            }
+            zipOutputStream.flush();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }finally {
+            //注意关闭顺序，否则可能文件错误
+            if (zipOutputStream != null) {
+                zipOutputStream.close();
+            }
+            if (out != null) {
+                out.close();
+            }
+        }
+    }
+
+    /**
+     * 向客户端发送响应流方法
+     *
+     * @param response
+     * @param fileName
+     */
+    public void setResponseHeader(HttpServletResponse response, String fileName) {
+        try {
+            try {
+                fileName = new String(fileName.getBytes(), "UTF-8");
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            }
+            response.setContentType("application/octet-stream; charset=utf-8");
+            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+    }
+
     @GetMapping(value = "/history/page")
     public IPage<AlarmHistoryInfo> queryByPage1(
             @RequestParam(value = "pagenum")Integer pageNum,

warning-web/src/main/java/com/gyee/wisdom/alarm/sharding/mapper/AlarmHisotryMapper.java

@@ -34,6 +34,32 @@ public interface AlarmHisotryMapper extends BaseMapper<AlarmHistory> {
                                          @Param("starttime") Date startTime,
                                          @Param("endtime") Date endTime);
 
+    List<AlarmHistoryInfo> queryAllByName(@Param("tbName") String tableName,
+                                         @Param("stid")String stationId,
+                                         @Param("wtid") String windturbineId,
+                                         @Param("category1") String category1,
+                                         @Param("category2") String category2,
+                                         @Param("rank") String rank,
+                                         @Param("modelid") String modelid,
+                                         @Param("snapid") Long snapid,
+                                         @Param("messagetype") Integer messagetype,
+                                         @Param("keyword") String keyword,
+                                         @Param("starttime") Date startTime,
+                                         @Param("endtime") Date endTime);
+
+    List<AlarmHistoryInfo> queryAll(@Param("tbName") String tableName,
+                                         @Param("stid")String stationId,
+                                         @Param("wtid") String windturbineId,
+                                         @Param("category1") String category1,
+                                         @Param("category2") String category2,
+                                         @Param("rank") String rank,
+                                         @Param("modelid") String modelid,
+                                         @Param("snapid") Long snapid,
+                                         @Param("messagetype") Integer messagetype,
+                                         @Param("keyword") String keyword,
+                                         @Param("starttime") Date startTime,
+                                         @Param("endtime") Date endTime);
+
     IPage<AlarmHistoryInfo> pageQueryAll2(Page page,
                                          @Param("simpleStationIdList") List<String> simplieStationIdList,
                                          @Param("yearmonth") String yearmonth,
@@ -49,6 +75,21 @@ public interface AlarmHisotryMapper extends BaseMapper<AlarmHistory> {
                                          @Param("starttime") Date startTime,
                                          @Param("endtime") Date endTime);
 
+    List<AlarmHistoryInfo> queryAll2(
+                                          @Param("simpleStationIdList") List<String> simplieStationIdList,
+                                          @Param("yearmonth") String yearmonth,
+                                          @Param("stid")String stationId,
+                                          @Param("wtid") String windturbineId,
+                                          @Param("category1") String category1,
+                                          @Param("category2") String category2,
+                                          @Param("rank") String rank,
+                                          @Param("modelid") String modelid,
+                                          @Param("snapid") Long snapid,
+                                          @Param("messagetype") Integer messagetype,
+                                          @Param("keyword") String keyword,
+                                          @Param("starttime") Date startTime,
+                                          @Param("endtime") Date endTime);
+
     int selectSnapCount(@Param("tbName") String tableName,
                         @Param("snapid") Long snapid,
                         @Param("starttime") Date startTime,

warning-web/src/main/java/com/gyee/wisdom/alarm/sharding/service/AlarmHistoryService.java

@@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.wisdom.alarm.sharding.config.ConfigProperties;
 import com.gyee.wisdom.alarm.sharding.entity.AlarmHistory;
-import com.gyee.wisdom.alarm.sharding.entity.AlarmSnap;
 import com.gyee.wisdom.alarm.sharding.entity.Windturbine;
 import com.gyee.wisdom.alarm.sharding.mapper.AlarmHisotryMapper;
 import com.gyee.wisdom.alarm.sharding.mapper.MainBrownoutsMapper;
@@ -18,7 +17,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -54,6 +52,109 @@ public class AlarmHistoryService extends ServiceImpl<AlarmHisotryMapper, AlarmHi
         return  alarmHisotryMapper.selectById(hisId);
     }
 
+
+    public List<AlarmHistoryInfo> queryAllExport(String stationId,
+                                                String windturbineId,
+                                                String category1,
+                                                String category2,
+                                                String rank,
+                                                String modelid,
+                                                Long snapId,
+                                                Integer messageType,
+                                                String keyword,
+                                                String startTime,
+                                                String endTime) {
+        try {
+
+            if (keyword != null && ("").equals(keyword.trim()))
+                keyword = "%" + keyword.trim() + "%";
+            startTime = startTime.trim();
+            endTime = endTime.trim();
+            Date dtStart = null;
+            Date dtEnd = null;
+            if (startTime != null && startTime != "") {
+                if (startTime.length() < 19)
+                    dtStart = DateUtil.parseDate(startTime);
+                else
+                    dtStart = DateUtil.parseDate1(startTime);
+            }
+            if (endTime != null && endTime != "") {
+                if (endTime.length() < 19)
+                    dtEnd = DateUtil.parseDate(endTime);
+                else
+                    dtEnd = DateUtil.parseDate1(endTime);
+            }
+
+
+            if (dtStart == null || dtEnd == null)
+                return null;
+
+            if (dtEnd.before(dtStart) || dtEnd.before(configProperties.getSetupDate()))
+                return null;
+
+            if (dtStart.before(configProperties.getSetupDate()))
+                dtStart = configProperties.getSetupDate();
+
+            Date dtNow = new Date();
+            if (dtStart.after(dtNow))
+                return null;
+
+            if (dtEnd.after(dtNow))
+                dtEnd = dtNow;
+
+
+            if (StringUtils.isNotBlank(windturbineId) && StringUtils.isBlank(stationId)) {
+                Windturbine windturbine = windturbineMapper.selectByPrimaryKey(windturbineId);
+                if (windturbine != null)
+                    stationId = windturbine.getWindpowerstationid();
+            }
+
+            if (stationId == null || ("").equals(stationId.trim())) {
+                String[] stationIds = tableNameService.getStationIds();
+                List<String> simpleStationIdList = Arrays.asList(stationIds).stream().map(s -> StringUtils.split(s, "_")[0]).collect(Collectors.toList());
+                //多场站查询，由近到远
+                List<String> yearMonthList = tableNameService.getYearAndMonthList(dtStart, dtEnd);
+                if (yearMonthList != null && yearMonthList.size() > 0) {
+                    if (yearMonthList.size() == 1) {
+                        return alarmHisotryMapper.queryAll2(simpleStationIdList, yearMonthList.get(0), stationId, windturbineId, category1, category2,
+                                rank, modelid, snapId, messageType, keyword, dtStart, dtEnd);
+                    } else {
+                        List<AlarmHistoryInfo> result = new ArrayList<>();
+                        for (String yearMonth : yearMonthList) {
+                            List<AlarmHistoryInfo> iPage = alarmHisotryMapper.queryAll2(simpleStationIdList, yearMonth, stationId, windturbineId, category1, category2,
+                                    rank, modelid, snapId, messageType, keyword, dtStart, dtEnd);
+                            result.addAll(iPage);
+                        }
+
+                        return result;
+                    }
+                }
+            }else {
+                    //表序： 由近到远
+                    long pageNum = 1;
+                    List<String> tbNames = tableNameService.getAlarmHistoryTableNames(stationId, dtStart, dtEnd);
+                    if (tbNames != null && tbNames.size() > 0) {
+                        if (tbNames.size() == 1) {
+                            return alarmHisotryMapper.queryAll(tbNames.get(0), stationId, windturbineId, category1, category2,
+                                    rank, modelid, snapId, messageType, keyword, dtStart, dtEnd);
+                        }
+                        List<AlarmHistoryInfo> list = new ArrayList<>();
+                        for (String tbName : tbNames) {
+                            List<AlarmHistoryInfo> alarmHistoryInfoList = alarmHisotryMapper.queryAllByName(tbName, stationId, windturbineId, category1, category2,
+                                    rank, modelid, snapId, messageType, keyword, dtStart, dtEnd);
+                            list.addAll(alarmHistoryInfoList);
+                        }
+
+                        return list;
+                    }
+                }
+            }catch(Exception ex){
+                log.error(ex.getMessage());
+                log.error(ex.getStackTrace().toString());
+            }
+            return null;
+    }
+
     //todo: 跨表分页bug
     public IPage<AlarmHistoryInfo> pageQueryAll(Page page,
                                                 String stationId,

warning-web/src/main/java/com/gyee/wisdom/alarm/sharding/util/ExcelExportUtil.java

@@ -0,0 +1,238 @@
+package com.gyee.wisdom.alarm.sharding.util;
+import org.apache.poi.hssf.usermodel.*;
+
+import org.apache.poi.hssf.util.HSSFColor;
+import org.apache.poi.ss.usermodel.*;
+import org.apache.poi.ss.util.CellRangeAddress;
+import org.apache.poi.xssf.usermodel.*;
+
+import java.util.List;
+
+/**
+ * @author ：xugp
+ * @date ：Created in 2022/10/17 16:25
+ * @description：
+ * @modified By：
+ * @version: $
+ */
+public class ExcelExportUtil {
+    /**
+     * 导出Excel
+     *
+     * @param sheetName sheet名称
+     * @param title     标题
+     * @param values    内容
+     * @param wb        HSSFWorkbook对象
+     * @return
+     */
+    public static XSSFWorkbook getHSSFWorkbook(String sheetName, String[] title, String[][] values, XSSFWorkbook wb) {
+
+        // 第一步，创建一个HSSFWorkbook，对应一个Excel文件
+        if (wb == null)
+            wb = new XSSFWorkbook();
+
+        // 第二步，在workbook中添加一个sheet,对应Excel文件中的sheet
+        XSSFSheet sheet = wb.createSheet(sheetName);
+
+        // 第三步，在sheet中添加表头第0行,注意老版本poi对Excel的行数列数有限制
+        XSSFRow row = sheet.createRow(0);
+
+        // 第四步，创建单元格，并设置值表头 设置表头居中
+        XSSFCellStyle style = wb.createCellStyle();
+        style.setAlignment(HSSFCellStyle.ALIGN_CENTER); // 创建一个居中格式
+
+        //声明列对象
+        XSSFCell cell = null;
+
+        //创建标题
+        for (int i = 0; i < title.length; i++) {
+            cell = row.createCell(i);
+            cell.setCellValue(title[i]);
+            cell.setCellStyle(style);
+        }
+
+        //创建内容
+        for (int i = 0; i < values.length; i++) {
+            row = sheet.createRow(i + 1);
+            for (int j = 0; j < values[i].length; j++) {
+                //将内容按顺序赋给对应的列对象
+                row.createCell(j).setCellValue(values[i][j]);
+            }
+        }
+        return wb;
+    }
+
+    /**
+     * 表显示字段
+     * @param wb
+     * @param sheet
+     * @param
+     * @return
+     */
+    public static int writeExcel(HSSFWorkbook wb, HSSFSheet sheet, List<String> titles, List<List<Object>> rows) {
+        int rowIndex = 0;
+        rowIndex = writeTitlesToExcel(wb, sheet, titles);
+        rowIndex = writeRowsToExcel(wb, sheet, rows, rowIndex);
+        autoSizeColumns(sheet, titles.size() + 1);
+        return rowIndex;
+    }
+
+    //表头样式
+    public static void showTitle(HSSFSheet sheet, int amount, HSSFWorkbook wb){
+        HSSFCellStyle cellStyle = wb.createCellStyle();
+        HSSFFont font = wb.createFont();
+        //设置字体首先要先引入一个字体的接口
+        font.setFontHeightInPoints((short) 14);//设置字体高度？24大小可修改（short）不改
+        font.setFontName("simsun");//设置什么样式的字体比如宋体什么的 Courier new字体样式可修改
+        font.setItalic(false);//倾斜字体
+        //设置粗体
+        font.setBoldweight(Short.MAX_VALUE);
+        cellStyle.setFont(font);
+        //第一行标题
+        //合并excel第一行
+        CellRangeAddress region = new CellRangeAddress(0, 0, 0, amount);
+        sheet.addMergedRegion(region);
+        HSSFRow oneRow = sheet.createRow(0);
+        oneRow.setHeightInPoints(25);
+        HSSFCell cell = oneRow.createCell(0);
+        cell.setCellValue("标题");
+        cell.setCellStyle(cellStyle);
+        //********************************************************
+        HSSFCellStyle cellStyle2 = wb.createCellStyle();
+        HSSFFont font2 = wb.createFont();
+        //设置字体首先要先引入一个字体的接口
+        font2.setFontHeightInPoints((short) 10);//设置字体高度？24大小可修改（short）不改
+        font2.setFontName("simsun");//设置什么样式的字体比如宋体什么的 Courier new字体样式可修改
+        font2.setItalic(false);//倾斜字体
+        font2.setColor(HSSFFont.COLOR_RED);
+        cellStyle2.setFont(font2);
+        //换行的话加一个\n就可以但是在样式中要设置他可以换行
+        cellStyle2.setWrapText(true);//设置可以换行
+        String remark="测试测试测试";
+        //合并第二行单元格，加一些说明 remark
+        CellRangeAddress region2 = new CellRangeAddress(1, 1, 0, amount);
+        sheet.addMergedRegion(region2);
+        HSSFRow twoRow = sheet.createRow(1);
+        twoRow.setHeightInPoints(100);
+        HSSFCell cel2 = twoRow.createCell(0);
+        cel2.setCellValue(remark);
+        cel2.setCellStyle(cellStyle2);
+    }
+
+
+    //列标题
+    private static int writeTitlesToExcel(HSSFWorkbook wb, HSSFSheet sheet, List<String> titles) {
+        int rowIndex = 2;
+        int colIndex = 0;
+        Font titleFont = wb.createFont();
+        //设置字体
+        titleFont.setFontName("simsun");
+        //设置粗体
+        titleFont.setBoldweight(Short.MAX_VALUE);
+        //设置字号
+        titleFont.setFontHeightInPoints((short) 14);
+        //设置颜色
+        titleFont.setColor(IndexedColors.BLACK.index);
+        HSSFCellStyle titleStyle = wb.createCellStyle();
+        //水平居中
+        titleStyle.setAlignment(HSSFCellStyle.ALIGN_CENTER);
+        //垂直居中
+        titleStyle.setVerticalAlignment(HSSFCellStyle.VERTICAL_CENTER);
+        //设置图案颜色
+        //设置填充方案
+        titleStyle.setFillForegroundColor(HSSFColor.YELLOW.index);
+        //设置自定义填充颜色
+        HSSFPalette customPalette=wb.getCustomPalette();
+        customPalette.setColorAtIndex(HSSFColor.LIME.index, (byte) 242,(byte) 242, (byte) 242);
+        //设置图案样式
+        titleStyle.setFillPattern(HSSFCellStyle.SOLID_FOREGROUND);
+        titleStyle.setFont(titleFont);
+        setBorder(titleStyle);
+        Row titleRow = sheet.createRow(rowIndex);
+        titleRow.setHeightInPoints(50);
+        colIndex = 0;
+        for (String field : titles) {
+            Cell cell = titleRow.createCell(colIndex);
+            cell.setCellValue(field);
+            cell.setCellStyle(titleStyle);
+            colIndex++;
+        }
+        rowIndex++;
+        return rowIndex;
+    }
+
+    /**
+     * 设置内容
+     *
+     * @param wb
+     * @param sheet
+     * @param rows
+     * @param rowIndex
+     * @return
+     */
+    private static int writeRowsToExcel(HSSFWorkbook wb, HSSFSheet sheet, List<List<Object>> rows, int rowIndex) {
+        int colIndex;
+        Font dataFont = wb.createFont();
+        dataFont.setFontName("simsun");
+        dataFont.setFontHeightInPoints((short) 12);
+        dataFont.setColor(IndexedColors.BLACK.index);
+        HSSFCellStyle dataStyle = wb.createCellStyle();
+        dataStyle.setAlignment(HSSFCellStyle.ALIGN_CENTER);
+        dataStyle.setVerticalAlignment(HSSFCellStyle.VERTICAL_CENTER);
+        dataStyle.setFont(dataFont);
+        setBorder(dataStyle);
+        for (List<Object> rowData : rows) {
+            Row dataRow = sheet.createRow(rowIndex);
+            dataRow.setHeightInPoints(25);
+            colIndex = 0;
+            for (Object cellData : rowData) {
+                Cell cell = dataRow.createCell(colIndex);
+                if (cellData != null) {
+                    cell.setCellValue(cellData.toString());
+                } else {
+                    cell.setCellValue("");
+                }
+                cell.setCellStyle(dataStyle);
+                colIndex++;
+            }
+            rowIndex++;
+        }
+        return rowIndex;
+    }
+
+    /**
+     * 自动调整列宽
+     *
+     * @param sheet
+     * @param columnNumber
+     */
+    private static void autoSizeColumns(Sheet sheet, int columnNumber) {
+        for (int i = 0; i < columnNumber; i++) {
+            int orgWidth = sheet.getColumnWidth(i)+300;
+            sheet.autoSizeColumn(i, true);
+            int newWidth = (int) (sheet.getColumnWidth(i) + 300);
+            if (newWidth > orgWidth) {
+                sheet.setColumnWidth(i, newWidth);
+            } else {
+                sheet.setColumnWidth(i, orgWidth);
+            }
+        }
+    }
+
+
+    /**
+     * 设置边框
+     *
+     * @param style
+     */
+    private static void setBorder(HSSFCellStyle style) {
+        style.setBorderBottom(HSSFCellStyle.BORDER_THIN); //下边框
+        style.setBorderLeft(HSSFCellStyle.BORDER_THIN);//左边框
+        style.setBorderTop(HSSFCellStyle.BORDER_THIN);//上边框
+        style.setBorderRight(HSSFCellStyle.BORDER_THIN);//右边框
+        style.setFillPattern(HSSFCellStyle.SOLID_FOREGROUND);
+        style.setWrapText(true);//设置自动换行
+
+    }
+
+}

warning-web/src/main/resources/mappers-oracle/AlarmHistoryMapper.xml

@@ -27,6 +27,61 @@
         <!--SELECT 1 FROM DUAL-->
     <!--</insert>-->
 
+    <select id="queryAllByName" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
     <!-- 单表查询 -->
     <select id="pageQueryAll" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
         select a.*,
@@ -86,6 +141,119 @@
         order by a.alerttime  desc
     </select>
 
+    <select id="queryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from (
+        <foreach collection="simpleStationIdList" item="station" index="index" separator="union">
+            select * from alarmhistory_${station}_${yearmonth}
+        </foreach>
+        ) a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime,jdbcType=DATE} and a.alerttime &lt;= #{endtime,jdbcType=DATE}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
+    <select id="queryAll" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
 
     <!-- 联合查询 -->
     <select id="pageQueryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">

warning-web/src/main/resources/mappers-postgresql/AlarmHistoryMapper.xml

@@ -27,6 +27,61 @@
         <!--SELECT 1 FROM DUAL-->
     <!--</insert>-->
 
+    <select id="queryAllByName" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
     <!-- 单表查询 -->
     <select id="pageQueryAll" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
         select a.*,
@@ -83,6 +138,119 @@
         order by a.alerttime  desc
     </select>
 
+    <select id="queryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from (
+        <foreach collection="simpleStationIdList" item="station" index="index" separator="union">
+            select * from alarmhistory_${station}_${yearmonth}
+        </foreach>
+        ) a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime,jdbcType=DATE} and a.alerttime &lt;= #{endtime,jdbcType=DATE}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
+    <select id="queryAll" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
 
     <!-- 联合查询 -->
     <select id="pageQueryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">

warning-web/src/main/resources/mappers/AlarmHistoryMapper.xml

@@ -83,6 +83,116 @@
         order by a.alerttime  desc
     </select>
 
+    <select id="queryAllByName" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
+    <select id="queryAll" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from ${tbName} a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime} and a.alerttime &lt;= #{endtime}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
 
     <!-- 联合查询 -->
     <select id="pageQueryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
@@ -144,6 +254,65 @@
         order by a.alerttime  desc
     </select>
 
+    <select id="queryAll2" parameterType="java.util.Map" resultType="com.gyee.wisdom.alarm.sharding.model.AlarmHistoryInfo">
+        select a.*,
+        b.stationid,
+        b.windturbineid,
+        b.projectid,
+        b.lineid,
+        b.alertvalue,
+        b.category1,
+        b.category2,
+        b.category3,
+        b.rank,
+        b.stationname,
+        b.projectname,
+        b.linename,
+        b.windturbinename,
+        b.alerttext,
+        b.modelid
+        from (
+        <foreach collection="simpleStationIdList" item="station" index="index" separator="union">
+            select * from alarmhistory_${station}_${yearmonth}
+        </foreach>
+        ) a
+        left join alarmsnap b on a.snapid = b.id
+        <where>
+            1=1
+            <if test="starttime !=null and endtime !=null">
+                and a.alerttime &gt;= #{starttime,jdbcType=DATE} and a.alerttime &lt;= #{endtime,jdbcType=DATE}
+            </if>
+            <if test="stid !=null and stid !=''">
+                and b.stationid=#{stid}
+            </if>
+            <if test="wtid !=null and wtid !=''">
+                and b.windturbineid=#{wtid}
+            </if>
+            <if test="category1 !=null and category1 !=''">
+                and b.category1=#{category1}
+            </if>
+            <if test="category2 !=null and category2 !=''">
+                and b.category2=#{category2}
+            </if>
+            <if test="rank !=null and rank !=''">
+                and b.rank=#{rank}
+            </if>
+            <if test="modelid !=null and modelid !=''">
+                and b.modelid=#{modelid}
+            </if>
+            <if test="snapid !=null ">
+                and a.snapid=#{snapid}
+            </if>
+            <if test="messagetype !=null ">
+                and a.messagetype=#{messagetype}
+            </if>
+            <if test="keyword !=null and keyword !=''">
+                and b.alerttext like '%${keyword}%'
+            </if>
+        </where>
+        order by a.alerttime  desc
+    </select>
+
     <select id="selectSnapCount" parameterType="java.util.Map" resultType="java.lang.Integer">
         select count(*) from ${tbName} where snapid = #{snapid}
             and messagetype = '1'