Files
pms/pms/controllers/pms_portal.py
2022-11-17 19:48:49 +01:00

649 lines
25 KiB
Python

import re
from odoo import _, fields, http, tools
from odoo.exceptions import AccessError, MissingError
from odoo.http import request
from odoo.addons.payment.controllers.portal import PaymentProcessing
from odoo.addons.portal.controllers.portal import CustomerPortal, pager as portal_pager
from odoo.addons.portal.models.portal_mixin import PortalMixin
class PortalFolio(CustomerPortal):
def _prepare_home_portal_values(self, counters):
partner = request.env.user.partner_id
values = super()._prepare_home_portal_values(counters)
Folio = request.env["pms.folio"]
if "folio_count" in counters:
values["folio_count"] = (
Folio.search_count(
[
("partner_id", "=", partner.id),
]
)
if Folio.check_access_rights("read", raise_exception=False)
else 0
)
return values
def _folio_get_page_view_values(self, folio, access_token, **kwargs):
values = {"folio": folio, "token": access_token}
payment_inputs = request.env["payment.acquirer"]._get_available_payment_input(
partner=folio.partner_id, company=folio.company_id
)
is_public_user = request.env.user._is_public()
if is_public_user:
payment_inputs.pop("pms", None)
token_count = (
request.env["payment.token"]
.sudo()
.search_count(
[
("acquirer_id.company_id", "=", folio.company_id.id),
("partner_id", "=", folio.partner_id.id),
]
)
)
values["existing_token"] = token_count > 0
values.update(payment_inputs)
values["partner_id"] = (
folio.partner_id if is_public_user else request.env.user.partner_id,
)
return self._get_page_view_values(
folio, access_token, values, "my_folios_history", False, **kwargs
)
@http.route(
"/folio/pay/<int:folio_id>/form_tx", type="json", auth="public", website=True
)
def folio_pay_form(
self, acquirer_id, folio_id, save_token=False, access_token=None, **kwargs
):
folio_sudo = request.env["pms.folio"].sudo().browse(folio_id)
if not folio_sudo:
return False
try:
acquirer_id = int(acquirer_id)
except Exception:
return False
if request.env.user._is_public():
save_token = False # we avoid to create a token for the public user
success_url = kwargs.get(
"success_url",
"%s?%s" % (folio_sudo.access_url, access_token if access_token else ""),
)
vals = {
"acquirer_id": acquirer_id,
"return_url": success_url,
}
if save_token:
vals["type"] = "form_save"
transaction = folio_sudo._create_payment_transaction(vals)
PaymentProcessing.add_payment_transaction(transaction)
if not transaction:
return False
tx_ids_list = set(request.session.get("__payment_tx_ids__", [])) | set(
transaction.ids
)
request.session["__payment_tx_ids__"] = list(tx_ids_list)
return transaction.render_folio_button(
folio_sudo,
submit_txt=_("Pay & Confirm"),
render_values={
"type": "form_save" if save_token else "form",
"alias_usage": _(
"If we store your payment information on our server, "
"subscription payments will be made automatically."
),
},
)
@http.route(
["/my/folios", "/my/folios/page/<int:page>"],
type="http",
auth="public",
website=True,
)
def portal_my_folios(
self, page=1, date_begin=None, date_end=None, sortby=None, filterby=None, **kw
):
partner = request.env.user.partner_id
values = self._prepare_portal_layout_values()
PmsFolio = request.env["pms.folio"]
values["folios"] = PmsFolio.search(
[
("partner_id", "child_of", partner.id),
]
)
domain = [
("partner_id", "child_of", partner.id),
]
searchbar_sortings = {
"date": {"label": _("Order Date"), "folio": "date_order desc"},
"name": {"label": _("Reference"), "folio": "name"},
"stage": {"label": _("Stage"), "folio": "state"},
}
if not sortby:
sortby = "date"
sort_order = searchbar_sortings[sortby]["folio"]
if date_begin and date_end:
domain += [
("create_date", ">", date_begin),
("create_date", "<=", date_end),
]
folio_count = PmsFolio.search_count(domain)
pager = portal_pager(
url="/my/folios",
url_args={"date_begin": date_begin, "date_end": date_end, "sortby": sortby},
total=folio_count,
page=page,
step=self._items_per_page,
)
folios = PmsFolio.search(
domain, order=sort_order, limit=self._items_per_page, offset=pager["offset"]
)
request.session["my_folios_history"] = folios.ids[:100]
values.update(
{
"date": date_begin,
"folios": folios.sudo(),
"page_name": "folios",
"pager": pager,
"default_url": "/my/folios",
"searchbar_sortings": searchbar_sortings,
"sortby": sortby,
}
)
return request.render("pms.portal_my_folio", values)
@http.route(["/my/folios/<int:folio_id>"], type="http", auth="public", website=True)
def portal_my_folio_detail(
self, folio_id, access_token=None, report_type=None, download=False, **kw
):
try:
folio_sudo = self._document_check_access(
"pms.folio",
folio_id,
access_token=access_token,
)
except (AccessError, MissingError):
return request.redirect("/my")
if report_type in ("html", "pdf", "text"):
return self._show_report(
model=folio_sudo,
report_type=report_type,
report_ref="pms.action_report_folio",
download=download,
)
values = self._folio_get_page_view_values(folio_sudo, access_token, **kw)
return request.render("pms.folio_portal_template", values)
class PortalReservation(CustomerPortal):
def _prepare_home_portal_values(self, counters):
partner = request.env.user.partner_id
values = super()._prepare_home_portal_values(counters)
Reservation = request.env["pms.reservation"]
if "reservation_count" in counters:
values["reservation_count"] = (
Reservation.search_count(
[
("partner_id", "=", partner.id),
]
)
if Reservation.check_access_rights("read", raise_exception=False)
else 0
)
return values
def _reservation_get_page_view_values(self, reservation, access_token, **kwargs):
values = {"reservation": reservation, "token": access_token}
return self._get_page_view_values(
reservation,
access_token,
values,
"my_reservations_history",
False,
**kwargs
)
@http.route(
["/my/reservations", "/my/reservations/page/<int:page>"],
type="http",
auth="public",
website=True,
)
def portal_my_reservations(self, page=1, date_begin=None, date_end=None):
partner = request.env.user.partner_id
values = self._prepare_portal_layout_values()
Reservation = request.env["pms.reservation"]
values["reservations"] = Reservation.search(
[
("partner_id", "child_of", partner.id),
]
)
domain = [
("partner_id", "child_of", partner.id),
]
if date_begin and date_end:
domain += [
("create_date", ">", date_begin),
("create_date", "<=", date_end),
]
reservation_count = Reservation.search_count(domain)
pager = portal_pager(
url="/my/reservations",
url_args={"date_begin": date_begin, "date_end": date_end},
total=reservation_count,
page=page,
step=self._items_per_page,
)
reservations = Reservation.search(
domain, limit=self._items_per_page, offset=pager["offset"]
)
folios_dict = {}
for reservation in reservations:
folio = reservation.folio_id
folios_dict[folio] = ""
request.session["my_reservations_history"] = reservations.ids[:100]
values.update(
{
"date": date_begin,
"reservations": reservations.sudo(),
"page_name": "reservations",
"pager": pager,
"default_url": "/my/reservations",
"folios_dict": folios_dict,
"partner": partner,
}
)
return request.render("pms.portal_my_reservation", values)
@http.route(
["/my/reservations/<int:reservation_id>"],
type="http",
auth="public",
website=True,
)
def portal_my_reservation_detail(self, reservation_id, access_token=None, **kw):
try:
reservation_sudo = self._document_check_access(
"pms.reservation",
reservation_id,
access_token=access_token,
)
except (AccessError, MissingError):
return request.redirect("/my")
values = self._reservation_get_page_view_values(
reservation_sudo, access_token, **kw
)
return request.render("pms.portal_my_reservation_detail", values)
class PortalPrecheckin(CustomerPortal):
def _precheckin_get_page_view_values(
self, checkin_partner_id, access_token, **kwargs
):
checkin_partner = request.env["pms.checkin.partner"].browse(checkin_partner_id)
values = {"checkin_partner_id": checkin_partner, "token": access_token}
return self._get_page_view_values(
checkin_partner,
access_token,
values,
"my_precheckins_history",
False,
**kwargs
)
@http.route(
["/my/folios/<int:folio_id>/precheckin"],
type="http",
auth="public",
website=True,
)
def portal_my_precheckin(
self,
folio_id,
access_token=None,
):
country_ids = request.env["res.country"].search([])
state_ids = request.env["res.country.state"].search([])
doc_type_ids = request.env["res.partner.id_category"].sudo().search([])
values = self._prepare_portal_layout_values()
try:
folio_sudo = self._document_check_access(
"pms.folio",
folio_id,
access_token=access_token,
)
except (AccessError, MissingError):
return request.redirect("/my")
available_checkins = folio_sudo.checkin_partner_ids.filtered(
lambda c: c.state in ["dummy", "draft"]
)
checkin_partner = (
available_checkins[0]
if available_checkins
else folio_sudo.checkin_partner_ids[0]
)
values.update(
{
"no_breadcrumbs": True,
"error": {},
"country_ids": country_ids,
"state_ids": state_ids,
"doc_type_ids": doc_type_ids,
"folio": folio_sudo,
"checkin_partner_id": checkin_partner,
"checkin_pos": 0,
}
)
if checkin_partner.state not in ["dummy", "draft"]:
return request.render("pms.portal_not_checkin", values)
return request.render("pms.portal_my_reservation_precheckin", values)
@http.route(
["/my/precheckin/<int:folio_id>/checkin/<int:checkin_partner_id>"],
type="http",
auth="public",
website=True,
csrf=False,
)
def portal_precheckin_submit(self, folio_id, checkin_partner_id, **kw):
error, error_message = {}, {}
if kw.get("checkin_pos"):
checkin_pos = int(kw.get("checkin_pos"))
else:
checkin_pos = -2
folio_id = request.env["pms.folio"].sudo().browse(folio_id)
country_ids = request.env["res.country"].search([])
state_ids = request.env["res.country.state"].search([])
doc_type_ids = request.env["res.partner.id_category"].sudo().search([])
values = kw
if not kw.get("first") and kw.get("checkin_pos") and not kw.get("back"):
error, error_message = self.form_validate(kw, None)
if not kw.get("first") and not kw.get("back") and not error:
kw.update({"checkin_partner_id": checkin_partner_id})
if kw.get("residence_state_id") == "placeholder":
kw["residence_state_id"] = False
if kw.get("residence_country_id") == "placeholder":
kw["residence_country_id"] = False
request.env["pms.checkin.partner"]._save_data_from_portal(kw)
if error:
checkin_pos = checkin_pos - 1
values.update({"checkin_pos": checkin_pos})
if checkin_pos == len(folio_id.checkin_partner_ids) or checkin_pos == -2:
values = {
"folio": folio_id,
"no_breadcrumbs": True,
}
return request.render("pms.portal_my_precheckin_end", values)
values.update(
{
"folio": folio_id,
"error": error,
"error_message": error_message,
"country_ids": country_ids,
"state_ids": state_ids,
"doc_type_ids": doc_type_ids,
"checkin_pos": checkin_pos,
}
)
if checkin_pos >= 0:
available_checkins = folio_id.checkin_partner_ids.filtered(
lambda c: c.state in ["dummy", "draft"]
)
if available_checkins:
checkin_partner = available_checkins[0]
else:
return request.render("pms.portal_not_checkin", values)
access_token = checkin_partner.access_token
if not checkin_partner.access_token:
access_token = PortalMixin._portal_ensure_token(checkin_partner)
values.update(
self._precheckin_get_page_view_values(checkin_partner.id, access_token)
)
values.update({"no_breadcrumbs": True})
if checkin_partner.state not in ["dummy", "draft"]:
return request.render("pms.portal_not_checkin", values)
return request.render("pms.portal_my_precheckin_detail", values)
@http.route(
["/my/folios/<int:folio_id>/invitations"],
type="http",
auth="public",
website=True,
csrf=False,
)
def portal_precheckin_invitation(self, folio_id, access_token=None, **kw):
try:
folio_sudo = self._document_check_access(
"pms.folio",
folio_id,
access_token=access_token,
)
except (AccessError, MissingError):
return request.redirect("/my")
web_url = (
request.env["ir.config_parameter"]
.sudo()
.search([("key", "=", "web.base.url")])
)
values = self._folio_get_page_view_values(folio_sudo, access_token, **kw)
values.update({"no_breadcrumbs": True, "error": {}, "web_url": web_url.value})
return request.render("pms.portal_my_folio_invitations", values)
def form_validate(self, data, counter):
error, error_message = {}, {}
if data.get("checkin_pos") != "-1":
error, error_message = self.form_document_validate(data, counter)
mobile = "mobile"
if data.get("mobile"):
if not re.match(
r"^(\d{3}[\-\s]?\d{2}[\-\s]?\d{2}[\-\s]?\d{2}[\-\s]?|"
r"\d{3}[\-\s]?\d{3}[\-\s]?\d{3})$",
data[mobile],
):
error[mobile] = "error"
error_message[mobile] = "Invalid phone"
birthdate_date = "birthdate_date"
if data.get("birthdate_date") and data.get("birthdate_date") > str(
fields.Datetime.today()
):
error[birthdate_date] = "error"
error_message[birthdate_date] = "Birthdate must be less than today"
email = "email"
if data.get("email") and not tools.single_email_re.match(data.get("email")):
error[email] = "error"
error_message[email] = "Email format is wrong"
firstname = "firstname"
if (
not data.get("firstname")
and not data.get("lastname")
and not data.get("lastname2")
):
error[firstname] = "error"
error_message[firstname] = "Firstname or any lastname are not included"
if not data.get("gender"):
error["gender"] = "error"
error_message["gender"] = "Gender is mandatory"
if not data.get("document_number"):
error["document_number"] = "error"
error_message["document_number"] = "Document number is mandatory"
if not data.get("document_type"):
error["document_type"] = "error"
error_message["document_type"] = "Document type is mandatory"
if not data.get("document_expedition_date"):
error["document_expedition_date"] = "error"
error_message[
"document_expedition_date"
] = "Document expedition date is mandatory"
if not data.get("birthdate_date"):
error["birthdate_date"] = "error"
error_message["birthdate_date"] = "Birth date is mandatory"
if not data.get("nationality_id"):
error["nationality_id"] = "error"
error_message["nationality_id"] = "Nationality is mandatory"
if (
not data.get("residence_street")
or not data.get("residence_city")
or not data.get("residence_zip")
or data.get("residence_country_id") == "placeholder"
or data.get("residence_state_id") == "placeholder"
):
error["address"] = "error"
error_message["address"] = "Address data is mandatory"
return error, error_message
def form_document_validate(self, data, counter):
error = dict()
error_message = {}
data.keys()
document_number = "document_number"
document_type = "document_type"
document_expedition_date = "document_expedition_date"
if data.get("document_expedition_date") and not data.get("document_number"):
error[document_expedition_date] = "error"
error_message[
document_expedition_date
] = "Document Number not entered and Document Type is not selected"
if data.get("document_number"):
if not data[document_type]:
error[document_type] = "error"
error_message[document_type] = "Document Type is not selected"
if data[document_type] == "D":
if (
len(data.get("document_number")) == 9
or len(data.get("document_number")) == 10
):
if not re.match(
r"^\d{8}[ -]?[a-zA-Z]$", data.get("document_number")
):
error[document_number] = "error"
error_message[document_number] = "The DNI format is wrong"
letters = {
0: "T",
1: "R",
2: "W",
3: "A",
4: "G",
5: "M",
6: "Y",
7: "F",
8: "P",
9: "D",
10: "X",
11: "B",
12: "N",
13: "J",
14: "Z",
15: "S",
16: "Q",
17: "V",
18: "H",
19: "L",
20: "C",
21: "K",
22: "E",
}
dni_number = data.get("document_number")[0:8]
dni_letter = data.get("document_number")[
len(data.get("document_number"))
- 1 : len(data.get("document_number"))
]
if letters.get(int(dni_number) % 23) != dni_letter.upper():
error[document_number] = "error"
error_message[document_number] = "DNI format is invalid"
else:
error[document_number] = "error"
error_message[document_number] = "DNI is invalid"
if data[document_type] == "C" and not re.match(
r"^\d{8}[ -]?[a-zA-Z]$", data.get("document_number")
):
error[document_number] = "error"
error_message[document_number] = "The Driving License format is wrong"
if data[document_type] == "N" and not re.match(
r"^[X|Y]{1}[ -]?\d{7,8}[ -]?[a-zA-Z]$", data.get("document_number")
):
error[document_number] = "error"
error_message[
document_number
] = "The Spanish Residence Permit format is wrong"
if data[document_type] == "X" and not re.match(
r"^[X|Y]{1}[ -]?\d{7,8}[ -]?[a-zA-Z]$", data.get("document_number")
):
error[document_number] = "error"
error_message[
document_number
] = "The European Residence Permit format is wrong"
elif data.get("document_type"):
error[document_number] = "error"
error_message[document_number] = "Document Number not entered"
return error, error_message
@http.route(
["/my/precheckin/send_invitation"],
auth="public",
type="json",
website=True,
csrf=False,
)
def portal_precheckin_folio_send_invitation(self, **kw):
if kw.get("folio_id"):
folio = request.env["pms.folio"].browse(int(kw.get("folio_id")))
kw.update({"folio": folio})
checkin_partner = (
request.env["pms.checkin.partner"]
.sudo()
.browse(int(kw["checkin_partner_id"]))
)
firstname = kw["firstname"]
email = kw["email"]
if firstname and email:
checkin_partner.write({"firstname": firstname, "email": email})
checkin_partner.send_portal_invitation_email(firstname, email)
class PortalAccount(CustomerPortal):
@http.route(
["/my/invoices/proforma/<int:invoice_id>"],
type="http",
auth="public",
website=True,
)
def portal_proforma_my_invoice_detail(
self, invoice_id, access_token=None, report_type=None, download=False, **kw
):
try:
invoice_sudo = self._document_check_access(
"account.move", invoice_id, access_token
)
except (AccessError, MissingError):
return request.redirect("/my")
if report_type in ("html", "pdf", "text"):
return self._show_report(
model=invoice_sudo,
report_type=report_type,
report_ref="pms.action_report_pms_pro_forma_invoice",
download=download,
)
invoice_sudo = invoice_sudo.with_context(proforma=True)
values = self._invoice_get_page_view_values(invoice_sudo, access_token, **kw)
acquirers = values.get("acquirers")
if acquirers:
country_id = (
values.get("partner_id") and values.get("partner_id")[0].country_id.id
)
values["acq_extra_fees"] = acquirers.get_acquirer_extra_fees(
invoice_sudo.amount_residual, invoice_sudo.currency_id, country_id
)
return request.render("pms.pms_proforma_invoice_template", values)