逻辑优化

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<ResourceFileRecordPo> list = sourceFileService.getDelFiles();
+        log.info("废弃文件:{}",list);
+        if(CollectionUtils.isNotEmpty(list)) {
+            for (ResourceFileRecordPo recordPo : list) {
+                fileUploadService.delFile(recordPo.getFilePath());
+            }
+        }
+    }
+}

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<ErrorInfo> totalList = new ArrayList<>();
+        // 主体库
+        List<ErrorInfo> enterpriselist = imdEnterpriseService.queryExpiredCertificate();
+        if(CollectionUtils.isNotEmpty(enterpriselist)) {
+            totalList.addAll(enterpriselist);
+        }
+        // 人员库
+        List<ErrorInfo> personnellist = imdPersonnelService.queryExpiredCertificate();
+        if(CollectionUtils.isNotEmpty(personnellist)) {
+            totalList.addAll(personnellist);
+        }
+        if(CollectionUtils.isNotEmpty(totalList)) {
+            imdErrorInfoService.addErrorInfo(totalList);
+        }
+    }
+}