From 3470b33466cfd9ce423a46220ff81f734fae9fb7 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期五, 20 六月 2025 11:32:34 +0800
Subject: [PATCH] 预警分析管理-主属性和配置属性
---
src/main/java/com/whyc/service/SubTablePageInfoService.java | 599 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 583 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/whyc/service/SubTablePageInfoService.java b/src/main/java/com/whyc/service/SubTablePageInfoService.java
index 46fb3dd..e126ffe 100644
--- a/src/main/java/com/whyc/service/SubTablePageInfoService.java
+++ b/src/main/java/com/whyc/service/SubTablePageInfoService.java
@@ -1,20 +1,27 @@
package com.whyc.service;
-import com.whyc.dto.AlmHis.BattAlarmRes;
import com.whyc.dto.AlmHis.BattAlmPar;
import com.whyc.dto.AlmHis.DevAlmPar;
import com.whyc.dto.AlmHis.PwrAlmPar;
+import com.whyc.dto.AnalysisAlm.ResAnalysis;
+import com.whyc.dto.Real.*;
+import com.whyc.dto.Statistic.QuarterPwr7Res;
import com.whyc.mapper.CallBack;
import com.whyc.pojo.db_alarm.BattalarmDataHistory;
import com.whyc.pojo.db_alarm.DevalarmDataHistory;
+import com.whyc.pojo.db_batt_testdata.BatttestdataId;
+import com.whyc.pojo.db_data_history.BattRealdataId;
+import com.whyc.pojo.db_data_history.PwrdevHistorydataId;
import com.whyc.pojo.db_pwrdev_alarm.PwrdevAlarmHistory;
import com.whyc.util.ThreadLocalUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.lang.reflect.Field;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;
+import java.util.stream.Collectors;
@Service
public class SubTablePageInfoService {
@@ -27,11 +34,11 @@
public int getBattAlmHisCount(BattAlmPar param){
String sql="select count(distinct history.num) as number " +
" from db_alarm."+param.getRecordYear()+" history,db_station.tb_station_inf,db_station.tb_batt_inf " +
- " where history.battgroup_id=tb_battinf.battgroup_id " +
+ " where history.battgroup_id=tb_batt_inf.battgroup_id " +
" and tb_batt_inf.station_id=tb_station_inf.station_id " +
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -83,15 +90,15 @@
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 " +
- " where history.battgroup_id=tb_battinf.battgroup_id " +
+ " where history.battgroup_id=tb_batt_inf.battgroup_id " +
" and tb_batt_inf.station_id=tb_station_inf.station_id " +
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -125,7 +132,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 +180,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;
}
@@ -184,7 +219,7 @@
" and tb_batt_inf.station_id=tb_station_inf.station_id "+
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -237,14 +272,14 @@
}
//鑾峰彇璁惧鍘嗗彶鍛婅闆嗗悎
public List getDevAlmHisList(DevAlmPar param){
- String sql="SELECT history.num,dev_id,dev_ip,alm_level,alm_start_time,alm_end_time,alm_is_confirmed,alm_confirmed_time,alm_cleared_type,alm_severity, " +
+ String sql="SELECT history.*, " +
" tb_station_inf.station_name,tb_station_inf.provice,tb_station_inf.city,tb_station_inf.country,tb_batt_inf.dev_name " +
" FROM db_alarm."+param.getRecordYear()+" history,db_station.tb_batt_inf,db_station.tb_station_inf " +
" where history.dev_id=tb_batt_inf.dev_id "+
" and tb_batt_inf.station_id=tb_station_inf.station_id "+
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -286,6 +321,7 @@
ph.setNum(rs.getLong("num"));
ph.setDevId(rs.getInt("dev_id"));
ph.setDevIp(rs.getString("dev_ip"));
+ ph.setAlmId(rs.getInt("alm_id"));
ph.setAlmLevel(rs.getInt("alm_level"));
ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
@@ -312,7 +348,7 @@
" and tb_power_inf.station_id=tb_station_inf.station_id "+
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -324,11 +360,11 @@
sql+=" and tb_station_inf.station_name like '%"+param.getStationName()+"%' ";
}
if(param.getAlmLevel()!=null){
- sql+=" and history.alm_level="+param.getAlmLevel()+" ";
+ sql+=" and alarm.alm_level="+param.getAlmLevel()+" ";
}
List<Integer> almIds=param.getAlmIds();
if(almIds!=null&&almIds.size()>0){
- sql+=" and history.alm_id in ( ";
+ sql+=" and alarm.alm_id in ( ";
for (int i=0;i<almIds.size();i++) {
sql+=almIds.get(i);
if(i!=(almIds.size()-1)){
@@ -373,7 +409,7 @@
" and tb_power_inf.station_id=tb_station_inf.station_id "+
" and alm_start_time>='"+ThreadLocalUtil.format(param.getAlmStartTime(),1)+"' and alm_start_time <='"+ThreadLocalUtil.format(param.getAlmEndTime(),1)+"' " ;
if(param.getProvice()!=null){
- sql+=" and tb_station_inf.province='"+param.getProvice()+"' ";
+ sql+=" and tb_station_inf.provice='"+param.getProvice()+"' ";
}
if(param.getCity()!=null){
sql+=" and tb_station_inf.city='"+param.getCity()+"' ";
@@ -385,11 +421,11 @@
sql+=" and tb_station_inf.station_name like '%"+param.getStationName()+"%' ";
}
if(param.getAlmLevel()!=null){
- sql+=" and history.alm_level="+param.getAlmLevel()+" ";
+ sql+=" and alarm.alm_level="+param.getAlmLevel()+" ";
}
List<Integer> almIds=param.getAlmIds();
if(almIds!=null&&almIds.size()>0){
- sql+=" and history.alm_id in ( ";
+ sql+=" and alarm.alm_id in ( ";
for (int i=0;i<almIds.size();i++) {
sql+=almIds.get(i);
if(i!=(almIds.size()-1)){
@@ -414,6 +450,7 @@
PwrdevAlarmHistory ph=new PwrdevAlarmHistory();
ph.setNum(rs.getLong("num"));
ph.setPowerId(rs.getInt("power_id"));
+ ph.setAlmId(rs.getInt("alm_id"));
ph.setPowerName(rs.getString("power_name"));
ph.setAlmLevel(rs.getInt("alm_level"));
ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
@@ -436,5 +473,535 @@
});
return list;
}
+ //鑾峰彇鐢垫睜缁勬煇涓�骞存湀鐨勬暟鎹�
+ public List<QuarterDto> getBattRealHis(String tableName, String columnName) {
+ String sql="select distinct mon_num,record_time,"+columnName+" from "+tableName+" order by record_time asc";
+ List<QuarterDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<QuarterDto> list=new ArrayList<>();
+ while (rs.next()){
+ QuarterDto data=new QuarterDto();
+ data.setRecordTime(rs.getTimestamp("record_time"));
+ data.setNumValue(rs.getFloat(columnName));
+ data.setMonNum(rs.getInt("mon_num"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //鑾峰彇琛ㄤ腑鏈�澶э紝鏈�灏忥紝骞冲潎鏁版嵁鍊�
+ public CompareDto getBattCompareHis(String tableName, String columnName) {
+ String sql="select max("+columnName+") as maxData,min("+columnName+") as minData,avg("+columnName+") as avgData"+" from "+tableName;
+ List<CompareDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<CompareDto> list=new ArrayList<>();
+ while (rs.next()){
+ CompareDto data=new CompareDto();
+ data.setMaxData(rs.getFloat("maxData"));
+ data.setMinData(rs.getFloat("minData"));
+ data.setAvgData(rs.getFloat("avgData"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ if(list!=null&&list.size()>0){
+ return list.get(0);
+ }else {
+ return null;
+ }
+ }
+ //鑾峰彇鍐呴樆鏁版嵁
+ public List<QuarterDto> getBattResInfData(Integer battgroupId,Integer testRecordCount) {
+ String sql="select distinct mon_num,test_starttime,mon_res, from db_batt_testdata.tb_battresdata_"+battgroupId
+ +" where test_record_count="+testRecordCount+" order by mon_num asc";
+ List<QuarterDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<QuarterDto> list=new ArrayList<>();
+ while (rs.next()){
+ QuarterDto data=new QuarterDto();
+ data.setMonNum(rs.getInt("mon_num"));
+ data.setNumValue(rs.getFloat("mon_res"));
+ data.setRecordTime(rs.getTimestamp("test_starttime"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //鎵捐繖娆℃斁鐢电殑鎸囧畾涓�绗旀暟鎹�
+ public List<BatttestdataId> getLastDataByBattgroupId(Integer battgroupId, Integer testRecordCount, Integer recordNum) {
+ String sql="select distinct * from db_batt_testdata.tb_batttestdata_"+battgroupId
+ +" where test_record_count="+testRecordCount+" and record_num="+recordNum+ " order by mon_num asc";
+ List<BatttestdataId> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<BatttestdataId> list=new ArrayList<>();
+ while (rs.next()){
+ BatttestdataId data=new BatttestdataId();
+ data.setBattgroupId(rs.getInt("battgroup_id"));
+ data.setTestRecordCount(rs.getInt("test_record_count"));
+ data.setTestStarttime(rs.getTimestamp("test_starttime"));
+ data.setOnlineVol(rs.getFloat("online_vol"));
+ data.setGroupVol(rs.getFloat("group_vol"));
+ data.setTestCurr(rs.getFloat("test_curr"));
+ data.setTestCap(rs.getFloat("test_cap"));
+ data.setMonNum(rs.getInt("mon_num"));
+ data.setMonVol(rs.getFloat("mon_vol"));
+ data.setMonRes(rs.getFloat("mon_res"));
+ data.setMonTmp(rs.getFloat("mon_tmp"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //绯荤粺姒傝鑾峰彇鍗婂皬鏃舵牳瀹硅澶囦俊鎭�(缁勭淇℃伅鍙栦竴涓崟浣撲俊鎭嵆鍙�)
+ public List<BattHisRealDto> getHalfHourBattDevData(String tableName,Integer granularity,String halfHourAgoTime) {
+ String sql="select distinct mon_num,record_time,group_vol,online_vol,group_curr,group_tmp,load_curr " +
+ "from (select a.*, (@i:= @i+1) as number " +
+ " from (select * from "+tableName+" "+
+ " where record_time>='"+halfHourAgoTime+"' and mon_num=1) a, " +
+ " (select @i:=0) b) c "+
+ " where c.number%"+granularity+"=0 or c.number=1 ";
+ sql+=" order by record_time asc";
+ List<BattHisRealDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<BattHisRealDto> list=new ArrayList<>();
+ while (rs.next()){
+ BattHisRealDto data=new BattHisRealDto();
+ data.setRecordTime(rs.getTimestamp("record_time"));
+ data.setGroupVol(rs.getFloat("group_vol"));
+ data.setOnlineVol(rs.getFloat("online_vol"));
+ data.setGroupCurr(rs.getFloat("group_curr"));
+ data.setGroupTmp(rs.getFloat("group_tmp"));
+ data.setLoadCurr(rs.getFloat("load_curr"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //绯荤粺姒傝鑾峰彇鍗婂皬鏃朵氦娴佽緭鍏ョ粺璁�
+ public List<PwrHisRealAcInDto> getHalfHourPwrHisAcinData(String tableName,Integer granularity,String halfHourAgoTime) {
+ String sql="select distinct record_datetime,acin1_vola,acin1_volb,acin1_volc,acin2_vola,acin2_volb,acin2_volc " +
+ ",acin1_curra,acin1_currb,acin1_currc,acin2_curra,acin2_currb,acin2_currc " +
+ "from (select a.*, (@i:= @i+1) as number " +
+ " from (select * from "+tableName+" "+
+ " where record_datetime>='"+halfHourAgoTime+"') a, " +
+ " (select @i:=0) b) c "+
+ " where c.number%"+granularity+"=0 or c.number=1 ";
+ sql+=" order by record_datetime asc";
+ List<PwrHisRealAcInDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<PwrHisRealAcInDto> list=new ArrayList<>();
+ while (rs.next()){
+ PwrHisRealAcInDto data=new PwrHisRealAcInDto();
+ 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.setAcin1Curra(rs.getFloat("acin1_curra"));
+ data.setAcin1Currb(rs.getFloat("acin1_currb"));
+ data.setAcin1Currc(rs.getFloat("acin1_currc"));
+ data.setAcin2Curra(rs.getFloat("acin2_curra"));
+ data.setAcin2Currb(rs.getFloat("acin2_currb"));
+ data.setAcin2Currc(rs.getFloat("acin2_currc"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ public List<PwrHisRealDcoutInDto> getHalfHourPwrHisDcoutData(String tableName,Integer granularity,String halfHourAgoTime) {
+ String sql="select distinct * " +
+ "from (select a.*, (@i:= @i+1) as number " +
+ " from (select * from "+tableName+" "+
+ " where record_datetime>='"+halfHourAgoTime+"') a, " +
+ " (select @i:=0) b) c "+
+ " where c.number%"+granularity+"=0 or c.number=1 ";
+ sql+=" order by record_datetime asc";
+ List<PwrHisRealDcoutInDto> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<PwrHisRealDcoutInDto> list=new ArrayList<>();
+ while (rs.next()){
+ PwrHisRealDcoutInDto data=new PwrHisRealDcoutInDto();
+ data.setRecordDatetime(rs.getTimestamp("record_datetime"));
+ 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.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"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //鍘嗗彶娴嬭瘯璁板綍鍏蜂綋鏌愪竴娆℃斁鐢垫暟鎹鎯�
+ public List<BatttestdataId> getTinfDataWithTestRecordCount(String tableName, Integer testRecordCount, Integer recordNum, Integer granularity) {
+ String sql="select distinct * from "+tableName+" "+
+ " where test_record_count="+testRecordCount+" " +
+ " and record_num%"+granularity+"=0 or record_num=1 or record_num="+recordNum;
+ sql+=" order by record_time asc";
+ List<BatttestdataId> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<BatttestdataId> list=new ArrayList<>();
+ while (rs.next()){
+ BatttestdataId data=new BatttestdataId();
+ data.setNum(rs.getInt("num"));
+ data.setBattgroupId(rs.getInt("battgroup_id"));
+ data.setTestRecordCount(rs.getInt("test_record_count"));
+ data.setTestType(rs.getInt("test_type"));
+ data.setRecordNum(rs.getInt("record_num"));
+ data.setDataNew(rs.getInt("data_new"));
+ data.setDataAvailable(rs.getInt("data_available"));
+ data.setTestTimelong(rs.getInt("test_timelong"));
+ data.setTestCurr(rs.getFloat("test_curr"));
+ data.setTestCap(rs.getFloat("test_cap"));
+ data.setMonNum(rs.getInt("mon_num"));
+ data.setMonVol(rs.getFloat("mon_vol"));
+ data.setMonTmp(rs.getFloat("mon_tmp"));
+ data.setMonRes(rs.getFloat("mon_res"));
+ data.setTestStarttime(rs.getTimestamp("test_starttime"));
+ data.setRecordTime(rs.getTimestamp("record_time"));
+ data.setGroupVol(rs.getFloat("group_vol"));
+ data.setOnlineVol(rs.getFloat("online_vol"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //鍒ゆ柇鐢垫睜缁勫巻鍙插疄鏃惰〃鏄惁瀛樺湪
+ public int judgeTable_realdata( String table){
+ String sql="select count(*) as tableNum " +
+ " from INFORMATION_SCHEMA.TABLES " +
+ " where TABLE_SCHEMA = 'db_data_history' " +
+ " and TABLE_NAME = 'tb_batt_realdata_"+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;
+ }
+ //鍒ゆ柇鐢垫簮鍘嗗彶瀹炴椂琛ㄦ槸鍚﹀瓨鍦�
+ public int judgeTable_pwrhis( String table){
+ String sql="select count(*) as tableNum " +
+ " from INFORMATION_SCHEMA.TABLES " +
+ " where TABLE_SCHEMA = 'db_data_history' " +
+ " and TABLE_NAME = 'tb_pwrdev_historydata_"+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;
+ }
+ //鐢垫睜鏁版嵁鍘嗗彶瀹炴椂澶勭悊
+ public List<RealDateDTO> getBattRealDataHis(BattRealdataId realdata, int granularity,Integer maxRecordNum,Integer minRecordNum) {
+ 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)+"' "+
+ " and (record_num-"+minRecordNum+")%"+granularity+"=0 or record_num="+maxRecordNum+" or record_num="+minRecordNum ;
+ 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;
+ }
+ //鐢垫睜鏁版嵁鍘嗗彶瀹炴椂澶勭悊(棰勮鍒嗘瀽)
+ public List<ResAnalysis> getBattHisRealInAlm(BattRealdataId realdata, List<String> battList) {
+ String result = battList.stream().collect(Collectors.joining(","));
+ String sql=" select record_time,"+result+" " +
+ " 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<ResAnalysis> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<ResAnalysis> list=new ArrayList<>();
+ while (rs.next()){
+ ResAnalysis ph=new ResAnalysis();
+ ph.setRecordTime(rs.getTimestamp("record_time"));
+ for (int i=0;i<battList.size();i++){
+ try {
+ Float value = rs.getFloat(battList.get(i));
+ String propertyName = "dataName"+(i+1);
+ Field fieldName = ResAnalysis.class.getDeclaredField(propertyName);
+ fieldName.setAccessible(true); // 濡傛灉瀛楁鏄鏈夌殑锛岄渶瑕佽缃负鍙闂�
+ fieldName.set(ph,battList.get(i));
+
+ String propertyValue = "dataValue"+(i+1);
+ Field fieldValue = ResAnalysis.class.getDeclaredField(propertyValue);
+ fieldValue.setAccessible(true);
+ fieldValue.set(ph,value);
+ } catch (NoSuchFieldException e) {
+ e.printStackTrace();
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ }
+ }
+ list.add(ph);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+
+ //鐢垫簮鏁版嵁鍘嗗彶瀹炴椂澶勭悊(棰勮鍒嗘瀽)
+ public List<ResAnalysis> getPwrHisRealInAlm(PwrdevHistorydataId pwrHis, List<String> pwrList) {
+ String result = pwrList.stream().collect(Collectors.joining(","));
+ String sql=" select record_datetime,"+result+" " +
+ " from db_data_history.tb_pwrdev_historydata_"+pwrHis.getTableName()+" " +
+ " where record_datetime >= '"+ThreadLocalUtil.format(pwrHis.getRecordDatetime(),1)+"' " +
+ " and record_datetime <= '"+ThreadLocalUtil.format(pwrHis.getRecordDatetime1(),1)+"' " +
+ " order by record_datetime asc ";
+ List<ResAnalysis> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<ResAnalysis> list=new ArrayList<>();
+ while (rs.next()){
+ ResAnalysis ph=new ResAnalysis();
+ ph.setRecordTime(rs.getTimestamp("record_datetime"));
+ for (int i=0;i<pwrList.size();i++){
+ try {
+ Float value = rs.getFloat(pwrList.get(i));
+ String propertyName = "dataName"+(i+1);
+ Field fieldName = ResAnalysis.class.getDeclaredField(propertyName);
+ fieldName.setAccessible(true); // 濡傛灉瀛楁鏄鏈夌殑锛岄渶瑕佽缃负鍙闂�
+ fieldName.set(ph,pwrList.get(i));
+
+ String propertyValue = "dataValue"+(i+1);
+ Field fieldValue = ResAnalysis.class.getDeclaredField(propertyValue);
+ fieldValue.setAccessible(true);
+ fieldValue.set(ph,value);
+ } catch (NoSuchFieldException e) {
+ e.printStackTrace();
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ }
+ }
+ list.add(ph);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //鑾峰彇鎸囧畾鏃堕棿娈靛唴鏈�澶ф渶灏弐ecordNum纭繚鏁版嵁鐨勫畬鏁�
+ public List getMaxAndMinRecordNum(BattRealdataId realdata) {
+ String sql="select max(record_num) as maxRecordNum,min(record_num) as minRecordNum " +
+ " 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)+"' " +
+ " limit 1";
+ List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List list = new ArrayList<>();
+ while (rs.next()) {
+ list.add(rs.getInt("maxRecordNum"));
+ list.add(rs.getInt("minRecordNum"));
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //1.2.7浼樿壇鐢垫簮缁熻涓婁竴瀛ｅ害鐨勭數婧愭煇涓�灞炴�у拰鍙傛暟闃堝�艰秴杩囩殑娆℃暟
+ public List<PwrdevHistorydataId> getPwrQuarter7(String tableName) {
+ String sql=" select distinct * " +
+ " from "+tableName+" " ;
+ sql+=" order by record_datetime asc";
+ List<PwrdevHistorydataId> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<PwrdevHistorydataId> list=new ArrayList<>();
+ while (rs.next()){
+ 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;
+ }
+ });
+ return list;
+ }
}
--
Gitblit v1.9.1