From 9c2530bafbd5f502fd9bdc9abaa7c357d6f91e86 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 06 八月 2024 17:46:00 +0800
Subject: [PATCH] 点位导入导出
---
ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java | 117 +++++++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 103 insertions(+), 14 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..f372bb3 100644
--- a/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java
+++ b/ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java
@@ -1,36 +1,35 @@
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.base.CheckIndex;
+import com.ycl.platform.domain.entity.YwPoint;
+import com.ycl.platform.mapper.YwPointMapper;
+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.Date;
import java.util.List;
import java.util.Map;
-import java.util.function.Function;
+import java.util.Optional;
import java.util.stream.Collectors;
/**
* 璁＄畻鍏紡
*/
@Component
+@Slf4j
public class IndexCalculationServe {
-
@Autowired
- private ITMonitorService monitorService;
+ private YwPointMapper pointMapper;
//鐐逛綅鍦ㄧ嚎鐜�
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);
+ BigDecimal onlineSites = new BigDecimal((Integer) param.get("onlineSites"));
return onlineSites.divide(totalSites, 4, RoundingMode.HALF_UP);
}
@@ -60,10 +59,100 @@
.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 BigDecimal videoUsability(Map<String, Object> param) {
+ BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
+ BigDecimal usabilitySites = new BigDecimal((Integer) param.get("usabilitySites"));
+ return usabilitySites.divide(totalSites, 4, RoundingMode.HALF_UP);
+ }
+
//杩斿洖鐪佸巺鍥芥爣鐮侀泦鍚�
public List<String> getProvince() {
- // TODO: 鍒嗙渷鍘呭競灞� 闇�瑕佽ˉ鍏呴泦鍚堟暟鎹�
- List<String> list = new ArrayList<>();
- return list;
+ List<YwPoint> province = pointMapper.selectByTag(null, "province");
+ return province.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());
+ }
+
+ //杩斿洖閲嶇偣鐐逛綅闆嗗悎
+ public List<String> getImportant() {
+ List<YwPoint> important = pointMapper.selectByTag("important", null);
+ return important.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());
+ }
+
+ //妫�鏌ユ槸鍚﹀瓨鍦ㄥ綋鏃ユ暟鎹�
+ 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