启动固化流程优化

yangys

2025-08-14 33e6270d2d3a40591e58d45fd8435d2f3eaf66b2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
package org.springblade.mdm.flow.controller;
 
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.tenant.annotation.NonDS;
import org.springblade.core.tool.api.R;
import org.springblade.mdm.flow.entity.FlowProgramFile;
import org.springblade.mdm.flow.service.FlowProgramFileService;
import org.springblade.mdm.flow.vo.ProgramUploadVO;
import org.springblade.mdm.program.service.NcProgramService;
import org.springblade.mdm.program.service.ProcessProgRefService;
import org.springframework.web.bind.annotation.*;
 
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
 
/**
 * 程序节点
 *
 * @author yangys
 */
@NonDS
@RestController
@RequestMapping("/flow/mgr")
@AllArgsConstructor
@Tag(name = "流程管理", description = "流程管理")
@Slf4j
public class FlowProgramController {
 
    private final NcProgramService ncProgramService;
    private final ProcessProgRefService ncProcessProgRefService;
 
    private final FlowProgramFileService flowProgramFileService;
 
    @PostMapping("/ncupload")
    @Operation(summary = "上传程序文件", description = "上传程序文件")
    public R<Boolean> upload(ProgramUploadVO uploadVO) {
        try {
            flowProgramFileService.uploadFlowProgramFile(uploadVO);
        }catch(Exception e) {
            log.error("程序上传执行错误",e);
            return R.fail("上传失败:" + e.getMessage());
        }
        return R.success();
    }
 
    @GetMapping("/nclist-by-instanceid")
    @Operation(summary = "流程程序文件列表", description = "流程程序文件列表")
    public R<List<FlowProgramFile>> listNcFileByProcess(@Parameter(description="流程实例id")@RequestParam String processInstanceId) {
        return R.data(flowProgramFileService.lambdaQuery().eq(FlowProgramFile::getProcessInstanceId, processInstanceId).orderByAsc(FlowProgramFile::getCreateTime).list());
    }
 
    @PostMapping("/remove")
    @Operation(summary = "删除临时程序文件", description = "")
    public R<Boolean> removeFile(Long id) {
        try {
            flowProgramFileService.removeById(id);
        }catch(Exception e) {
            log.error("删除文件失败",e);
            return R.fail(e.getMessage());
        }
        return R.success();
    }
 
    @GetMapping("/nc-content")
    @Operation(summary = "获取文件内容", description = "仅限文本格式的内容，二进制文件将返回空串")
    public R<String> fileContent(@Parameter(description = "程序文件id") Long id) {
        try {
            return R.data(flowProgramFileService.getFileContent(id));
        }catch(Exception e) {
            log.error("删除文件失败",e);
            return R.fail(e.getMessage());
        }
    }
 
    @GetMapping("/down-flow-file")
    @Operation(summary = "获取文件内容", description = "仅限文本格式的内容，二进制文件将返回空串")
    public void downloadFile(@Parameter(description = "程序文件id") Long id, HttpServletResponse response) {
        try {
            flowProgramFileService.download(id,response);
        }catch(Exception e) {
            log.error("下载程序文件异常", e);
            throw new ServiceException(e.getMessage());
        }
    }
 
}