联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
java110
2021-08-28 eadc0790df8b8dcf17dcb22f4bec302ee9f57b7b 
 service-common/src/main/java/com/java110/common/smo/impl/OaWorkflowUserInnerServiceSMOImpl.java


@@ -13,19 +13,28 @@


import com.java110.intf.user.IUserInnerServiceSMO;


import com.java110.utils.util.Assert;


import com.java110.utils.util.StringUtil;


import org.activiti.bpmn.model.BpmnModel;


import org.activiti.bpmn.model.FlowNode;


import org.activiti.bpmn.model.SequenceFlow;


import org.activiti.engine.HistoryService;


import org.activiti.engine.ProcessEngine;


import org.activiti.engine.RepositoryService;


import org.activiti.engine.RuntimeService;


import org.activiti.engine.TaskService;


import org.activiti.engine.history.HistoricActivityInstance;


import org.activiti.engine.history.HistoricProcessInstance;


import org.activiti.engine.history.HistoricTaskInstance;


import org.activiti.engine.history.HistoricTaskInstanceQuery;


import org.activiti.engine.impl.identity.Authentication;


import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;


import org.activiti.engine.query.Query;


import org.activiti.engine.runtime.Execution;


import org.activiti.engine.runtime.ProcessInstance;


import org.activiti.engine.task.Comment;


import org.activiti.engine.task.Task;


import org.activiti.engine.task.TaskQuery;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.RequestBody;


import org.springframework.web.bind.annotation.RestController;


@@ -39,6 +48,7 @@


@RestController


public class OaWorkflowUserInnerServiceSMOImpl extends BaseServiceSMO implements IOaWorkflowUserInnerServiceSMO {




    private static Logger logger = LoggerFactory.getLogger(OaWorkflowUserInnerServiceSMOImpl.class);


    @Autowired


    private ProcessEngine processEngine;




@@ -49,10 +59,16 @@


    private TaskService taskService;




    @Autowired


    private HistoryService historyService;




    @Autowired


    private IUserInnerServiceSMO userInnerServiceSMOImpl;




    @Autowired


    private IWorkflowInnerServiceSMO workflowInnerServiceSMOImpl;




    @Autowired


    private RepositoryService repositoryService;






    /**


@@ -65,7 +81,8 @@


        Map<String, Object> variables = new HashMap<String, Object>();


        //variables.put("reqJson", reqJson);


        variables.put("startUserId", reqJson.getString("createUserId"));


        ProcessInstance processInstance = runtimeService.startProcessInstanceById(getWorkflowDto(reqJson.getString("processDefinitionKey")), reqJson.getString("id"), variables);


        variables.put("nextUserId", reqJson.getString("createUserId"));


        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(getWorkflowDto(reqJson.getString("flowId")), reqJson.getString("id"), variables);


        //将得到的实例流程id值赋给之前设置的变量


        String processInstanceId = processInstance.getId();


        // System.out.println("流程开启成功.......实例流程id:" + processInstanceId);


@@ -75,9 +92,8 @@


        return reqJson;


    }




    //WorkflowDto.DEFAULT_PROCESS +


    private String getWorkflowDto(String processDefinitionId) {


        return  processDefinitionId;


    private String getWorkflowDto(String flowId) {


        return WorkflowDto.DEFAULT_PROCESS + flowId;


    }




    /**


@@ -108,7 +124,7 @@


     */


    public long getUserTaskCount(@RequestBody AuditUser user) {


        TaskService taskService = processEngine.getTaskService();


        TaskQuery query = taskService.createTaskQuery().processDefinitionId(getWorkflowDto(user.getProcessDefinitionKey()));


        TaskQuery query = taskService.createTaskQuery().processDefinitionKey(getWorkflowDto(user.getFlowId()));


        query.taskAssignee(user.getUserId());


        return query.count();


    }


@@ -120,8 +136,8 @@


     */


