package cn.stylefeng.guns.workflow.modular.controller; import cn.stylefeng.guns.base.auth.context.LoginContextHolder; import cn.stylefeng.guns.base.consts.ConstantsContext; import cn.stylefeng.guns.base.pojo.page.LayuiPageInfo; import cn.stylefeng.guns.sys.core.util.FileDownload; import cn.stylefeng.guns.workflow.modular.controller.base.ActBaseController; import cn.stylefeng.guns.workflow.core.util.FileZip; import cn.stylefeng.guns.workflow.core.util.PathUtil; import cn.stylefeng.guns.workflow.modular.model.params.ProcdefParam; import cn.stylefeng.guns.workflow.modular.service.ProcessService; import cn.stylefeng.guns.sys.modular.system.model.UploadResult; import cn.stylefeng.guns.sys.modular.system.service.FileInfoService; import cn.stylefeng.roses.core.util.ToolUtil; import cn.stylefeng.roses.kernel.model.exception.RequestEmptyException; import cn.stylefeng.roses.kernel.model.response.ResponseData; import cn.stylefeng.roses.kernel.model.response.SuccessResponseData; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestPart; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.Map; /** * 流程管理控制器 * * @author stylefeng * @Date 2019-08-11 21:59:38 */ @Controller @RequestMapping("/process") @Slf4j public class ProcessController extends ActBaseController { private String PREFIX = "/modular/act/process"; @Autowired private ProcessService processService; @Autowired private FileInfoService fileInfoService; /** * 跳转到主页面 * * @author stylefeng * @Date 2019-08-11 */ @RequestMapping("") public String index() { return PREFIX + "/process.html"; } /** * 导入流程 * * @author stylefeng * @Date 2019-08-11 */ @RequestMapping("/add") public String add() { return PREFIX + "/process_add.html"; } /** * 导入流程 * * @author stylefeng * @Date 2019-08-11 */ @RequestMapping("/addItem") @ResponseBody public ResponseData addItem(@RequestPart("file") MultipartFile file) { if (null != file && !file.isEmpty()) { //bpmn文件上传路径 String fileParentPath = ConstantsContext.getBpmnFileUploadPath(); //执行上传 UploadResult uploadResult = fileInfoService.uploadFile(file, fileParentPath); try { deploymentProcessDefinitionFromInputStream(uploadResult.getOriginalFilename(), uploadResult.getFileSavePath()); } catch (Exception e) { log.error("上传文件出错", e); return ResponseData.error("上传文件出错"); } } return ResponseData.success(); } /** * 删除接口 * * @author stylefeng * @Date 2019-08-11 */ @RequestMapping("/delete") @ResponseBody public ResponseData delete(ProcdefParam procdefParam) { try { super.deleteDeployment(procdefParam.getDeploymentId()); } catch (Exception e) { log.error("删除失败！", e); return ResponseData.error("删除失败！"); } return ResponseData.success(); } /** * 查询列表 * * @author stylefeng * @Date 2019-08-11 */ @ResponseBody @RequestMapping("/list") public LayuiPageInfo list(ProcdefParam procdefParam) { return this.processService.findPageBySpec(procdefParam); } /** * 打包下载xml和png * * @author fengshuonan * @Date 2019/8/12 21:37 */ @RequestMapping(value = "/download") public void download(HttpServletResponse response, String deploymentId) throws Exception { //生成XML和PNG createXmlAndPng(deploymentId); //生成的全部代码压缩成zip文件 if (FileZip.zip(PathUtil.getProjectpath() + "uploadFiles/activitiFile", PathUtil.getProjectpath() + "uploadFiles/activitiFile.zip")) { //下载代码 FileDownload.fileDownload(response, PathUtil.getProjectpath() + "uploadFiles/activitiFile.zip", "activitiFile.zip"); } } /** * 激活or挂起流程实例 * * @author fengshuonan * @Date 2019/8/12 21:41 */ @RequestMapping(value = "/onoffPro") @ResponseBody public ResponseData onoffProcessDefinition(@RequestParam("id") String id, @RequestParam("status") Integer status) throws Exception { //如果是挂起 if (status == 2) { //挂起前先把此流程的所有任务状态设置成激活状态 this.processService.onoffAllTask(id, 1); //挂起流程实例 suspendProcessDefinitionById(id); } else { //激活前先把此流程的所有任务状态设置成挂起状态 this.processService.onoffAllTask(id, 2); //激活流程实例 activateProcessDefinitionById(id); } return new SuccessResponseData(); } /** * 激活or挂起某个任务 * * @author fengshuonan * @Date 2019/8/27 10:52 */ @RequestMapping(value = "/onoffTask") @ResponseBody public ResponseData onoffTask(@RequestParam("id") String id, @RequestParam("status") Integer status) { if (ToolUtil.isEmpty(id) || ToolUtil.isEmpty(status)) { throw new RequestEmptyException("参数不能为空"); } this.processService.onoffTask(id, status); return ResponseData.success(); } /** * 委派 * * @author fengshuonan * @Date 2019/8/21 21:41 */ @RequestMapping(value = "/delegate") @ResponseBody public ResponseData delegate(@RequestParam("id") String id, @RequestParam("assignee") String assignee) { if (ToolUtil.isEmpty(id) || ToolUtil.isEmpty(assignee)) { throw new RequestEmptyException("id或assignee不能为空"); } Map zmap = new HashMap<>(); String errInfo = "success"; Map map = new LinkedHashMap<>(); //审批结果中记录委派 map.put("审批结果", " 任务由 [" + LoginContextHolder.getContext().getUser().getAccount() + "] 委派 "); //设置流程变量 setVariablesByTaskIdAsMap(id, map); setAssignee(id, assignee); //用于给待办人发送新任务消息 zmap.put("ASSIGNEE_", assignee); //返回结果 zmap.put("result", errInfo); return ResponseData.success(zmap); } /** * 作废流程 * * @author fengshuonan * @Date 2019/8/21 21:41 */ @RequestMapping(value = "/deleteAct") @ResponseBody public ResponseData delete(@RequestParam("procInstId") String procInstId, @RequestParam("reason") String dReason) { if (ToolUtil.isEmpty(procInstId)) { throw new RequestEmptyException("procInstId不能为空"); } Map map = new HashMap<>(); String errInfo = "success"; //作废原因 String reason = null; try { reason = "【作废】" + LoginContextHolder.getContext().getUser().getName() + "：" + URLDecoder.decode(dReason, "UTF-8"); } catch (UnsupportedEncodingException e) { log.error("作废失败，编码错误！", e); } //作废流程 deleteProcessInstance(procInstId, reason); map.put("result", errInfo); return ResponseData.success(map); } }