1 package org.simantics.simulation.export;
\r
3 import java.util.ArrayList;
\r
4 import java.util.Collections;
\r
5 import java.util.List;
\r
7 import org.eclipse.core.runtime.IProgressMonitor;
\r
8 import org.simantics.Simantics;
\r
9 import org.simantics.databoard.binding.error.BindingException;
\r
10 import org.simantics.databoard.binding.mutable.Variant;
\r
11 import org.simantics.databoard.util.Bean;
\r
12 import org.simantics.db.exception.DatabaseException;
\r
13 import org.simantics.export.core.ExportContext;
\r
14 import org.simantics.export.core.error.ExportException;
\r
15 import org.simantics.export.core.intf.ExportClass;
\r
16 import org.simantics.export.core.manager.Content;
\r
17 import org.simantics.history.History;
\r
18 import org.simantics.history.HistoryException;
\r
19 import org.simantics.history.HistoryManager;
\r
20 import org.simantics.history.ItemManager;
\r
21 import org.simantics.history.util.subscription.SamplingFormat;
\r
22 import org.simantics.simulation.experiment.IExperiment;
\r
23 import org.simantics.simulation.experiment.IHistoryExperiment;
\r
24 import org.simantics.simulation.export.CSVItemsQuery.CSVItem;
\r
25 import org.simantics.simulation.project.ExperimentManager;
\r
26 import org.simantics.simulation.project.IExperimentManager;
\r
27 import org.simantics.utils.datastructures.MapList;
\r
29 public class ExportSubscriptionCSV extends ExperimentExportClass implements ExportClass {
\r
32 public void export(List<Content> contents,
\r
34 ExportContext context,
\r
36 IProgressMonitor monitor,
\r
37 MapList<Content, Content> attachmentMap
\r
38 ) throws ExportException {
\r
40 // Flush all experiments, just in case.
\r
41 IExperimentManager em = Simantics.getProject().getHint( ExperimentManager.KEY_EXPERIMENT_MANAGER );
\r
43 for (IExperiment exp : em.getExperiments()) {
\r
44 if ( exp instanceof IHistoryExperiment ) {
\r
45 IHistoryExperiment he = (IHistoryExperiment) exp;
\r
48 } catch (HistoryException e) {
\r
54 CSVWriter writer = (CSVWriter) writer_;
\r
55 List<HistoryManager> historiesToClose = new ArrayList<HistoryManager>();
\r
57 List<ModelRef> models = ExperimentExportClass.getResult(context, options, true);
\r
59 // Label format is the following
\r
60 // "MODEL EXPERIMENT/RUN ITEM"
\r
61 // MODEL is omited, if itemCount <= 1
\r
62 // RUN is omited, if runCount <= 1
\r
64 int modelCount = models.size();
\r
65 for (ModelRef model : models) runCount += model.enabledRunCount();
\r
67 List<CSVItem> items = new ArrayList<CSVItem>();
\r
68 for (Content content : contents) {
\r
69 items.addAll( context.session.syncRequest( new CSVItemsQuery( content.url ) ) );
\r
73 for (ModelRef model : models) {
\r
74 for (ExperimentRef experiment : model.experiments) {
\r
75 if ( experiment.runs.isEmpty() ) continue;
\r
76 for (RunRef run : experiment.runs) {
\r
77 if ( run.historyFolder == null || !run.historyFolder.exists() ) continue;
\r
79 HistoryManager history = History.openFileHistory( run.historyFolder );
\r
80 historiesToClose.add( history );
\r
81 ItemManager im = new ItemManager( history.getItems() );
\r
83 for ( CSVItem item : items ) {
\r
84 if ( !item.modelUri.equals( model.uri ) ) continue;
\r
85 StringBuilder labelBuilder = new StringBuilder();
\r
86 labelBuilder.append( item.label );
\r
87 if ( modelCount>1 ) {
\r
88 labelBuilder.append(" (");
\r
89 labelBuilder.append(model.label);
\r
90 labelBuilder.append(")");
\r
93 labelBuilder.append(" (");
\r
94 labelBuilder.append( experiment.label );
\r
95 labelBuilder.append( "\\" );
\r
96 labelBuilder.append( run.label );
\r
97 labelBuilder.append(")");
\r
100 List<Bean> historyItems = im.search("variableId", item.variableReference);
\r
101 Collections.sort(historyItems, SamplingFormat.INTERVAL_COMPARATOR);
\r
102 if (items.isEmpty()) continue;
\r
103 Bean config = historyItems.get(0);
\r
104 String historyId = (String) config.getFieldUnchecked("id");
\r
106 writer.addItem(history, historyId, labelBuilder.toString(), item.variableReference, item.unit);
\r
113 } catch (DatabaseException e) {
\r
114 throw new ExportException( e );
\r
115 } catch (HistoryException e) {
\r
116 throw new ExportException( e );
\r
117 } catch (BindingException e) {
\r
118 throw new ExportException( e );
\r
120 for (HistoryManager history : historiesToClose) history.close();
\r
126 public List<String> validate(String contentUri, ExportContext context, Variant options) {
\r
127 return Collections.emptyList();
\r