wkc/ccdi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改配置文件

Browse Source
This commit is contained in:
wkc
2026-03-05 11:05:41 +08:00
parent 5af6f236f0
commit 190c7b096e
4 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ccdi-project/src/main/java/com/ruoyi/ccdi/project/mapper/CcdiFileUploadRecordMapper.java
View File

@@ -6,6 +6,7 @@ import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
/**
* 文件上传记录 Mapper 接口
@@ -30,5 +31,5 @@ public interface CcdiFileUploadRecordMapper extends BaseMapper<CcdiFileUploadRec
* @param projectId 项目ID
* @return 统计结果（Map形式，key为状态，value为数量）
*/
List<java.util.Map<String, Object>> countByStatus(@Param("projectId") Long projectId);
List<Map<String, Object>> countByStatus(@Param("projectId") Long projectId);
}

11
ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiFileUploadServiceImpl.java
View File

@@ -27,14 +27,10 @@ import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardCopyOption;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executor;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;
import java.util.ArrayList;
import java.util.Date;
import java.util.UUID;
/**
* 文件上传服务实现
@@ -262,8 +258,7 @@ public class CcdiFileUploadServiceImpl implements ICcdiFileUploadService {
try {
// 尝试提交异步任务
CompletableFuture.runAsync(
() -> processFileAsync(projectId, lsfxProjectId, tempFilePath,
record.getId(), batchId, record),
() -> processFileAsync(projectId, lsfxProjectId, tempFilePath, record.getId(), batchId, record),
fileUploadExecutor
);
submitted = true;