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.Parameters; import io.swagger.v3.oas.annotations.enums.ParameterIn; import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.tags.Tag; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.core.tenant.annotation.NonDS; import org.springblade.core.tool.api.R; import org.springblade.core.tool.utils.Func; import org.springblade.mdm.basesetting.machine.vo.MachineQueryVO; import org.springblade.mdm.basesetting.machine.vo.MachineVO; import org.springblade.mdm.flow.service.FlowProgramFileService; import org.springblade.mdm.program.entity.NcNode; import org.springblade.mdm.program.entity.NcProgram; import org.springblade.mdm.program.service.NcNodeService; import org.springblade.mdm.program.service.NcProgramService; import org.springblade.mdm.program.service.ProgramFlowStatusQueryService; import org.springblade.mdm.program.vo.*; import org.springframework.web.bind.annotation.*; import java.util.List; /** * 程序节点 * * @author yangys */ @NonDS @RestController @RequestMapping("/program/node") @AllArgsConstructor @Tag(name = "程序节点", description = "程序节点") @Slf4j public class NcNodeController { private final NcProgramService ncProgramService; private final NcNodeService ncNodeService; private final ProgramFlowStatusQueryService programFlowStatusQueryService; private final FlowProgramFileService flowProgramFileService; /** * 新增 */ @PostMapping("/save") @Operation(summary = "新增节点", description = "节点信息,id保持空") public R save(@RequestBody NcNodeVO vo) { ncNodeService.saveNcCode(vo); return R.status(true); } @PostMapping("/update") @Operation(summary = "修改节点", description = "节点信息,必须传入ID") public R update(@RequestBody NcNodeVO vo) { ncNodeService.updateNcNode(vo); return R.status(true); } @PostMapping("/remove") @Operation(summary = "删除节点") public R remove(Long id) { ncNodeService.removeById(id); return R.status(true); } @PostMapping("/lock") @Operation(summary = "锁定节点(程序包名)") public R lock(@Parameter(description="程序包名节点id)")Long id) { ncNodeService.lock(id); return R.status(true); } @GetMapping("/lazy-list") @Operation(summary = "懒加载列表", description = "程序目录树形结构") public R> lazyList(Long parentId) { List list = ncNodeService.lazyList(parentId); if(list != null && !list.isEmpty()) { for(NcNodeVO ncNodeVO : list) { if(NcNode.TYPE_PROGRAM_PACKAGE.equals(ncNodeVO.getNodeType())){ ncNodeVO.setFlowStatus(programFlowStatusQueryService.queryFlowStatus(ncNodeVO.getProcessInstanceId())); } } } return R.data(list); } @GetMapping("/search-list") @Operation(summary = "查询树状列表", description = "程序目录树形结构(查询专用)") public R> searchList(NcNodeQueryVO queryVO) { if(Func.isEmpty(queryVO.getName())){ return R.fail("请输入名称"); } List list = ncNodeService.searchList(queryVO); return R.data(list); } @GetMapping("/history-by-nodeid") @Operation(summary = "根据绑定节点id获取历史列表", description = "程序历史列表,仅‘程序包’字典值70的数据。用于显示程序的‘历史版本’") public R> historyByBindNodeId(@Parameter(description="节点ID(nodeType=70的节点id)")@RequestParam Long id) { return R.data(this.ncNodeService.historyByNodeId(id)); } @GetMapping("/compare-content") @Operation(summary = "对比内容数据", description = "查询对比内容的2个文本数据") public R compareContent(@Parameter(description="节点1的ID(nodeType=70的节点id)")Long id1,@Parameter(description="节点2的ID(nodeType=70的节点id)")Long id2) { CompareDataVO vo = new CompareDataVO(); NcNode node1 = ncNodeService.getById(id1); NcNode node2 = ncNodeService.getById(id2); if(node1.getFlowProgramFileId() != null) { vo.setContent1(flowProgramFileService.getFileContent(node1.getFlowProgramFileId())); } if(node2.getFlowProgramFileId() != null) { vo.setContent2(flowProgramFileService.getFileContent(node2.getFlowProgramFileId())); } return R.data(vo); } }