feat(lsfx): Controller添加获取文件上传状态和删除文件接口

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);
+    }
 }