account_account.py

# -*- coding: utf-8 -*-
import logging

from odoo import api, fields, models, _, tools
from odoo.osv import expression
from odoo.exceptions import UserError, ValidationError

_logger = logging.getLogger(__name__)


class AccountAccountType(models.Model):
    _name = "account.account.type"
    _description = "Account Type"

    name = fields.Char(string='Account Type', required=True, translate=True)
    include_initial_balance = fields.Boolean(
        string="Bring Accounts Balance Forward",
        help="Used in reports to know if we should consider journal items from the beginning of time instead of from "
             "the fiscal year only. Account types that should be reset to zero at each new fiscal year (like "
             "expenses, revenue..) should not have this option set.")
    type = fields.Selection([
        ('other', 'Regular'),
        ('receivable', 'Receivable'),
        ('payable', 'Payable'),
        ('liquidity', 'Liquidity'),
    ], required=True, default='other',
        help="The 'Internal Type' is used for features available on " \
             "different types of accounts: liquidity type is for cash or bank accounts" \
             ", payable/receivable is for vendor/customer accounts.")
    internal_group = fields.Selection([
        ('equity', 'Equity'),
        ('asset', 'Asset'),
        ('liability', 'Liability'),
        ('income', 'Income'),
        ('expense', 'Expense'),
        ('off_balance', 'Off Balance'),
    ], string="Internal Group",
        required=True,
        help="The 'Internal Group' is used to filter accounts based on the internal group set on the account type.")
    note = fields.Text(string='Description')


