SpringBoot+Vue3快速开发平台、自研工作流引擎

package com.mldong.modules.wf.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.convert.Convert; import cn.hutool.core.lang.Dict; import cn.hutool.core.util.ReflectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.extra.expression.ExpressionUtil; import cn.hutool.extra.spring.SpringUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.toolkit.SqlHelper; import com.mldong.base.CommonPage; import com.mldong.base.LabelValueVO; import com.mldong.base.YesNoEnum; import com.mldong.modules.wf.api.WfUserApi; import com.mldong.modules.wf.dto.ProcessInstancePageParam; import com.mldong.modules.wf.dto.ProcessInstanceParam; import com.mldong.modules.wf.engine.DecisionHandler; import com.mldong.modules.wf.engine.FlowEngine; import com.mldong.modules.wf.engine.core.Execution; import com.mldong.modules.wf.engine.core.ServiceContext; import com.mldong.modules.wf.engine.handlers.impl.MergeBranchHandler; import com.mldong.modules.wf.engine.model.*; import com.mldong.modules.wf.engine.util.FlowUtil; import com.mldong.modules.wf.entity.ProcessCcInstance; import com.mldong.modules.wf.entity.ProcessDefine; import com.mldong.modules.wf.entity.ProcessInstance; import com.mldong.modules.wf.entity.ProcessTask; import com.mldong.modules.wf.enums.FlowConst; import com.mldong.modules.wf.enums.ProcessInstanceStateEnum; import com.mldong.modules.wf.enums.ProcessSubmitTypeEnum; import com.mldong.modules.wf.enums.ProcessTaskStateEnum; import com.mldong.modules.wf.mapper.ProcessCcInstanceMapper; import com.mldong.modules.wf.mapper.ProcessInstanceMapper; import com.mldong.modules.wf.mapper.ProcessTaskMapper; import com.mldong.modules.wf.service.ProcessDefineService; import com.mldong.modules.wf.service.ProcessInstanceService; import com.mldong.modules.wf.service.ProcessTaskService; import com.mldong.modules.wf.vo.HighLightVO; import com.mldong.modules.wf.vo.ProcessInstanceVO; import com.mldong.modules.wf.vo.ProcessTaskVO; import com.mldong.web.LoginUserHolder; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.*; import java.util.stream.Collectors; /** * <p> * 流程实例 服务实现类 * </p> * * @author mldong * @since 2023-09-26 */ @Service @RequiredArgsConstructor public class ProcessInstanceServiceImpl extends ServiceImpl<ProcessInstanceMapper, ProcessInstance> implements ProcessInstanceService { private final ProcessTaskMapper processTaskMapper; private final ProcessCcInstanceMapper processCcInstanceMapper; @Override @Transactional(rollbackFor = Exception.class) public boolean save(ProcessInstanceParam param) { param.setId(null); ProcessInstance processInstance = new ProcessInstance(); BeanUtil.copyProperties(param, processInstance); return super.save(processInstance); } @Override public boolean update(ProcessInstanceParam param) { ProcessInstance processInstance = new ProcessInstance(); BeanUtil.copyProperties(param, processInstance); return super.updateById(processInstance); } @Override public CommonPage<ProcessInstanceVO> page(ProcessInstancePageParam param) { if(StrUtil.isEmpty(param.getOrderBy())) { // 按id即时间倒序 param.setOrderBy("t.id desc"); } IPage<ProcessInstanceVO> page = param.buildMpPage(); QueryWrapper queryWrapper = param.buildQueryWrapper(); Long userId = LoginUserHolder.getUserId(); if(YesNoEnum.YES.equals(param.getIsCC())) { // 我的抄送实例 queryWrapper.exists("select * from wf_process_cc_instance cc where cc.process_instance_id=t.id and cc.actor_id="+userId); } else { // 当前用户发起的流程 queryWrapper.eq("t.operator", userId); } List<ProcessInstanceVO> list = baseMapper.selectCustom(page, queryWrapper); page.setRecords(list); return CommonPage.toPage(page); } @Override public ProcessInstanceVO findById(Long id) { ProcessInstanceVO vo = baseMapper.findById(id); if(vo!=null) { vo.setJsonObject(SpringUtil.getBean(ProcessDefineService.class).getDefineJsonObject(vo.getProcessDefineId())); } return vo; } @Transactional(rollbackFor = Exception.class) @Override public void finishProcessInstance(Long processInstanceId) { ProcessInstance processInstance = new ProcessInstance(); processInstance.setId(processInstanceId); processInstance.setState(ProcessInstanceStateEnum.FINISHED.getCode()); baseMapper.updateById(processInstance); } @Override public void rejectProcessInstance(Long processInstanceId) { ProcessInstance processInstance = new ProcessInstance(); processInstance.setId(processInstanceId); processInstance.setState(ProcessInstanceStateEnum.REJECT.getCode()); baseMapper.updateById(processInstance); } @Override public ProcessInstance createProcessInstance(ProcessDefine processDefine, String operator, Dict args) { return createProcessInstance(processDefine, operator, args, null, null); } @Override public ProcessInstance createProcessInstance(ProcessDefine processDefine, String operator, Dict args, Long parentId, String parentNodeName) { ProcessInstance processInstance = new ProcessInstance(); processInstance.setParentId(parentId); processInstance.setParentNodeName(parentNodeName); processInstance.setProcessDefineId(processDefine.getId()); processInstance.setOperator(operator); processInstance.setState(ProcessInstanceStateEnum.DOING.getCode()); // 业务流水号从流程变量中获取 processInstance.setBusinessNo(args.getStr(FlowConst.BUSINESS_NO)); // 追加用户信息到参数 FlowUtil.addUserInfoToArgs(operator,args); // 追加自动构造标题 FlowUtil.addAutoGenTitle(processDefine.getDisplayName(),args); processInstance.setVariable(JSONUtil.toJsonStr(args)); ProcessModel processModel = SpringUtil.getBean(ProcessDefineService.class).processDefineToModel(processDefine); String expireTime = processModel.getExpireTime(); if(StrUtil.isNotEmpty(expireTime)) { processInstance.setExpireTime(FlowUtil.processTime(expireTime,args)); } saveProcessInstance(processInstance); return processInstance; } @Override public void addVariable(Long processDefineId, Dict args) { ProcessInstance processInstance = baseMapper.selectById(processDefineId); Dict newDict = Dict.create(); newDict.putAll(JSONUtil.toBean(processInstance.getVariable(),Dict.class)); newDict.putAll(args); ProcessInstance up = new ProcessInstance(); up.setId(processDefineId); up.setVariable(JSONUtil.toJsonStr(newDict)); baseMapper.updateById(up); } @Override public void removeVariable(Long processDefineId, String... keys) { ProcessInstance processInstance = baseMapper.selectById(processDefineId); Dict oldDict = JSONUtil.toBean(processInstance.getVariable(),Dict.class); for (int i = 0; i < keys.length; i++) { oldDict.remove(keys[i]); } ProcessInstance up = new ProcessInstance(); up.setId(processDefineId); up.setVariable(JSONUtil.toJsonStr(oldDict)); baseMapper.updateById(up); } @Override public void saveProcessInstance(ProcessInstance processInst