断路器告警历史查询

lxw

2023-12-14 d1b97b2eebbc4b928a321a29a7ee50197b7471d0

断路器告警历史查询

 src/main/java/com/whyc/controller/CKPowerDevBreakAlarmHistoryController.java

@@ -7,10 +7,7 @@
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;

import java.text.ParseException;

@@ -28,7 +25,7 @@
        return service.getPage(alarmDto);
    }

    @PostMapping("getCountByLevel")
    @GetMapping("getCountByLevel")
    @ApiOperation("头部统计")
    public Response getCountByLevel() throws InterruptedException {
        return service.getCountByLevel();

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

@@ -131,8 +131,8 @@

    //查询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 " +
        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.break_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,8 +171,8 @@

    //查询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 " +
        String sql="select  breakAlarm.* 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.break_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() {