Revert "new functionality: support measurement intervals"

This reverts commit b0ddd24d

bt5/erp5_wendelin/SkinTemplateItem/portal_skins/erp5_wendelin/DataAnalysis_executeDataOperation.py

@@ -2,7 +2,6 @@ portal = context.getPortalObject()
 operation = None
 use = None
 parameter_dict = {}
-
 context.checkConsistency(fixit=True)
 initial_product = context.getSpecialiseValue(portal_type="Data Transformation").getResourceValue()
 for analysis_line in context.objectValues(portal_type="Data Analysis Line"):
@@ -29,9 +28,6 @@ for analysis_line in context.objectValues(portal_type="Data Analysis Line"):
       parameter[base_category] = analysis_line.getVariationCategoryItemList(
                                    base_category_list=(base_category,))[0][0]
     reference = analysis_line.getReference()
-    
-    parameter["Start Date"] = analysis_line.getStartDate()
-    parameter["Stop Date"] = analysis_line.getStopDate()
     # several lines with same reference wil turn the parameter into a list
     if reference in parameter_dict:
       if not isinstance(parameter_dict[reference], list):
@@ -39,9 +35,7 @@ for analysis_line in context.objectValues(portal_type="Data Analysis Line"):
       parameter_dict[reference].append(parameter)
     else:
       parameter_dict[reference] = parameter
-
 script_id = operation.getScriptId()
-
 out = getattr(operation_analysis_line, script_id)(**parameter_dict)
 
 if out == 1:

bt5/erp5_wendelin/SkinTemplateItem/portal_skins/erp5_wendelin/ERP5Site_createDataAnalysisList.py

@@ -35,7 +35,6 @@ for movement in portal_catalog(query):
   delivery = movement.getParentValue()
   data_supply = delivery.getSpecialiseValue(portal_type="Data Supply")
   data_supply_list = delivery.getSpecialiseValueList(portal_type="Data Supply")
-
   composed_data_supply = data_supply.asComposedDocument()
   # Get applicable transformation
   transformation_list = []
@@ -92,7 +91,6 @@ for movement in portal_catalog(query):
                      "Data Transformation Operation Line"]):
       resource = transformation_line.getResourceValue()
       quantity = transformation_line.getQuantity()
-
       if isinstance(quantity, tuple):
         quantity = quantity[0]
       # In case of shared data anylsis only add additional input lines
@@ -101,7 +99,6 @@ for movement in portal_catalog(query):
       aggregate_set = set()
       # manually add device to every line
       aggregate_set.add(movement.getAggregateDevice())
-
       if transformation_line.getPortalType() == \
           "Data Transformation Resource Line":
         # at the moment, we only check for positive or negative quantity
@@ -113,7 +110,6 @@ for movement in portal_catalog(query):
           # then we search for an ingestion line with resource portal type
           # Data Product
           batch_relative_url = movement.getAggregateDataIngestionBatch()
-
           if batch_relative_url is not None:
             related_movement_list = portal_catalog(
               portal_type="Data Ingestion Line",
@@ -124,10 +120,10 @@ for movement in portal_catalog(query):
             related_movement_list = movement.getParentValue().searchFolder(
               portal_type=["Data Ingestion Line", "Data Analysis Line"],
               resource_relative_url = resource.getRelativeUrl())
-          #for related_movement in related_movement_list:
-            #aggregate_set.update(related_movement.getAggregateSet())   ########## do not copy device configurations to lines!!
-            #if related_movement.getUse() == "big_data/ingestion/batch":
-              #related_movement.getParentValue().deliver()
+          for related_movement in related_movement_list:
+            aggregate_set.update(related_movement.getAggregateSet())
+            if related_movement.getUse() == "big_data/ingestion/batch":
+              related_movement.getParentValue().deliver()
         # create new item based on item_type if it is not already aggregated
         aggregate_type_set = set(
           [portal.restrictedTraverse(a).getPortalType() for a in aggregate_set])
@@ -135,15 +131,7 @@ for movement in portal_catalog(query):
           # create item if it does note exist yet.
           # Except if it is a Data Array Line, then it is currently created by
           # data operation itself (probably this exception is inconsistent)
-
-        if transformation_line.getPortalType() ==  "Data Transformation Operation Line" and item_type not in aggregate_type_set:
-          if item_type in portal.getPortalDeviceConfigurationTypeList() + portal.getPortalDataConfigurationTypeList():
-            item = portal.portal_catalog.getResultValue(
-              portal_type=item_type,
-              #validation_state="validated",
-              item_project_relative_url=data_analysis.getDestinationProject(),
-              item_source_relative_url=data_analysis.getSource())
-          elif item_type != "Data Array Line":
+          if item_type not in aggregate_type_set and item_type != "Data Array Line":
             item = portal.portal_catalog.getResultValue(
               portal_type=item_type,
               validation_state="validated",
@@ -164,15 +152,14 @@ for movement in portal_catalog(query):
               except AttributeError:
                 pass
             aggregate_set.add(item.getRelativeUrl())
-
       # find other items such as device configuration and data configuration
       # from data ingestion and data supply
-      #composed = data_analysis.asComposedDocument()
-      #line_list = [l for l in delivery.objectValues(portal_type="Data Ingestion Line")]
-      #line_list +=  [l for l in composed.objectValues(portal_type="Data Supply Line")]
-      #for line in line_list:
-        #if line.getResourceValue().getPortalType() == "Data Operation":
-          #aggregate_set.update(line.getAggregateList())
+      composed = data_analysis.asComposedDocument()
+      line_list = [l for l in delivery.objectValues(portal_type="Data Ingestion Line")]
+      line_list +=  [l for l in composed.objectValues(portal_type="Data Supply Line")]
+      for line in line_list:
+        if line.getResourceValue().getPortalType() == "Data Operation":
+          aggregate_set.update(line.getAggregateList())
 
       data_analysis_line = data_analysis.newContent(
         portal_type = "Data Analysis Line",
@@ -185,12 +172,12 @@ for movement in portal_catalog(query):
         quantity_unit = transformation_line.getQuantityUnit(),
         use = transformation_line.getUse(),
         aggregate_set = aggregate_set)
+
       # for intput lines of first level analysis set causality and specialise
       if quantity < 0 and delivery.getPortalType() == "Data Ingestion":
         data_analysis_line.edit(
           causality_value = delivery,
           specialise_value_list = data_supply_list)
-
     data_analysis.checkConsistency(fixit=True)
     try:
       data_analysis.start()