From f26dc28abc0f5efc0ab0143d3554474ebbc6c169 Mon Sep 17 00:00:00 2001
From: whycxzp <glperry@163.com>
Date: 星期四, 10 四月 2025 09:32:03 +0800
Subject: [PATCH] 提交电池告警参数,电池实时数据历史和电源实时数据历史
---
src/main/java/com/whyc/service/SubTableService.java | 217 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 217 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/SubTableService.java b/src/main/java/com/whyc/service/SubTableService.java
index 4cc80c6..37c8ecc 100644
--- a/src/main/java/com/whyc/service/SubTableService.java
+++ b/src/main/java/com/whyc/service/SubTableService.java
@@ -6,7 +6,9 @@
import com.whyc.pojo.db_alarm.DevLithiumAlarmDataYear;
import com.whyc.pojo.db_dis_batt.BattTestInfData;
import com.whyc.pojo.db_power_alarm.PowerAlarmHistory;
+import com.whyc.pojo.db_power_history.BattRealTimeDataHistory;
import com.whyc.pojo.db_power_history.BattStationTempHistory;
+import com.whyc.pojo.db_power_history.PowerRealTimeDataHistory;
import com.whyc.util.ActionUtil;
import com.whyc.util.ThreadLocalUtil;
import org.springframework.beans.factory.annotation.Autowired;
@@ -189,6 +191,221 @@
});
return list;
}
+
+ public int getBattRealTimeDataHisCount(BattRealTimeDataHistory tempHistory) {
+ String sql="select count(1) as number from db_power_history."+tempHistory.getRecordYearMonth()+" where 1=1 ";
+ if(tempHistory.getStartTime()!=null){
+ sql+=" and record_time >='"+ ThreadLocalUtil.format(tempHistory.getStartTime(),1)+"' ";
+ }
+ if(tempHistory.getEndTime()!=null){
+ sql+=" and record_time <='"+ThreadLocalUtil.format(tempHistory.getEndTime(),1)+"' ";
+ }
+ 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;
+ }
+
+ public int getPowerRealTimeDataHisCount(PowerRealTimeDataHistory tempHistory) {
+ String sql="select count(1) as number from db_power_history."+tempHistory.getRecordYearMonth()+" where 1=1 ";
+ if(tempHistory.getStartTime()!=null){
+ sql+=" and record_time >='"+ ThreadLocalUtil.format(tempHistory.getStartTime(),1)+"' ";
+ }
+ if(tempHistory.getEndTime()!=null){
+ sql+=" and record_time <='"+ThreadLocalUtil.format(tempHistory.getEndTime(),1)+"' ";
+ }
+ 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;
+ }
+
+ public List<BattRealTimeDataHistory> getBattRealTimeDataHisList(BattRealTimeDataHistory tempHistory) {
+ String sql="select * from db_power_history."+tempHistory.getRecordYearMonth()+" where 1=1 ";
+ if(tempHistory.getStartTime()!=null){
+ sql+=" and record_time >='"+ ThreadLocalUtil.format(tempHistory.getStartTime(),1)+"' ";
+ }
+ if(tempHistory.getEndTime()!=null){
+ sql+=" and record_time <='"+ThreadLocalUtil.format(tempHistory.getEndTime(),1)+"' ";
+ }
+ sql+=" ORDER BY record_time desc limit "+ tempHistory.getLimitStart()+","+ tempHistory.getLimitEnd()+" ";
+ List<BattRealTimeDataHistory> list=sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<BattRealTimeDataHistory> list=new ArrayList();
+ while (rs.next()){
+ BattRealTimeDataHistory data=new BattRealTimeDataHistory();
+ data.setBattGroupId(rs.getInt("binf_id"));
+ data.setRecordTime(rs.getTimestamp("record_time"));
+ data.setOnlineVol(rs.getFloat("online_vol"));
+ data.setGroupVol(rs.getFloat("group_vol"));
+ data.setGroupTmp(rs.getFloat("group_tmp"));
+ data.setGroupCurr(rs.getFloat("group_curr"));
+ data.setBattState(rs.getInt("batt_state"));
+ data.setTestStartTime(rs.getTimestamp("test_start_time"));
+ data.setBattTestType(rs.getFloat("batt_test_type"));
+ data.setBattTestLong(rs.getInt("batt_test_tlong"));
+ data.setBattTestCap(rs.getFloat("batt_test_cap"));
+ data.setBattRealCap(rs.getFloat("batt_real_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.setMonSer(rs.getFloat("mon_ser"));
+ data.setMonConnRes(rs.getFloat("mon_conn_res"));
+
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+
+ public List<PowerRealTimeDataHistory> getPowerRealTimeDataHisList(PowerRealTimeDataHistory tempHistory) {
+ String sql="select * from db_power_history."+tempHistory.getRecordYearMonth()+" where 1=1 ";
+ if(tempHistory.getStartTime()!=null){
+ sql+=" and record_time >='"+ ThreadLocalUtil.format(tempHistory.getStartTime(),1)+"' ";
+ }
+ if(tempHistory.getEndTime()!=null){
+ sql+=" and record_time <='"+ThreadLocalUtil.format(tempHistory.getEndTime(),1)+"' ";
+ }
+ sql+=" ORDER BY record_time desc limit "+ tempHistory.getLimitStart()+","+ tempHistory.getLimitEnd()+" ";
+ List<PowerRealTimeDataHistory> list=sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List<PowerRealTimeDataHistory> list=new ArrayList();
+ while (rs.next()){
+ PowerRealTimeDataHistory data=new PowerRealTimeDataHistory();
+ data.setPowerId(rs.getInt("power_id"));
+ data.setDevType(rs.getInt("dev_type"));
+ data.setRecordTime(rs.getTimestamp("record_time"));
+ data.setCharOutVol(rs.getFloat("char_out_vol"));
+ data.setCharOutCurr(rs.getFloat("char_out_curr"));
+ data.setGroupVol(rs.getFloat("group_vol"));
+ data.setGroupCurr(rs.getFloat("group_curr"));
+ data.setGroupTmp(rs.getFloat("group_tmp"));
+ data.setBusVol(rs.getFloat("bus_vol"));
+ data.setAc1VolA(rs.getFloat("ac1_vola"));
+ data.setAc1VolB(rs.getFloat("ac1_volb"));
+ data.setAc1VolC(rs.getFloat("ac1_volc"));
+ data.setAc2VolA(rs.getFloat("ac2_vola"));
+ data.setAc2VolB(rs.getFloat("ac2_volb"));
+ data.setAc2VolC(rs.getFloat("ac2_volc"));
+ data.setBusVolPositive(rs.getFloat("bus_vol_positive"));
+ data.setBusVolNegative(rs.getFloat("bus_vol_negative"));
+ data.setBusResPositive(rs.getFloat("bus_res_positive"));
+ data.setBusResNegative(rs.getFloat("bus_res_negative"));
+ data.setCharJunFloat(rs.getInt("char_jun_float"));
+ data.setCharOpenClose(rs.getInt("char_open_close"));
+ data.setCharModelError(rs.getInt("char_model_error"));
+ data.setCharOutOverVol(rs.getInt("char_out_overvol"));
+ data.setCharOutLessVol(rs.getInt("char_out_lessvol"));
+ data.setBattOverVol(rs.getInt("batt_overvol"));
+ data.setBattLessVol(rs.getInt("batt_lessvol"));
+ data.setBattMonOverVol(rs.getInt("batt_mon_overvol"));
+ data.setBattMonLessVol(rs.getInt("batt_mon_lessvol"));
+ data.setBattState(rs.getInt("batt_state"));
+ data.setControlBusOverVol(rs.getInt("control_bus_overvol"));
+ data.setControlBusLessVol(rs.getInt("control_bus_lessvol"));
+ data.setInsualBusVolError(rs.getInt("insual_bus_vol_error"));
+ data.setControlBusPositiveError(rs.getInt("control_bus_positive_error"));
+ data.setControlBusNegativeError(rs.getInt("control_bus_negative_error"));
+ data.setInsualBusAcVolOverVol(rs.getInt("insual_bus_acvol_overvol"));
+ data.setBattPatrolDetectorError(rs.getInt("batt_patrol_detector_error"));
+ data.setInsualError(rs.getInt("insual_error"));
+ data.setAcIn1Qf11(rs.getInt("acin1_qf11"));
+ data.setAcIn1Qf12(rs.getInt("acin1_qf12"));
+ data.setCharOutBusDk11(rs.getInt("char_out_bus_dk11"));
+ data.setCharOutBattDk12(rs.getInt("char_out_batt_dk12"));
+ data.setBattOutQf1(rs.getInt("batt_out_qf1"));
+ data.setBusSwitchN1lzk(rs.getInt("bus_switch_n1lzk"));
+ data.setAc1Fault(rs.getInt("ac1_fault"));
+ data.setAc2Fault(rs.getInt("ac2_fault"));
+ data.setMainSwitchFault(rs.getInt("main_switch_fault"));
+ data.setFeederTripFault(rs.getInt("feeder_trip_fault"));
+ data.setThunderFault(rs.getInt("thunder_fault"));
+ data.setFeedersCommFault(rs.getInt("feeders_comm_fault"));
+ data.setDcFeeder7To9Switch1(rs.getInt("dc_feeder7to9_switch1"));
+ data.setDcFeeder7Switch(rs.getInt("dc_feeder7_switch"));
+ data.setDcFeeder7Bus1Zk11(rs.getInt("dc_feeder7_bus1_zk11"));
+ data.setDcFeeder7Bus2Zk12(rs.getInt("dc_feeder7_bus2_zk12"));
+ data.setDcFeeder8Switch(rs.getInt("dc_feeder8_switch"));
+ data.setDcFeeder8Bus1Zk11(rs.getInt("dc_feeder8_bus1_zk11"));
+ data.setDcFeeder8Bus2Zk12(rs.getInt("dc_feeder8_bus2_zk12"));
+ data.setDcFeeder9Switch(rs.getInt("dc_feeder9_switch"));
+ data.setDcFeeder9Bus1Zk11(rs.getInt("dc_feeder9_bus1_zk11"));
+ data.setDcFeeder9Bus2Zk12(rs.getInt("dc_feeder9_bus2_zk12"));
+ data.setAcFeeder7Switch(rs.getInt("ac_feeder7_switch"));
+ data.setAcFeeder7AcIn1Q11(rs.getInt("ac_feeder7_acin1_q11"));
+ data.setAcFeeder7AcIn2Q12(rs.getInt("ac_feeder7_acin2_q12"));
+ data.setAcFeeder7AcIn1Fault(rs.getInt("ac_feeder7_acin1_fault"));
+ data.setAcFeeder7AcIn2Fault(rs.getInt("ac_feeder7_acin2_fault"));
+ data.setAcFeeder9Switch(rs.getInt("ac_feeder9_switch"));
+ data.setAcFeeder9AcIn1Q11(rs.getInt("ac_feeder9_acin1_q11"));
+ data.setAcFeeder9AcIn2Q12(rs.getInt("ac_feeder9_acin2_q12"));
+ data.setAcFeeder9AcIn1Fault(rs.getInt("ac_feeder9_acin1_fault"));
+ data.setAcFeeder9AcIn2Fault(rs.getInt("ac_feeder9_acin2_fault"));
+ data.setInsualCommFault(rs.getInt("insual_comm_fault"));
+ data.setInsualInsualFault(rs.getInt("insual_insual_fault"));
+ data.setInsualMiainCommFault(rs.getInt("insual_miain_comm_fault"));
+ data.setAcIn2Qf21(rs.getInt("acin2_qf21"));
+ data.setAcIn2Qf22(rs.getInt("acin2_qf22"));
+ data.setCharOutBusDk21(rs.getInt("char_out_bus_dk21"));
+ data.setCharOutBattDk22(rs.getInt("char_out_batt_dk22"));
+ data.setDcFeeder7Bus1Zk21(rs.getInt("dc_feeder7_bus1_zk21"));
+ data.setDcFeeder7Bus2Zk22(rs.getInt("dc_feeder7_bus2_zk22"));
+ data.setDcFeeder8Bus1Zk21(rs.getInt("dc_feeder8_bus1_zk21"));
+ data.setDcFeeder8Bus2Zk22(rs.getInt("dc_feeder8_bus2_zk22"));
+ data.setDcFeeder9Bus1Zk21(rs.getInt("dc_feeder9_bus1_zk21"));
+ data.setDcFeeder9Bus2Zk22(rs.getInt("dc_feeder9_bus2_zk22"));
+ data.setAcFeeder8Switch(rs.getInt("ac_feeder8_switch"));
+ data.setAcFeeder8AcIn1Q11(rs.getInt("ac_feeder8_acin1_q11"));
+ data.setAcFeeder8AcIn2Q12(rs.getInt("ac_feeder8_acin2_q12"));
+ data.setAcFeeder8AcIn1Fault(rs.getInt("ac_feeder8_acin1_fault"));
+ data.setAcFeeder8AcIn2Fault(rs.getInt("ac_feeder8_acin2_fault"));
+ data.setAcIn3Qf31(rs.getInt("acin3_qf31"));
+ data.setAcIn3Qf32(rs.getInt("acin3_qf32"));
+ data.setCharOutBatt1Dk31(rs.getInt("char_out_batt1_dk31"));
+ data.setCharOutBatt2Dk31(rs.getInt("char_out_batt2_dk31"));
+
+
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+
//鐢垫簮鍛婅鍘嗗彶瀹炴椂璁＄畻姣忓紶琛ㄦ煡璇㈡�绘暟
public int getPowerHisCount(PowerAlarmHistory powerAlarmHistory) {
String sql="SELECT count(*) as number FROM db_power_alarm."+ powerAlarmHistory.getRecordYear()+" history " +
--
Gitblit v1.9.1