summaryrefslogtreecommitdiff
path: root/addons/pos_adyen/models/adyen_account.py
blob: e6621b4a03d572bc4bd99674a00ceba59eae1bf7 (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
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
# -*- coding: utf-8 -*-
# Part of Odoo. See LICENSE file for full copyright and licensing details.

import uuid
from werkzeug.urls import url_join

from odoo import api, fields, models, _
from odoo.exceptions import ValidationError


class AdyenAccount(models.Model):
    _inherit = 'adyen.account'

    store_ids = fields.One2many('adyen.store', 'adyen_account_id')
    terminal_ids = fields.One2many('adyen.terminal', 'adyen_account_id')

    @api.model
    def _sync_adyen_cron(self):
        self.env['adyen.terminal']._sync_adyen_terminals()
        super(AdyenAccount, self)._sync_adyen_cron()

    def action_order_terminal(self):
        if not self.store_ids:
            raise ValidationError(_('Please create a store first.'))

        store_uuids = ','.join(self.store_ids.mapped('store_uuid'))
        onboarding_url = self.env['ir.config_parameter'].sudo().get_param('adyen_platforms.onboarding_url')
        return {
            'type': 'ir.actions.act_url',
            'target': 'new',
            'url': url_join(onboarding_url, 'order_terminals?store_uuids=%s' % store_uuids),
        }


class AdyenStore(models.Model):
    _name = 'adyen.store'
    _inherit = ['adyen.address.mixin']
    _description = 'Adyen for Platforms Store'

    adyen_account_id = fields.Many2one('adyen.account', ondelete='cascade')
    store_reference = fields.Char('Reference', default=lambda self: uuid.uuid4().hex)
    store_uuid = fields.Char('UUID', readonly=True) # Given by Adyen
    name = fields.Char('Name', required=True)
    phone_number = fields.Char('Phone Number', required=True)
    terminal_ids = fields.One2many('adyen.terminal', 'store_id', string='Payment Terminals', readonly=True)

    @api.model
    def create(self, values):
        adyen_store_id = super(AdyenStore, self).create(values)
        response = adyen_store_id.adyen_account_id._adyen_rpc('create_store', adyen_store_id._format_data())
        stores = response['accountHolderDetails']['storeDetails']
        created_store = next(store for store in stores if store['storeReference'] == adyen_store_id.store_reference)
        adyen_store_id.with_context(update_from_adyen=True).sudo().write({
            'store_uuid': created_store['store'],
        })
        return adyen_store_id

    def unlink(self):
        for store_id in self:
            store_id.adyen_account_id._adyen_rpc('close_stores', {
                'accountHolderCode': store_id.adyen_account_id.account_holder_code,
                'stores': [store_id.store_uuid],
            })
        return super(AdyenStore, self).unlink()

    def _format_data(self):
        return {
            'accountHolderCode': self.adyen_account_id.account_holder_code,
            'accountHolderDetails': {
                'storeDetails': [{
                    'storeReference': self.store_reference,
                    'storeName': self.name,
                    'merchantCategoryCode': '7999',
                    'address': {
                        'city': self.city,
                        'country': self.country_id.code,
                        'houseNumberOrName': self.house_number_or_name,
                        'postalCode': self.zip,
                        'stateOrProvince': self.state_id.code or None,
                        'street': self.street,
                    },
                    'fullPhoneNumber': self.phone_number,
                }],
            }
        }


class AdyenTerminal(models.Model):
    _name = 'adyen.terminal'
    _description = 'Adyen for Platforms Terminal'
    _rec_name = 'terminal_uuid'

    adyen_account_id = fields.Many2one('adyen.account', ondelete='cascade')
    store_id = fields.Many2one('adyen.store')
    terminal_uuid = fields.Char('Terminal ID')

    @api.model
    def _sync_adyen_terminals(self):
        for adyen_store_id in self.env['adyen.store'].search([]):
            response = adyen_store_id.adyen_account_id._adyen_rpc('connected_terminals', {
                'store': adyen_store_id.store_uuid,
            })
            terminals_in_db = set(self.search([('store_id', '=', adyen_store_id.id)]).mapped('terminal_uuid'))

            # Added terminals
            for terminal in set(response.get('uniqueTerminalIds')) - terminals_in_db:
                self.sudo().create({
                    'adyen_account_id': adyen_store_id.adyen_account_id.id,
                    'store_id': adyen_store_id.id,
                    'terminal_uuid': terminal,
                })