package org.springblade.mdm.program.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 lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.flowable.engine.task.Comment; import org.flowable.task.api.history.HistoricTaskInstance; 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.vo.ApproveRecordVO; import org.springblade.mdm.flow.vo.TaskTraceVO; import org.springblade.mdm.program.entity.NcProgram; 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.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import java.util.ArrayList; import java.util.List; /** * 程序节点 * * @author yangys */ @NonDS @RestController @RequestMapping("/program/ncfile") @AllArgsConstructor @Tag(name = "数控程序", description = "数控程序") @Slf4j public class NcProgramController { private final NcProgramService ncProgramService; private final ProcessProgRefService ncProcessProgRefService; private final ApproveRecordService approveRecordService; @PostMapping("/upload") @Operation(summary = "上传文件", description = "上传程序/附件文件") public R upload(NcProgramUploadVO uploadVO) { //@Parameter(description="文件") @RequestPart("file") MultipartFile file, @Parameter(description="所属节点ID")@RequestParam Long nodeId, // @Parameter(description="文件分类,使用字典(node_file_type)") @RequestParam String category ncProgramService.uploadProgramFileNew(uploadVO); return R.status(true); } @PostMapping("/remove") @Operation(summary = "删除程序文件", description = "") public R removeFile(Long id) { try { ncProgramService.removeProgram(id); return R.success(); }catch(Exception e) { log.error("删除文件失败",e); return R.fail(e.getMessage()); } } @GetMapping("/content") @Operation(summary = "获取文件内容", description = "仅限文本格式的内容,二进制文件将返回空串") public R fileContent(@Parameter(description = "程序文件id") Long id) { try { return R.data(ncProgramService.getFileContent(id)); }catch(Exception e) { log.error("删除文件失败",e); return R.fail(e.getMessage()); } } @GetMapping("/content-by-nodeid") @Operation(summary = "根据节点获取文件内容", description = "仅限文本格式的内容,二进制文件将返回空串") public R fileContentByNodeId(@Parameter(description = "节点id") Long nodeId) { try { return R.data(ncProgramService.getFileContentByNodeId(nodeId)); }catch(Exception e) { log.error("删除文件失败",e); return R.fail(e.getMessage()); } } @GetMapping("/list-by-node") @Operation(summary = "节点程序文件列表", description = "某节点内的程序列表,仅‘程序包’字典值60") public R> listByNode(@Parameter(description="所属节点ID")@RequestParam Long nodeId) { return R.data(ncProgramService.listByNode(nodeId)); } @PostMapping("/upgrade-process-edition") @Operation(summary = "升版", description = "升级工序版次") public R upgradeProcessEdition(Long id,String newProcessEdition ) { ncProgramService.upgradeProcessEdition(id,newProcessEdition); return R.status(true); } @Operation(summary = "程序分页查询", description = "用于在编制节点选择流程对应的程序") @GetMapping("/programpickpage") public R> page(NcNodeProgramQueryVO query) { IPage pages = ncProgramService.pageQuery(query); return R.data(pages); } @GetMapping("/list-by-process") @Operation(summary = "流程已选程序文件列表", description = "流程已选程序列表") public R> listByProcess(@Parameter(description="所属节点ID")@RequestParam String processInstanceId) { return R.data(ncProcessProgRefService.listByProcess(processInstanceId)); } @Operation(summary = "操作日志", description = "程序操作日志,即审批记录,在主页点击某一个程序后的下方标签显示") @GetMapping("approve-records") public R> processTrace1(@Parameter(description = "程序id") Long ncProgramId){ List result = new ArrayList<>(); return R.data(approveRecordService.listByNcProgramId(ncProgramId)); } @PostMapping("/send") @Operation(summary = "程序下发", description = "工控网数控程序下发(发送到机床配置的下发目录)") public R> send(@Parameter(description="所属节点ID")@RequestParam Long id) { return null;//R.data(ncProcessProgRefService.listByProcess(processInstanceId)); } @GetMapping("/send-to-machine-by-nodeid") @Operation(summary = "下发", description = "下发给机床设定的目录") public R sendToMachineByNodeId(@Parameter(description = "节点id") Long nodeId) { try { ncProgramService.sendByBindNodeId(nodeId); return R.success(); }catch(Exception e) { log.error("删除文件失败",e); return R.fail(e.getMessage()); } } }