修改

whyclxw

2024-07-01 0ce771b4a4ff5897dc91bb1b84a4561781b00ca5

 src/main/java/com/whyc/service/SubTablePageInfoService.java

@@ -129,11 +129,11 @@
        return list;
    }

    //查询beeak历史告警数量
    //查询break历史告警数量
    public int getCountForBreakAlm(BreakAlarmDto alm) {
        String sql="select  count(distinct num) as number from db_ckpwrdev_break_alarm." +alm.getRecordYear()+",db_ckpwrdev_break_alarm.tb_ckpowerdev_break_alarm_config,db_ckpwrdev_inf.tb_breaker_inf"
                +" where   tb_ckpowerdev_break_alarm.alm_id=tb_ckpowerdev_break_alarm_config.alm_id " +
                "            and tb_ckpowerdev_break_alarm_config.break_id=tb_breaker_inf.breaker_id ";
        String sql="select  count(distinct  breakAlarm.num) as number from db_ckpwrdev_break_alarm." +alm.getRecordYear()+" breakAlarm ,db_ckpwrdev_break_alarm.tb_ckpowerdev_break_alarm_config,db_ckpwrdev_inf.tb_breaker_inf"
                +" where   breakAlarm.alm_id=tb_ckpowerdev_break_alarm_config.alm_id " +
                "            and tb_ckpowerdev_break_alarm_config.breaker_id=tb_breaker_inf.breaker_id ";
        if(alm.getAlmStarttime()!=null){
            sql+=" and alm_starttime  >='"+ DateUtil.format_YYYY_MM_DD_HH_MM_SS(alm.getAlmStarttime())+"' ";
        }
@@ -141,13 +141,13 @@
            sql+=" and alm_endtime  <='"+DateUtil.format_YYYY_MM_DD_HH_MM_SS(alm.getAlmEndTime())+"' ";
        }
        if(alm.getAlmName()!=null){
            sql+=" and tb_ckpowerdev_break_alarm.alm_name="+alm.getAlmName();
            sql+=" and breakAlarm.alm_name='"+alm.getAlmName()+"'";
        }
        if(alm.getBreakerType()!=null){
            sql+=" and tb_breaker_inf.breaker_type=="+alm.getBreakerType();
            sql+=" and tb_breaker_inf.breaker_type='"+alm.getBreakerType()+"'";
        }
        if(alm.getBreakerName()!=null){
            sql+=" and tb_breaker_inf.breaker_name=="+alm.getBreakerName();
            sql+=" and tb_breaker_inf.breaker_name='"+alm.getBreakerName()+"'";
        }
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
@@ -171,9 +171,9 @@

    //查询break历史告警数量
    public List getListBreakAlm(BreakAlarmDto alm){
        String sql="select  * from db_ckpwrdev_break_alarm." +alm.getRecordYear()+",db_ckpwrdev_break_alarm.tb_ckpowerdev_break_alarm_config,db_ckpwrdev_inf.tb_breaker_inf"
                +" where   tb_ckpowerdev_break_alarm.alm_id=tb_ckpowerdev_break_alarm_config.alm_id " +
                "            and tb_ckpowerdev_break_alarm_config.break_id=tb_breaker_inf.breaker_id ";
        String sql="select  breakAlarm.*,breaker_type,breaker_name,breaker_addr from db_ckpwrdev_break_alarm." +alm.getRecordYear()+" breakAlarm,db_ckpwrdev_break_alarm.tb_ckpowerdev_break_alarm_config,db_ckpwrdev_inf.tb_breaker_inf"
                +" where   breakAlarm.alm_id=tb_ckpowerdev_break_alarm_config.alm_id " +
                "            and tb_ckpowerdev_break_alarm_config.breaker_id=tb_breaker_inf.breaker_id ";
        if(alm.getAlmStarttime()!=null){
            sql+=" and alm_starttime  >='"+ DateUtil.format_YYYY_MM_DD_HH_MM_SS(alm.getAlmStarttime())+"' ";
        }
@@ -181,13 +181,13 @@
            sql+=" and alm_endtime  <='"+DateUtil.format_YYYY_MM_DD_HH_MM_SS(alm.getAlmEndTime())+"' ";
        }
        if(alm.getAlmName()!=null){
            sql+=" and tb_ckpowerdev_break_alarm.alm_name="+alm.getAlmName();
            sql+=" and breakAlarm.alm_name='"+alm.getAlmName()+"'";
        }
        if(alm.getBreakerType()!=null){
            sql+=" and tb_breaker_inf.breaker_type=="+alm.getBreakerType();
            sql+=" and tb_breaker_inf.breaker_type='"+alm.getBreakerType()+"'";
        }
        if(alm.getBreakerName()!=null){
            sql+=" and tb_breaker_inf.breaker_name=="+alm.getBreakerName();
            sql+=" and tb_breaker_inf.breaker_name='"+alm.getBreakerName()+"'";
        }
        sql+="  ORDER BY alm_starttime desc limit "+alm.getLimitStart()+","+alm.getLimitEnd()+" ";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
@@ -206,6 +206,42 @@
                    ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
                    ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
                    ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
                    ph.setBreakerType(rs.getString("breaker_type"));
                    ph.setBreakerName(rs.getString("breaker_name"));
                    ph.setBreakerAddr(rs.getString("breaker_addr"));
                    list.add(ph);
                }
                return list;
            }
        });
        return list;
    }

    //查询所有的历史时间表
    public List getBreakAlmHisList() {
        String sql="SELECT table_name FROM information_schema.tables WHERE table_name LIKE 'tb_ckpowerdev_break_alarm_history%'";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<String> list=new ArrayList<>();
                while (rs.next()){
                    list.add(rs.getString("table_name"));
                }
                return list;
            }
        });
        return list;
    }
    //统计按照等级的告警信息
    public List<CKPowerDevBreakAlarmHistory> selectBreakLevelCountList(String tableYear) {
        String sql="select  alm_level from db_ckpwrdev_break_alarm." +tableYear;
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<CKPowerDevBreakAlarmHistory> list=new ArrayList<>();
                while (rs.next()){
                    CKPowerDevBreakAlarmHistory ph=new CKPowerDevBreakAlarmHistory();
                    ph.setAlmLevel(rs.getInt("alm_level"));
                    list.add(ph);
                }
                return list;