[Erp5-report] r26651 - /erp5/trunk/products/ERP5/Document/TradeModelRule.py
nobody at svn.erp5.org
nobody at svn.erp5.org
Mon Apr 27 11:45:36 CEST 2009
Author: luke
Date: Mon Apr 27 11:45:35 2009
New Revision: 26651
URL: http://svn.erp5.org?rev=26651&view=rev
Log:
- rule to express trade models in simulations
Added:
erp5/trunk/products/ERP5/Document/TradeModelRule.py
Added: erp5/trunk/products/ERP5/Document/TradeModelRule.py
URL: http://svn.erp5.org/erp5/trunk/products/ERP5/Document/TradeModelRule.py?rev=26651&view=auto
==============================================================================
--- erp5/trunk/products/ERP5/Document/TradeModelRule.py (added)
+++ erp5/trunk/products/ERP5/Document/TradeModelRule.py [utf8] Mon Apr 27 11:45:35 2009
@@ -1,0 +1,180 @@
+# -*- coding: utf8 -*-
+##############################################################################
+#
+# Copyright (c) 2009 Nexedi SARL and Contributors. All Rights Reserved.
+# Łukasz Nowak <luke at nexedi.com>
+#
+# 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 AccessControl import ClassSecurityInfo
+from Products.ERP5Type import Permissions, PropertySheet, Constraint, Interface
+from Products.ERP5.Document.TransformationRule import TransformationRule
+
+from Products.ERP5.Document.Rule import Rule
+
+class TradeModelRule(TransformationRule):
+ """
+ Rule for Trade Model
+ """
+ # CMF Type Definition
+ meta_type = 'ERP5 Trade Model Rule'
+ portal_type = 'Trade Model Rule'
+ add_permission = Permissions.AddPortalContent
+ isPortalContent = 1
+ isRADContent = 1
+
+ # Declarative security
+ security = ClassSecurityInfo()
+ security.declareObjectProtected(Permissions.AccessContentsInformation)
+
+ __implements__ = ( Interface.Predicate,
+ Interface.Rule )
+
+ # Default Properties
+ property_sheets = ( PropertySheet.Base
+ , PropertySheet.XMLObject
+ , PropertySheet.CategoryCore
+ , PropertySheet.DublinCore
+ , PropertySheet.Task
+ , PropertySheet.AppliedRule
+ )
+
+ def getSpecialiseList(self, simulation_movement):
+ """Returns (trade_condition, bpm)"""
+ bpm = simulation_movement.getRootAppliedRule().getBusinessProcessValue()
+ causality = simulation_movement.getRootAppliedRule().getCausalityValue()
+ trade_condition = None
+ if causality is not None and getattr(causality, 'getSpecialiseValueList',
+ None) is not None:
+ trade_condition = causality.getSpecialiseValue()
+
+ return trade_condition, bpm
+
+ def _getMovementDictByBusinessPath(self, movement, business_path_list):
+ """Sets Business Path's provided values"""
+ if len(business_path_list) > 1:
+ raise NotImplementedError('Only one path supported')
+
+ business_path = business_path_list[0]
+ movement_dict = {}
+
+ if 0: # XXX use arrow from path (not working currently)
+ for base_category in \
+ business_path.getSourceArrowBaseCategoryList() +\
+ business_path.getDestinationArrowBaseCategoryList():
+ movement_dict[base_category] = business_path\
+ .getDefaultAcquiredCategoryMembership(base_category,
+ context=movement)
+ print base_category, movement_dict[base_category]
+ else:
+ movement_dict['source'] = movement.getSource()
+ movement_dict['source_section'] = movement.getSourceSection()
+ movement_dict['source_administration'] = \
+ movement.getSourceAdministration()
+ movement_dict['destination'] = movement.getDestination()
+ movement_dict['destination_section'] = movement.getDestinationSection()
+ movement_dict['destination_administration'] = \
+ movement.getDestinationAdministration()
+
+ if business_path.getQuantity():
+ movement_dict['quantity'] = business_path.getQuantity()
+ elif business_path.getEfficiency():
+ movement_dict['quantity'] = movement.getQuantity() * \
+ business_path.getEfficiency()
+ else:
+ movement_dict['quantity'] = movement.getQuantity()
+
+ if 0: # XXX use path date calculation system
+ movement_dict['start_date'] = business_path \
+ .getExpectedStartDate(movement)
+ movement_dict['stop_date'] = business_path.getExpectedStopDate(movement)
+ else:
+ movement_dict['start_date'] = movement.getStartDate()
+ movement_dict['stop_date'] = movement.getStopDate()
+
+ movement_dict['causality_value'] = business_path
+
+ return movement_dict
+
+ def _generatePrevisionList(self, applied_rule, **kw):
+ """Generates list of movements (as dicts), and let parent class to decide
+ which is to add, modify or delete"""
+ movement_list = []
+ trade_condition, bpm = self.getSpecialiseList(applied_rule)
+
+ if trade_condition is None or bpm is None:
+ return movement_list
+
+ for amount in trade_condition.getAggregatedAmountList(applied_rule):
+ context_movement = applied_rule.getParentValue()
+ movement_kw = {}
+ # everything static
+ for prop in self.getExpandablePropertyList():
+ movement_kw[prop] = context_movement.getProperty(prop)
+
+ # business path specific
+ business_path_list = bpm.getPathValueList(
+ trade_phase=amount.getTradePhaseList())
+ movement_kw.update(**self._getMovementDictByBusinessPath(
+ context_movement, business_path_list))
+
+ # rule specific
+ movement_kw['price'] = amount.getProperty('price')
+ movement_kw['resource'] = amount.getProperty('resource')
+ movement_kw['quantity'] = amount.getProperty('quantity')
+ movement_kw['base_application_list'] = amount.getProperty(
+ 'base_application_list')
+ movement_kw['base_contribution_list'] = amount.getProperty(
+ 'base_contribution_list')
+
+ movement_list.append(movement_kw)
+
+ return movement_list
+
+ security.declareProtected(Permissions.ModifyPortalContent, 'expand')
+ def expand(self, applied_rule, force=0, **kw):
+ """Expands XXX COPY & PASTE OF InvoicingRule.expand"""
+ parent_movement = applied_rule.getParentValue()
+ if parent_movement is not None:
+ if not parent_movement.isFrozen():
+ add_list, modify_dict, \
+ delete_list = self._getCompensatedMovementList(applied_rule,
+ matching_property_list= ('resource',), **kw)
+ for movement_id in delete_list:
+ applied_rule._delObject(movement_id)
+
+ for movement, prop_dict in modify_dict.items():
+ applied_rule[movement].edit(**prop_dict)
+
+ for movement_dict in add_list:
+ if 'id' in movement_dict.keys():
+ mvmt_id = applied_rule._get_id(movement_dict.pop('id'))
+ new_mvmt = applied_rule.newContent(id=mvmt_id,
+ portal_type=self.movement_type)
+ else:
+ new_mvmt = applied_rule.newContent(portal_type=self.movement_type)
+ new_mvmt.edit(**movement_dict)
+
+ # Pass to base class
+ Rule.expand(self, applied_rule, force=force, **kw)
More information about the Erp5-report
mailing list