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
|
# -*- 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 in payments.grouped('employee_id').items():
payments_by_employee[employee.id] = {
'id': employee.id,
'name': employee.name,
'amount': sum(payments.mapped('amount')),
}
return sorted(payments_by_employee.values(), key=lambda p: 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
|
