From 83424bb99598addcea12c74c028e7ca7d68e74cf Mon Sep 17 00:00:00 2001
From: zhangzhiqiang <zhangzhiqiang@yoycol.com>
Date: Wed, 1 Mar 2023 14:36:30 +0800
Subject: [PATCH] =?UTF-8?q?add:=E6=97=A5=E5=BF=97=E6=B8=85=E9=99=A4?=
 =?UTF-8?q?=E6=8C=89=E9=92=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/logging/rest/EsLogController.java |  6 ++
 .../modules/logging/service/EsLogService.java |  5 ++
 .../service/impl/EsLogServiceImpl.java        | 17 ++++++
 lms/nladmin-ui/src/views/loki/api/loki.js     | 10 +++-
 lms/nladmin-ui/src/views/loki/view/index.vue  | 57 +++++++++++++++++++
 5 files changed, 94 insertions(+), 1 deletion(-)

diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/rest/EsLogController.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/rest/EsLogController.java
index bc9f8b9b5..5ab34932b 100644
--- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/rest/EsLogController.java
+++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/rest/EsLogController.java
@@ -34,5 +34,11 @@ public class EsLogController {
    public ResponseEntity<Object> queryAll(@RequestBody LogQuery query) {
         return new ResponseEntity<>(esLogService.query(query), HttpStatus.OK);
     }
+    @DeleteMapping("/clearLogs")
+    @ApiOperation("清空日志")
+    public ResponseEntity<Object> clearLogs(@RequestBody LogQuery query) {
+        esLogService.clearLogs(query);
+        return new ResponseEntity<>(HttpStatus.OK);
+    }
 
 }
diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/EsLogService.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/EsLogService.java
index 1a7d2c79a..0df5f374a 100644
--- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/EsLogService.java
+++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/EsLogService.java
@@ -12,6 +12,11 @@ import org.nl.modules.logging.service.dto.LogQuery;
  * @desc desc
  */
 public interface EsLogService {
+
+    /**
+     * 清空日志
+     */
+    void clearLogs(LogQuery query);
     /**
      * 获取labels和values树
      * @return
diff --git a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java
index 601304c0d..bceafcdaa 100644
--- a/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java
+++ b/lms/nladmin-system/src/main/java/org/nl/modules/logging/service/impl/EsLogServiceImpl.java
@@ -1,5 +1,7 @@
 package org.nl.modules.logging.service.impl;
 
+import cn.hutool.core.date.DateField;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.http.HttpRequest;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
@@ -27,6 +29,7 @@ import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
 import org.springframework.data.elasticsearch.core.aggregation.impl.AggregatedPageImpl;
+import org.springframework.data.elasticsearch.core.query.DeleteQuery;
 import org.springframework.data.elasticsearch.core.query.FetchSourceFilter;
 import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
 import org.springframework.stereotype.Service;
@@ -99,6 +102,20 @@ public class EsLogServiceImpl implements EsLogService {
         }
     }
 
+    @Override
+    public void clearLogs(LogQuery logQuery) {
+        String system = logQuery.getSystem();
+        BoolQueryBuilder query = QueryBuilders.boolQuery();
+        if (!StringUtils.isEmpty(system)){
+            query.must().add(QueryBuilders.matchQuery("system", system));
+        }
+        long time = DateUtil.offset(new Date(), DateField.DAY_OF_MONTH, -10).getTime();
+        String script = "doc['@timestamp'].value.millis < " + time + "L";
+        query.must().add(QueryBuilders.scriptQuery(new Script(script)));
+        DeleteQuery deleteQuery = new DeleteQuery();
+        deleteQuery.setQuery(query);
+        elasticsearchRestTemplate.delete(deleteQuery,new LogRepositoryDTO().getClass());
+    }
 
 
     @Override
diff --git a/lms/nladmin-ui/src/views/loki/api/loki.js b/lms/nladmin-ui/src/views/loki/api/loki.js
index b5a309420..8cc509d5a 100644
--- a/lms/nladmin-ui/src/views/loki/api/loki.js
+++ b/lms/nladmin-ui/src/views/loki/api/loki.js
@@ -15,4 +15,12 @@ export function labelsValues(type) {
   })
 }
 
-export default { getLogData, labelsValues }
+export function clearLogs(param) {
+  return request({
+    url: '/api/esLog/clearLogs',
+    method: 'delete',
+    data: param
+  })
+}
+
+export default { getLogData, labelsValues, clearLogs }
diff --git a/lms/nladmin-ui/src/views/loki/view/index.vue b/lms/nladmin-ui/src/views/loki/view/index.vue
index e06a1d156..6380fe875 100644
--- a/lms/nladmin-ui/src/views/loki/view/index.vue
+++ b/lms/nladmin-ui/src/views/loki/view/index.vue
@@ -118,6 +118,14 @@
             :step="1"
           />
         </el-form-item>
+        <el-form-item label="总条数">
+          <el-input
+            v-model="total"
+            size="small"
+            disabled
+            style="width: 110px"
+          />
+        </el-form-item>
         <el-form-item>
           <el-dropdown split-button type="primary" size="mini" @click="queryData">
             查询
@@ -126,6 +134,9 @@
             </el-dropdown-menu>
           </el-dropdown>
         </el-form-item>
+        <el-form-item>
+          <el-button @click="clearLogs">清空日志</el-button>
+        </el-form-item>
       </el-form>
     </div>
     <!--  <div style="margin: 3px; min-height: 80vh;">
@@ -180,6 +191,7 @@ let queryParam = {
   filterSql: true,
   isRequest: true,
   page: null,
+  total: 0,
   size: 20
 }
 export default {
@@ -308,6 +320,7 @@ export default {
 
       logOperation.getLogData(queryParam).then(res => {
         this.showEmpty = false
+        this.total = res.total
         // 清空
         this.logs = []
         for (const j in res.records) { // 用push的方式将所有日志数组添加进去
@@ -315,6 +328,50 @@ export default {
         }
       })
     },
+    clearLogs() {
+      var message = '您确定要清空'
+      if (this.system !== '' && this.system !== null) {
+        message += '标签为:' + this.system + ' '
+      }
+      message += '10天前的日志吗 ?'
+      this.$confirm(message, '确认信息', {
+        distinguishCancelAndClose: true,
+        confirmButtonText: '确定',
+        cancelButtonText: '取消'
+      })
+        .then(() => {
+          // 清空查询数据
+          this.clearParam()
+          queryParam.logLevel = this.logLevelValue
+          const time = new Date()
+          if (this.timeZoneValue !== '') {
+            queryParam.startTime = new Date(((time.getTime() - this.timeZoneValue)))
+          }
+          if (this.timeRange !== '' && this.timeRange.length > 0) {
+            queryParam.startTime = this.timeRange[0]
+            queryParam.endTime = this.timeRange[1]
+          }
+          queryParam.message = this.message.replace(/^\s*|\s*$/g, '')
+          queryParam.traceId = this.traceId
+          queryParam.system = this.system
+
+          logOperation.clearLogs(queryParam).then(res => {
+            this.queryData()
+            this.$message({
+              type: 'info',
+              message: '清除成功'
+            })
+          })
+        })
+        .catch(action => {
+          this.$message({
+            type: 'info',
+            message: action === 'cancel'
+              ? '已取消'
+              : '已取消'
+          })
+        })
+    },
     changetype() {
 
     },