新增日志及附件临时表数据定时清理

zhongrj

2024-05-25 f37c32e7d663b40a8a55e50735f46c9535016c2c

新增日志及附件临时表数据定时清理

 src/main/java/org/springblade/modules/resource/mapper/AttachDataMapper.java

@@ -22,4 +22,9 @@
     */
    List<AttachDataVO> selectAttachDataPage(IPage page, AttachDataVO attachData);

    /**
     * 附件临时文件信息清理
     * @return
     */
    void removeBladeAttachData();
}

 src/main/java/org/springblade/modules/resource/mapper/AttachDataMapper.xml

@@ -19,4 +19,9 @@
        select * from blade_attach_data where 1=1
    </select>

    <!--附件临时文件信息清理(删除今天之前的数据)-->
    <delete id="removeBladeAttachData">
        DELETE FROM blade_attach_data WHERE create_time &lt; CURDATE();
    </delete>

</mapper>

 src/main/java/org/springblade/modules/resource/service/IAttachDataService.java

@@ -22,4 +22,10 @@
     */
    IPage<AttachDataVO> selectAttachDataPage(IPage<AttachDataVO> page, AttachDataVO attachData);

    /**
     * 附件临时文件信息清理
     * @param param
     * @return
     */
    boolean removeBladeAttachDatas(String param);
}

 src/main/java/org/springblade/modules/resource/service/impl/AttachDataServiceImpl.java

@@ -21,4 +21,14 @@
        return page.setRecords(baseMapper.selectAttachDataPage(page, attachData));
    }

    /**
     * 附件临时文件信息清理
     * @param param
     * @return
     */
    @Override
    public boolean removeBladeAttachDatas(String param) {
        baseMapper.removeBladeAttachData();
        return true;
    }
}

 src/main/java/org/springblade/modules/system/mapper/LogApiMapper.java

@@ -37,4 +37,9 @@
     * @return
     */
    List<LogApiExt> selectLogApiExtPage(IPage<LogApiExt> page,@Param("logApi") LogApiExt logApi);

    /**
     * 删除日志
     */
    int removeByTime();
}

 src/main/java/org/springblade/modules/system/mapper/LogApiMapper.xml

@@ -20,4 +20,9 @@
        order by id desc,create_time desc
    </select>

    <!--删除接口日志信息-->
    <delete id="removeByTime">
        DELETE FROM blade_log_api WHERE create_time &lt; NOW() - INTERVAL 180 DAY;
    </delete>

</mapper>

 src/main/java/org/springblade/modules/system/mapper/LogErrorMapper.java

@@ -26,4 +26,8 @@
 */
public interface LogErrorMapper extends BaseMapper<LogError> {

    /**
     * 删除日志
     */
    void removeByTime();
}

 src/main/java/org/springblade/modules/system/mapper/LogErrorMapper.xml

@@ -24,4 +24,9 @@
        <result column="create_by" property="createBy"/>
    </resultMap>

    <!--删除接口日志信息-->
    <delete id="removeByTime">
        DELETE FROM blade_log_error WHERE create_time &lt; NOW() - INTERVAL 90 DAY;
    </delete>

</mapper>

 src/main/java/org/springblade/modules/system/mapper/LogUsualMapper.java

@@ -26,4 +26,9 @@
 */
public interface LogUsualMapper extends BaseMapper<LogUsual> {

    /**
     *
     * @return
     */
    int removeByTime();
}

 src/main/java/org/springblade/modules/system/mapper/LogUsualMapper.xml

@@ -19,4 +19,9 @@
        <result column="create_by" property="createBy"/>
    </resultMap>

    <!--删除通用日志信息-->
    <delete id="removeByTime">
        DELETE FROM blade_log_usual WHERE create_time &lt; NOW() - INTERVAL 90 DAY;
    </delete>

</mapper>

 src/main/java/org/springblade/modules/system/service/ILogApiService.java

@@ -34,4 +34,9 @@
     * @return
     */
    IPage<LogApiExt> selectLogApiExtPage(IPage<LogApiExt> page, LogApiExt logApi);

    /**
     * 删除日志
     */
    void removeByTime();
}

 src/main/java/org/springblade/modules/system/service/ILogErrorService.java

