-/*******************************************************************************\r
- * Copyright (c) 2012 Association for Decentralized Information Management in\r
- * Industry THTH ry.\r
- * All rights reserved. This program and the accompanying materials\r
- * are made available under the terms of the Eclipse Public License v1.0\r
- * which accompanies this distribution, and is available at\r
- * http://www.eclipse.org/legal/epl-v10.html\r
- *\r
- * Contributors:\r
- * VTT Technical Research Centre of Finland - initial API and implementation\r
- *******************************************************************************/\r
-package org.simantics.charts.ui;\r
-\r
-import java.io.BufferedOutputStream;\r
-import java.io.File;\r
-import java.io.FileOutputStream;\r
-import java.io.IOException;\r
-import java.io.PrintStream;\r
-import java.io.RandomAccessFile;\r
-import java.lang.reflect.InvocationTargetException;\r
-import java.util.ArrayList;\r
-import java.util.Collection;\r
-import java.util.HashSet;\r
-import java.util.List;\r
-import java.util.Set;\r
-\r
-import org.eclipse.core.commands.ExecutionException;\r
-import org.eclipse.core.runtime.IProgressMonitor;\r
-import org.eclipse.core.runtime.IStatus;\r
-import org.eclipse.core.runtime.Status;\r
-import org.eclipse.core.runtime.SubMonitor;\r
-import org.eclipse.core.runtime.preferences.IScopeContext;\r
-import org.eclipse.core.runtime.preferences.InstanceScope;\r
-import org.eclipse.jface.operation.IRunnableWithProgress;\r
-import org.osgi.service.prefs.BackingStoreException;\r
-import org.osgi.service.prefs.Preferences;\r
-import org.simantics.Simantics;\r
-import org.simantics.charts.Activator;\r
-import org.simantics.charts.editor.ChartData;\r
-import org.simantics.charts.editor.ChartKeys;\r
-import org.simantics.databoard.binding.error.BindingException;\r
-import org.simantics.databoard.serialization.SerializationException;\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.Session;\r
-import org.simantics.db.common.NamedResource;\r
-import org.simantics.db.common.request.UniqueRead;\r
-import org.simantics.db.common.utils.Logger;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.layer0.request.PossibleModel;\r
-import org.simantics.history.HistoryException;\r
-import org.simantics.history.csv.CSVFormatter;\r
-import org.simantics.modeling.preferences.CSVPreferences;\r
-import org.simantics.utils.datastructures.hints.IHintContext.Key;\r
-import org.simantics.utils.format.FormattingUtils;\r
-import org.simantics.utils.ui.dialogs.ShowMessage;\r
-\r
-/**\r
- * @author Antti Villberg\r
- */\r
-public class CSVExporter implements IRunnableWithProgress {\r
-\r
- CSVExportPlan exportModel;\r
-\r
- public CSVExporter(CSVExportPlan exportModel) {\r
- this.exportModel = exportModel;\r
- }\r
-\r
- @Override\r
- public void run(IProgressMonitor monitor) throws InvocationTargetException, InterruptedException {\r
- SubMonitor progress = SubMonitor.convert(monitor, 50);\r
- try {\r
- exportModel(progress.newChild(50, SubMonitor.SUPPRESS_NONE));\r
- } catch (IOException e) {\r
- throw new InvocationTargetException(e);\r
- } catch (DatabaseException e) {\r
- throw new InvocationTargetException(e);\r
- } catch (BindingException e) {\r
- throw new InvocationTargetException(e);\r
- } finally {\r
- monitor.done();\r
- }\r
- }\r
-\r
- void exportModel(SubMonitor mon) throws IOException, DatabaseException, SerializationException, BindingException{\r
- \r
- try {\r
- doExport(mon, exportModel.exportLocation, exportModel);\r
- } catch (ExecutionException e) {\r
- e.printStackTrace();\r
- Logger.defaultLogError(e);\r
- mon.setCanceled(true);\r
- ShowMessage.showError("Export failed.", "Internal application error in export. See log for details.");\r
- } finally {\r
- mon.setWorkRemaining(0);\r
- }\r
- \r
- }\r
- \r
- private static Set<Resource> resolveContainingModels(final Collection<NamedResource> res) throws DatabaseException {\r
- return Simantics.getSession().syncRequest(new UniqueRead<Set<Resource>>() {\r
- @Override\r
- public Set<Resource> perform(ReadGraph graph) throws DatabaseException {\r
- Set<Resource> models = new HashSet<Resource>();\r
- for (NamedResource r : res) {\r
- Resource m = graph.syncRequest(new PossibleModel(r.getResource()));\r
- if (m != null)\r
- models.add(m);\r
- }\r
- return models;\r
- }\r
- });\r
- }\r
- \r
- public static void doExport(IProgressMonitor monitor, final File f, final CSVExportPlan plan) throws ExecutionException, IOException {\r
- \r
- IScopeContext context = InstanceScope.INSTANCE;\r
- Preferences node = context.getNode(CSVPreferences.P_NODE);\r
-\r
- node.putDouble(CSVPreferences.P_CSV_START_TIME, plan.startTime);\r
- node.putDouble(CSVPreferences.P_CSV_TIME_STEP, plan.timeStep);\r
- node.put(CSVPreferences.P_CSV_DECIMAL_SEPARATOR, plan.decimalSeparator.toPreference());\r
- node.put(CSVPreferences.P_CSV_COLUMN_SEPARATOR, plan.columnSeparator.toPreference());\r
- \r
- node.putBoolean(CSVPreferences.P_CSV_RESAMPLE, plan.resample);\r
- node.put(CSVPreferences.P_CSV_SAMPLING_MODE, plan.samplingMode.toPreference());\r
- \r
- node.putInt(CSVPreferences.P_CSV_TIME_DIGITS, plan.timeDigits);\r
- node.putInt(CSVPreferences.P_CSV_FLOAT_DIGITS, plan.floatDigits);\r
- node.putInt(CSVPreferences.P_CSV_DOUBLE_DIGITS, plan.doubleDigits);\r
-\r
- try {\r
- node.flush();\r
- } catch (BackingStoreException ex) {\r
- Activator.getDefault().getLog().log(\r
- new Status(IStatus.WARNING, Activator.PLUGIN_ID, "Could not store preferences for node " + node.absolutePath()));\r
- }\r
-\r
- Set<Resource> models;\r
- try {\r
- models = resolveContainingModels(plan.models);\r
- } catch (DatabaseException e3) {\r
- throw new ExecutionException("Containing model resolution failed.", e3);\r
- }\r
- if (models.isEmpty())\r
- throw new ExecutionException("Selected resources are not part of any model");\r
- if (models.size() > 1)\r
- throw new ExecutionException("Selected resources are part of several models, only subscriptions from a single model can be selected");\r
- Resource model = models.iterator().next();\r
- Key chartDataKey = ChartKeys.chartSourceKey(model);\r
- \r
- final ChartData data = Simantics.getProject().getHint(chartDataKey);\r
- if ( data == null ) {\r
- throw new ExecutionException("There is no "+chartDataKey);\r
- }\r
- if ( data.history == null ) {\r
- throw new ExecutionException("There is no history in "+chartDataKey);\r
- }\r
-\r
- final CSVFormatter csv = new CSVFormatter();\r
-\r
- csv.setStartTime( plan.startTime );\r
- csv.setTimeStep( plan.timeStep );\r
- csv.setDecimalSeparator( plan.decimalSeparator );\r
- csv.setColumnSeparator( plan.columnSeparator );\r
- csv.setResample( plan.resample );\r
- csv.setNumberInterpolation( plan.samplingMode );\r
- csv.setTimeFormat( FormattingUtils.significantDigitFormat( plan.timeDigits ) );\r
- csv.setFloatFormat( FormattingUtils.significantDigitFormat( plan.floatDigits ) );\r
- csv.setNumberFormat( FormattingUtils.significantDigitFormat( plan.doubleDigits ) );\r
-\r
- try {\r
- Session session = Simantics.getSession();\r
- List<Resource> list = new ArrayList<Resource>();\r
- for(NamedResource nr : plan.models) list.add(nr.getResource());\r
- session.sync( new CSVParamsQuery(data.history, csv, list) );\r
- csv.sort();\r
- } catch (DatabaseException e2) {\r
- throw new ExecutionException(e2.getMessage(), e2);\r
- } catch (HistoryException e) {\r
- throw new ExecutionException(e.getMessage(), e);\r
- }\r
- \r
- try {\r
- // Ensure all views are built.\r
- monitor.beginTask("Exporting Time Series as CSV...", IProgressMonitor.UNKNOWN);\r
- try {\r
- data.collector.flush();\r
- if ( !f.exists() ) {\r
- f.createNewFile();\r
- } else {\r
- RandomAccessFile raf = new RandomAccessFile(f, "rw");\r
- raf.setLength(0);\r
- raf.close();\r
- }\r
- \r
- FileOutputStream fos = new FileOutputStream(f, true);\r
- BufferedOutputStream bos = new BufferedOutputStream( fos );\r
- try {\r
- PrintStream ps = new PrintStream( bos );\r
- csv.formulate2( new CSVProgressMonitor( monitor ), ps );\r
- bos.flush();\r
- } finally {\r
- fos.close();\r
- }\r
- } catch (HistoryException e) {\r
- throw new ExecutionException(e.getMessage(), e);\r
- } catch (IOException e1) {\r
- throw new ExecutionException(e1.getMessage(), e1);\r
- }\r
- monitor.setTaskName("Done");\r
- } finally {\r
- monitor.done();\r
- }\r
- \r
- }\r
- \r
-}\r
+/*******************************************************************************
+ * Copyright (c) 2012 Association for Decentralized Information Management in
+ * Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+package org.simantics.charts.ui;
+
+import java.io.BufferedOutputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.PrintStream;
+import java.io.RandomAccessFile;
+import java.lang.reflect.InvocationTargetException;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+import org.eclipse.core.commands.ExecutionException;
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.core.runtime.IStatus;
+import org.eclipse.core.runtime.Status;
+import org.eclipse.core.runtime.SubMonitor;
+import org.eclipse.core.runtime.preferences.IScopeContext;
+import org.eclipse.core.runtime.preferences.InstanceScope;
+import org.eclipse.jface.operation.IRunnableWithProgress;
+import org.osgi.service.prefs.BackingStoreException;
+import org.osgi.service.prefs.Preferences;
+import org.simantics.Simantics;
+import org.simantics.charts.Activator;
+import org.simantics.charts.editor.ChartData;
+import org.simantics.charts.editor.ChartKeys;
+import org.simantics.databoard.binding.error.BindingException;
+import org.simantics.databoard.serialization.SerializationException;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.Session;
+import org.simantics.db.common.NamedResource;
+import org.simantics.db.common.request.UniqueRead;
+import org.simantics.db.common.utils.Logger;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.layer0.request.PossibleModel;
+import org.simantics.history.HistoryException;
+import org.simantics.history.csv.CSVFormatter;
+import org.simantics.modeling.preferences.CSVPreferences;
+import org.simantics.utils.datastructures.hints.IHintContext.Key;
+import org.simantics.utils.format.FormattingUtils;
+import org.simantics.utils.ui.dialogs.ShowMessage;
+
+/**
+ * @author Antti Villberg
+ */
+public class CSVExporter implements IRunnableWithProgress {
+
+ CSVExportPlan exportModel;
+
+ public CSVExporter(CSVExportPlan exportModel) {
+ this.exportModel = exportModel;
+ }
+
+ @Override
+ public void run(IProgressMonitor monitor) throws InvocationTargetException, InterruptedException {
+ SubMonitor progress = SubMonitor.convert(monitor, 50);
+ try {
+ exportModel(progress.newChild(50, SubMonitor.SUPPRESS_NONE));
+ } catch (IOException e) {
+ throw new InvocationTargetException(e);
+ } catch (DatabaseException e) {
+ throw new InvocationTargetException(e);
+ } catch (BindingException e) {
+ throw new InvocationTargetException(e);
+ } finally {
+ monitor.done();
+ }
+ }
+
+ void exportModel(SubMonitor mon) throws IOException, DatabaseException, SerializationException, BindingException{
+
+ try {
+ doExport(mon, exportModel.exportLocation, exportModel);
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ Logger.defaultLogError(e);
+ mon.setCanceled(true);
+ ShowMessage.showError("Export failed.", "Internal application error in export. See log for details.");
+ } finally {
+ mon.setWorkRemaining(0);
+ }
+
+ }
+
+ private static Set<Resource> resolveContainingModels(final Collection<NamedResource> res) throws DatabaseException {
+ return Simantics.getSession().syncRequest(new UniqueRead<Set<Resource>>() {
+ @Override
+ public Set<Resource> perform(ReadGraph graph) throws DatabaseException {
+ Set<Resource> models = new HashSet<Resource>();
+ for (NamedResource r : res) {
+ Resource m = graph.syncRequest(new PossibleModel(r.getResource()));
+ if (m != null)
+ models.add(m);
+ }
+ return models;
+ }
+ });
+ }
+
+ public static void doExport(IProgressMonitor monitor, final File f, final CSVExportPlan plan) throws ExecutionException, IOException {
+
+ IScopeContext context = InstanceScope.INSTANCE;
+ Preferences node = context.getNode(CSVPreferences.P_NODE);
+
+ node.putDouble(CSVPreferences.P_CSV_START_TIME, plan.startTime);
+ node.putDouble(CSVPreferences.P_CSV_TIME_STEP, plan.timeStep);
+ node.put(CSVPreferences.P_CSV_DECIMAL_SEPARATOR, plan.decimalSeparator.toPreference());
+ node.put(CSVPreferences.P_CSV_COLUMN_SEPARATOR, plan.columnSeparator.toPreference());
+
+ node.putBoolean(CSVPreferences.P_CSV_RESAMPLE, plan.resample);
+ node.put(CSVPreferences.P_CSV_SAMPLING_MODE, plan.samplingMode.toPreference());
+
+ node.putInt(CSVPreferences.P_CSV_TIME_DIGITS, plan.timeDigits);
+ node.putInt(CSVPreferences.P_CSV_FLOAT_DIGITS, plan.floatDigits);
+ node.putInt(CSVPreferences.P_CSV_DOUBLE_DIGITS, plan.doubleDigits);
+
+ try {
+ node.flush();
+ } catch (BackingStoreException ex) {
+ Activator.getDefault().getLog().log(
+ new Status(IStatus.WARNING, Activator.PLUGIN_ID, "Could not store preferences for node " + node.absolutePath()));
+ }
+
+ Set<Resource> models;
+ try {
+ models = resolveContainingModels(plan.models);
+ } catch (DatabaseException e3) {
+ throw new ExecutionException("Containing model resolution failed.", e3);
+ }
+ if (models.isEmpty())
+ throw new ExecutionException("Selected resources are not part of any model");
+ if (models.size() > 1)
+ throw new ExecutionException("Selected resources are part of several models, only subscriptions from a single model can be selected");
+ Resource model = models.iterator().next();
+ Key chartDataKey = ChartKeys.chartSourceKey(model);
+
+ final ChartData data = Simantics.getProject().getHint(chartDataKey);
+ if ( data == null ) {
+ throw new ExecutionException("There is no "+chartDataKey);
+ }
+ if ( data.history == null ) {
+ throw new ExecutionException("There is no history in "+chartDataKey);
+ }
+
+ final CSVFormatter csv = new CSVFormatter();
+
+ csv.setStartTime( plan.startTime );
+ csv.setTimeStep( plan.timeStep );
+ csv.setDecimalSeparator( plan.decimalSeparator );
+ csv.setColumnSeparator( plan.columnSeparator );
+ csv.setResample( plan.resample );
+ csv.setNumberInterpolation( plan.samplingMode );
+ csv.setTimeFormat( FormattingUtils.significantDigitFormat( plan.timeDigits ) );
+ csv.setFloatFormat( FormattingUtils.significantDigitFormat( plan.floatDigits ) );
+ csv.setNumberFormat( FormattingUtils.significantDigitFormat( plan.doubleDigits ) );
+
+ try {
+ Session session = Simantics.getSession();
+ List<Resource> list = new ArrayList<Resource>();
+ for(NamedResource nr : plan.models) list.add(nr.getResource());
+ session.sync( new CSVParamsQuery(data.history, csv, list) );
+ csv.sort();
+ } catch (DatabaseException e2) {
+ throw new ExecutionException(e2.getMessage(), e2);
+ } catch (HistoryException e) {
+ throw new ExecutionException(e.getMessage(), e);
+ }
+
+ try {
+ // Ensure all views are built.
+ monitor.beginTask("Exporting Time Series as CSV...", IProgressMonitor.UNKNOWN);
+ try {
+ data.collector.flush();
+ if ( !f.exists() ) {
+ f.createNewFile();
+ } else {
+ RandomAccessFile raf = new RandomAccessFile(f, "rw");
+ raf.setLength(0);
+ raf.close();
+ }
+
+ FileOutputStream fos = new FileOutputStream(f, true);
+ BufferedOutputStream bos = new BufferedOutputStream( fos );
+ try {
+ PrintStream ps = new PrintStream( bos );
+ csv.formulate2( new CSVProgressMonitor( monitor ), ps );
+ bos.flush();
+ } finally {
+ fos.close();
+ }
+ } catch (HistoryException e) {
+ throw new ExecutionException(e.getMessage(), e);
+ } catch (IOException e1) {
+ throw new ExecutionException(e1.getMessage(), e1);
+ }
+ monitor.setTaskName("Done");
+ } finally {
+ monitor.done();
+ }
+
+ }
+
+}
Code Review / simantics / platform.git / blobdiff