From 17c42f7159d78dd300784f7e1bfc62bd33e9f4b5 Mon Sep 17 00:00:00 2001
From: fit2cloud-chenyw <yawen.chen@fit2cloud.com>
Date: Thu, 10 Nov 2022 09:55:54 +0800
Subject: [PATCH] =?UTF-8?q?perf(=E7=B3=BB=E7=BB=9F):=20=E6=AF=8F=E5=A4=A90?=
 =?UTF-8?q?0:00:00=E5=AE=9A=E6=97=B6=E6=B8=85=E7=90=86=E5=BA=9F=E5=BC=83?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/io/dataease/job/sechedule/Schedular.java     | 11 +++++++++++
 .../io/dataease/service/CleaningRebotService.java     |  5 +++++
 .../io/dataease/service/message/SysMsgService.java    |  7 +++++++
 3 files changed, 23 insertions(+)

diff --git a/backend/src/main/java/io/dataease/job/sechedule/Schedular.java b/backend/src/main/java/io/dataease/job/sechedule/Schedular.java
index c6575cc218..2a1c8d94f3 100644
--- a/backend/src/main/java/io/dataease/job/sechedule/Schedular.java
+++ b/backend/src/main/java/io/dataease/job/sechedule/Schedular.java
@@ -1,6 +1,8 @@
 package io.dataease.job.sechedule;
 
 import com.fit2cloud.quartz.anno.QuartzScheduled;
+import io.dataease.commons.utils.LogUtil;
+import io.dataease.service.CleaningRebotService;
 import io.dataease.service.datasource.DatasourceService;
 import io.dataease.service.dataset.DataSetTableService;
 import io.dataease.service.kettle.KettleService;
@@ -17,6 +19,9 @@ public class Schedular {
     @Resource
     private KettleService kettleService;
 
+    @Resource
+    private CleaningRebotService cleaningRebotService;
+
     @QuartzScheduled(cron = "0 0/3 * * * ?")
     public void updateDatasetTableStatus() {
         dataSetTableService.updateDatasetTableStatus();
@@ -32,4 +37,10 @@ public class Schedular {
         kettleService.updateKettleStatus();
     }
 
+    @QuartzScheduled(cron = "0 0 0 ? * *")
+    public void cheanDisusedData() {
+        LogUtil.info("start execute clean task...");
+        cleaningRebotService.execute();
+    }
+
 }
diff --git a/backend/src/main/java/io/dataease/service/CleaningRebotService.java b/backend/src/main/java/io/dataease/service/CleaningRebotService.java
index fcf44517f5..7b3f501c47 100644
--- a/backend/src/main/java/io/dataease/service/CleaningRebotService.java
+++ b/backend/src/main/java/io/dataease/service/CleaningRebotService.java
@@ -1,6 +1,7 @@
 package io.dataease.service;
 
 import io.dataease.ext.CleaningRebotMapper;
+import io.dataease.service.message.SysMsgService;
 import io.dataease.service.sys.log.LogService;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -20,6 +21,9 @@ public class CleaningRebotService {
     @Resource
     private LogService logService;
 
+    @Resource
+    private SysMsgService sysMsgService;
+
     public void execute() {
         int floatDept = 0;
         do {
@@ -38,5 +42,6 @@ public class CleaningRebotService {
             cleaningRebotMapper.delFloatingCreatorLinkMapping();
         }
         logService.cleanDisusedLog();
+        sysMsgService.cleanDisusedMsg();
     }
 }
diff --git a/backend/src/main/java/io/dataease/service/message/SysMsgService.java b/backend/src/main/java/io/dataease/service/message/SysMsgService.java
index 721a466c5b..0d6dadd22a 100644
--- a/backend/src/main/java/io/dataease/service/message/SysMsgService.java
+++ b/backend/src/main/java/io/dataease/service/message/SysMsgService.java
@@ -55,6 +55,13 @@ public class SysMsgService {
     @Autowired
     private SystemParameterService systemParameterService;
 
+    public void cleanDisusedMsg() {
+        Long overTime = overTime();
+        SysMsgExample example = new SysMsgExample();
+        example.createCriteria().andCreateTimeLessThan(overTime);
+        sysMsgMapper.deleteByExample(example);
+    }
+
     public List<MsgGridDto> queryGrid(Long userId, MsgRequest msgRequest, List<Long> typeIds, Long startTime) {
         String orderClause = " create_time desc";
         SysMsgExample example = new SysMsgExample();