# -*- coding: utf-8 -*- ############################################################################## # # Copyright (c) 2005-2008 Nexedi SA and Contributors. All Rights Reserved. # Romain Courteaud <romain@nexedi.com> # # WARNING: This program as such is intended to be used by professional # programmers who take the whole responsibility 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 # guarantees 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 zLOG import LOG, BLATHER from AccessControl import ClassSecurityInfo from Products.ERP5Type import Permissions, PropertySheet from Products.ERP5.mixin.builder import BuilderMixin, SelectMethodError from Products.ERP5Type.TransactionalVariable import getTransactionalVariable from Products.ERP5Type.UnrestrictedMethod import UnrestrictedMethod from Products.ERP5Type.CopySupport import CopyError, tryMethodCallWithTemporaryPermission class SimulatedDeliveryBuilder(BuilderMixin): """ Delivery Builder objects allow to gather multiple Simulation Movements into a single Delivery. The initial quantity property of the Delivery Line is calculated by summing quantities of related Simulation Movements. Delivery Builders are called for example whenever an order is confirmed. They are also called globaly in order to gather any confirmed or above Simulation Movement which was not associated to any Delivery Line. Such movements are called orphaned Simulation Movements. Delivery Builder objects are provided with a set a parameters to achieve their goal: A path definition: source, destination, etc. which defines the general kind of movements it applies. simulation_select_method which defines how to query all Simulation Movements which meet certain criteria (including the above path path definition). collect_order_list which defines how to group selected movements according to gathering rules. delivery_select_method which defines how to select existing Delivery which may eventually be updated with selected simulation movements. delivery_module, delivery_type and delivery_line_type which define the module and portal types for newly built Deliveries and Delivery Lines. Delivery Builders can also be provided with optional parameters to restrict selection to a given root Applied Rule caused by a single Order or to Simulation Movements related to a limited set of existing Deliveries. """ # CMF Type Definition meta_type = 'ERP5 Delivery Builder' portal_type = 'Delivery Builder' # Declarative security security = ClassSecurityInfo() security.declareObjectProtected(Permissions.AccessContentsInformation) # Default Properties property_sheets = ( PropertySheet.Base , PropertySheet.XMLObject , PropertySheet.CategoryCore , PropertySheet.DublinCore , PropertySheet.Arrow , PropertySheet.Amount , PropertySheet.Comment , PropertySheet.DeliveryBuilder ) def callBeforeBuildingScript(self): # XXX-JPS """ Redefine this method, because it seems nothing interesting can be done before building Delivery. """ pass @UnrestrictedMethod def searchMovementList(self, applied_rule_uid=None, **kw): """ defines how to query all Simulation Movements which meet certain criteria (including the above path path definition). First, select movement matching to criteria define on Delivery Builder Then, call script simulation_select_method to restrict movement_list """ # Search only child movement from this applied rule if applied_rule_uid: kw['parent_uid'] = applied_rule_uid # XXX Add profile query # Add resource query portal_type = self.getResourcePortalType() if portal_type: kw['resource_portal_type'] = portal_type movement_list = [] for movement in self._searchMovementList( portal_type='Simulation Movement', **kw): if movement.getDelivery(): LOG("searchMovementList", BLATHER, "ignore already built simulation movement %r" % movement.getRelativeUrl()) elif movement.isBuildable(): movement_list.append(movement) # XXX Add predicate test return movement_list def _setDeliveryMovementProperties(self, delivery_movement, simulation_movement, property_dict, update_existing_movement=0, force_update=0, activate_kw=None): """ Initialize or update delivery movement properties. Set delivery ratio on simulation movement. Create the relation between simulation movement and delivery movement. """ delivery = delivery_movement.getExplanationValue() simulation_movement.recursiveReindexObject(activate_kw=dict( activate_kw or (), tag='built:'+delivery.getPath())) BuilderMixin._setDeliveryMovementProperties( self, delivery_movement, simulation_movement, property_dict, update_existing_movement=update_existing_movement, force_update=force_update, activate_kw=activate_kw) if update_existing_movement and not force_update: # Important. # Attributes of delivery_movement must not be modified here. # Because we can not change values modified by the user. # Delivery will probably diverge now, but this is not the job of # Delivery Builder to resolve such problem. # Use Solver instead. simulation_movement._setDeliveryRatio(0) else: simulation_movement._setDeliveryRatio(1) delivery_movement = delivery_movement.getRelativeUrl() if simulation_movement.getDeliveryList() != [delivery_movement]: simulation_movement._setDelivery(delivery_movement) if not simulation_movement.isTempDocument(): try: getCausalityState = delivery.aq_explicit.getCausalityState except AttributeError: return if getCausalityState() == 'building': # Make sure no other node is changing state of the delivery delivery.serializeCausalityState() else: delivery.startBuilding() # Simulation consistency propagation security.declareProtected(Permissions.ModifyPortalContent, 'updateFromSimulation') def updateFromSimulation(self, delivery_relative_url, **kw): """ Update all lines of this transaction based on movements in the simulation related to this transaction. """ # We have to get a delivery, else, raise a Error delivery = self.getPortalObject().restrictedTraverse(delivery_relative_url) divergence_to_adopt_list = delivery.getDivergenceList() return self.solveDivergence( delivery_relative_url, divergence_to_adopt_list=divergence_to_adopt_list) @UnrestrictedMethod def solveDeliveryGroupDivergence(self, delivery_relative_url, property_dict=None): """ solve each divergence according to users decision (accept, adopt or do nothing). """ if property_dict in (None, {}): return delivery = self.getPortalObject().restrictedTraverse(delivery_relative_url) for (property, value) in property_dict.iteritems(): delivery.setPropertyList(property, value) # Try to remove existing properties/categories from Movements that # should exist on Deliveries. for movement in delivery.getMovementList(): for prop in property_dict.keys(): # XXX The following should be implemented in better way. if movement.hasProperty(prop): try: # for Property movement._delProperty(prop) except AttributeError: # for Category movement.setProperty(prop, None) divergence_to_accept_list = [] for divergence in delivery.getDivergenceList(): if divergence.getProperty('tested_property') not in property_dict.keys(): continue divergence_to_accept_list.append(divergence) self._solveDivergence(delivery_relative_url, divergence_to_accept_list=divergence_to_accept_list) def _solveDivergence(self, delivery_relative_url, # XXX-JPS what is this doing here ????? divergence_to_accept_list=None, divergence_to_adopt_list=None, **kw): """ solve each divergence according to users decision (accept, adopt or do nothing). """ # We have to get a delivery, else, raise a Error delivery = self.getPortalObject().restrictedTraverse(delivery_relative_url) if divergence_to_accept_list is None: divergence_to_accept_list = [] if divergence_to_adopt_list is None: divergence_to_adopt_list = [] if not len(divergence_to_accept_list) and \ not len(divergence_to_adopt_list): return divergence_list = delivery.getDivergenceList() # First, we update simulation movements according to # divergence_to_accept_list. if len(divergence_to_accept_list): solver_script = delivery._getTypeBasedMethod('acceptDecision', 'Delivery_acceptDecision') solver_script(divergence_to_accept_list) # Then, we update delivery/line/cell from simulation movements # according to divergence_to_adopt_list. if not len(divergence_to_adopt_list): return # Select movement_type_list = (self.getDeliveryLinePortalType(), self.getDeliveryCellPortalType()) movement_list = delivery.getMovementList(portal_type=movement_type_list) simulation_movement_list = [] for movement in movement_list: movement.edit(quantity=0) for simulation_movement in movement.getDeliveryRelatedValueList( portal_type="Simulation Movement"): simulation_movement_list.append(simulation_movement) # Collect root_group_node = self.collectMovement(simulation_movement_list) # Build portal = self.getPortalObject() delivery_module = getattr(portal, self.getDeliveryModule()) delivery_to_update_list = [delivery] self._resetUpdated() delivery_list = self._processDeliveryGroup( delivery_module, root_group_node, self.getDeliveryMovementGroupList(), delivery_to_update_list=delivery_to_update_list, divergence_list=divergence_to_adopt_list, force_update=1) # Then, we should re-apply quantity divergence according to 'Do # nothing' quanity divergence list because all quantity are already # calculated in adopt prevision phase. quantity_dict = {} for divergence in divergence_list: if divergence.getProperty('divergence_scope') != 'quantity' or \ divergence in divergence_to_accept_list or \ divergence in divergence_to_adopt_list: continue s_m = divergence.getProperty('simulation_movement') delivery_movement = s_m.getDeliveryValue() quantity_gap = divergence.getProperty('decision_value') - \ divergence.getProperty('prevision_value') delivery_movement.setQuantity(delivery_movement.getQuantity() + \ quantity_gap) quantity_dict[s_m] = \ divergence.getProperty('decision_value') # Finally, recalculate delivery_ratio # # Here, created/updated movements are not indexed yet. So we try to # gather delivery relations from simulation movements. delivery_dict = {} for s_m in simulation_movement_list: delivery_path = s_m.getDelivery() delivery_dict[delivery_path] = \ delivery_dict.get(delivery_path, []) + \ [s_m] for s_m_list_per_movement in delivery_dict.values(): total_quantity = sum([quantity_dict.get(s_m, s_m.getMappedProperty('quantity')) \ for s_m in s_m_list_per_movement]) if total_quantity != 0.0: for s_m in s_m_list_per_movement: delivery_ratio = quantity_dict.get(s_m, s_m.getMappedProperty('quantity')) \ / total_quantity s_m.edit(delivery_ratio=delivery_ratio) else: for s_m in s_m_list_per_movement: delivery_ratio = 1.0 / len(s_m_list_per_movement) s_m.edit(delivery_ratio=delivery_ratio) # Call afterscript if new deliveries are created new_delivery_list = [x for x in delivery_list if x != delivery] self.callAfterBuildingScript(new_delivery_list, simulation_movement_list) return delivery_list solveDivergence = UnrestrictedMethod(_solveDivergence) def _createDelivery(self, delivery_module, movement_list, activate_kw): """ Refer to the docstring in GeneratedDeliveryBuilder. Unlike GeneratedDeliveryBuilder, SimulatedDeliveryBuilder needs to respect existing relationship. """ try: old_delivery = self._searchUpByPortalType( movement_list[0].getDeliveryValue(), self.getDeliveryPortalType()) except AttributeError: old_delivery = None if old_delivery is None: # from scratch new_delivery_id = str(delivery_module.generateNewId()) delivery = super(SimulatedDeliveryBuilder, self)._createDelivery( delivery_module, movement_list, activate_kw) # Interactions will usually trigger reindexing of related SM when # simulation state changes. Disable them for this transaction # because we already do this in _setDeliveryMovementProperties delivery.updateSimulation(index_related=0) else: # from duplicated original delivery cp = tryMethodCallWithTemporaryPermission( delivery_module, 'Copy or Move', lambda parent, *ids: parent._duplicate(parent.manage_copyObjects(ids=ids))[0], (delivery_module, old_delivery.getId()), {}, CopyError) delivery = delivery_module[cp['new_id']] # delete non-split movements keep_id_list = [y.getDeliveryValue().getId() for y in movement_list] delete_id_list = [x.getId() for x in delivery.contentValues() \ if x.getId() not in keep_id_list] delivery.deleteContent(delete_id_list) return delivery def _createDeliveryLine(self, delivery, movement_list, activate_kw): """ Refer to the docstring in GeneratedDeliveryBuilder. Unlike GeneratedDeliveryBuilder, SimulatedDeliveryBuilder needs to respect existing relationship. """ try: old_delivery_line = self._searchUpByPortalType( movement_list[0].getDeliveryValue(), self.getDeliveryLinePortalType()) except AttributeError: old_delivery_line = None if old_delivery_line is None: # from scratch delivery_line = delivery.newContent( portal_type=self.getDeliveryLinePortalType(), variation_category_list=[], activate_kw=activate_kw) else: # from duplicated original line cp = tryMethodCallWithTemporaryPermission( delivery, 'Copy or Move', lambda parent, *ids: parent._duplicate(parent.manage_copyObjects(ids=ids))[0], (delivery, old_delivery_line.getId()), {}, CopyError) delivery_line = delivery[cp['new_id']] # reset variation category list delivery_line.setVariationCategoryList([]) # delete non-split movements keep_id_list = [y.getDeliveryValue().getId() for y in movement_list] delete_id_list = [x.getId() for x in delivery_line.contentValues() \ if x.getId() not in keep_id_list] delivery_line.deleteContent(delete_id_list) return delivery_line def _createDeliveryCell(self, delivery_line, movement, activate_kw, base_id, cell_key): """ Refer to the docstring in GeneratedDeliveryBuilder. Unlike GeneratedDeliveryBuilder, SimulatedDeliveryBuilder needs to respect existing relationship. """ try: old_cell = movement.getDeliveryValue() except AttributeError: old_cell = None if old_cell is None: # from scratch cell = delivery_line.newCell(base_id=base_id, \ portal_type=self.getDeliveryCellPortalType(), activate_kw=activate_kw,*cell_key) else: # from duplicated original line cp = tryMethodCallWithTemporaryPermission( delivery_line, 'Copy or Move', lambda parent, *ids: parent._duplicate(parent.manage_copyObjects(ids=ids))[0], (delivery_line, old_cell.getId()), {}, CopyError) cell = delivery_line[cp['new_id']] return cell