feat: 添加企业文件管理功能及相关任务类

refactor: 重构企业文件验证和移动逻辑

fix: 修复企业合规验证逻辑及路径处理问题

docs: 添加VerifyContext工具类及相关文档

style: 优化代码格式及注释

client/src/main/java/com/ecep/contract/task/CompanyCompositeUpdateTasker.java

@@ -4,7 +4,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.ecep.contract.MessageHolder;
-import com.ecep.contract.constant.CloudServiceConstant;
+import com.ecep.contract.WebSocketClientTasker;
 import com.ecep.contract.vo.CompanyVo;
 
 import lombok.Setter;
@@ -12,7 +12,7 @@ import lombok.Setter;
 /**
  * 合并更新
  */
-public class CompanyCompositeUpdateTasker extends Tasker<Object> {
+public class CompanyCompositeUpdateTasker extends Tasker<Object> implements WebSocketClientTasker {
     private static final Logger logger = LoggerFactory.getLogger(CompanyCompositeUpdateTasker.class);
     @Setter
     private CompanyVo company;
@@ -20,14 +20,17 @@ public class CompanyCompositeUpdateTasker extends Tasker<Object> {
     @Override
     protected Object execute(MessageHolder holder) throws Exception {
         updateTitle("合并更新 " + company.getName());
+        return callRemoteTask(holder, getLocale(), company.getId());
+    }
 
-        holder.debug("1. 从 " + CloudServiceConstant.RK_NAME + " 更新...");
-        updateProgress(0.1, 1);
-        holder.debug("2. 从 " + CloudServiceConstant.U8_NAME + " 更新...");
-        updateProgress(0.3, 1);
-        holder.debug("3. 从 " + CloudServiceConstant.TYC_NAME + " 更新...");
-        updateProgress(1, 1);
-        return null;
+    @Override
+    public String getTaskName() {
+        return "CompanyCompositeUpdateTasker";
+    }
+
+    @Override
+    public void updateProgress(long workDone, long max) {
+        super.updateProgress(workDone, max);
     }
 
 }

client/src/main/java/com/ecep/contract/task/CompanyFileMoveTasker.java

@@ -0,0 +1,123 @@
+package com.ecep.contract.task;
+
+import java.io.File;
+
+import org.springframework.util.StringUtils;
+
+import com.ecep.contract.MessageHolder;
+import com.ecep.contract.service.CompanyFileService;
+import com.ecep.contract.service.CompanyService;
+import com.ecep.contract.vo.CompanyFileVo;
+import com.ecep.contract.vo.CompanyVo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 公司文件移动任务类
+ * 用于将文件从老系统中移动到指定的企业目录中
+ */
+public class CompanyFileMoveTasker extends Tasker<Boolean> {
+    @Getter
+    @Setter
+    private CompanyVo company;
+
+    @Getter
+    private boolean filesMoved = false;
+
+    @Override
+    protected Boolean execute(MessageHolder holder) throws Exception {
+        updateTitle("移动公司文件");
+        updateProgress(0, 100);
+
+        if (company == null) {
+            holder.error("公司对象为空");
+            updateProgress(100, 100);
+            return false;
+        }
+
+        try {
+            holder.info("开始移动公司文件：" + company.getName());
+            updateProgress(10, 100);
+
+            // 获取CompanyFileService
+            CompanyFileService companyFileService = getCachedBean(CompanyFileService.class);
+            CompanyService companyService = getCachedBean(CompanyService.class);
+
+            // 获取公司的所有文件
+            holder.info("获取公司文件列表...");
+            java.util.List<CompanyFileVo> list = companyFileService.findByCompany(company);
+            updateProgress(20, 100);
+
+            if (list.isEmpty()) {
+                holder.info("该公司没有文件需要移动");
+                updateProgress(100, 100);
+                return false;
+            }
+
+            holder.info("共有" + list.size() + "个文件需要处理");
+
+            // 确保公司目录存在
+            holder.info("检查并创建公司目录...");
+            if (companyService.makePathAbsent(company, holder)) {
+                company = companyService.save(company);
+                holder.info("公司目录已创建");
+            }
+            updateProgress(30, 100);
+
+            // 检查公司路径
+            String path = company.getPath();
+            if (!StringUtils.hasText(path)) {
+                holder.error("异常, 企业目录未设置");
+                updateProgress(100, 100);
+                return false;
+            }
+
+            File companyPath = new File(path);
+            int movedCount = 0;
+            int totalFiles = list.size();
+
+            // 逐个处理文件
+            for (int i = 0; i < list.size(); i++) {
+                CompanyFileVo companyFile = list.get(i);
+                String filePath = companyFile.getFilePath();
+
+                // 更新进度
+                updateProgress(30 + (i * 70) / totalFiles, 100);
+
+                if (StringUtils.hasText(filePath)) {
+                    File file = new File(filePath);
+                    if (file.exists()) {
+                        if (file.getParentFile().equals(companyPath)) {
+                            holder.info("文件已在目标位置：" + file.getName());
+                            continue;
+                        }
+
+                        File dest = new File(companyPath, file.getName());
+                        holder.info("移动文件：" + file.getName() + " -> " + companyPath.getName());
+
+                        if (file.renameTo(dest)) {
+                            companyFile.setFilePath(dest.getAbsolutePath());
+                            companyFileService.save(companyFile);
+                            holder.info("文件移动成功：" + file.getName());
+                            movedCount++;
+                            filesMoved = true;
+                        } else {
+                            holder.warn("文件移动失败：" + file.getName());
+                        }
+                    } else {
+                        holder.warn("文件不存在：" + filePath);
+                    }
+                }
+            }
+
+            holder.info("文件移动完成，成功移动" + movedCount + "个文件");
+            updateProgress(100, 100);
+            return filesMoved;
+        } catch (Exception e) {
+            holder.error("文件移动过程中发生错误：" + e.getMessage());
+            updateProgress(100, 100);
+            throw e;
+        }
+    }
+}

client/src/main/java/com/ecep/contract/task/CompanyFileResetTasker.java

@@ -0,0 +1,274 @@
+package com.ecep.contract.task;
+
+import java.io.File;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import org.springframework.util.StringUtils;
+
+import com.ecep.contract.CompanyFileType;
+import com.ecep.contract.MessageHolder;
+import com.ecep.contract.MyDateTimeUtils;
+import com.ecep.contract.constant.CloudServiceConstant;
+import com.ecep.contract.constant.CompanyConstant;
+import com.ecep.contract.service.CompanyFileService;
+import com.ecep.contract.service.CompanyOldNameService;
+import com.ecep.contract.util.FileUtils;
+import com.ecep.contract.vo.CompanyFileVo;
+import com.ecep.contract.vo.CompanyOldNameVo;
+import com.ecep.contract.vo.CompanyVo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 公司文件重置任务类
+ * 用于本地执行公司文件重置操作，不通过WebSocket调用远程服务
+ */
+public class CompanyFileResetTasker extends Tasker<Boolean> {
+    @Getter
+    @Setter
+    private CompanyVo company;
+
+    @Getter
+    @Setter
+    private boolean filesUpdated = false;
+
+    private CompanyFileService getCompanyFileService() {
+        return getCachedBean(CompanyFileService.class);
+    }
+
+    private CompanyOldNameService getCompanyOldNameService() {
+        return getCachedBean(CompanyOldNameService.class);
+    }
+
+    @Override
+    protected Boolean execute(MessageHolder holder) throws Exception {
+        updateTitle("重置公司文件");
+        updateProgress(0, 100);
+
+        if (company == null) {
+            holder.error("公司对象为空");
+            updateProgress(100, 100);
+            return false;
+        }
+
+        try {
+            holder.info("开始重置公司文件：" + company.getName());
+            updateProgress(10, 100);
+
+            boolean result = reBuildingFiles(company, holder);
+
+            if (result) {
+                holder.info("公司文件重置成功");
+                setFilesUpdated(true);
+            } else {
+                holder.info("公司文件重置完成，但没有更新任何文件");
+                setFilesUpdated(false);
+            }
+
+            updateProgress(100, 100);
+            return result;
+        } catch (Exception e) {
+            holder.error("公司文件重置失败：" + e.getMessage());
+            updateProgress(100, 100);
+            throw e;
+        }
+    }
+
+    public boolean reBuildingFiles(CompanyVo company, MessageHolder holder) {
+        CompanyFileService companyFileService = getCompanyFileService();
+        boolean modfied = false;
+        List<CompanyFileVo> dbFiles = companyFileService.findByCompany(company);
+        holder.debug("现有 " + dbFiles.size() + " 条文件记录");
+
+        Map<String, CompanyFileVo> map = new HashMap<>();
+        // 排除掉数据库中重复的
+        for (CompanyFileVo dbFile : dbFiles) {
+            String filePath = dbFile.getFilePath();
+            // 没有文件信息，无效记录，删除
+            if (!StringUtils.hasText(filePath)) {
+                companyFileService.delete(dbFile);
+                holder.info("删除无效记录：" + filePath);
+                modfied = true;
+                continue;
+            }
+
+            // 目录不存在，删除
+            File dir = new File(filePath);
+            if (!dir.exists()) {
+                companyFileService.delete(dbFile);
+                holder.info("删除不存在目录记录：" + filePath);
+                modfied = true;
+                continue;
+            }
+
+            CompanyFileVo old = map.put(filePath, dbFile);
+            // 目录有重复删除
+            if (old != null) {
+                companyFileService.delete(old);
+                holder.info("删除重复目录记录：" + filePath);
+                modfied = true;
+            }
+        }
+
+        Map<String, File> directoryMap = new HashMap<>();
+
+        // 公司目录
+        if (StringUtils.hasText(company.getPath())) {
+            File dir = new File(company.getPath());
+            directoryMap.put(company.getName(), dir);
+        }
+
+        // 获取所有曾用名
+        List<CompanyOldNameVo> oldNames = getCompanyOldNameService().findAllByCompany(company);
+        for (CompanyOldNameVo companyOldName : oldNames) {
+            String path = companyOldName.getPath();
+            if (StringUtils.hasText(path)) {
+                File dir = new File(path);
+                directoryMap.put(companyOldName.getName(), dir);
+            }
+        }
+
+        for (Map.Entry<String, File> entry : directoryMap.entrySet()) {
+            String companyName = entry.getKey();
+            File dir = entry.getValue();
+            if (!StringUtils.hasText(companyName)) {
+                continue;
+            }
+            if (dir == null || !dir.exists()) {
+                continue;
+            }
+
+            File[] files = dir.listFiles();
+            if (files == null) {
+                // 文件系统出错或者没有相关文件
+                continue;
+            }
+            holder.debug("目录 " + companyName + " 下有 " + files.length + " 个文件");
+            for (File file : files) {
+                // 只处理文件
+                if (!file.isFile() || FileUtils.isHiddenFile(file)) {
+                    continue;
+                }
+                String filePath = file.getAbsolutePath();
+                if (!map.containsKey(filePath)) {
+                    // 未记录
+                    CompanyFileVo filled = fillFileType(file, holder);
+                    filled.setCompanyId(company.getId());
+                    companyFileService.save(filled);
+                    holder.info("导入 " + file.getName() + " ");
+                    modfied = true;
+                }
+            }
+        }
+        return modfied;
+    }
+
+    /**
+     * 从文件名生成公司文件对象，文件已经存在公司对应的存储目录下
+     *
+     * @param file   文件
+     * @param holder 状态输出
+     * @return 公司文件对象
+     */
+    private CompanyFileVo fillFileType(File file, MessageHolder holder) {
+        String fileName = file.getName();
+        CompanyFileVo companyFile = new CompanyFileVo();
+        companyFile.setType(CompanyFileType.General);
+        companyFile.setFilePath(file.getAbsolutePath());
+        fillApplyDateAndExpiringDateAbsent(file, companyFile);
+
+        // 天眼查 基础版企业信用报告
+        if (fileName.contains(CloudServiceConstant.TYC_ENTERPRISE_BASIC_REPORT)
+                || fileName.contains(CloudServiceConstant.TYC_ENTERPRISE_MAJOR_REPORT)
+                || fileName.contains(CloudServiceConstant.TYC_ENTERPRISE_ANALYSIS_REPORT)) {
+            companyFile.setType(CompanyFileType.CreditReport);
+            fillExpiringDateAbsent(companyFile);
+            return companyFile;
+        }
+
+        // 天眼查 企业信用信息公示报告
+        if (fileName.contains(CloudServiceConstant.TYC_ENTERPRISE_CREDIT_REPORT)) {
+            companyFile.setType(CompanyFileType.CreditInfoPublicityReport);
+            return companyFile;
+        }
+
+        // 集团相关方平台 元素征信 企业征信报告
+        if (fileName.contains(CloudServiceConstant.RK_VENDOR_NAME)
+                && fileName.contains(CloudServiceConstant.RK_ENTERPRISE_CREDIT_REPORT)) {
+            companyFile.setType(CompanyFileType.CreditReport);
+            fillExpiringDateAbsent(companyFile);
+            return companyFile;
+        }
+
+        // 营业执照
+        if (fileName.contains(CompanyConstant.BUSINESS_LICENSE)) {
+            companyFile.setType(CompanyFileType.BusinessLicense);
+            return companyFile;
+        }
+
+        // 其他企业信用报告
+        if (fileName.contains(CompanyConstant.ENTERPRISE_REPORT)) {
+            companyFile.setType(CompanyFileType.CreditReport);
+            fillExpiringDateAbsent(companyFile);
+            return companyFile;
+        }
+        return companyFile;
+    }
+
+    /**
+     * 补齐有效期
+     */
+    private void fillExpiringDateAbsent(CompanyFileVo file) {
+        LocalDate expiringDate = file.getExpiringDate();
+        if (expiringDate == null) {
+            LocalDate applyDate = file.getApplyDate();
+            if (applyDate != null) {
+                expiringDate = applyDate.plusYears(1);
+                file.setExpiringDate(expiringDate);
+            }
+        }
+    }
+
+    private static void fillApplyDateAndExpiringDateAbsent(File file, CompanyFileVo companyFile) {
+        LocalDate applyDate = companyFile.getApplyDate();
+        if (applyDate != null) {
+            return;
+        }
+
+        String fileName = file.getName();
+        Pattern pattern = Pattern.compile(MyDateTimeUtils.REGEX_DATE);
+        Matcher matcher = pattern.matcher(fileName);
+        while (matcher.find()) {
+            // 找到第一个日期，记作起始日期
+            String date = matcher.group();
+            try {
+                LocalDate n = LocalDate.parse(date);
+                companyFile.setApplyDate(n);
+
+                // 如果 截至日期未设置，则第二个日期记作截至日期（如有）
+                LocalDate expiringDate = companyFile.getExpiringDate();
+                if (expiringDate == null) {
+                    while (matcher.find()) {
+                        date = matcher.group();
+                        try {
+                            n = LocalDate.parse(date);
+                            companyFile.setExpiringDate(n);
+                            break;
+                        } catch (Exception ignored) {
+                        }
+                    }
+                }
+                break;
+            } catch (Exception ignored) {
+            }
+        }
+
+    }
+}

client/src/main/java/com/ecep/contract/task/CompanyFileRetrieveFromDownloadDirTasker.java

@@ -0,0 +1,306 @@
+package com.ecep.contract.task;
+
+import java.io.File;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.StringUtils;
+
+import com.ecep.contract.CompanyFileType;
+import com.ecep.contract.MessageHolder;
+import com.ecep.contract.MyDateTimeUtils;
+import com.ecep.contract.MyProperties;
+import com.ecep.contract.constant.CloudServiceConstant;
+import com.ecep.contract.service.CloudTycService;
+import com.ecep.contract.service.CompanyFileService;
+import com.ecep.contract.service.CompanyOldNameService;
+import com.ecep.contract.vo.CompanyFileVo;
+import com.ecep.contract.vo.CompanyOldNameVo;
+import com.ecep.contract.vo.CompanyVo;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 从下载目录检索公司文件的本地任务器
+ * 用于在客户端本地执行从下载目录检索相关资质文件的操作
+ */
+public class CompanyFileRetrieveFromDownloadDirTasker extends Tasker<Object> {
+    private static final Logger logger = LoggerFactory.getLogger(CompanyFileRetrieveFromDownloadDirTasker.class);
+
+    @Getter
+    @Setter
+    private CompanyVo company;
+
+    @Getter
+    @Setter
+    private String downloadDirPath;
+    @Getter
+    @Setter
+    private boolean companyPathChanged = false;
+
+    private CompanyFileService getCompanyFileService() {
+        return getCachedBean(CompanyFileService.class);
+    }
+
+    private CompanyOldNameService getCompanyOldNameService() {
+        return getCachedBean(CompanyOldNameService.class);
+    }
+
+    @Override
+    protected Object execute(MessageHolder holder) throws Exception {
+        updateTitle("从下载目录检索文件");
+
+        // 获取下载目录
+        File dir;
+        if (StringUtils.hasText(downloadDirPath)) {
+            dir = new File(downloadDirPath);
+        } else {
+            // 如果没有提供下载目录，则使用配置中的
+            MyProperties myProperties = getBean(MyProperties.class);
+            dir = myProperties.getDownloadDirectory();
+        }
+
+        // 检查下载目录是否存在
+        if (!dir.exists()) {
+            String errorMsg = "下载目录 " + dir.getAbsolutePath() + " 不存在，请检查";
+            holder.warn(errorMsg);
+            return false;
+        }
+
+        // 开始检索下载文件夹
+        holder.info("开始检索 下载 文件夹：" + dir.getAbsolutePath() + "...");
+        File[] files = dir.listFiles(File::isFile);
+
+        // 检查检索是否成功
+        if (files == null) {
+            String errorMsg = "检索 下载 文件夹失败";
+            holder.error(errorMsg);
+            return false;
+        }
+
+        // 检查文件夹是否有文件
+        if (files.length == 0) {
+            String errorMsg = "下载 文件夹没有文件";
+            holder.info(errorMsg);
+            return false;
+        }
+
+        // 报告文件夹中的文件数量
+        holder.info("下载 文件夹中共有文件 " + files.length + " 个文件");
+        updateProgress(20, 100);
+        //
+        companyPathChanged = getCompanyService().makePathAbsent(company, holder);
+        if (companyPathChanged) {
+            holder.info("企业目录已创建或更新：" + company.getPath());
+            company = getCompanyService().save(company);
+        }
+        updateProgress(25, 100);
+
+        // 检查企业目录是否存在
+        if (!StringUtils.hasText(company.getPath())) {
+            holder.error("企业存储目录未设置，请检查");
+            return false;
+        }
+
+        // 检查企业目录是否存在
+        File home = new File(company.getPath());
+        if (!home.exists()) {
+            holder.error(company.getPath() + " 不存在，无法访问，请检查或者修改");
+            return false;
+        }
+
+        // 获取所有曾用名
+        List<CompanyOldNameVo> oldNames = getCompanyOldNameService().findAllByCompany(company);
+        holder.info("企业曾用名共有 " + oldNames.size() + " 个");
+
+        // 按照 企业名字 移动到对应的曾用名目录
+        Map<String, File> oldNameOfDir = new HashMap<>();
+        oldNameOfDir.put(company.getName(), home);
+        toMap(oldNames, oldNameOfDir);
+        updateProgress(30, 100);
+
+        // 执行文件检索操作
+        for (int i = 0; i < files.length; i++) {
+
+            updateProgress(30 + (i * 50) / files.length, 100);
+
+            File file = files[i];
+            // 只处理文件
+            if (!file.isFile()) {
+                continue;
+            }
+
+            MessageHolder sub = holder.sub("[" + (i + 1) + "/" + files.length + "]");
+            String fileName = file.getName();
+
+            for (Map.Entry<String, File> entry : oldNameOfDir.entrySet()) {
+                String companyName = entry.getKey();
+                // 必须要包含公司名称否则无法区分
+                if (!fileName.contains(companyName)) {
+                    sub.debug(fileName);
+                    continue;
+                }
+
+                // 文件存储的目的地目录
+                File destPath = entry.getValue();
+                if (destPath == null) {
+                    destPath = home;
+                }
+                sub.info(fileName + " -> " + destPath);
+
+                CompanyFileVo filled = fillDownloadFileType(company, file, companyName, destPath, sub);
+                if (filled != null) {
+                    filled.setCompanyId(company.getId());
+                    getCompanyFileService().save(filled);
+                    holder.info("导入 " + fileName + " 到 " + destPath.getAbsolutePath());
+                }
+            }
+        }
+
+        updateProgress(100, 100);
+        return null;
+    }
+
+    void toMap(List<CompanyOldNameVo> oldNames, Map<String, File> oldNameOfDir) {
+        for (CompanyOldNameVo oldName : oldNames) {
+            String name = oldName.getName();
+            if (!StringUtils.hasText(name)) {
+                continue;
+            }
+            File dir = null;
+            String path = oldName.getPath();
+            if (StringUtils.hasText(path)) {
+                dir = new File(path);
+            }
+            oldNameOfDir.put(name, dir);
+        }
+    }
+
+    /**
+     * 从文件名生成公司文件对象
+     * 文件从下载目录中导入
+     *
+     * @param company     公司对象
+     * @param file        导入的文件对象
+     * @param companyName 公司名称
+     * @param destDir     目标目录
+     * @param holder      状态输出
+     * @return 生成的公司文件对象，如果无法转换则返回null
+     */
+    private CompanyFileVo fillDownloadFileType(CompanyVo company, File file, String companyName, File destDir,
+            MessageHolder holder) {
+        String fileName = file.getName();
+        // 天眼查的报告
+        // 目前只有 基础版企业信用报告, 企业信用信息公示报告下载保存时的文件名中没有天眼查
+        if (CloudTycService.isTycReport(fileName)) {
+            CompanyFileVo companyFile = new CompanyFileVo();
+            companyFile.setType(CompanyFileType.CreditReport);
+            fillApplyDateAbsent(file, companyFile);
+
+            String destFileName = fileName;
+            // 重命名 基础版企业信用报告
+            for (String report : Arrays.asList(
+                    CloudServiceConstant.TYC_ENTERPRISE_ANALYSIS_REPORT,
+                    CloudServiceConstant.TYC_ENTERPRISE_BASIC_REPORT,
+                    CloudServiceConstant.TYC_ENTERPRISE_MAJOR_REPORT)) {
+
+                if (fileName.contains(report)) {
+                    LocalDate applyDate = companyFile.getApplyDate();
+                    if (applyDate == null) {
+                        applyDate = LocalDate.now();
+                        companyFile.setApplyDate(applyDate);
+                    }
+                    String formatted = MyDateTimeUtils.format(applyDate);
+                    String extension = StringUtils.getFilenameExtension(fileName);
+                    destFileName = String.format("%s_%s_%s_%s.%s",
+                            companyName, CloudServiceConstant.TYC_NAME, report, formatted, extension);
+                }
+            }
+
+            // 重新设置 企业分析报告 未普通文件
+            // if (fileName.contains(CloudTycService.TYC_ENTERPRISE_ANALYSIS_REPORT)) {
+            // companyFile.setType(General);
+            // }
+
+            File dest = new File(destDir, destFileName);
+            // 移动文件
+            if (!file.renameTo(dest)) {
+                // 移动失败时
+                holder.warn(fileName + " 无法移动到 " + dest.getAbsolutePath());
+                return null;
+            }
+
+            holder.info(fileName + " 移动到 " + dest.getAbsolutePath());
+            companyFile.setFilePath(dest.getAbsolutePath());
+
+            //
+            if (companyFile.getExpiringDate() == null) {
+                if (companyFile.getApplyDate() != null) {
+                    companyFile.setExpiringDate(companyFile.getApplyDate().plusYears(1));
+                }
+            }
+            return companyFile;
+        }
+
+        // 企业信用信息公示报告
+        if (fileName.contains(CloudServiceConstant.TYC_ENTERPRISE_CREDIT_REPORT)) {
+            CompanyFileVo companyFile = new CompanyFileVo();
+            companyFile.setType(CompanyFileType.CreditInfoPublicityReport);
+            fillApplyDateAbsent(file, companyFile);
+            File dest = new File(destDir, fileName);
+
+            // 移动文件
+            if (!file.renameTo(dest)) {
+                if (dest.exists()) {
+                    // 尝试删除已经存在的文件
+                    if (!dest.delete()) {
+                        holder.warn("覆盖时，无法删除已存在的文件 " + dest.getAbsolutePath());
+                        return null;
+                    }
+                    if (file.renameTo(dest)) {
+                        List<CompanyFileVo> files = getCompanyFileService().findByCompanyAndPath(company,
+                                dest.getAbsolutePath());
+                        if (!files.isEmpty()) {
+                            companyFile = files.getFirst();
+                        }
+                    } else {
+                        holder.error(fileName + " 无法覆盖到 " + dest.getAbsolutePath());
+                        return null;
+                    }
+                } else {
+                    holder.error(fileName + " 无法移动到 " + dest.getAbsolutePath());
+                    return null;
+                }
+            }
+
+            holder.info(fileName + " 移动到 " + dest.getAbsolutePath());
+            companyFile.setFilePath(dest.getAbsolutePath());
+            return companyFile;
+        }
+        return null;
+    }
+
+    /**
+     * 当 ApplyDate 未设置时，尝试使用文件名中包含的日期
+     */
+    private static void fillApplyDateAbsent(File file, CompanyFileVo companyFile) {
+        LocalDate applyDate = companyFile.getApplyDate();
+        if (applyDate != null) {
+            return;
+        }
+        String fileName = file.getName();
+        // 从文件名中提取日期
+        LocalDate picked = MyDateTimeUtils.pickLocalDate(fileName);
+        if (picked != null) {
+            companyFile.setApplyDate(picked);
+        }
+    }
+
+}

client/src/main/java/com/ecep/contract/task/CompanyVerifyTasker.java

@@ -1,20 +1,35 @@
 package com.ecep.contract.task;
 
 import com.ecep.contract.MessageHolder;
+import com.ecep.contract.WebSocketClientTasker;
 import com.ecep.contract.vo.CompanyVo;
 
 import lombok.Getter;
 import lombok.Setter;
 
-public class CompanyVerifyTasker extends Tasker<Object> {
+public class CompanyVerifyTasker extends Tasker<Object> implements WebSocketClientTasker {
     @Getter
     @Setter
     private CompanyVo company;
 
+    @Getter
+    @Setter
+    boolean passed = false;
+
     @Override
     protected Object execute(MessageHolder holder) throws Exception {
         updateTitle("验证企业是否符合合规要求");
-        return null;
+        return callRemoteTask(holder, getLocale(), company.getId());
+    }
+
+    @Override
+    public String getTaskName() {
+        return "CompanyVerifyTasker";
+    }
+
+    @Override
+    public void updateProgress(long workDone, long max) {
+        super.updateProgress(workDone, max);
     }
 
 }

client/src/main/java/com/ecep/contract/task/Tasker.java

@@ -50,7 +50,7 @@ public abstract class Tasker<T> extends Task<T> {
         @SuppressWarnings("unchecked")
         K bean = (K) cachedMap.get(requiredType);
         if (bean == null) {
-            bean = getBean(requiredType);
+            bean = SpringApp.getBean(requiredType);
             cachedMap.put(requiredType, bean);
         }
         return bean;