bladex审批流流程图配置和后端代码

@Override
	@Transactional(rollbackFor = Exception.class)
	// @GlobalTransactional
	public boolean startProcess(ProcessPurchaseOrder bean) {
		//是否启动流程
		boolean isStartProcess = false;
		//是否新增数据
		boolean isAdd = false;
		if (bean != null) {
			if (Func.isEmpty(bean.getProcessInstanceId())) {
				isStartProcess = true;
			}
			if (Func.isEmpty(bean.getId())) {
				isAdd = true;
			}
			//更新业务数据
			if (isAdd) {
				Date now = new Date();
				SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
				String dateStr = format.format(now);
				if(Func.isNull(bean.getOrderNumber())){
					bean.setOrderNumber(oaSerialService.getSerial(bean.getTenantId(),"purchaseOrder",dateStr,dateStr,5));
				}
				//第一次发起 保存数据到采购订单表和订单详情表
				save(bean);
				//采购订单明细进入明细表
				saveDetail(bean.getPurchaseOrderDetail(), bean.getOrderNumber());
			} else {
				updateById(bean);
				//从新发起修改采购订单详细表1.先删除以前的数据，2.从新插入新的订单详情
				deleteOrderDetail(bean.getOrderNumber());
				saveDetail(bean.getPurchaseOrderDetail(), bean.getOrderNumber());
			}
			//更新附件信息
			oaAttachmentService.saveOrUpdateOaAttachment(bean.getAttachments(),bean.getId(),bean.getProcessInstanceId(),bean.getTenantId(),"purchaseOrder");
		}
		//除了茶叶 原物料 都走主管 经理审批
		bean.setChanges("01");
		System.out.println("urchaseType=================="+bean.getPurchaseType());
		//茶叶 原物料 价格没有变动 只走主管审批
		if(bean.getPurchaseType().equals("茶叶") || bean.getPurchaseType().equals("原物料")){
			if (null != bean.getPurchaseOrderDetail() && bean.getPurchaseOrderDetail().size() > 0) {
				for (ProcessPurchaseOrderDetail processPurchaseOrderDetail : bean.getPurchaseOrderDetail()) {
					System.out.println("processPurchaseOrderDetail.getPriceChange()====" + processPurchaseOrderDetail.getPriceChange());
					if (processPurchaseOrderDetail.getPriceChange().equals("1")) {//01价格有变动 02没有变动
						bean.setChanges("01");
						break;
					}else{
						bean.setChanges("02");
					}
				}
			}
		}
		//获取发起人部门id
		Long curDeptId = DeskUtil.getCurDeptId(bean.getCreateDept());
		//获取经理职位
		Long managerUser=null;
		String roleId=deptUserUtil.getRoleId(AuthUtil.getTenantId(), "经理");
		List<User>users=deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),false);
		if(!Func.isEmpty(users)){
			managerUser=users.get(0).getId();
		}
		log.info("获取经理职位roleId====="+roleId+"------users========================"+users);
		//获取部门总监
		String majorRoleId=deptUserUtil.getRoleId(AuthUtil.getTenantId(), "总监");
		List<User>majordomoUsers=deptUserUtil.getUserListByRoleIdAndDeptId(majorRoleId,String.valueOf(curDeptId),true);
		Long generalManager=null;
		if(null!=majordomoUsers && majordomoUsers.size()>0){
			generalManager =majordomoUsers.get(0).getId();
		}
		log.info("获取总监majorRoleId===="+majorRoleId+"-----majordomoUsers========================"+majordomoUsers);
		//获取总经理
		String companyBossPostId=deptUserUtil.getPostId("总经理",bean.getTenantId());
		List<User>companyBossUsers=deptUserUtil.getUserListByPostId(companyBossPostId);//总经理不属于某个部门，不用根据部门id查询
		Long companyBoss=null;
		if(null!=companyBossUsers && companyBossUsers.size()>0){
			companyBoss=companyBossUsers.get(0).getId();
		}
		log.info("获取总经理companyBossPostId====="+companyBossPostId+"-------companyBossUsers========================"+companyBossUsers);
		//上级主管
		roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(),"主管");
		boolean isManager = Func.isNotEmpty(AuthUtil.getUserRole())&&AuthUtil.getUserRole().contains("主管")?true:false;
		Long lastManagerUserId = null;
		if(isManager){
			users = deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),true,AuthUtil.getUserId());
			lastManagerUserId = Func.isEmpty(users)?null:users.get(0).getId();
		}
		/**
		 * 判断条件
		 */
		//如果发起人是总监或者经理不是部门最高领导 没有的职位跳过经理职位
		if(null!=managerUser){
			if(AuthUtil.getUser().getUserId().longValue()==managerUser.longValue()){
				managerUser=null;//经理
			}
		}
		//跳过总监
		if(null!=generalManager){
			//跳过总监
			if(AuthUtil.getUser().getUserId().longValue()==generalManager.longValue()){
				//跳过经理
				managerUser=null;//经理
				//跳过总监职位
				generalManager=null;
			}
		}
		Kv variables =DeskUtil.createKV(curDeptId,"采购订单",bean.getOrderNumber(),bean.getApplicantName(),isManager,bean.getCcUser(),bean.getCcUserName())
			.set("taskUser", TaskUtil.getTaskUser(AuthUtil.getUser().getUserId().toString()))
			.set("category", bean.getCategory())//申请类型
			.set("changes", bean.getChanges())//价格是否变动
			.set("managerSkip", Func.isEmpty(managerUser))
			.set("managerUser",TaskUtil.getTaskUser(String.valueOf(managerUser==null ? "" : managerUser)))//经理
			.set("generalManagerSkip", Func.isEmpty(generalManager))
			.set("generalManager",TaskUtil.getTaskUser(String.valueOf(generalManager==null ? "" : generalManager)))//总监
			.set("companyBossSkip",Func.isEmpty(companyBoss))
			.set("companyBossUser", TaskUtil.getTaskUser(String.valueOf(companyBoss==null ? "" : companyBoss)))//总经理
			.set("lastManagerSkip",Func.isEmpty(lastManagerUserId))
			.set("lastManagerUser",TaskUtil.getTaskUser(String.valueOf(lastManagerUserId)));

		//开启流程
		if (isStartProcess) {
			String businessTable = FlowUtil.getBusinessTable(ProcessConstant.PURCHASE_ORDER_KEY);//获取表名
			R<BladeFlow> result = flowClient.startProcessInstanceById(bean.getProcessDefinitionId(), FlowUtil.getBusinessKey(businessTable, String.valueOf(bean.getId())), variables);
			if (result.isSuccess()) {
				log.debug("流程已启动,流程ID:" + result.getData().getProcessInstanceId());
				// 返回流程id写入leave
				bean.setProcessInstanceId(result.getData().getProcessInstanceId());
				updateById(bean);
			} else {
				throw new ServiceException("开启流程失败");
			}
		} else {
			//开启流程 TaskId ProcessInstanceId
			if(!Func.isEmpty(bean.getFlow())&&!Func.isEmpty(bean.getFlow().getTaskId())&&!Func.isEmpty(bean.getProcessInstanceId())){
				variables.put(ProcessConstant.PASS_KEY, true);
				flowClient.completeTask(bean.getFlow().getTaskId(),bean.getProcessInstanceId(),bean.getFlow().getComment(),variables);
			}
		}
		return true;
	}

