/*
|
* JBoss, Home of Professional Open Source
|
* Copyright 2005, JBoss Inc., and individual contributors as indicated
|
* by the @authors tag. See the copyright.txt in the distribution for a
|
* full listing of individual contributors.
|
*
|
* This is free software; you can redistribute it and/or modify it
|
* under the terms of the GNU Lesser General Public License as
|
* published by the Free Software Foundation; either version 2.1 of
|
* the License, or (at your option) any later version.
|
*
|
* This software is distributed in the hope that it will be useful,
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
* Lesser General Public License for more details.
|
*
|
* You should have received a copy of the GNU Lesser General Public
|
* License along with this software; if not, write to the Free
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
*/
|
package org.jbpm.pvm.internal.svc;
|
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
import org.jbpm.api.TaskQuery;
|
import org.jbpm.api.TaskService;
|
import org.jbpm.api.history.HistoryComment;
|
import org.jbpm.api.task.Participation;
|
import org.jbpm.api.task.Task;
|
import org.jbpm.pvm.internal.cmd.AddParticipationCmd;
|
import org.jbpm.pvm.internal.cmd.AddReplyCommentCmd;
|
import org.jbpm.pvm.internal.cmd.AddTaskCommentCmd;
|
import org.jbpm.pvm.internal.cmd.AssignTaskCmd;
|
import org.jbpm.pvm.internal.cmd.CompositeCmd;
|
import org.jbpm.pvm.internal.cmd.DeleteTaskCmd;
|
import org.jbpm.pvm.internal.cmd.CompleteTaskCmd;
|
import org.jbpm.pvm.internal.cmd.CreateTaskQueryCmd;
|
import org.jbpm.pvm.internal.cmd.DeleteCommentCmd;
|
import org.jbpm.pvm.internal.cmd.GetOutcomes;
|
import org.jbpm.pvm.internal.cmd.GetParticipantsCmd;
|
import org.jbpm.pvm.internal.cmd.GetSubTasksCmd;
|
import org.jbpm.pvm.internal.cmd.GetTaskCmd;
|
import org.jbpm.pvm.internal.cmd.GetTaskCommentsCmd;
|
import org.jbpm.pvm.internal.cmd.GetTaskVariableNamesCmd;
|
import org.jbpm.pvm.internal.cmd.GetTaskVariablesCmd;
|
import org.jbpm.pvm.internal.cmd.NewTaskCmd;
|
import org.jbpm.pvm.internal.cmd.RemoveParticipantCmd;
|
import org.jbpm.pvm.internal.cmd.SaveTaskCmd;
|
import org.jbpm.pvm.internal.cmd.SetTaskVariablesCmd;
|
import org.jbpm.pvm.internal.query.TaskQueryImpl;
|
import org.jbpm.pvm.internal.task.TaskImpl;
|
|
/**
|
* @author Alejandro Guizar, Tom Baeyens
|
* @author Heiko Braun <heiko.braun@jboss.com>
|
*/
|
public class TaskServiceImpl extends AbstractServiceImpl implements TaskService {
|
|
public Task newTask() {
|
return commandService.execute(new NewTaskCmd(null));
|
}
|
|
public Task getTask(String taskId) {
|
return commandService.execute(new GetTaskCmd(taskId));
|
}
|
|
public String saveTask(Task task) {
|
return commandService.execute(new SaveTaskCmd((TaskImpl) task));
|
}
|
|
public void deleteTask(String taskId) {
|
commandService.execute(new DeleteTaskCmd(taskId));
|
}
|
|
public void deleteTask(String taskId, String reason) {
|
commandService.execute(new DeleteTaskCmd(taskId, reason));
|
}
|
|
public void deleteTaskCascade(String taskId) {
|
commandService.execute(new DeleteTaskCmd(taskId, true));
|
}
|
|
public void completeTask(String taskId) {
|
commandService.execute(new CompleteTaskCmd(taskId));
|
}
|
|
public void completeTask(String taskId, Map<String, Object> variables) {
|
completeTask(taskId, null, variables);
|
}
|
|
public void completeTask(String taskId, String outcome) {
|
commandService.execute(new CompleteTaskCmd(taskId, outcome));
|
}
|
|
public void completeTask(String taskId, String outcome, Map<String, Object> variables) {
|
SetTaskVariablesCmd setTaskVariablesCmd = new SetTaskVariablesCmd(taskId);
|
setTaskVariablesCmd.setVariables(variables);
|
CompositeCmd compositeCmd = new CompositeCmd();
|
compositeCmd.addCommand(setTaskVariablesCmd);
|
compositeCmd.addCommand(new CompleteTaskCmd(taskId, outcome));
|
commandService.execute(compositeCmd);
|
}
|
|
public void addTaskParticipatingUser(String taskId, String userId, String participation) {
|
commandService.execute(new AddParticipationCmd(taskId, null, userId, null, participation));
|
}
|
|
public void addTaskParticipatingGroup(String taskId, String groupId, String participation) {
|
commandService.execute(new AddParticipationCmd(taskId, null, null, groupId, participation));
|
}
|
|
public List<Participation> getTaskParticipations(String taskId) {
|
return commandService.execute(new GetParticipantsCmd(taskId, null));
|
}
|
|
public void removeTaskParticipatingUser(String taskId, String userId, String participation) {
|
commandService.execute(new RemoveParticipantCmd(taskId, null, userId, null, participation));
|
}
|
|
public void removeTaskParticipatingGroup(String taskId, String groupId, String participation) {
|
commandService.execute(new RemoveParticipantCmd(taskId, null, null, groupId, participation));
|
}
|
|
|
public List<Task> findPersonalTasks(String userId) {
|
return createTaskQuery()
|
.assignee(userId)
|
.orderDesc(TaskQuery.PROPERTY_PRIORITY)
|
.list();
|
}
|
|
public List<Task> findGroupTasks(String userId) {
|
return createTaskQuery()
|
.candidate(userId)
|
.orderDesc(TaskQuery.PROPERTY_PRIORITY)
|
.list();
|
}
|
|
public TaskQuery createTaskQuery() {
|
TaskQueryImpl query = commandService.execute(new CreateTaskQueryCmd());
|
query.setCommandService(commandService);
|
return query;
|
}
|
|
public List<Task> getSubTasks(String taskId) {
|
return commandService.execute(new GetSubTasksCmd(taskId));
|
}
|
|
public Task newTask(String parentTaskId) {
|
return commandService.execute(new NewTaskCmd(parentTaskId));
|
}
|
|
public HistoryComment addTaskComment(String taskId, String message) {
|
return commandService.execute(new AddTaskCommentCmd(taskId, message));
|
}
|
|
public List<HistoryComment> getTaskComments(String taskId) {
|
return commandService.execute(new GetTaskCommentsCmd(taskId));
|
}
|
|
public void deleteComment(String commentId) {
|
commandService.execute(new DeleteCommentCmd(commentId));
|
}
|
|
public HistoryComment addReplyComment(String commentId, String message) {
|
return commandService.execute(new AddReplyCommentCmd(commentId, message));
|
}
|
|
public void assignTask(String taskId, String userId) {
|
commandService.execute(new AssignTaskCmd(taskId, userId));
|
}
|
|
public void takeTask(String taskId, String userId) {
|
commandService.execute(new AssignTaskCmd(taskId, userId, true));
|
}
|
|
public Object getVariable(String taskId, String variableName) {
|
Set<String> variableNames = new HashSet<String>();
|
variableNames.add(variableName);
|
GetTaskVariablesCmd cmd = new GetTaskVariablesCmd(taskId, variableNames);
|
Map<String, Object> variables = commandService.execute(cmd);
|
return variables.get(variableName);
|
}
|
|
public Set<String> getVariableNames(String taskDbid) {
|
return commandService.execute(new GetTaskVariableNamesCmd(taskDbid));
|
}
|
|
public Map<String, Object> getVariables(String taskDbid, Set<String> variableNames) {
|
return commandService.execute(new GetTaskVariablesCmd(taskDbid, variableNames));
|
}
|
|
public void setVariables(String taskDbid, Map<String, Object> variables) {
|
SetTaskVariablesCmd cmd = new SetTaskVariablesCmd(taskDbid);
|
cmd.setVariables(variables);
|
commandService.execute(cmd);
|
}
|
|
public Set<String> getOutcomes(String taskId) {
|
return commandService.execute(new GetOutcomes(taskId));
|
}
|
}
|
