audrius/pms
1
0
Fork 1
mirror of https://github.com/OCA/pms.git synced 2025-01-29 00:17:45 +02:00
Code Issues Packages Projects Releases Wiki Activity

[WIP] improve modifications

Browse Source
This commit is contained in:
Pablo
2019-06-05 14:39:53 +02:00
parent cb0b72c68f
commit 6c9526c2b4
1 changed files with 19 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
hotel_channel_connector_wubook/models/hotel_reservation/importer.py
View File

@@ -304,9 +304,9 @@ class HotelReservationImporter(Component):
if reservations: if reservations:
modified_codes = ' '.join(str(e) for e in book['modified_reservations']) modified_codes = ' '.join(str(e) for e in book['modified_reservations'])
modified_reservations = self.env['channel.hotel.reservation'].search([ modified_reservations = self.env['channel.hotel.reservation'].search([
('modified_reservations', 'in', modified_codes), ('modified_reservations', 'ilike', modified_codes),
]) ])
used_rooms = False used_rooms = []
if modified_reservations: if modified_reservations:
used_rooms = modified_reservations.mapped('room_id') used_rooms = modified_reservations.mapped('room_id')
reservation = reservations.filtered( reservation = reservations.filtered(
@@ -358,7 +358,6 @@ class HotelReservationImporter(Component):
rcode = str(book['reservation_code']) rcode = str(book['reservation_code'])
crcode = str(book['channel_reservation_code']) \ crcode = str(book['channel_reservation_code']) \
if book['channel_reservation_code'] else 'undefined' if book['channel_reservation_code'] else 'undefined'
rcode_modified = str(book['reservation_code'])
# Can't process failed reservations # Can't process failed reservations
# (for example set a invalid new reservation and receive in # (for example set a invalid new reservation and receive in
@@ -389,7 +388,7 @@ class HotelReservationImporter(Component):
if reserv_bind: if reserv_bind:
folio_id = reserv_bind.folio_id folio_id = reserv_bind.folio_id
if rcode_modified: if len(book['modified_reservations']) > 0:
is_cancellation = book['status'] in WUBOOK_STATUS_BAD is_cancellation = book['status'] in WUBOOK_STATUS_BAD
if book['was_modified'] and is_cancellation: if book['was_modified'] and is_cancellation:
continue continue
@@ -402,27 +401,29 @@ class HotelReservationImporter(Component):
if reservations: if reservations:
new_books, old_reservations = self.wubook_modification(reservations, book) new_books, old_reservations = self.wubook_modification(reservations, book)
if old_reservations: if old_reservations:
old_reservations.with_context({ old_reservations.odoo_id.with_context({
'connector_no_export': True, 'connector_no_export': True,
'ota_limits': False, 'ota_limits': False,
'no_penalty': True}).action_cancel() 'no_penalty': True}).action_cancel()
else: if len(new_books) == 0:
processed_rids.append(rcode) processed_rids.append(rcode)
continue continue
# Need update reservations? # Need update reservations?
reservs_processed = False is_cancellation = book['status'] in WUBOOK_STATUS_BAD
reservs_binds = channel_reserv_obj.search([ if not book['was_modified'] and is_cancellation:
('backend_id', '=', self.backend_record.id), reservs_processed = False
('external_id', '=', rcode), reservs_binds = channel_reserv_obj.search([
]) ('backend_id', '=', self.backend_record.id),
for reserv_bind in reservs_binds: ('external_id', '=', rcode),
self._update_reservation_binding(reserv_bind, book) ])
reservs_processed = True for reserv_bind in reservs_binds:
# Do Nothing if already processed 'external_id' self._update_reservation_binding(reserv_bind, book)
if reservs_processed: reservs_processed = True
processed_rids.append(rcode) # Do Nothing if already processed 'external_id'
continue if reservs_processed:
processed_rids.append(rcode)
continue
# Create new Customer # Create new Customer
partner_id = res_partner_obj.create(self._generate_partner_vals(book)) partner_id = res_partner_obj.create(self._generate_partner_vals(book))