日志清除job

sys-api-service/pom.xml

@@ -81,6 +81,15 @@
             <artifactId>xy-es</artifactId>
             <version>1.0</version>
         </dependency>
-
+        <dependency>
+            <groupId>com.xy</groupId>
+            <artifactId>xy-job</artifactId>
+            <version>1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.xy</groupId>
+            <artifactId>xy-enum</artifactId>
+            <version>1.0</version>
+        </dependency>
     </dependencies>
 </project>

sys-api-service/src/main/java/com/xy/job/LogOperateJob.java

@@ -0,0 +1,48 @@
+package com.xy.job;
+
+import cn.easyes.core.conditions.LambdaEsQueryWrapper;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xy.annotate.RestMappingController;
+import com.xy.entity.LogOperate;
+import com.xy.entity.SysDictRedis;
+import com.xy.mapper.LogOperateMapper;
+import com.xy.sys.EnumDataClearSize;
+import com.xy.utils.DataTime;
+import com.xy.utils.IndexUtils;
+import com.xy.utils.SysDictUtils;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * 操作日志执行器
+ */
+@Slf4j
+@Component
+@AllArgsConstructor
+@RestMappingController("test")
+public class LogOperateJob {
+
+    private LogOperateMapper logOperateMapper;
+
+    /**
+     * 清除操作日志
+     *
+     * @return
+     */
+    @Deprecated
+    @XxlJob("removeLogOperate")
+    public ReturnT<String> removeLogOperate() {
+        SysDictRedis sysDictRedis = SysDictUtils.get(EnumDataClearSize.Code.CODE.getCode(), EnumDataClearSize.LOG_PPERATE_CLEAD_DAY.getCode());
+        int day = Integer.valueOf(sysDictRedis.getValue());
+        String beginTime = DataTime.getStringAround(0, 0, (~(day - 1)), 0, 0, 0);
+        Integer delete = logOperateMapper.delete(new LambdaEsQueryWrapper<LogOperate>()
+                .le(LogOperate::getCreateTime, beginTime)
+        );
+        //合并索引
+        IndexUtils.forceMerge(delete > 0, logOperateMapper);
+        log.info("已清除操作日志，条数：{}", delete);
+        return ReturnT.SUCCESS;
+    }
+}

sys-api-service/src/main/java/com/xy/job/LogSysEventsJob.java

@@ -0,0 +1,46 @@
+package com.xy.job;
+
+import cn.easyes.core.conditions.LambdaEsQueryWrapper;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xy.entity.LogSysEvents;
+import com.xy.entity.SysDictRedis;
+import com.xy.mapper.LogSysEventsMapper;
+import com.xy.sys.EnumDataClearSize;
+import com.xy.utils.DataTime;
+import com.xy.utils.IndexUtils;
+import com.xy.utils.SysDictUtils;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * 系统事件日志执行器
+ */
+@Slf4j
+@Component
+@AllArgsConstructor
+public class LogSysEventsJob {
+
+    private LogSysEventsMapper logSysEventsMapper;
+
+    /**
+     * 清除系统事件日志
+     *
+     * @return
+     */
+    @Deprecated
+    @XxlJob("removeLogSysEvents")
+    public ReturnT<String> removeLogSysEvents() {
+        SysDictRedis sysDictRedis = SysDictUtils.get(EnumDataClearSize.Code.CODE.getCode(), EnumDataClearSize.LOG_SYS_EVENTS_CLEAN_DAY.getCode());
+        int day = Integer.valueOf(sysDictRedis.getValue());
+        String beginTime = DataTime.getStringAround(0, 0, (~(day - 1)), 0, 0, 0);
+        Integer delete = logSysEventsMapper.delete(new LambdaEsQueryWrapper<LogSysEvents>()
+                .le(LogSysEvents::getCreateTime, beginTime)
+        );
+        //合并索引
+        IndexUtils.forceMerge(delete > 0, logSysEventsMapper);
+        log.info("已清除系统事件日志，条数：{}", delete);
+        return ReturnT.SUCCESS;
+    }
+}

sys-start/src/main/resources/bootstrap-uat.yml

@@ -13,3 +13,10 @@ cloud:
 #雪花ID唯一标识
 workerId: 30
 
+#xxl-job配置
+xxl:
+  job:
+    executor:
+      appname: sys-excutor
+      ip: ${cloud.service.ip}
+      port: 9063