Multi Complete Task

<%@page import="com.ptc.arbortext.windchill.asps.structure.client.ASPSMessages"%>

<%@page import="java.util.Enumeration"%>

<%@page import="java.util.HashSet"%>

<%@page import="java.util.Vector"%>

<%@page import="wt.fc.ObjectIdentifier"%>

<%@page import="wt.fc.ObjectReference"%>

<%@page import="wt.fc.PersistenceHelper"%>

<%@page import="wt.org.WTPrincipal"%>

<%@page import="wt.org.WTPrincipalReference"%>

<%@page import="wt.pom.Transaction"%>

<%@page import="wt.project.Role"%>

<%@page import="wt.session.SessionHelper"%>

<%@page import="wt.team.Team"%>

<%@page import="wt.team.TeamReference"%>

<%@page import="wt.util.WTException"%>

<%@page import="wt.workflow.definer.WfAssignedActivityTemplate"%>

<%@page import="wt.workflow.definer.WfDefinerHelper"%>

<%@page import="wt.workflow.engine.ProcessData"%>

<%@page import="wt.workflow.engine.WfEngineHelper"%>

<%@page import="wt.workflow.engine.WfProcess"%>

<%@page import="wt.workflow.engine.WfRouterType"%>

<%@page import="wt.workflow.engine.WfTransition"%>

<%@page import="wt.workflow.engine.WfVariable"%>

<%@page import="wt.workflow.work.WfAssignedActivity"%>

<%@page import="wt.workflow.work.WfAssignment"%>

<%@page import="wt.workflow.work.WorkItem"%>

<%

String sourceOid = request.getParameter("source");

String oids = request.getParameter("oids");

ObjectIdentifier sourceIdentifier = ObjectIdentifier.newObjectIdentifier(sourceOid);

ObjectReference sourceReference = ObjectReference.newObjectReference(sourceIdentifier);

WorkItem source = (WorkItem) sourceReference.getObject();

HashSet<WorkItem> workItems = new HashSet<WorkItem>();

for(String oid : oids.split(";")) {

ObjectIdentifier objectIdentifier = ObjectIdentifier.newObjectIdentifier(oid);

ObjectReference objectReference = ObjectReference.newObjectReference(objectIdentifier);

WorkItem workItem = (WorkItem) objectReference.getObject();

workItems.add(workItem);

}

// For the next 30 seconds, check whether the task is completed every second. If it is

// completed, carry on with the method before the end of the 30 seconds. If it gets to

// 30 seconds without being completed, throw an exception. The reason this is needed is that

// just because a WorkItem is incomplete when the method is run, doesn't mean the user

// hasn't completed it. If it is still in the process of completing, it will show up as

// incomplete. So we need to wait a few seconds to be sure whether it is actually complete

// or not.

long start = System.currentTimeMillis();

while (!source.isComplete() || System.currentTimeMillis() < start + 30) {

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

throw new WTException(e);

}

source = (WorkItem) PersistenceHelper.manager.refresh(source);

}

// If the source object is not completed, throw an exception

if(!source.isComplete()) {

Object[] params = {};

throw new WTException(ASPSMessages.class.getName(), ASPSMessages.INITIAL_WORKITEM_INCOMPLETE, params);

}

// Check that there are items in the list

if (workItems == null || workItems.isEmpty()) {

return;

}

// Check that the Set of WorkItems are not completed

for(WorkItem workItem : workItems) {

if(workItem.isComplete()) {

Object[] params = {};

throw new WTException(ASPSMessages.class.getName(), ASPSMessages.SELECTED_WORKITEM_COMPLETE, params);

}

}

// Complete all the WorkItems, taking the result from the source WorkItem

Transaction transaction = new Transaction();

try {

transaction.start();

WfAssignedActivity sourceActivity = (WfAssignedActivity) source.getSource().getObject();

WfProcess sourceProcess = sourceActivity.getParentProcess();

ObjectReference sourceAssignmentReference = source.getParentWA();

WfAssignment sourceAssignment = (WfAssignment) sourceAssignmentReference.getObject();

Vector sourceEvents = sourceAssignment.getAllEvents();

ProcessData sourceContext = source.getContext();

for(WorkItem workItem : workItems) {

WfAssignedActivity activity = (WfAssignedActivity) workItem.getSource().getObject();

WfProcess process = activity.getParentProcess();

Team team = (Team) process.getTeamId().getObject();

ProcessData context = new ProcessData();

context.setTaskComments(sourceContext.getTaskComments());

// Set variables

WfVariable[] variables = sourceContext.getVariableList();

for(WfVariable variable : variables) {

if(variable.getName().equals("self")) {

variable.setValue(ObjectReference.newObjectReference(activity));

} else if(variable.getName().equals("primaryBusinessObject")) {

variable.setValue(workItem.getPrimaryBusinessObject().getObject());

}

}

context.setVariables(variables);

workItem.setContext(context);

activity.setContext(context);

// Set roles

@SuppressWarnings("unchecked")

Vector<Role> roles = sourceProcess.getProcessRoles();

for(Role role : roles) {

Enumeration roleEnum = sourceProcess.getPrincipals(role);

while(roleEnum.hasMoreElements()) {

WTPrincipalReference principalReference = (WTPrincipalReference) roleEnum.nextElement();

team.addPrincipal(role, principalReference.getPrincipal());

}

}

WTPrincipal user = SessionHelper.getPrincipal();

workItem.setComplete(user.getName());

process.setTeamId(TeamReference.newTeamReference(team));

PersistenceHelper.manager.modify(process);

PersistenceHelper.manager.modify(workItem);

activity = (WfAssignedActivity) PersistenceHelper.manager.modify(activity);

// Set the relevant routing options on the activity

WfAssignedActivityTemplate aat = (WfAssignedActivityTemplate) activity.getTemplate().getObject();

WfRouterType rt = aat.getRouterType();

if (WfDefinerHelper.service.getRouterExpression(aat) == null && rt.equals(WfRouterType.MANUAL) || rt.equals(WfRouterType.MANUAL_EXCLUSIVE)) {

WfEngineHelper.service.complete(activity, sourceEvents);

} else {

WfEngineHelper.service.changeState(activity, WfTransition.COMPLETE);

}

}

// Check that they are all complete

for(WorkItem workItem : workItems) {

if(!workItem.isComplete()) {

Object[] params = {};

throw new WTException(ASPSMessages.class.getName(), ASPSMessages.SELECTED_WORKITEM_INCOMPLETE, params);

}

}

transaction.commit();

transaction = null;

} finally {

if(transaction != null) {

transaction.rollback();

}

}

%>

<html>

<body onload="window.close()"/>

</html>