@@ -26,4 +26,8 @@
 */
public interface ILogErrorService extends IService<LogError> {

    /**
     * 删除日志
     */
    void removeByTime();
}

 src/main/java/org/springblade/modules/system/service/ILogService.java

@@ -51,4 +51,10 @@
     */
    Boolean saveErrorLog(LogError log);

    /**
     * 清理时间范围外的日志记录信息
     * @param param
     * @return
     */
    boolean removeLogs(String param);
}

 src/main/java/org/springblade/modules/system/service/ILogUsualService.java

@@ -26,4 +26,8 @@
 */
public interface ILogUsualService extends IService<LogUsual> {

    /**
     * 删除日志
     */
    void removeByTime();
}

 src/main/java/org/springblade/modules/system/service/impl/LogApiServiceImpl.java

@@ -41,4 +41,12 @@
    public IPage<LogApiExt> selectLogApiExtPage(IPage<LogApiExt> page, LogApiExt logApi) {
        return page.setRecords(baseMapper.selectLogApiExtPage(page,logApi));
    }

    /**
     * 删除日志
     */
    @Override
    public void removeByTime() {
        baseMapper.removeByTime();
    }
}

 src/main/java/org/springblade/modules/system/service/impl/LogErrorServiceImpl.java

@@ -30,4 +30,11 @@
@Service
public class LogErrorServiceImpl extends ServiceImpl<LogErrorMapper, LogError> implements ILogErrorService {

    /**
     * 删除日志
     */
    @Override
    public void removeByTime() {
        baseMapper.removeByTime();
    }
}

 src/main/java/org/springblade/modules/system/service/impl/LogServiceImpl.java

@@ -91,6 +91,18 @@
        return errorService.save(log);
    }

    /**
     * 清理时间范围外的日志记录信息
     * @param param
     * @return
     */
    @Override
    public boolean removeLogs(String param) {
        usualService.removeByTime();
        apiService.removeByTime();
        errorService.removeByTime();
        return true;
    }

    /**
     * 解析请求头

 src/main/java/org/springblade/modules/system/service/impl/LogUsualServiceImpl.java

@@ -30,4 +30,11 @@
@Service
public class LogUsualServiceImpl extends ServiceImpl<LogUsualMapper, LogUsual> implements ILogUsualService {

    /**
     * 删除日志
     */
    @Override
    public void removeByTime() {
        baseMapper.removeByTime();
    }
}

 src/main/java/org/springblade/xxljob/jobhandler/DataHandleJob.java

New file
@@ -0,0 +1,59 @@
package org.springblade.xxljob.jobhandler;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.apache.logging.log4j.util.Strings;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.modules.resource.service.IAttachDataService;
import org.springblade.modules.system.service.ILogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 数据处理任务
 * @author zhongrj
 * @date 2024-05-25
 */
@Component
public class DataHandleJob {

    private static Logger logger = LoggerFactory.getLogger(LabelHandleJob.class);

    @Autowired
    private ILogService logService;

    @Autowired
    private IAttachDataService attachDataService;

    /**
     * 清理时间范围外的日志记录信息
     */
    @XxlJob("logJobHandler")
    public void logJobHandler (String param){
        XxlJobHelper.log("开始执行任务...清理时间范围外的日志记录信息");
        // 解析参数
        JSONObject jsonParam = JSON.parseObject(param);
//        String dayString = jsonParam.getString("day");
        // 开始执行
        boolean result = logService.removeLogs(param);
        XxlJobHelper.log("任务响应结果..." + result);
        // 结束
        XxlJobHelper.log("结束自动创建任务...");
    }

    /**
     * 附件临时文件信息清理
     */
    @XxlJob("attachDataJobHandler")
    public void attachDataJobHandler (String param){
        XxlJobHelper.log("开始执行任务...附件临时文件信息清理");
        // 开始执行
        boolean result = attachDataService.removeBladeAttachDatas(param);
        XxlJobHelper.log("任务响应结果..." + result);
        // 结束
        XxlJobHelper.log("结束自动创建任务...");
    }
}