Skip to content

erp5
erp5
Commit 49fdecde authored by Sebastien Robin's avatar Sebastien Robin
Browse files
Options

This code is not generic at all and it's design is 

dirty, so delete it

git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@28679 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 8fa3c9aa
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 1101 deletions
product/ERP5SyncML/Conduit/BaobabConduit.py deleted 100644 → 0
View file @ 8fa3c9aa
##############################################################################
#
# Copyright (c) 2005 Nexedi SARL and Contributors. All Rights Reserved.
# Kevin Deldycke <kevin@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 Products.ERP5SyncML.Conduit.ERP5Conduit import ERP5Conduit
from AccessControl import ClassSecurityInfo
from Products.ERP5Type import Permissions
from Products.ERP5Type.Utils import convertToUpperCase
from Products.CMFCore.utils import getToolByName
from Acquisition import aq_base, aq_inner, aq_chain, aq_acquire
from ZODB.POSException import ConflictError
import datetime
from zLOG import LOG
import sys
class BaobabConduit(ERP5Conduit):
"""
A conduit is in charge to read data from a particular structure,
and then to save this data in another structure.
In baobab, the data is read from some sql tables and it will stored
with ERP5 objects. The difficult parts are :
- for one sql table we have several kind of objects in ERP5
- for each properties that comes from sql, we have one ore more
properties in ERP5
Most importants method defined here are :
- constructContent : it is used when a new set of data comes from
the sql table, then constructContent must decide
wich kind of object must be created in ERP5
- editDocument : after constructContent, editDocument is called with
all properties that comes from the set of data from
sql. Each property must be converted to ERP5 property.
If you need to handle a new property, the most important thing to know
is what will be the property used in ERP5. Then you have to enter a
new dictionary in the property_map variable.
# New changes on october 2006:
* on Compte
- numero become numero_interne
- add code_pays (ex K)
- add code etab (code etablissement), ex 0101
- add code_guichet
- add numero_compte : international account number
- add rib : ex 52
- add code_bic : ex SGBSSND0
- add overdraft_facility O/N (Yes/No)
- add swift_registered O/N (Yes/No)
* on Client
- remove code_bic
- zone_residence is now well completed, we should find country
information. We should be a corresponding dictionary in order
to set the right region
"""
global property_map
# Declarative security
security = ClassSecurityInfo()
### This data structure associate a xml property to an ERP5 object property in certain conditions
property_map = {
# For example, in the sql export, we use for the first name of a person the
# property 'nom', in ERP5 we use the property first_name
'nom':[{
'erp5_property': 'first_name'
, 'conditions' : {'erp5_portal_type':'Person'}
}
, {
'erp5_property': 'title'
, 'conditions' : {'erp5_portal_type':'Organisation'}
}],
# For example, in the sql export, we use for the name of an organisation the
# property 'nom', in ERP5 we use the property title
'adresse': [{
'erp5_property': 'default_address_street_address'
, 'conditions' : [{'erp5_portal_type':'Organisation'}
,{'erp5_portal_type':'Person'}]
}],
'zone_residence': [{
'erp5_property': 'default_address_region'
, 'conditions' : [{'erp5_portal_type':'Organisation'}
,{'erp5_portal_type':'Person'}]
}],
'titre': [{
'erp5_property': 'prefix'
, 'conditions' : {'erp5_portal_type':'Person'}
}],
'telephone': [{
'erp5_property': 'default_telephone_number'
, 'conditions' : [{'erp5_portal_type':'Organisation'}
,{'erp5_portal_type':'Person'}]
}],
'telex': [{
'erp5_property': 'default_fax_number'
, 'conditions' : [{'erp5_portal_type':'Organisation'}
,{'erp5_portal_type':'Person'}]
}],
'prenom': [{
'erp5_property': 'last_name'
, 'conditions' : {'erp5_portal_type':'Person'}
}],
'date_naissance': [{
'erp5_property': 'birthday'
, 'conditions' : {'erp5_portal_type':'Person'}
}],
'code_bic': [{
'erp5_property': 'bic_code'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'code_pays': [{
'erp5_property': 'bank_country_code'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'code_etab': [{
'erp5_property': 'bank_code'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'code_guichet': [{
'erp5_property': 'branch'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'numero_compte': [{
'erp5_property': 'bank_account_number'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
#'rib': [{
# 'erp5_property': 'bank_account_key'
# , 'conditions' : {'erp5_portal_type':'Bank Account'}
# }],
'numero_interne': [{
'erp5_property': 'internal_bank_account_number'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'intitule': [{
'erp5_property': 'title'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
'montant_maxi': [{
'erp5_property': 'operation_upper_limit'
, 'conditions' : {'erp5_portal_type':'Agent Privilege'}
}],
'description': [{
'erp5_property': 'description'
, 'conditions' : {'erp5_portal_type':'Agent Privilege'}
}],
'inventory_title': [{
'erp5_property': 'title'
, 'conditions' : {'erp5_portal_type':'Cash Inventory Group'}
}],
'inventory_date': [{
'erp5_property': 'start_date'
, 'conditions' : {'erp5_portal_type':'Cash Inventory Group'}
}],
'title': [{
'erp5_property': 'title'
, 'conditions' : {'erp5_portal_type':'Bank Account Inventory'}
}],
'amount': [{
'erp5_property': 'quantity'
, 'conditions' : {'erp5_portal_type':'Bank Account Inventory Line'}
}],
'cle': [{
'erp5_property': 'int_index'
, 'conditions' : {'erp5_portal_type':'Bank Account'}
}],
}
try:
from Products.Baobab.Conduit import inventory_code_to_path
from Products.Baobab.Conduit import vault_code_to_path
from Products.Baobab.Conduit import variation_translate_dict
from Products.Baobab.Conduit import status_code_to_cash_status
from Products.Baobab.Conduit import former_coin_variation_list
from Products.Baobab.Conduit import default_letter_code
from Products.Baobab.Conduit import valid_letter_code_set
except ImportError:
inventory_code_to_path = {}
vault_code_to_path = {}
variation_translate_dict = {}
status_code_to_cash_status = {}
former_coin_variation_list = []
default_letter_code = None
valid_letter_code_set = ()
"""
Methods below are tools to use the property_map.
"""
security.declarePrivate('buildConditions')
def buildConditions(self, object):
"""
Build a condition dictionnary based on the portal type.
For example it will returns :
{'erp5_portal_type':'Agent Privilege'}
"""
dict = {}
dict['erp5_portal_type'] = object.getPortalType()
return dict
security.declarePrivate('findPropertyMapItem')
def findPropertyMapItem(self, xml_property_name, conditions):
"""
Find the property_map item that match conditions
It will returns for example :
{ 'xml_property' : 'nom'
, 'erp5_property': 'first_name'
, 'conditions' : {'erp5_portal_type':'Person'} }
"""
if property_map.has_key(xml_property_name):
for item in property_map[xml_property_name]:
c = item['conditions']
if type(c) == type([]):
if conditions in c:
return item
else:
if conditions == c:
return item
return None
security.declareProtected(Permissions.ModifyPortalContent, 'constructContent')
def constructContent(self, object, object_id, portal_type):
"""
This is a redefinition of the original ERP5Conduit.constructContent function to
create Baobab objects.
This method is in charge to create a new object.
"""
# Register some path in some variables
erp5_site_path = object.absolute_url(relative=1)
person_module_object = object.person_module
organisation_module_object = object.organisation_module
# Modules below are not always required
# (it depends of the nature of objects you want to synchronize)
# So if a module to not exist, we set the value to None
try: cash_inventory_module = object.cash_inventory_module
except AttributeError: cash_inventory_module = None
try: bank_account_inventory_module = object.bank_account_inventory_module
except AttributeError: bank_account_inventory_module = None
try: currency_cash_module = object.currency_cash_module
except AttributeError: currency_cash_module = None
subobject = None
# Function to search the parent object where the new content must be construct.
# Given parameter is the special encoded portal type that represent the path to
# the wanted destination.
def findObjectFromSpecialPortalType(special_portal_type,object_id=None):
# The first part or portal type, for example "Mandataire"
source_portal_type = special_portal_type.split('_')[0]
# The place where we should build,
# [1:] is used to takes the full list except the first element
# [::-1] is used in order to reverse the order
# construction_location will be for example 40/Z000900001
# (person with id 40 and account with id Z000900001
construction_location = '/'.join(special_portal_type.split('_')[1:][::-1])
parent_object = None
for search_folder in ('person_module', 'organisation_module'):
# full path : /person_module/40/Z000900001
path = '/' + search_folder + '/' + construction_location
parent_object_path = erp5_site_path + path
try:
# Get the object with the path
parent_object_path_list = parent_object_path.split('/')
root = getattr(object, parent_object_path_list[0])
parent_object = root
for subpath in parent_object_path_list[1:]:
parent_object = getattr(aq_base(parent_object), subpath, None)
if parent_object is None:
break
if parent_object is not None:
# call restrictedTraverse to make sure to get object
# with acquisition, wich is required for creating sub object
parent_object = object.restrictedTraverse(parent_object_path)
break
except ConflictError:
raise
except:
LOG( 'BaobabConduit:'
, 0
, "expected %s parent object (%s) not found in %s" % ( source_portal_type
, construction_location
, search_folder
),
error=sys.exc_info())
if parent_object == None:
LOG( 'BaobabConduit:'
, 100
, "expected %s parent object (%s) not found !" % (source_portal_type, construction_location)
)
else:
LOG( 'BaobabConduit:'
, 0
, "%s parent object found at %s" % (source_portal_type, parent_object_path)
)
return parent_object
### handle client objects
if portal_type.startswith('Client'):
# This is a person object
if portal_type[-3:] == 'PER':
subobject = person_module_object.newContent( portal_type = 'Person'
, id = object_id
)
subobject.setCareerRole('client')
# We first try to get the organisation corresponding
organisation_id = 'site_%s' % object_id[:3]
organisation = organisation_module_object._getOb(organisation_id)
#organisation = person_module_object.portal_catalog(
# portal_type='Organisation',
# id=organisation_id
# )[0].getObject()
subobject._setCareerSubordinationValue(organisation)
else: # This is an organisation object
site_value = organisation_module_object.Baobab_getSiteFromCodification(
object_id[:3])
subobject = organisation_module_object.newContent( portal_type = 'Organisation'
, id = object_id
, site = site_value.getRelativeUrl().replace('site/','')
)
subobject.setRole('client')
### handle bank account objects
elif portal_type.startswith('Compte'):
owner = findObjectFromSpecialPortalType(portal_type)
if owner == None: return None
subobject = getattr(owner, object_id, None)
if subobject is None:
subobject = owner.newContent( portal_type = 'Bank Account'
, id = object_id
)
# set the bank account owner as agent with no-limit privileges (only for persons)
if owner.getPortalType() == 'Person':
new_agent = getattr(subobject, 'owner', None)
if new_agent is None:
new_agent = subobject.newContent( portal_type = 'Agent'
, id = 'owner'
)
new_agent.setAgent(owner.getRelativeUrl())
#privileges = ( 'circularization'
# , 'cash_out'
# , 'withdrawal_and_payment'
# , 'account_document_view'
# , 'signature'
# , 'treasury'
# )
#for privilege in privileges:
# new_priv = new_agent.newContent(portal_type = 'Agent Privilege')
# new_priv.setAgentPrivilege(privilege)
### handle agent objects
elif portal_type.startswith('Mandataire'):
# Get the person or organisation thanks to the portal_type
dest = findObjectFromSpecialPortalType(portal_type,object_id=object_id)
if dest == None: return None
try:
subobject = dest._getOb(object_id)
except (AttributeError, KeyError, TypeError):
subobject = None
if subobject is None:
subobject = dest.newContent( portal_type = 'Agent'
, id = object_id
)
# try to get the agent in the person module
person = findObjectFromSpecialPortalType('Person_' + object_id)
if person == None:
person = person_module_object.newContent( portal_type = 'Person'
, id = object_id + 'a'
)
subobject.setAgent(person.getRelativeUrl())
### handle privilege objects
elif portal_type.startswith('Pouvoir'):
# Get the person or organisation thanks to the portal_type
dest = findObjectFromSpecialPortalType(portal_type)
if dest == None: return None
try:
subobject = dest._getOb(object_id)
except (AttributeError, KeyError, TypeError):
subobject = None
if subobject is None:
subobject = dest.newContent( portal_type = 'Agent Privilege'
, id = object_id
)
### handle inventory objects
elif portal_type == 'Cash Inventory':
if cash_inventory_module == None: return None
subobject = cash_inventory_module.newContent( portal_type = 'Cash Inventory Group'
, id = object_id
)
### handle inventory details objects
elif portal_type == 'Cash Inventory Detail':
if currency_cash_module == None: return None
# get currency and vault informations by analizing the id
id_items = object_id.split('_')
if len(id_items) != 5:
LOG( 'BaobabConduit:'
, 100
, "Cash Inventory Detail object has a wrong id (%s) !" % (object_id)
)
return None
cell_id = id_items[0]
agency_code = id_items[1]
inventory_code = id_items[2]
vault_code = id_items[3]
currency_id = id_items[4]
# get the path to the vault_code
vault_path = self.getVaultPathFromCodification( object = object
, agency_code = agency_code
, inventory_code = inventory_code
, vault_code = vault_code
, currency_id = currency_id
)
if vault_path in (None, ''):
LOG( 'BaobabConduit:'
, 100
, "can't find a path to the vault '%s/%s/%s' !" % (agency_code, inventory_code, vault_code)
)
return None
# try to find an existing inventory with the same price currency and vault
inventory_list = object.contentValues(filter={'portal_type': 'Cash Inventory'})
new_inventory = None
for inventory in inventory_list:
inventory_currency = inventory.getPriceCurrencyId()
inventory_vault = inventory.getDestination()
if inventory_currency not in (None, '') and \
inventory_vault not in (None, '') and \
inventory_currency == currency_id and \
inventory_vault == vault_path :
new_inventory = inventory
#LOG( 'BaobabConduit:'
# , 0
# , "previous Cash Inventory found (%s) !" % (repr(new_inventory))
# )
break
# no previous inventory found, create one
if new_inventory == None:
new_inventory = object.newContent(portal_type = 'Cash Inventory')
new_inventory.setPriceCurrency('currency_module/' + currency_id)
new_inventory.setDestination(vault_path)
subobject = new_inventory
### handle bank account inventory objects
elif portal_type == 'Bank Account Inventory':
if bank_account_inventory_module == None: return None
subobject = bank_account_inventory_module.newContent( portal_type = 'Bank Account Inventory Group'
, id = object_id
)
### handle bank account inventory line objects
elif portal_type == 'Bank Account Inventory Line':
subobject = object.newContent( portal_type = 'Bank Account Inventory'
, id = object_id
)
subsubobject = subobject.newContent( portal_type = 'Bank Account Inventory Line'
, id = 'line'
)
return (subobject, 0, 0)
security.declareProtected(Permissions.ModifyPortalContent, 'editDocument')
def editDocument(self, object=None, **kw):
"""
This function transfer datas from the dictionary to the baobab document
object given in parameters.
"""
if object == None: return
### Cash Inventory objects needs two properties to generate the vault path
#LOG('BaobabConduit.editDocument, object', 0, object)
if object.getPortalType() == 'Cash Inventory Group':
vault_path = self.getVaultPathFromCodification( object = object
, agency_code = kw['agency_code']
, inventory_code = kw['inventory_code']
)
object.setDestination(vault_path)
### Cash Inventory Detail objects needs all properties to create and update the cell matrix
# This part is only usefull for cash inventory, it is not used for most portal types
if object.getPortalType() == 'Cash Inventory':
# Make sure all variables will be defined
quantity = None
cell_id = None
resource_type = None
base_price = None
currency_name = None
for k,v in kw.items():
if k == 'quantity' : quantity = float(v)
if k == 'cell_id' : cell_id = v
if k == 'currency_type': resource_type = v
if k == 'price' : base_price = float(v)
if k == 'currency' : currency_name = v
# try to find an existing line with the same resource as the current cell
if resource_type in ['BIL']:
currency_portal_type = 'Banknote'
elif resource_type in ['MON']:
currency_portal_type = 'Coin'
else:
LOG( 'BaobabConduit:'
, 100
, "Cash Inventory Detail resource type can't be guess (%s) !" % (resource_type)
)
return None
# get the list of existing currency to find the currency of the line
line_currency_cash = None
currency_cash_list = object.currency_cash_module.contentValues(filter={'portal_type': currency_portal_type})
for currency_cash in currency_cash_list:
# Check the price_currency_id and the base price to make sure
# we have the right currency
if base_price not in (None, '') and \
currency_name not in (None, '') and \
currency_cash.getBasePrice() == base_price and \
currency_cash.getPriceCurrencyId() == currency_name:
# getFormer value must match searched coin variation.
if currency_portal_type == 'Coin' and \
(kw.get('variation', None) in self.former_coin_variation_list) != \
bool(currency_cash.getFormer()):
continue
line_currency_cash = currency_cash
break
# no currency found
if line_currency_cash == None:
LOG( 'BaobabConduit:'
, 100
, "Currency '%s %s' not found for the Cash Inventory Detail !" % (base_price, currency_name)
)
return None
# We are looking for an existing line
inventory_lines = object.contentValues(filter={'portal_type': 'Cash Inventory Line'})
new_line = None
for line in inventory_lines:
# getResourceValue returns the currency_cash, so if it is
# equivalent to the currency_cash we have found, then we can
# update the line
if line.getResourceValue() == line_currency_cash:
new_line = line
break
# no previous line found, create one
if new_line == None:
new_line = object.newContent(portal_type = 'Cash Inventory Line')
new_line.setResourceValue(line_currency_cash)
new_line.setPrice(line_currency_cash.getBasePrice())
# get matrix variation values
category_list = []
# This is the 3 variation axes of the matrix
base_cat_map = { 'variation' : 'variation'
, 'letter_code': 'emission_letter'
, 'status_code': 'cash_status'
}
for base_key in base_cat_map.keys():
if base_key in kw.keys() and kw[base_key] not in ('', None):
if base_key == 'status_code':
category = self.status_code_to_cash_status[kw[base_key]]
elif base_key == 'variation':
if currency_portal_type == 'Banknote': # Variation is set only for Banknotes.
category = self.variation_translate_dict.get(kw[base_key], kw[base_key])
else:
category = 'not_defined'
elif base_key == 'letter_code':
letter = kw[base_key]
if letter in self.valid_letter_code_set:
category = letter
else:
category = self.default_letter_code
else:
category = 'not_defined'
# We must have at least a category for each axis
category_list.append(base_cat_map[base_key] + '/' + category)
# update the matrix with this cell
self.updateCashInventoryMatrix( line = new_line
, cell_category_list = category_list
, quantity = quantity
, cell_uid = cell_id
)
### Bank Account Inventory Line objects needs two properties to get the right bank account object
# This part is only usefull for bank account inventory line, it is not used for most portal types
if object.getPortalType() == 'Bank Account Inventory':
line = object['line']
# Make sure variables will be defined
currency_id = None
bank_account_number = None
for k,v in kw.items():
if k == 'currency' : currency_id = v
if k == 'account_number': bank_account_number = v
if k == "amount" : quantity = float(v)
# try to find the bank account
line.setQuantity(quantity)
if bank_account_number != None:
bank_account_object = None
# We use here the catalog in order to find very quickly
# all bank with a particular reference, so most of the time
# we should get only 1 bank account
bank_account_list = [x.getObject() for x in object.portal_catalog(
portal_type=('Bank Account'),
string_index=bank_account_number,
)]
# Make sure we have found the right bank account
for bank_account in bank_account_list:
LOG('BaobabConduit editDocument account number',0, (bank_account.getInternalBankAccountNumber(), bank_account_number))
if bank_account.getInternalBankAccountNumber() == bank_account_number:
bank_account_object = bank_account
break
if bank_account_object != None:
# Se the right account on the inventory line
object.setDestinationValue(bank_account_object)
object.setDestinationPaymentValue(bank_account_object)
if currency_id != None:
# verify or add the currency
current_currency_id = bank_account_object.getPriceCurrencyId()
# Make sure that the bank account will have a currency defined
if current_currency_id in (None, ''):
bank_account_object.setPriceCurrency('currency_module/' + currency_id)
elif current_currency_id != currency_id:
LOG( 'BaobabConduit inconsistency:'
, 200
, 'found bank account has not the expected currency (%s in stead of %s)' % (current_currency_id, currency_id)
)
else:
LOG( 'BaobabConduit inconsistency:'
, 200
, 'no bank account found'
)
raise KeyError, 'No bank account Found with number %r' % (bank_account_number, )
"""
Here we use 2 generic way to update object properties :
1. We try to use the property_map mapping to migrate a value from a property
to another;
2. If the latter fail, we try to find a method with a pre-defined name in
this script to handle the value.
"""
# Set properties of the destination baobab object
for k,v in kw.items():
# Try to find a translation rule in the property_map
cond = self.buildConditions(object)
map_item = self.findPropertyMapItem(k, cond)
### There is a translation rule, so call the right setProperty() method
if map_item != None:
# The method id can be for example 'setTitle'
method_id = "set" + convertToUpperCase(map_item['erp5_property'])
LOG( 'BaobabConduit:'
, 0
, "try to call object method %s on %s" % (repr(method_id), repr(object))
)
if v not in ('', None):
# We look if the method exist
if hasattr(object, method_id):
# get the method itself
method = getattr(object, method_id)
# This call the method, this exactly the same thing
# as calling directly : object.setTitle(v)
method(v)
else:
LOG( 'BaobabConduit:'
, 100
, 'property map item don\'t match object properties'
)
### No translation rule found, try to find a hard-coded translation method in the conduit
else:
# The method is generated with the type of the document and with the
# name of the property. If the type of the document is 'Client' and the
# property is nature_economique, then it will try to find a method
# defined in this conduit 'editClientNatureEconomique'. This is very
# usefull if we must do some particular conversion or some calculation
# before editing an object. This is used when there is no simple
# equivalent between sql table and ERP5.
method_id = "edit%s%s" % (kw['type'].replace(' ', ''), convertToUpperCase(k))
#LOG( 'BaobabConduit:'
# , 0
# , "try to call conduit method %s on %s" % (repr(method_id), repr(object))
# )
if v not in ('', None):
if hasattr(self, method_id):
# get the method itself
method = getattr(self, method_id)
# This call the method, this exactly the same thing
# as calling directly : self.editClientNatureEconomique(object,v)
method(object, v)
#else:
# LOG( 'BaobabConduit:'
# , 100
# , "there is no method to handle <%s>%s</%s> data" % (k,repr(v),k)
# )
if object.getPortalType() == 'Bank Account' and object.getValidationState()!='valid':
object.portal_workflow.doActionFor(object, 'validate_action',
wf_id='bank_account_workflow')
if object.getPortalType() in ('Person','Organisation'):
object.updateLocalRolesOnSecurityGroups()
"""
All functions below are defined to set a document's property to a value
given in parameters.
The name of those functions are chosen to help the transfert of datas
from a given XML format to standard Baobab objects.
"""
### Client-related-properties functions
def editClientCategorie(self, document, value):
if document.getPortalType() == 'Organisation':
id_table = { 'BIF': 'institution/world/bank'
, 'PFR': 'institution/world/institution'
, 'ICU': 'institution/local/common'
, 'BET': 'institution/local/institution'
, 'ETF': 'institution/local/bank'
, 'BTR': 'treasury/national'
, 'ORP': 'treasury/other'
, 'ORI': 'organism/international'
, 'ORR': 'organism/local'
, 'COR': 'intermediaries'
, 'DIV': 'depositories/various'
, 'DER': 'depositories/savings'
, 'DAU': 'depositories/other'
}
#document.setActivity('banking_finance/' + id_table[value])
document.setActivity(value)
else:
LOG('BaobabConduit:', 0, 'Person\'s category ignored')
def editClientNatureEconomique(self, document, value):
if document.getPortalType() == 'Organisation':
# build the economical class category path
c = ''
path = ''
for i in value[1:]:
c += i
if c == '13':
path += '/S13'
if value != 'S13':
path += '/' + value
break
path += '/S' + c
document.setEconomicalClass(path)
else:
LOG( 'BaobabConduit inconsistency:'
, 200
, 'a non-Organisation client can\'t have an economical class'
)
def editClientSituationMatrimoniale(self, document, value):
"""
Here we can convert data from sql to data in ERP5 thanks
to a simple dictionnary: the id_table.
"""
if document.getPortalType() == 'Person':
id_table = { 'VEU' : 'widowed'
, 'DIV' : 'divorced'
, 'MAR' : 'married'
, 'CEL' : 'never_married'
}
document.setMaritalStatus(id_table[value])
else:
LOG( 'BaobabConduit inconsistency:'
, 200
, 'a non-Person client can\'t have a marital status'
)
def editClientCode(self, document, value):
pass
### BankAccount-related-properties functions
def editCompteDevise(self, document, value):
# Convert compte_devise to price_currency
document.setPriceCurrency('currency_module/' + value)
def editCompteRib(self, document, value):
# Convert compte_devise to price_currency
value = '%02i' % int(value)
document.setBankAccountKey(value)
def editCompteOverdraftFacility(self, document, value):
new_value = False
if value=='O':
new_value = True
document.setOverdraftFacility(new_value)
def editCompteSwiftRegistered(self, document, value):
new_value = False
if value=='O':
new_value = True
document.setSwiftRegistered(new_value)
def editCompteDateOuverture(self, document, value):
# Convert date_ouverture to start_date and stop_date
if document.getStopDate() in ('', None):
document.setStopDate(str(datetime.datetime.max))
document.setStartDate(value)
def editCompteDateFermeture(self, document, value):
# Convert date_firemeture to start_date and stop_date
if document.getStartDate() in ('', None):
document.setStartDate(str(datetime.datetime.min))
document.setStopDate(value)
### Agent-related-properties functions
def editMandataireNom(self, document, value):
# Convert mandataire_nom to first_name
LOG('BaobabConduit.editMandataireNom, document', 0, document)
LOG('BaobabConduit.editMandataireNom, document.getAgentValue()', 0, document.getAgentValue())
old_value = document.getAgentValue().getFirstName()
new_value = value
if old_value != new_value:
LOG( 'BaobabConduit:'
, 200
, 'old value of agent first name (%s) was replaced by a new one (%s)' % (old_value, new_value)
)
document.getAgentValue().setFirstName(new_value)
def editMandatairePrenom(self, document, value):
# Convert mandataire_prenom to last_name
old_value = document.getAgentValue().getLastName()
new_value = value
if old_value != new_value:
LOG( 'BaobabConduit:'
, 200
, 'old value of agent last name (%s) was replaced by a new one (%s)' % (old_value, new_value)
)
document.getAgentValue().setLastName(new_value)
def editMandataireService(self, document, value):
# Convert mandataire_service to an assignment
assignment = document.getAgentValue().newContent( portal_type = 'Assignment'
, id = 'service'
)
assignment.setGroup(value)
return
def editMandataireFonction(self, document, value):
# Convert mandataire_function to a career grade
document.getAgentValue().setCareerGrade(value)
return
def editMandataireTelephone(self, document, value):
# Convert mandataire_telephone to default_telephone_number
old_value = document.getAgentValue().getDefaultTelephoneNumber()
new_value = value
if old_value != new_value:
LOG( 'BaobabConduit:'
, 200
, "old value of agent's telephone (%s) was replaced by a new one (%s)" % (old_value, new_value)
)
document.getAgentValue().setDefaultTelephoneNumber(new_value)
def editMandataireDateCreation(self, document, value):
# Convert mandataire_date_creation to stop_date and start_date
if document.getStopDate() in ('', None):
document.setStopDate(str(datetime.datetime.max))
document.setStartDate(value)
### AgentPrivilege-related-properties functions
def editPouvoirCategorie(self, document, value):
# Convert pouvoir_categorie to agent_privilege property
id_table = { 'COM' : 'clearing'
, 'CIR' : 'circularization'
, 'REM' : 'cash_out'
, 'RET' : 'withdrawal_and_payment'
, 'RTE' : 'account_document_view'
, 'SIG' : 'signature'
, 'TRE' : 'treasury'
}
document.setAgentPrivilege(id_table[value])
def editPouvoirDateDebut(self, document, value):
# Convert pouvoir_date_debut to start_date and stop_date properties
if document.getStopDate() in ('', None):
document.setStopDate(str(datetime.datetime.max))
document.setStartDate(value)
def editPouvoirDateFin(self, document, value):
# Convert pouvoir_date_fin to start_date and stop_date properties
if document.getStartDate() in ('', None):
document.setStartDate(str(datetime.datetime.min))
document.setStopDate(value)
### CashInventory-related-properties functions
def editCashInventoryInventoryDate(self, document, value):
# Convert cash_inventory_inventory_date to stop_date property
if value in ('', None):
date = str(datetime.datetime.max)
else:
# Convert french date to strandard date
date_items = value.split('/')
day = date_items[0]
month = date_items[1]
year = date_items[2]
date = '/'.join([year, month, day])
document.setStopDate(date)
def getVaultPathFromCodification( self, object, agency_code=None, inventory_code=None, vault_code=None, currency_id=None):
"""
Recompose category path from agency_code, inventory_code and vault_code.
agency_code : site's codification
inventory_code : relative path common to all vaults for a given
inventory
vault_code : relative path specific to a given vault in a given
inventory
"""
if agency_code is None:
return None
portal = object.getPortalObject()
resolveCategory = portal.portal_categories.resolveCategory
site_list = portal.Delivery_getVaultItemList(vault_type=('site',),
strict_membership=1,
leaf_node=0,
user_site=0,
with_base=1)[1:]
agency_dict = dict([(resolveCategory(path).getCodification(), path) \
for (title, path) in site_list])
agency_path = agency_dict.get(agency_code)
result_list = []
if agency_path is not None:
result_list.append(agency_path)
inventory_path = self.inventory_code_to_path.get(inventory_code)
if inventory_path is not None:
result_list.append(inventory_path)
vault_path = self.vault_code_to_path.get(vault_code)
if vault_path != '':
if vault_path is not None:
result_list.append(vault_path)
elif vault_code is not None:
raise ValueError, '%s is not a known vault import codification' % (vault_code, )
elif inventory_code is not None:
raise ValueError, '%s is not a known inventory import codification' % (inventory_code, )
if len(result_list) == 0:
return None
return '/'.join(result_list)
### CashInventoryDetail-related-properties functions
def updateCashInventoryMatrix(self, line, cell_category_list, quantity, cell_uid):
base_id = 'movement'
base_category_list = [ 'emission_letter'
, 'variation'
, 'cash_status'
]
old_line_category_list = line.getVariationCategoryList()
messy_line_category_list = cell_category_list + old_line_category_list
sorted_line_base_category_list = []
sorted_line_category_list = []
sorted_cell_category_list = []
sorted_cell_range = []
# cell_category_list must have the same base category order of cell_range base category
for base_category in base_category_list:
# generate the sorted line categories
for category in messy_line_category_list:
if category.startswith(base_category + '/') and category not in sorted_line_category_list:
sorted_line_category_list.append(category)
# generate the sorted cell range
base_group = []
for category in messy_line_category_list:
if category.startswith(base_category + '/') and category not in base_group:
base_group.append(category)
sorted_cell_range.append(base_group)
# generate the sorted base category
if len(base_group) > 0:
sorted_line_base_category_list.append(base_category)
# generate the sorted cell variation categories
for category in cell_category_list:
if category.startswith(base_category + '/') and category not in sorted_cell_category_list:
sorted_cell_category_list.append(category)
# update line variation categories
line.setVariationBaseCategoryList(sorted_line_base_category_list)
line.setVariationCategoryList(sorted_line_category_list)
line.setCellRange(base_id = base_id, *sorted_cell_range)
# create the cell
kwd = { 'base_id' : base_id
, 'portal_type': 'Cash Inventory Cell'
}
new_cell = line.newCell(*sorted_cell_category_list, **kwd)
new_cell.edit( mapped_value_property_list = ('price', 'inventory')
, force_update = 1
, inventory = quantity
, membership_criterion_category_list = sorted_cell_category_list
, category_list = sorted_cell_category_list
, title = cell_uid
)
new_cell.getPrice()
### BankAccountInventory-related-properties functions
def editBankAccountInventoryAgencyCode(self, document, value):
# Convert bank_account_inventory_agency_code to a destination
agency_path = self.getVaultPathFromCodification( object = document
, agency_code = value
)
document.setDestination(agency_path)
def editBankAccountInventoryDate(self, document, value):
# Convert bank_account_inventory_date to stop_date property
if value in ('', None):
date = str(datetime.datetime.max)
else:
# Convert french date to strandard date
date_items = value.split('/')
day = date_items[0]
month = date_items[1]
year = date_items[2]
date = '/'.join([year, month, day])
document.setStopDate(date)
def editBankAccountInventoryLineCurrency(self, document, value):
# Convert bank_account_inventory_date to stop_date property
resource_url = 'currency_module/%s' % value
resource_value = document.getPortalObject().restrictedTraverse(resource_url)
document.setResourceValue(resource_value)
def newObject(self, object=None, xml=None, simulate=0, reset_local_roles=0, reset_workflow=0):
"""
define it here in order to make sure to not delete security
"""
ERP5Conduit.newObject(self, object=object, xml=xml, simulate=simulate,
reset_local_roles=reset_local_roles, reset_workflow=reset_workflow)
def getGidFromObject(self, object):
"""
return the Gid composed with the object informations
"""
script = None
parent = object.aq_parent
while not (parent.id.endswith('_xml') or (parent.id.endswith('_module'))):
parent = parent.aq_parent
if parent.id == 'bank_account_inventory_xml':
script = getattr(object, 'BankAccountInventory_getMasterGid')
elif parent.id == 'customers_xml':
script = getattr(object, 'Oracle_getGid')
elif parent.id == 'cash_inventory_xml':
script = getattr(object, 'Inventory_getMasterGid')
elif object.getPortalType() == 'Bank Account Inventory Group':
script = getattr(object, 'BankAccountInventory_getGid')
elif object.getPortalType() == 'Cash Inventory Group':
script = getattr(object, 'Inventory_getClientGid')
else:
script = getattr(object, 'Baobab_getGid')
return script()
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7