diff --git a/ccdi-lsfx/src/main/java/com/ruoyi/lsfx/controller/LsfxTestController.java b/ccdi-lsfx/src/main/java/com/ruoyi/lsfx/controller/LsfxTestController.java index 65611df..ca19f31 100644 --- a/ccdi-lsfx/src/main/java/com/ruoyi/lsfx/controller/LsfxTestController.java +++ b/ccdi-lsfx/src/main/java/com/ruoyi/lsfx/controller/LsfxTestController.java @@ -4,8 +4,10 @@ import com.ruoyi.common.annotation.Anonymous; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.lsfx.client.LsfxAnalysisClient; +import com.ruoyi.lsfx.domain.request.DeleteFilesRequest; import com.ruoyi.lsfx.domain.request.FetchInnerFlowRequest; import com.ruoyi.lsfx.domain.request.GetBankStatementRequest; +import com.ruoyi.lsfx.domain.request.GetFileUploadStatusRequest; import com.ruoyi.lsfx.domain.request.GetTokenRequest; import com.ruoyi.lsfx.domain.response.*; import io.swagger.v3.oas.annotations.Operation; @@ -141,4 +143,43 @@ public class LsfxTestController { GetBankStatementResponse response = lsfxAnalysisClient.getBankStatement(request); return AjaxResult.success(response); } + + @Operation(summary = "获取单个文件上传状态", + description = "获取文件解析后的主体名称和账号等信息。status=-5且uploadStatusDesc='data.wait.confirm.newaccount'表示解析成功") + @GetMapping("/getFileUploadStatus") + public AjaxResult getFileUploadStatus( + @Parameter(description = "项目ID") @RequestParam Integer groupId, + @Parameter(description = "文件ID(可选,不传则查询所有)") @RequestParam(required = false) Integer logId + ) { + // 参数校验 + if (groupId == null || groupId <= 0) { + return AjaxResult.error("参数不完整:groupId为必填且大于0"); + } + + GetFileUploadStatusRequest request = new GetFileUploadStatusRequest(); + request.setGroupId(groupId); + request.setLogId(logId); + + GetFileUploadStatusResponse response = lsfxAnalysisClient.getFileUploadStatus(request); + return AjaxResult.success(response); + } + + @Operation(summary = "删除文件", + description = "删除解析失败或不需要的流水文件") + @PostMapping("/deleteFiles") + public AjaxResult deleteFiles(@RequestBody DeleteFilesRequest request) { + // 参数校验 + if (request.getGroupId() == null || request.getGroupId() <= 0) { + return AjaxResult.error("参数不完整:groupId为必填且大于0"); + } + if (request.getLogIds() == null || request.getLogIds().length == 0) { + return AjaxResult.error("参数不完整:logIds为必填且不能为空"); + } + if (request.getUserId() == null) { + return AjaxResult.error("参数不完整:userId为必填"); + } + + DeleteFilesResponse response = lsfxAnalysisClient.deleteFiles(request); + return AjaxResult.success(response); + } }