From 9d30f3aba92b1fe90eaecd486113f544f0f18b7c Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期五, 16 八月 2024 16:41:11 +0800
Subject: [PATCH] 资产管理动态字段

---
 ycl-server/src/main/java/com/ycl/calculate/IndexCalculationServe.java |   72 +++++++++++++++++++++++++++++++++++
 1 files changed, 71 insertions(+), 1 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 6546b7b..28f72a2 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,27 @@
 
 
 import com.ycl.platform.base.CheckIndex;
+import com.ycl.platform.domain.entity.TMonitor;
 import com.ycl.platform.domain.entity.YwPoint;
+import com.ycl.platform.domain.result.UY.MonitorQualifyResult;
+import com.ycl.platform.domain.vo.TMonitorVO;
+import com.ycl.platform.mapper.TMonitorMapper;
 import com.ycl.platform.mapper.YwPointMapper;
+import com.ycl.utils.DateUtils;
 import constant.ApiConstants;
 import constant.CheckConstants;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.*;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 /**
@@ -25,13 +34,32 @@
     @Autowired
     private YwPointMapper pointMapper;
 
+    @Autowired
+    private TMonitorMapper monitorMapper;
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
     //涓�鏈轰竴妗e悎鏍肩巼
     public BigDecimal monitorQualify(Map<String, Object> param) {
         BigDecimal totalMonitors = new BigDecimal((Integer) param.get("totalMonitors"));
         BigDecimal qualifyMonitor = new BigDecimal((Integer) param.get("qualifyMonitor"));
         return qualifyMonitor.divide(totalMonitors, 4, RoundingMode.HALF_UP);
     }
-
+    //涓�鏈轰竴妗f敞鍐岀巼鐜�
+    public BigDecimal monitorRegistration(Map<String, Object> param) {
+        //鏂�+姝e湪鐢ㄧ殑妗f鏁�
+        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
+        //姝e湪鐢ㄧ殑妗f鏁�
+        BigDecimal useSites = new BigDecimal((Integer) param.get("totalSites") - (Integer) param.get("newSites"));
+        return useSites.divide(totalSites, 4, RoundingMode.HALF_UP);
+    }
+    //妗f鑰冩牳姣�
+    public BigDecimal archivesRate(Map<String, Object> param) {
+        BigDecimal allFiles = new BigDecimal((Integer) param.get("allFiles"));
+        BigDecimal todayFiles = new BigDecimal((Integer) param.get("todayFiles"));
+        return todayFiles.divide(allFiles, 4, RoundingMode.HALF_UP);
+    }
     //鐐逛綅鍦ㄧ嚎鐜�
     public BigDecimal siteOnline(Map<String, Object> param) {
         BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
@@ -39,6 +67,31 @@
         return onlineSites.divide(totalSites, 4, RoundingMode.HALF_UP);
     }
 
+    //瑙嗛Osd鍑嗙‘鐜�
+    public BigDecimal osdAccuracy(Map<String, Object> param) {
+        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
+        BigDecimal osdAccuracySites = new BigDecimal((Integer) param.get("osdAccuracySites"));
+        return osdAccuracySites.divide(totalSites, 4, RoundingMode.HALF_UP);
+    }
+    //瑙嗛鏃堕棿鍚堟牸鐜�
+    public BigDecimal osdTimeAccuracy(Map<String, Object> param) {
+        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
+        BigDecimal timeAccuracySites = new BigDecimal((Integer) param.get("timeAccuracySites"));
+        return timeAccuracySites.divide(totalSites, 4, RoundingMode.HALF_UP);
+    }
+
+    //鐩綍涓�鑷寸巼锛屾瘡瓒呰繃鐧惧垎涔�1鎵�10%
+    public BigDecimal directoryConstant(Map<String, Object> param) {
+        BigDecimal totalSites = new BigDecimal((Integer) param.get("totalSites"));
+        BigDecimal newSites = new BigDecimal((Integer) param.get("newSites"));
+        // 璁$畻newSites鍗爐otalSites鐨勭櫨鍒嗘瘮鍊嶆暟
+        BigDecimal percentage = newSites.divide(totalSites, 2, RoundingMode.DOWN).multiply(BigDecimal.valueOf(100));
+        BigDecimal result = BigDecimal.ONE;
+        if(BigDecimal.ONE.compareTo(percentage) <= 0 ){
+            result = result.subtract(percentage.multiply(new BigDecimal("0.1")));
+        }
+        return result.max(BigDecimal.ZERO);
+    }
     //瑙嗗浘搴撳鎺ョǔ瀹氭��
     public BigDecimal viewConnectStability(Map<String, Object> param) {
         BigDecimal totalDataSum = new BigDecimal((Integer) param.get("totalDataSum"));
@@ -140,7 +193,24 @@
         List<YwPoint> commandImages = pointMapper.selectByTag(null, null, Boolean.TRUE);
         return CollectionUtils.isEmpty(commandImages) ? new ArrayList<>() : commandImages.stream().map(YwPoint::getSerialNumber).collect(Collectors.toList());
     }
+    //杩斿洖monitor
+    public List<String> getMonitorFromMongo() {
+        // 鑾峰彇Calendar瀹炰緥锛岄粯璁や娇鐢ㄥ綋鍓嶆椂鍖哄拰璇█鐜
+        Calendar calendar = Calendar.getInstance();
+        // 娓呴櫎Calendar涓殑鎵�鏈夊瓧娈靛�硷紝浠ラ伩鍏嶅畠浠褰撳墠鏃ユ湡鏃堕棿鏈夊奖鍝�
+        calendar.clear();
+        // 璁剧疆骞翠唤銆佹湀浠斤紙娉ㄦ剰锛氭湀浠芥槸浠�0寮�濮嬬殑锛屾墍浠�8鏈堟槸7锛夈�佹棩鏈�
+        calendar.set(Calendar.YEAR, 2024);
+        calendar.set(Calendar.MONTH, Calendar.AUGUST);
+        calendar.set(Calendar.DAY_OF_MONTH, 13);
+        // Calendar.getTime()鏂规硶杩斿洖涓�涓〃绀烘Calendar鏃堕棿鍊肩殑Date瀵硅薄
+        Date date = calendar.getTime();
+        Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(date)).lt(DateUtils.getDayEnd(date)));
+//        Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
+        List<MonitorQualifyResult> oneMachineFileResults = mongoTemplate.find(query, MonitorQualifyResult.class);
 
+        return CollectionUtils.isEmpty(oneMachineFileResults) ? new ArrayList<>() : oneMachineFileResults.stream().map(result -> result.getSerialNumber().getValue()).collect(Collectors.toList());
+    }
     //妫�鏌ユ槸鍚﹀瓨鍦ㄥ綋鏃ユ暟鎹�
     public <T extends CheckIndex> T getCheckIndex(String key, List<T> checkIndexList, Class<T> clazz) {
         T checkIndex;

--
Gitblit v1.8.0