erp5_open_trade: Optimise calls of updateSimulation to not overcall the API

  This optimisation aims reduce the potential activity leak when over launching accross multiple activities/transactions the updateSimulation.
  SubscriptionItem: Add a method to call updateSimulation from sqldict activities
    updateExpandableRootSimulation allow launch activities in a safer matter and have lower calls.

bt5/erp5_open_trade/SkinTemplateItem/portal_skins/erp5_open_trade/Alarm_updateOpenOrderSimulation.py

+kw = {}
+if params is None:
+  params = {}
+
+last_active_process = context.getLastActiveProcess()
+if not params.get('full', False) and last_active_process is not None:
+  # fetch only objects modified since last alarm run
+  kw['indexation_timestamp'] = '>= %s' % last_active_process.getStartDate().ISO()
+
+# register active process in order to have "windows" of last indexed objects
+context.newActiveProcess().getRelativeUrl()
+
+portal = context.getPortalObject()
+
+kw['portal_type'] = portal.getPortalOpenOrderTypeList()
+kw['children_portal_type'] = [ i + " Line" for i in portal.getPortalOpenOrderTypeList()]
+
+
+portal.portal_catalog.searchAndActivate(
+  method_id='OpenOrder_updateSimulation',
+  packet_size=1,
+  activate_kw={'tag':tag},
+  **kw
+  )
+
+# make alarm run once at time
+context.activate(after_tag=tag).getId()

bt5/erp5_open_trade/SkinTemplateItem/portal_skins/erp5_open_trade/Alarm_updateOpenOrderSimulation.xml

@@ -48,40 +48,6 @@
               </object>
             </value>
         </item>
-        <item>
-            <key> <string>_body</string> </key>
-            <value> <string encoding="cdata"><![CDATA[
-
-kw = {}\n
-if params is None:\n
-  params = {}\n
-\n
-last_active_process = context.getLastActiveProcess()\n
-if not params.get(\'full\', False) and last_active_process is not None:\n
-  # fetch only objects modified since last alarm run\n
-  kw[\'indexation_timestamp\'] = \'>= %s\' % last_active_process.getStartDate().ISO()\n
-\n
-# register active process in order to have "windows" of last indexed objects\n
-context.newActiveProcess().getRelativeUrl()\n
-\n
-portal = context.getPortalObject()\n
-\n
-kw[\'portal_type\'] = portal.getPortalOpenOrderTypeList()\n
-\n
-portal.portal_catalog.searchAndActivate(\n
-  method_id=\'OpenOrder_updateSimulation\',\n
-#  method_kw={\'tag\': tag}, # XXX: Post merge compatibility, maybe OpenOrder_updateSimulation shall be reconfigured to being able to expand without activity (immediate expand)\n
-  packet_size=1, # As OpenOrder_updateSimulation can generate big transaction separate the calls\n
-  activate_kw={\'tag\':tag},\n
-  **kw # XXX: In one query put parents of last modified lines\n
-  )\n
-\n
-# make alarm run once at time\n
-context.activate(after_tag=tag).getId()\n
-
-
-]]></string> </value>
-        </item>
         <item>
             <key> <string>_params</string> </key>
             <value> <string>tag, fixit, params</string> </value>

bt5/erp5_open_trade/SkinTemplateItem/portal_skins/erp5_open_trade/OpenOrder_updateSimulation.py

 subscription_item_set = set()
+portal = context.getPortalObject()
+
+def hasUpdateSimulationActivity(item):
+  for activity in portal.portal_activities.getMessageList(
+     method_id="_updateSimulation", path="/erp5/" + item.getRelativeUrl()):
+    if activity.kw == {"expand_root" : 1}:
+      return True
+
+  return False
 
 for open_order_line in context.objectValues():
   for ob in [open_order_line] + open_order_line.getCellValueList():
     for item in ob.getAggregateValueList():
-       if getattr(item.aq_explicit, 'updateSimulation', None) is not None and \
+      if getattr(item.aq_explicit, 'updateSimulation', None) is not None and \
           item not in subscription_item_set:
-         subscription_item_set.add(item)
-         item.updateSimulation(expand_root=1)
+        subscription_item_set.add(item)
+
+        # Optmise for not launch an activity when some activity
+        # is there already pending for the same purpose.
+        if not hasUpdateSimulationActivity(item):
+          if getattr(item.aq_explicit, 'updateExpandableRootSimulation', None):
+            # If this method is implemented use activate to only execute it
+            # once.
+            item.activate().updateExpandableRootSimulation()
+          else:
+            item.updateSimulation(expand_root=1)

product/ERP5/Document/SubscriptionItem.py

@@ -176,6 +176,10 @@ class SubscriptionItem(Item, CompositionMixin, MovementGeneratorMixin,
 
     return result
 
+  def updateExpandableRootSimulation(self):
+    """ Utility method to help use updateSimulation with SQLDict on activities """
+    self.updateSimulation(expand_root=1)
+
   # XXX BELOW HACKS
   def getResource(self):
     open_order_line = self.getAggregateRelatedValue(portal_type='Open Sale Order Line')