1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
|
#########################################################################
#This module intergrates Open ERP with the magento core #
#Core settings are stored here #
#########################################################################
# #
# Copyright (C) 2009 Sharoon Thomas #
# #
#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 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 General Public License for more details. #
# #
#You should have received a copy of the GNU General Public License #
#along with this program. If not, see <http://www.gnu.org/licenses/>. #
#########################################################################
from osv import osv, fields
import magerp_osv
from base_external_referentials import external_osv
import tools
DEBUG = True
TIMEOUT = 2
class external_referential(magerp_osv.magerp_osv):
#This class stores instances of magento to which the ERP will connect, so you can connect OpenERP to multiple Magento installations (eg different Magento databases)
_inherit = "external.referential"
_columns = {
'attribute_sets':fields.one2many('magerp.product_attribute_set', 'referential_id', 'Attribute Sets'),
'default_pro_cat':fields.many2one('product.category','Default Product Category',required=True, help="Products imported from magento may have many categories.\nOpenERP requires a specific category for a product to facilitate invoicing etc."),
'default_lang_id':fields.many2one('res.lang', 'Default Language',required=True, help="Choose the language which will be used for the Default Value in Magento"),
'active': fields.boolean('Active'),
}
_defaults = {
'active': lambda *a: 1,
}
def connect(self, cr, uid, ids, context=None):
#ids has to be a list
if isinstance(ids, (list, tuple)) and len(ids) == 1:
instance = self.browse(cr, uid, ids[0], context)
if instance:
core_imp_conn = self.external_connection(cr, uid, instance, DEBUG)
if core_imp_conn.connect():
return core_imp_conn
else:
raise osv.except_osv(_("Connection Error"), _("Could not connect to server\nCheck location, username & password."))
return False
def core_sync(self, cr, uid, ids, context=None):
instances = self.browse(cr, uid, ids, context)
filter = []
for inst in instances:
core_imp_conn = self.external_connection(cr, uid, inst, DEBUG)
self.pool.get('external.shop.group').mage_import_base(cr, uid,core_imp_conn, inst.id, defaults={'referential_id':inst.id})
self.pool.get('sale.shop').mage_import_base(cr, uid, core_imp_conn, inst.id, {'magento_shop':True, 'company_id':self.pool.get('res.users').browse(cr, uid, uid).company_id.id})
self.pool.get('magerp.storeviews').mage_import_base(cr,uid,core_imp_conn, inst.id, defaults={})
return True
def sync_categs(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
pro_cat_conn = self.external_connection(cr, uid, inst, DEBUG)
confirmation = pro_cat_conn.call('catalog_category.currentStore', [0]) #Set browse to root store
if confirmation:
categ_tree = pro_cat_conn.call('catalog_category.tree') #Get the tree
self.pool.get('product.category').record_entire_tree(cr, uid, inst.id, pro_cat_conn, categ_tree, DEBUG)
#exp_ids = self.pool.get('product.category').search(cr,uid,[('exportable','=',True)])
#self.pool.get('product.category').ext_export(cr,uid,exp_ids,[inst.id],{},{'conn_obj':pro_cat_conn})
return True
def sync_attribs(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
attrib_set_ids = self.pool.get('magerp.product_attribute_set').search(cr, uid, [('referential_id', '=', inst.id)])
attrib_sets = self.pool.get('magerp.product_attribute_set').read(cr, uid, attrib_set_ids, ['magento_id'])
#Get all attribute set ids to get all attributes in one go
all_attr_set_ids = self.pool.get('magerp.product_attribute_set').get_all_mage_ids(cr, uid, [], inst.id)
#Call magento for all attributes
mage_inp = attr_conn.call('ol_catalog_product_attribute.list', [all_attr_set_ids]) #Get the tree
#self.pool.get('magerp.product_attributes').sync_import(cr, uid, mage_inp, inst.id, DEBUG) #Last argument is extra mage2oe filter as same attribute ids
self.pool.get('magerp.product_attributes').ext_import(cr, uid, mage_inp, inst.id, defaults={'referential_id':inst.id}, context={'referential_id':inst.id})
#Relate attribute sets & attributes
mage_inp = {}
#Pass in {attribute_set_id:{attributes},attribute_set_id2:{attributes}}
#print "Attribute sets are:", attrib_sets
for each in attrib_sets:
mage_inp[each['magento_id']] = attr_conn.call('ol_catalog_product_attribute.relations', [each['magento_id']])
if mage_inp:
self.pool.get('magerp.product_attribute_set').relate(cr, uid, mage_inp, inst.id, DEBUG)
return True
def sync_attrib_sets(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
filter = []
self.pool.get('magerp.product_attribute_set').mage_import_base(cr, uid, attr_conn, inst.id,{'referential_id':inst.id},{'ids_or_filter':filter})
return True
def sync_attrib_groups(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
attrset_ids = self.pool.get('magerp.product_attribute_set').get_all_mage_ids(cr, uid, [], inst.id)
filter = [{'attribute_set_id':{'in':attrset_ids}}]
self.pool.get('magerp.product_attribute_groups').mage_import_base(cr, uid, attr_conn, inst.id, {'referential_id': inst.id}, {'ids_or_filter':filter})
return True
def sync_customer_groups(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
filter = []
self.pool.get('res.partner.category').mage_import_base(cr, uid, attr_conn, inst.id, {}, {'ids_or_filter':filter})
return True
def sync_customer_addresses(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
filter = []
#self.pool.get('res.partner').mage_import(cr, uid, filter, attr_conn, inst.id, DEBUG)
#TODO fix by retrieving customer list first
self.pool.get('res.partner.address').mage_import_base(cr, uid, attr_conn, inst.id, {}, {'ids_or_filter':filter})
return True
def sync_products(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
filter = []
list_prods = attr_conn.call('catalog_product.list')
#self.pool.get('product.product').mage_import(cr, uid, filter, attr_conn, inst.id, DEBUG)
result = []
for each in list_prods:
each_product_info = attr_conn.call('catalog_product.info', [each['product_id']])
result.append(each_product_info)
self.pool.get('product.product').ext_import(cr, uid, result, inst.id, context={})
return True
def export_products(self, cr, uid, ids, context):
shop_ids = self.pool.get('sale.shop').search(cr, uid, [])
for inst in self.browse(cr, uid, ids, context):
for shop in self.pool.get('sale.shop').browse(cr, uid, shop_ids, context):
context['conn_obj'] = self.external_connection(cr, uid, inst)
#shop.export_catalog
tools.debug((cr, uid, shop, context,))
shop.export_products(cr, uid, shop, context)
return True
def sync_partner(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
result = []
result_address = []
list_customer = attr_conn.call('customer.list')
for each in list_customer:
customer_id = int(each['customer_id'])
each_customer_info = attr_conn.call('customer.info', [customer_id])
result.append(each_customer_info)
each_customer_address_info = attr_conn.call('customer_address.list', [customer_id])
if len(each_customer_address_info):
customer_address_info = each_customer_address_info[0]
customer_address_info['customer_id'] = customer_id
customer_address_info['email'] = each_customer_info['email']
result_address.append(customer_address_info)
print customer_address_info
partner_ids = self.pool.get('res.partner').ext_import(cr, uid, result, inst.id, context={})
if result_address:
partner_address_ids = self.pool.get('res.partner.address').ext_import(cr, uid, result_address, inst.id, context={})
return True
def sync_newsletter(self, cr, uid, ids, context):
#update first all customer
self.sync_partner(cr, uid, ids, context)
instances = self.browse(cr, uid, ids, context)
partner_obj = self.pool.get('res.partner')
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
filter = []
list_subscribers = attr_conn.call('ol_customer_subscriber.list')
result = []
for each in list_subscribers:
each_subscribers_info = attr_conn.call('ol_customer_subscriber.info', [each])
# search this customer. If exist, update your newsletter subscription
partner_ids = partner_obj.search(cr, uid, [('emailid', '=', each_subscribers_info[0]['subscriber_email'])])
if partner_ids:
#unsubscriber magento value: 3
if int(each_subscribers_info[0]['subscriber_status']) == 1:
subscriber_status = 1
else:
subscriber_status = 0
partner_obj.write(cr, uid, partner_ids[0], {'mag_newsletter': subscriber_status})
return True
def sync_newsletter_unsubscriber(self, cr, uid, ids, context):
instances = self.browse(cr, uid, ids, context)
partner_obj = self.pool.get('res.partner')
for inst in instances:
attr_conn = self.external_connection(cr, uid, inst, DEBUG)
partner_ids = partner_obj.search(cr, uid, [('mag_newsletter', '!=', 1), ('emailid', '!=', '')])
print partner_ids
for partner in partner_obj.browse(cr, uid, partner_ids):
print partner.emailid
if partner.emailid:
attr_conn.call('ol_customer_subscriber.delete', [partner.emailid])
return True
# Schedules functions ============ #
def run_import_newsletter_scheduler(self, cr, uid, context=None):
if context == None:
context = {}
instances_ids = self.search(cr, uid, [('active', '=', 1)])
if instances_ids:
self.sync_newsletter(cr, uid, instances_ids, context)
if DEBUG:
print "run_import_newsletter_scheduler: %s" % instances_ids
def run_import_newsletter_unsubscriber_scheduler(self, cr, uid, context=None):
if context == None:
context = {}
instances_ids = self.search(cr, uid, [('active', '=', 1)])
if instances_ids:
self.sync_newsletter_unsubscriber(cr, uid, instances_ids, context)
if DEBUG:
print "run_import_newsletter_unsubscriber_scheduler: %s" % instances_ids
external_referential()
class external_shop_group(magerp_osv.magerp_osv):
_inherit = "external.shop.group"
#Return format of API:{'code': 'base', 'name': 'Main', 'website_id': '1', 'is_default': '1', 'sort_order': '0', 'default_group_id': '1'}
# default_group_id is the default shop of the external_shop_group (external_shop_group = website)
def _get_default_shop_id(self, cr, uid, ids, prop, unknow_none, context):
res = {}
for shop_group in self.browse(cr, uid, ids, context):
if shop_group.default_shop_integer_id:
rid = self.pool.get('sale.shop').extid_to_oeid(cr, uid, shop_group.default_shop_integer_id, shop_group.referential_id.id)
res[shop_group.id] = rid
else:
res[shop_group.id] = False
return res
_columns = {
'code':fields.char('Code', size=100),
'is_default':fields.boolean('Is Default?'),
'sort_order':fields.integer('Sort Order'),
'default_shop_integer_id':fields.integer('Default Store'), #This field can't be a many2one because shop_group field will be mapped before creating Shop (Shop = Store, shop_group = website)
'default_shop_id':fields.function(_get_default_shop_id, type="many2one", relation="sale.shop", method=True, string="Default Store"),
'referential_type' : fields.related('referential_id', 'type_id', type='many2one', relation='external.referential.type', string='External Referential Type'),
}
external_shop_group()
class magerp_storeviews(magerp_osv.magerp_osv):
_name = "magerp.storeviews"
_description = "The magento store views information"
_columns = {
'name':fields.char('Store View Name', size=100),
'code':fields.char('Code', size=100),
'website_id':fields.many2one('external.shop.group', 'Website', select=True, ondelete='cascade'),
'is_active':fields.boolean('Default ?'),
'sort_order':fields.integer('Sort Order'),
'shop_id':fields.many2one('sale.shop', 'Shop', select=True, ondelete='cascade'),
'lang_id':fields.many2one('res.lang', 'Language'),
}
#Return format of API:{'code': 'default', 'store_id': '1', 'website_id': '1', 'is_active': '1', 'sort_order': '0', 'group_id': '1', 'name': 'Default Store View'}
magerp_storeviews()
|