LibreCCM
/
libreccm
3
0
Fork 0
Code Issues 10 Pull Requests Packages Releases Wiki Activity

CCM NG/ccm-core: Several improvments for Workflow Handling 

git-svn-id: https://svn.libreccm.org/ccm/ccm_ng@4816 8810af33-2d31-482b-a856-94f89814c4df
pull/2/head
jensp 2017-06-26 17:15:45 +00:00
parent c48e01f9f3
commit f1266b0b5d
7 changed files with 74 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ccm-cms/src/main/java/com/arsdigita/cms/ui/workflow/AssignedTaskController.java
View File

@ -67,7 +67,6 @@ public class AssignedTaskController {
defaultLocale = kernelConfig.getDefaultLocale();
}
@Transactional(Transactional.TxType.REQUIRED)
public List<RowData<Long>> getAssignedTasks(final Workflow workflow) {
final User user = shiro.getUser().get();
@ -83,7 +82,6 @@ public class AssignedTaskController {
private RowData<Long> createRowData(final AssignableTask task) {
final RowData<Long> rowData = new RowData<>(3);
rowData.setRowKey(task.getTaskId());
@ -99,7 +97,6 @@ public class AssignedTaskController {
rowData.setColData(2, "");
return rowData;
}

2
ccm-cms/src/main/java/com/arsdigita/cms/ui/workflow/AssignedTaskTableModelBuilder.java
View File

@ -56,8 +56,6 @@ class AssignedTaskTableModelBuilder extends AbstractTableModelBuilder {
Assert.exists(workflow, Workflow.class);
final CdiUtil cdiUtil = CdiUtil.createCdiUtil();
final WorkflowManager workflowManager = cdiUtil.findBean(
WorkflowManager.class);
final WorkflowState workflowState = workflow.getState();
if (workflowState == WorkflowState.STARTED) {

11
ccm-core/src/main/java/org/libreccm/workflow/AssignableTask.java
View File

@ -70,12 +70,21 @@ import static org.libreccm.core.CoreConstants.DB_SCHEMA;
,
@NamedQuery(
name = "AssignableTask.findAssignedTasks",
query = "SELECT t FROM AssignableTask t "
query = "SELECT DISTINCT t FROM AssignableTask t "
+ "JOIN t.assignments a "
+ "WHERE a.role IN :roles "
+ "AND t.workflow = :workflow "
+ "AND t.active = true")
,
@NamedQuery(
name = "AssignableTask.isAssignedTo",
query = "SELECT (CASE WHEN COUNT(t) > 0 THEN true ELSE false END) "
+ "FROM AssignableTask t "
+ "JOIN t.assignments a "
+ "WHERE a.role IN :roles "
+ "AND t = :task"
)
,
@NamedQuery(
name = "AssignableTask.findOverdueTasks",
query = "SELECT t FROM AssignableTask t "

19
ccm-core/src/main/java/org/libreccm/workflow/AssignableTaskManager.java
View File

@ -22,6 +22,7 @@ import org.libreccm.core.CoreConstants;
import org.libreccm.security.AuthorizationRequired;
import org.libreccm.security.RequiresPrivilege;
import org.libreccm.security.Role;
import org.libreccm.security.RoleMembership;
import org.libreccm.security.RoleRepository;
import org.libreccm.security.Shiro;
import org.libreccm.security.User;
@ -125,6 +126,24 @@ public class AssignableTaskManager {
}
}
@Transactional(Transactional.TxType.REQUIRED)
public boolean isAssignedTo(final AssignableTask task,
final User user) {
final TypedQuery<Boolean> query = entityManager
.createNamedQuery("AssignableTask.isAssignedTo",
Boolean.class);
final List<Role> roles = user
.getRoleMemberships()
.stream()
.map(RoleMembership::getRole)
.collect(Collectors.toList());
query.setParameter("roles", roles);
query.setParameter("task", task);
return query.getSingleResult();
}
/**
*
* @param task

17
ccm-core/src/main/java/org/libreccm/workflow/AssignableTaskRepository.java
View File

@ -20,11 +20,13 @@ package org.libreccm.workflow;
import org.libreccm.core.AbstractEntityRepository;
import org.libreccm.security.Role;
import org.libreccm.security.RoleMembership;
import org.libreccm.security.User;
import javax.enterprise.context.RequestScoped;
import javax.persistence.NoResultException;
import javax.persistence.TypedQuery;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
@ -56,7 +58,8 @@ public class AssignableTaskRepository
* @return An optional either with the found item or empty
*/
public Optional<AssignableTask> findByUuid(final String uuid) {
final TypedQuery<AssignableTask> query = getEntityManager().createNamedQuery(
final TypedQuery<AssignableTask> query = getEntityManager()
.createNamedQuery(
"AssignableTask.findByUuid", AssignableTask.class);
query.setParameter("uuid", uuid);
@ -71,7 +74,8 @@ public class AssignableTaskRepository
final User user, final Workflow workflow) {
final TypedQuery<AssignableTask> query = getEntityManager()
.createNamedQuery(
"AssignableTask.findEnabledTasksForWorkflow", AssignableTask.class);
"AssignableTask.findEnabledTasksForWorkflow",
AssignableTask.class);
query.setParameter("user", user);
query.setParameter("workflow", workflow);
@ -81,11 +85,12 @@ public class AssignableTaskRepository
public List<AssignableTask> getAssignedTasks(final User user,
final Workflow workflow) {
final TypedQuery<AssignableTask> query = getEntityManager()
.createNamedQuery(
"AssignableTask.findAssignedTasks", AssignableTask.class);
final List<Role> roles = user.getRoleMemberships()
.createNamedQuery("AssignableTask.findAssignedTasks",
AssignableTask.class);
final List<Role> roles = user
.getRoleMemberships()
.stream()
.map(membership -> membership.getRole())
.map(RoleMembership::getRole)
.collect(Collectors.toList());
query.setParameter("roles", roles);

1
ccm-core/src/main/java/org/libreccm/workflow/Task.java
View File

@ -216,6 +216,7 @@ public class Task implements Identifiable, Serializable {
this.taskId = taskId;
}
@Override
public String getUuid() {
return uuid;
}

24
ccm-core/src/main/java/org/libreccm/workflow/WorkflowManager.java
View File

@ -51,7 +51,9 @@ import javax.persistence.TypedQuery;
import javax.transaction.Transactional;
import org.apache.shiro.subject.Subject;
import org.libreccm.security.Role;
import org.libreccm.security.User;
import java.util.Optional;
/**
* Manager for {@link Workflow}s. The logic of some of these classes has been
@ -360,9 +362,23 @@ public class WorkflowManager {
workflow.setActive(true);
updateState(workflow);
for (final Task current : workflow.getTasks()) {
current.setActive(true);
taskManager.updateState(current);
// for (final Task current : workflow.getTasks()) {
// current.setActive(true);
// taskManager.updateState(current);
// }
final List<Task> tasks = workflow.getTasks();
if (!tasks.isEmpty()) {
final Task firstTask = tasks.get(0);
firstTask.setActive(true);
taskManager.updateState(firstTask);
final Optional<User> currentUser = shiro.getUser();
if (!currentUser.isPresent()
&& assignableTaskManager
.isAssignedTo((AssignableTask) firstTask,
currentUser.get())) {
assignableTaskManager.lockTask((AssignableTask) firstTask);
}
}
}