终止流程

operation_manager/src/main/java/com/huaxu/process/activiti/Service/ProgressSevice.java

@@ -45,8 +45,12 @@ public class ProgressSevice  implements JavaDelegate{
         String value = (String) expression.getValue(delegateExecution);
         TaskUserDTO taskUserDTO = JSONObject.parseObject(value, TaskUserDTO.class);
         message.setChannel(taskUserDTO.getChannel());
-        Set<Integer> taskUsers = userFormService.getTaskUsers(taskUserDTO);
 
+        Set<Integer> taskUsers = userFormService.getTaskUsers(taskUserDTO);
+        if(taskUserDTO.getUserFormFlag()==1){
+            String assineeFormUserId = (String)variables.get("assineeFormUserId");
+            taskUsers.add(Integer.parseInt(assineeFormUserId));
+        }
         if(taskUsers!=null){
 
             taskUsers.forEach(id->{

operation_manager/src/main/java/com/huaxu/process/controller/WorkFlowController.java

@@ -153,7 +153,7 @@ public class WorkFlowController {
     @GetMapping("/testStartProgress")
     @ApiOperation(value = "开启流程")
     public AjaxMessage testStartProgress() {
-        ProcessDefinition processDefinition=workFlowService.findProcessDefinition("test1",1,1);
+        ProcessDefinition processDefinition=workFlowService.findProcessDefinition("test1",8,8);
 
         Map<String, Object> vars=new HashMap<>();
         vars.put("assineeFormUserId","55,66");
@@ -179,8 +179,6 @@ public class WorkFlowController {
         Action action=null;
         if(actionId==1){
             action=Action.ACTION_AUDIT;
-        }else if(actionId==2){
-            action=Action.ACTION_RECEIVE;
         }
         else if(actionId==3){
             action=Action.ACTION_REJECT;
@@ -189,4 +187,11 @@ public class WorkFlowController {
         List<TaskPorcessResult> results = workFlowService.handleTask(action, taskId, args, "haowan");
         return new AjaxMessage(ResultStatus.OK,results);
     }
+    @PostMapping ("/stopProgress")
+    @ApiOperation(value = "流程流转")
+    public AjaxMessage stopProgress( String processId) {
+
+        workFlowService.stopProcessInstance(processId);
+        return new AjaxMessage(ResultStatus.OK);
+    }
 }

operation_manager/src/main/java/com/huaxu/process/service/JumpTaskCmdService.java

@@ -0,0 +1,68 @@
+package com.huaxu.process.service;
+import org.activiti.engine.impl.context.Context;
+
+import org.activiti.engine.impl.interceptor.Command;
+
+import org.activiti.engine.impl.interceptor.CommandContext;
+
+import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
+
+import org.activiti.engine.impl.persistence.entity.TaskEntity;
+
+import org.activiti.engine.impl.pvm.process.ActivityImpl;
+
+import org.activiti.engine.impl.pvm.process.ProcessDefinitionImpl;
+
+import org.activiti.engine.task.Comment;
+
+import org.springframework.stereotype.Service;
+public class JumpTaskCmdService implements Command<Comment>{
+    protected String executionId;  //当前任务的executionID
+
+    protected String activityId;  //跳转目标activityID
+
+
+
+    public JumpTaskCmdService() {
+
+
+
+    }
+
+
+
+    public JumpTaskCmdService(String executionId, String activityId) {
+
+        this.executionId = executionId;
+
+        this.activityId = activityId;
+
+    }
+
+
+
+    public Comment execute(CommandContext commandContext) {
+
+        for (TaskEntity taskEntity : Context.getCommandContext().getTaskEntityManager().findTasksByExecutionId(executionId)) {
+
+            Context.getCommandContext().getTaskEntityManager().deleteTask(taskEntity, "jump", false);
+
+        }
+
+        ExecutionEntity executionEntity = Context.getCommandContext().getExecutionEntityManager().findExecutionById(executionId);
+
+        ProcessDefinitionImpl processDefinition = executionEntity.getProcessDefinition();
+
+        ActivityImpl activity = processDefinition.findActivity(activityId);
+
+        executionEntity.executeActivity(activity);
+
+        return null;
+
+    }
+
+
+
+}
+
+

operation_manager/src/main/java/com/huaxu/process/service/WorkFlowService.java

@@ -151,6 +151,7 @@ public interface WorkFlowService {
      * @return
      */
     public boolean deleteProcessInstance(String processInstanceId, String remark);
+    public void stopProcessInstance(String processInstanceId);
 
     /**
      * 获取流程实例当前待处理任务

operation_manager/src/main/java/com/huaxu/process/service/impl/WorkFlowServiceImpl.java

@@ -19,6 +19,7 @@ import com.huaxu.process.dto.ProcessDefinitionDTO;
 import com.huaxu.process.dto.TaskPorcessResult;
 import com.huaxu.process.dto.TaskUserDTO;
 import com.huaxu.process.entity.WorkflowAssignUser;
+import com.huaxu.process.service.JumpTaskCmdService;
 import com.huaxu.process.service.UserFormService;
 import com.huaxu.process.service.WorkFlowService;
 import com.huaxu.process.utils.Action;
@@ -34,6 +35,7 @@ import org.activiti.engine.history.HistoricActivityInstance;
 import org.activiti.engine.history.HistoricProcessInstance;
 import org.activiti.engine.history.HistoricTaskInstance;
 import org.activiti.engine.impl.RepositoryServiceImpl;
+import org.activiti.engine.impl.TaskServiceImpl;
 import org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl;
 import org.activiti.engine.impl.context.Context;
 import org.activiti.engine.impl.el.ExpressionManager;
@@ -47,6 +49,7 @@ import org.activiti.engine.repository.Deployment;
 import org.activiti.engine.runtime.ProcessInstance;
 import org.activiti.engine.task.IdentityLink;
 import org.activiti.engine.task.Task;
+import org.activiti.engine.task.TaskQuery;
 import org.apache.commons.lang3.StringUtils;
 import org.dom4j.DocumentException;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -494,6 +497,7 @@ public class WorkFlowServiceImpl implements WorkFlowService {
             taskService.addComment(taskId, pi.getId(), comment);
         }
         taskService.complete(taskId, vars);
+
     }
 
     @Override
@@ -624,6 +628,32 @@ public class WorkFlowServiceImpl implements WorkFlowService {
         return true;
     }
 
+    @Override
+    public void stopProcessInstance(String processInstanceId) {
+        Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
+
+        org.activiti.engine.repository.ProcessDefinition definition = repositoryService.
+                createProcessDefinitionQuery().processDefinitionId(task.getProcessDefinitionId()).singleResult();
+        ProcessDefinitionEntity processDefinition = (ProcessDefinitionEntity) ((RepositoryServiceImpl)
+                repositoryService) .getDeployedProcessDefinition(definition.getId());
+        List<ActivityImpl> allActivities = processDefinition.getActivities();
+        String endActivityId = null;
+        for(ActivityImpl activity : allActivities){
+
+            String type = activity.getProperty("type").toString();
+           if(type.equals("endEvent")){
+               endActivityId = activity.getId();
+                break;
+            }
+
+        }
+
+        TaskServiceImpl taskServiceImpl=(TaskServiceImpl  )taskService;
+        taskServiceImpl.getCommandExecutor().execute( new JumpTaskCmdService( task.getExecutionId(), endActivityId) );
+
+
+    }
+
     @Override
     public List<Task> getProcessRuntimeTask(String processInstanceId) {
         List<Task> tasks = taskService.createTaskQuery().executionId(processInstanceId).list();