com.kdayun.z1.core.workflow.service

类 WorkFlowServiceImpl

java.lang.Object

com.kdayun.z1.core.workflow.service.WorkFlowServiceImpl

所有已实现的接口:

ManagerService

@Transactional(rollbackFor=java.lang.Exception.class)
 @Service
public class WorkFlowServiceImpl
extends java.lang.Object
implements ManagerService

工作流程管理

作者:

gk @date 2017-3-13 上午11:54:12

构造器概要

构造器

构造器和说明
WorkFlowServiceImpl()

方法概要

限定符和类型	方法和说明
void	addCopyUsers(java.lang.String processInstanceId, java.util.Collection<java.lang.String> copyUserIds) 增加抄送人
void	completeProcess(java.lang.String processInstanceId, java.lang.Class<?> classz, java.util.Map<java.lang.String,java.lang.Object> variables, java.lang.String confirm, java.util.Map<java.lang.String,WfItem> wfsetting, java.lang.Boolean goFirst, java.lang.Boolean getBack, java.lang.Boolean goPrv, java.lang.Boolean forceComplete) 完成流程
java.lang.String	completeProcess(java.lang.String processInstanceId, java.util.Map<java.lang.String,java.lang.Object> variables) 完成流程
java.lang.String	completeProcess(java.lang.String processInstanceId, java.util.Map<java.lang.String,java.lang.Object> variables, java.lang.Boolean goFirst, java.lang.Boolean getBack, java.lang.Boolean goPrv, java.lang.Boolean forceComplete) 完成流程
void	copyTo(java.util.List<java.lang.String> srcModelIds, java.util.List<java.lang.String> desDwIds) 机构之间的流程拷贝
void	deleteProcessInstanceByProcessInstanceId(java.lang.String processInstanceId, java.lang.String deleteReason) 删除流程实例
RetVo	deleteTaskByMap(java.util.Map<java.lang.String,java.lang.String> map, java.lang.String reason)
RetVo	deleteTaskByProcessInstanceId(java.util.List<java.lang.String> taskidlist, java.lang.String reason) 删除流程
void	depolyModel(java.io.File file) 通过文件更新文件,比对文件的版本号
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	findRunTaskByOrg(java.util.Map<java.lang.String,java.lang.Object> map) 查询机构工作流正在运行的实例
RetVo	forceCompleteProcessById(java.lang.String taskId) 结束当前的流程节点
java.lang.String	generateProcessId(java.lang.Class<?> clasz, java.util.Map<java.lang.String,WfItem> wfSettings) 生成流程标识 区分出个性化和通用的流程
java.util.List<ListernerVo>	getAllListeners() 获取所有的实现TaskListenerBase接口的策略类名
java.util.List<java.lang.String>	getNextTaskAssigees(java.lang.String processInstanceId, java.util.Map<java.lang.String,java.lang.Object> variables) 得到下一个节点的参与者 注意这个函数存在弊端就是某些复杂流程无法获取下一个节点,只适用简单
static CoreOrgService	getOrgService()
java.lang.String	getProcessKey(java.lang.String key) 获取流程key
java.lang.String	getProcessKey(java.lang.String key, java.lang.String orgid) 查找个性流程key，无则返回通用流程key
java.lang.String	getProcessKeyByFunctionId(java.lang.String functionId) 通过功能id获取流程key 缓存管理
com.kdayun.workflow.engine.impl.persistence.entity.ModelEntity	getProcessModelByFunctionId(java.lang.String functionId) 通过功能id获取流程实体
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	getTaskAudRightByProcessId(java.lang.String processInstanceId) 得到流程当前的待处理节点资源权限
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	getTaskAudRightByTaskId(java.lang.String taskId) 得到指定 TaskId节点id的待处理节点资源权限
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	getTaskFormDatasByProcessId(java.lang.String processInstanceId) 获取流程待处理的from存储的信息
java.util.Map<java.lang.String,java.lang.String>	getWorkFlowDatas(java.lang.String processInstanceId)
java.util.List<Workflowlog>	getWorkLogbyProcessInstanceId(java.lang.String processInstanceId) 获取流程实例的流程日志
java.lang.String	goFirst(java.lang.String processInstanceId, java.util.Map<java.lang.String,java.lang.Object> variables) 退回流程(返回到发起者)
void	init() 初始化
void	setComment(java.lang.String processInstanceId, java.lang.String commet) 设置流程是实例的备注
void	setCopyUserState(java.lang.String[] processInstanceIds, java.lang.String wfUserId, java.lang.String comment) 设置抄送为已读状态
void	setCopyUserStateByCurrentUser(java.lang.String[] processInstanceIds, java.lang.String comment) 设置抄送为已读状态
java.lang.String	startProcess(java.lang.String processIndentifier) 启动流程 无任何参数,businessKey默认与流程标识一致
java.lang.String	startProcess(java.lang.String processIndentifier, java.util.Map<java.lang.String,java.lang.Object> variables) 启动流程
java.lang.String	startProcess(java.lang.String processIndentifier, java.lang.String businessKey, java.util.Map<java.lang.String,java.lang.Object> variables) 启动流程
java.lang.String	startProcess(java.lang.String processIndentifier, java.lang.String businessKey, java.util.Map<java.lang.String,java.lang.Object> variables, java.lang.Boolean autoComplete) 启动流程
java.lang.String	startProcessByFunctionId(java.lang.String functionId, java.util.Map<java.lang.String,java.lang.Object> variables) 通过功能Id启动流程
java.lang.String	startProcessByMenuId(java.lang.String menuId, java.util.Map<java.lang.String,java.lang.Object> variables) 通过菜单ID启动流程
void	unInit() 结束

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

