whyclxw
2025-05-28 b83319baccfa93115782cc85e4d2d4db43c57624
电池组历史告警查询分开
4个文件已修改
50 ■■■■■ 已修改文件
src/main/java/com/whyc/pojo/db_alarm/BattalarmDataHistory.java 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/SubTablePageInfoService.java 32 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/util/SubTablePageInfoUtils.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/RealTimeSocket.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/pojo/db_alarm/BattalarmDataHistory.java
@@ -1,6 +1,7 @@
package com.whyc.pojo.db_alarm;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
@@ -76,5 +77,15 @@
    @ApiModelProperty(value = "告警重要等级[0:重要;1:紧急]")
    private Integer almSeverity;
    @TableField(exist = false)
    private String stationName;//机房名称
    @TableField(exist = false)
    private String provice;//机房名称
    @TableField(exist = false)
    private String city;//机房名称
    @TableField(exist = false)
    private String country;//机房名称
    @TableField(exist = false)
    private String battGroupName;//电池组名称
}
src/main/java/com/whyc/service/SubTablePageInfoService.java
@@ -83,7 +83,7 @@
        return num;
    }
    //获取电池组历史告警集合
    public List<BattAlarmRes> getBattAlmHisList(BattAlmPar param){
    public List<BattalarmDataHistory> getBattAlmHisList(BattAlmPar param){
        String sql="select history.battgroup_id,history.num,alm_signal_id,history.mon_num,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time,alm_severity  " +
                "        ,tb_station_inf.station_name,tb_station_inf.provice,tb_station_inf.city,tb_station_inf.country,tb_batt_inf.battgroup_name  " +
                "        from db_alarm."+param.getRecordYear()+" history,db_station.tb_station_inf,db_station.tb_batt_inf " +
@@ -125,7 +125,7 @@
        }
        sql+="   order by history.alm_start_time desc,history.battgroup_id asc,history.mon_num asc limit "+param.getLimitStart()+","+param.getLimitEnd()+" ";
        List<BattAlarmRes> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
        /*List<BattAlarmRes> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattAlarmRes> list=new ArrayList<>();
@@ -173,6 +173,34 @@
                }
                return list;
            }
        });*/
        List<BattalarmDataHistory> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattalarmDataHistory> list=new ArrayList<>();
                while (rs.next()){
                    BattalarmDataHistory data=new BattalarmDataHistory();
                    data.setNum(rs.getLong("num"));
                    data.setBattgroupId(rs.getInt("battgroup_id"));
                    data.setAlmSignalId(rs.getInt("alm_signal_id"));
                    data.setMonNum(rs.getInt("mon_num"));
                    data.setAlmValue(rs.getFloat("alm_value"));
                    data.setAlmLevel(rs.getInt("alm_level"));
                    data.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
                    data.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
                    data.setAlmStartTime(rs.getTimestamp("alm_start_time"));
                    data.setAlmEndTime(rs.getTimestamp("alm_end_time"));
                    data.setAlmSeverity(rs.getInt("alm_severity"));
                    data.setBattgroupId(rs.getInt("battgroup_id"));
                    data.setStationName(rs.getString("station_name"));
                    data.setProvice(rs.getString("provice"));
                    data.setCity(rs.getString("city"));
                    data.setCountry(rs.getString("country"));
                    data.setBattGroupName(rs.getString("battgroup_name"));
                    list.add(data);
                }
                return list;
            }
        });
        return list;
    }
src/main/java/com/whyc/util/SubTablePageInfoUtils.java
@@ -216,7 +216,7 @@
                data.setLimitStart(limitList.get(0));
                data.setLimitEnd(limitList.get(1));
                data.setRecordYear(recordYear);
                List<BattAlarmRes> list = subService.getBattAlmHisList(data);
                List<BattalarmDataHistory> list = subService.getBattAlmHisList(data);
                dataList.addAll(list);
            }
            else if (pojo instanceof DevAlmPar) {
src/main/java/com/whyc/webSocket/RealTimeSocket.java
@@ -297,6 +297,11 @@
    }
    //获取系统概述界面信息
    private Response getSystemPage(RealTimeDto realDto) {
        try {
        }catch (Exception e) {
            e.printStackTrace();
        }
        return new Response().set(1);
    }