修改告警阈值重启线程

whyclxw

2024-04-28 b25b814a949d2065a61fd3167206ffb51a57af65

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

@@ -3,6 +3,7 @@
import com.whyc.dto.InterfaceParam;
import com.whyc.dto.ReportBattDTO;
import com.whyc.dto.StandardFeatureCurve;
import com.whyc.dto.UpsAlarmDTO;
import com.whyc.dto.paramter.AlarmPar;
import com.whyc.dto.paramter.DevAlarmPar;
import com.whyc.dto.result.AlarmRes;
@@ -28,7 +29,7 @@
    private MybatisSqlExecuteService sqlExecuteService;
    //2,7,33,55，72，78，109-SubTablePageInfoUtils.java;201行,435行
    public List<PwrdevAlarmHistory> getList2(PwrdevAlarmHistory data){
        String sql="select  alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5 " +
        String sql="select  alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5,inf.PowerDeviceName " +
            " from db_pwrdev_alarm."+data.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
            " where alarm.PowerDeviceId = inf.PowerDeviceId ";
        if(data.getStationName1()!=null){
@@ -84,6 +85,7 @@
                    ph.setNum(rs.getLong("num"));
                    ph.setRecordId(rs.getLong("record_id"));
                    ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
                    ph.setPowerDeviceName(rs.getString("PowerDeviceName"));
                    ph.setAlmType(rs.getInt("alm_type"));
                    ph.setAlmLevel(rs.getInt("alm_level"));
                    ph.setAlmSource(rs.getInt("alm_source"));
@@ -112,7 +114,7 @@

    //3,53,54,77,102,127,136-SubTablePageInfoUtils.java;72行 211行,445行
    public List<PwrdevAlarmHistory> getListForTX(PwrdevAlarmHistory data){
        String sql="select  alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5 " +
        String sql="select  alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5,inf.PowerDeviceName " +
        " from db_pwrdev_alarm."+data.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
        " where alarm.PowerDeviceId = inf.PowerDeviceId ";
        if(data.getStationName1()!=null){
@@ -178,6 +180,7 @@
                    ph.setNum(rs.getLong("num"));
                    ph.setRecordId(rs.getLong("record_id"));
                    ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
                    ph.setPowerDeviceName(rs.getString("PowerDeviceName"));
                    ph.setAlmType(rs.getInt("alm_type"));
                    ph.setAlmLevel(rs.getInt("alm_level"));
                    ph.setAlmSource(rs.getInt("alm_source"));
@@ -668,6 +671,59 @@
        }
        return num;
    }
    //13,14,17,36，94-SubTablePageInfoUtils.java;88行
    public int getCount_stationId(DevAlarmPar param){
        String sql="SELECT count(distinct history.num) as number FROM db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf " +
                " where  history.dev_id=db_battinf.tb_battinf.FbsDeviceId ";
        /*if(param.getStationName1()!=null){
            if(param.getStationName1().equals("")){
                sql+=" and stationName1!='"+param.getStationName1()+"' ";
            }else{
                sql+=" and stationName1='"+param.getStationName1()+"' ";
            }
        }
        if(param.getStationName()!=null){
            if(param.getStationName().equals("")){
                sql+=" and stationName!='"+param.getStationName()+"' ";
            }else{
                sql+=" and stationName='"+param.getStationName()+"' ";
            }
        }*/
        if(param.getStationId()!=null){
            if(param.getStationId().equals("")){
                sql+=" and stationId!='"+param.getStationId()+"' ";
            }else{
                sql+=" and stationId='"+param.getStationId()+"' ";
            }
        }
        sql+="  and alm_start_time  >='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time  <='"+ThreadLocalUtil.format(param.getAlmStartTime1(),1)+"' ";
        sql+=" and history.dev_id in(select distinct db_battinf.tb_battinf.FbsDeviceId " +
                "            from " +
                "            db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " +
                "            where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
                "            and " +
                "            db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +
                "            and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +
                "            and db_user.tb_user_inf.uid="+param.getUId()+")";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                LinkedList<Object> temp = new LinkedList<>();
                try {
                    while (rs.next())
                        temp.add(rs.getInt("number"));
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                return temp;
            }
        });
        int num =0;
        if(list!=null){
            num= (int) list.get(0);
        }
        return num;
    }

    //15,41-PwrdevTimeOutAlarmService.java;28行 47行
    public List getList(int uId,String alarmParamTableName){
@@ -705,11 +761,75 @@
        });
        return list;
    }

    public List getList2_stationId(DevAlarmPar param){
        String sql=" SELECT   history.num,dev_id,dev_ip,alm_type,alm_level,alm_start_time,alm_end_time,alm_is_confirmed,alm_confirmed_time,alm_cleared_type,alm_severity,  " +
                "        db_battinf.tb_battinf.stationName,stationName1,stationName2,stationName3,stationName5,db_battinf.tb_battinf.stationName4 as dev_name  " +
                "        FROM db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf  " +
                " where history.dev_id=db_battinf.tb_battinf.FbsDeviceId  ";
        /*if(param.getStationName1()!=null){
            if(param.getStationName1().equals("")){
                sql+=" and stationName1!='"+param.getStationName1()+"' ";
            }else{
                sql+=" and stationName1='"+param.getStationName1()+"' ";
            }
        }
        if(param.getStationName()!=null){
            if(param.getStationName().equals("")){
                sql+=" and stationName!='"+param.getStationName()+"' ";
            }else{
                sql+=" and stationName='"+param.getStationName()+"' ";
            }
        }*/
        if(param.getStationId()!=null){
            if(param.getStationId().equals("")){
                sql+=" and stationId!='"+param.getStationId()+"' ";
            }else{
                sql+=" and stationId='"+param.getStationId()+"' ";
            }
        }
        sql+="  and alm_start_time  >='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time  <='"+ThreadLocalUtil.format(param.getAlmStartTime1(),1)+"' ";
        sql+=" and history.dev_id in(select distinct db_battinf.tb_battinf.FbsDeviceId  " +
                "            from  " +
                "            db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf  " +
                "            where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId  " +
                "            and  " +
                "            db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id  " +
                "            and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid  " +
                "            and db_user.tb_user_inf.uid="+param.getUId()+") " +
                "  ORDER BY alm_start_time desc ,dev_name asc limit "+param.getLimitStart()+","+param.getLimitEnd()+" ";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<DevalarmDataHistory> list=new ArrayList<>();
                while (rs.next()){
                    DevalarmDataHistory ph=new DevalarmDataHistory();
                    ph.setNum(rs.getLong("num"));
                    ph.setDevId(rs.getInt("dev_id"));
                    ph.setDevIp(rs.getString("dev_ip"));
                    ph.setAlmType(rs.getInt("alm_type"));
                    ph.setAlmLevel(rs.getInt("alm_level"));
                    ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
                    ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
                    ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
                    ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
                    ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
                    ph.setDevName(rs.getString("dev_name"));
                    ph.setStationName(rs.getString("stationName"));
                    ph.setStationName1(rs.getString("stationName1"));
                    ph.setStationName2(rs.getString("stationName2"));
                    ph.setStationName3(rs.getString("stationName3"));
                    ph.setStationName5(rs.getString("stationName5"));
                    list.add(ph);
                }
                return list;
            }
        });
        return list;
    }
    //16,19,30，61,105，111,123-SubTablePageInfoUtils.java;188行 422行
    public List getList2(DevAlarmPar param){
        String sql=" SELECT   history.num,dev_id,dev_ip,alm_type,alm_level,alm_start_time,alm_end_time,alm_is_confirmed,alm_confirmed_time,alm_cleared_type,alm_severity,  " +
                "        db_battinf.tb_battinf.stationName,stationName1,stationName2,stationName3,stationName5,db_battinf.tb_battinf.FbsDeviceName as dev_name  " +
                "        db_battinf.tb_battinf.stationName,stationName1,stationName2,stationName3,stationName5,db_battinf.tb_battinf.stationName4 as dev_name  " +
                "        FROM db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf  " +
                " where history.dev_id=db_battinf.tb_battinf.FbsDeviceId  ";
        if(param.getStationName1()!=null){
@@ -1961,7 +2081,7 @@
        }
        sqlExecuteService.execute(sql);
    }
    //
    //100-StandardFeatureCurveMapper.xml;12行
    public void createTable(String titleNameUnion){
        String sql="CREATE TABLE `web_site`.`tb_standard_feature_curve_"+titleNameUnion+"` ( " +
                "        `id` INT NOT NULL AUTO_INCREMENT, " +
@@ -2247,7 +2367,7 @@
        return  list;
    }

    //
    //97-Ld9testdatastopMapper.xml;11行
    public List<Ld9testdatastop> serchByCondition(int testRecordCount, int battGroupId){
        String sql=" select num,BattGroupId,test_record_count,test_type,test_starttime,record_time,test_timelong,group_vol,test_curr,test_cap,mon_cap,mon_rest_cap,mon_num,mon_vol,test_monnum,max_monvol,min_monvol,test_stopreason " +
                "        from db_ld9_testdata.tb_ld9testdatastop_"+battGroupId+" " +
@@ -2307,12 +2427,12 @@
        return monVol;
    }

    //23-ElePriceMapper.xml;8行
    //64-ElePriceMapper.xml;18行
    public void deleteEleprice(String tableName){
        String sql=" delete from web_site."+tableName+" ";
        sqlExecuteService.execute(sql);
    }
    //
    //23-ElePriceMapper.xml;8行
    public void createEleprice(String tableName){
        String sql="CREATE TABLE IF NOT EXISTS web_site."+tableName+" ( " +
                "        `num` int(11) NOT NULL AUTO_INCREMENT, " +
@@ -2324,7 +2444,7 @@
                "        )";
        sqlExecuteService.execute(sql);
    }
    //
    //75-ElePriceMapper.xml;25行
    public List<ElePrice> getList(String tableName){
        String sql="select * from web_site."+tableName+" order by tmp_starttime asc";
        List<ElePrice> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
@@ -2409,7 +2529,7 @@
        return list;
    }

     //
     //92-BattRealdataMapper.xml;29行
    public  int searchMaxNum(BattRealdata realdata){
        String sql="select count(*) as maxNum " +
                "        from db_batt_history.tb_batt_realdata_"+realdata.getTableName()+" " +
@@ -2435,7 +2555,7 @@
        }
        return maxNum;
    }
    //
    //105-BattRealdataMapper.xml;36行
    public  int searchMinNum(BattRealdata realdata){
        String sql="select min(num) as minNum " +
                "        from db_batt_history.tb_batt_realdata_"+realdata.getTableName()+" " +
@@ -2606,7 +2726,7 @@
        return  list;
    }

    //
    //59-Ld9testdataMapper.xml;6行
    public List<Ld9testdata>  serchByInfo(Ld9testdata ld9testdata){
        String sql=" select test_monnum,max(record_num) as record_nums,BattGroupId,test_record_count " +
                "        from db_ld9_testdata.tb_ld9testdata_"+ld9testdata.getBattGroupId()+" " +
@@ -2629,7 +2749,7 @@
        });
        return  list;
    }
    //
    //73-Ld9testdataMapper.xml;17行
    public  List<Ld9testdata> getLD9AllGroupByTestRecordCount(Ld9testdataInf ld9inf){
        String sql="select * from db_ld9_testdata.tb_ld9testdata_"+ld9inf.getBattGroupId()+" " +
                "        where test_record_count="+ld9inf.getTestRecordCount()+"  order by mon_num asc";
@@ -2664,7 +2784,7 @@
        return  list;
    }

    //
    //62-Ld9testdataMapper.xml;22行
    public Map getLD9AllGroupTimeLong(Ld9testdataInf ld9inf){
        String sql="select mon_num,max(test_timelong) as max_testTimelong " +
                "        from db_ld9_testdata.tb_ld9testdata_"+ld9inf.getBattGroupId()+" " +
@@ -2722,7 +2842,7 @@

    }

    //
    //65-BattTestDataStopMapper.xml;6行
    public BattTestDataStop findByMonNum(Integer battGroupId,Integer monNum){
        String sql="select stop.battgroupid,stop.test_curr,stop.test_cap,stop.mon_vol,stop.test_record_count,stop.mon_num,stop.group_vol,inf.max_monvol " +
                "        from db_batt_testdata.tb_batttestdatastop_"+battGroupId+" stop,db_batt_testdata.tb_batttestdata_inf inf " +
@@ -2755,7 +2875,7 @@
        return btsp;
    }

    //
    //77-BattTestDataStopMapper.xml;13行
    public Float getRealCap(BattTestDataStop stop){
        String sql=" select test_cap from db_batt_testdata.tb_batttestdata_"+stop.getBattGroupId()+" " +
                "        where test_record_count="+stop.getTestRecordCount()+"  and mon_vol>"+stop.getMonVol()+" and mon_num="+stop.getMonNum()+" and data_available=1 " +
@@ -2777,7 +2897,7 @@
        return test_cap;
    }

    //
    //89-BattTestDataStopMapper.xml;20行
    public List<BattTestDataStop> getTestDataStop(Integer battGroupId, Date testStarttime){
        String sql=" select num,BattGroupId,test_record_count,test_type,data_new,data_available,record_num,test_starttime,record_time,test_timelong,online_vol" +
                ",group_vol,test_curr,test_cap,mon_num,mon_vol,mon_tmp " +
@@ -2814,7 +2934,7 @@
        return list;
    }

    //38-BattMaintDealarmMapper.xml;226行
    //38,67--BattMaintDealarmMapper.xml;226行 210
    public List<ReportBattResultDTO> searchByBattGroupId5(ReportBattDTO dto){
        String sql=" select  distinct(db_battinf.tb_battinf.BattgroupId),moncount,moncapstd,monvolstd,monresstd,monserstd,FloatVolLevel,OfflineVolLevel " +
                "        ,db_batt_testdata.tb_battresdata_inf.battgroupid,db_batt_testdata.tb_battresdata_inf.test_record_count " +
@@ -2903,7 +3023,7 @@
        return list;
    }

    //
    //76-FBOTestDataMapper.xml;27行
    public int getMonCuntBytestRecordCount(int battGroupId, int testRecordCount){
        String sql="select  if(max(mon_num) is null,0,max(mon_num)) as monCount  " +
                "from db_fbo_testdata.tb_fbotestdata_"+battGroupId+" where test_record_count = "+testRecordCount+" limit 1";
@@ -3060,4 +3180,301 @@
        return list;
    }

    //60-PwrdevAlarmParamMapper.xml;27行
    public int updateParam(PwrdevAlarmParam param){
        String sql=" update db_pwrdev_alarm.tb_pwrdev_alarm_param_"+param.getPowerDeviceId()+" set alarm_limitH ="+param.getAlarmLimith()+"," +
                "        alarm_limitL ="+param.getAlarmLimitl()+",alarm_level="+param.getAlarmLevel()+
                ",UserAlarm_EN="+param.getUseralarmEn()+" where alarm_id ="+param.getAlarmId()+" ";
        int flag=sqlExecuteService.executeUpdate(sql,null);
        return flag;
    }

    //61-BattResDataMapper.xml;21行
    public List serchisStandard(int battGroupId){
        String sql=" select * from db_batt_testdata.tb_battresdata_"+battGroupId+" where isStandard=1 ";
        List<BattResData> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattResData> list=new ArrayList<>();
                while (rs.next()){
                    BattResData bh=new BattResData();
                    bh.setNum(rs.getLong("num"));
                    bh.setBattGroupId(rs.getInt("BattGroupId"));
                    bh.setTestRecordCount(rs.getInt("test_record_count"));
                    bh.setTestType(rs.getInt("test_type"));
                    bh.setDataNew(rs.getInt("data_new"));
                    bh.setDataAvailable(rs.getInt("data_available"));
                    bh.setTestStartTime(rs.getTimestamp("test_starttime"));
                    bh.setGroupVol(rs.getFloat("group_vol"));
                    bh.setTestCurr(rs.getFloat("test_curr"));
                    bh.setMonNum(rs.getInt("mon_num"));
                    bh.setMonVol(rs.getFloat("mon_vol"));
                    bh.setMonTemp(rs.getFloat("mon_tmp"));
                    bh.setMonSer(rs.getFloat("mon_ser"));
                    bh.setMonRes(rs.getFloat("mon_res"));
                    bh.setConnRes(rs.getFloat("conn_res"));
                    list.add(bh);
                }
                return list;
            }
        });
        return list;
    }

    //78-BattResDataMapper.xml;24行
    public  List serchCurrent( int battGroupId){
        String sql=" select * from db_batt_testdata.tb_battresdata_"+battGroupId+" " +
                "        where test_starttime=( " +
                "        SELECT DISTINCT test_starttime from db_batt_testdata.tb_battresdata_inf  where BattGroupId="+battGroupId+"  order by test_starttime desc limit 1 " +
                "        )";
        List<BattResData> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattResData> list=new ArrayList<>();
                while (rs.next()){
                    BattResData bh=new BattResData();
                    bh.setNum(rs.getLong("num"));
                    bh.setBattGroupId(rs.getInt("BattGroupId"));
                    bh.setTestRecordCount(rs.getInt("test_record_count"));
                    bh.setTestType(rs.getInt("test_type"));
                    bh.setDataNew(rs.getInt("data_new"));
                    bh.setDataAvailable(rs.getInt("data_available"));
                    bh.setTestStartTime(rs.getTimestamp("test_starttime"));
                    bh.setGroupVol(rs.getFloat("group_vol"));
                    bh.setTestCurr(rs.getFloat("test_curr"));
                    bh.setMonNum(rs.getInt("mon_num"));
                    bh.setMonVol(rs.getFloat("mon_vol"));
                    bh.setMonTemp(rs.getFloat("mon_tmp"));
                    bh.setMonSer(rs.getFloat("mon_ser"));
                    bh.setMonRes(rs.getFloat("mon_res"));
                    bh.setConnRes(rs.getFloat("conn_res"));
                    list.add(bh);
                }
                return list;
            }
        });
        return list;
    }
    //96-BattResDataMapper.xml;18行
    public List<BattResData> getResInfoByBattGroupId( int battGroupId){
        String sql="select * from db_batt_testdata.tb_battresdata_"+battGroupId+" order by test_starttime desc";
        List<BattResData> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BattResData> list=new ArrayList<>();
                while (rs.next()){
                    BattResData bh=new BattResData();
                    bh.setNum(rs.getLong("num"));
                    bh.setBattGroupId(rs.getInt("BattGroupId"));
                    bh.setTestRecordCount(rs.getInt("test_record_count"));
                    bh.setTestType(rs.getInt("test_type"));
                    bh.setDataNew(rs.getInt("data_new"));
                    bh.setDataAvailable(rs.getInt("data_available"));
                    bh.setTestStartTime(rs.getTimestamp("test_starttime"));
                    bh.setGroupVol(rs.getFloat("group_vol"));
                    bh.setTestCurr(rs.getFloat("test_curr"));
                    bh.setMonNum(rs.getInt("mon_num"));
                    bh.setMonVol(rs.getFloat("mon_vol"));
                    bh.setMonTemp(rs.getFloat("mon_tmp"));
                    bh.setMonSer(rs.getFloat("mon_ser"));
                    bh.setMonRes(rs.getFloat("mon_res"));
                    bh.setConnRes(rs.getFloat("conn_res"));
                    list.add(bh);
                }
                return list;
            }
        });
        return list;
    }

    //108-BattResDataMapper.xml;4行
    public void deleteByTestRecordCount(Integer battGroupId, Integer testRecordCount){
        String sql="delete from db_batt_testdata.tb_battresdata_"+battGroupId+" where test_record_count = "+testRecordCount+"";
        sqlExecuteService.execute(sql);
    }

    //93-CommonMapper.xml;160行
    public void truncate(String dbName, String tableName){
        String sql="TRUNCATE "+dbName+".`"+tableName+"`";
        sqlExecuteService.execute(sql);
    }

    //107-PwrdevHistorydataGwMapper.xml;5行
    public int judgeTable_pwr(String table){
        String sql=" select count(*) as tableNum " +
                "        from INFORMATION_SCHEMA.TABLES " +
                "        where TABLE_SCHEMA = 'db_pwrdev_data_history_gw' " +
                "          and TABLE_NAME = 'tb_pwrdev_historydata_gw_"+table+"';";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                LinkedList<Object> temp = new LinkedList<>();
                try {
                    while (rs.next())
                        temp.add(rs.getInt("tableNum"));
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                return temp;
            }
        });
        int tableNum =0;
        if(list!=null){
            tableNum= (int) list.get(0);
        }
        return tableNum;
    }
    //查询ups历史告警数量
    public int getCountForUps(UpsAlarmDTO param) {
        String sql="select  count(distinct alarm.num) as number from db_upspwrdev_alarm."+param.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
                "  where alarm.power_device_id = inf.PowerDeviceId ";
        if(param.getStationName1()!=null){
            sql+=" and stationName1 like '%"+param.getStationName1()+"%'";
        }
        if(param.getStationName2()!=null){
            sql+=" and stationName2 like '%"+param.getStationName2()+"%'";
        }
        if(param.getStationName5()!=null){
            sql+=" and stationName5 like '%"+param.getStationName5()+"%'";
        }
        if(param.getStationName3()!=null){
            sql+=" and stationName3 like '%"+param.getStationName3()+"%'";
        }
        /*if(param.getPwrdevId()!=0){
            sql+=" and alarm.power_device_id="+param.getPwrdevId();
        }*/
        if(param.getAlmStartTime()!=null){
            sql+=" and alarm.alm_start_time  >='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' ";
        }
        if(param.getAlmEndTime()!=null){
            sql+=" and alarm.alm_start_time  <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' ";
        }
        if(param.getAlmTypes()!=null&&param.getAlmTypes().size()>0){
            sql+=" and alm_type in ( ";
            for (int i=0;i<param.getAlmTypes().size();i++) {
                sql+=param.getAlmTypes().get(i);
                if(i!=(param.getAlmTypes().size()-1)){
                    sql+=",";
                }
            }
            sql+=")";
        }
        sql+=" and alarm.power_device_id in ( select distinct inf.PowerDeviceId from" +
                "            (select PowerDeviceId,StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf," +
                "            db_user.tb_user_battgroup_baojigroup_battgroup," +
                "            db_user.tb_user_battgroup_baojigroup_usr," +
                "            db_user.tb_user_inf" +
                "            where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId" +
                "            and" +
                "            db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id" +
                "            and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid" +
                "            and db_user.tb_user_inf.uid="+param.getUsrId()+" )";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                LinkedList<Object> temp = new LinkedList<>();
                try {
                    while (rs.next())
                        temp.add(rs.getInt("number"));
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                return temp;
            }
        });
        int num =0;
        if(list!=null){
            num= (int) list.get(0);
        }
        return num;
    }
    //查询ups历史告警
    public List getList2(UpsAlarmDTO param){
        String sql=" SELECT   history.num,record_id,power_device_id,alm_type,alm_level,alm_start_time,alm_end_time,alm_value,alm_is_confirmed,alm_confirmed_time,alm_cleared_type,  " +
                "        inf.stationName,stationName1,stationName2,stationName3,stationName5,inf.PowerDeviceName as dev_name " +
                "        FROM db_upspwrdev_alarm."+param.getRecordYear()+" history,db_pwrdev_inf.tb_pwrdev_inf inf  " +
                " where history.power_device_id = inf.PowerDeviceId  ";
        if(param.getStationName1()!=null){
            sql+=" and stationName1 like '%"+param.getStationName1()+"%'";
        }
        if(param.getStationName2()!=null){
            sql+=" and stationName2 like '%"+param.getStationName2()+"%'";
        }
        if(param.getStationName5()!=null){
            sql+=" and stationName5 like '%"+param.getStationName5()+"%'";
        }
        if(param.getStationName3()!=null){
            sql+=" and stationName3 like '%"+param.getStationName3()+"%'";
        }
        if(param.getAlmTypes()!=null&&param.getAlmTypes().size()>0){
            sql+=" and alm_type in ( ";
            for (int i=0;i<param.getAlmTypes().size();i++) {
                sql+=param.getAlmTypes().get(i);
                if(i!=(param.getAlmTypes().size()-1)){
                    sql+=",";
                }
            }
            sql+=")";
        }
        sql+="  and alm_start_time  >='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time  <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' ";
        sql+=" and history.power_device_id in ( select distinct inf.PowerDeviceId from" +
                "            (select PowerDeviceId,StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf," +
                "            db_user.tb_user_battgroup_baojigroup_battgroup," +
                "            db_user.tb_user_battgroup_baojigroup_usr," +
                "            db_user.tb_user_inf" +
                "            where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId" +
                "            and" +
                "            db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id" +
                "            and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid" +
                "            and db_user.tb_user_inf.uid="+param.getUsrId()+" ) " +
                "  ORDER BY alm_start_time desc ,dev_name asc limit "+param.getLimitStart()+","+param.getLimitEnd()+" ";
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<UpspwrdevAlarmHistory> list=new ArrayList<>();
                while (rs.next()){
                    UpspwrdevAlarmHistory ph=new UpspwrdevAlarmHistory();
                    ph.setNum(rs.getLong("num"));
                    ph.setRecordId(rs.getLong("record_id"));
                    ph.setPowerDeviceId(rs.getLong("power_device_id"));
                    ph.setAlmType(rs.getInt("alm_type"));
                    ph.setAlmLevel(rs.getInt("alm_level"));
                    ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
                    ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
                    ph.setAlmValue(rs.getFloat("alm_value"));
                    ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
                    ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
                    ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
                    ph.setDevName(rs.getString("dev_name"));
                    ph.setStationName(rs.getString("stationName"));
                    ph.setStationName1(rs.getString("stationName1"));
                    ph.setStationName2(rs.getString("stationName2"));
                    ph.setStationName3(rs.getString("stationName3"));
                    ph.setStationName5(rs.getString("stationName5"));
                    list.add(ph);
                }
                return list;
            }
        });
        return list;
    }
    //ups历史告警确认
    public int setHisAlmIsConfirmed(int num, String year) {
        String sql=" update db_upspwrdev_alarm.tb_upspwrdev_alarm_history_"+year+" set alm_is_confirmed =1," +
                " where num = "+num+" ";
        int flag=sqlExecuteService.executeUpdate(sql,null);
        return flag;
    }
    //ups历史告警取消
    public int cancleHisAlmIsConfirmed(int num, String year) {
        String sql=" update db_upspwrdev_alarm.tb_upspwrdev_alarm_history_"+year+" set alm_is_confirmed =0," +
                " where num = "+num+" ";
        int flag=sqlExecuteService.executeUpdate(sql,null);
        return flag;
    }
    //ups历史告警删除
    public void delHisAlm(int num, String year) {
        String sql="delete from db_upspwrdev_alarm.tb_upspwrdev_alarm_history_"+year+" where num = "+num+"";
        sqlExecuteService.execute(sql);
    }
}