格式化代码

ibzwf-core/src/main/java/cn/ibizlab/core/workflow/extensions/service/WFCoreService.java

@@ -37,12 +37,14 @@ import org.flowable.engine.repository.DeploymentBuilder;
 import org.flowable.engine.runtime.ProcessInstance;
 import org.flowable.engine.task.Comment;
 import org.flowable.identitylink.api.IdentityLink;
+import org.flowable.idm.api.User;
 import org.flowable.task.api.DelegationState;
 import org.flowable.task.api.Task;
 import org.flowable.task.api.TaskQuery;
 import org.flowable.task.api.history.HistoricTaskInstance;
 import org.flowable.task.service.impl.persistence.entity.HistoricTaskInstanceEntity;
 import org.flowable.task.service.impl.persistence.entity.TaskEntity;
+import org.flowable.task.service.impl.persistence.entity.TaskEntityImpl;
 import org.flowable.ui.common.security.SecurityUtils;
 import org.flowable.ui.modeler.domain.AbstractModel;
 import org.flowable.ui.modeler.domain.AppModelDefinition;
@@ -1946,6 +1948,25 @@ public class WFCoreService
 		}
 	}
 
+	/**
+	 * @param taskId 当前taskId
+	 * @param delegateUser 被委托人
+	 * @return
+	 */
+	public boolean delegateTask(String taskId,String delegateUser) {
+
+		TaskEntityImpl currTask = (TaskEntityImpl) taskService.createTaskQuery().taskId(taskId).singleResult();
+		if (currTask != null) {
+			User currUser = SecurityUtils.getCurrentUserObject();
+			// 设置审批人是当前登录人
+			taskService.setAssignee(taskId, currUser.getId());
+			// 执行委派
+			taskService.delegateTask(taskId,delegateUser);
+			return true;
+		}
+		return false;
+	}
+
 	/**
 	 * @param taskId 当前需要回退的节点
 	 * @return 回退上一个节点
@@ -1962,13 +1983,19 @@ public class WFCoreService
 			log.debug("processInstanceId不存在");
 			return false;
 		}
-		List<HistoricTaskInstance> history = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).orderByHistoricTaskInstanceEndTime().desc().list();
-		if(ObjectUtils.isEmpty(history)){
-			throw new BadRequestAlertException("暂无流程数据","WFCoreService","sendBack");
+		List<HistoricTaskInstance> history = historyService.createHistoricTaskInstanceQuery()
+				.processInstanceId(processInstanceId)
+				.orderByHistoricTaskInstanceEndTime()
+				.desc()
+				.list();
+		if(history.size() > 0){
+			HistoricTaskInstance sourceRef = history.get(0);
+			// 执行回退
+			runtimeService.createChangeActivityStateBuilder()
+					.processInstanceId(processInstanceId)
+					.moveActivityIdTo(taskDefinitionKey, sourceRef.getTaskDefinitionKey())
+					.changeState();
 		}
-		HistoricTaskInstance sourceRef = history.get(0);
-		// 执行回退
-		runtimeService.createChangeActivityStateBuilder().processInstanceId(processInstanceId).moveActivityIdTo(taskDefinitionKey, sourceRef.getTaskDefinitionKey()).changeState();
 		return true;
 	}
 }