80 lines
3.8 KiB
Python
80 lines
3.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Copyright 2020 Akretion France (http://www.akretion.com/)
|
|
# @author: Alexis de Lattre <alexis.delattre@akretion.com>
|
|
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl).
|
|
|
|
from odoo import api, SUPERUSER_ID
|
|
|
|
oldtype2label = {
|
|
'1_home': 'Ancien type : Maison',
|
|
# '2_mobile': 'Ancien type : Portable',
|
|
'3_office': 'Ancien type : Bureau',
|
|
'4_home_fax': 'Ancien type : Fax maison',
|
|
'5_office_fax': 'Ancien type : Fax bureau',
|
|
'6_phone_fax_home': u'Ancien type : Tél/fax maison',
|
|
'7_other': 'Ancien type : Autre',
|
|
}
|
|
|
|
|
|
def migrate(cr, version):
|
|
if not version:
|
|
return
|
|
|
|
with api.Environment.manage():
|
|
env = api.Environment(cr, SUPERUSER_ID, {})
|
|
rppo = env['res.partner.phone']
|
|
|
|
wdict = {} # key = partnerID, values = {id: {'type': '1_home', 'phone': '+33'}}
|
|
for rec in rppo.search_read([('type', '!=', False)], ['type', 'phone', 'partner_id', 'note']):
|
|
if rec['partner_id'][0] not in wdict:
|
|
wdict[rec['partner_id'][0]] = {}
|
|
wdict[rec['partner_id'][0]][rec['id']] = rec
|
|
|
|
# first pass for primary phone
|
|
for partner_id, xdict in wdict.items():
|
|
mig_phone_entries(cr, xdict, '3_phone_primary', '4_phone_secondary', ['1_home', '6_phone_fax_home', '3_office', '7_other'])
|
|
mig_phone_entries(cr, xdict, '5_mobile_primary', '6_mobile_secondary', ['2_mobile'])
|
|
mig_phone_entries(cr, xdict, '7_fax_primary', '8_fax_secondary', ['4_home_fax', '5_office_fax'])
|
|
cr.execute('select id, email from res_partner where email is not null order by id')
|
|
for partner in cr.dictfetchall():
|
|
print('partner_id=', partner['id'])
|
|
old_email = partner['email'].strip()
|
|
if old_email:
|
|
email_split = old_email.split(',')
|
|
clean_email_split = [x.strip() for x in email_split if x.strip()]
|
|
# primary:
|
|
email_primary = clean_email_split.pop(0)
|
|
rppo.create({
|
|
'type': '1_email_primary',
|
|
'partner_id': partner['id'],
|
|
'email': email_primary,
|
|
})
|
|
cr.execute('UPDATE res_partner set email=%s where id=%s', (email_primary, partner['id']))
|
|
for email_sec in clean_email_split:
|
|
email_sec = email_sec.strip()
|
|
if email_sec:
|
|
rppo.create({
|
|
'type': '2_email_secondary',
|
|
'partner_id': partner['id'],
|
|
'email': email_sec.strip(),
|
|
})
|
|
|
|
|
|
def mig_phone_entries(cr, xdict, new_type_primary, new_type_secondary, old_type_list):
|
|
zdict = {}
|
|
for phone_id, values in xdict.items():
|
|
if values['type'] in old_type_list:
|
|
zdict[phone_id] = values
|
|
if zdict:
|
|
values_sorted = sorted(zdict.values(), key=lambda x: x['type'])
|
|
primary_phone_val = values_sorted[0]
|
|
cr.execute("""UPDATE res_partner_phone SET type=%s WHERE id=%s""", (new_type_primary, primary_phone_val['id']))
|
|
if not primary_phone_val.get('note') and oldtype2label.get(primary_phone_val['type']):
|
|
cr.execute("""UPDATE res_partner_phone SET note=%s WHERE id=%s""", (oldtype2label[primary_phone_val['type']], primary_phone_val['id']))
|
|
|
|
zdict.pop(primary_phone_val['id'])
|
|
for secondary_phone_val in zdict.values():
|
|
cr.execute("""UPDATE res_partner_phone SET type=%s WHERE id=%s""", (new_type_secondary, secondary_phone_val['id']))
|
|
if not secondary_phone_val.get('note') and oldtype2label.get(secondary_phone_val['type']):
|
|
cr.execute("""UPDATE res_partner_phone SET note=%s WHERE id=%s""", (oldtype2label[secondary_phone_val['type']], secondary_phone_val['id']))
|