TaskServiceImpl.java 文件源码

private void changeTask(long taskId,String username,StatusOperation operation,String faultMessage) {
    EntityManager em=getEntityManager();
    EntityTransaction trans=em.getTransaction();
    try{
        trans.begin();
        Task task=em.find(Task.class, taskId);
        if(StringUtils.isNotEmpty(faultMessage)){
            task.setFaultMessage(faultMessage);
        }
        if(changeTaskStatus(task,operation)){
            em.persist(task);               
        }
        TaskStatus status=task.getStatus();
        if(status.equals(TaskStatus.Completed) || status.equals(TaskStatus.Error) || status.equals(TaskStatus.Exited) || status.equals(TaskStatus.Obsolete) || status.equals(TaskStatus.Failed)){
            StatefulKnowledgeSession session=this.bpmService.getSession(task.getSessionId());
            session.getWorkItemManager().completeWorkItem(task.getWorkItemId(),null);   
            session.dispose();
        }
        trans.commit();
    }catch(Exception ex){
        trans.rollback();
        throw new RuntimeException(ex);
    }
}