| | |
| | | }); |
| | | return list; |
| | | } |
| | | //电池数据历史实时处理(预警分析) |
| | | public List<RealDateDTO> getBattHisRealInAlm(BattRealdataId realdata) { |
| | | String sql=" select record_time, group_vol, online_vol,group_curr, mon_vol, mon_tmp, mon_res, mon_num,record_num " + |
| | | " from db_data_history.tb_batt_realdata_"+realdata.getTableName()+" " + |
| | | " where record_time >= '"+ThreadLocalUtil.format(realdata.getRecordTime(),1)+"' " + |
| | | " and record_time <= '"+ThreadLocalUtil.format(realdata.getRecordTime1(),1)+"' " + |
| | | " order by record_time asc,mon_num asc"; |
| | | List<RealDateDTO> list = sqlExecuteService.executeQuery_call(sql, new CallBack() { |
| | | @Override |
| | | public List getResults(ResultSet rs) throws SQLException { |
| | | List<RealDateDTO> list=new ArrayList<>(); |
| | | while (rs.next()){ |
| | | RealDateDTO ph=new RealDateDTO(); |
| | | ph.setRecordTime(rs.getTimestamp("record_time")); |
| | | ph.setGroupVol(rs.getFloat("group_vol")); |
| | | ph.setOnlineVol(rs.getFloat("online_vol")); |
| | | ph.setGroupCurr(rs.getFloat("group_curr")); |
| | | ph.setMonVol(rs.getFloat("mon_vol")); |
| | | ph.setMonTmp(rs.getFloat("mon_tmp")); |
| | | ph.setMonRes(rs.getFloat("mon_res")); |
| | | ph.setMonNum(rs.getInt("mon_num")); |
| | | ph.setRecordNum(rs.getInt("record_num")); |
| | | list.add(ph); |
| | | } |
| | | return list; |
| | | } |
| | | }); |
| | | return list; |
| | | } |
| | | //获取指定时间段内最大最小recordNum确保数据的完整 |
| | | public List getMaxAndMinRecordNum(BattRealdataId realdata) { |
| | | String sql="select max(record_num) as maxRecordNum,min(record_num) as minRecordNum " + |
| | |
| | | return list; |
| | | } |
| | | //1.2.7优良电源统计上一季度的电源某一属性和参数阈值超过的次数 |
| | | public List<QuarterPwr7Res> getPwrQuarter7(String tableName) { |
| | | public List<PwrdevHistorydataId> getPwrQuarter7(String tableName) { |
| | | String sql=" select distinct * " + |
| | | " from "+tableName+" " ; |
| | | sql+=" order by record_datetime asc"; |
| | | List<QuarterPwr7Res> list = sqlExecuteService.executeQuery_call(sql, new CallBack() { |
| | | List<PwrdevHistorydataId> list = sqlExecuteService.executeQuery_call(sql, new CallBack() { |
| | | @Override |
| | | public List getResults(ResultSet rs) throws SQLException { |
| | | List<QuarterPwr7Res> list=new ArrayList<>(); |
| | | List<PwrdevHistorydataId> list=new ArrayList<>(); |
| | | while (rs.next()){ |
| | | QuarterPwr7Res data=new QuarterPwr7Res(); |
| | | PwrdevHistorydataId data=new PwrdevHistorydataId(); |
| | | data.setRecordDatetime(rs.getTimestamp("record_datetime")); |
| | | data.setAcin1Vola(rs.getFloat("acin1_vola")); |
| | | data.setAcin1Volb(rs.getFloat("acin1_volb")); |
| | | data.setAcin1Volc(rs.getFloat("acin1_volc")); |
| | | data.setAcin2Vola(rs.getFloat("acin2_vola")); |
| | | data.setAcin2Volb(rs.getFloat("acin2_volb")); |
| | | data.setAcin2Volc(rs.getFloat("acin2_volc")); |
| | | data.setAcoutVola(rs.getFloat("acout_vola")); |
| | | data.setAcoutVolb(rs.getFloat("acout_volb")); |
| | | data.setAcoutVolc(rs.getFloat("acout_volc")); |
| | | data.setAcoutCurra(rs.getFloat("acout_curra")); |
| | | data.setAcoutCurrb(rs.getFloat("acout_currb")); |
| | | data.setAcoutCurrc(rs.getFloat("acout_currc")); |
| | | data.setDcoutVol(rs.getFloat("dcout_vol")); |
| | | data.setDcoutCurr(rs.getFloat("dcout_curr")); |
| | | |
| | | data.setBattgroup1Vol(rs.getFloat("battgroup1_vol")); |
| | | data.setBattgroup1Curr(rs.getFloat("battgroup1_curr")); |
| | | data.setBattgroup2Vol(rs.getFloat("battgroup2_vol")); |
| | | data.setBattgroup2Curr(rs.getFloat("battgroup2_curr")); |
| | | data.setTemprature(rs.getFloat("temprature")); |
| | | data.setMOutputvol(rs.getFloat("m_outputvol")); |
| | | data.setM1Outcurr(rs.getFloat("m1_outcurr")); |
| | | data.setM2Outcurr(rs.getFloat("m2_outcurr")); |
| | | data.setM3Outcurr(rs.getFloat("m3_outcurr")); |
| | | data.setM4Outcurr(rs.getFloat("m4_outcurr")); |
| | | data.setM5Outcurr(rs.getFloat("m5_outcurr")); |
| | | data.setM6Outcurr(rs.getFloat("m6_outcurr")); |
| | | data.setM7Outcurr(rs.getFloat("m7_outcurr")); |
| | | data.setM8Outcurr(rs.getFloat("m8_outcurr")); |
| | | data.setM9Outcurr(rs.getFloat("m9_outcurr")); |
| | | data.setM10Outcurr(rs.getFloat("m10_outcurr")); |
| | | data.setM11Outcurr(rs.getFloat("m11_outcurr")); |
| | | data.setM12Outcurr(rs.getFloat("m12_outcurr")); |
| | | data.setM13Outcurr(rs.getFloat("m13_outcurr")); |
| | | data.setM14Outcurr(rs.getFloat("m14_outcurr")); |
| | | data.setM15Outcurr(rs.getFloat("m15_outcurr")); |
| | | data.setM16Outcurr(rs.getFloat("m16_outcurr")); |
| | | |
| | | data.setAcin1Curra(rs.getFloat("acin1_curra")); |
| | | data.setAcin1Currb(rs.getFloat("acin1_currb")); |
| | | data.setAcin1Currc(rs.getFloat("acin1_currc")); |
| | | data.setLoaderCurr(rs.getFloat("loader_curr")); |
| | | data.setBattgroup1Ah(rs.getFloat("battgroup1_ah")); |
| | | data.setBattgroup1Temp(rs.getFloat("battgroup1_temp")); |
| | | data.setBattgroup2Ah(rs.getFloat("battgroup2_ah")); |
| | | data.setBattgroup2Temp(rs.getFloat("battgroup2_temp")); |
| | | data.setAcdcmTemp(rs.getFloat("acdcm_temp")); |
| | | data.setM1OutVol(rs.getFloat("m1_out_vol")); |
| | | data.setM2OutVol(rs.getFloat("m2_out_vol")); |
| | | data.setM3OutVol(rs.getFloat("m3_out_vol")); |
| | | data.setM4OutVol(rs.getFloat("m4_out_vol")); |
| | | data.setM5OutVol(rs.getFloat("m5_out_vol")); |
| | | data.setM6OutVol(rs.getFloat("m6_out_vol")); |
| | | data.setM7OutVol(rs.getFloat("m7_out_vol")); |
| | | data.setM8OutVol(rs.getFloat("m8_out_vol")); |
| | | data.setM9OutVol(rs.getFloat("m9_out_vol")); |
| | | data.setM10OutVol(rs.getFloat("m10_out_vol")); |
| | | data.setM11OutVol(rs.getFloat("m11_out_vol")); |
| | | data.setM12OutVol(rs.getFloat("m12_out_vol")); |
| | | data.setM13OutVol(rs.getFloat("m13_out_vol")); |
| | | data.setM14OutVol(rs.getFloat("m14_out_vol")); |
| | | data.setM15OutVol(rs.getFloat("m15_out_vol")); |
| | | data.setM16OutVol(rs.getFloat("m16_out_vol")); |
| | | |
| | | data.setUseracin1Vola(rs.getFloat("useracin1_vola")); |
| | | data.setUseracin1Volb(rs.getFloat("useracin1_volb")); |
| | | data.setUseracin1Volc(rs.getFloat("useracin1_volc")); |
| | | data.setUseracin1Curra(rs.getFloat("useracin1_curra")); |
| | | data.setUseracin1Currb(rs.getFloat("useracin1_currb")); |
| | | data.setUseracin1Currc(rs.getFloat("useracin1_currc")); |
| | | data.setUseracin1Freq(rs.getFloat("useracin1_freq")); |
| | | data.setUseracin2Vola(rs.getFloat("useracin2_vola")); |
| | | data.setUseracin2Volb(rs.getFloat("useracin2_volb")); |
| | | data.setUseracin2Volc(rs.getFloat("useracin2_volc")); |
| | | data.setUseracin2Curra(rs.getFloat("useracin2_curra")); |
| | | data.setUseracin2Currb(rs.getFloat("useracin2_currb")); |
| | | data.setUseracin2Currc(rs.getFloat("useracin2_currc")); |
| | | data.setUseracin2Freq(rs.getFloat("useracin2_freq")); |
| | | |
| | | data.setMTemper1(rs.getFloat("m_temper1")); |
| | | data.setMTemper2(rs.getFloat("m_temper2")); |
| | | data.setMTemper3(rs.getFloat("m_temper3")); |
| | | data.setMHumidity1(rs.getFloat("m_humidity1")); |
| | | data.setMHumidity2(rs.getFloat("m_humidity2")); |
| | | data.setMHumidity3(rs.getFloat("m_humidity3")); |
| | | list.add(data); |
| | | } |
| | | return list; |