From 097a19a80c2c4e5bfa41b0d48b818c20f030aea5 Mon Sep 17 00:00:00 2001
From: lxw <810412026@qq.com>
Date: 星期二, 07 三月 2023 17:39:43 +0800
Subject: [PATCH] 监控层，运维层首页+跳转页
---
src/main/java/com/whyc/service/StationInfService.java | 75 +++++++++++++++++++++++++++++++++++--
1 files changed, 71 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/whyc/service/StationInfService.java b/src/main/java/com/whyc/service/StationInfService.java
index 0c9e133..9a8b58d 100644
--- a/src/main/java/com/whyc/service/StationInfService.java
+++ b/src/main/java/com/whyc/service/StationInfService.java
@@ -7,10 +7,7 @@
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.*;
-import com.whyc.pojo.BattRtdata;
-import com.whyc.pojo.BattRtstate;
-import com.whyc.pojo.PwrdevAcdcdata;
-import com.whyc.pojo.StationInf;
+import com.whyc.pojo.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -41,6 +38,12 @@
@Autowired(required = false)
private PwrdevAlarmMapper pwrAlmMapper;
+
+ @Autowired(required = false)
+ private BadbattMonMapper badMapper;
+
+ @Autowired(required = false)
+ private BattEnduranceMapper endMapper;
//鎻掑叆绔欑偣
public Response insertStation(StationInf stationInf) {
@@ -201,4 +204,68 @@
}
}
+
+ //杩愮淮灞傞椤碉細澶撮儴缁熻
+ public Response getDevOpSkipHead(int userId) {
+ try {
+ Map<String, Object> map = new HashMap();
+ //澶撮儴缁熻鏁版嵁
+ int stationNum = mapper.getStation(userId);
+ map.put("stationNum", stationNum);
+ //娴厖/鍏呯數
+ List<BattRtstate> stateList = rtstateMapper.getBattStateStatic(userId);
+ Map<Integer, Integer> statemap = new HashMap();
+ Map<Integer, List<BattRtstate>> battstateMap = stateList.stream().collect(Collectors.groupingBy(BattRtstate::getBattState));
+ for (Integer state : battstateMap.keySet()) {
+ statemap.put(state, battstateMap.get(state).size());
+ }
+ map.put("battState", statemap);
+ //鏁存祦鍣ㄦ晠闅�/璐熻浇鐔旀柇
+ List<PwrdevAcdcdata> acdcList = acdcMapper.getAcdcStatic(userId);
+ Map<Integer, Integer> errmap = new HashMap();
+ Map<Integer, List<PwrdevAcdcdata>> aderrMap = acdcList.stream().collect(Collectors.groupingBy(PwrdevAcdcdata::getAcdcErr));
+ for (Integer acdcerr : aderrMap.keySet()) {
+ errmap.put(acdcerr, aderrMap.get(acdcerr).size());
+ }
+ map.put("errmap", errmap);
+ Map<Integer, Integer> fusemap = new HashMap();
+ Map<Integer, List<PwrdevAcdcdata>> adfuseMap = acdcList.stream().collect(Collectors.groupingBy(PwrdevAcdcdata::getIsLoaderFuse));
+ for (Integer fuse : adfuseMap.keySet()) {
+ fusemap.put(fuse, adfuseMap.get(fuse).size());
+ }
+ map.put("fusemap", fusemap);
+ //绔欑偣缁熻
+
+ return new Response().setII(1, true, map, "绔欑偣瀹炴椂鏁版嵁鎺ㄩ��");
+ } catch (Exception e) {
+ return new Response().set(1, false, "鍙戠敓寮傚父:" + e.getCause());
+ }
+
+ }
+
+ //鎸囧畾绔欑偣璇︽儏绗竴娆¤烦杞満鎴縤d涓�0锛歮essage
+ public Response getDevOpSkipStation(int userId, String stationId) {
+ //鏌ヨ鎸囧畾鏈烘埧淇℃伅
+ StationInf inf = mapper.getSystemSkipStation(userId, stationId);
+ if (inf != null) {
+ if (inf.getRtlist() != null && inf.getRtlist().size() > 0) {
+ for (int i = 0; i < inf.getRtlist().size(); i++) {
+ //鍒ゆ柇鏄惁钀藉悗
+ int battGroupId = inf.getRtlist().get(i).getBattGroupId();
+ int badbattFlag = badMapper.judgeBatt(battGroupId);
+ inf.getRtlist().get(i).setBadbattFlag(badbattFlag);
+ }
+ }
+ //鏌ヨ鍋滅數缁埅鏃堕棿
+ QueryWrapper wrapper = new QueryWrapper();
+ wrapper.eq("stationid", stationId);
+ BattEndurance endurance = endMapper.selectOne(wrapper);
+ if (endurance != null) {
+ inf.setEndurance(endurance);
+ }
+ return new Response().setII(1, true, inf, "鎸囧畾绔欑偣璇︽儏");
+ } else {
+ return new Response().set(1, false, "鎸囧畾绔欑偣璇︽儏");
+ }
+ }
}
--
Gitblit v1.9.1