From 8322676d29e1202e093016233b5c260d29fe92e7 Mon Sep 17 00:00:00 2001 From: 龚焕茏 <2842157468@qq.com> Date: 星期五, 02 八月 2024 18:19:16 +0800 Subject: [PATCH] feat:运维到期预警 --- ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java | 97 +++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 91 insertions(+), 6 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java b/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java index 6d5d7b7..aa33b57 100644 --- a/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java +++ b/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java @@ -2,18 +2,20 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.ycl.platform.base.CheckIndex; +import com.ycl.platform.domain.entity.CheckIndexCar; import com.ycl.platform.domain.entity.TMonitor; import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult; import com.ycl.platform.service.ITMonitorService; +import constant.CheckConstants; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.math.RoundingMode; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; @@ -21,10 +23,8 @@ * 璁$畻鍏紡 */ @Component +@Slf4j public class IndexCalculationServe { - - @Autowired - private ITMonitorService monitorService; //鐐逛綅鍦ㄧ嚎鐜� public BigDecimal siteOnline(Map<String, Object> param) { @@ -60,10 +60,95 @@ .add(delayCount3.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.6"))); return result.setScale(4, RoundingMode.HALF_UP); } + + //杞﹁締鏁版嵁瀹屾暣鎬� + public BigDecimal dataIntegrity(Map<String, Object> param) { + BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal importantTotalSites = new BigDecimal((Integer) param.get("importantTotalSites")); + BigDecimal integritySites = new BigDecimal((Integer) param.get("integritySites")); + BigDecimal importantIntegritySites = new BigDecimal((Integer) param.get("importantIntegritySites")); + BigDecimal result = integritySites.divide(totalSites, 10, RoundingMode.HALF_UP) + .add(importantIntegritySites.divide(importantTotalSites, 10, RoundingMode.HALF_UP)); + return result.setScale(4, RoundingMode.HALF_UP); + } + + //杞﹁締鏁版嵁瀹屾暣鎬� + public BigDecimal dataAccuracy(Map<String, Object> param) { + BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal importantTotalSites = new BigDecimal((Integer) param.get("importantTotalSites")); + BigDecimal accuracySites = new BigDecimal((Integer) param.get("accuracySites")); + BigDecimal importantAccuracySites = new BigDecimal((Integer) param.get("importantAccuracySites")); + BigDecimal result = accuracySites.divide(totalSites, 10, RoundingMode.HALF_UP) + .add(importantAccuracySites.divide(importantTotalSites, 10, RoundingMode.HALF_UP)); + return result.setScale(4, RoundingMode.HALF_UP); + } + + //鏃堕挓鍑嗙‘鎬� + public BigDecimal clockAccuracy(Map<String, Object> param) { + BigDecimal totalSitesCount = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal accuracySites = new BigDecimal((Integer) param.get("accuracySites")); + return accuracySites.divide(totalSitesCount, 4, RoundingMode.HALF_UP); + } + + //url鍙敤鎬� + public BigDecimal urlUsability(Map<String, Object> param) { + BigDecimal totalSitesCount = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal urlQualifySites = new BigDecimal((Integer) param.get("urlQualifySites")); + return urlQualifySites.divide(totalSitesCount, 4, RoundingMode.HALF_UP); + } + + //澶у浘鍙敤鎬� + public BigDecimal picUsability(Map<String, Object> param) { + BigDecimal totalSitesCount = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal picUsabilitySites = new BigDecimal((Integer) param.get("picUsabilitySites")); + return picUsabilitySites.divide(totalSitesCount, 4, RoundingMode.HALF_UP); + } + + //鍥剧墖鍚堟牸鐜� + public BigDecimal dataQualify(Map<String, Object> param) { + BigDecimal totalSitesCount = new BigDecimal((Integer) param.get("totalSites")); + BigDecimal picQualifySites = new BigDecimal((Integer) param.get("picQualifySites")); + return picQualifySites.divide(totalSitesCount, 4, RoundingMode.HALF_UP); + } + //杩斿洖鐪佸巺鍥芥爣鐮侀泦鍚� public List<String> getProvince() { // TODO: 鍒嗙渷鍘呭競灞� 闇�瑕佽ˉ鍏呴泦鍚堟暟鎹� List<String> list = new ArrayList<>(); return list; } + + //杩斿洖閲嶇偣鐐逛綅闆嗗悎 + public List<String> getImportant() { + // TODO: 閲嶇偣鐐逛綅 闇�瑕佽ˉ鍏呴泦鍚堟暟鎹� + List<String> list = new ArrayList<>(); + return list; + } + + //妫�鏌ユ槸鍚﹀瓨鍦ㄥ綋鏃ユ暟鎹� + public <T extends CheckIndex> T getCheckIndex(String key, List<T> checkIndexList, Class<T> clazz) { + T checkIndex; + + // 妫�鏌ユ槸鍚﹀凡瀛樺湪浠婃棩鏁版嵁 + Optional<T> existingIndex = checkIndexList.stream() + .filter(index -> key.equals(index.getDeptId().toString()) && + (key.startsWith("Province_") ? CheckConstants.Examine_Tag_City.equals(index.getExamineTag()) + : CheckConstants.Examine_Tag_County.equals(index.getExamineTag()))) + .findFirst(); + + if (existingIndex.isPresent()) { + checkIndex = existingIndex.get(); + } else { + try { + checkIndex = clazz.getDeclaredConstructor().newInstance(); + checkIndex.setDeptId(key.startsWith("Province_") ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key)); + checkIndex.setExamineTag(key.startsWith("Province_") ? CheckConstants.Examine_Tag_City : CheckConstants.Examine_Tag_County); + checkIndex.setCreateTime(new Date()); + } catch (Exception e) { + checkIndex = null; + log.error("鏃犳硶鍒涘缓 checkIndex 瀹炰緥", e); + } + } + return checkIndex; + } } -- Gitblit v1.8.0