| | |
| | | |
| | | package org.springblade.mdm.flow.controller; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | 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.service.ApproveRecordService; |
| | | import org.springblade.mdm.flow.entity.FlowProgramFile; |
| | | import org.springblade.mdm.flow.service.FlowProgramFileService; |
| | | import org.springblade.mdm.flow.vo.ApproveRecordVO; |
| | | import org.springblade.mdm.flow.vo.ProgramUploadVO; |
| | | import org.springblade.mdm.flow.vo.TaskTraceVO; |
| | | import org.springblade.mdm.program.service.NcProgramService; |
| | | import org.springblade.mdm.program.service.ProcessProgRefService; |
| | | import org.springblade.mdm.program.vo.NcNodeProgramQueryVO; |
| | | import org.springblade.mdm.program.vo.NcProgramUploadVO; |
| | | import org.springblade.mdm.program.vo.NcProgramVO; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.io.InputStream; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | |
| | | @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("/list-by-node") |
| | | @Operation(summary = "节点程序文件列表", description = "某节点内的程序列表,仅‘程序包’字典值60") |
| | | public R<List<NcProgramVO>> listByNode(@Parameter(description="所属节点ID")@RequestParam Long nodeId) { |
| | | return R.data(ncProgramService.listByNode(nodeId)); |
| | | @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") |
| | |
| | | return R.success(); |
| | | } |
| | | |
| | | @GetMapping("/content") |
| | | @GetMapping("/nc-content") |
| | | @Operation(summary = "获取文件内容", description = "仅限文本格式的内容,二进制文件将返回空串") |
| | | public R<String> fileContent(@Parameter(description = "程序文件id") Long id) { |
| | | try { |
| | |
| | | } |
| | | } |
| | | |
| | | @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()); |
| | | } |
| | | } |
| | | |
| | | } |