WorkFlowServiceImpl

public WorkFlowServiceImpl()

方法详细资料

init

public void init()

从接口复制的说明: ManagerService

初始化

指定者:

init 在接口中 ManagerService

getOrgService

public static CoreOrgService getOrgService()

generateProcessId

public java.lang.String generateProcessId(java.lang.Class<?> clasz,
                                          java.util.Map<java.lang.String,WfItem> wfSettings)

生成流程标识 区分出个性化和通用的流程

参数:

clasz - 类型

wfSettings - 设置

返回:

流程key

getProcessKey

public java.lang.String getProcessKey(java.lang.String key)

获取流程key

参数:

key - 流程的唯一key

返回:

流程key

date:

2021年2月20日 下午3:14:32

getProcessKey

public java.lang.String getProcessKey(java.lang.String key,
                                      java.lang.String orgid)

查找个性流程key，无则返回通用流程key

参数:

key - 流程的唯一key

orgid - 机构id

返回:

流程key

date:

2021年2月20日 下午3:15:35

unInit

public void unInit()

从接口复制的说明: ManagerService

结束

指定者:

unInit 在接口中 ManagerService

startProcess

public java.lang.String startProcess(java.lang.String processIndentifier)

启动流程 无任何参数,businessKey默认与流程标识一致

参数:

processIndentifier - 流程实例id

返回:

流程实例id

startProcess

public java.lang.String startProcess(java.lang.String processIndentifier,
                                     java.lang.String businessKey,
                                     java.util.Map<java.lang.String,java.lang.Object> variables)
                              throws java.lang.Exception

启动流程

参数:

processIndentifier - 流程标识

businessKey - 流程key

variables - 流程变量

返回:

流程实例id

抛出:

java.lang.Exception - 出错会抛出异常

startProcess

public java.lang.String startProcess(java.lang.String processIndentifier,
                                     java.util.Map<java.lang.String,java.lang.Object> variables)
                              throws java.lang.Exception

启动流程

参数:

processIndentifier - 流程标识

variables - 流程变量

返回:

流程实例id

抛出:

java.lang.Exception - 出错会抛出异常

startProcessByMenuId

public java.lang.String startProcessByMenuId(java.lang.String menuId,
                                             java.util.Map<java.lang.String,java.lang.Object> variables)
                                      throws java.lang.Exception

通过菜单ID启动流程

参数:

menuId - 表单ID

variables - 启动流程传递的参数

返回:

流程实例Id

抛出:

java.lang.Exception - 出错会抛出异常

startProcess

public java.lang.String startProcess(java.lang.String processIndentifier,
                                     java.lang.String businessKey,
                                     java.util.Map<java.lang.String,java.lang.Object> variables,
                                     java.lang.Boolean autoComplete)
                              throws java.lang.Exception

启动流程

参数:

processIndentifier - 流程唯一id

businessKey - 业务key

variables - 流程变量

autoComplete - 首节点是否自动结束

返回:

流程实例id

抛出:

java.lang.Exception - 出错会抛出异常

startProcessByFunctionId

