/** * Copyright © 2015-2020 JeePlus All rights reserved. */ package com.jeeplus.modules.act.service; import java.io.InputStream; import java.util.*; import com.jeeplus.common.utils.SpringContextHolder; import com.jeeplus.common.websocket.service.system.SystemInfoSocketHandler; import com.jeeplus.modules.oa.entity.OaNotify; import com.jeeplus.modules.oa.entity.OaNotifyRecord; import com.jeeplus.modules.oa.service.OaNotifyService; import com.jeeplus.modules.sg.advence.activiti.entity.Advance; import com.jeeplus.modules.sg.advence.activiti.service.AdvanceService; import com.jeeplus.modules.sg.managementcenter.activiti.entity.Construction; import com.jeeplus.modules.sg.managementcenter.activiti.entity.Disclose; import com.jeeplus.modules.sg.managementcenter.activiti.entity.ProcessPersonnel; import com.jeeplus.modules.sg.managementcenter.activiti.service.ConstructionService; import com.jeeplus.modules.sg.managementcenter.activiti.service.DiscloseService; import com.jeeplus.modules.sg.managementcenter.activiti.service.ProcessPersonnelService; import com.jeeplus.modules.sg.managementcenter.activiti.utils.MyActiviUtils; import com.jeeplus.modules.sg.managementcenter.project.entity.Project; import com.jeeplus.modules.sg.materialmodule.activiti.entity.MaterialModule; import com.jeeplus.modules.sg.materialmodule.activiti.service.MaterialModuleService; import com.jeeplus.modules.sg.picking.activiti.entity.PickApplication; import com.jeeplus.modules.sg.picking.activiti.entity.ShowList; import com.jeeplus.modules.sg.picking.activiti.service.PickIngService; import com.jeeplus.modules.sg.picking.activiti.service.ShowListService; import org.activiti.bpmn.model.BpmnModel; import org.activiti.engine.FormService; import org.activiti.engine.HistoryService; import org.activiti.engine.IdentityService; import org.activiti.engine.RepositoryService; import org.activiti.engine.RuntimeService; import org.activiti.engine.TaskService; import org.activiti.engine.delegate.Expression; import org.activiti.engine.history.HistoricActivityInstance; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.history.HistoricProcessInstanceQuery; import org.activiti.engine.history.HistoricTaskInstance; import org.activiti.engine.history.HistoricTaskInstanceQuery; import org.activiti.engine.impl.RepositoryServiceImpl; import org.activiti.engine.impl.bpmn.behavior.UserTaskActivityBehavior; import org.activiti.engine.impl.context.Context; import org.activiti.engine.impl.javax.el.ExpressionFactory; import org.activiti.engine.impl.javax.el.ValueExpression; import org.activiti.engine.impl.juel.ExpressionFactoryImpl; import org.activiti.engine.impl.juel.SimpleContext; import org.activiti.engine.impl.persistence.entity.ExecutionEntity; import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity; import org.activiti.engine.impl.pvm.PvmActivity; import org.activiti.engine.impl.pvm.PvmTransition; import org.activiti.engine.impl.pvm.delegate.ActivityBehavior; import org.activiti.engine.impl.pvm.process.ActivityImpl; import org.activiti.engine.impl.task.TaskDefinition; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.repository.ProcessDefinitionQuery; import org.activiti.engine.runtime.Execution; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.runtime.ProcessInstanceQuery; import org.activiti.engine.task.Comment; import org.activiti.engine.task.Task; import org.activiti.engine.task.TaskQuery; import org.activiti.image.impl.DefaultProcessDiagramGenerator; import org.activiti.spring.ProcessEngineFactoryBean; import org.apache.commons.beanutils.PropertyUtils; import org.apache.commons.lang3.builder.ToStringBuilder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.jeeplus.common.utils.StringUtils; import com.jeeplus.core.persistence.Page; import com.jeeplus.core.service.BaseService; import com.jeeplus.modules.act.entity.Act; import com.jeeplus.modules.act.mapper.ActMapper; import com.jeeplus.modules.act.utils.ActUtils; import com.jeeplus.modules.act.utils.ProcessDefCache; import com.jeeplus.modules.sys.entity.User; import com.jeeplus.modules.sys.utils.UserUtils; import javax.servlet.ServletContext; /** * 流程定义相关Service * * @author jeeplus * @version 2016-11-03 */ @Service @Transactional(readOnly = true) public class ActTaskService extends BaseService { @Autowired private ActMapper actMapper; @Autowired private ProcessEngineFactoryBean processEngine; @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; @Autowired private FormService formService; @Autowired private HistoryService historyService; @Autowired private RepositoryService repositoryService; @Autowired private IdentityService identityService; @Autowired private ConstructionService constructionService; @Autowired private ShowListService showListService; @Autowired private MaterialModuleService materialModuleService; @Autowired private AdvanceService advanceService; @Autowired private OaNotifyService oaNotifyService; @Autowired private PickIngService pickIngService; /** * 获取待办任务列表 * * @return */ public Page> newTodoList(Page> page, Act act, String xmName) { List> result = new ArrayList>(); String userId = UserUtils.getUser().getLoginName();//ObjectUtils.toString(UserUtils.getUser().getId()); // =============== 已经签收的任务 =============== TaskQuery todoTaskQuery = taskService.createTaskQuery().taskAssignee(userId).active() .includeProcessVariables().orderByTaskCreateTime().desc(); // 设置查询条件 if (StringUtils.isNotBlank(act.getProcDefKey())) { todoTaskQuery.processDefinitionKey(act.getProcDefKey()); } //开始时间 if (act.getBeginDate() != null) { todoTaskQuery.taskCreatedAfter(act.getBeginDate()); } //结束时间 if (act.getEndDate() != null) { todoTaskQuery.taskCreatedBefore(act.getEndDate()); } if (!"".equals(xmName) && xmName != null) { List strings = constructionService.insIdByName(xmName); if (strings != null && strings.size() > 0) { todoTaskQuery.processInstanceIdIn(strings); } else { strings.add(""); todoTaskQuery.processInstanceIdIn(strings); } } // =============== 等待签收的任务 =============== TaskQuery toClaimQuery = taskService.createTaskQuery().taskCandidateUser(userId) .includeProcessVariables().active().orderByTaskCreateTime().desc(); // 设置查询条件 if (StringUtils.isNotBlank(act.getProcDefKey())) { toClaimQuery.processDefinitionKey(act.getProcDefKey()); } if (act.getBeginDate() != null) { toClaimQuery.taskCreatedAfter(act.getBeginDate()); } if (act.getEndDate() != null) { toClaimQuery.taskCreatedBefore(act.getEndDate()); } long taskCount = todoTaskQuery.count(); long claimCount = toClaimQuery.count(); long total = taskCount + claimCount; page.setCount(total); int start = page.getFirstResult(); int end = page.getFirstResult() + page.getMaxResults(); // 查询列表 List todoList = Lists.newArrayList(); // 查询列表 List toClaimList = Lists.newArrayList(); if (end == -1) {//不分页 todoList = todoTaskQuery.list(); toClaimList = toClaimQuery.list(); } else { if (end <= taskCount) { todoList = todoTaskQuery.listPage(start, page.getMaxResults()); } else if (start < taskCount) { todoList = todoTaskQuery.listPage(start, (int) taskCount - start); toClaimList = toClaimQuery.listPage(0, end - (int) taskCount); } else { toClaimList = toClaimQuery.listPage(start - (int) taskCount, page.getMaxResults()); } } for (Task task : todoList) { HashMap map = new HashMap(); map.put("task.assignee", task.getAssignee()); map.put("task.id", task.getId()); map.put("task.createTime", task.getCreateTime()); map.put("task.name", task.getName()); map.put("task.executionId", task.getExecutionId()); map.put("task.processDefinitionId", task.getProcessDefinitionId()); map.put("task.processInstanceId", task.getProcessInstanceId()); String s = constructionService.idProjectName(task.getProcessInstanceId()); String s2 = constructionService.idProjectName3(task.getProcessInstanceId()); String s1 = constructionService.idProjectName2(task.getProcessInstanceId()); if (!"".equals(s) && s != null) { map.put("task.projectName", s); } else if (!"".equals(s1) && s1 != null) { map.put("task.projectName", s1); } else if (!"".equals(s2) && s2 != null) { map.put("task.projectName", s2); } map.put("task.taskDefinitionKey", task.getTaskDefinitionKey()); map.put("vars", task.getProcessVariables()); map.put("procDef.name", ProcessDefCache.get(task.getProcessDefinitionId()).getName()); map.put("procDef.version", ProcessDefCache.get(task.getProcessDefinitionId()).getVersion()); map.put("status", "todo"); map.put("title", task.getProcessVariables().get("title")); page.getList().add(map); } for (Task task : toClaimList) { HashMap map = new HashMap(); map.put("task.assignee", task.getAssignee()); map.put("task.id", task.getId()); map.put("task.name", task.getName()); map.put("task.createTime", task.getCreateTime()); map.put("task.executionId", task.getExecutionId()); map.put("task.processInstanceId", task.getProcessInstanceId()); map.put("task.processDefinitionId", task.getProcessDefinitionId()); map.put("task.taskDefinitionKey", task.getTaskDefinitionKey()); map.put("vars", task.getProcessVariables()); map.put("procDef.name", ProcessDefCache.get(task.getProcessDefinitionId()).getName()); map.put("procDef.version", ProcessDefCache.get(task.getProcessDefinitionId()).getVersion()); map.put("status", "claim"); map.put("title", task.getProcessVariables().get("title")); page.getList().add(map); } return page; } /** * 获取待办任务列表（旧） * * @return */ public Page> todoList(Page> page, Act act) { List> result = new ArrayList>(); String userId = UserUtils.getUser().getLoginName();//ObjectUtils.toString(UserUtils.getUser().getId()); // =============== 已经签收的任务 =============== TaskQuery todoTaskQuery = taskService.createTaskQuery().taskAssignee(userId).active() .includeProcessVariables().orderByTaskCreateTime().desc(); // 设置查询条件 if (StringUtils.isNotBlank(act.getProcDefKey())) { todoTaskQuery.processDefinitionKey(act.getProcDefKey()); } if (act.getBeginDate() != null) { todoTaskQuery.taskCreatedAfter(act.getBeginDate()); } if (act.getEndDate() != null) { todoTaskQuery.taskCreatedBefore(act.getEndDate()); } // =============== 等待签收的任务 =============== TaskQuery toClaimQuery = taskService.createTaskQuery().taskCandidateUser(userId) .includeProcessVariables().active().orderByTaskCreateTime().desc(); // 设置查询条件 if (StringUtils.isNotBlank(act.getProcDefKey())) { toClaimQuery.processDefinitionKey(act.getProcDefKey()); } if (act.getBeginDate() != null) { toClaimQuery.taskCreatedAfter(act.getBeginDate()); } if (act.getEndDate() != null) { toClaimQuery.taskCreatedBefore(act.getEndDate()); } long taskCount = todoTaskQuery.count(); long claimCount = toClaimQuery.count(); long total = taskCount + claimCount; page.setCount(total); int start = page.getFirstResult(); int end = page.getFirstResult() + page.getMaxResults(); // 查询列表 List todoList = Lists.newArrayList(); // 查询列表 List toClaimList = Lists.newArrayList(); if (end == -1) {//不分页 todoList = todoTaskQuery.list(); toClaimList = toClaimQuery.list(); } else { if (end <= taskCount) { todoList = todoTaskQuery.listPage(start, page.getMaxResults()); } else if (start < taskCount) { todoList = todoTaskQuery.listPage(start, (int) taskCount - start); toClaimList = toClaimQuery.listPage(0, end - (int) taskCount); } else { toClaimList = toClaimQuery.listPage(start - (int) taskCount, page.getMaxResults()); } } for (Task task : todoList) { HashMap map = new HashMap(); map.put("task.assignee", task.getAssignee()); map.put("task.id", task.getId()); map.put("task.createTime", task.getCreateTime()); map.put("task.name", task.getName()); map.put("task.executionId", task.getExecutionId()); map.put("task.processDefinitionId", task.getProcessDefinitionId()); map.put("task.processInstanceId", task.getProcessInstanceId()); map.put("task.taskDefinitionKey", task.getTaskDefinitionKey()); map.put("vars", task.getProcessVariables()); map.put("procDef.name", ProcessDefCache.get(task.getProcessDefinitionId()).getName()); map.put("procDef.version", ProcessDefCache.get(task.getProcessDefinitionId()).getVersion()); map.put("status", "todo"); map.put("title", task.getProcessVariables().get("title")); page.getList().add(map); } for (Task task : toClaimList) { HashMap map = new HashMap(); map.put("task.assignee", task.getAssignee()); map.put("task.id", task.getId()); map.put("task.name", task.getName()); map.put("task.createTime", task.getCreateTime()); map.put("task.executionId", task.getExecutionId()); map.put("task.processInstanceId", task.getProcessInstanceId()); map.put("task.processDefinitionId", task.getProcessDefinitionId()); map.put("task.taskDefinitionKey", task.getTaskDefinitionKey()); map.put("vars", task.getProcessVariables()); map.put("procDef.name", ProcessDefCache.get(task.getProcessDefinitionId()).getName()); map.put("procDef.version", ProcessDefCache.get(task.getProcessDefinitionId()).getVersion()); map.put("status", "claim"); map.put("title", task.getProcessVariables().get("title")); page.getList().add(map); } return page; } /** * 获取已办任务列表 * * @param page * @return */ public Page> historicList(Page> page, Act act) { String userId = UserUtils.getUser().getLoginName();//ObjectUtils.toString(UserUtils.getUser().getId()); HistoricTaskInstanceQuery histTaskQuery = historyService.createHistoricTaskInstanceQuery().taskAssignee(userId).finished() .includeProcessVariables().orderByHistoricTaskInstanceEndTime().desc(); // 设置查询条件 if (StringUtils.isNotBlank(act.getProcDefKey())) { histTaskQuery.processDefinitionKey(act.getProcDefKey()); } if (act.getBeginDate() != null) { histTaskQuery.taskCompletedAfter(act.getBeginDate()); } if (act.getEndDate() != null) { histTaskQuery.taskCompletedBefore(act.getEndDate()); } // 查询总数 page.setCount(histTaskQuery.count()); page.initialize(); // 查询列表 List histList = Lists.newArrayList(); if (page.getMaxResults() == -1) { histList = histTaskQuery.list(); } else { histList = histTaskQuery.listPage(page.getFirstResult(), page.getMaxResults()); } for (HistoricTaskInstance histTask : histList) { Act e = new Act(); e.setHistTask(histTask); e.setVars(histTask.getProcessVariables()); // e.setTaskVars(histTask.getTaskLocalVariables()); // System.out.println(histTask.getId()+" = "+histTask.getProcessVariables() + " ========== " + histTask.getTaskLocalVariables()); e.setProcDef(ProcessDefCache.get(histTask.getProcessDefinitionId())); // e.setProcIns(runtimeService.createProcessInstanceQuery().processInstanceId(task.getProcessInstanceId()).singleResult()); // e.setProcExecUrl(ActUtils.getProcExeUrl(task.getProcessDefinitionId())); e.setStatus("finish"); HashMap map = new HashMap(); map.put("task.assignee", histTask.getAssignee()); map.put("task.id", histTask.getId()); map.put("task.name", histTask.getName()); map.put("task.endTime", histTask.getEndTime()); map.put("task.executionId", histTask.getExecutionId()); map.put("task.processInstanceId", histTask.getProcessInstanceId()); map.put("task.processDefinitionId", histTask.getProcessDefinitionId()); map.put("task.taskDefinitionKey", histTask.getTaskDefinitionKey()); map.put("vars", histTask.getProcessVariables()); map.put("procDef.name", ProcessDefCache.get(histTask.getProcessDefinitionId()).getName()); map.put("procDef.version", ProcessDefCache.get(histTask.getProcessDefinitionId()).getVersion()); try { map.put("status", queryProcessState(histTask.getProcessInstanceId())); } catch (Exception e1) { e1.printStackTrace(); } page.getList().add(map); } return page; } /** * 获取流转历史任务列表 * * @param procInsId 流程实例 * @param startAct 开始活动节点名称 * @param endAct 结束活动节点名称 */ public List histoicFlowList(String procInsId, String startAct, String endAct) { List actList = Lists.newArrayList(); List list = Lists.newArrayList(); List historicActivityInstances2 = historyService.createHistoricActivityInstanceQuery().processInstanceId(procInsId) .orderByHistoricActivityInstanceStartTime().asc().orderByHistoricActivityInstanceEndTime().asc().list(); ; for (HistoricActivityInstance historicActivityInstance : historicActivityInstances2) { if (historicActivityInstance.getEndTime() != null) { list.add(historicActivityInstance); } } for (HistoricActivityInstance historicActivityInstance : historicActivityInstances2) { if (historicActivityInstance.getEndTime() == null) { list.add(historicActivityInstance); } } boolean start = false; Map actMap = Maps.newHashMap(); for (int i = 0; i < list.size(); i++) { HistoricActivityInstance histIns = list.get(i); // 过滤开始节点前的节点 if (StringUtils.isNotBlank(startAct) && startAct.equals(histIns.getActivityId())) { start = true; } if (StringUtils.isNotBlank(startAct) && !start) { continue; } // 只显示开始节点和结束节点，并且执行人不为空的任务 if (StringUtils.isNotBlank(histIns.getAssignee()) || "startEvent".equals(histIns.getActivityType()) || "endEvent".equals(histIns.getActivityType())) { // 给节点增加一个序号 Integer actNum = actMap.get(histIns.getActivityId()); if (actNum == null) { actMap.put(histIns.getActivityId(), actMap.size()); } Act e = new Act(); e.setHistIns(histIns); // 获取流程发起人名称 if ("startEvent".equals(histIns.getActivityType())) { List il = historyService.createHistoricProcessInstanceQuery().processInstanceId(procInsId).orderByProcessInstanceStartTime().asc().list(); // List il = historyService.getHistoricIdentityLinksForProcessInstance(procInsId); if (il.size() > 0) { if (StringUtils.isNotBlank(il.get(0).getStartUserId())) { User user = UserUtils.getByLoginName(il.get(0).getStartUserId()); if (user != null) { e.setAssignee(histIns.getAssignee()); e.setAssigneeName(user.getName()); } } } } // 获取任务执行人名称 if (StringUtils.isNotEmpty(histIns.getAssignee())) { User user = UserUtils.getByLoginName(histIns.getAssignee()); if (user != null) { e.setAssignee(histIns.getAssignee()); e.setAssigneeName(user.getName()); } } // 获取意见评论内容 if (StringUtils.isNotBlank(histIns.getTaskId())) { List commentList = taskService.getTaskComments(histIns.getTaskId()); if (commentList.size() > 0) { e.setComment(commentList.get(0).getFullMessage()); } } actList.add(e); } // 过滤结束节点后的节点 if (StringUtils.isNotBlank(endAct) && endAct.equals(histIns.getActivityId())) { boolean bl = false; Integer actNum = actMap.get(histIns.getActivityId()); // 该活动节点，后续节点是否在结束节点之前，在后续节点中是否存在 for (int j = i + 1; j < list.size(); j++) { HistoricActivityInstance hi = list.get(j); Integer actNumA = actMap.get(hi.getActivityId()); if ((actNumA != null && actNumA < actNum) || StringUtils.equals(hi.getActivityId(), histIns.getActivityId())) { bl = true; } } if (!bl) { break; } } } return actList; } /** * 获取流程定义列表 * * @param category 流程分类 */ public Page processList(Page page, String category) { /* * 保存两个对象，一个是ProcessDefinition（流程定义），一个是Deployment（流程部署） */ ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery() .latestVersion().active().orderByProcessDefinitionKey().asc(); if (StringUtils.isNotEmpty(category)) { processDefinitionQuery.processDefinitionCategory(category); } page.setCount(processDefinitionQuery.count()); List processDefinitionList = Lists.newArrayList(); if (page.getMaxResults() == -1) {//不分页 processDefinitionList = processDefinitionQuery.list(); } else { processDefinitionList = processDefinitionQuery.listPage(page.getFirstResult(), page.getMaxResults()); } for (ProcessDefinition processDefinition : processDefinitionList) { String deploymentId = processDefinition.getDeploymentId(); Deployment deployment = repositoryService.createDeploymentQuery().deploymentId(deploymentId).singleResult(); page.getList().add(new Object[]{processDefinition, deployment}); } return page; } /** * 获取流程表单（首先获取任务节点表单KEY，如果没有则取流程开始节点表单KEY） * * @return */ public String getFormKey(String procDefId, String taskDefKey) { String formKey = ""; if (StringUtils.isNotBlank(procDefId)) { if (StringUtils.isNotBlank(taskDefKey)) { try { formKey = formService.getTaskFormKey(procDefId, taskDefKey); } catch (Exception e) { formKey = ""; } } if (StringUtils.isBlank(formKey)) { formKey = formService.getStartFormKey(procDefId); } if (StringUtils.isBlank(formKey)) { formKey = "/404"; } } logger.debug("getFormKey: {}", formKey); return formKey; } /** * 获取正在运行的流程实例对象 * * @param procInsId * @return */ @Transactional(readOnly = false) public ProcessInstance getProcIns(String procInsId) { return runtimeService.createProcessInstanceQuery().processInstanceId(procInsId).singleResult(); } /** * 获取已经结束流程实例对象 * * @param procInsId * @return */ @Transactional(readOnly = false) public HistoricProcessInstance getFinishedProcIns(String procInsId) { return historyService.createHistoricProcessInstanceQuery().processInstanceId(procInsId).singleResult(); } /** * 获取正在运行的流程实例对象列表 * * @param procDefKey * @return */ @Transactional(readOnly = false) public List getRunngingProcIns(String procDefKey, User user, int[] pageParams) { ProcessInstanceQuery query = runtimeService.createProcessInstanceQuery().processDefinitionKey(procDefKey).active().orderByProcessInstanceId().desc(); List list = new ArrayList(); if (User.isAdmin(user.getId())) { list = query.listPage(pageParams[0], pageParams[1]); } else { list = query.involvedUser(user.getLoginName()).listPage(pageParams[0], pageParams[1]); } return list; } /** * 获取已经结束的流程实例对象列表 * * @param procDefKey * @return */ @Transactional(readOnly = false) public List getFinishedProcIns(String procDefKey, User user, int[] pageParams) { HistoricProcessInstanceQuery query = historyService.createHistoricProcessInstanceQuery().processDefinitionKey(procDefKey).finished().orderByProcessInstanceEndTime().desc(); List list = new ArrayList(); if (User.isAdmin(user.getId())) { list = query.listPage(pageParams[0], pageParams[1]); } else { list = query.involvedUser(user.getLoginName()).listPage(pageParams[0], pageParams[1]); } return list; } /** * 获取我发起的流程申请列表 * * @param user * @return */ @Transactional(readOnly = false) public Page getMyStartedProcIns(User user, Page page) throws Exception { HistoricProcessInstanceQuery query = historyService.createHistoricProcessInstanceQuery().startedBy(user.getLoginName()).includeProcessVariables().orderByProcessInstanceStartTime().desc(); page.setCount(query.count()); List histList = Lists.newArrayList(); if (page.getMaxResults() == -1) {//不分页 histList = query.list(); } else { histList = query.involvedUser(user.getLoginName()).listPage(page.getFirstResult(), page.getMaxResults()); } for (HistoricProcessInstance historicProcessInstance : histList) { HashMap map = new HashMap(); // p.getActivityId()); // map.put("suspended", String.valueOf(p.isSuspended())); // historicProcessInstance. String state = queryProcessState(historicProcessInstance.getId()); map.put("procIns.endTime", historicProcessInstance.getEndTime()); map.put("procIns.startTime", historicProcessInstance.getStartTime()); map.put("procIns.processInstanceId", historicProcessInstance.getId()); map.put("procDef.processDefinitionId", historicProcessInstance.getProcessDefinitionId()); map.put("vars", historicProcessInstance.getProcessVariables()); map.put("procDef.name", historicProcessInstance.getProcessDefinitionName()); map.put("procDef.version", historicProcessInstance.getProcessDefinitionVersion()); map.put("procIns.status", state); page.getList().add(map); } return page; } /** * 启动流程 * * @param procDefKey 流程定义KEY * @param businessTable 业务表表名 * @param businessId 业务表编号 * @return 流程实例ID */ @Transactional(readOnly = false) public String startProcess(String procDefKey, String businessTable, String businessId) { return startProcess(procDefKey, businessTable, businessId, ""); } /** * 启动流程 * * @param procDefKey 流程定义KEY * @param businessTable 业务表表名 * @param businessId 业务表编号 * @param title 流程标题，显示在待办任务标题 * @return 流程实例ID */ @Transactional(readOnly = false) public String startProcess(String procDefKey, String businessTable, String businessId, String title) { Map vars = Maps.newHashMap(); return startProcess(procDefKey, businessTable, businessId, title, vars); } /** * 启动流程 * * @param procDefKey 流程定义KEY * @param businessTable 业务表表名 * @param businessId 业务表编号 * @param title 流程标题，显示在待办任务标题 * @param vars 流程变量 * @return 流程实例ID */ @SuppressWarnings("unused") @Transactional(readOnly = false) public String startProcess(String procDefKey, String businessTable, String businessId, String title, Map vars) { //String userId = UserUtils.getUser().getLoginName();//ObjectUtils.toString(UserUtils.getUser().getId()) // 设置流程变量 if (vars == null) { vars = Maps.newHashMap(); } String userId = (String) vars.get("applyUserId"); if (userId == null) { userId = UserUtils.getUser().getLoginName(); } String userName = UserUtils.getByLoginName(userId).getName(); vars.put("userName", userName); // 用来设置启动流程的人员ID，引擎会自动把用户ID保存到activiti:initiator中 identityService.setAuthenticatedUserId(userId); // 设置流程标题 if (StringUtils.isNotBlank(title)) { vars.put("title", title); } // 启动流程 ProcessInstance procIns = runtimeService.startProcessInstanceByKey(procDefKey, businessTable + ":" + businessId, vars); // 更新业务表流程实例ID Act act = new Act(); act.setBusinessTable(businessTable);// 业务表名 act.setBusinessId(businessId); // 业务表ID act.setProcInsId(procIns.getId()); act.setVars(vars); actMapper.updateProcInsIdByBusinessId(act); return act.getProcInsId(); } /** * 新启动流程 * * @param procDefKey 流程定义KEY * @param businessTable 业务表表名 * @param businessId 业务表编号 * @param title 流程标题，显示在待办任务标题 * @param vars 流程变量 * @return 流程实例ID */ @SuppressWarnings("unused") @Transactional(readOnly = false) public String startProcessNew(String procDefKey, String businessTable, String businessId, String title, Map vars) { //String userId = UserUtils.getUser().getLoginName();//ObjectUtils.toString(UserUtils.getUser().getId()) // 设置流程变量 if (vars == null) { vars = Maps.newHashMap(); } String userId = (String) vars.get("applyUserId"); if (userId == null) { userId = UserUtils.getUser().getLoginName(); } String userName = UserUtils.getByLoginName(userId).getName(); vars.put("userName", userName); String processer = (String) vars.get("processer"); if (processer != null) { vars.put("processer", processer); } // 用来设置启动流程的人员ID，引擎会自动把用户ID保存到activiti:initiator中 identityService.setAuthenticatedUserId(userId); // 设置流程标题 if (StringUtils.isNotBlank(title)) { vars.put("title", title); } // 启动流程 ProcessInstance procIns = runtimeService.startProcessInstanceByKey(procDefKey, businessTable + ":" + businessId, vars); // 更新业务表流程实例ID Act act = new Act(); act.setBusinessTable(businessTable);// 业务表名 act.setBusinessId(businessId); // 业务表ID act.setProcInsId(procIns.getId()); act.setVars(vars); actMapper.updateProcInsIdByBusinessId(act); return act.getProcInsId(); } /** * 获取任务 * * @param taskId 任务ID */ public Task getTask(String taskId) { return taskService.createTaskQuery().taskId(taskId).singleResult(); } /** * 删除任务 * * @param taskId 任务ID * @param deleteReason 删除原因 */ public void deleteTask(String taskId, String deleteReason) { taskService.deleteTask(taskId, deleteReason); } /** * 签收任务 * * @param taskId 任务ID * @param userId 签收用户ID（用户登录名） */ @Transactional(readOnly = false) public void claim(String taskId, String userId) { taskService.claim(taskId, userId); } /** * 提交任务, 并保存意见 * * @param taskId 任务ID * @param procInsId 流程实例ID，如果为空，则不保存任务提交意见 * @param comment 任务提交意见的内容 * @param vars 任务变量 */ @Transactional(readOnly = false) public void complete(String taskId, String procInsId, String comment, Map vars) { complete(taskId, procInsId, comment, "", vars); } /** * 提交任务, 并保存意见 * * @param taskId 任务ID * @param procInsId 流程实例ID，如果为空，则不保存任务提交意见 * @param comment 任务提交意见的内容 * @param title 流程标题，显示在待办任务标题 * @param vars 任务变量 */ @Transactional(readOnly = false) public void complete(String taskId, String procInsId, String comment, String title, Map vars) { // 添加意见 if (StringUtils.isNotBlank(procInsId) && StringUtils.isNotBlank(comment)) { taskService.addComment(taskId, procInsId, comment); } // 设置流程变量 if (vars == null) { vars = Maps.newHashMap(); } // 设置流程标题 if (StringUtils.isNotBlank(title)) { vars.put("title", title); } // 提交任务 taskService.complete(taskId, vars); } /** * 完成第一个任务 * * @param procInsId */ public void completeFirstTask(String procInsId) { completeFirstTask(procInsId, null, null, null); } /** * 完成第一个任务 * * @param procInsId * @param comment * @param title * @param vars */ public void completeFirstTask(String procInsId, String comment, String title, Map vars) { String userId = UserUtils.getUser().getLoginName(); Task task = taskService.createTaskQuery().taskAssignee(userId).processInstanceId(procInsId).active().singleResult(); if (task != null) { complete(task.getId(), procInsId, comment, title, vars); } } /** * 查询流程实例状态 * * @param processInstanceId * @return * @throws Exception */ public String queryProcessState(String processInstanceId) throws Exception { // 通过流程实例ID查询流程实例 ProcessInstance pi = runtimeService.createProcessInstanceQuery() .processInstanceId(processInstanceId).singleResult(); if (pi != null) { if (pi.isSuspended()) { //执行实例 return "[已挂起]"; } else { //执行实例 List tasks = taskService.createTaskQuery().processInstanceId(pi.getId()).active().orderByTaskCreateTime().desc().listPage(0, 1); return "[进行中] :" + tasks.get(0).getName(); } } else { HistoricProcessInstance pi2 = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); if (pi2 != null) { if (pi2.getDeleteReason() == null) { return "[正常结束]"; } else if (pi2.getDeleteReason().equals("用户撤销")) { return "[用户撤销]"; } else { return "[流程作废] :" + pi2.getDeleteReason(); } } else { return "[已删除]"; } } } /** * 终止流程实例 * * @param processInstanceId */ public void endProcessInstance(String processInstanceId, String deleteReason) throws Exception { runtimeService.deleteProcessInstance(processInstanceId, deleteReason); } // /** // * 委派任务 // * @param taskId 任务ID // * @param userId 被委派人 // */ // public void delegateTask(String taskId, String userId){ // taskService.delegateTask(taskId, userId); // } // // /** // * 被委派人完成任务 // * @param taskId 任务ID // */ // public void resolveTask(String taskId){ // taskService.resolveTask(taskId); // } // // /** // * 回退任务 // * @param taskId // */ // public void backTask(String taskId){ // taskService. // } //////////////////////////////////////////////////////////////////// /** * 读取带跟踪的图片 * * @param executionId 环节ID * @return 封装了各种节点信息 */ public InputStream tracePhoto(String processDefinitionId, String executionId) { // ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(executionId).singleResult(); BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId); List activeActivityIds = Lists.newArrayList(); if (runtimeService.createExecutionQuery().executionId(executionId).count() > 0) { activeActivityIds = runtimeService.getActiveActivityIds(executionId); } List highLightedFlows = Lists.newArrayList(); // 获得历史活动记录实体（通过启动时间正序排序，不然有的线可以绘制不出来） List historicActivityInstances = Lists.newArrayList(); List historicActivityInstances2 = historyService .createHistoricActivityInstanceQuery().executionId(executionId).orderByHistoricActivityInstanceStartTime().asc().orderByHistoricActivityInstanceEndTime().asc().list(); for (HistoricActivityInstance historicActivityInstance : historicActivityInstances2) { if (historicActivityInstance.getEndTime() != null) { historicActivityInstances.add(historicActivityInstance); } } for (HistoricActivityInstance historicActivityInstance : historicActivityInstances2) { if (historicActivityInstance.getEndTime() == null) { historicActivityInstances.add(historicActivityInstance); } } List highLightedActivities = Lists.newArrayList(); for (HistoricActivityInstance historicActivityInstance : historicActivityInstances) { highLightedActivities.add(historicActivityInstance.getActivityId()); } // 计算活动线 highLightedFlows = this.getHighLightedFlows((ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService) .getDeployedProcessDefinition(processDefinitionId), historicActivityInstances); // 不使用spring请使用下面的两行代码 // ProcessEngineImpl defaultProcessEngine = (ProcessEngineImpl)ProcessEngines.getDefaultProcessEngine(); // Context.setProcessEngineConfiguration(defaultProcessEngine.getProcessEngineConfiguration()); // 使用spring注入引擎请使用下面的这行代码 Context.setProcessEngineConfiguration(processEngine.getProcessEngineConfiguration()); DefaultProcessDiagramGenerator processDiagramGeneratornew = new DefaultProcessDiagramGenerator(); //return processDiagramGeneratornew.generateDiagram(bpmnModel, "png", activeActivityIds); return processDiagramGeneratornew.generateDiagram(bpmnModel, "png", highLightedActivities, highLightedFlows, processEngine.getProcessEngineConfiguration().getActivityFontName(), processEngine.getProcessEngineConfiguration().getLabelFontName(), executionId, processEngine.getProcessEngineConfiguration().getClassLoader(), 1.0); } /** * 获得高亮线 * * @param processDefinitionEntity 流程定义实体 * @param historicActivityInstances 历史活动实体 * @return 线ID集合 */ public List getHighLightedFlows(ProcessDefinitionEntity processDefinitionEntity, List historicActivityInstances) { List highFlows = new ArrayList();// 用以保存高亮的线flowId for (int i = 0; i < historicActivityInstances.size(); i++) {// 对历史流程节点进行遍历 ActivityImpl activityImpl1 = processDefinitionEntity .findActivity(historicActivityInstances.get(i) .getActivityId());// 得到节点定义的详细信息 List sameStartTimeNodes = new ArrayList();// 用以保存后需开始时间相同的节点 HistoricActivityInstance historicActivityInstance1 = historicActivityInstances .get(i);// 后续第一个节点 for (int j = 0; j < historicActivityInstances.size(); j++) { if (i == j) { continue; } HistoricActivityInstance historicActivityInstance2 = historicActivityInstances .get(j);// 后续第一个节点 if (historicActivityInstance1.getEndTime() != null && historicActivityInstance1.getEndTime().equals( historicActivityInstance2.getStartTime())) { // 如果第一个节点的结束时间和第二个节点开始时间相同保存 ActivityImpl sameActivityImpl2 = processDefinitionEntity .findActivity(historicActivityInstance2.getActivityId()); sameStartTimeNodes.add(sameActivityImpl2); } } List pvmTransitions = activityImpl1 .getOutgoingTransitions();// 取出节点的所有出去的线 for (PvmTransition pvmTransition : pvmTransitions) { // 对所有的线进行遍历 ActivityImpl pvmActivityImpl = (ActivityImpl) pvmTransition .getDestination(); // 如果取出的线的目标节点存在时间相同的节点里，保存该线的id，进行高亮显示 if (sameStartTimeNodes.contains(pvmActivityImpl)) { highFlows.add(pvmTransition.getId()); } } } return highFlows; } /** * 流程跟踪图信息 * * @param processInstanceId 流程实例ID * @return 封装了各种节点信息 */ public List> traceProcess(String processInstanceId) throws Exception { Execution execution = runtimeService.createExecutionQuery().executionId(processInstanceId).singleResult();//执行实例 Object property = PropertyUtils.getProperty(execution, "activityId"); String activityId = ""; if (property != null) { activityId = property.toString(); } ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId) .singleResult(); ProcessDefinitionEntity processDefinition = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService) .getDeployedProcessDefinition(processInstance.getProcessDefinitionId()); List activitiList = processDefinition.getActivities();//获得当前任务的所有节点 List> activityInfos = new ArrayList>(); for (ActivityImpl activity : activitiList) { boolean currentActiviti = false; String id = activity.getId(); // 当前节点 if (id.equals(activityId)) { currentActiviti = true; } Map activityImageInfo = packageSingleActivitiInfo(activity, processInstance, currentActiviti); activityInfos.add(activityImageInfo); } return activityInfos; } /** * 封装输出信息，包括：当前节点的X、Y坐标、变量信息、任务类型、任务描述 * * @param activity * @param processInstance * @param currentActiviti * @return */ private Map packageSingleActivitiInfo(ActivityImpl activity, ProcessInstance processInstance, boolean currentActiviti) throws Exception { Map vars = new HashMap(); Map activityInfo = new HashMap(); activityInfo.put("currentActiviti", currentActiviti); setPosition(activity, activityInfo); setWidthAndHeight(activity, activityInfo); Map properties = activity.getProperties(); vars.put("节点名称", properties.get("name")); vars.put("任务类型", ActUtils.parseToZhType(properties.get("type").toString())); ActivityBehavior activityBehavior = activity.getActivityBehavior(); logger.debug("activityBehavior={}", activityBehavior); if (activityBehavior instanceof UserTaskActivityBehavior) { Task currentTask = null; // 当前节点的task if (currentActiviti) { currentTask = getCurrentTaskInfo(processInstance); } // 当前任务的分配角色 UserTaskActivityBehavior userTaskActivityBehavior = (UserTaskActivityBehavior) activityBehavior; TaskDefinition taskDefinition = userTaskActivityBehavior.getTaskDefinition(); Set candidateGroupIdExpressions = taskDefinition.getCandidateGroupIdExpressions(); if (!candidateGroupIdExpressions.isEmpty()) { // 任务的处理角色 setTaskGroup(vars, candidateGroupIdExpressions); // 当前处理人 if (currentTask != null) { setCurrentTaskAssignee(vars, currentTask); } } } vars.put("节点说明", properties.get("documentation")); String description = activity.getProcessDefinition().getDescription(); vars.put("描述", description); logger.debug("trace variables: {}", vars); activityInfo.put("vars", vars); return activityInfo; } /** * 设置任务组 * * @param vars * @param candidateGroupIdExpressions */ private void setTaskGroup(Map vars, Set candidateGroupIdExpressions) { String roles = ""; for (Expression expression : candidateGroupIdExpressions) { String expressionText = expression.getExpressionText(); String roleName = identityService.createGroupQuery().groupId(expressionText).singleResult().getName(); roles += roleName; } vars.put("任务所属角色", roles); } /** * 设置当前处理人信息 * * @param vars * @param currentTask */ private void setCurrentTaskAssignee(Map vars, Task currentTask) { String assignee = currentTask.getAssignee(); if (assignee != null) { org.activiti.engine.identity.User assigneeUser = identityService.createUserQuery().userId(assignee).singleResult(); String userInfo = assigneeUser.getFirstName() + " " + assigneeUser.getLastName(); vars.put("当前处理人", userInfo); } } /** * 获取当前节点信息 * * @param processInstance * @return */ private Task getCurrentTaskInfo(ProcessInstance processInstance) { Task currentTask = null; try { String activitiId = (String) PropertyUtils.getProperty(processInstance, "activityId"); logger.debug("current activity id: {}", activitiId); currentTask = taskService.createTaskQuery().processInstanceId(processInstance.getId()).taskDefinitionKey(activitiId) .singleResult(); logger.debug("current task for processInstance: {}", ToStringBuilder.reflectionToString(currentTask)); } catch (Exception e) { logger.error("can not get property activityId from processInstance: {}", processInstance); } return currentTask; } /** * 设置宽度、高度属性 * * @param activity * @param activityInfo */ private void setWidthAndHeight(ActivityImpl activity, Map activityInfo) { activityInfo.put("width", activity.getWidth()); activityInfo.put("height", activity.getHeight()); } /** * 设置坐标位置 * * @param activity * @param activityInfo */ private void setPosition(ActivityImpl activity, Map activityInfo) { activityInfo.put("x", activity.getX()); activityInfo.put("y", activity.getY()); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void auditSave(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 经研所保存审核意见 * * @param act */ @Transactional(readOnly = false) public void economics(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { act.setComment("[同意] " + act.getComment()); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } else { act.setComment("[驳回] " + act.getComment()); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工保存审核意见 * * @param act */ @Transactional(readOnly = false) public void auditSave2(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[存在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("processer", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 人工选择问题类型审批 * * @param act */ @Transactional(readOnly = false) public void artificialTask(Act act) { /* * pass1 = 设计变更 * pass2 = 项目关闭 * pass3 = 政策处理（城区道路） * pass4 = 驳回施工单位 * pass5 = 政策处理（农场/民事） * */ boolean pass1 = false; boolean pass2 = false; boolean pass3 = false; boolean pass4 = false; boolean pass5 = false; boolean pass6 = false; Map vars = Maps.newHashMap(); //pass对应进入问题模块，pass4对应没有问题完成施工交底 vars.put("pass", false); vars.put("pass1", false); vars.put("pass2", false); vars.put("pass4", false); vars.put("pass3", false); vars.put("pass5", false); vars.put("pass6", false); vars.put("countryside", false); String flag = act.getFlag(); String[] split = flag.split(";"); for (String a : split) { if ("pass1".equals(a)) { pass1 = true; } else if ("pass2".equals(a)) { pass2 = true; } else if ("pass3".equals(a)) { pass3 = true; } else if ("pass4".equals(a)) { pass4 = true; } else if ("pass5".equals(a)) { pass5 = true; } else if ("pass6".equals(a)) { pass6 = true; } } if (pass4 == true) { act.setComment("[完成施工交底]" + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("processer", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); vars.put("pass4", true); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); if (pass1 == true) { vars.put("pass1", true); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } if (pass2 == true) { vars.put("pass2", true); vars.put("itemClose", UserUtils.getByUserName(user.getDistributionEngineering()).getLoginName()); } if (pass3 == true) { vars.put("pass3", true); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); } if (pass5 == true) { vars.put("pass5", true); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); } if (pass6 == true) { vars.put("countryside", true); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); } vars.put("problem", true); act.setComment("[存在问题]" + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目经理人工审核问题 * * @param act */ @Transactional(readOnly = false) public void humanReviewTask(Act act) { /* * pass1 = 设计变更 * pass2 = 项目关闭 * pass3 = 政策处理（城区道路） * pass4 = 驳回施工单位 * pass5 = 政策处理（农场/民事） * pass7 = 无问题 * */ boolean pass1 = false;//设计变更 boolean pass2 = false;//项目关闭 boolean pass3 = false;//行政证处 boolean pass5 = false;//农村证处 boolean pass7 = false;//无问题 boolean countryside = false;//民事行政 Map vars = Maps.newHashMap(); //pass对应进入问题模块，pass4对应没有问题完成施工交底 vars.put("pass", false); vars.put("pass1", false); vars.put("pass2", false); vars.put("pass3", false); vars.put("pass5", false); vars.put("countryside", false);//性质民事 String flag = act.getFlag(); String[] split = flag.split(";"); for (String a : split) { if ("pass1".equals(a)) { pass1 = true; } else if ("pass2".equals(a)) { pass2 = true; } else if ("pass3".equals(a)) { pass3 = true; } else if ("pass5".equals(a)) { pass5 = true; } else if ("pass6".equals(a)) { countryside = true; } else if ("pass7".equals(a)) { pass7 = true; } } if (pass7) { vars.put("pass", true); act.setComment("[完成施工交底]" + act.getComment()); } else { if (pass1) { vars.put("pass1", true); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } if (pass2) { vars.put("pass2", true); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("itemClose", UserUtils.getByUserName(user.getDistributionEngineering()).getLoginName());//配网工程专职角色 } if (pass3) { vars.put("pass3", true); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName());//施工单位角色 } if (pass5) { vars.put("pass5", true); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName());//配网政策处理专职角色 } if (countryside) { vars.put("countryside", true); Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName());//配网政策处理专职角色 } } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目经理人工审核问题 * * @param act */ @Transactional(readOnly = false) public void divideForm(Act act) { /* * pass1 = 政策处理（城区道路） * pass2 = * pass5 = 农村 * */ boolean design = false; boolean close = false; boolean pass3 = false; boolean pass5 = false; boolean pass6 = false; boolean finish = false; Map vars = Maps.newHashMap(); //完成施工交底 vars.put("pass", false); //人工判断设计变更 vars.put("pass1", false); //项目关闭 vars.put("pass2", false); //行政政处 vars.put("pass3", false); //前置条件，人工判断 vars.put("pass4", false); //农村政处 vars.put("pass5", false); //通过页面修改施工交底 vars.put("self", true); //没有前置条件，人工审核 vars.put("problem", false); //(民事/行政) vars.put("countryside", false); //没有问题 vars.put("finish", false); String flag = act.getFlag(); String[] split = flag.split(";"); for (String a : split) { if ("pass1".equals(a)) { design = true;//设计变更 } else if ("pass2".equals(a)) { //项目关闭 close = true; } else if ("pass3".equals(a)) {//行政政处（城区道路） pass3 = true; } else if ("pass5".equals(a)) { pass5 = true;//农村政处 } else if ("pass6".equals(a)) { pass6 = true;//民事政处/行政政处 } else if ("pass8".equals(a)) { //没有问题 finish = true; } } if (finish) { //没有问题，完成交底 act.setComment("[完成施工交底]" + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); vars.put("finish", true); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); if (close) { //项目关闭 vars.put("pass2", true); vars.put("itemClose", UserUtils.getByUserName(user.getDistributionEngineering()).getLoginName()); } else { act.setComment("[存在问题]" + act.getComment()); if (design) { //设计变更 vars.put("pass1", true); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } if (pass3) { //政策处理（城区道路） vars.put("pass3", true); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); } if (pass5) { //农村 vars.put("pass5", true); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); } if (pass6) { //民事政处/行政政处 vars.put("countryside", true); vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); } } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } } /** * 配网运行人员设计变更页面 * * @param act */ @Transactional(readOnly = false) public void operator(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("jys", false); vars.put("des", false); vars.put("manager", false); //获取流程id String procInsId = act.getProcInsId(); Project user = MyActiviUtils.findUser(procInsId); if ("yes".equals(flag)) { //查询需求提出单位 String demandUnit = user.getDemandUnit(); if ("经研所".equals(demandUnit)) { vars.put("design", UserUtils.getByUserName(user.getThroughResearchRole()).getLoginName()); vars.put("jys", true); } else { vars.put("design", UserUtils.getByUserName(user.getDesignUnitManage()).getLoginName()); vars.put("des", true); } } else { vars.put("manager", true); vars.put("design", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目经理判定是否需要设计变更 * * @param act */ @Transactional(readOnly = false) public void managerDesign(Act act) { Map vars = Maps.newHashMap(); Project user = MyActiviUtils.findUser(act.getProcInsId()); String flag = act.getFlag(); if ("yes".equals(flag)) { vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } else { } vars.put("pass", "yes".equals(act.getFlag()) ? true : false); // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 设计单位人员提交文件 * * @param act */ @Transactional(readOnly = false) public void designUpload(Act act) { Map vars = Maps.newHashMap(); Project user = MyActiviUtils.findUser(act.getProcInsId()); //根据登陆查询所属的角色 vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网运行人员判断变更后材料 * * @param act */ @Transactional(readOnly = false) public void operatorUpload(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("design", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } else { vars.put("design", UserUtils.getByUserName(user.getDesignUnitManage()).getLoginName()); } //根据登陆查询所属的角色 vars.put("pass", "yes".equals(flag) ? true : false); // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网项目经理判断变更后材料 * * @param act */ @Transactional(readOnly = false) public void managerUpload(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); //发给施工单位人员审核 if ("yes".equals(flag)) { User byUserName = UserUtils.getByUserName(user.getConstructionUnitRole()); String s = constructionService.idProjectName(act.getProcInsId()); OaNotify oaNotify = new OaNotify(); oaNotify.setType("8"); oaNotify.setTitle(s + "设计变更完成"); oaNotify.setStatus("1"); oaNotify.setFiles(act.getProcInsId()); oaNotify.setOaNotifyRecordIds(byUserName.getId()); //根据流程实例id查询对应的项目信息（如果没有，发送通知，没有该项目计划信息） oaNotify.setContent(s + "：设计变更完成"); oaNotifyService.save(oaNotify); List list = oaNotify.getOaNotifyRecordList(); for (OaNotifyRecord o : list) { //发送通知到客户端 ServletContext context = SpringContextHolder.getBean(ServletContext.class); new SystemInfoSocketHandler().sendMessageToUser(byUserName.getLoginName(), "收到一条新通知，请到我的通知查看！"); } //发送通知 vars.put("design", byUserName.getLoginName()); } else { //驳回 vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } //根据登陆查询所属的角色 vars.put("pass", "yes".equals(flag) ? true : false); // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位判断变更后材料 * * @param act */ @Transactional(readOnly = false) public void conAfterChange(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); //完成施工交底 if ("yes".equals(flag)) { } else { //驳回 vars.put("design", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } //根据登陆查询所属的角色 vars.put("pass", "yes".equals(flag) ? true : false); // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 经理保存审核意见 * * @param act */ @Transactional(readOnly = false) public void auditSave3(Act act, Disclose disclose, Boolean flagDesign, Boolean flagItemCLose, String flagDeal) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[存在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); /** * problem pass pass4 是互斥网关，同时只能执行一条线路 * */ //代表进入问题模块 vars.put("problem", false); //没有问题 vars.put("pass", false); //项目经理人工判断问题 vars.put("pass4", false); /** * pass1 pass2 pass3 pass5 分别对应了问题模块不同的问题类型 * pass2不可以与其它三个同时发起 * pass3 pass5 只可同时发起一种 * */ //设计变更 vars.put("pass1", false); //项目关闭 vars.put("pass2", false); //行政政处（城区道路） vars.put("pass3", false); //1·农村政处2·民事政处/行政政处（公路/水利） vars.put("pass5", false); //获取前置条件不为空就进入项目经理人工判断问题类型 if (null != disclose.getPrecondition() && !"".equals(disclose.getPrecondition())) { vars.put("pass4", true); } else { //如果符合项目关闭，步入项目关闭，其它问题类型不触发 if (flagItemCLose) { vars.put("itemClose", "专职"); vars.put("pass2", true); vars.put("problem", true); } else { //当不符合设计变更，项目关闭，政处处理时，判定项目没有问题，完成施工交底 if (!flagDesign && "init".equals(flagDeal)) { vars.put("pass", true); } else { //判断是否符合设计变更条件，符合 if (flagDesign) { vars.put("design", "运行人员"); vars.put("pass1", true); } //查看政处类型步入不同的问题模块 if ("民事农村".equals(flagDeal)) { vars.put("policy", "政策处理"); vars.put("pass5", true); } else if ("行政".equals(flagDeal)) { vars.put("coveredPerson", "施工单位"); vars.put("pass3", true); } } } } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 交底:判断项目是否需要关闭 * * @param act */ @Transactional(readOnly = false) public void specially(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); String flag = act.getFlag(); if ("yes".equals(flag)) { Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("operators", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); } else { //驳回到项目经理人工判断问题 Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("processer", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } // vars.put("yes".equals(act.getFlag())?"operators":"processer",fullName); vars.put("flagNo", "yes".equals(act.getFlag()) ? false : true); vars.put("flagYes", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存项目关闭 项目经理选择 * * @param act */ @Transactional(readOnly = false) public void managerFormTask(Act act, String fullName) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[存在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); if ("yes".equals(act.getFlag())) { vars.put("itemClose", fullName); vars.put("managerYes", true); vars.put("managerNo", false); } else { vars.put("managerYes", false); vars.put("managerNo", true); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目关闭 配网运行人员 * * @param act */ @Transactional(readOnly = false) public void addMember(Act act, String fullTime) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[驳回] ") + act.getComment()); act.preUpdate(); String flag = act.getFlag(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("systemfulltime", UserUtils.getByUserName(user.getDistributionSystem()).getLoginName()); } else { vars.put("itemClose", UserUtils.getByUserName(user.getDistributionEngineering()).getLoginName()); } // vars.put("yes".equals(act.getFlag())?"systemfulltime":"itemClose","yes".equals(act.getFlag())?fullTime:fullTime); vars.put("systemNo", "yes".equals(act.getFlag()) ? false : true); vars.put("systemYes", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 是否可以政策处理（农场/民事） * * @param act */ @Transactional(readOnly = false) public void policiesChange(Act act) { Map vars = Maps.newHashMap(); vars.put("pass1", false); vars.put("pass2", false); vars.put("pass3", false); vars.put("reject", false); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("pass3".equals(flag)) { vars.put("pass3", true); vars.put("policy", UserUtils.getUser().getLoginName()); act.setComment("[通过]" + act.getComment()); } else if ("pass1".equals(flag)) { vars.put("pass1", true); vars.put("design", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); act.setComment("[设计变更]" + act.getComment()); } else if ("pass2".equals(flag)) { vars.put("pass2", true); vars.put("itemClose", UserUtils.getByUserName(user.getDistributionEngineering()).getLoginName()); act.setComment("[项目关闭]" + act.getComment()); } else if ("reject".equals(flag)) { vars.put("reject", true); vars.put("policy", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); act.setComment("[驳回]" + act.getComment()); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目经理重新审核是否可以政策处理 * * @param act */ @Transactional(readOnly = false) public void managerPolicesChange(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【需要政策处理】" + act.getComment()); } else { act.setComment("【无需政策处理】" + act.getComment()); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(flag) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 上传未签字版政策处理清单 * * @param act */ @Transactional(readOnly = false) public void notSignUpload(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【未签字版清单】" + act.getComment()); } else { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【驳回】" + act.getComment()); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(flag) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 上传签字版政策处理清单 * * @param act */ @Transactional(readOnly = false) public void signUploadList(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【签字版清单】" + act.getComment()); } else { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【驳回】" + act.getComment()); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(flag) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 上传签字版合同 * * @param act */ @Transactional(readOnly = false) public void contractUploadList(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【签字版合同】" + act.getComment()); } else { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【驳回】" + act.getComment()); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(flag) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 上传签字版合同 * * @param act */ @Transactional(readOnly = false) public void loanUploadList(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { act.setComment("【完成政策处理】" + act.getComment()); } else { vars.put("policy", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("【驳回】" + act.getComment()); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 vars.put("pass", "yes".equals(flag) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存项目关闭 运行人员审批意见 * * @param act */ @Transactional(readOnly = false) public void addDepartment(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[存在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理 * * @param act */ @Transactional(readOnly = false) public void policiesDeal(Act act, String fullName) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[没有问题] " : "[存在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("yes".equals(act.getFlag()) ? "coveredPerson" : "coveredPerson", "yes".equals(act.getFlag()) ? fullName : fullName); vars.put("coveredNo", "yes".equals(act.getFlag()) ? false : true); vars.put("coveredYes", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 行政政处(城区道路)：施工单位人员上传未覆盖盖章 * * @param act */ @Transactional(readOnly = false) public void covered(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("sealYes", false); vars.put("sealNo", false); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("sealPerson", UserUtils.getByUserName(user.getDistributionPolicy()).getLoginName()); act.setComment("[没有问题]" + act.getComment()); vars.put("sealYes", true); } else { vars.put("phasePerson", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); act.setComment("[驳回]" + act.getComment()); vars.put("sealNo", true); } act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理：施工单位人员上传盖章 * * @param act */ @Transactional(readOnly = false) public void seal(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("receiptYes", false); vars.put("receiptNo", false); if ("yes".equals(flag)) { vars.put("receiptPerson", UserUtils.getUser().getLoginName()); act.setComment("[没有问题]" + act.getComment()); vars.put("receiptYes", true); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); act.setComment("[驳回]" + act.getComment()); vars.put("receiptNo", true); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理：项目经理 * * @param act */ @Transactional(readOnly = false) public void phaseManager(Act act, String fullName) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("phaseYes", false); vars.put("phaseNo", false); if ("yes".equals(flag)) { String manager2 = MyActiviUtils.findHistoryActivity(act.getProcInsId(), "交底:上传未盖章施工方案(行政政处(城区道路))"); vars.put("coveredPerson", manager2); act.setComment("[重新发起]" + act.getComment()); vars.put("phaseYes", true); } else { act.setComment("[无需发起，结束流程]" + act.getComment()); vars.put("phaseNo", true); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理：配网政策处理专职 : 收据 * * @param act */ @Transactional(readOnly = false) public void receiptTask(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("singleYes", false); vars.put("singleNo", false); if ("yes".equals(flag)) { vars.put("singlePerson", UserUtils.getUser().getLoginName()); act.setComment("[没有问题]" + act.getComment()); vars.put("singleYes", true); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); act.setComment("[驳回]" + act.getComment()); vars.put("singleNo", true); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理：配网政策处理专职 : 上传缴费单 * * @param act */ @Transactional(readOnly = false) public void singleTask(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("policyYes", false); vars.put("singleNo", false); if ("yes".equals(flag)) { vars.put("policyPay", UserUtils.getUser().getLoginName()); act.setComment("[没有问题]" + act.getComment()); vars.put("policyYes", true); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("coveredPerson", UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName()); act.setComment("[驳回]" + act.getComment()); vars.put("singleNo", true); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 政策处理：配网政策处理专职 : 上传借款 * * @param act */ @Transactional(readOnly = false) public void policy1Pay(Act act) { Map vars = Maps.newHashMap(); String flag = act.getFlag(); vars.put("finishYes", false); vars.put("finishNo", false); if ("yes".equals(flag)) { act.setComment(act.getComment()); vars.put("finishYes", true); } else { Project user = MyActiviUtils.findUser(act.getProcInsId()); vars.put("coveredPerson", UserUtils.get(user.getConstructionUnitRole()).getLoginName()); act.setComment(act.getComment()); vars.put("finishNo", true); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void newAuditSave(Act act, String tuser, Construction construction) { // String comment = act.getComment(); // 设置意见 // constructionService.save(construction); if ("manager".equals(act.getFlag())) { act.setComment(act.getComment()); } else if ("company".equals(act.getFlag())) { act.setComment(act.getComment()); } else { act.setComment(act.getComment()); } // act.setComment(("yes".equals(act.getFlag())?"[同意] ":"[驳回] ")+act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 // Map vars = Maps.newHashMap(); Map vars = new HashMap<>(); String flag = act.getFlag(); if ("manager".equals(flag)) { vars.put("manager", true); vars.put("company", false); vars.put("reject", false); if (tuser != null || tuser != "") { String loginName = UserUtils.getByLoginName(tuser).getLoginName(); vars.put("processer", loginName); } } else if ("company".equals(flag)) { vars.put("manager", false); vars.put("company", true); vars.put("reject", false); String loginName = UserUtils.getUser().getLoginName(); vars.put("processer", loginName); } else { vars.put("manager", false); vars.put("company", false); vars.put("reject", true); } constructionService.newUpdate(construction); // vars.put("processer", UserUtils.get(construction.getTuser().getId()).getLoginName()); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 判断下一个节点是互斥网关还是用户任务节点 * * @param processInstanceId 任务Id信息 * @return 下一个用户任务用户组信息 * @throws Exception */ public boolean isNextGatewaty(String processInstanceId) { ProcessDefinitionEntity processDefinitionEntity = null; String id = null; ActivityImpl nextActivityImpl = null; //获取流程实例Id信息 //String processInstanceId = taskService.createTaskQuery().taskId(taskId).singleResult().getProcessInstanceId(); //获取流程发布Id信息 ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); if (processInstance == null) { return false; } String definitionId = processInstance.getProcessDefinitionId(); processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService) .getDeployedProcessDefinition(definitionId); ExecutionEntity execution = (ExecutionEntity) runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); //当前流程节点Id信息 String activitiId = execution.getActivityId(); //获取流程所有节点信息 List activitiList = processDefinitionEntity.getActivities(); //遍历所有节点信息 for (ActivityImpl activityImpl : activitiList) { id = activityImpl.getId(); if (activitiId.equals(id)) { //获取下一个节点信息 { PvmActivity ac = null; Object s = null; // 如果遍历节点为用户任务并且节点不是当前节点信息 if ("userTask".equals(activityImpl.getProperty("type")) && !activitiId.equals(activityImpl.getId())) { // 获取该节点下一个节点信息 TaskDefinition taskDefinition = ((UserTaskActivityBehavior) activityImpl.getActivityBehavior()) .getTaskDefinition(); return false; } else if ("exclusiveGateway".equals(activityImpl.getProperty("type"))) {// 当前节点为exclusiveGateway List outTransitions = activityImpl.getOutgoingTransitions(); //outTransitionsTemp = ac.getOutgoingTransitions(); // 如果网关路线判断条件为空信息 // if (StringUtils.isEmpty(elString)) { // 获取流程启动时设置的网关判断条件信息 String elString = getGatewayCondition(activityImpl.getId(), processInstanceId); // } // 如果排他网关只有一条线路信息 if (outTransitions.size() == 1) { return false; } else if (outTransitions.size() > 1) { // 如果排他网关有多条线路信息 return true; } } else { // 获取节点所有流向线路信息 List outTransitions = activityImpl.getOutgoingTransitions(); List outTransitionsTemp = null; for (PvmTransition tr : outTransitions) { ac = tr.getDestination(); // 获取线路的终点节点 // 如果流向线路为排他网关 if ("exclusiveGateway".equals(ac.getProperty("type"))) { return true; } else if ("userTask".equals(ac.getProperty("type"))) { return false; } else { return false; } } return false; } return false; } } } return false; } /** * 下一个任务节点信息, *

* 如果下一个节点为用户任务则直接返回, *

* 如果下一个节点为排他网关, 获取排他网关Id信息, 根据排他网关Id信息和execution获取流程实例排他网关Id为key的变量值, * 根据变量值分别执行排他网关后线路中的el表达式, 并找到el表达式通过的线路后的用户任务 * * @param activityImpl 流程节点信息 * @param activityId 当前流程节点Id信息 * @param elString 排他网关顺序流线段判断条件 * @param processInstanceId 流程实例Id信息 * @return */ private TaskDefinition nextTaskDefinition(ActivityImpl activityImpl, String activityId, String elString, String processInstanceId) { PvmActivity ac = null; Object s = null; // 如果遍历节点为用户任务并且节点不是当前节点信息 if ("userTask".equals(activityImpl.getProperty("type")) && !activityId.equals(activityImpl.getId())) { // 获取该节点下一个节点信息 TaskDefinition taskDefinition = ((UserTaskActivityBehavior) activityImpl.getActivityBehavior()) .getTaskDefinition(); return taskDefinition; } else if ("exclusiveGateway".equals(activityImpl.getProperty("type"))) {// 当前节点为exclusiveGateway List outTransitions = activityImpl.getOutgoingTransitions(); //outTransitionsTemp = ac.getOutgoingTransitions(); // 如果网关路线判断条件为空信息 // if (StringUtils.isEmpty(elString)) { // 获取流程启动时设置的网关判断条件信息 elString = getGatewayCondition(activityImpl.getId(), processInstanceId); // } // 如果排他网关只有一条线路信息 if (outTransitions.size() == 1) { return nextTaskDefinition((ActivityImpl) outTransitions.get(0).getDestination(), activityId, elString, processInstanceId); } else if (outTransitions.size() > 1) { // 如果排他网关有多条线路信息 for (PvmTransition tr1 : outTransitions) { s = tr1.getProperty("conditionText"); // 获取排他网关线路判断条件信息 // 判断el表达式是否成立 if (isCondition(activityImpl.getId(), StringUtils.trim(s.toString()), elString)) { return nextTaskDefinition((ActivityImpl) tr1.getDestination(), activityId, elString, processInstanceId); } } } } else { // 获取节点所有流向线路信息 List outTransitions = activityImpl.getOutgoingTransitions(); List outTransitionsTemp = null; for (PvmTransition tr : outTransitions) { ac = tr.getDestination(); // 获取线路的终点节点 // 如果流向线路为排他网关 if ("exclusiveGateway".equals(ac.getProperty("type"))) { outTransitionsTemp = ac.getOutgoingTransitions(); // 如果网关路线判断条件为空信息 if (StringUtils.isEmpty(elString)) { // 获取流程启动时设置的网关判断条件信息 elString = getGatewayCondition(ac.getId(), processInstanceId); } // 如果排他网关只有一条线路信息 if (outTransitionsTemp.size() == 1) { return nextTaskDefinition((ActivityImpl) outTransitionsTemp.get(0).getDestination(), activityId, elString, processInstanceId); } else if (outTransitionsTemp.size() > 1) { // 如果排他网关有多条线路信息 for (PvmTransition tr1 : outTransitionsTemp) { s = tr1.getProperty("conditionText"); // 获取排他网关线路判断条件信息 // 判断el表达式是否成立 if (isCondition(ac.getId(), StringUtils.trim(s.toString()), elString)) { return nextTaskDefinition((ActivityImpl) tr1.getDestination(), activityId, elString, processInstanceId); } } } } else if ("userTask".equals(ac.getProperty("type"))) { return ((UserTaskActivityBehavior) ((ActivityImpl) ac).getActivityBehavior()).getTaskDefinition(); } else { } } return null; } return null; } /** * 查询流程启动时设置排他网关判断条件信息 * * @param gatewayId 排他网关Id信息, 流程启动时设置网关路线判断条件key为网关Id信息 * @param processInstanceId 流程实例Id信息 * @return */ public String getGatewayCondition(String gatewayId, String processInstanceId) { Execution execution = runtimeService.createExecutionQuery().processInstanceId(processInstanceId).singleResult(); Object object = runtimeService.getVariable(execution.getId(), gatewayId); return object == null ? "" : object.toString(); } /** * 根据key和value判断el表达式是否通过信息 * * @param key el表达式key信息 * @param el el表达式信息 * @param value el表达式传入值信息 * @return */ public boolean isCondition(String key, String el, String value) { ExpressionFactory factory = new ExpressionFactoryImpl(); SimpleContext context = new SimpleContext(); context.setVariable(key, factory.createValueExpression(value, String.class)); ValueExpression e = factory.createValueExpression(context, el, boolean.class); return (Boolean) e.getValue(context); } //项目关闭 public Boolean isJudgeItemClose(Disclose disclose) { Boolean flag = false; if (null != disclose.getChannel() && disclose.getChannel().equals("无")) {//施工通道 flag = true; } if (null != disclose.getHiddenDanger() && disclose.getHiddenDanger().equals("有")) { flag = true; } if (null != disclose.getInfluenceConstruction() && disclose.getInfluenceConstruction().equals("有")) { flag = true; } if (null != disclose.getProjectRepetition() && disclose.getProjectRepetition().equals("是")) { flag = true; } if (null != disclose.getImplemented() && disclose.getImplemented().equals("是")) { flag = true; } if (null != disclose.getTransformer() && disclose.getTransformer().equals("有")) { flag = true; } //必要性说明 // if (null!=disclose.getTransformer()&&disclose.getTransformer().equals("有")){ // flag =true; // } return flag; } //设计变更 public Boolean isJudgeDesign(Disclose disclose) { Boolean flag = false; if (null != disclose.getLineName() && disclose.getLineName().equals("否")) { flag = true; } if (null != disclose.getQuantities() && disclose.getQuantities().equals("否")) { flag = true; } if (null != disclose.getRodNumber() && disclose.getRodNumber().equals("否")) { flag = true; } return flag; } public Boolean isJudgeDeal(Disclose disclose) { Boolean flag = false; if (null != disclose.getAdministrationType()) { if (disclose.getAdministrationType().contains("民事证处") || disclose.getAdministrationType().contains("行政证处") || disclose.getAdministrationType().contains("农村证处")) { flag = true; } } // if (null!) return flag; } public String newJudgeDeal(Disclose disclose) { String flag = "init"; String a = ""; if (null != disclose.getAdministrationType()) { if (disclose.getAdministrationType().contains("民事政处") || disclose.getAdministrationType().contains("农村政处")) { flag = "民事农村"; } else if (disclose.getAdministrationType().indexOf("城区道路") >= 0) { flag = "行政"; } } // if (null!) return flag; } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void pickIng(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitLeader()).getLoginName()); // complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void managerExam(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); ShowList showList = new ShowList(); showList.setAct(act); List newTemList = showListService.findNewTemList(showList); pickIngService.processList(newTemList); Project wzUser = MyActiviUtils.findWZUser(act.getProcInsId()); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(act.getFlag()) ? true : false); vars.put("manager", UserUtils.getByUserName(wzUser.getConstructionUnitLeader()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void constructionLeader(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); String loginName = UserUtils.getByUserName(user.getConstructionUnitRole()).getLoginName(); String loginName1 = UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName(); vars.put("manager", "yes".equals(flag) ? loginName : loginName1); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位物资专职审核 * * @param act */ @Transactional(readOnly = false) public void fullExamine(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); String loginName = UserUtils.getByUserName(user.getProjectManageRole()).getLoginName(); String loginName1 = UserUtils.getByUserName(user.getConstructionUnitLeader()).getLoginName(); vars.put("manager", "yes".equals(flag) ? loginName : loginName1); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 项目中心领导审核领料单 * * @param act */ @Transactional(readOnly = false) public void leaderExamine(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); if ("yes".equals(flag)) { showListService.updateManagerTime(act.getProcInsId()); } vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); String loginName = UserUtils.getByUserName(user.getDistributionMaterials()).getLoginName(); vars.put("manager", "yes".equals(flag) ? "" : loginName); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网项目经理审核领料单 * * @param act */ @Transactional(readOnly = false) public void managerAudit(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); String loginName = UserUtils.getByUserName(user.getDistributionMaterials()).getLoginName(); String loginName1 = UserUtils.getByUserName(user.getProjectManageRole()).getLoginName(); vars.put("manager", "yes".equals(flag) ? loginName : loginName1); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网物资专职审核领料单 * * @param act */ @Transactional(readOnly = false) public void netExamine(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findWZUser(act.getProcInsId()); String loginName = UserUtils.getByUserName(user.getManagementLeader()).getLoginName(); String loginName1 = UserUtils.getByUserName(user.getProjectManageRole()).getLoginName(); vars.put("manager", "yes".equals(flag) ? loginName : loginName1); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void auditDrawings(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); String flag = act.getFlag(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); vars.put("pass", "yes".equals(flag) ? true : false); Project user = MyActiviUtils.findUser(act.getProcInsId()); if ("yes".equals(flag)) { vars.put("design", UserUtils.getByUserName(user.getDesignUnitManage()).getLoginName()); } else { vars.put("design", UserUtils.getByUserName(user.getThroughResearchRole()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void applicationAudit(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); String info = ""; //选择项目发起请求 String flag = act.getFlag(); String procInsId = act.getProcInsId(); Project nameByInsID = constructionService.findNameByInsID(procInsId); if ("yes".equals(flag)) { PickApplication pickApplication = new PickApplication(); pickApplication.setProjectId(nameByInsID.getId()); info = nameByInsID.getRequireName() + "项目通过审核"; showListService.projectUpdate(pickApplication); } else { info = nameByInsID.getRequireName() + "项目没有通过审核"; } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 保存审核意见 * * @param act */ @Transactional(readOnly = false) public void contructionManager(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); String status = ""; //选择项目发起请求 String flag = act.getFlag(); String procInsId = act.getProcInsId(); Project project = constructionService.findNameByInsID(procInsId); Advance advance = new Advance(); advance.setId(project.getId()); if ("yes".equals(flag)) { status = project.getRequireName() + "提前施工通过"; advance.setPreConstruction(1); } else { status = project.getRequireName() + "提前施工未通过"; advance.setPreConstruction(0); } advanceService.updatePreConstruction(advance); // act.setComment(("yes".equals(act.getFlag())?"[同意] ":"[驳回] ")+act.getComment()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理土建开工流程提交文件 * * @param act */ @Transactional(readOnly = false) public void nonPowerStartTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理电气开工流程提交文件 * * @param act */ @Transactional(readOnly = false) public void electricalStartTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理土建施工中流程提交文件 * * @param act */ @Transactional(readOnly = false) public void nonPowerMiddleTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理电气施工中流程提交文件 * * @param act */ @Transactional(readOnly = false) public void electricalMiddleTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 电气竣工流程 * * @param act */ @Transactional(readOnly = false) public void electricalEndTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 审核土建施工流程 * * @param act */ @Transactional(readOnly = false) public void nonRePowerMiddleTask(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[没有问题] " : "[纯在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); vars.put("pass", "yes".equals(flag) ? true : false); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 审核土建竣工流程 * * @param act */ @Transactional(readOnly = false) public void nonRePowerEndTask(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[没有问题] " : "[纯在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); vars.put("pass", "yes".equals(flag) ? true : false); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 审核涉电施工流程 * * @param act */ @Transactional(readOnly = false) public void rePowerEnd(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[没有问题] " : "[纯在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); vars.put("pass", "yes".equals(flag) ? true : false); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 审核电气竣工流程 * * @param act */ @Transactional(readOnly = false) public void reElectricalEndTask(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[没有问题] " : "[纯在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); vars.put("pass", "yes".equals(flag) ? true : false); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 审核土建施工流程 * * @param act */ @Transactional(readOnly = false) public void reElectricalMiddleTask(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[没有问题] " : "[纯在问题] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); vars.put("pass", "yes".equals(flag) ? true : false); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 土建竣工流程 * * @param act */ @Transactional(readOnly = false) public void nonPowerEndTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网项目经理判断是否完成土建工作 * * @param act */ @Transactional(readOnly = false) public void reviewNonPower(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); MaterialModule byProcInsId = materialModuleService.findByProcInsId(act.getProcInsId()); Integer nonPower = byProcInsId.getNonPower(); Integer electrical = byProcInsId.getElectrical(); Integer power = byProcInsId.getPower(); // 提交流程任务 Map vars = Maps.newHashMap(); if (nonPower == 0 && electrical == 0 && power == 1) { vars.put("contain", true); } else if (nonPower == 0 && electrical == 0 && power == 0) { vars.put("contain", false); } //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网项目经理判断是否完成电气工作 * * @param act */ @Transactional(readOnly = false) public void reviewElectrical(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); MaterialModule byProcInsId = materialModuleService.findByProcInsId(act.getProcInsId()); Integer nonPower = byProcInsId.getNonPower(); Integer electrical = byProcInsId.getElectrical(); Integer power = byProcInsId.getPower(); // 提交流程任务 Map vars = Maps.newHashMap(); if (nonPower == 0 && electrical == 0 && power == 1) { vars.put("contain", true); } else if (nonPower == 0 && electrical == 0 && power == 0) { vars.put("contain", false); } //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } else { //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getProjectManageRole()).getLoginName()); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理判断是否包含涉电工作 * * @param act */ @Transactional(readOnly = false) public void managerWhetherTask(Act act) { String flag = act.getFlag(); // 设置意见 act.setComment(("yes".equals(flag) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); if ("yes".equals(flag)) { //根据项目设置的流转人员，流转对应人员 vars.put("manager", user.getConstructionUnitManage()); vars.put("yes", true); vars.put("no", false); } else { //根据项目设置的流转人员，流转对应人员 vars.put("yes", false); vars.put("no", true); } complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 施工单位项目经理 涉电开工流程提交文件 * * @param act */ @Transactional(readOnly = false) public void PowerStartTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 涉电竣工流程 * * @param act */ @Transactional(readOnly = false) public void PowerEndTask(Act act) { // 设置意见 act.setComment(("yes".equals(act.getFlag()) ? "[同意] " : "[驳回] ") + act.getComment()); act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); //根据项目设置的流转人员，流转对应人员 vars.put("manager", UserUtils.getByUserName(user.getRunUnitRole()).getLoginName()); complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } /** * 配网项目经理判断涉电工作 * * @param act */ @Transactional(readOnly = false) public void PowerWhetherTask(Act act) { Map vars = Maps.newHashMap(); //根据流程实例id查询项目的相关信息 Project user = MyActiviUtils.sgFindUser(act.getProcInsId()); String flag = act.getFlag(); if ("finish".equals(flag)) { act.setComment("[无二次涉电]" + act.getComment()); vars.put("finish", true); vars.put("second", false); vars.put("no", false); } else if ("second".equals(flag)) { act.setComment("[纯在二次涉电]" + act.getComment()); vars.put("finish", false); vars.put("second", true); vars.put("no", false); vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } else { act.setComment("[审核不通过]" + act.getComment()); vars.put("finish", false); vars.put("second", false); vars.put("no", true); vars.put("manager", UserUtils.getByUserName(user.getConstructionUnitManage()).getLoginName()); } // 设置意见 act.preUpdate(); // 对不同环节的业务逻辑进行操作 String taskDefKey = act.getTaskDefKey(); // 提交流程任务 complete(act.getTaskId(), act.getProcInsId(), act.getComment(), vars); } }