blob: 8b386e29128672473f4d0c587ac6e04a948ba51b (
plain)
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
|
# -*- coding: utf-8 -*-
# Part of Odoo. See LICENSE file for full copyright and licensing details.
import logging
from odoo import api, fields, models
_logger = logging.getLogger(__name__)
class ResPartnerAutocompleteSync(models.Model):
_name = 'res.partner.autocomplete.sync'
_description = 'Partner Autocomplete Sync'
partner_id = fields.Many2one('res.partner', string="Partner", ondelete='cascade')
synched = fields.Boolean('Is synched', default=False)
@api.model
def start_sync(self):
to_sync_items = self.search([('synched', '=', False)])
for to_sync_item in to_sync_items:
partner = to_sync_item.partner_id
params = {
'partner_gid': partner.partner_gid,
}
if partner.vat and partner._is_vat_syncable(partner.vat):
params['vat'] = partner.vat
result, error = partner._rpc_remote_api('update', params)
if error:
_logger.error('Send Partner to sync failed: %s' % str(error))
to_sync_item.write({'synched': True})
def add_to_queue(self, partner_id):
to_sync = self.search([('partner_id', '=', partner_id)])
if not to_sync:
to_sync = self.create({'partner_id': partner_id})
return to_sync
|