# -*- coding: utf-8 -*- # Part of Odoo. See LICENSE file for full copyright and licensing details. from odoo import fields, models, api, _ from odoo.tools import plaintext2html class PosSession(models.Model): _inherit = 'pos.session' employee_id = fields.Many2one( "hr.employee", string="Cashier", help="The employee who currently uses the cash register", tracking=True, ) @api.model def _load_pos_data_models(self, config_id): data = super()._load_pos_data_models(config_id) config_id = self.env['pos.config'].browse(config_id) if config_id.module_pos_hr: data += ['hr.employee'] return data def set_opening_control(self, cashbox_value: int, notes: str): super().set_opening_control(cashbox_value, notes) if not self.employee_id: return author_id = self.employee_id._get_related_partners() or self.user_id self.message_post(body=plaintext2html(_('Opened register')), author_id=author_id.id) def post_close_register_message(self): if not self.employee_id: return super().post_close_register_message() author_id = self.employee_id._get_related_partners() or self.user_id self.message_post(body=plaintext2html(_('Closed Register')), author_id=author_id.id) def _aggregate_payments_amounts_by_employee(self, payments): payments_by_employee = [] for employee, payments_group in payments.grouped('employee_id').items(): payments_by_employee.append({ 'id': employee.id if employee else 'others', 'name': employee.name if employee else _('Others'), 'amount': sum(payments_group.mapped('amount')), }) # Sort such that "Others" is always the last item return sorted( payments_by_employee, key=lambda p: (p['id'] == 'others', p['name']) ) def _aggregate_moves_by_employee(self): moves_per_employee = {} for employee, moves in self.sudo().statement_line_ids.grouped('employee_id').items(): moves_per_employee[employee.id] = { 'id': employee.id, 'name': employee.name, 'amount': sum(moves.mapped('amount')), } return sorted(moves_per_employee.values(), key=lambda p: -p['amount']) def get_closing_control_data(self): data = super().get_closing_control_data() orders = self._get_closed_orders() payments = orders.payment_ids.filtered(lambda p: p.payment_method_id.type != "pay_later") cash_payment_method_ids = self.payment_method_ids.filtered(lambda pm: pm.type == 'cash') default_cash_payment_method_id = cash_payment_method_ids[0] if cash_payment_method_ids else None default_cash_payments = payments.filtered(lambda p: p.payment_method_id == default_cash_payment_method_id) if default_cash_payment_method_id else self.env['pos.payment'] non_cash_payment_method_ids = self.payment_method_ids - default_cash_payment_method_id if default_cash_payment_method_id else self.payment_method_ids non_cash_payments_grouped_by_method_id = {pm.id: orders.payment_ids.filtered(lambda p: p.payment_method_id == pm) for pm in non_cash_payment_method_ids} data['default_cash_details']['amount_per_employee'] = self._aggregate_payments_amounts_by_employee(default_cash_payments) for payment_method in data['non_cash_payment_methods']: payment_method['amount_per_employee'] = self._aggregate_payments_amounts_by_employee(non_cash_payments_grouped_by_method_id[payment_method['id']]) data['default_cash_details']['moves_per_employee'] = self._aggregate_moves_by_employee() return data def _prepare_account_bank_statement_line_vals(self, session, sign, amount, reason, extras): vals = super()._prepare_account_bank_statement_line_vals(session, sign, amount, reason, extras) if extras.get('employee_id'): vals['employee_id'] = extras['employee_id'] return vals