基于SpringBoot+Activiti7的hiss-center工作流组件设计源码

package cn.itcast.hiss.process.activiti.service.impl; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.itcast.hiss.api.client.HissProcessConstants; import cn.itcast.hiss.api.client.common.HissVariableServer; import cn.itcast.hiss.api.client.form.FormSubmitData; import cn.itcast.hiss.api.client.processdefinition.ProcessDesignModel; import cn.itcast.hiss.api.client.task.*; import cn.itcast.hiss.api.server.common.UserInfo; import cn.itcast.hiss.common.SystemConstant; import cn.itcast.hiss.common.enums.*; import cn.itcast.hiss.event.pojo.HissActivitiEvent; import cn.itcast.hiss.form.service.HissFormModelService; import cn.itcast.hiss.message.CurrentUser; import cn.itcast.hiss.message.Message; import cn.itcast.hiss.message.MessageContext; import cn.itcast.hiss.message.sender.form.FormSubmitDataMessage; import cn.itcast.hiss.message.sender.processdefinition.ProcessDesignModelMessage; import cn.itcast.hiss.message.sender.task.*; import cn.itcast.hiss.process.activiti.configurator.function.HissUtil; import cn.itcast.hiss.process.activiti.listener.HissActivitiEventBuilder; import cn.itcast.hiss.process.activiti.mapper.*; import cn.itcast.hiss.process.activiti.multilnstance.AddMultiInstanceExecutionCmd; import cn.itcast.hiss.process.activiti.multilnstance.JumpMultiInstanceExecutionCmd; import cn.itcast.hiss.process.activiti.pojo.*; import cn.itcast.hiss.process.activiti.service.ActivitiService; import cn.itcast.hiss.process.activiti.service.CommentService; import cn.itcast.hiss.process.activiti.service.UpdateProcessTenantService; import cn.itcast.hiss.process.activiti.service.UserTaskService; import cn.itcast.hiss.process.activiti.util.AdminUtil; import cn.itcast.hiss.process.activiti.util.VariableUtil; import cn.itcast.hiss.process.activiti.variables.SysVariableManager; import cn.itcast.hiss.process.activiti.vo.MultiInstanceVo; import cn.itcast.hiss.server.template.HissServerApperanceTemplate; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import lombok.extern.slf4j.Slf4j; import org.activiti.bpmn.constants.BpmnXMLConstants; import org.activiti.bpmn.converter.BpmnXMLConverter; import org.activiti.bpmn.model.Process; import org.activiti.bpmn.model.*; import org.activiti.engine.*; import org.activiti.engine.delegate.DelegateExecution; import org.activiti.engine.delegate.Expression; import org.activiti.engine.history.*; import org.activiti.engine.impl.bpmn.behavior.ParallelMultiInstanceBehavior; import org.activiti.engine.impl.bpmn.behavior.SequentialMultiInstanceBehavior; import org.activiti.engine.impl.identity.Authentication; import org.activiti.engine.impl.persistence.entity.ExecutionEntityImpl; import org.activiti.engine.impl.persistence.entity.TaskEntity; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.DeploymentBuilder; import org.activiti.engine.repository.Model; import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.runtime.Execution; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.DelegationState; import org.activiti.engine.task.IdentityLink; import org.activiti.engine.task.Task; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import java.io.ByteArrayInputStream; import java.io.InputStreamReader; import java.nio.charset.StandardCharsets; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; import java.util.stream.Collectors; /* * @author miukoo * @description 流程办理各功能实现 * @date 2023/6/3 11:19 * @version 1.0 **/ @Slf4j @Service @Transactional public class ActivitiServiceImpl implements ActivitiService { @Autowired HissProcessUpdateJobMapper hissProcessUpdateJobMapper; @Autowired HissProcessPreLaunchMapper hissProcessPreLaunchMapper; @Autowired private TaskService taskService; @Autowired private RuntimeService runtimeService; @Autowired private CommentService commentService; @Autowired private ProcessEngine processEngine; @Autowired private HistoryService historyService; @Autowired private RepositoryService repositoryService; @Autowired private HiActinstMapper hiActinstMapper; @Autowired private ManagementService managementService; @Autowired private HissAutoApprovalConfigMapper hissAutoApprovalConfigMapper; @Autowired private UserTaskService userTaskService; @Autowired private ActRuEventSubscrMapper actRuEventSubscrMapper; @Autowired private HissServerApperanceTemplate hissServerApperanceTemplate; @Autowired private GeBytearrayMapper geBytearrayMapper; @Autowired private HissProcessFormMapper hissProcessFormMapper; @Autowired private HissFormModelService hissFormModelService; @Autowired private ActReModelMapper actReModelMapper; /** * 创建知会任务 * * @param params * @return */ @Override public void createNotificationTask(NotificationTaskMessage params, MessageContext messageContext) { createTask(params, HissTaskTypeEnum.NOTIFICATION, messageContext); } private void createTask(NotificationTaskMessage params, HissTaskTypeEnum type, MessageContext messageContext) { NotificationTask notificationTask = params.getPalyload(); createTask(notificationTask, params.getMessageAuth().getCurrentUser(), type, messageContext); } @Override public void createTask(NotificationTask notificationTask, CurrentUser currentUser, HissTaskTypeEnum type, MessageContext messageContext) { String actionName = notificationTask.getOperatorName(); Task task = taskService.createTaskQuery().taskId(notificationTask.getTaskId()).singleResult(); if (task != null) { if (StrUtil.isNotEmpty(task.getAssignee()) && task.getAssignee().equalsIgnoreCase(currentUser.getUserId())) { ActReModel actReModel = actReModelMapper.getModelByBusId(type.name().toLowerCase()); ProcessDefinition hissNotification = repositoryService.createProcessDefinitionQuery() .processDefinitionName("hiss_"+type.name().toLowerCase()) .deploymentId(actReModel.getDeploymentId()) .processDefinitionTenantId("tenant_hiss") .latestVersion().singleResult(); // 增加流程标识 Map<String,Object> map = new HashMap<>(); map.put(type.name().toLowerCase(),notificationTask.getUserId()); map.put(HissProcessConstants.PARENT_PROCESS_INSTANCE,task.getProcessInstanceId()); map.put(HissProcessConstants.NODE_TYPE, type.name());// 这里type实际是ActiveNodeTypeEnum的值，但是可以直接使用type，因为抄送和知会 ProcessInstance oldProcessInstance = runtimeService.createProcessInstanceQuery().processInstanceId(task.getProcessInstanceId()).singleResult(); Authentication.setAuthenticatedUserId(task.getAssignee()); ProcessInstance processInstance = runtimeService.startProcessInstanceById(hissNotification.getId(), task.getBusinessKey(), map); addHissProcessUpdateJob("【"+actionName+"】"+oldProcessInstance.getName(),task.getTenantId(),processInstance.g