# -*- coding: utf-8 -*- # Part of Odoo. See LICENSE file for full copyright and licensing details. import json from odoo import http, _ from odoo.http import request from odoo.addons.payment import utils as payment_utils from odoo.addons.website_sale.controllers.main import WebsiteSale from odoo.exceptions import UserError class WebsiteSaleDelivery(WebsiteSale): _express_checkout_shipping_route = '/shop/express/shipping_address_change' @http.route(['/shop/update_carrier'], type='json', auth='public', methods=['POST'], website=True) def update_eshop_carrier(self, **post): order = request.website.sale_get_order() if not post.get('no_reset_access_point_address'): order.access_point_address = {} carrier_id = int(post['carrier_id']) if order and carrier_id != order.carrier_id.id: if any(tx.sudo().state not in ('cancel', 'error', 'draft') for tx in order.transaction_ids): raise UserError(_('It seems that there is already a transaction for your order, you can not change the delivery method anymore')) order._check_carrier_quotation(force_carrier_id=carrier_id) return self._update_website_sale_delivery_return(order, **post) @http.route(['/shop/carrier_rate_shipment'], type='json', auth='public', methods=['POST'], website=True) def cart_carrier_rate_shipment(self, carrier_id, **kw): order = request.website.sale_get_order(force_create=True) if not int(carrier_id) in order._get_delivery_methods().ids: raise UserError(_('It seems that a delivery method is not compatible with your address. Please refresh the page and try again.')) Monetary = request.env['ir.qweb.field.monetary'] res = {'carrier_id': carrier_id} carrier = request.env['delivery.carrier'].sudo().browse(int(carrier_id)) rate = WebsiteSaleDelivery._get_rate(carrier, order) if rate.get('success'): res['status'] = True res['new_amount_delivery'] = Monetary.value_to_html(rate['price'], {'display_currency': order.currency_id}) res['is_free_delivery'] = not bool(rate['price']) res['error_message'] = rate['warning_message'] else: res['status'] = False res['new_amount_delivery'] = Monetary.value_to_html(0.0, {'display_currency': order.currency_id}) res['error_message'] = rate['error_message'] return res @http.route( _express_checkout_shipping_route, type='json', auth='public', methods=['POST'], website=True, sitemap=False ) def express_checkout_process_shipping_address(self, partial_shipping_address): """ Processes shipping address and returns available carriers. Depending on whether the partner is registered and logged in or not, creates a new partner or uses an existing partner that matches the partial shipping address received. :param dict shipping_address: a dictionary containing part of shipping information sent by the express payment provider. :return dict: all available carriers for `shipping_address` sorted by lowest price. """ order_sudo = request.website.sale_get_order() public_partner = request.website.partner_id self._include_country_and_state_in_address(partial_shipping_address) if order_sudo.partner_id == public_partner: # The partner_shipping_id and partner_invoice_id will be automatically computed when # changing the partner_id of the SO. This allow website_sale to avoid create duplicates. order_sudo.partner_id = self._create_or_edit_partner( partial_shipping_address, type='delivery', name=_('Anonymous express checkout partner for order %s', order_sudo.name), ) # Pricelist are recomputed every time the partner is changed. We don't want to recompute # the price with another pricelist at this state since the customer has already accepted # the amount and validated the payment. order_sudo.env.remove_to_compute(order_sudo._fields['pricelist_id'], order_sudo) elif order_sudo.partner_shipping_id.name.endswith(order_sudo.name): self._create_or_edit_partner( partial_shipping_address, edit=True, type='delivery', partner_id=order_sudo.partner_shipping_id.id, ) elif any( partial_shipping_address[k] != order_sudo.partner_shipping_id[k] for k in partial_shipping_address ): # Check if a child partner doesn't already exist with the same informations. The # phone isn't always checked because it isn't sent in shipping information with # Google Pay. child_partner_id = self._find_child_partner( order_sudo.partner_id.commercial_partner_id.id, partial_shipping_address ) order_sudo.partner_shipping_id = child_partner_id or self._create_or_edit_partner( partial_shipping_address, type='delivery', parent_id=order_sudo.partner_id.id, name=_('Anonymous express checkout partner for order %s', order_sudo.name), ) # Returns the list of develivery carrier available for the sale order. return sorted([{ 'id': carrier.id, 'name': carrier.name, 'description': carrier.website_description, 'minorAmount': payment_utils.to_minor_currency_units( WebsiteSaleDelivery._get_rate(carrier, order_sudo, is_express_checkout_flow=True)['price'], order_sudo.currency_id, ), } for carrier in order_sudo._get_delivery_methods()], key=lambda carrier: carrier['minorAmount']) @http.route('/shop/access_point/set', type='json', auth='public', methods=['POST'], website=True, sitemap=False) def set_access_point(self, access_point_encoded): order = request.website.sale_get_order() if hasattr(order.carrier_id, order.carrier_id.delivery_type + '_use_locations'): use_location = getattr(order.carrier_id, order.carrier_id.delivery_type + '_use_locations') access_point = use_location and (json.loads(access_point_encoded) if access_point_encoded else False) or False order.write({'access_point_address': access_point}) @http.route('/shop/access_point/get', type='json', auth='public', website=True, sitemap=False) def get_access_point(self): order = request.website.sale_get_order() if not order.carrier_id.delivery_type or not order.carrier_id.display_name: return {} order_location = order.access_point_address if not order_location: return {} address = order_location['address'] name = order_location['pick_up_point_name'] return {order.carrier_id.delivery_type + '_access_point': address, 'name': name, 'delivery_name': order.carrier_id.display_name} @http.route('/shop/access_point/close_locations', type='json', auth='public', website=True, sitemap=False) def get_close_locations(self): order = request.website.sale_get_order() try: error = {'error': _('No pick-up point available for that shipping address')} if not hasattr(order.carrier_id, '_' + order.carrier_id.delivery_type + '_get_close_locations'): return error close_locations = getattr(order.carrier_id, '_' + order.carrier_id.delivery_type + '_get_close_locations')(order.partner_shipping_id) partner_address = order.partner_shipping_id inline_partner_address = ' '.join((part or '') for part in [partner_address.street, partner_address.street2, partner_address.zip, partner_address.country_id.code]) if len(close_locations) < 0: return error for location in close_locations: location['address_stringified'] = json.dumps(location) return {'close_locations': close_locations, 'partner_address': inline_partner_address} except UserError as e: return {'error': str(e)} @staticmethod def _get_rate(carrier, order, is_express_checkout_flow=False): """ Compute the price of the order shipment and apply the taxes if relevant :param recordset carrier: the carrier for which the rate is to be recovered :param recordset order: the order for which the rate is to be recovered :param boolean is_express_checkout_flow: Whether the flow is express checkout or not :return dict: the rate, as returned in `rate_shipment()` """ # Some delivery carriers check if all the required fields are available before computing the # rate, even if those fields aren't required for computing the rate (although they are for # delivering the goods). If we only have partial information about the delivery address but # still want to compute the rate, this context key will ensure that we only check the # required fields for a partial delivery address (city, zip, country_code, state_code). rate = carrier.rate_shipment(order.with_context( express_checkout_partial_delivery_address=is_express_checkout_flow )) if rate.get('success'): tax_ids = carrier.product_id.taxes_id.filtered( lambda t: t.company_id == order.company_id ) if tax_ids: fpos = order.fiscal_position_id tax_ids = fpos.map_tax(tax_ids) taxes = tax_ids.compute_all( rate['price'], currency=order.currency_id, quantity=1.0, product=carrier.product_id, partner=order.partner_shipping_id, ) if not is_express_checkout_flow and request.website.show_line_subtotals_tax_selection == 'tax_excluded': rate['price'] = taxes['total_excluded'] else: rate['price'] = taxes['total_included'] return rate def _update_website_sale_delivery_return(self, order, **post): Monetary = request.env['ir.qweb.field.monetary'] carrier_id = int(post['carrier_id']) currency = order.currency_id if order: return { 'status': order.delivery_rating_success, 'error_message': order.delivery_message, 'carrier_id': carrier_id, 'is_free_delivery': not bool(order.amount_delivery), 'new_amount_delivery': Monetary.value_to_html(order.amount_delivery, {'display_currency': currency}), 'new_amount_untaxed': Monetary.value_to_html(order.amount_untaxed, {'display_currency': currency}), 'new_amount_tax': Monetary.value_to_html(order.amount_tax, {'display_currency': currency}), 'new_amount_total': Monetary.value_to_html(order.amount_total, {'display_currency': currency}), 'new_amount_total_raw': order.amount_total, } return {}