| | |
|---|
| | | task.setTaskDefinitionKey(currentTask.getTaskDefinitionKey()); |
|---|
| | | task.setPriority(currentTask.getPriority()); |
|---|
| | | task.setCreateTime(new Date()); |
|---|
| | | if (TenantHelper.isEnable()) { |
|---|
| | | task.setTenantId(TenantHelper.getTenantId()); |
|---|
| | | } |
|---|
| | | task.setTenantId(TenantHelper.getTenantId()); |
|---|
| | | PROCESS_ENGINE.getTaskService().saveTask(task); |
|---|
| | | } |
|---|
| | | if (ObjectUtil.isNotNull(task)) { |
|---|
| | |
|---|
| | | actHiTaskinst.setProcDefId(processDefinitionId); |
|---|
| | | actHiTaskinst.setProcInstId(processInstanceId); |
|---|
| | | actHiTaskinst.setScopeType(TaskStatusEnum.COPY.getStatus()); |
|---|
| | | if (TenantHelper.isEnable()) { |
|---|
| | | actHiTaskinst.setTenantId(TenantHelper.getTenantId()); |
|---|
| | | } |
|---|
| | | actHiTaskinst.setTenantId(TenantHelper.getTenantId()); |
|---|
| | | LambdaUpdateWrapper<ActHiTaskinst> updateWrapper = new LambdaUpdateWrapper<>(); |
|---|
| | | updateWrapper.in(ActHiTaskinst::getId, taskIds); |
|---|
| | | ACT_HI_TASKINST_MAPPER.update(actHiTaskinst, updateWrapper); |
|---|
| | |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | List<HistoricIdentityLink> candidateList = StreamUtils.filter(linksForTask, e -> FlowConstant.CANDIDATE.equals(e.getType())); |
|---|
| | | List<Long> userIdList = new ArrayList<>(); |
|---|
| | | for (HistoricIdentityLink historicIdentityLink : linksForTask) { |
|---|
| | | try { |
|---|
| | | userIdList.add(Long.valueOf(historicIdentityLink.getUserId())); |
|---|
| | | } catch (NumberFormatException ignored) { |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | List<Long> userIdList = StreamUtils.toList(linksForTask, e -> Long.valueOf(e.getUserId())); |
|---|
| | | List<SysUserVo> sysUsers = WORKFLOW_USER_SERVICE.getUserListByIds(userIdList); |
|---|
| | | if (CollUtil.isNotEmpty(sysUsers)) { |
|---|
| | | List<Long> userIds = StreamUtils.toList(sysUsers, SysUserVo::getUserId); |
|---|
