001: /*--
002:
003: Copyright (C) 2002 Anthony Eden.
004: All rights reserved.
005:
006: Redistribution and use in source and binary forms, with or without
007: modification, are permitted provided that the following conditions
008: are met:
009:
010: 1. Redistributions of source code must retain the above copyright
011: notice, this list of conditions, and the following disclaimer.
012:
013: 2. Redistributions in binary form must reproduce the above copyright
014: notice, this list of conditions, and the disclaimer that follows
015: these conditions in the documentation and/or other materials
016: provided with the distribution.
017:
018: 3. The names "OBE" and "Open Business Engine" must not be used to
019: endorse or promote products derived from this software without prior
020: written permission. For written permission, please contact
021: me@anthonyeden.com.
022:
023: 4. Products derived from this software may not be called "OBE" or
024: "Open Business Engine", nor may "OBE" or "Open Business Engine"
025: appear in their name, without prior written permission from
026: Anthony Eden (me@anthonyeden.com).
027:
028: In addition, I request (but do not require) that you include in the
029: end-user documentation provided with the redistribution and/or in the
030: software itself an acknowledgement equivalent to the following:
031: "This product includes software developed by
032: Anthony Eden (http://www.anthonyeden.com/)."
033:
034: THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
035: WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
036: OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
037: DISCLAIMED. IN NO EVENT SHALL THE AUTHOR(S) BE LIABLE FOR ANY DIRECT,
038: INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
039: (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
040: SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
041: HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
042: STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
043: IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
044: POSSIBILITY OF SUCH DAMAGE.
045:
046: For more information on OBE, please see <http://obe.sourceforge.net/>.
047:
048: */
049:
050: package org.obe.designer;
051:
052: import com.anthonyeden.lib.event.ErrorListener;
053: import com.anthonyeden.lib.event.ErrorListenerSupport;
054: import com.anthonyeden.lib.util.IOUtilities;
055: import com.jgraph.graph.DefaultGraphCell;
056: import java.awt.*;
057: import java.io.File;
058: import java.io.FileOutputStream;
059: import java.util.Iterator;
060: import org.apache.commons.logging.Log;
061: import org.apache.commons.logging.LogFactory;
062: import org.obe.designer.view.ActivityView;
063: import org.obe.xpdl.model.activity.Activity;
064: import org.obe.xpdl.model.pkg.XPDLPackage;
065: import org.obe.xpdl.model.workflow.WorkflowProcess;
066: import org.obe.xpdl.serializer.dom4j.Dom4JXPDLSerializer;
067:
068: /**
069: * A threaded class for saving workflow definitions.
070: *
071: * @author Anthony Eden
072: */
073: public class SaveWorkflowThread extends Thread {
074:
075: private static final Log log = LogFactory
076: .getLog(SaveWorkflowThread.class);
077:
078: private OBEDesigner parent;
079: private XPDLPackage workflowPackage;
080: private OBETabbedPane tabbedPane;
081:
082: private File file;
083:
084: private ErrorListenerSupport errorListenerSupport;
085:
086: public SaveWorkflowThread(OBEDesigner parent,
087: XPDLPackage workflowPackage, OBETabbedPane tabbedPane) {
088: this .parent = parent;
089: this .workflowPackage = workflowPackage;
090: this .tabbedPane = tabbedPane;
091:
092: errorListenerSupport = new ErrorListenerSupport(this );
093: }
094:
095: /**
096: * Save the workflow definition to the given file.
097: *
098: * @param file The file
099: * @throws Exception
100: */
101:
102: public void saveWorkflowDefinition(File file) throws Exception {
103: this .file = file;
104: start();
105: }
106:
107: public void run() {
108: FileOutputStream out = null;
109: try {
110: log.info("Saving workflow package");
111: parent.setStatus("Saving workflow to "
112: + file.getAbsolutePath());
113: out = new FileOutputStream(file);
114: Dom4JXPDLSerializer serializer = new Dom4JXPDLSerializer();
115:
116: workflowPackage.clear(XPDLPackage.WORKFLOW_PROCESS);
117:
118: Iterator editedProcesses = tabbedPane
119: .getWorkflowProcesses().iterator();
120: while (editedProcesses.hasNext()) {
121: workflowPackage.add((WorkflowProcess) editedProcesses
122: .next());
123: }
124:
125: setBounds();
126:
127: log.info("Serializing workflow package");
128: serializer.serialize(workflowPackage, out);
129: } catch (Exception e) {
130: errorListenerSupport.fireError(e);
131: } finally {
132: parent.setStatus("");
133: IOUtilities.close(out);
134: }
135: }
136:
137: protected void setBounds() {
138: log.info("Setting bounds for activities");
139: Iterator graphs = tabbedPane.getGraphs().iterator();
140: while (graphs.hasNext()) {
141: OBEGraph graph = (OBEGraph) graphs.next();
142: log.info("Setting bounds for graph: " + graph);
143: Object[] roots = graph.getRoots();
144: for (int i = 0; i < roots.length; i++) {
145: Object userObject = ((DefaultGraphCell) roots[i])
146: .getUserObject();
147: if (userObject instanceof ActivityView) {
148: ActivityView view = (ActivityView) userObject;
149: log.info("Setting bounds for " + view);
150:
151: Rectangle bounds = graph.getCellBounds(roots[i]);
152:
153: Activity activity = view.getActivity();
154: activity.setBounds(bounds);
155: }
156: }
157: }
158: }
159:
160: /**
161: * Add the specified error listener.
162: *
163: * @param l The ErrorListener
164: */
165:
166: public void addErrorListener(ErrorListener l) {
167: errorListenerSupport.addErrorListener(l);
168: }
169:
170: /**
171: * Remove the specified error listener.
172: *
173: * @param l The ErrorListener
174: */
175:
176: public void removeErrorListener(ErrorListener l) {
177: errorListenerSupport.removeErrorListener(l);
178: }
179:
180: }
|