将 UML 活动关系图转换为 WebSphere Business Modeler 流程

<node xmi:type="uml:Action" xmi:id="_Avu8wIUVEdm56dw_R1diwQ"
name="Display the invalid transaction method" outgoing="_HWnxMIUVEdm56dw_R1diwQ"
incoming="_G8_wQIUVEdm56dw_R1diwQ" inPartition="_Ma1wgCxWEdmvKqXrpJi5vg" />

<edge xmi:type="uml:ControlFlow" xmi:id="_ToFR0ItkEduYV7PKgmO2BA"
source="_PGZ2YItkEduYV7PKgmO2BA" target="_D6QW4CxTEdmvKqXrpJi5vg"
inPartition="_Ma1wgCxWEdmvKqXrpJi5vg">
    <guard xmi:type="uml:OpaqueExpression" xmi:id="_ToFR0YtkEduYV7PKgmO2BA" />
    <weight xmi:type="uml:LiteralInteger" xmi:id="_ToFR0otkEduYV7PKgmO2BA" value="1" />
 </edge>

<node xmi:type="uml:InitialNode" xmi:id="_CnqM0Ov4EdiPOP7oqdlXhA" name="Initial Node"
outgoing="_0zcw8IUUEdm56dw_R1diwQ" inPartition="_KMFZ8CxWEdmvKqXrpJi5vg" />
 
<node xmi:type="uml:DecisionNode" xmi:id="_dGPToCxSEdmvKqXrpJi5vg"
outgoing="_G8_wQIUVEdm56dw_R1diwQ _PZwhMIUVEdm56dw_R1diwQ"
incoming="__Vbh8IUUEdm56dw_R1diwQ" inPartition="_Ma1wgCxWEdmvKqXrpJi5vg" />

<node xmi:type="uml:ActivityFinalNode" xmi:id="_D6QW4CxTEdmvKqXrpJi5vg" 
name="Activity Final Node" incoming="_ToFR0ItkEduYV7PKgmO2BA"
inPartition="_Ma1wgCxWEdmvKqXrpJi5vg" />

<node xmi:type="uml:MergeNode" xmi:id="_KLhj0CxXEdmvKqXrpJi5vg"
outgoing="_MgsEYCxXEdmvKqXrpJi5vg" incoming="_HWnxMIUVEdm56dw_R1diwQ
_S1GmsIUVEdm56dw_R1diwQ" inPartition="_Ma1wgCxWEdmvKqXrpJi5vg" />

<node xmi:type="uml:Action" xmi:id="_nWKFYIUUEdm56dw_R1diwQ" 
name="Customer/Teller selects Transfer money from menu"   
outgoing="_3eaoIUUEdm56dw_R1diwQ" incoming="_0zcw8IUUEdm56dw_R1diwQ"
inPartition="_KMFZ8CxWEdmvKqXrpJi5vg" />

<xsd:element name="flowContent" minOccurs="0">
	<xsd:complexType>
		<xsd:choice maxOccurs="unbounded">
		<xsd:element name="startNode" minOccurs="0">
		…
			</xsd:element>
			<xsd:element name="stopNode" minOccurs="0">
			…
			</xsd:element>
			<xsd:element name="endNode" minOccurs="0">
			…
			</xsd:element>
			<xsd:element name="task" type="Task" minOccurs="0"/>
			<xsd:element name="decision" type="Decision" minOccurs="0"/>
			<xsd:element name="merge" type="Merge" minOccurs="0"/>
			<xsd:element name="fork" type="Fork" minOccurs="0"/>
			<xsd:element name="join" type="Join" minOccurs="0"/>

import uml "http://www.eclipse.org/uml2/1.0.0/UML"
import bom "http://www.ibm.com/wbim/bomSchema1.0"
import emf "http://www.eclipse.org/emf/2002/Ecore"
import uml "http:///com/ibm/mtf/xtools/uml2.ecore"
import ws "http:///com/ibm/mtf/model/workspace.ecore"
import emf "http:///com/ibm/mtf/model/emf.ecore"
import util “http:///com/ibm/mtf/util.ecore”

relate activity2process(uml:Activity activity, bom:Process process)
relate pkg2Catalog(uml:Package pkg, bom:Catalog bomCatalog)
relate action(uml:Action action, bom:Task task)
relate connection(uml:ControlFlow flow, bom:Connection conn)

relate action(uml:Action action, bom:Task task)
	when equals(action.xmi_id, task.name) {
	equals(action.name, task.description)
}

relate activity2process(uml:Activity activity, bom:Process process)
	when util:MatchString "{0}##{1}" (activity.package.xmi_id, activity.name, process.name) {
	action(over activity.action, over process.flowContent.task),
	connection(over activity.edge, over process.flowContent.connection)
}

Resource targetResource  = set.createResource
(URI .createPlatformResourceURI(target.getFullPath().toString()));
……  
/*MTF invocation, transforming original UML model into Modeler resource */
ITransformationSession engine = MappingEngineFactory.createTransformationSession(def);
Object[] args = new Object[] { source, targetResource };
Mapping mapping = engine.map(rule, args, new SubProgressMonitor(monitor, 27));

DocumentRootImpl wbmDocRoot= (DocumentRootImpl)  targetResource.getContents().get(0);
// Then, using DocumentRoot, retrieve the Processes object.
ModelType modelType = wbmDocRoot.getModel();
ProcessModel pcsModel = modelType.getProcessModel();
ProcessesType pcsType = pcsModel.getProcesses();
EList processes = pcsType.getProcess();

for (Iterator i = processes.iterator();i.hasNext();){
	ProcessImpl process = (ProcessImpl)i.next();
	FlowContentType flowCType = process.getFlowContent();
	EList tasks = flowCType.getTask();
	EList connections = flowCType.getConnection();
	......
}

private HashMap taskNameMap = new HashMap();
....
// associate task names with a  legible description
for (Iterator j = tasks.iterator();j.hasNext();){
	TaskImpl task = (TaskImpl)j.next();
	String name = task.getName(); 
	// The current name that comes from UML and which is a unique Id.
	String desc = task.getDescription();
	if (desc!=null && !("").equals(desc)){ //  truncate desc length to 50 at most
		if (desc.length() > 50) { desc = desc.substring(0,50); }
		// verify whether desc already exists and update the max ID value for same Name
		iif (taskNameMap.get(desc)== null)  { 
			taskNameMap.put(desc,new Integer(0));
		} else { // Update the suffix maximum
			Integer maxID = (Integer)taskNameMap.get(desc);
			maxID = new Integer(maxID.intValue()+1);
			taskNameMap.put(desc,maxID);
			desc += maxID.toString();
		}
		task.setName(desc);  
		nameUpdateMap.put(name,desc); // Update the names correspondence with the suffixes
	}
}

// Then process the nodes to update the names in the model.

for (Iterator k = connections.iterator();k.hasNext();){
	ConnectionImpl connection = (ConnectionImpl)k.next();
	SourceType sourceType = connection.getSource();
	TargetType targetType = connection.getTarget();
	String cp = sourceType.getNode();
	if (nameUpdateMap.get(cp)!=null) 
		{ sourceType.setNode((String)nameUpdateMap.get(cp)); }
		cp = targetType.getNode();
		if (nameUpdateMap.get(cp)!=null) 
		{ targetType.setNode((String)nameUpdateMap.get(cp)); }
}