public java.lang.String startProcessByFunctionId(java.lang.String functionId,
                                                 java.util.Map<java.lang.String,java.lang.Object> variables)
                                          throws java.lang.Exception

通过功能Id启动流程

参数:

functionId - 功能资源id

variables - 流程变量Map

返回:

流程实例id

抛出:

java.lang.Exception - 出错会抛出异常

getProcessKeyByFunctionId

public java.lang.String getProcessKeyByFunctionId(java.lang.String functionId)

通过功能id获取流程key 缓存管理

参数:

functionId - 功能资源id

返回:

返回null 就失败，否则返回流程的key

getProcessModelByFunctionId

public com.kdayun.workflow.engine.impl.persistence.entity.ModelEntity getProcessModelByFunctionId(java.lang.String functionId)

通过功能id获取流程实体

参数:

functionId - 功能资源id

返回:

返回null 就失败，否则返回流程定义实体

completeProcess

public java.lang.String completeProcess(java.lang.String processInstanceId,
                                        java.util.Map<java.lang.String,java.lang.Object> variables)
                                 throws java.lang.Exception

完成流程

参数:

processInstanceId - 流程实例id

variables - 流程变量 Map

返回:

null

抛出:

java.lang.Exception - 出错会抛出异常

goFirst

public java.lang.String goFirst(java.lang.String processInstanceId,
                                java.util.Map<java.lang.String,java.lang.Object> variables)
                         throws java.lang.Exception

退回流程(返回到发起者)

参数:

processInstanceId - 流程实例id

variables - 流程变量

返回:

任务id

抛出:

java.lang.Exception - 出错会抛出异常

completeProcess

public java.lang.String completeProcess(java.lang.String processInstanceId,
                                        java.util.Map<java.lang.String,java.lang.Object> variables,
                                        java.lang.Boolean goFirst,
                                        java.lang.Boolean getBack,
                                        java.lang.Boolean goPrv,
                                        java.lang.Boolean forceComplete)
                                 throws java.lang.Exception

完成流程

参数:

processInstanceId - 流程实例id

variables - 流程变量

goFirst - 退到底

getBack - 是否取回

goPrv - 原路返回

forceComplete - 强制完成流程

返回:

任务id

抛出:

java.lang.Exception - 出错会抛出异常

completeProcess

public void completeProcess(java.lang.String processInstanceId,
                            java.lang.Class<?> classz,
                            java.util.Map<java.lang.String,java.lang.Object> variables,
                            java.lang.String confirm,
                            java.util.Map<java.lang.String,WfItem> wfsetting,
                            java.lang.Boolean goFirst,
                            java.lang.Boolean getBack,
                            java.lang.Boolean goPrv,
                            java.lang.Boolean forceComplete)
                     throws java.lang.Exception

完成流程

参数:

processInstanceId - 流程实例id

classz - 对应的流程类

variables - 流程变量集合

confirm - 审核的变量标识

wfsetting - 流程的审核设置

goFirst - 是否退回

getBack - 是否取回

goPrv - 原路返回

forceComplete - 强制完成任务无需校验任务的参与者是否本人

抛出:

java.lang.Exception - 出错会抛出异常

getWorkLogbyProcessInstanceId

public java.util.List<Workflowlog> getWorkLogbyProcessInstanceId(java.lang.String processInstanceId)
                                                          throws java.io.UnsupportedEncodingException

获取流程实例的流程日志

参数:

processInstanceId - 流程实例id

返回:

流程日志List

抛出:

java.io.UnsupportedEncodingException - 出错会抛出异常

deleteProcessInstanceByProcessInstanceId

public void deleteProcessInstanceByProcessInstanceId(java.lang.String processInstanceId,
                                                     java.lang.String deleteReason)
                                              throws java.lang.Exception

删除流程实例

参数:

processInstanceId - 流程实例id

deleteReason - 删除原因

抛出:

java.lang.Exception - 出错会抛出异常

setComment

public void setComment(java.lang.String processInstanceId,
                       java.lang.String commet)

设置流程是实例的备注

参数:

processInstanceId - 流程实例id

commet - 备注

getAllListeners

public java.util.List<ListernerVo> getAllListeners()
                                            throws java.lang.Exception

获取所有的实现TaskListenerBase接口的策略类名

返回:

实现的TaskListenerBase接口的策略类List

抛出:

java.lang.Exception - 出错抛出异常

copyTo

