From e9e0e12c5d855b587784c4b1c3c86975d3b7df6f Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期三, 04 六月 2025 13:14:23 +0800
Subject: [PATCH] 实施页面系统概论半小时数据
---
src/main/java/com/whyc/service/SubTablePageInfoService.java | 85 +++++++++++++++++++++++++++++++++++++++++-
1 files changed, 83 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/whyc/service/SubTablePageInfoService.java b/src/main/java/com/whyc/service/SubTablePageInfoService.java
index f0391a7..6370eb3 100644
--- a/src/main/java/com/whyc/service/SubTablePageInfoService.java
+++ b/src/main/java/com/whyc/service/SubTablePageInfoService.java
@@ -3,12 +3,13 @@
import com.whyc.dto.AlmHis.BattAlmPar;
import com.whyc.dto.AlmHis.DevAlmPar;
import com.whyc.dto.AlmHis.PwrAlmPar;
-import com.whyc.dto.Real.CompareDto;
-import com.whyc.dto.Real.QuarterDto;
+import com.whyc.dto.Real.*;
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;
@@ -557,4 +558,84 @@
});
return list;
}
+ //绯荤粺姒傝鑾峰彇鍗婂皬鏃舵牳瀹硅澶囦俊鎭�
+ public List<BattHisRealDto> getHalfHourBattDevData(String tableName) {
+ String sql="select distinct mon_num,record_time,group_vol,online_vol,group_curr,group_tmp from "+tableName+" ";
+ sql+="where record_time>date_sub(now(),interval 0.5 hour)";
+ 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"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+ //绯荤粺姒傝鑾峰彇鍗婂皬鏃朵氦娴佽緭鍏ョ粺璁�
+ public List<PwrHisRealAcInDto> getHalfHourPwrHisAcinData(String tableName) {
+ 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 "+tableName+" ";
+ sql+="where record_datetime>date_sub(now(),interval 0.5 hour)";
+ 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) {
+ String sql="select distinct record_datetime,dcout_vol,dcout_curr,battgroup1_vol,battgroup1_curr,battgroup2_vol,battgroup2_curr from "+tableName+" ";
+ sql+="where record_datetime>date_sub(now(),interval 0.5 hour)";
+ 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.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"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
}
--
Gitblit v1.9.1