activiti7前端设计器bpmn-js整合shiro，mybatis-plus，使用maven构建的springboot项目

package com.bzgwl.mybatis_plus.web.controller; import com.bzgwl.mybatis_plus.sys.entity.User; import com.bzgwl.mybatis_plus.utils.JsonResponse; import com.bzgwl.mybatis_plus.utils.StringUtil; import com.bzgwl.mybatis_plus.web.activitiListeners.MyExecutionListener; import com.bzgwl.mybatis_plus.web.entity.QingjForm; import org.activiti.bpmn.model.*; import org.activiti.bpmn.model.Process; import org.activiti.engine.*; import org.activiti.engine.history.*; import org.activiti.engine.impl.identity.Authentication; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.runtime.Execution; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.apache.shiro.SecurityUtils; import org.apache.shiro.subject.Subject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.io.Resource; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.servlet.ModelAndView; import javax.servlet.http.HttpServletResponse; import java.io.FileInputStream; import java.io.InputStream; import java.net.URL; import java.util.*; import java.util.stream.Collectors; /** * @Author Professor_Kong * @Description * @Date 2019/11/20 */ @Controller @RequestMapping("web/act") @SuppressWarnings("all") public class ActivityController { @Autowired private RepositoryService repositoryService; @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; @Autowired private HistoryService historyService; @Autowired private MyExecutionListener myExecutionListener; /** * 新建工作 -页面跳转 * @return */ @RequestMapping("/index") public String index(){ return "act/act"; } @RequestMapping("/myApply") public String myApply(){ return "act/act-my-apply"; } @RequestMapping("/waiting") public String waiting(){ return "act/act-my-waiting"; } /** * 工作流 流程图 查看 * @return */ @RequestMapping("/view") public String view(){ return "act/act-view"; } /** * 工作流 流程图 个人流程查看 * @return */ @RequestMapping("/apply-my-view") public ModelAndView applyMyView(ModelAndView modelAndView,String instanceId){ modelAndView.setViewName("act/act-my-view"); modelAndView.addObject("instanceId",instanceId); return modelAndView; } /** * @param resp * @return */ @RequestMapping("/addIndex") public String addIndex(HttpServletResponse resp){ return "act/act-add"; } /** * 流程模板列表 * @param page * @param limit * @return */ @RequestMapping("/proDefList") @ResponseBody public JsonResponse modelList(Integer page , Integer limit){ JsonResponse jsonResponse = new JsonResponse(); long count = repositoryService.createProcessDefinitionQuery().count(); List<ProcessDefinition> processDefinitionList = repositoryService.createProcessDefinitionQuery() .latestVersion() .listPage(page-1,limit); List<Map<String,String>> list =processDefinitionList.stream().map( (s)-> { Map<String,String> map = new HashMap(); map.put("name", s.getName()); map.put("des", s.getDescription()); map.put("version", String.valueOf(s.getVersion())); map.put("key",s.getKey()); map.put("id",s.getId()); return map; }).collect(Collectors.toList()); jsonResponse.setCount(count); jsonResponse.setData(list); return jsonResponse; } /** * 我的待办 * @return */ @RequestMapping("/myWaitingToDo") @ResponseBody public JsonResponse getActList(Integer page , Integer limit){ JsonResponse jsonResponse = new JsonResponse(); User user = (User)SecurityUtils.getSubject().getPrincipal(); List<Task> taskList = taskService.createTaskQuery() .taskAssignee(user.getUsername()) .listPage(page-1,limit); long count = taskService.createTaskQuery() .taskAssignee(user.getUsername()).count(); List<Map<String,String>> list = new ArrayList<>(); String username =""; if(taskList!=null && taskList.size()!=0){ HistoricVariableInstance historicVariableInstance = historyService.createHistoricVariableInstanceQuery() .variableName("username").taskId(taskList.get(0).getId()).singleResult(); username = (String)historicVariableInstance.getValue(); } for(Task t : taskList){ Map map2 = new HashMap(); t.setDescription(username+"-请假申请单-"+t.getCreateTime()); map2.put("description",username+"-请假申请单-"+t.getCreateTime()); map2.put("name",t.getName()); map2.put("executionId",t.getExecutionId()); map2.put("status",t.getDelegationState()); map2.put("id",t.getId()); list.add(map2); } jsonResponse.setData(list); jsonResponse.setCount(count); return jsonResponse; } /** * 流程部署-- 导入方式 * @param file * @return * @throws Exception */ @RequestMapping("/importProcess") @ResponseBody public JsonResponse importProcess(@RequestParam("file") MultipartFile file) throws Exception{ JsonResponse jsonResponse = new JsonResponse(); Resource resource = file.getResource(); InputStream inputStream = resource.getInputStream(); try { Deployment deployment = repositoryService//获取流程定义和部署对象相关的Service .createDeployment()//创建部署对象 .name("请假流程-EL") .addInputStream("请假复杂流程-EL.bpmn", file.getInputStream()) .deploy();//完成部署 System.out.println("部署ID：" + deployment.getId());//1 System.out.println("部署Name：" + deployment.getName()); System.out.println("部署时间：" + deployment.getDeploymentTime()); }catch (Exception e){ e.printStackTrace(); } return jsonResponse; } /** * 一键删除 * @return */ @RequestMapping("/oneDel") @ResponseBody public JsonResponse oneDel(){ JsonResponse jsonResponse = new JsonResponse(); List<Deployment> list = repositoryService.createDeploymentQuery().list(); list.forEach(e ->{ repositoryService.deleteDeployment(e.getId(),true); }); return jsonResponse; } /** * 一键删除 * @return */ @RequestMapping("/batchDel") @ResponseBody public JsonResponse batchDel( @RequestParam(value = "ids[]")String[] ids){ JsonResponse jsonResponse = new JsonResponse(); jsonResponse.setMsg("未选择有效数据！"); if(ids == null){ return jsonResponse; } List<String> list = Arrays.asList(ids); list.forEach(e ->{ repositoryService.deleteDeployment(e,true); }); return jsonResponse; } @RequestMapping("/newProBefore") public String newProBefore(){ return "act/act-add-form"; } @RequestMapping("/addNewApply") @ResponseBody public JsonResponse addNewApply(QingjForm qingjForm){