From 7b269be1ccc6c738b4ffe9416004e09c6fd8e9c6 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期六, 15 六月 2024 15:38:56 +0800
Subject: [PATCH] 电池告警历史实时
---
src/main/java/com/whyc/service/SubTableService.java | 64 ++++++++++++++++++++++++++++++++
1 files changed, 64 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/whyc/service/SubTableService.java b/src/main/java/com/whyc/service/SubTableService.java
index 61a33c3..6f2d1e2 100644
--- a/src/main/java/com/whyc/service/SubTableService.java
+++ b/src/main/java/com/whyc/service/SubTableService.java
@@ -1,13 +1,16 @@
package com.whyc.service;
import com.whyc.mapper.CallBack;
+import com.whyc.pojo.BattAlarmHis;
import com.whyc.pojo.BattTestInfData;
+import com.whyc.util.ThreadLocalUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
+import java.util.LinkedList;
import java.util.List;
@Service
@@ -48,4 +51,65 @@
});
return list;
}
+ //鍛婅鍘嗗彶瀹炴椂璁＄畻姣忓紶琛ㄦ煡璇㈡�绘暟
+ public int getBattHisCount(BattAlarmHis battAlarmHis) {
+ String sql="SELECT count(*) as number FROM db_alarm."+battAlarmHis.getRecordYear()+" history " +
+ " where history.binf_id="+battAlarmHis.getBinfId() ;
+ if(battAlarmHis.getAlmStartTime()!=null){
+ sql+=" and alm_start_time >='"+ ThreadLocalUtil.format(battAlarmHis.getAlmStartTime(),1)+"' ";
+ }
+ if(battAlarmHis.getAlmEndTime()!=null){
+ sql+=" and alm_start_time <='"+ThreadLocalUtil.format(battAlarmHis.getAlmEndTime(),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<BattAlarmHis> getBattHisList(BattAlarmHis battAlarmHis) {
+ String sql="SELECT * FROM db_alarm."+battAlarmHis.getRecordYear()+" history " +
+ " where history.binf_id="+battAlarmHis.getBinfId() ;
+ if(battAlarmHis.getAlmStartTime()!=null){
+ sql+=" and alm_start_time >='"+ ThreadLocalUtil.format(battAlarmHis.getAlmStartTime(),1)+"' ";
+ }
+ if(battAlarmHis.getAlmEndTime()!=null){
+ sql+=" and alm_start_time <='"+ThreadLocalUtil.format(battAlarmHis.getAlmEndTime(),1)+"' ";
+ }
+ sql+=" ORDER BY alm_start_time asc limit "+battAlarmHis.getLimitStart()+","+battAlarmHis.getLimitEnd()+" ";
+ List<BattAlarmHis> list=sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List list=new ArrayList();
+ while (rs.next()){
+ BattAlarmHis data=new BattAlarmHis();
+ data.setNum(rs.getInt("num"));
+ data.setBinfId(rs.getInt("binf_id"));
+ data.setAlmStartTime(rs.getTimestamp("alm_start_time"));
+ data.setAlmEndTime(rs.getTimestamp("alm_end_time"));
+ data.setMonNum(rs.getInt("mon_num"));
+ data.setAlmId(rs.getInt("alm_id"));
+ data.setAlmLevel(rs.getInt("alm_level"));
+ data.setAlmValue(rs.getFloat("alm_value"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
}
\ No newline at end of file
--
Gitblit v1.9.1