class AccountAccount(models.Model):
    _name = "account.account"
    _description = "Account"
    _order = "is_off_balance, code"
    _check_company_auto = True

    @api.constrains('internal_type', 'reconcile')
    def _check_reconcile(self):
        for account in self:
            if account.internal_type in ('receivable', 'payable') and account.reconcile == False:
                raise ValidationError(
                    _('You cannot have a receivable/payable account that is not reconcilable. (account code: %s)',
                      account.code))

    # @api.constrains('user_type_id')
    # def _check_user_type_id_unique_current_year_earning(self):
    #     data_unaffected_earnings = self.env.ref('account.data_unaffected_earnings')
    #     result = self.read_group([('user_type_id', '=', data_unaffected_earnings.id)], ['company_id'], ['company_id'])
    #     for res in result:
    #         if res.get('company_id_count', 0) >= 2:
    #             account_unaffected_earnings = self.search([('company_id', '=', res['company_id'][0]),
    #                                                        ('user_type_id', '=', data_unaffected_earnings.id)])
    #             raise ValidationError(
    #                 _('You cannot have more than one account with "Current Year Earnings" as type. (accounts: %s)',
    #                   [a.code for a in account_unaffected_earnings]))

    name = fields.Char(string="Account Name", required=True, index=True)
    currency_id = fields.Many2one('res.currency', string='Account Currency',
                                  help="Forces all moves for this account to have this account currency.")
    code = fields.Char(size=64, required=True, index=True)
    deprecated = fields.Boolean(index=True, default=False)
    used = fields.Boolean(compute='_compute_used', search='_search_used')
    user_type_id = fields.Many2one('account.account.type', string='Type', required=True,
                                   help="Account Type is used for information purpose, to generate country-specific "
                                        "legal reports, and set the rules to close a fiscal year and generate opening "
                                        "entries.")
    internal_type = fields.Selection(related='user_type_id.type', string="Internal Type", store=True, readonly=True)
    internal_group = fields.Selection(related='user_type_id.internal_group', string="Internal Group", store=True,
                                      readonly=True)
    help = fields.Char()
    # has_unreconciled_entries = fields.Boolean(compute='_compute_has_unreconciled_entries',
    #    help="The account has at least one unreconciled debit and credit since last time the invoices & payments
    #    matching was performed.")
    reconcile = fields.Boolean(string='Allow Reconciliation', default=False,
                               help="Check this box if this account allows invoices & payments matching of journal "
                                    "items.")
    tax_ids = fields.Many2many('account.tax', 'account_account_tax_default_rel',
                               'account_id', 'tax_id', string='Default Taxes',
                               check_company=True,
                               context={'append_type_to_tax_name': True})
    note = fields.Text('Internal Notes')
    # company_id = fields.Many2one('res.company', string='Company', required=True, readonly=True,
    #                              default=lambda self: self.env.company)
    tag_ids = fields.Many2many('account.account.tag', 'account_account_account_tag', string='Tags',
                               help="Optional tags you may want to assign for custom reporting")
    group_id = fields.Many2one('account.group', compute='_compute_account_group', store=True, readonly=True)
    root_id = fields.Many2one('account.root', compute='_compute_account_root', store=True)
    # allowed_journal_ids = fields.Many2many('account.journal', string="Allowed Journals",
    #                                        help="Define in which journals this account can be used. If empty, "
    #                                             "can be used in all journals.")

    opening_debit = fields.Monetary(string="Opening Debit", compute='_compute_opening_debit_credit',
                                    inverse='_set_opening_debit', help="Opening debit value for this account.")
    opening_credit = fields.Monetary(string="Opening Credit", compute='_compute_opening_debit_credit',
                                     inverse='_set_opening_credit', help="Opening credit value for this account.")
    opening_balance = fields.Monetary(string="Opening Balance", compute='_compute_opening_debit_credit',
                                      help="Opening balance value for this account.")

    is_off_balance = fields.Boolean(compute='_compute_is_off_balance', default=False, store=True, readonly=True)

    _sql_constraints = [
        ('code_uniq', 'unique (code)', 'The code of the account must be unique per company !')  # ,company_id
    ]

    @api.constrains('reconcile', 'internal_group', 'tax_ids')
    def _constrains_reconcile(self):
        for record in self:
            if record.internal_group == 'off_balance':
                if record.reconcile:
                    raise UserError(_('An Off-Balance account can not be reconcilable'))
                if record.tax_ids:
                    raise UserError(_('An Off-Balance account can not have taxes'))

    # @api.constrains('allowed_journal_ids')
    # def _constrains_allowed_journal_ids(self):
    #     self.env['account.move.line'].flush(['account_id', 'journal_id'])
    #     self.flush(['allowed_journal_ids'])
    #     self._cr.execute("""
    #         SELECT aml.id
    #         FROM account_move_line aml
    #         WHERE aml.account_id in %s
    #         AND EXISTS (SELECT 1 FROM account_account_account_journal_rel WHERE account_account_id = aml.account_id)
    #         AND NOT EXISTS (SELECT 1 FROM account_account_account_journal_rel WHERE account_account_id =
    #         aml.account_id AND account_journal_id = aml.journal_id)
    #     """, [tuple(self.ids)])
    #     ids = self._cr.fetchall()
    #     if ids:
    #         raise ValidationError(
    #             _('Some journal items already exist with this account but in other journals than the allowed ones.'))

    # @api.constrains('currency_id')
    # def _check_journal_consistency(self):
    #     ''' Ensure the currency set on the journal is the same as the currency set on the
    #     linked accounts.
    #     '''
    #     if not self:
    #         return
    #
    #     self.env['account.account'].flush(['currency_id'])
    #     self.env['account.journal'].flush([
    #         'currency_id',
    #         'default_account_id',
    #         'payment_debit_account_id',
    #         'payment_credit_account_id',
    #         'suspense_account_id',
    #     ])
    #     self._cr.execute('''
    #         SELECT account.id, journal.id
    #         FROM account_account account
    #         JOIN res_company company ON company.id = account.company_id
    #         JOIN account_journal journal ON
    #             journal.default_account_id = account.id
    #         WHERE account.id IN %s
    #         AND journal.type IN ('bank', 'cash')
    #         AND journal.currency_id IS NOT NULL
    #         AND journal.currency_id != company.currency_id
    #         AND account.currency_id != journal.currency_id
    #     ''', [tuple(self.ids)])
    #     res = self._cr.fetchone()
    #     if res:
    #         account = self.env['account.account'].browse(res[0])
    #         journal = self.env['account.journal'].browse(res[1])
    #         raise ValidationError(_(
    #             "The foreign currency set on the journal '%(journal)s' and the account '%(account)s' must be the
    #             same.",
    #             journal=journal.display_name,
    #             account=account.display_name
    #         ))

    # @api.constrains('company_id')
    # def _check_company_consistency(self):
    #     if not self:
    #         return
    #
    #     self.flush(['company_id'])
    #     self._cr.execute('''
    #         SELECT line.id
    #         FROM account_move_line line
    #         JOIN account_account account ON account.id = line.account_id
    #         WHERE line.account_id IN %s
    #         AND line.company_id != account.company_id
    #     ''', [tuple(self.ids)])
    #     if self._cr.fetchone():
    #         raise UserError(
    #             _("You can't change the company of your account since there are some journal items linked to it."))

    # @api.constrains('user_type_id')
    # def _check_user_type_id_sales_purchase_journal(self):
    #     if not self:
    #         return
    #
    #     self.flush(['user_type_id'])
    #     self._cr.execute('''
    #         SELECT account.id
    #         FROM account_account account
    #         JOIN account_account_type acc_type ON account.user_type_id = acc_type.id
    #         JOIN account_journal journal ON journal.default_account_id = account.id
    #         WHERE account.id IN %s
    #         AND acc_type.type IN ('receivable', 'payable')
    #         AND journal.type IN ('sale', 'purchase')
    #         LIMIT 1;
    #     ''', [tuple(self.ids)])
    #
    #     if self._cr.fetchone():
    #         raise ValidationError(
    #             _("The account is already in use in a 'sale' or 'purchase' journal. This means that the account's "
    #               "type couldn't be 'receivable' or 'payable'."))

    # @api.constrains('reconcile')
    # def _check_used_as_journal_default_debit_credit_account(self):
    #     accounts = self.filtered(lambda a: not a.reconcile)
    #     if not accounts:
    #         return
    #
    #     self.flush(['reconcile'])
    #     self._cr.execute('''
    #         SELECT journal.id
    #         FROM account_journal journal
    #         WHERE journal.payment_credit_account_id in %(credit_account)s
    #         OR journal.payment_debit_account_id in %(debit_account)s ;
    #     ''', {
    #         'credit_account': tuple(accounts.ids),
    #         'debit_account': tuple(accounts.ids)
    #     })
    #
    #     rows = self._cr.fetchall()
    #     if rows:
    #         journals = self.env['account.journal'].browse([r[0] for r in rows])
    #         raise ValidationError(_(
    #             "This account is configured in %(journal_names)s journal(s) (ids %(journal_ids)s) as payment debit
    #             or "
    #             "credit account. This means that this account's type should be reconcilable.",
    #             journal_names=journals.mapped('display_name'),
    #             journal_ids=journals.ids
    #         ))

    @api.depends('code')
    def _compute_account_root(self):
        # this computes the first 2 digits of the account.
        # This field should have been a char, but the aim is to use it in a side panel view with hierarchy,
        # and it's only supported by many2one fields so far.
        # So instead, we make it a many2one to a psql view with what we need as records.
        for record in self:
            record.root_id = (ord(record.code[0]) * 1000 + ord(record.code[1:2] or '\x00')) if record.code else False

    @api.depends('code')
    def _compute_account_group(self):
        pass
        if self.ids:
            self.env['account.group']._adapt_accounts_for_account_groups(self)
        else:
            self.group_id = False

    def _search_used(self, operator, value):
        if operator not in ['=', '!='] or not isinstance(value, bool):
            raise UserError(_('Operation not supported'))
        if operator != '=':
            value = not value
        self._cr.execute("""
            SELECT id FROM account_account account
            WHERE EXISTS (SELECT * FROM account_move_line aml WHERE aml.account_id = account.id LIMIT 1)
        """)
        return [('id', 'in' if value else 'not in', [r[0] for r in self._cr.fetchall()])]

    def _compute_used(self):
        ids = set(self._search_used('=', True)[0][2])
        for record in self:
            record.used = record.id in ids

    @api.model
    def _search_new_account_code(self, company, digits, prefix):
        for num in range(1, 10000):
            new_code = str(prefix.ljust(digits - 1, '0')) + str(num)
            rec = self.search([('code', '=', new_code), ], limit=1)  # ('company_id', '=', company.id)
            if not rec:
                return new_code
        raise UserError(_('Cannot generate an unused account code.'))

    # def _compute_opening_debit_credit(self):
    #     self.opening_debit = 0
    #     self.opening_credit = 0
    #     self.opening_balance = 0
    #     if not self.ids:
    #         return
    #     self.env.cr.execute("""
    #         SELECT line.account_id,
    #                SUM(line.balance) AS balance,
    #                SUM(line.debit) AS debit,
    #                SUM(line.credit) AS credit
    #           FROM account_move_line line
    #           JOIN res_company comp ON comp.id = line.company_id
    #          WHERE line.move_id = comp.account_opening_move_id
    #            AND line.account_id IN %s
    #          GROUP BY line.account_id
    #     """, [tuple(self.ids)])
    #     result = {r['account_id']: r for r in self.env.cr.dictfetchall()}
    #     for record in self:
    #         res = result.get(record.id) or {'debit': 0, 'credit': 0, 'balance': 0}
    #         record.opening_debit = res['debit']
    #         record.opening_credit = res['credit']
    #         record.opening_balance = res['balance']

    @api.depends('internal_group')
    def _compute_is_off_balance(self):
        for account in self:
            account.is_off_balance = account.internal_group == "off_balance"

    def _set_opening_debit(self):
        for record in self:
            record._set_opening_debit_credit(record.opening_debit, 'debit')

    def _set_opening_credit(self):
        for record in self:
            record._set_opening_debit_credit(record.opening_credit, 'credit')

    # def _set_opening_debit_credit(self, amount, field):
    #     """ Generic function called by both opening_debit and opening_credit's
    #     inverse function. 'Amount' parameter is the value to be set, and field
    #     either 'debit' or 'credit', depending on which one of these two fields
    #     got assigned.
    #     """
    #     self.company_id.create_op_move_if_non_existant()
    #     opening_move = self.company_id.account_opening_move_id
    #
    #     if opening_move.state == 'draft':
    #         # check whether we should create a new move line or modify an existing one
    #         account_op_lines = self.env['account.move.line'].search([('account_id', '=', self.id),
    #                                                                  ('move_id', '=', opening_move.id),
    #                                                                  (field, '!=', False),
    #                                                                  (field, '!=',
    #                                                                   0.0)])  # 0.0 condition important for import
    #
    #         if account_op_lines:
    #             op_aml_debit = sum(account_op_lines.mapped('debit'))
    #             op_aml_credit = sum(account_op_lines.mapped('credit'))
    #
    #             # There might be more than one line on this account if the opening entry was manually edited
    #             # If so, we need to merge all those lines into one before modifying its balance
    #             opening_move_line = account_op_lines[0]
    #             if len(account_op_lines) > 1:
    #                 merge_write_cmd = [(1, opening_move_line.id, {
    #                     'debit': op_aml_debit, 'credit': op_aml_credit, 'partner_id': None, 'name': _("Opening
    #                     balance")
    #                 })]
    #                 unlink_write_cmd = [(2, line.id) for line in account_op_lines[1:]]
    #                 opening_move.write({'line_ids': merge_write_cmd + unlink_write_cmd})
    #
    #             if amount:
    #                 # modify the line
    #                 opening_move_line.with_context(check_move_validity=False)[field] = amount
    #             else:
    #                 # delete the line (no need to keep a line with value = 0)
    #                 opening_move_line.with_context(check_move_validity=False).unlink()
    #
    #         elif amount:
    #             # create a new line, as none existed before
    #             self.env['account.move.line'].with_context(check_move_validity=False).create({
    #                 'name': _('Opening balance'),
    #                 field: amount,
    #                 'move_id': opening_move.id,
    #                 'account_id': self.id,
    #             })
    #
    #         # Then, we automatically balance the opening move, to make sure it stays valid
    #         if not 'import_file' in self.env.context:
    #             # When importing a file, avoid recomputing the opening move for each account and do it at the end,
    #             # for better performances
    #             self.company_id._auto_balance_opening_move()

    @api.model
    def default_get(self, default_fields):
        """If we're creating a new account through a many2one, there are chances that we typed the account code
        instead of its name. In that case, switch both fields values.
        """
        if 'name' not in default_fields and 'code' not in default_fields:
            return super().default_get(default_fields)
        default_name = self._context.get('default_name')
        default_code = self._context.get('default_code')
        if default_name and not default_code:
            try:
                default_code = int(default_name)
            except ValueError:
                pass
            if default_code:
                default_name = False
        contextual_self = self.with_context(default_name=default_name, default_code=default_code)
        return super(AccountAccount, contextual_self).default_get(default_fields)

    @api.model
    def _name_search(self, name, args=None, operator='ilike', limit=100, name_get_uid=None):
        args = args or []
        domain = []
        if name:
            domain = ['|', ('code', '=ilike', name.split(' ')[0] + '%'), ('name', operator, name)]
            if operator in expression.NEGATIVE_TERM_OPERATORS:
                domain = ['&', '!'] + domain[1:]
        return self._search(expression.AND([domain, args]), limit=limit, access_rights_uid=name_get_uid)

    # @api.onchange('user_type_id')
    # def _onchange_user_type_id(self):
    #     self.reconcile = self.internal_type in ('receivable', 'payable')
    #     if self.internal_type == 'liquidity':
    #         self.reconcile = False
    #     elif self.internal_group == 'off_balance':
    #         self.reconcile = False
    #         self.tax_ids = False
    #     elif self.internal_group == 'income' and not self.tax_ids:
    #         self.tax_ids = self.company_id.account_sale_tax_id
    #     elif self.internal_group == 'expense' and not self.tax_ids:
    #         self.tax_ids = self.company_id.account_purchase_tax_id

    def name_get(self):
        result = []
        for account in self:
            name = account.code + ' ' + account.name
            result.append((account.id, name))
        return result

    @api.returns('self', lambda value: value.id)
    def copy(self, default=None):
        default = dict(default or {})
        if default.get('code', False):
            return super(AccountAccount, self).copy(default)
        try:
            default['code'] = (str(int(self.code) + 10) or '').zfill(len(self.code))
            default.setdefault('name', _("%s (copy)") % (self.name or ''))
            while self.env['account.account'].search([('code', '=', default['code']), ],
                                                     limit=1):
                # ('company_id', '=',
                #  default.get('company_id', False)
                #  or self.company_id.id)
                #
                default['code'] = (str(int(default['code']) + 10) or '')
                default['name'] = _("%s (copy)") % (self.name or '')
        except ValueError:
            default['code'] = _("%s (copy)") % (self.code or '')
            default['name'] = self.name
        return super(AccountAccount, self).copy(default)

    @api.model
    def load(self, fields, data):
        """ Overridden for better performances when importing a list of account
        with opening debit/credit. In that case, the auto-balance is postpone
        until the whole file has been imported.
        """
        # _logger.info(f"fields,data")
        rslt = super(AccountAccount, self).load(fields, data)

        # if 'import_file' in self.env.context:
        #     companies = self.search([('id', 'in', rslt['ids'])]).mapped('company_id')
        #     for company in companies:
        #         company._auto_balance_opening_move()
        return rslt

    def _toggle_reconcile_to_true(self):
        '''Toggle the `reconcile´ boolean from False -> True

        Note that: lines with debit = credit = amount_currency = 0 are set to `reconciled´ = True
        '''
        if not self.ids:
            return None
        query = """
            UPDATE account_move_line SET
                reconciled = CASE WHEN debit = 0 AND credit = 0 AND amount_currency = 0
                    THEN true ELSE false END,
                amount_residual = (debit-credit),
                amount_residual_currency = amount_currency
            WHERE full_reconcile_id IS NULL and account_id IN %s
        """
        self.env.cr.execute(query, [tuple(self.ids)])

    def _toggle_reconcile_to_false(self):
        '''Toggle the `reconcile´ boolean from True -> False

        Note that it is disallowed if some lines are partially reconciled.
        '''
        if not self.ids:
            return None
        partial_lines_count = self.env['account.move.line'].search_count([
            ('account_id', 'in', self.ids),
            ('full_reconcile_id', '=', False),
            ('|'),
            ('matched_debit_ids', '!=', False),
            ('matched_credit_ids', '!=', False),
        ])
        if partial_lines_count > 0:
            raise UserError(_('You cannot switch an account to prevent the reconciliation '
                              'if some partial reconciliations are still pending.'))
        query = """
            UPDATE account_move_line
                SET amount_residual = 0, amount_residual_currency = 0
            WHERE full_reconcile_id IS NULL AND account_id IN %s
        """
        self.env.cr.execute(query, [tuple(self.ids)])

    def write(self, vals):
        # Do not allow changing the company_id when account_move_line already exist
        # if vals.get('company_id', False):
        #     move_lines = self.env['account.move.line'].search([('account_id', 'in', self.ids)], limit=1)
        #     for account in self:
        #         if (account.company_id.id != vals['company_id']) and move_lines:
        #             raise UserError(
        #                 _('You cannot change the owner company of an account that already contains journal items.'))
        if 'reconcile' in vals:
            if vals['reconcile']:
                self.filtered(lambda r: not r.reconcile)._toggle_reconcile_to_true()
            else:
                self.filtered(lambda r: r.reconcile)._toggle_reconcile_to_false()

        if vals.get('currency_id'):
            for account in self:
                if self.env['account.move.line'].search_count(
                        [('account_id', '=', account.id), ('currency_id', 'not in', (False, vals['currency_id']))]):
                    raise UserError(
                        _('You cannot set a currency on this account as it already has some journal entries having a '
                          'different foreign currency.'))

        return super(AccountAccount, self).write(vals)

    def unlink(self):
        # if self.env['account.move.line'].search([('account_id', 'in', self.ids)], limit=1):
        #     raise UserError(_('You cannot perform this action on an account that contains journal items.'))
        # Checking whether the account is set as a property to any Partner or not
        values = ['account.account,%s' % (account_id,) for account_id in self.ids]
        partner_prop_acc = self.env['ir.property'].sudo().search([('value_reference', 'in', values)], limit=1)
        if partner_prop_acc:
            account_name = partner_prop_acc.get_by_record().display_name
            raise UserError(
                _('You cannot remove/deactivate the account %s which is set on a customer or vendor.', account_name)
            )
        return super(AccountAccount, self).unlink()

    def action_read_account(self):
        self.ensure_one()
        return {
            'name': self.display_name,
            'type': 'ir.actions.act_window',
            'view_type': 'form',
            'view_mode': 'form',
            'res_model': 'account.account',
            'res_id': self.id,
        }

    def action_duplicate_accounts(self):
        for account in self.browse(self.env.context['active_ids']):
            account.copy()


