-/*******************************************************************************\r
- * Copyright (c) 2007, 2011 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.modeling.subscription;\r
-\r
-import java.util.UUID;\r
-\r
-import org.simantics.databoard.Bindings;\r
-import org.simantics.databoard.Databoard;\r
-import org.simantics.databoard.binding.Binding;\r
-import org.simantics.db.ReadGraph;\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.common.request.PossibleTypedParent;\r
-import org.simantics.db.common.request.ResourceRead;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.db.layer0.request.PossibleActiveExperiment;\r
-import org.simantics.db.layer0.variable.RVI;\r
-import org.simantics.db.layer0.variable.Variable;\r
-import org.simantics.db.layer0.variable.Variables;\r
-import org.simantics.layer0.Layer0;\r
-import org.simantics.modeling.ModelingResources;\r
-\r
-/**\r
- * This query returns SubscriptionItem description\r
- * \r
- * @author Antti Villberg\r
- */\r
-public class SubscriptionItemQuery extends ResourceRead<SubscriptionItem> {\r
-\r
- public SubscriptionItemQuery(Resource resource) {\r
- super(resource);\r
- }\r
-\r
- @SuppressWarnings("unused")\r
- @Override\r
- public SubscriptionItem perform(ReadGraph graph) throws DatabaseException {\r
- \r
- ModelingResources MOD = ModelingResources.getInstance(graph);\r
- Layer0 L0 = Layer0.getInstance(graph);\r
-\r
- SubscriptionItem item = new SubscriptionItem();\r
- \r
- item.variableId = "";\r
- item.groupItemId = "";\r
- Resource subscriptionItem = resource;\r
- Resource subscription = null;\r
- if (subscriptionItem!=null) {\r
- item.simpleLabel = graph.getPossibleRelatedValue(subscriptionItem, L0.HasLabel, Bindings.STRING);\r
- subscription = graph.syncRequest( new PossibleTypedParent(subscriptionItem, MOD.Subscription) ); \r
- }\r
- if (item.simpleLabel==null) item.simpleLabel = "";\r
- if (subscriptionItem != null) \r
- SubscriptionItem: { \r
- \r
- label2: {\r
- item.groupItemId = graph.getPossibleRelatedValue(subscriptionItem, L0.HasName, Bindings.STRING);\r
- if (item.groupItemId == null) break SubscriptionItem;\r
-\r
- Binding rviBinding = graph.getService(Databoard.class).getBindingUnchecked( RVI.class );\r
- RVI rvi = graph.getPossibleRelatedValue(subscriptionItem, MOD.Subscription_Item_VariableId, rviBinding);\r
- if (rvi == null) break SubscriptionItem; \r
- //variablePersistentId = rvi.toString();\r
- \r
- Variable configuration = Variables.getPossibleConfigurationContext(graph, subscription);\r
- if (configuration == null) break SubscriptionItem;\r
- \r
- Resource activeExperiment = graph.syncRequest(new PossibleActiveExperiment(subscription));\r
- if (activeExperiment != null) {\r
- Variable experimentVariable = null;\r
- try {\r
- experimentVariable = Variables.switchRealization(graph, configuration, activeExperiment);\r
- } catch (DatabaseException e) {\r
- experimentVariable = Variables.switchPossibleContext(graph, configuration, activeExperiment);\r
- }\r
- if (experimentVariable != null) {\r
- configuration = experimentVariable;\r
- }\r
- }\r
-\r
- item.variableId = item.variableReference = rvi.toPossibleString(graph, configuration);\r
- if (item.variableId == null) break SubscriptionItem;\r
-\r
- if (item.simpleLabel.isEmpty()) {\r
- item.simpleLabel = SubscriptionItemLabel.removeVariablePrefixPath( item.variableId );\r
- }\r
- }\r
- \r
- subscription: {\r
- if (subscription!=null) {\r
- item.groupId = graph.getPossibleRelatedValue(subscription, L0.HasName, Bindings.STRING);\r
- } else {\r
- item.groupId = UUID.randomUUID().toString();\r
- }\r
- }\r
- \r
- unit: {\r
- item.unit = graph.getPossibleRelatedValue(subscriptionItem, MOD.Subscription_Item_Unit, Bindings.STRING);\r
- }\r
- \r
- } \r
- \r
- if (item.groupItemId==null) item.groupItemId = "";\r
- if (item.variableId==null) item.variableId = "";\r
- if (item.groupId==null) item.groupId = "";\r
- if (item.unit==null) item.unit = "";\r
- \r
- return item;\r
- }\r
-\r
-}\r
+/*******************************************************************************
+ * Copyright (c) 2007, 2011 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.modeling.subscription;
+
+import java.util.UUID;
+
+import org.simantics.databoard.Bindings;
+import org.simantics.databoard.Databoard;
+import org.simantics.databoard.binding.Binding;
+import org.simantics.db.ReadGraph;
+import org.simantics.db.Resource;
+import org.simantics.db.common.request.PossibleTypedParent;
+import org.simantics.db.common.request.ResourceRead;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.db.layer0.request.PossibleActiveExperiment;
+import org.simantics.db.layer0.variable.RVI;
+import org.simantics.db.layer0.variable.Variable;
+import org.simantics.db.layer0.variable.Variables;
+import org.simantics.layer0.Layer0;
+import org.simantics.modeling.ModelingResources;
+
+/**
+ * This query returns SubscriptionItem description
+ *
+ * @author Antti Villberg
+ */
+public class SubscriptionItemQuery extends ResourceRead<SubscriptionItem> {
+
+ public SubscriptionItemQuery(Resource resource) {
+ super(resource);
+ }
+
+ @SuppressWarnings("unused")
+ @Override
+ public SubscriptionItem perform(ReadGraph graph) throws DatabaseException {
+
+ ModelingResources MOD = ModelingResources.getInstance(graph);
+ Layer0 L0 = Layer0.getInstance(graph);
+
+ SubscriptionItem item = new SubscriptionItem();
+
+ item.variableId = "";
+ item.groupItemId = "";
+ Resource subscriptionItem = resource;
+ Resource subscription = null;
+ if (subscriptionItem!=null) {
+ item.simpleLabel = graph.getPossibleRelatedValue(subscriptionItem, L0.HasLabel, Bindings.STRING);
+ subscription = graph.syncRequest( new PossibleTypedParent(subscriptionItem, MOD.Subscription) );
+ }
+ if (item.simpleLabel==null) item.simpleLabel = "";
+ if (subscriptionItem != null)
+ SubscriptionItem: {
+
+ label2: {
+ item.groupItemId = graph.getPossibleRelatedValue(subscriptionItem, L0.HasName, Bindings.STRING);
+ if (item.groupItemId == null) break SubscriptionItem;
+
+ Binding rviBinding = graph.getService(Databoard.class).getBindingUnchecked( RVI.class );
+ RVI rvi = graph.getPossibleRelatedValue(subscriptionItem, MOD.Subscription_Item_VariableId, rviBinding);
+ if (rvi == null) break SubscriptionItem;
+ //variablePersistentId = rvi.toString();
+
+ Variable configuration = Variables.getPossibleConfigurationContext(graph, subscription);
+ if (configuration == null) break SubscriptionItem;
+
+ Resource activeExperiment = graph.syncRequest(new PossibleActiveExperiment(subscription));
+ if (activeExperiment != null) {
+ Variable experimentVariable = null;
+ try {
+ experimentVariable = Variables.switchRealization(graph, configuration, activeExperiment);
+ } catch (DatabaseException e) {
+ experimentVariable = Variables.switchPossibleContext(graph, configuration, activeExperiment);
+ }
+ if (experimentVariable != null) {
+ configuration = experimentVariable;
+ }
+ }
+
+ item.variableId = item.variableReference = rvi.toPossibleString(graph, configuration);
+ if (item.variableId == null) break SubscriptionItem;
+
+ if (item.simpleLabel.isEmpty()) {
+ item.simpleLabel = SubscriptionItemLabel.removeVariablePrefixPath( item.variableId );
+ }
+ }
+
+ subscription: {
+ if (subscription!=null) {
+ item.groupId = graph.getPossibleRelatedValue(subscription, L0.HasName, Bindings.STRING);
+ } else {
+ item.groupId = UUID.randomUUID().toString();
+ }
+ }
+
+ unit: {
+ item.unit = graph.getPossibleRelatedValue(subscriptionItem, MOD.Subscription_Item_Unit, Bindings.STRING);
+ }
+
+ }
+
+ if (item.groupItemId==null) item.groupItemId = "";
+ if (item.variableId==null) item.variableId = "";
+ if (item.groupId==null) item.groupId = "";
+ if (item.unit==null) item.unit = "";
+
+ return item;
+ }
+
+}
Code Review / simantics / platform.git / blobdiff