20260910:清理日志，iot_device_log这个设备采集的数据需要做备份

fastbee-admin/src/main/java/com/fastbee/web/task/LogCleanTask.java

@@ -0,0 +1,88 @@
+package com.fastbee.web.task;
+
+import com.fastbee.iot.service.IAlertLogService;
+import com.fastbee.iot.service.IEventLogService;
+import com.fastbee.notify.service.INotifyLogService;
+import com.fastbee.quartz.service.ISysJobLogService;
+import com.fastbee.system.service.ISysLogininforService;
+import com.fastbee.system.service.ISysOperLogService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 日志清理定时任务
+ *
+ * @author fastbee
+ */
+@Component("logCleanTask")
+public class LogCleanTask {
+    private static final Logger log = LoggerFactory.getLogger(LogCleanTask.class);
+
+    @Autowired
+    private IEventLogService eventLogService;
+
+    @Autowired
+    private ISysOperLogService operLogService;
+
+    @Autowired
+    private ISysLogininforService logininforService;
+
+    @Autowired
+    private IAlertLogService alertLogService;
+
+    @Autowired
+    private ISysJobLogService jobLogService;
+
+    @Autowired
+    private INotifyLogService notifyLogService;
+
+    // 之后还有清理的表往下写
+
+    /**
+     * 清理日志（默认清理15天前）
+     */
+    public void cleanLogs() {
+        cleanLogs(15);
+    }
+
+    /**
+     * 清理日志
+     *
+     * @param days 保留天数
+     */
+    public void cleanLogs(int days) {
+        log.info("========== 开始清理日志数据，保留最近 {} 天的记录 ==========", days);
+        try {
+            // 清理 IoT 事件日志
+            eventLogService.cleanEventLog(days);
+            //log.info("已清理 iot_event_log 表 {} 天前的数据", days);
+
+            // 清理系统操作日志
+            operLogService.cleanOperLog(days);
+            //log.info("已清理 sys_oper_log 表 {} 天前的数据", days);
+
+            // 清理登录日志
+            logininforService.cleanLogininfor(days);
+            //log.info("已清理 sys_logininfor 表 {} 天前的数据", days);
+
+            // 清理设备告警日志
+            alertLogService.cleanAlertLog(days);
+            //log.info("已清理 iot_alert_log 表 {} 天前的数据", days);
+
+            // 清理定时任务日志
+            jobLogService.cleanJobLog(days);
+            //log.info("已清理 sys_job_log 表 {} 天前的数据", days);
+
+            // 清理通知日志
+            notifyLogService.cleanNotifyLog(days);
+            //log.info("已清理 notify_log 表 {} 天前的数据", days);
+
+            log.info("========== 日志清理任务执行完成 ==========");
+        } catch (Exception e) {
+            log.error("日志清理任务执行失败", e);
+            throw e;
+        }
+    }
+}

fastbee-notify/fastbee-notify-web/src/main/java/com/fastbee/notify/mapper/NotifyLogMapper.java

@@ -58,4 +58,12 @@ public interface NotifyLogMapper {
      * @return 结果
      */
     public int deleteNotifyLogByIds(Long[] ids);
+
+    /**
+     * 删除指定天数前的通知日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    public int deleteNotifyLogBeforeDays(int days);
 }

fastbee-notify/fastbee-notify-web/src/main/java/com/fastbee/notify/service/INotifyLogService.java

@@ -58,4 +58,11 @@ public interface INotifyLogService {
      * @return 结果
      */
     public int deleteNotifyLogById(Long id);
+
+    /**
+     * 清理通知日志
+     *
+     * @param days 保留天数
+     */
+    public void cleanNotifyLog(int days);
 }

fastbee-notify/fastbee-notify-web/src/main/java/com/fastbee/notify/service/impl/NotifyLogServiceImpl.java

