From 9b55891e6dd57bc244e6c5654434b32e05c83496 Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期三, 25 九月 2024 15:10:25 +0800
Subject: [PATCH] 异常监控排除已经审核过的工单作为状态

---
 ycl-server/src/main/java/com/ycl/utils/MongoUtil.java |   99 ++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 92 insertions(+), 7 deletions(-)

diff --git a/ycl-server/src/main/java/com/ycl/utils/MongoUtil.java b/ycl-server/src/main/java/com/ycl/utils/MongoUtil.java
index 4f88595..3cff535 100644
--- a/ycl-server/src/main/java/com/ycl/utils/MongoUtil.java
+++ b/ycl-server/src/main/java/com/ycl/utils/MongoUtil.java
@@ -1,12 +1,20 @@
 package com.ycl.utils;
 
+import com.ycl.platform.domain.query.DataCenterQuery;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.TextCriteria;
+import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
 import java.lang.reflect.Field;
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.List;
 import java.util.Objects;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
 
 /**
  * mongo宸ュ叿绫�
@@ -17,16 +25,93 @@
 public class MongoUtil {
 
     /**
-     * 鏋勯�犲叏鏂囩储寮曠殑鏉′欢
+     * 鏋勯�犳暟鎹腑蹇冩悳绱㈢殑鏉′欢
      *
-     * @param query
-     * @param keyword
+     * @param params 鏁版嵁涓績璇锋眰鍙傛暟
+     * @param timeFiled 鏃堕棿瀛楁鏄摢涓�涓�
+     * @param dataAuth 鐐逛綅绫诲瀷锛歯ull 鎵�鏈�  1 閮ㄧ骇  2 鐪佸巺  3 閲嶇偣  4 閲嶇偣鎸囨尌  5 鏄惁鏂拌澶�
+     * @param likeFileds 浣跨敤like鏌ヨ鐨勫瓧娈�
      */
-    public static void fullText(Query query, String keyword) {
-        if (StringUtils.hasText(keyword)) {
-            TextCriteria criteria = TextCriteria.forDefaultLanguage().matching(keyword);
-            query.addCriteria(criteria);
+    public static Query getQuery(DataCenterQuery params, String timeFiled, List<String> likeFileds, Integer dataAuth) {
+        // 鍏抽敭瀛�
+        List<Criteria> likeList = null;
+        if (StringUtils.hasText(params.getKeyword()) && !CollectionUtils.isEmpty(likeFileds)) {
+            // 杞箟
+            String keyword = Pattern.quote(params.getKeyword());
+            likeList = likeFileds.stream().map(filed -> {
+                return Criteria.where(filed).regex(".*?" + keyword + ".*");
+            }).collect(Collectors.toList());
         }
+        // 灏唋ike瀛楁or璧锋潵
+        Criteria or = null;
+        if (! CollectionUtils.isEmpty(likeList)) {
+            or = new Criteria();
+            or.orOperator(likeList);
+        }
+
+        Criteria tag = null;
+        // in
+        if (Objects.nonNull(dataAuth)) {
+            switch (dataAuth) {
+                case 1:
+                    tag = Criteria.where("deptTag").is(Boolean.TRUE);
+                    break;
+                case 2:
+                    tag = Criteria.where("provinceTag").is(Boolean.TRUE);
+                    break;
+                case 3:
+                    tag = Criteria.where("importantTag").is(Boolean.TRUE);
+                    break;
+                case 4:
+                    tag = Criteria.where("importantCommandImageTag").is(Boolean.TRUE);
+                    break;
+                case 5:
+                    tag = Criteria.where("newDevice").is(Boolean.TRUE);
+                    break;
+                default:
+                    break;
+            }
+        }
+
+        // 鏃堕棿
+        Criteria time = Criteria.where(timeFiled).gte(params.getStartTime()).lte(params.getEndTime());
+
+        // 鏁版嵁绫诲瀷
+        Criteria dType = null;
+        if (params.getDataType().equals(1)) {
+            dType = Criteria.where("provinceTag").is(Boolean.TRUE);
+        }else if(params.getDataType().equals(2)){
+            dType = Criteria.where("deptTag").is(Boolean.TRUE);
+        }
+
+        // 灏嗘煡璇㈡潯浠禷nd璧锋潵
+        Criteria and = new Criteria();
+        List<Criteria> qList = new ArrayList<>(3);
+        qList.add(time);
+        if (Objects.nonNull(tag)) {
+            qList.add(tag);
+        }
+        if (Objects.nonNull(or)) {
+            qList.add(or);
+        }
+        if (Objects.nonNull(dType)) {
+            qList.add(dType);
+        }
+        and.andOperator(qList);
+        // 杩斿洖鏌ヨ
+        return Query.query(and);
+    }
+
+    /**
+     * 鏋勯�犳暟鎹腑蹇冩悳绱㈢殑鏉′欢
+     *
+     * @param query 鏌ヨ鏉′欢
+     * @param timeFiled 鏃堕棿瀛楁鏄摢涓�涓�
+     * @param params 璇锋眰鍙傛暟
+     */
+    public static void setPage(Query query,DataCenterQuery params, String timeFiled) {
+        // 鎺掑簭鍒嗛〉
+        query.with(Sort.by(Sort.Order.desc(timeFiled))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
     }
 
 }

--
Gitblit v1.8.0