From b14531e3b850fe6d2fa916ba7b88b3e2bd2ff30a Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期三, 11 九月 2024 16:47:48 +0800
Subject: [PATCH] OSD加标签
---
ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java | 85 +++++++++++++++++-------------------------
1 files changed, 35 insertions(+), 50 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..402ce11 100644
--- a/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java
+++ b/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java
@@ -1,69 +1,54 @@
package com.ycl.calculate;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.ycl.platform.domain.entity.TMonitor;
-import com.ycl.platform.domain.result.HK.SnapshotDataMonitorResult;
-import com.ycl.platform.service.ITMonitorService;
+import com.ycl.platform.domain.result.BaseResult;
+import com.ycl.platform.domain.vo.TMonitorVO;
+import com.ycl.platform.mapper.TMonitorMapper;
+import constant.ApiConstants;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
-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;
/**
- * 璁＄畻鍏紡
+ * 鎶藉嚭鍚勫尯鍩熺粺璁℃暟閲忔柟娉�
*/
@Component
-public class IndexCalculationServe {
-
+@Slf4j
+public abstract class IndexCalculationServe <T extends BaseResult, S> extends IndexCalculationUtils {
@Autowired
- private ITMonitorService monitorService;
+ private TMonitorMapper monitorMapper;
- //鐐逛綅鍦ㄧ嚎鐜�
- public BigDecimal siteOnline(Map<String, Object> param) {
- BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
- BigDecimal offlineSites = new BigDecimal((Integer) param.get("offlineSites"));
- BigDecimal onlineSites = totalSites.subtract(offlineSites);
- return onlineSites.divide(totalSites, 4, RoundingMode.HALF_UP);
- }
+ //鎶借薄鏂规硶锛岀敱瀛愮被缂栧啓鍏蜂綋閫昏緫绠楁硶
+ protected abstract void updateAreaStats(Map<String, S> areaStatsMap, String key, T result);
- //瑙嗗浘搴撳鎺ョǔ瀹氭��
- public BigDecimal viewConnectStability(Map<String, Object> param) {
- BigDecimal totalDataSum = new BigDecimal((Integer) param.get("totalDataSum"));
- BigDecimal avgCount = new BigDecimal((Integer) param.get("avgCount"));
- return avgCount.divide(totalDataSum, 4, RoundingMode.HALF_UP);
- }
+ protected Map<String, S> getAreaStatsMap(List<T> list){
+ if (CollectionUtils.isEmpty(list)) {
+ log.info("鏁版嵁涓虹┖");
+ return null;
+ }
+ //杩斿洖浠ュ浗鏍囩爜涓簁ey鐨勮澶噈ap
+ Map<String, TMonitorVO> monitorMap = monitorMapper.selectListByIds(list.stream().map(BaseResult::getNo).collect(Collectors.toList()))
+ .stream().collect(Collectors.toMap(TMonitorVO::getSerialNumber, Function.identity()));
+ Map<String, S> areaStatsMap = new HashMap<>();
- //鏍囨敞姝ｇ‘鐜�
- public BigDecimal infoAccuracy(Map<String, Object> param) {
- BigDecimal totalSitesCount = new BigDecimal((Integer) param.get("totalSites"));
- BigDecimal qualifySiteCount = new BigDecimal((Integer) param.get("qualifySite"));
- return qualifySiteCount.divide(totalSitesCount, 4, RoundingMode.HALF_UP);
- }
+ for (T result : list) {
+ //鑾峰彇璁惧鎵�灞為儴闂�
+ TMonitorVO monitor = monitorMap.get(result.getNo());
+ if (monitor == null) continue;
+ String deptId = monitor.getDeptId().toString();
+ updateAreaStats(areaStatsMap, deptId, result);
- //鏁版嵁涓婁紶鍙婃椂鎬�
- public BigDecimal snapshopDelay(Map<String, Object> param) {
- BigDecimal totalCount = new BigDecimal((Integer) param.get("totalCount"));
- BigDecimal delayCount1 = new BigDecimal((Integer) param.get("delayCount1"));
- BigDecimal delayCount2 = new BigDecimal((Integer) param.get("delayCount2"));
- BigDecimal delayCount3 = new BigDecimal((Integer) param.get("delayCount3"));
-
- BigDecimal result = delayCount1.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(BigDecimal.ONE)
- .add(delayCount2.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.8")))
- .add(delayCount3.divide(totalCount, 10, RoundingMode.HALF_UP).multiply(new BigDecimal("0.6")));
- return result.setScale(4, RoundingMode.HALF_UP);
- }
- //杩斿洖鐪佸巺鍥芥爣鐮侀泦鍚�
- public List<String> getProvince() {
- // TODO: 鍒嗙渷鍘呭競灞� 闇�瑕佽ˉ鍏呴泦鍚堟暟鎹�
- List<String> list = new ArrayList<>();
- return list;
+ // 澶勭悊鐪佸巺鏁版嵁
+ if (result.getProvinceTag()!=null && result.getProvinceTag()) {
+ String provinceKey = ApiConstants.Province + deptId;
+ updateAreaStats(areaStatsMap, provinceKey, result);
+ }
+ }
+ return areaStatsMap;
}
}
--
Gitblit v1.8.0