@@ -132,4 +132,14 @@ public class NotifyLogServiceImpl implements INotifyLogService {
     public int deleteNotifyLogById(Long id) {
         return notifyLogMapper.deleteNotifyLogById(id);
     }
+
+    /**
+     * 清理通知日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanNotifyLog(int days) {
+        notifyLogMapper.deleteNotifyLogBeforeDays(days);
+    }
 }

fastbee-notify/fastbee-notify-web/src/main/resources/mapper/NotifyLogMapper.xml

@@ -138,4 +138,9 @@
             #{id}
         </foreach>
     </delete>
+
+    <delete id="deleteNotifyLogBeforeDays">
+        DELETE FROM notify_log
+        WHERE create_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
 </mapper>

fastbee-open-api/src/main/java/com/fastbee/controller/system/LogCleanController.java

@@ -0,0 +1,96 @@
+package com.fastbee.controller.system;
+
+import com.fastbee.common.annotation.Log;
+import com.fastbee.common.core.controller.BaseController;
+import com.fastbee.common.core.domain.AjaxResult;
+import com.fastbee.common.enums.BusinessType;
+import com.fastbee.iot.service.IAlertLogService;
+import com.fastbee.iot.service.IEventLogService;
+import com.fastbee.notify.service.INotifyLogService;
+import com.fastbee.quartz.service.ISysJobLogService;
+import com.fastbee.system.service.ISysLogininforService;
+import com.fastbee.system.service.ISysOperLogService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 日志清理Controller
+ *
+ * @author fastbee
+ */
+@Api(tags = "系统管理：日志清理")
+@RestController
+@RequestMapping("/system/log")
+public class LogCleanController extends BaseController {
+
+    @Autowired
+    private IEventLogService eventLogService;
+
+    @Autowired
+    private ISysOperLogService operLogService;
+
+    @Autowired
+    private ISysLogininforService logininforService;
+
+    @Autowired
+    private IAlertLogService alertLogService;
+
+    @Autowired
+    private ISysJobLogService jobLogService;
+
+    @Autowired
+    private INotifyLogService notifyLogService;
+
+    /**
+     * 清理日志数据
+     *
+     * @param days 保留天数，默认15天
+     * @return 清理结果
+     */
+    @ApiOperation("清理日志数据")
+    @PreAuthorize("@ss.hasRole('admin')")
+    @Log(title = "日志清理", businessType = BusinessType.CLEAN)
+    @PostMapping("/clean")
+    public AjaxResult cleanLogs(
+            @ApiParam("保留天数，默认15天")
+            @RequestParam(value = "days", defaultValue = "15") Integer days) {
+        try {
+            logger.info("手动触发日志清理，保留最近 {} 天的记录", days);
+
+            if (days < 1) {
+                return error("保留天数必须大于等于1天");
+            }
+
+            // 清理 IoT 事件日志
+            eventLogService.cleanEventLog(days);
+
+            // 清理系统操作日志
+            operLogService.cleanOperLog(days);
+
+            // 清理登录日志
+            logininforService.cleanLogininfor(days);
+
+            // 清理设备告警日志
+            alertLogService.cleanAlertLog(days);
+
+            // 清理定时任务日志
+            jobLogService.cleanJobLog(days);
+
+            // 清理通知日志
+            notifyLogService.cleanNotifyLog(days);
+
+            logger.info("日志清理完成，保留最近 {} 天的记录", days);
+            return success(String.format("日志清理完成，已删除 %d 天前的历史数据", days));
+        } catch (Exception e) {
+            logger.error("日志清理失败", e);
+            return error("日志清理失败：" + e.getMessage());
+        }
+    }
+}

fastbee-plugs/fastbee-quartz/src/main/java/com/fastbee/quartz/mapper/SysJobLogMapper.java

@@ -61,4 +61,12 @@ public interface SysJobLogMapper {
      * 清空任务日志
      */
     public void cleanJobLog();
+
+    /**
+     * 删除指定天数前的任务日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    public int deleteJobLogBeforeDays(int days);
 }

fastbee-plugs/fastbee-quartz/src/main/java/com/fastbee/quartz/service/ISysJobLogService.java

@@ -53,4 +53,11 @@ public interface ISysJobLogService {
      * 清空任务日志
      */
     public void cleanJobLog();
+
+    /**
+     * 清理指定天数前的任务日志
+     *
+     * @param days 保留天数
+     */
+    public void cleanJobLog(int days);
 }

fastbee-plugs/fastbee-quartz/src/main/java/com/fastbee/quartz/service/impl/SysJobLogServiceImpl.java

@@ -78,4 +78,14 @@ public class SysJobLogServiceImpl implements ISysJobLogService {
     public void cleanJobLog() {
         jobLogMapper.cleanJobLog();
     }
+
+    /**
+     * 清理指定天数前的任务日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanJobLog(int days) {
+        jobLogMapper.deleteJobLogBeforeDays(days);
+    }
 }

fastbee-plugs/fastbee-quartz/src/main/resources/mapper/quartz/SysJobLogMapper.xml

@@ -77,6 +77,11 @@
         truncate table sys_job_log
     </update>
 
+    <delete id="deleteJobLogBeforeDays">
+        DELETE FROM sys_job_log
+        WHERE create_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
+
     <insert id="insertJobLog" parameterType="SysJobLog">
         insert into sys_job_log(
         <if test="jobLogId != null and jobLogId != 0">job_log_id,</if>

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/mapper/AlertLogMapper.java

@@ -115,4 +115,12 @@ public interface AlertLogMapper {
      * @return com.fastbee.iot.model.AlertCountVO
      */
     List<AlertCountVO> countAlertLevel(DataCenterParam dataCenterParam);
+
+    /**
+     * 删除指定天数前的告警日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    int deleteAlertLogBeforeDays(@Param("days") int days);
 }

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/mapper/EventLogMapper.java

@@ -25,4 +25,12 @@ public interface EventLogMapper extends BaseMapperX<EventLog> {
 
     Long selectEventLogCount(@Param("userId") Long userId);
 
+    /**
+     * 删除指定天数前的日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    int deleteEventLogBeforeDays(@Param("days") int days);
+
 }

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/service/IAlertLogService.java

@@ -107,4 +107,11 @@ public interface IAlertLogService {
      * @return com.fastbee.iot.model.AlertCountVO
      */
     List<AlertCountVO> countAlertLevel(DataCenterParam dataCenterParam);
+
+    /**
+     * 清理告警日志
+     *
+     * @param days 保留天数
+     */
+    void cleanAlertLog(int days);
 }

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/service/IEventLogService.java

@@ -37,4 +37,11 @@ public interface IEventLogService extends IService<EventLog> {
      */
     List<HistoryModel> listHistory(EventLog eventLog);
 
+    /**
+     * 清理事件日志
+     *
+     * @param days 保留天数
+     */
+    void cleanEventLog(int days);
+
 }

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/service/impl/AlertLogServiceImpl.java

@@ -199,4 +199,14 @@ public class AlertLogServiceImpl implements IAlertLogService {
     public List<AlertCountVO> countAlertLevel(DataCenterParam dataCenterParam) {
         return alertLogMapper.countAlertLevel(dataCenterParam);
     }
+
+    /**
+     * 清理告警日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanAlertLog(int days) {
+        alertLogMapper.deleteAlertLogBeforeDays(days);
+    }
 }

fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/service/impl/EventLogServiceImpl.java

@@ -64,4 +64,14 @@ public class EventLogServiceImpl extends ServiceImpl<EventLogMapper, EventLog> i
     public List<HistoryModel> listHistory(EventLog eventLog) {
         return eventLogMapper.listHistory(eventLog);
     }
+
+    /**
+     * 清理事件日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanEventLog(int days) {
+        eventLogMapper.deleteEventLogBeforeDays(days);
+    }
 }

fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/AlertLogMapper.xml

@@ -274,4 +274,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </foreach>
     </delete>
 
+    <delete id="deleteAlertLogBeforeDays">
+        DELETE FROM iot_alert_log
+        WHERE create_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
+
 </mapper>

fastbee-service/fastbee-iot-service/src/main/resources/mapper/iot/EventLogMapper.xml

@@ -59,4 +59,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="userId != null and userId != 0"> and user_id = #{userId}</if>
         </where>
     </select>
+
+    <delete id="deleteEventLogBeforeDays">
+        DELETE FROM iot_event_log
+        WHERE create_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
 </mapper>

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/mapper/SysLogininforMapper.java

@@ -41,4 +41,12 @@ public interface SysLogininforMapper {
     public int cleanLogininfor();
 
     public List<SysLogininfor> getUserCount();
+
+    /**
+     * 删除指定天数前的登录日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    public int deleteLogininforBeforeDays(int days);
 }

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/mapper/SysOperLogMapper.java

@@ -45,4 +45,12 @@ public interface SysOperLogMapper {
      * 清空操作日志
      */
     public void cleanOperLog();
+
+    /**
+     * 删除指定天数前的操作日志
+     *
+     * @param days 保留天数
+     * @return 删除记录数
+     */
+    public int deleteOperLogBeforeDays(int days);
 }

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/service/ISysLogininforService.java

@@ -42,4 +42,11 @@ public interface ISysLogininforService {
      * 统计一周内的登陆数据
      */
     public List<SysLogininfor> getUserCount();
+
+    /**
+     * 清理指定天数前的登录日志
+     *
+     * @param days 保留天数
+     */
+    public void cleanLogininfor(int days);
 }

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/service/ISysOperLogService.java

@@ -45,4 +45,11 @@ public interface ISysOperLogService {
      * 清空操作日志
      */
     public void cleanOperLog();
+
+    /**
+     * 清理指定天数前的操作日志
+     *
+     * @param days 保留天数
+     */
+    public void cleanOperLog(int days);
 }

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/service/impl/SysLogininforServiceImpl.java

@@ -63,4 +63,14 @@ public class SysLogininforServiceImpl implements ISysLogininforService {
     public List<SysLogininfor> getUserCount() {
         return logininforMapper.getUserCount();
     }
+
+    /**
+     * 清理指定天数前的登录日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanLogininfor(int days) {
+        logininforMapper.deleteLogininforBeforeDays(days);
+    }
 }

fastbee-service/fastbee-system-service/src/main/java/com/fastbee/system/service/impl/SysOperLogServiceImpl.java

@@ -68,4 +68,14 @@ public class SysOperLogServiceImpl implements ISysOperLogService {
     public void cleanOperLog() {
         operLogMapper.cleanOperLog();
     }
+
+    /**
+     * 清理指定天数前的操作日志
+     *
+     * @param days 保留天数
+     */
+    @Override
+    public void cleanOperLog(int days) {
+        operLogMapper.deleteOperLogBeforeDays(days);
+    }
 }

fastbee-service/fastbee-system-service/src/main/resources/mapper/system/SysLogininforMapper.xml

@@ -76,4 +76,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			) b on a.login_time = b.datetime;
 	</select>
 