    public List<JSONObject> getUserTasks(@RequestBody AuditUser user) {


        TaskService taskService = processEngine.getTaskService();


        TaskQuery query = taskService.createTaskQuery().processDefinitionId(getWorkflowDto(user.getProcessDefinitionKey()));


        ;


        TaskQuery query = taskService.createTaskQuery().processDefinitionKey(getWorkflowDto(user.getFlowId()));




        query.taskAssignee(user.getUserId());


        query.orderByTaskCreateTime().desc();


        List<Task> list = null;


@@ -156,11 +172,11 @@


    public long getUserHistoryTaskCount(@RequestBody AuditUser user) {


        HistoryService historyService = processEngine.getHistoryService();


//        Query query = historyService.createHistoricTaskInstanceQuery()


//                .processDefinitionId("complaint")


//                .processDefinitionKey("complaint")


//                .taskAssignee(user.getUserId());




        HistoricTaskInstanceQuery historicTaskInstanceQuery = historyService.createHistoricTaskInstanceQuery()


                .processDefinitionId(getWorkflowDto(user.getProcessDefinitionKey()))


                .processDefinitionKey(getWorkflowDto(user.getFlowId()))


                .taskAssignee(user.getUserId())


                .finished();


        if (!StringUtil.isEmpty(user.getAuditLink()) && "START".equals(user.getAuditLink())) {


@@ -183,7 +199,7 @@


        HistoryService historyService = processEngine.getHistoryService();




        HistoricTaskInstanceQuery historicTaskInstanceQuery = historyService.createHistoricTaskInstanceQuery()


                .processDefinitionId(getWorkflowDto(user.getProcessDefinitionKey()))


                .processDefinitionKey(getWorkflowDto(user.getFlowId()))


                .taskAssignee(user.getUserId())


                .finished();


        if (!StringUtil.isEmpty(user.getAuditLink()) && "START".equals(user.getAuditLink())) {


@@ -220,13 +236,11 @@


        TaskService taskService = processEngine.getTaskService();


        Task task = taskService.createTaskQuery().taskId(reqJson.getString("taskId")).singleResult();


        String processInstanceId = task.getProcessInstanceId();


        Authentication.setAuthenticatedUserId(reqJson.getString("createUserId"));


        Authentication.setAuthenticatedUserId(reqJson.getString("nextUserId"));


        taskService.addComment(reqJson.getString("taskId"), processInstanceId, reqJson.getString("auditMessage"));


        Map<String, Object> variables = new HashMap<String, Object>();


        variables.put("auditCode", reqJson.getString("auditCode"));


        variables.put("currentUserId", reqJson.getString("createUserId"));


        variables.put("flag", "1200".equals(reqJson.getString("auditCode")) ? "false" : "true");


        variables.put("startUserId", reqJson.getString("startUserId"));


        variables.put("nextUserId", reqJson.getString("nextUserId"));


        //variables.put("startUserId", reqJson.getString("startUserId"));


        taskService.complete(reqJson.getString("taskId"), variables);




        ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();


@@ -236,6 +250,90 @@


        return false;


    }




    public boolean changeTaskToOtherUser(@RequestBody JSONObject reqJson) {


        TaskService taskService = processEngine.getTaskService();


        Task task = taskService.createTaskQuery().taskId(reqJson.getString("taskId")).singleResult();


        String processInstanceId = task.getProcessInstanceId();


        taskService.addComment(reqJson.getString("taskId"), processInstanceId, reqJson.getString("auditMessage"));


        taskService.setAssignee(reqJson.getString("taskId"), reqJson.getString("nextUserId"));


        taskService.setOwner(reqJson.getString("taskId"), reqJson.getString("nextUserId"));


        return true;


    }




    public boolean goBackTask(@RequestBody JSONObject reqJson) {


        TaskService taskService = processEngine.getTaskService();


        Task task = taskService.createTaskQuery().taskId(reqJson.getString("taskId")).singleResult();


        if (task == null) {


            throw new IllegalArgumentException("流程未启动或已执行完成，无法退回");


        }


        List<HistoricTaskInstance> htiList = historyService.createHistoricTaskInstanceQuery()


                .processInstanceBusinessKey(reqJson.getString("id"))


                .orderByTaskCreateTime()


                .asc()


                .list();


        String myTaskId = null;


        HistoricTaskInstance myTask = null;


        for (HistoricTaskInstance hti : htiList) {


            if (reqJson.getString("curUserId").equals(hti.getAssignee())) {


                myTaskId = hti.getId();


                myTask = hti;


                break;


            }


        }


        if (null == myTaskId) {


            throw new IllegalArgumentException("该任务非当前用户提交，无法退回");


        }




        String processDefinitionId = myTask.getProcessDefinitionId();


        ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) repositoryService.createProcessDefinitionQuery().processDefinitionId(processDefinitionId).singleResult();


        BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);




        //变量


//      Map<String, VariableInstance> variables = runtimeService.getVariableInstances(currentTask.getExecutionId());


        String myActivityId = null;


        List<HistoricActivityInstance> haiList = historyService.createHistoricActivityInstanceQuery()


                .executionId(myTask.getExecutionId()).finished().list();


        for (HistoricActivityInstance hai : haiList) {


            if (myTaskId.equals(hai.getTaskId())) {


                myActivityId = hai.getActivityId();


                break;


            }


        }


        FlowNode myFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(myActivityId);






        Execution execution = runtimeService.createExecutionQuery().executionId(task.getExecutionId()).singleResult();


        String activityId = execution.getActivityId();


        logger.warn("------->> activityId:" + activityId);


        FlowNode flowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(activityId);




        //记录原活动方向


        List<SequenceFlow> oriSequenceFlows = new ArrayList<SequenceFlow>();


        oriSequenceFlows.addAll(flowNode.getOutgoingFlows());




        //清理活动方向


        flowNode.getOutgoingFlows().clear();


        //建立新方向


        List<SequenceFlow> newSequenceFlowList = new ArrayList<SequenceFlow>();


        SequenceFlow newSequenceFlow = new SequenceFlow();


        newSequenceFlow.setId("newSequenceFlowId");


        newSequenceFlow.setSourceFlowElement(flowNode);


        newSequenceFlow.setTargetFlowElement(myFlowNode);


        newSequenceFlowList.add(newSequenceFlow);


        flowNode.setOutgoingFlows(newSequenceFlowList);




        Authentication.setAuthenticatedUserId(reqJson.getString("curUserId"));


        taskService.addComment(task.getId(), task.getProcessInstanceId(), "退回，" + reqJson.getString("auditMessage"));




        Map<String, Object> currentVariables = new HashMap<String, Object>();


        currentVariables.put("applier", reqJson.getString("curUserId"));


        //完成任务


        taskService.complete(task.getId(), currentVariables);


        //恢复原方向


        flowNode.setOutgoingFlows(oriSequenceFlows);


        return true;


    }




    public List<AuditMessageDto> getAuditMessage(@RequestBody JSONObject reqJson) {




        TaskService taskService = processEngine.getTaskService();