From 9814046268f11b43fc674142db0fb3b690c3fbaf Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期五, 02 八月 2024 15:10:40 +0800
Subject: [PATCH] mongodb加索引注解

---
 ycl-server/src/main/java/com/ycl/calculate/CarSiteOnlineCalculation.java |   30 ++++++++++--------------------
 1 files changed, 10 insertions(+), 20 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/calculate/CarSiteOnlineCalculation.java b/ycl-server/src/main/java/com/ycl/calculate/CarSiteOnlineCalculation.java
index 2b64436..79d5619 100644
--- a/ycl-server/src/main/java/com/ycl/calculate/CarSiteOnlineCalculation.java
+++ b/ycl-server/src/main/java/com/ycl/calculate/CarSiteOnlineCalculation.java
@@ -92,7 +92,9 @@
         checkIndexCarService.saveOrUpdateBatch(checkIndexCars);
     }
 
-    /** 绱鎬荤偣浣嶆暟銆佺绾挎暟銆佹�绘姄鎷嶉噺 */
+    /**
+     * 绱鎬荤偣浣嶆暟銆佺绾挎暟銆佹�绘姄鎷嶉噺
+     */
     private void updateAreaStats(Map<String, AreaStats> areaStatsMap, String key, SnapshotDataMonitorResult result) {
         //杩斿洖瀵硅薄鐨勫紩鐢紝濡傛灉涓嶅瓨鍦ㄤ細鏀惧叆鏂扮殑key,value
         AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats());
@@ -104,7 +106,9 @@
         }
     }
 
-    /** 鑾峰彇2022鍚屾湡鎶撴媿骞冲潎鍊� */
+    /**
+     * 鑾峰彇2022鍚屾湡鎶撴媿骞冲潎鍊�
+     */
     private BigDecimal getAverageCount(String configKey) {
         String count = sysConfigMapper.checkConfigKeyUnique(configKey).getConfigValue();
         return new BigDecimal(count)
@@ -113,25 +117,11 @@
                 .divide(new BigDecimal(LocalDate.now().getDayOfMonth()), 0, RoundingMode.HALF_UP);
     }
 
-    /** 杞﹁締鐐逛綅鍦ㄧ嚎鐜囧拰瑙嗗浘搴撳鎺ョǔ瀹氭�� */
+    /**
+     * 杞﹁締鐐逛綅鍦ㄧ嚎鐜囧拰瑙嗗浘搴撳鎺ョǔ瀹氭��
+     */
     private CheckIndexCar createOrUpdateCheckIndexCar(String key, AreaStats stats, BigDecimal cityCountAvg, BigDecimal countyCountAvg, List<CheckIndexCar> checkIndexCarList) {
-        CheckIndexCar checkIndexCar;
-
-        // 妫�鏌ユ槸鍚﹀凡瀛樺湪浠婃棩鏁版嵁
-        Optional<CheckIndexCar> existingCar = checkIndexCarList.stream()
-                .filter(car -> key.equals(car.getDeptId().toString()) &&
-                        (key.startsWith("Province_") ? CheckConstants.Examine_Tag_City.equals(car.getExamineTag())
-                                : CheckConstants.Examine_Tag_County.equals(car.getExamineTag())))
-                .findFirst();
-
-        if (existingCar.isPresent()) {
-            checkIndexCar = existingCar.get();
-        } else {
-            checkIndexCar = new CheckIndexCar();
-            checkIndexCar.setDeptId(key.startsWith("Province_") ? Long.parseLong(key.split("_")[1]) : Long.parseLong(key));
-            checkIndexCar.setExamineTag(key.startsWith("Province_") ? CheckConstants.Examine_Tag_City : CheckConstants.Examine_Tag_County);
-            checkIndexCar.setCreateTime(new Date());
-        }
+        CheckIndexCar checkIndexCar = getCheckIndex(key, checkIndexCarList, CheckIndexCar.class);
         //璋冪敤鐐逛綅鍦ㄧ嚎璁$畻鏂规硶
         Map<String, Object> siteOnlineParam = new HashMap<>();
         siteOnlineParam.put("totalSites", stats.totalSites);

--
Gitblit v1.8.0