首页 / 更多教程 / //多实例任务节点完成条件
//多实例任务节点完成条件
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了//多实例任务节点完成条件，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含17070字，纯文字阅读大概需要25分钟。
内容图文
package org.springblade.flow.engine.listener.common;
import org.flowable.engine.delegate.DelegateExecution;
import org.springframework.stereotype.Component;
import java.io.Serializable;
//多实例任务节点完成条件
@Component("multiInstance")
public class MultiInstance implements Serializable {
/**
* 一票否决
* 1、如果有驳回操作，则驳回当前任务节点。
* 2、若已审批人数不等于总人数，则多实例任务继续执行
* 3、若已审批人数等于总人数，则结束当前任务节点，进入下一个任务节点。
* @param execution 分配执行实例
*/
public boolean vetoPower(DelegateExecution execution) {
return vetoPower(execution,"pass");
}
public boolean vetoPower(DelegateExecution execution,String agreeFlagText){
//已完成的实例数
int completedInstance = (int) execution.getVariable("nrOfCompletedInstances");
//总实例数
int nrOfInstances = (int) execution.getVariable("nrOfInstances");
//否决判断，一票否决
if (execution.getVariable(agreeFlagText) != null) {
boolean pass = (boolean) execution.getVariable(agreeFlagText);
if (!pass) {
//输出方向为拒绝
//一票否决其他实例没必要做，结束
return true;
}
}
//所有实例任务未全部做完则继续其他实例任务
if (completedInstance != nrOfInstances) {
return false;
} else {
//输出方向为赞同
//所有都做完了没被否决，结束
return true;
}
}
/**
* 一票否决 + 少数服从多数
* 1、如果有驳回操作，则驳回当前任务节点。
* 2、若同意人数比例大于等于0.5，则结束当前任务节点，进入下一个任务节点。
* 3、若不同意人数比例大于0.5，则驳回当前任务节点。
* 4、否则多实例任务继续执行
* @param execution
* @return
*/
public boolean vetoPowerAndObeyMost(DelegateExecution execution) {
return vetoPowerAndObeyMost(execution,"pass","rejectCount","agreeCount",0.5d);
}
public boolean vetoPowerAndObeyMost(DelegateExecution execution,String agreeFlagText,String rejectCountText,String agreeCountText,double agreeRate) {
//否决判断，一票否决
if (execution.getVariable(agreeFlagText) != null) {
boolean pass = (boolean) execution.getVariable(agreeFlagText);
if (!pass) {
//输出方向为拒绝
//一票否决其他实例没必要做，结束
return true;
}
}
//已完成的实例数
int completedInstance = (int) execution.getVariable("nrOfCompletedInstances");
//总实例数
int nrOfInstances = (int) execution.getVariable("nrOfInstances");
//获取不同意的次数
int rejectCount = (int)execution.getVariable(rejectCountText);
//获取同意人的次数
int agreeCount = (int)execution.getVariable(agreeCountText);
//所有实例任务未全部做完则继续其他实例任务
if (completedInstance != nrOfInstances) {
//不同意的人数大于设置比例*总人数
if (rejectCount*1.00/nrOfInstances>(1-agreeRate)){
execution.setVariable(agreeFlagText, false);
return true;
}
if (agreeCount*1.00/nrOfInstances>=agreeRate){
execution.setVariable(agreeFlagText, true);
return true;
}
return false;
} else {
//输出方向为赞同
//所有都做完了没被否决，结束
return true;
}
}
/**
* 少数服从多数
* 1、若同意人数比例大于等于0.5，则结束当前任务节点，进入下一个任务节点。
* 2、若不同意人数比例大于0.5，则驳回当前任务节点。
* 3、否则多实例任务继续执行
* @param execution
* @return
*/
public boolean obeyMost(DelegateExecution execution) {
return obeyMost(execution,"pass","rejectCount","agreeCount",0.5);
}
public boolean obeyMost(DelegateExecution execution,String agreeFlagText,String rejectCountText,String agreeCountText,double agreeRate) {
//已完成的实例数
int completedInstance = (int) execution.getVariable("nrOfCompletedInstances");
//总实例数
int nrOfInstances = (int) execution.getVariable("nrOfInstances");
//获取不同意的次数
int rejectCount = (int)execution.getVariable(rejectCountText);
//获取同意人的次数
int agreeCount = (int)execution.getVariable(agreeCountText);
//所有实例任务未全部做完则继续其他实例任务
if (completedInstance != nrOfInstances) {
//不同意的人数大于设置比例*总人数
if (rejectCount*1.00/nrOfInstances>(1-agreeRate)){
execution.setVariable(agreeFlagText, false);
return true;
}
if (agreeCount*1.00/nrOfInstances>=agreeRate){
execution.setVariable(agreeFlagText, true);
return true;
}
return false;
} else {
//不同意的人数大于设置比例*总人数
if (rejectCount*1.00/nrOfInstances>(1-agreeRate)){
execution.setVariable(agreeFlagText, false);
return true;
}
if (agreeCount*1.00/nrOfInstances>=agreeRate){
execution.setVariable(agreeFlagText, true);
return true;
}
return true;
}
}
public boolean test(DelegateExecution execution,int i,String a){
System.out.println("===========i====="+i);
System.out.println("===========a====="+a);
return false;
}
}
/*
* 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.service.impl;
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.mp.support.Condition;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.support.Kv;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.desk.entity.PurchaseRequest;
import org.springblade.desk.entity.PurchaseRequestLine;
import org.springblade.desk.entity.SapFormInfo;
import org.springblade.desk.mapper.PurchaseRequestMapper;
import org.springblade.desk.service.IPurchaseRequestService;
import org.springblade.desk.service.ISapFormInfoService;
import org.springblade.desk.utils.DeptUserUtil;
import org.springblade.desk.utils.DeskUtil;
import org.springblade.desk.vo.PurchaseRequestVO;
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.entity.Dept;
import org.springblade.system.user.entity.User;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
/**
* 服务实现类
*
* @author Chill
*/
@Slf4j
@Service
@AllArgsConstructor
public class PurchaseRequestServiceImpl extends BaseServiceImpl<PurchaseRequestMapper, PurchaseRequest> implements IPurchaseRequestService {
private IFlowClient flowClient;
private PurchaseRequestLineServiceImpl lineService;
private DeptUserUtil deptUserUtil;
private OaSerialServiceImpl oaSerialService;
private OaAttachmentServiceImpl oaAttachmentService;
private ISapFormInfoService infoService;
@Override
@Transactional(rollbackFor = Exception.class)
// @GlobalTransactional
public boolean startProcess(PurchaseRequest bean) {
//是否启动流程
boolean isStartProcess = false;
//是否新增数据
boolean isAdd = false;
String tenantId = "000000";
if(!Func.isEmpty(AuthUtil.getTenantId())){
tenantId = AuthUtil.getTenantId();
}
if(bean!=null){
if(Func.isEmpty(bean.getProcessInstanceId())){
isStartProcess = true;
}
if(Func.isEmpty(bean.getId())){
isAdd = true;
}
//更新业务数据
if(bean.getApplyTime()==null){
bean.setApplyTime(DateUtil.now());
}
if(isStartProcess){
Date now = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
String dateStr = format.format(now);
bean.setOrderCode(oaSerialService.getSerial(Func.toStr(AuthUtil.getTenantId(),"000000"),"purchaseRequest",dateStr,dateStr,5));
}
saveOrUpdate(bean);
PurchaseRequestLine lineEntity = new PurchaseRequestLine();
lineEntity.setPurchaseRequestId(bean.getId());
lineService.remove(Condition.getQueryWrapper(lineEntity));
if(bean.getLineList()!=null&&!bean.getLineList().isEmpty()){
List<PurchaseRequestLine> list = new ArrayList<>();
for(PurchaseRequestLine line : bean.getLineList()){
line.setPurchaseRequestId(bean.getId());
line.setNotUsedQuantity(line.getQuantity());
line.setUsedQuantity(new BigDecimal(0));
line.setTenantId(tenantId);
list.add(line);
//lineService.saveOrUpdate(line);
}
if(!Func.isNull(list)){
lineService.saveOrUpdateBatch(list);
}
}
//更新附件信息
oaAttachmentService.saveOrUpdateOaAttachment(bean.getAttachments(),bean.getId(),bean.getProcessInstanceId(),bean.getTenantId(),"purchaseRequest");
}
Long curDeptId = DeskUtil.getCurDeptId(bean.getCreateDept());
/*
//经理
String roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(),"经理");
List<User> users = deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),true,AuthUtil.getUserId());
Long managerUserId = Func.isEmpty(users)?null:users.get(0).getId();
//总监
roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(),"总监");
users = deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),true,AuthUtil.getUserId());
Long directorUserId = Func.isEmpty(users)?null:users.get(0).getId();
//总经理
roleId =deptUserUtil.getRoleId(AuthUtil.getTenantId(),"总经理");
users = deptUserUtil.getUserListByRoleIdAndDeptId(roleId,String.valueOf(curDeptId),true,AuthUtil.getUserId());
Long presidentId = Func.isEmpty(users)?null:users.get(0).getId();
//采购主管
Long purchaseManagerUserId ;
if("茶叶".equals(bean.getType())){
roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(), "采购主管(茶叶)");
}
else{
roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(), "采购主管(其他)");
}
users = deptUserUtil.getUserListByRoleId(roleId);
purchaseManagerUserId = (users.isEmpty() ||users==null)?null:users.get(0).getId() ;
//IT采购人员
roleId = deptUserUtil.getRoleId(AuthUtil.getTenantId(), "IT(采购申请)");
users = deptUserUtil.getUserListByRoleId(roleId);
Long internetUserId = (users.isEmpty() ||users==null)?null:users.get(0).getId() ;
//上级主管
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();
}
*/
//总经理
String presidentRoleId =deptUserUtil.getRoleId(tenantId,"总经理");
List<User> users = deptUserUtil.getUserListByRoleIdAndDeptId(presidentRoleId,String.valueOf(curDeptId),true,AuthUtil.getUserId());
Long presidentId = Func.isEmpty(users)?null:users.get(0).getId();
//上级主管
String roleId = deptUserUtil.getRoleId(tenantId,"主管");
boolean isManager = Func.isNotEmpty(AuthUtil.getUserRole())&&AuthUtil.getUserRole().contains("主管")?true:false;
users = deptUserUtil.getUserListByRoleIdAndUntilRoleIdAndDeptId(roleId,presidentRoleId,String.valueOf(curDeptId),true);
List<String> managerUser = new ArrayList<>();
for (User u: users ) {
if(!AuthUtil.getUserId().equals(u.getId()) ){
managerUser.add(TaskUtil.getTaskUser(String.valueOf(u.getId())));
}
}
// 启动流程
Kv variables =DeskUtil.createKV(curDeptId,"采购申请",bean.getOrderCode(),bean.getOrigin(),isManager,bean.getCcUser(),bean.getCcUserName())
.set("type",bean.getType())
.set("managerSkip",Func.isEmpty(managerUser))
.set("managerUser",managerUser)
.set("presidentSkip",Func.isEmpty(presidentId))
.set("presidentUser",TaskUtil.getTaskUser(String.valueOf(presidentId)))
/*
.set("managerSkip",Func.isNull(managerUserId))
.set("managerUser",TaskUtil.getTaskUser(String.valueOf(managerUserId)))
.set("directorSkip",Func.isNull(directorUserId))
.set("directorUser",TaskUtil.getTaskUser(String.valueOf(directorUserId)))
.set("presidentSkip",Func.isEmpty(presidentId))
.set("presidentUser",TaskUtil.getTaskUser(String.valueOf(presidentId)))
.set("purchaseManagerSkip",Func.isEmpty(purchaseManagerUserId))
.set("purchaseManagerUser",TaskUtil.getTaskUser(String.valueOf(purchaseManagerUserId)))
.set("purchaseSkip",Func.isEmpty(bean.getPurchaseUser()))
.set("purchaseUser",TaskUtil.getTaskUser(String.valueOf(bean.getPurchaseUser())))
.set("internetSkip",Func.isEmpty(internetUserId))
.set("internetUser",TaskUtil.getTaskUser(String.valueOf(internetUserId)))
.set("lastManagerSkip",Func.isEmpty(lastManagerUserId))
.set("lastManagerUser",TaskUtil.getTaskUser(String.valueOf(lastManagerUserId)))
*/ ;
//启动流程
if (isStartProcess) {
String businessTable = FlowUtil.getBusinessTable(ProcessConstant.PURCHASE_REQUEST_KEY);
R<BladeFlow> result = new R<>();
if(Func.isEmpty(AuthUtil.getUserId()) || AuthUtil.getUserId() == -1L ){
String processDefinitionId = "";
SapFormInfo SapFormInfo = new SapFormInfo();
SapFormInfo.setName("采购申请单");
SapFormInfo.setIsEnable(1);
List<SapFormInfo> infoList = infoService.list(Condition.getQueryWrapper(SapFormInfo)) ;
if(infoList!=null && infoList.size() > 0 ){
processDefinitionId = infoList.get(0).getProcessDefinitionId() ;
}
result = flowClient.startProcessInstanceByIdDing( !Func.isEmpty(processDefinitionId) ? processDefinitionId: bean.getProcessDefinitionId() ,
FlowUtil.getBusinessKey(businessTable, String.valueOf(bean.getId())),
String.valueOf(bean.getCreateUser()),variables);
}
else{
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(),Func.toStr(bean.getFlow().getComment(),ProcessConstant.PASS_COMMENT),variables);
}
}
return true;
}
@Override
@Transactional(rollbackFor = Exception.class)
// @GlobalTransactional
public boolean saveDraft(PurchaseRequest bean) {
//是否新增数据
boolean isAdd = false;
if(bean!=null){
if(Func.isEmpty(bean.getId())){
isAdd = true;
}
//更新业务数据
saveOrUpdate(bean);
PurchaseRequestLine lineEntity = new PurchaseRequestLine();
lineEntity.setPurchaseRequestId(bean.getId());
lineService.remove(Condition.getQueryWrapper(lineEntity));
if(bean.getLineList()!=null&&!bean.getLineList().isEmpty()){
for(PurchaseRequestLine line : bean.getLineList()){
line.setPurchaseRequestId(bean.getId());
line.setNotUsedQuantity(line.getQuantity());
line.setUsedQuantity(new BigDecimal(0));
lineService.saveOrUpdate(line);
}
}
//更新附件信息
oaAttachmentService.saveOrUpdateOaAttachment(bean.getAttachments(),bean.getId(),bean.getProcessInstanceId(),bean.getTenantId(),"purchaseRequest");
}
return true;
}
/**
* 获取草稿列表
*/
@Override
public List<PurchaseRequest> getDraftList(PurchaseRequest bean){
bean.setTenantId(AuthUtil.getTenantId());
return baseMapper.getDraftList(bean);
};
/**
* 列表搜索
* @param bean
* @return
*/
@Override
public List<PurchaseRequestVO> search(PurchaseRequestVO bean){
bean.setTenantId(AuthUtil.getTenantId());
return baseMapper.search(bean);
}
/**
* 同意任务
* @param flow
* @return
*/
@Override
public boolean completeTask(BladeFlow flow,PurchaseRequest bean) {
String taskId = flow.getTaskId();
String processInstanceId = flow.getProcessInstanceId();
String comment = Func.toStr(flow.getComment(), ProcessConstant.PASS_COMMENT);
// 创建变量
Map<String, Object> variables = flow.getVariables();
if (variables == null) {
variables = Kv.create();
}
variables.put(ProcessConstant.PASS_KEY, flow.isPass());
if("purchaseManagerTask".equals(flow.getTaskDefinitionKey())){
PurchaseRequest entity = new PurchaseRequest();
entity.setId( bean.getId());
entity.setPurchaseUser(bean.getPurchaseUser());
entity.setPurchaseUserName(bean.getPurchaseUserName());
updateById(entity);
variables.put("purchaseSkip",Func.isEmpty(bean.getPurchaseUser()));
variables.put("purchaseUser",TaskUtil.getTaskUser(String.valueOf(bean.getPurchaseUser())));
}
flowClient.completeTask(taskId,processInstanceId,comment,variables);
return true;
}
/**
* 获取流程任务信息
* @param taskUser 当前流程用户
* @param processInstanceId 流程实例id
*/
public BladeFlow taskInfo(String taskUser,String processInstanceId){
R<BladeFlow> rFlow = flowClient.taskInfo(taskUser,processInstanceId);
if(rFlow!=null){
return rFlow.getData();
}
return null;
}
/**
* 作废任务
* @param businessId
* @param processInstanceId
* @param reason 作废原因
* @return
*/
@Override
@Transactional(rollbackFor = Exception.class)
public boolean cancellation(String businessId, String processInstanceId, String reason) {
log.info("采购申请单作废businessId===="+businessId+"--processInstanceId===="+processInstanceId+"---reason==="+reason);
boolean flag=removeById(Long.valueOf(businessId));
log.info("flag======"+flag);
if(flag){
flag=flowClient.deleteTask(processInstanceId,reason).isSuccess();
}else {
flag=false;
}
return flag;
}
}
内容总结
以上是互联网集市为您收集整理的//多实例任务节点完成条件全部内容，希望文章能够帮你解决//多实例任务节点完成条件所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】