/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.desk.management.service.impl;
import com.alibaba.fastjson.JSONObject;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.support.Kv;
import org.springblade.core.tool.utils.Func;
import org.springblade.desk.management.constant.AuthorityConstant;
import org.springblade.desk.management.entity.OaAuthorityManagement;
import org.springblade.desk.management.mapper.OaAuthorityManagementMapper;
import org.springblade.desk.management.service.IOaAuthorityManagementService;
import org.springblade.desk.service.impl.AdjustPriceDetailServiceImpl;
import org.springblade.desk.service.impl.OaSerialServiceImpl;
import org.springblade.desk.utils.DeptUserUtil;
import org.springblade.desk.utils.DeskUtil;
import org.springblade.flow.core.constant.ProcessConstant;
import org.springblade.flow.core.entity.BladeFlow;
import org.springblade.flow.core.feign.IFlowClient;
import org.springblade.flow.core.utils.FlowUtil;
import org.springblade.flow.core.utils.TaskUtil;
import org.springblade.system.user.entity.User;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
 * 权限申请单
 *
 * @author pei
 */
@Slf4j
@Service
@AllArgsConstructor
public class OaAuthorityManagementServiceImpl extends BaseServiceImpl<OaAuthorityManagementMapper, OaAuthorityManagement> implements IOaAuthorityManagementService {
	private IFlowClient flowClient;
	private OaSerialServiceImpl oaSerialService;
	private AdjustPriceDetailServiceImpl adjustPriceDetailServiceImpl;
	private DeptUserUtil deptUserUtil;
	@Override
	@Transactional(rollbackFor = Exception.class)
	public boolean startProcess(OaAuthorityManagement bean) {
		log.info("权限申请单开启流程bean============="+bean);
		//是否启动流程
		boolean isStartProcess = false;
		//是否新增数据
		boolean isAdd = false;
		if(bean!=null){
			if(Func.isEmpty(bean.getProcessInstanceId())){
				isStartProcess = true;
			}
			if(Func.isEmpty(bean.getId())){
				isAdd = true;
				bean.setTenantId(AuthUtil.getTenantId());
			}
			//更新业务数据
			if(isAdd){
				Date now = new Date();
				SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
				String dateStr = format.format(now);
				if(Func.isEmpty(bean.getAuthorityManagementNumber())){
					bean.setAuthorityManagementNumber(oaSerialService.getSerial(AuthUtil.getTenantId(),"OaAuthorityManagement",dateStr,dateStr,5));
				}
			}
			if(Func.isNotEmpty(bean.getObjIfo())){
				//将系统权限数据转换成string保存入库
				String str= JSONObject.toJSONString(bean.getObjIfo());
				bean.setApplicationSystemValue(str);
			}
			saveOrUpdate(bean);
		}

		Long curDeptId = DeskUtil.getCurDeptId(bean.getCreateDept());
		//获取主管
		Long managerUser=null;
		String roleId=deptUserUtil.getRoleId(AuthUtil.getTenantId(), "主管");
		List<User> users=deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),false,AuthUtil.getUserId());
		if(!Func.isEmpty(users)){
			managerUser=users.get(0).getId();
		}
		log.info("获取主管职位roleId====="+roleId+"------users========================"+users);
		//获取it部门审批人
		//1.根据部门名称获取部门id IT部
		String deptId= deptUserUtil.getDeptId(AuthUtil.getTenantId(),AuthorityConstant.IT_DEPT_NAME);
		String itRoleId=deptUserUtil.getRoleId(AuthUtil.getTenantId(), AuthorityConstant.IT_ROLE_NAME);
		List<User>itRoleUsers=deptUserUtil.getUserListByRoleIdAndDeptId(itRoleId,String.valueOf(deptId));
		log.info("获取it部门审批人itRoleUsers================="+itRoleUsers);
		Long itRoleManager=null;
		if(null!=itRoleUsers && itRoleUsers.size()>0){
			itRoleManager =itRoleUsers.get(0).getId();
		}
		boolean isManager = Func.isNotEmpty(AuthUtil.getUserRole())&&AuthUtil.getUserRole().contains("主管")?true:false;
		// 启动流程
		Kv variables =DeskUtil.createKV(curDeptId,"权限申请单",bean.getAuthorityManagementNumber(),bean.getApplicationSystem()+","+bean.getRemark(),isManager,bean.getCcUser(),bean.getCcUserName())
			.set("taskUser", TaskUtil.getTaskUser(AuthUtil.getUser().getUserId().toString()))
			.set("managerSkip", Func.isEmpty(managerUser))
			.set("managerUser",TaskUtil.getTaskUser(String.valueOf(managerUser==null ? "" : managerUser)))//主管
			.set("itRoleManager",AuthorityConstant.IT_ROLE_NAME);//IT审批人(角色名称）
		//启动流程 isStartProcess
		if (isStartProcess) {//先不开启流程
			String businessTable = FlowUtil.getBusinessTable(ProcessConstant.OA_AUTHORITY_MANAGEMENT);
			R<BladeFlow> result = flowClient.startProcessInstanceById(bean.getProcessDefinitionId(), FlowUtil.getBusinessKey(businessTable, String.valueOf(bean.getId())), variables);
			if (result.isSuccess()) {
				log.debug("流程已启动,流程ID:" + result.getData().getProcessInstanceId());
				// 返回流程id写入业务表中
				bean.setProcessInstanceId(result.getData().getProcessInstanceId());
				updateById(bean);
			} else {
				throw new ServiceException("开启流程失败");
			}
		}
		else{
			if(!Func.isEmpty(bean.getFlow())&&!Func.isEmpty(bean.getFlow().getTaskId())&&!Func.isEmpty(bean.getProcessInstanceId())){
				variables.put(ProcessConstant.PASS_KEY, true);
				flowClient.completeTask(bean.getFlow().getTaskId(),bean.getProcessInstanceId(),bean.getFlow().getComment(),variables);
			}
		}
		return true;
	}

}

package org.springblade.desk.management.constant;

/**
 * 2021-01-08
 */
public interface AuthorityConstant {
	/**
	 * 部门名称
	 */
	String IT_DEPT_NAME="IT部";
	/**
	 * IT部门角色
	 */
	String IT_ROLE_NAME="IT系统权限";

}