From 4b659a6ece105f30debf0def9225b9a89c43bcd4 Mon Sep 17 00:00:00 2001
From: whyclxw <810412026@qq.com>
Date: 星期三, 05 二月 2025 10:39:08 +0800
Subject: [PATCH] 告警实时推送和告警历史查询
---
src/main/java/com/whyc/service/SubTableService.java | 66 ++++++++++++++++++++++++++++++++
1 files changed, 65 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/whyc/service/SubTableService.java b/src/main/java/com/whyc/service/SubTableService.java
index 8f042e3..f29dbef 100644
--- a/src/main/java/com/whyc/service/SubTableService.java
+++ b/src/main/java/com/whyc/service/SubTableService.java
@@ -1,6 +1,7 @@
package com.whyc.service;
import com.whyc.mapper.CallBack;
+import com.whyc.pojo.db_lock_alarm.LockAlarmHis;
import com.whyc.pojo.db_lock_his.LockHis;
import com.whyc.util.ActionUtil;
import com.whyc.util.ThreadLocalUtil;
@@ -47,7 +48,7 @@
return num;
}
//閿佺殑鍘嗗彶璁板綍
- public List<LockHis> getBattHisList(LockHis his) {
+ public List<LockHis> getLockHisList(LockHis his) {
String sql="SELECT * FROM db_lock_his."+ his.getRecordYear()+" history " +
" where history.lock_id="+ his.getLockId() ;
if(his.getStartTime()!=null){
@@ -78,4 +79,67 @@
}
+ //閿佺殑鍛婅鍘嗗彶璁板綍鎬绘暟
+ public int getLockAlmHisCount(LockAlarmHis his) {
+ String sql="SELECT count(*) as number FROM db_lock_alarm."+ his.getRecordYear()+" history " +
+ " where history.lock_id="+ his.getLockId() ;
+ if(his.getStartTime()!=null){
+ sql+=" and alm_start_time >='"+ ThreadLocalUtil.format(his.getStartTime(),1)+"' ";
+ }
+ if(his.getEndTime()!=null){
+ sql+=" and alm_start_time <='"+ThreadLocalUtil.format(his.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<LockHis> getLockAlmHisList(LockAlarmHis his) {
+ String sql="SELECT * FROM db_lock_alarm."+ his.getRecordYear()+" history " +
+ " where history.lock_id="+ his.getLockId() ;
+ if(his.getStartTime()!=null){
+ sql+=" and alm_start_time >='"+ ThreadLocalUtil.format(his.getStartTime(),1)+"' ";
+ }
+ if(his.getEndTime()!=null){
+ sql+=" and alm_start_time <='"+ThreadLocalUtil.format(his.getEndTime(),1)+"' ";
+ }
+ sql+=" ORDER BY alm_start_time asc limit "+ his.getLimitStart()+","+ his.getLimitEnd()+" ";
+ List<LockHis> list=sqlExecuteService.executeQuery_call(sql, new CallBack() {
+ @Override
+ public List getResults(ResultSet rs) throws SQLException {
+ List list=new ArrayList();
+ while (rs.next()){
+ LockAlarmHis data=new LockAlarmHis();
+ data.setNum(rs.getInt("num"));
+ data.setLockId(rs.getInt("lock_id"));
+ data.setAlmId(rs.getInt("alm_id"));
+ data.setAlmSource(rs.getInt("alm_source"));
+ data.setAlmStartTime(rs.getTimestamp("alm_start_time"));
+ data.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
+ data.setAlmEndTime(rs.getTimestamp("alm_end_time"));
+ data.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
+ list.add(data);
+ }
+ return list;
+ }
+ });
+ return list;
+ }
+
+
}
\ No newline at end of file
--
Gitblit v1.9.1