Delivery.py 21.8 KB
Newer Older
Jean-Paul Smets's avatar
Jean-Paul Smets committed
1 2
##############################################################################
#
Romain Courteaud's avatar
Romain Courteaud committed
3
# Copyright (c) 2002, 2005 Nexedi SARL and Contributors. All Rights Reserved.
4
#                    Jean-Paul Smets-Solanes <jp@nexedi.com>
Romain Courteaud's avatar
Romain Courteaud committed
5
#                    Romain Courteaud <romain@nexedi.com>
Jean-Paul Smets's avatar
Jean-Paul Smets committed
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35
#
# WARNING: This program as such is intended to be used by professional
# programmers who take the whole responsability of assessing all potential
# consequences resulting from its eventual inadequacies and bugs
# End users who are looking for a ready-to-use solution with commercial
# garantees and support are strongly adviced to contract a Free Software
# Service Company
#
# This program is Free Software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2
# of the License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
#
##############################################################################

from Globals import InitializeClass, PersistentMapping
from Products.CMFCore.utils import getToolByName
from Products.CMFCore.WorkflowCore import WorkflowMethod
from AccessControl import ClassSecurityInfo
from Products.ERP5Type import Permissions, PropertySheet, Constraint, Interface
from Products.ERP5Type.XMLObject import XMLObject
36
from Products.ERP5Type.Base import Base
Jean-Paul Smets's avatar
Jean-Paul Smets committed
37 38 39
from Products.ERP5.Document.DeliveryCell import DeliveryCell
from Acquisition import Explicit, Implicit
from Products.PythonScripts.Utility import allow_class
40
from DateTime import DateTime
Jean-Paul Smets's avatar
Jean-Paul Smets committed
41 42 43 44

from zLOG import LOG

class Delivery(XMLObject):
45 46 47 48
    """
        Each time delivery is modified, it MUST launch a reindexing of
        inventories which are related to the resources contained in the Delivery
    """
Jean-Paul Smets's avatar
Jean-Paul Smets committed
49 50 51 52 53
    # CMF Type Definition
    meta_type = 'ERP5 Delivery'
    portal_type = 'Delivery'
    isPortalContent = 1
    isRADContent = 1
54
    isDelivery = 1
Jean-Paul Smets's avatar
Jean-Paul Smets committed
55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93

    # Declarative security
    security = ClassSecurityInfo()
    security.declareObjectProtected(Permissions.View)

    # Default Properties
    property_sheets = ( PropertySheet.Base
                      , PropertySheet.XMLObject
                      , PropertySheet.CategoryCore
                      , PropertySheet.DublinCore
                      , PropertySheet.Task
                      , PropertySheet.Arrow
                      , PropertySheet.Movement
                      , PropertySheet.Delivery
                      , PropertySheet.Reference
                      )

    security.declareProtected(Permissions.AccessContentsInformation, 'isAccountable')
    def isAccountable(self):
      """
        Returns 1 if this needs to be accounted
        Only account movements which are not associated to a delivery
        Whenever delivery is there, delivery has priority
      """
      return 1

    # Pricing methods
    def _getTotalPrice(self, context):
      return 2.0

    def _getDefaultTotalPrice(self, context):
      return 3.0

    def _getSourceTotalPrice(self, context):
      return 4.0

    def _getDestinationTotalPrice(self, context):
      return 5.0

Yoshinori Okuji's avatar
Yoshinori Okuji committed
94
    security.declareProtected(Permissions.AccessContentsInformation, 'getDefaultTotalPrice')
Jean-Paul Smets's avatar
Jean-Paul Smets committed
95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112
    def getDefaultTotalPrice(self, context=None, REQUEST=None, **kw):
      """
      """
      return self._getDefaultTotalPrice(self.asContext(context=context, REQUEST=REQUEST, **kw))

    security.declareProtected(Permissions.AccessContentsInformation, 'getSourceTotalPrice')
    def getSourceTotalPrice(self, context=None, REQUEST=None, **kw):
      """
      """
      return self._getSourceTotalPrice(self.asContext(context=context, REQUEST=REQUEST, **kw))

    security.declareProtected(Permissions.AccessContentsInformation, 'getDestinationTotalPrice')
    def getDestinationTotalPrice(self, context=None, REQUEST=None, **kw):
      """
      """
      return self._getDestinationTotalPrice(self.asContext(context=context, REQUEST=REQUEST, **kw))

    # Pricing