+	<delete id="deleteLogininforBeforeDays">
+		DELETE FROM sys_logininfor
+		WHERE login_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+	</delete>
+
 </mapper>

fastbee-service/fastbee-system-service/src/main/resources/mapper/system/SysOperLogMapper.xml

@@ -80,4 +80,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         truncate table sys_oper_log
     </update>
 
+    <delete id="deleteOperLogBeforeDays">
+        DELETE FROM sys_oper_log
+        WHERE oper_time &lt; DATE_SUB(NOW(), INTERVAL #{days} DAY)
+    </delete>
+
 </mapper> 

sql/log_clean_task_init.sql

@@ -0,0 +1,96 @@
+-- ============================================
+-- 日志清理定时任务初始化 SQL
+-- ============================================
+
+-- 1. 插入定时任务记录到 sys_job 表
+-- 说明：每天凌晨 0 点自动清理 15 天前的日志数据
+-- 注意：LogCleanTask 类位于 fastbee-admin 模块的 com.fastbee.web.task 包下
+INSERT INTO `sys_job` (
+    `job_name`,
+    `job_group`,
+    `invoke_target`,
+    `cron_expression`,
+    `misfire_policy`,
+    `concurrent`,
+    `status`,
+    `create_by`,
+    `create_time`,
+    `remark`
+) VALUES (
+    '日志清理任务',                   -- 任务名称
+    'SYSTEM',                         -- 任务组名
+    'logCleanTask.cleanLogs()',       -- 调用目标字符串
+    '0 0 0 * * ?',                    -- Cron 表达式：每天凌晨 00:00:00
+    '3',                              -- 错误策略：不触发立即执行
+    '1',                              -- 禁止并发执行
+    '0',                              -- 状态：正常
+    'admin',                          -- 创建者
+    NOW(),                            -- 创建时间
+    '每天凌晨0点自动清理15天前的日志数据（iot_event_log、sys_oper_log、sys_logininfor、iot_alert_log、sys_job_log、notify_log）'
+);
+
+-- ============================================
+-- 清理的日志表说明
+-- ============================================
+-- 1. iot_event_log - IoT 事件日志
+-- 2. sys_oper_log - 系统操作日志
+-- 3. sys_logininfor - 登录日志
+-- 4. iot_alert_log - 设备告警日志
+-- 5. sys_job_log - 定时任务日志
+-- 6. notify_log - 通知日志
+--
+-- 注意：iot_device_log 表（设备监测日志）不参与清理
+-- 该表为核心数据，目前有 214 万条记录，需要数据迁移方案
+
+-- 2. 可选：添加日志清理权限菜单（根据需要执行）
+-- 如果需要在管理后台显示权限按钮，可以执行以下 SQL
+/*
+INSERT INTO `sys_menu` (
+    `menu_name`,
+    `parent_id`,
+    `order_num`,
+    `path`,
+    `component`,
+    `query`,
+    `is_frame`,
+    `is_cache`,
+    `menu_type`,
+    `visible`,
+    `status`,
+    `perms`,
+    `icon`,
+    `create_by`,
+    `create_time`,
+    `remark`
+) VALUES (
+    '日志清理',                       -- 菜单名称
+    2,                                -- 父菜单ID（根据实际情况调整，2通常是系统管理）
+    99,                               -- 显示顺序
+    '',                               -- 路由地址
+    '',                               -- 组件路径
+    '',                               -- 路由参数
+    1,                                -- 不是外链
+    0,                                -- 不缓存
+    'F',                              -- 菜单类型：F=按钮
+    '0',                              -- 显示状态
+    '0',                              -- 菜单状态
+    'system:log:clean',               -- 权限标识
+    '#',                              -- 图标
+    'admin',                          -- 创建者
+    NOW(),                            -- 创建时间
+    '日志清理按钮权限'
+);
+*/
+
+-- ============================================
+-- 验证定时任务是否创建成功
+-- ============================================
+-- SELECT * FROM sys_job WHERE job_name = '日志清理任务';
+
+-- ============================================
+-- 手动触发清理（可选）
+-- ============================================
+-- 如果需要立即清理历史数据，可以通过以下方式：
+-- 方式1：通过管理后台 -> 系统监控 -> 定时任务 -> 点击"执行一次"
+-- 方式2：调用 API 接口：POST /system/log/clean?days=30
+-- 方式3：数据库执行：UPDATE sys_job SET status = '0' WHERE job_name = '日志清理任务';