Atul Patel(OpenERP) has proposed merging lp:~openerp-dev/openobject-addons/trunk-import_sugarcrm-import_crm_dictionary_mapping-atp into lp:~openerp-dev/openobject-addons/trunk-import_sugarcrm.
Requested reviews: tfr (Openerp) (tfr) For more details, see: https://code.launchpad.net/~openerp-dev/openobject-addons/trunk-import_sugarcrm-import_crm_dictionary_mapping-atp/+merge/52383 1) Import lead into lead - Dictionary Mapping 2) Import opportunity into lead - Dictionary Mapping -- https://code.launchpad.net/~openerp-dev/openobject-addons/trunk-import_sugarcrm-import_crm_dictionary_mapping-atp/+merge/52383 Your team OpenERP R&D Team is subscribed to branch lp:~openerp-dev/openobject-addons/trunk-import_sugarcrm.
=== modified file 'sugarcrm_syncro/__init__.py' --- sugarcrm_syncro/__init__.py 2011-02-17 11:07:49 +0000 +++ sugarcrm_syncro/__init__.py 2011-03-07 09:54:04 +0000 @@ -22,3 +22,4 @@ import import_sugarcrm import sugar import wizard +import sugarcrm_fields_mapping \ No newline at end of file === modified file 'sugarcrm_syncro/import_sugarcrm.py' --- sugarcrm_syncro/import_sugarcrm.py 2011-03-03 13:52:35 +0000 +++ sugarcrm_syncro/import_sugarcrm.py 2011-03-07 09:54:04 +0000 @@ -18,11 +18,32 @@ # along with this program. If not, see <http://www.gnu.org/licenses/>. # ############################################################################## -from operator import itemgetter from osv import fields, osv import sugar -from tools.translate import _ +import sugarcrm_fields_mapping +MAP_FIELDS={'Opportunities':{'name': 'name', + 'probability': 'probability', + 'planned_revenue': 'amount_usdollar', + 'write_date':'date_modified', + 'date_deadline':'date_closed' + }, + + 'Leads':{'name': ['first_name','last_name'], + 'contact_name': ['first_name','last_name'], + 'description': 'description', + 'partner_name': ['first_name','last_name'], + 'email_from': 'email1', + 'phone': 'phone_work', + 'mobile': 'phone_mobile', + 'write_date':'date_modified', + 'function':'title', + 'street': 'primary_address_street', + 'zip': 'primary_address_postalcode', + 'city':'primary_address_city', + } + } + class import_sugarcrm(osv.osv): """Import SugarCRM DATA""" @@ -39,186 +60,39 @@ 'opportunity': lambda *a: True, } - def _get_all(self, cr, uid, model, sugar_val, context=None): - if not context: - context = {} - models = self.pool.get(model) - all_model_ids = models.search(cr, uid, [('name', '=', sugar_val)]) - output = [(False, '')] - output = sorted([(o.id, o.name) - for o in models.browse(cr, uid, all_model_ids, - context=context)], - key=itemgetter(1)) - return output - - def _get_all_states(self, cr, uid, sugar_val, context=None): - if not context: - context = {} - return self._get_all( - cr, uid, 'res.country.state', sugar_val, context=context) - - def _get_all_countries(self, cr, uid, sugar_val, context=None): - if not context: - context = {} - return self._get_all( - cr, uid, 'res.country', sugar_val, context=context) - - def _get_lead_status(self, cr, uid, sugar_val, context=None): - if not context: - context = {} - sugar_stage = '' - if sugar_val.get('status','') == 'New': - sugar_stage = 'New' - elif sugar_val.get('status','') == 'Assigned': - sugar_stage = 'Qualification' - elif sugar_val.get('status','') == 'In Progress': - sugar_stage = 'Proposition' - elif sugar_val.get('status','') == 'Recycled': - sugar_stage = 'Negotiation' - elif sugar_val.get('status','') == 'Dead': - sugar_stage = 'Lost' - else: - sugar_stage = '' - return sugar_stage - - def _get_opportunity_status(self, cr, uid, sugar_val, context=None): - if not context: - context = {} - sugar_stage = '' - if sugar_val.get('sales_stage','') == 'Need Analysis': - sugar_stage = 'New' - elif sugar_val.get('sales_stage','') == 'Closed Lost': - sugar_stage = 'Lost' - elif sugar_val.get('sales_stage','') == 'Closed Won': - sugar_stage = 'Won' - elif sugar_val.get('sales_stage','') == 'Value Proposition': - sugar_stage = 'Proposition' - elif sugar_val.get('sales_stage','') == 'Negotiation/Review': - sugar_stage = 'Negotiation' - else: - sugar_stage = '' - return sugar_stage - - def create_lead(self, cr, uid, sugar_val, country, state, context=None): - if not context: - context = {} - - lead_pool = self.pool.get("crm.lead") - stage_id = '' - stage = self._get_lead_status(cr, uid, sugar_val, context=None) - stage_pool = self.pool.get('crm.case.stage') - - stage_ids = stage_pool.search(cr, uid, [("type", '=', 'lead'), ('name', '=', stage)]) - - for stage in stage_pool.browse(cr, uid, stage_ids): - stage_id = stage.id - vals = {'name': sugar_val.get('first_name','')+' '+ sugar_val.get('last_name',''), - 'contact_name': sugar_val.get('first_name','')+' '+ sugar_val.get('last_name',''), - 'user_id':sugar_val.get('created_by',''), - 'description': sugar_val.get('description',''), - 'partner_name': sugar_val.get('first_name','')+' '+ sugar_val.get('last_name',''), - 'email_from': sugar_val.get('email1',''), - 'stage_id': stage_id or '', - 'phone': sugar_val.get('phone_work',''), - 'mobile': sugar_val.get('phone_mobile',''), - 'write_date':sugar_val.get('date_modified',''), - 'function':sugar_val.get('title',''), - 'street': sugar_val.get('primary_address_street',''), - 'zip': sugar_val.get('primary_address_postalcode',''), - 'city':sugar_val.get('primary_address_city',''), - 'country_id': country and country[0][0] or False, - 'state_id': state and state[0][0] or False - } - new_lead_id = lead_pool.create(cr, uid, vals) - return new_lead_id - - def create_opportunity(self, cr, uid, sugar_val, country, state, context=None): - if not context: - context = {} - lead_pool = self.pool.get("crm.lead") - stage_id = '' - stage_pool = self.pool.get('crm.case.stage') - stage = self._get_opportunity_status(cr, uid, sugar_val, context) - - stage_ids = stage_pool.search(cr, uid, [("type", '=', 'opportunity'), ('name', '=', stage)]) - for stage in stage_pool.browse(cr, uid, stage_ids): - stage_id = stage.id - vals = {'name': sugar_val.get('name',''), - 'probability': sugar_val.get('probability',''), - 'user_id': sugar_val.get('created_by', ''), - 'stage_id': stage_id or '', - 'type': 'opportunity', - 'user_id': sugar_val.get('created_by',''), - 'planned_revenue': sugar_val.get('amount_usdollar'), - 'write_date':sugar_val.get('date_modified',''), - } - new_opportunity_id = lead_pool.create(cr, uid, vals) - return new_opportunity_id - def _get_sugar_module_name(self, cr, uid, ids, context=None): - if not context: context = {} - sugar_name = [] - for current in self.read(cr, uid, ids): if current.get('lead'): sugar_name.append('Leads') if current.get('opportunity'): sugar_name.append('Opportunities') - return sugar_name - - - def _get_module_name(self, cr, uid, ids, context=None): - - if not context: - context = {} - module_name = [] - - for current in self.read(cr, uid, ids, ['lead', 'opportunity']): - if not current.get('lead') and not current.get('opportunity'): - raise osv.except_osv(_('Error !'), _('Please Select Module')) - - if current.get('lead'): - module_name.append('crm') - if current.get('opportunity'): - module_name.append('crm') - - ids = self.pool.get("ir.module.module").search(cr, uid, [('name', 'in', module_name),('state', '=', 'installed')]) - if not ids: - for module in module_name: - raise osv.except_osv(_('Error !'), _('Please Install %s Module') % ((module))) - - def get_create_method(self, cr, uid, sugar_name, sugar_val, country, state, context=None): - if not context: - context = {} - - if sugar_name == "Leads": - self.create_lead(cr, uid, sugar_val, country, state, context) - - elif sugar_name == "Opportunities": - self.create_opportunity(cr, uid, sugar_val, country, state,context) - return {} + + def get_type_val(self, sugar_name, fields, datas): + if sugar_name == 'Opportunities': + fields.append('type') + datas.append('opportunity') + if sugar_name == 'Leads': + fields.append('type') + datas.append('lead') + return fields, datas def import_data(self, cr, uid, ids,context=None): if not context: context={} - sugar_val = [] - - self._get_module_name(cr, uid, ids, context) + lead_pool = self.pool.get('crm.lead') sugar_module = self._get_sugar_module_name(cr, uid, ids, context=None) - + PortType,sessionid = sugar.login(context.get('username',''), context.get('password','')) for sugar_name in sugar_module: sugar_data = sugar.search(PortType,sessionid,sugar_name) - - for val in sugar_data: - country = self._get_all_countries(cr, uid, val.get('primary_address_country'), context) - state = self._get_all_states(cr, uid, val.get('primary_address_state'), context) - self.get_create_method(cr, uid, sugar_name, val, country, state, context) - + for val in sugar_data: + fields, datas = sugarcrm_fields_mapping.sugarcrm_fields_mapp(val, sugar_name, MAP_FIELDS) + fields_val, datas_val = self.get_type_val(sugar_name, fields, datas) + lead_pool.import_data(cr, uid, fields_val, [datas_val], mode='init', current_module='', noupdate=False, context=context) obj_model = self.pool.get('ir.model.data') model_data_ids = obj_model.search(cr,uid,[('model','=','ir.ui.view'),('name','=','import.message.form')]) === added file 'sugarcrm_syncro/sugarcrm_fields_mapping.py' --- sugarcrm_syncro/sugarcrm_fields_mapping.py 1970-01-01 00:00:00 +0000 +++ sugarcrm_syncro/sugarcrm_fields_mapping.py 2011-03-07 09:54:04 +0000 @@ -0,0 +1,32 @@ +# -*- coding: utf-8 -*- +############################################################################## +# +# OpenERP, Open Source Management Solution +# Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>). +# +# This program is free software: you can redistribute it and/or modify +# it under the terms of the GNU Affero General Public License as +# published by the Free Software Foundation, either version 3 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 Affero General Public License for more details. +# +# You should have received a copy of the GNU Affero General Public License +# along with this program. If not, see <http://www.gnu.org/licenses/>. +# +############################################################################## + +def sugarcrm_fields_mapp(dict_sugar,openerp_obj,openerp_dict): + fields=[] + data_lst = [] + for key,val in openerp_dict.get(openerp_obj).items(): + if key not in fields: + fields.append(key) + if isinstance(val, list): + data_lst.append(dict_sugar.get(val[0],['']) + ' ' + dict_sugar.get(val[1],[''])) + else: + data_lst.append(dict_sugar.get(val,[''])) + return fields,data_lst
_______________________________________________ Mailing list: https://launchpad.net/~openerp-dev-web Post to : [email protected] Unsubscribe : https://launchpad.net/~openerp-dev-web More help : https://help.launchpad.net/ListHelp