class AccountGroup(models.Model):
    _name = "account.group"
    _description = 'Account Group'
    _parent_store = True
    _order = 'code_prefix_start'

    parent_id = fields.Many2one('account.group', index=True, ondelete='cascade', readonly=True)
    parent_path = fields.Char(index=True)
    name = fields.Char(required=True)
    # code = fields.Char(required=True)
    code_prefix_start = fields.Char()
    code_prefix_end = fields.Char()
    help = fields.Char()
    # company_id = fields.Many2one('res.company', required=True, readonly=True, default=lambda self: self.env.company)

    _sql_constraints = [
        (
            'check_length_prefix',
            'CHECK(char_length(COALESCE(code_prefix_start, \'\')) = char_length(COALESCE(code_prefix_end, \'\')))',
            'The length of the starting and the ending code prefix must be the same'
        ),
    ]

    @api.onchange('code_prefix_start')
    def _onchange_code_prefix_start(self):
        if not self.code_prefix_end or self.code_prefix_end < self.code_prefix_start:
            self.code_prefix_end = self.code_prefix_start

    @api.onchange('code_prefix_end')
    def _onchange_code_prefix_end(self):
        if not self.code_prefix_start or self.code_prefix_start > self.code_prefix_end:
            self.code_prefix_start = self.code_prefix_end

    def name_get(self):
        result = []
        for group in self:
            prefix = group.code_prefix_start and str(group.code_prefix_start)
            if prefix and group.code_prefix_end != group.code_prefix_start:
                prefix += '-' + str(group.code_prefix_end)
            name = (prefix and (prefix + ' ') or '') + group.name
            result.append((group.id, name))
        return result

    @api.model
    def _name_search(self, name, args=None, operator='ilike', limit=100, name_get_uid=None):
        args = args or []
        if operator == 'ilike' and not (name or '').strip():
            domain = []
        else:
            criteria_operator = ['|'] if operator not in expression.NEGATIVE_TERM_OPERATORS else ['&', '!']
            domain = criteria_operator + [('code_prefix_start', '=ilike', name + '%'), ('name', operator, name)]
        return self._search(expression.AND([domain, args]), limit=limit, access_rights_uid=name_get_uid)

    # @api.constrains('code_prefix_start', 'code_prefix_end')
    # def _constraint_prefix_overlap(self):
    #     self.env['account.group'].flush()
    #     query = """
    #         SELECT other.id FROM account_group this
    #         JOIN account_group other
    #           ON char_length(other.code_prefix_start) = char_length(this.code_prefix_start)
    #          AND other.id != this.id
    #          AND other.company_id = this.company_id
    #          AND (
    #             other.code_prefix_start <= this.code_prefix_start AND this.code_prefix_start <= other.code_prefix_end
    #             OR
    #             other.code_prefix_start >= this.code_prefix_start AND this.code_prefix_end >= other.code_prefix_start
    #         )
    #         WHERE this.id IN %(ids)s
    #     """
    #     self.env.cr.execute(query, {'ids': tuple(self.ids)})
    #     res = self.env.cr.fetchall()
    #     if res:
    #         raise ValidationError(_('Account Groups with the same granularity can\'t overlap'))

    @api.model_create_multi
    def create(self, vals_list):
        for vals in vals_list:
            if 'code_prefix_start' in vals and not vals.get('code_prefix_end'):
                vals['code_prefix_end'] = vals['code_prefix_start']
        res_ids = super(AccountGroup, self).create(vals_list)
        res_ids._adapt_accounts_for_account_groups()
        res_ids._adapt_parent_account_group()
        return res_ids

    def write(self, vals):
        res = super(AccountGroup, self).write(vals)
        if 'code_prefix_start' in vals or 'code_prefix_end' in vals:
            self._adapt_accounts_for_account_groups()
            self._adapt_parent_account_group()
        return res

    def unlink(self):
        for record in self:
            account_ids = self.env['account.account'].search([('group_id', '=', record.id)])
            account_ids.write({'group_id': record.parent_id.id})

            children_ids = self.env['account.group'].search([('parent_id', '=', record.id)])
            children_ids.write({'parent_id': record.parent_id.id})
        super(AccountGroup, self).unlink()

    def _adapt_accounts_for_account_groups(self, account_ids=None):
        """Ensure consistency between accounts and account groups.

        Find and set the most specific group matching the code of the account.
        The most specific is the one with the longest prefixes and with the starting
        prefix being smaller than the account code and the ending prefix being greater.
        """
        if not self and not account_ids:
            return
        self.env['account.group'].flush(self.env['account.group']._fields)
        self.env['account.account'].flush(self.env['account.account']._fields)
        query = """
            WITH relation AS (
       SELECT DISTINCT FIRST_VALUE(agroup.id) OVER (PARTITION BY account.id ORDER BY char_length(
       agroup.code_prefix_start) DESC, agroup.id) AS group_id,
                       account.id AS account_id
                  FROM account_group agroup
                  JOIN account_account account
                    ON agroup.code_prefix_start <= LEFT(account.code, char_length(agroup.code_prefix_start))
                   AND agroup.code_prefix_end >= LEFT(account.code, char_length(agroup.code_prefix_end))
                 WHERE (1 = 1){where_account}
            )
            UPDATE account_account account
               SET group_id = relation.group_id
              FROM relation
             WHERE relation.account_id = account.id;
        """.format(
            where_account=account_ids and 'AND account.id IN %(account_ids)s' or ''
            # """                   -- AND
            # agroup.company_id = account.company_id
            #                  --WHERE
            #                  account.company_id
            #                  IN %(company_ids)s
            #                  {where_account}
            # """
        )
        self.env.cr.execute(query, {
            # 'company_ids': tuple((self.company_id or account_ids.company_id).ids),
            'account_ids': account_ids and tuple(account_ids.ids)
        })
        self.env['account.account'].invalidate_cache(fnames=['group_id'])

    def _adapt_parent_account_group(self):
        """Ensure consistency of the hierarchy of account groups.

        Find and set the most specific parent for each group.
        The most specific is the one with the longest prefixes and with the starting
        prefix being smaller than the child prefixes and the ending prefix being greater.
        """
        if not self:
            return
        self.env['account.group'].flush(self.env['account.group']._fields)
        query = """
            WITH relation AS (
       SELECT DISTINCT FIRST_VALUE(parent.id) OVER (PARTITION BY child.id ORDER BY child.id, char_length(
       parent.code_prefix_start) DESC) AS parent_id,
                       child.id AS child_id
                  FROM account_group parent
                  JOIN account_group child
                    ON char_length(parent.code_prefix_start) < char_length(child.code_prefix_start)
                   AND parent.code_prefix_start <= LEFT(child.code_prefix_start, char_length(
                   parent.code_prefix_start))
                   AND parent.code_prefix_end >= LEFT(child.code_prefix_end, char_length(parent.code_prefix_end))
                   AND parent.id != child.id
            )
            UPDATE account_group child
               SET parent_id = relation.parent_id
              FROM relation
             WHERE child.id = relation.child_id;
        """
        #         """
        #                            AND parent.company_id = child.company_id
        #                  WHERE child.company_id IN %(company_ids)s
        # """
        self.env.cr.execute(query)  # , {'company_ids': tuple(self.company_id.ids)}
        self.env['account.group'].invalidate_cache(fnames=['parent_id'])
        # self.env['account.group'].search([('company_id', 'in', self.company_id.ids)])._parent_store_update()


class AccountRoot(models.Model):
    _name = 'account.root'
    _description = 'Account codes first 2 digits'
    _auto = False

    name = fields.Char()
    parent_id = fields.Many2one('account.root')

    # company_id = fields.Many2one('res.company')

    def init(self):
        tools.drop_view_if_exists(self.env.cr, self._table)
        self.env.cr.execute('''
            CREATE OR REPLACE VIEW %s AS (
            SELECT DISTINCT ASCII(code) * 1000 + ASCII(SUBSTRING(code,2,1)) AS id,
                   LEFT(code,2) AS name,
                   ASCII(code) AS parent_id
            FROM account_account WHERE code IS NOT NULL
            UNION ALL
            SELECT DISTINCT ASCII(code) AS id,
                   LEFT(code,1) AS name,
                   NULL::int AS parent_id
            FROM account_account WHERE code IS NOT NULL
            )''' % (self._table,)
                            )