Jean-Paul Smets's avatar
Jean-Paul Smets committed
113 114 115 116 117 118
    security.declareProtected( Permissions.ModifyPortalContent, 'updatePrice' )
    def updatePrice(self):
      for c in self.objectValues():
        if hasattr(aq_base(c), 'updatePrice'):
          c.updatePrice()

Jean-Paul Smets's avatar
Jean-Paul Smets committed
119
    security.declareProtected(Permissions.AccessContentsInformation, 'getTotalPrice')
120
    def getTotalPrice(self,  src__=0, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
121 122 123
      """
        Returns the total price for this order
      """
124
      kw['explanation_uid'] = self.getUid()
125 126
      kw.update(self.portal_catalog.buildSQLQuery(**kw))
      if src__:
127 128
        return self.Delivery_zGetTotal(src__=1, **kw)
      aggregate = self.Delivery_zGetTotal(**kw)[0]
129
      return aggregate.total_price or 0
Jean-Paul Smets's avatar
Jean-Paul Smets committed
130 131

    security.declareProtected(Permissions.AccessContentsInformation, 'getTotalQuantity')
132
    def getTotalQuantity(self, src__=0, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
133 134
      """
        Returns the quantity if no cell or the total quantity if cells
135
      """
136
      kw['explanation_uid'] = self.getUid()
137 138
      kw.update(self.portal_catalog.buildSQLQuery(**kw))
      if src__:
139 140
        return self.Delivery_zGetTotal(src__=1, **kw)
      aggregate = self.Delivery_zGetTotal(**kw)[0]
141
      return aggregate.total_quantity or 0
Jean-Paul Smets's avatar
Jean-Paul Smets committed
142 143 144 145 146 147 148

    security.declareProtected(Permissions.AccessContentsInformation, 'getDeliveryUid')
    def getDeliveryUid(self):
      return self.getUid()

    security.declareProtected(Permissions.AccessContentsInformation, 'getDeliveryValue')
    def getDeliveryValue(self):
149 150 151 152 153 154 155 156 157 158 159
      """
      Deprecated, we should use getRootDeliveryValue instead
      """
      return self

    security.declareProtected(Permissions.AccessContentsInformation, 'getRootDeliveryValue')
    def getRootDeliveryValue(self):
      """
      This method returns the delivery, it is usefull to retrieve the delivery
      from a line or a cell
      """
Jean-Paul Smets's avatar
Jean-Paul Smets committed
160 161
      return self

162 163 164 165
    security.declareProtected(Permissions.AccessContentsInformation, 'getDelivery')
    def getDelivery(self):
      return self.getRelativeUrl()

166
    security.declareProtected(Permissions.AccessContentsInformation,
Romain Courteaud's avatar
Romain Courteaud committed
167 168
                             'getMovementList')
    def getMovementList(self, portal_type=None, **kw):
169 170 171
      """
        Return a list of movements.
      """
172 173
      if portal_type is None:
        portal_type = self.getPortalMovementTypeList()
Jean-Paul Smets's avatar
Jean-Paul Smets committed
174
      movement_list = []
175
      for m in self.contentValues(filter={'portal_type': portal_type}):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
176
        if m.hasCellContent():
177
          for c in m.contentValues(filter={'portal_type': portal_type}):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
178 179 180 181 182
            movement_list.append(c)
        else:
          movement_list.append(m)
      return movement_list

183 184 185 186 187 188
    security.declareProtected(Permissions.AccessContentsInformation, 'getSimulatedMovementList')
    def getSimulatedMovementList(self):
      """
        Return a list of simulated movements.
        This does not contain Container Line or Container Cell.
      """
189
      return self.getMovementList(portal_type=self.getPortalSimulatedMovementTypeList())
190 191 192 193 194 195 196

    security.declareProtected(Permissions.AccessContentsInformation, 'getInvoiceMovementList')
    def getInvoiceMovementList(self):
      """
        Return a list of simulated movements.
        This does not contain Container Line or Container Cell.
      """
197
      return self.getMovementList(portal_type=self.getPortalInvoiceMovementTypeList())
198 199 200 201 202 203 204 205

    security.declareProtected(Permissions.AccessContentsInformation, 'getContainerList')
    def getContainerList(self):
      """
        Return a list of root containers.
        This does not contain sub-containers.
      """
      container_list = []
206
      for m in self.contentValues(filter={'portal_type': self.getPortalContainerTypeList()}):
207 208 209
        container_list.append(m)
      return container_list

Jean-Paul Smets's avatar
Jean-Paul Smets committed
210 211 212 213 214
    def applyToDeliveryRelatedMovement(self, portal_type='Simulation Movement', method_id = 'expand'):
      for my_simulation_movement in self.getDeliveryRelatedValueList(
                                                portal_type = 'Simulation Movement'):
          # And apply
          getattr(my_simulation_movement.getObject(), method_id)()
215
      for m in self.contentValues(filter={'portal_type': self.getPortalMovementTypeList()}):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
216 217 218 219 220 221 222 223 224 225 226 227 228 229 230
        # Find related in simulation
        for my_simulation_movement in m.getDeliveryRelatedValueList(
                                                portal_type = 'Simulation Movement'):
          # And apply
          getattr(my_simulation_movement.getObject(), method_id)()
        for c in m.contentValues(filter={'portal_type': 'Delivery Cell'}):
          for my_simulation_movement in c.getDeliveryRelatedValueList(
                                                portal_type = 'Simulation Movement'):
            # And apply
            getattr(my_simulation_movement.getObject(), method_id)()


    #######################################################
    # Causality computation
    security.declareProtected(Permissions.View, 'isConvergent')
231
    def isConvergent(self,**kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
232 233 234
      """
        Returns 0 if the target is not met
      """
235
      return int(not self.isDivergent(**kw))
Jean-Paul Smets's avatar
Jean-Paul Smets committed
236

Jean-Paul Smets's avatar
Jean-Paul Smets committed
237 238
    security.declareProtected(Permissions.View, 'isSimulated')
    def isSimulated(self):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
239 240 241 242
      """
        Returns 1 if all movements have a delivery or order counterpart
        in the simulation
      """
243
      #LOG('Delivery.isSimulated getMovementList',0,self.getMovementList())
Jean-Paul Smets's avatar
Jean-Paul Smets committed
244
      for m in self.getMovementList():
245 246
        #LOG('Delivery.isSimulated m',0,m.getPhysicalPath())
        #LOG('Delivery.isSimulated m.isSimulated',0,m.isSimulated())
Jean-Paul Smets's avatar
Jean-Paul Smets committed
247
        if not m.isSimulated():
248 249
          #LOG('Delivery.isSimulated m.getQuantity',0,m.getQuantity())
          #LOG('Delivery.isSimulated m.getSimulationQuantity',0,m.getSimulationQuantity())
250
          if m.getQuantity() != 0.0 or m.getSimulationQuantity() != 0:
251 252
            return 0
          # else Do we need to create a simulation movement ? XXX probably not
Jean-Paul Smets's avatar
Jean-Paul Smets committed
253 254
      return 1

255
    security.declareProtected(Permissions.View, 'isDivergent')
256
    def isDivergent(self,fast=0,**kw):
257 258 259 260
      """
        Returns 1 if the target is not met according to the current information
        After and edit, the isOutOfTarget will be checked. If it is 1,
        a message is emitted
Jean-Paul Smets's avatar
Jean-Paul Smets committed
261

262 263
        emit targetUnreachable !
      """
264 265 266 267
      # Delivery_zIsDivergent only works when object and simulation is
      # reindexed, so if an user change the delivery, he must wait
      # until everything is indexed, this is not acceptable for users
      # so we should not use it by default (and may be we should remove)
268
      if fast==1 and len(self.Delivery_zIsDivergent(uid=self.getUid())) > 0:
269 270
        return 1
      # Check if the total quantity equals the total of each simulation movement quantity
271 272 273
      for movement in self.getMovementList():
        if movement.isDivergent():
          return 1
Jean-Paul Smets's avatar
Jean-Paul Smets committed
274 275
      return 0

276 277 278 279 280 281
    def updateCausalityState(self,**kw):
      """
      This is often called as an activity, it will check if the
      deliver is convergent, and if so it will put the delivery
      in a solved state, if not convergent in a diverged state
      """
282 283 284 285 286
      if hasattr(self,'diverge') and hasattr(self,'converge'):
        if self.isDivergent():
          self.diverge()
        else:
          self.converge()
287

Jean-Paul Smets's avatar
Jean-Paul Smets committed
288 289 290 291 292 293
    #######################################################
    # Defer indexing process
    def reindexObject(self, *k, **kw):
      """
        Reindex children and simulation
      """
294 295 296 297
      self.recursiveReindexObject()
      # NEW: we never rexpand simulation - This is a task for DSolver / TSolver
      # Make sure expanded simulation is still OK (expand and reindex)
      # self.activate().applyToDeliveryRelatedMovement(method_id = 'expand')
Jean-Paul Smets's avatar
Jean-Paul Smets committed
298 299 300 301 302

    #######################################################
    # Stock Management
    def _getMovementResourceList(self):
      resource_dict = {}
303
      for m in self.contentValues(filter={'portal_type': self.getPortalMovementTypeList()}):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
304 305 306 307 308 309
        r = m.getResource()
        if r is not None:
          resource_dict[r] = 1
      return resource_dict.keys()

    security.declareProtected(Permissions.AccessContentsInformation, 'getInventory')
310 311 312 313 314 315
    def getInventory(self, **kw):
      """
      Returns inventory
      """
      kw['resource'] = self._getMovementResourceList()
      return self.portal_simulation.getInventory(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
316 317

    security.declareProtected(Permissions.AccessContentsInformation, 'getCurrentInventory')
318
    def getCurrentInventory(self, **kw):
319 320 321 322 323
      """
      Returns current inventory
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getCurrentInventory(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
324 325

    security.declareProtected(Permissions.AccessContentsInformation, 'getAvailableInventory')
326
    def getAvailableInventory(self, **kw):
327 328 329 330 331 332 333 334
      """
      Returns available inventory
      (current inventory - deliverable)
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getAvailableInventory(**kw)

    security.declareProtected(Permissions.AccessContentsInformation, 'getFutureInventory')
335
    def getFutureInventory(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
336
      """
337
      Returns inventory at infinite
Jean-Paul Smets's avatar
Jean-Paul Smets committed
338
      """
339 340
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getFutureInventory(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
341 342

    security.declareProtected(Permissions.AccessContentsInformation, 'getInventoryList')
343
    def getInventoryList(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
344
      """
345
      Returns list of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
346
      """
347 348
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getInventoryList(**kw)
349

350
    security.declareProtected(Permissions.AccessContentsInformation, 'getCurrentInventoryList')
351
    def getCurrentInventoryList(self, **kw):
352 353 354 355 356
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getCurrentInventoryList(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
357 358

    security.declareProtected(Permissions.AccessContentsInformation, 'getFutureInventoryList')
359
    def getFutureInventoryList(self, **kw):
360 361 362 363 364
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getFutureInventoryList(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
365 366

    security.declareProtected(Permissions.AccessContentsInformation, 'getInventoryStat')
367
    def getInventoryStat(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
368
      """
369
      Returns statistics of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
370
      """
371 372
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getInventoryStat(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
373

374
    security.declareProtected(Permissions.AccessContentsInformation, 'getCurrentInventoryStat')
375
    def getCurrentInventoryStat(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
376
      """
377
      Returns statistics of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
378
      """
379 380
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getCurrentInventoryStat(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
381

382
    security.declareProtected(Permissions.AccessContentsInformation, 'getFutureInventoryStat')
383
    def getFutureInventoryStat(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
384
      """
385
      Returns statistics of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
386
      """
387 388
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getFutureInventoryStat(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
389 390

    security.declareProtected(Permissions.AccessContentsInformation, 'getInventoryChart')
391 392 393 394 395 396 397 398
    def getInventoryChart(self, **kw):
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getInventoryChart(**kw)

    security.declareProtected(Permissions.AccessContentsInformation, 'getCurrentInventoryChart')
399
    def getCurrentInventoryChart(self, **kw):
400 401 402 403 404
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getCurrentInventoryChart(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
405 406

    security.declareProtected(Permissions.AccessContentsInformation, 'getFutureInventoryChart')
407
    def getFutureInventoryChart(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
408
      """
409
      Returns list of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
410
      """
411 412
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getFutureInventoryChart(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
413

414
    security.declareProtected(Permissions.AccessContentsInformation, 'getInventoryHistoryList')
415
    def getInventoryHistoryList(self, **kw):
Jean-Paul Smets's avatar
Jean-Paul Smets committed
416
      """
417
      Returns list of inventory grouped by section or site
Jean-Paul Smets's avatar
Jean-Paul Smets committed
418
      """
419 420
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getInventoryHistoryList(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
421

422
    security.declareProtected(Permissions.AccessContentsInformation, 'getInventoryHistoryChart')
423
    def getInventoryHistoryChart(self, **kw):
424 425 426 427 428
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getInventoryHistoryChart(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
429 430

    security.declareProtected(Permissions.AccessContentsInformation, 'getMovementHistoryList')
431
    def getMovementHistoryList(self, **kw):
432 433 434 435 436
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getMovementHistoryList(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
437 438

    security.declareProtected(Permissions.AccessContentsInformation, 'getMovementHistoryStat')
439
    def getMovementHistoryStat(self, **kw):
440 441 442 443 444
      """
      Returns list of inventory grouped by section or site
      """
      kw['category'] = self._getMovementResourceList()
      return self.portal_simulation.getMovementHistoryStat(**kw)
Jean-Paul Smets's avatar
Jean-Paul Smets committed
445

446 447 448 449 450 451 452 453 454 455 456
    security.declarePrivate( '_edit' )
    def _edit(self, REQUEST=None, force_update = 0, **kw):
      """
      call propagateArrowToSimulation
      """
      XMLObject._edit(self,REQUEST=REQUEST,force_update=force_update,**kw)
      #self.propagateArrowToSimulation()
      # We must expand our applied rule only if not confirmed
      #if self.getSimulationState() in planned_order_state:
      #  self.updateAppliedRule() # This should be implemented with the interaction tool rather than with this hard coding

457 458 459 460 461 462 463 464 465
    security.declareProtected(Permissions.ModifyPortalContent, 'notifySimulationChange')
    def notifySimulationChange(self):
      """
        WorkflowMethod used to notify the causality workflow that the simulation
        has changed, so we have to check if the delivery is divergent or not
      """
      pass
    notifySimulationChange = WorkflowMethod(notifySimulationChange)

466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506
    ##########################################################################
    # Applied Rule stuff
    def updateAppliedRule(self, rule_id):
      """
        Create a new Applied Rule is none is related, or call expand
        on the existing one.
      """
      if (rule_id is not None) and\
         (self.getSimulationState() not in \
                                       self.getPortalDraftOrderStateList()):
        # Nothing to do if we are already simulated
        self._createAppliedRule(rule_id)

    def _createAppliedRule(self, rule_id):
      """
        Create a new Applied Rule is none is related, or call expand
        on the existing one.
      """
      # Return if draft or cancelled simulation_state
      if self.getSimulationState() in ('cancelled',):
        # The applied rule should be cleaned up 
        # ie. empty all movements which have no confirmed children
        return
      # Otherwise, expand
      # Look up if existing applied rule
      my_applied_rule_list = self.getCausalityRelatedValueList(\
                                            portal_type='Applied Rule')
      if len(my_applied_rule_list) == 0:
        if self.isSimulated(): 
          # No need to create a DeliveryRule 
          # if we are already in the simulation process
          return 
        # Create a new applied order rule (portal_rules.order_rule)
        portal_rules = getToolByName(self, 'portal_rules')
        portal_simulation = getToolByName(self, 'portal_simulation')
        my_applied_rule = portal_rules[rule_id].\
                                    constructNewAppliedRule(portal_simulation)
        # Set causality
        my_applied_rule.setCausalityValue(self)
        # We must make sure this rule is indexed
        # now in order not to create another one later
507
        my_applied_rule.reindexObject()
508 509 510 511
      elif len(my_applied_rule_list) == 1:
        # Re expand the rule if possible
        my_applied_rule = my_applied_rule_list[0]
      else:
Jérome Perrin's avatar
Jérome Perrin committed
512 513
        raise "SimulationError", 'Delivery %s has more than one applied'\
                                 ' rule.' % self.getRelativeUrl()
514 515 516

      # We are now certain we have a single applied rule
      # It is time to expand it
517
      self.activate(
518 519 520
        after_path_and_method_id=(
                my_applied_rule.getPath(),
               ['immediateReindexObject', 'recursiveImmediateReindexObject'])
521
        ).expand(my_applied_rule.getId())
522 523

    security.declareProtected(Permissions.ModifyPortalContent, 'expand')
524
    def expand(self, applied_rule_id, force=0, **kw):
525 526 527 528 529
      """
        Reexpand applied rule
      """
      my_applied_rule = self.portal_simulation.get(applied_rule_id, None)
      if my_applied_rule is not None:
530
        my_applied_rule.expand(force=force, **kw)
531
      else:
Jérome Perrin's avatar
Jérome Perrin committed
532
        LOG("ERP5 Error:", 100,
533 534
            "Could not expand applied rule %s for delivery %s" %\
                (applied_rule_id, self.getId()))
535

536 537 538 539 540 541 542 543 544
    security.declareProtected(Permissions.ModifyPortalContent, 'build')
    def build(self, builder_id):
      """
      Call the build method on the coressponding builder
      """
      builder = getToolByName(self,'portal_deliveries')[builder_id]
      applied_rule = self.getCausalityRelatedValue(portal_type='Applied Rule')
      builder.build(applied_rule_uid=applied_rule.getUid())