public void copyTo(java.util.List<java.lang.String> srcModelIds,
                   java.util.List<java.lang.String> desDwIds)
            throws java.lang.Exception

机构之间的流程拷贝

参数:

srcModelIds - 源modelid集合

desDwIds - 目标机构id集合,以逗号隔开的

抛出:

java.lang.Exception - 出错会抛出异常

depolyModel

public void depolyModel(java.io.File file)

通过文件更新文件,比对文件的版本号

参数:

file - 文件对象

getTaskFormDatasByProcessId

public java.util.List<java.util.Map<java.lang.String,java.lang.String>> getTaskFormDatasByProcessId(java.lang.String processInstanceId)

获取流程待处理的from存储的信息

参数:

processInstanceId - 流程实例ID

返回:

from存储的信息List

getTaskAudRightByTaskId

public java.util.List<java.util.Map<java.lang.String,java.lang.String>> getTaskAudRightByTaskId(java.lang.String taskId)

得到指定 TaskId节点id的待处理节点资源权限

参数:

taskId - 任务id

返回:

map如 { canTuih: true , canQuh : false ,canSongs : true ,canTongy : true ....}

getTaskAudRightByProcessId

public java.util.List<java.util.Map<java.lang.String,java.lang.String>> getTaskAudRightByProcessId(java.lang.String processInstanceId)

得到流程当前的待处理节点资源权限

参数:

processInstanceId - 流程实例id

返回:

map如 { canTuih: true , canQuh : false ,canSongs : true ,canTongy : true ....}

getWorkFlowDatas

public java.util.Map<java.lang.String,java.lang.String> getWorkFlowDatas(java.lang.String processInstanceId)

findRunTaskByOrg

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> findRunTaskByOrg(java.util.Map<java.lang.String,java.lang.Object> map)

查询机构工作流正在运行的实例

参数:

map - USERID 用户id (模糊);KEYVALUE 查询值(模糊); ORGID 机构id (模糊)

返回:

正在运行的map

date:

2018年9月30日 下午5:47:00

forceCompleteProcessById

public RetVo forceCompleteProcessById(java.lang.String taskId)

结束当前的流程节点

参数:

taskId - 任务id

返回:

处理的RetVo

date:

2018年10月11日 上午10:19:06

deleteTaskByProcessInstanceId

public RetVo deleteTaskByProcessInstanceId(java.util.List<java.lang.String> taskidlist,
                                           java.lang.String reason)
                                    throws java.lang.Exception

删除流程

参数:

taskidlist - 任务 List

reason - 原因

返回:

处理的RetVo

抛出:

java.lang.Exception - 出错会抛出异常

date:

2018年10月11日 上午10:24:45

deleteTaskByMap

@Transactional(rollbackFor=java.lang.Exception.class)
public RetVo deleteTaskByMap(java.util.Map<java.lang.String,java.lang.String> map,
                                                                                    java.lang.String reason)
                                                                             throws java.lang.Exception

抛出:

java.lang.Exception

getNextTaskAssigees

public java.util.List<java.lang.String> getNextTaskAssigees(java.lang.String processInstanceId,
                                                            java.util.Map<java.lang.String,java.lang.Object> variables)
                                                     throws java.lang.Exception

得到下一个节点的参与者 注意这个函数存在弊端就是某些复杂流程无法获取下一个节点,只适用简单

参数:

processInstanceId - 流程实例id

variables - 流程变量Map

返回:

参与者List

抛出:

java.lang.Exception - 出错会抛出异常

setCopyUserState

public void setCopyUserState(java.lang.String[] processInstanceIds,
                             java.lang.String wfUserId,
                             java.lang.String comment)

设置抄送为已读状态

参数:

processInstanceId - 流程实例id

wfUserId - 流程用户ID

comment - 备注

setCopyUserStateByCurrentUser

public void setCopyUserStateByCurrentUser(java.lang.String[] processInstanceIds,
                                          java.lang.String comment)
                                   throws java.lang.Exception

设置抄送为已读状态

参数:

processInstanceId - 流程实例id

comment - 备注

抛出:

java.lang.Exception - 出错会抛出异常

addCopyUsers

public void addCopyUsers(java.lang.String processInstanceId,
                         java.util.Collection<java.lang.String> copyUserIds)
                  throws java.lang.Exception

增加抄送人

参数:

processInstanceId - 流程实例id

copyUserIds - 流程用户ID

抛出:

java.lang.Exception - 出错会抛出异常