<%@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>
