diff --git a/bonus-quartz/src/main/java/com/bonus/quartz/task/ResourceFileTask.java b/bonus-quartz/src/main/java/com/bonus/quartz/task/ResourceFileTask.java new file mode 100644 index 0000000..dee03ce --- /dev/null +++ b/bonus-quartz/src/main/java/com/bonus/quartz/task/ResourceFileTask.java @@ -0,0 +1,45 @@ +package com.bonus.quartz.task; + +import com.bonus.common.domain.file.po.ResourceFileRecordPo; +import com.bonus.common.utils.StringUtils; +import com.bonus.file.service.FileUploadService; +import com.bonus.file.service.SourceFileService; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.List; + +/** + * 定时任务调度测试 + * + * @author bonus + */ +@Component("ResourceFileTask") +@Slf4j +public class ResourceFileTask { + + @Resource(name = "SourceFileService") + private SourceFileService sourceFileService; + + @Resource(name = "FileUploadService") + private FileUploadService fileUploadService; + + /** + * 查询废弃文件,并删除 + * @return void + * @author cwchen + * @date 2025/11/16 20:00 + */ + public void scanFiles() { + log.info("开始扫描不存在文件"); + List list = sourceFileService.getDelFiles(); + log.info("废弃文件:{}",list); + if(CollectionUtils.isNotEmpty(list)) { + for (ResourceFileRecordPo recordPo : list) { + fileUploadService.delFile(recordPo.getFilePath()); + } + } + } +} diff --git a/bonus-quartz/src/main/java/com/bonus/quartz/task/ScanCertificateTask.java b/bonus-quartz/src/main/java/com/bonus/quartz/task/ScanCertificateTask.java new file mode 100644 index 0000000..21e79c7 --- /dev/null +++ b/bonus-quartz/src/main/java/com/bonus/quartz/task/ScanCertificateTask.java @@ -0,0 +1,52 @@ +package com.bonus.quartz.task; + +import com.bonus.common.domain.mainDatabase.po.ErrorInfo; +import com.bonus.mainDataBase.service.IMDEnterpriseService; +import com.bonus.mainDataBase.service.IMDErrorInfoService; +import com.bonus.mainDataBase.service.IMDPersonnelService; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.List; + +/** + * @className:Scan + * @author:cwchen + * @date:2025-11-16-20:18 + * @version:1.0 + * @description:扫描证件是否过期 + */ +@Component("ScanCertificateTask") +@Slf4j +public class ScanCertificateTask { + + @Resource(name = "IMDErrorInfoService") + private IMDErrorInfoService imdErrorInfoService; + + @Resource(name = "IMDEnterpriseService") + private IMDEnterpriseService imdEnterpriseService; + + @Resource(name = "IMDPersonnelService") + private IMDPersonnelService imdPersonnelService; + + public void scanCertificate() { + log.info("开始扫描证件是否过期"); + List totalList = new ArrayList<>(); + // 主体库 + List enterpriselist = imdEnterpriseService.queryExpiredCertificate(); + if(CollectionUtils.isNotEmpty(enterpriselist)) { + totalList.addAll(enterpriselist); + } + // 人员库 + List personnellist = imdPersonnelService.queryExpiredCertificate(); + if(CollectionUtils.isNotEmpty(personnellist)) { + totalList.addAll(personnellist); + } + if(CollectionUtils.isNotEmpty(totalList)) { + imdErrorInfoService.addErrorInfo(totalList); + } + } +}