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

[ADD] Quota workflow

Browse Source
This commit is contained in:
Dario Lodeiros
2019-02-26 03:10:48 +01:00
parent d6bc9e72fe
commit 61cd954564
2 changed files with 35 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
hotel_channel_connector/models/hotel_reservation/common.py
View File

@@ -167,35 +167,34 @@ class HotelReservation(models.Model):
# origin_sale = fields.Char('Origin', compute=_get_origin_sale,
# store=True)
is_from_ota = fields.Boolean('Is From OTA',
readonly=True,
old_name='wis_from_channel')
readonly=True)
able_to_modify_channel = fields.Boolean(compute=_set_access_for_channel_fields,
string='Is user able to modify channel fields?',
old_name='able_to_modify_wubook')
string='Is user able to modify channel fields?')
to_read = fields.Boolean('To Read', default=False)
customer_notes = fields.Text(related='folio_id.customer_notes',
old_name='wcustomer_notes')
customer_notes = fields.Text(related='folio_id.customer_notes')
@api.model
def create(self, vals):
if vals.get('external_id') is not None:
from_channel = False
if 'channel_bind_ids' in vals and \
vals.get('channel_bind_ids')[0][2].get('external_id') is not None:
vals.update({'preconfirm': False})
from_channel = True
user = self.env['res.users'].browse(self.env.uid)
if user.has_group('hotel.group_hotel_call'):
vals.update({'to_read': True})
reservation_id = super(HotelReservation, self).create(vals)
import wdb; wdb.set_trace()
# restar quota si en viene de wubook y es mayor que cero
backend_id = self.env['channel.hotel.room.type'].search([
('odoo_id', '=', vals['room_type_id'])
]).backend_id
# WARNING: more than one backend_id is currently not expected
self.env['channel.hotel.room.type.availability'].refresh_availability(
vals['real_checkin'],
vals['real_checkout'],
backend_id.id,
room_id=vals['room_type_id'])
checkin=vals['real_checkin'],
checkout=vals['real_checkout'],
backend_id=backend_id.id,
room_type_id=vals['room_type_id'],
from_channel=from_channel,)
return reservation_id

45
hotel_channel_connector/models/hotel_room_type_availability/common.py
View File

@@ -84,7 +84,6 @@ class ChannelHotelRoomTypeAvailability(models.Model):
_description = 'Channel Availability'
odoo_id = fields.Many2one(comodel_name='hotel.room.type.availability',
string='Pricelist',
required=True,
ondelete='cascade')
channel_avail = fields.Integer("Availability", readonly=True,
@@ -98,7 +97,6 @@ class ChannelHotelRoomTypeAvailability(models.Model):
def _check_avail(self):
room_type_obj = self.env['hotel.room.type']
issue_obj = self.env['hotel.channel.connector.issue']
import wdb; wdb.set_trace()
for record in self:
cavail = len(room_type_obj.check_availability_room_type(
record.date,
@@ -120,7 +118,8 @@ class ChannelHotelRoomTypeAvailability(models.Model):
self._event('on_fix_channel_availability').notify(record)
@api.model
def refresh_availability(self, checkin, checkout, backend_id, room_id=False, room_type_id=False):
def refresh_availability(self, checkin, checkout, backend_id, room_id=False,
room_type_id=False, from_channel=True):
date_start = fields.Date.from_string(checkin)
date_end = fields.Date.from_string(checkout)
# Not count end day of the reservation
@@ -153,21 +152,21 @@ class ChannelHotelRoomTypeAvailability(models.Model):
room_type_avail_id = channel_room_type_avail_obj.search([
('room_type_id', '=', room_type_bind.odoo_id.id),
('date', '=', ndate_str)], limit=1)
# quota and max availability set by revenue ?
if room_type_avail_id:
if room_type_avail_id.quota >= 0:
to_eval.append(room_type_avail_id.quota)
if from_channel:
room_type_avail_id.update({
'quota': room_type_avail_id.quota - 1,
})
quota = room_type_avail_id.quota
if room_type_avail_id.max_avail >= 0:
to_eval.append(room_type_avail_id.max_avail)
if room_type_avail_id.quota < 0 and room_type_avail_id.max_avail < 0:
# add default availability for OTAs because
# on creation triggered by `no_ota` no rules are given
to_eval.append(room_type_bind.default_availability)
else:
# default availability for OTAs if not record given
# This should never happens because the channel.hotel.room.type.availability
# should be created and the quota update (if needed) __before__ refreshing_availability()
to_eval.append(room_type_bind.default_availability)
if room_type_bind.default_quota >= 0:
quota = room_type_bind.default_quota
if room_type_bind.default_max_avail >= 0:
to_eval.append(room_type_bind.default_max_avail)
to_eval.append(quota)
avail = max(min(to_eval), 0)
_logger.info({
@@ -186,14 +185,18 @@ class ChannelHotelRoomTypeAvailability(models.Model):
if room_type_avail_id.channel_avail != avail:
room_type_avail_id.write({'channel_avail': avail})
else:
# This should never happens because the channel.hotel.room.type.availability
# should be created and the quota update (if needed) __before__ refreshing_availability()
channel_room_type_avail_obj.create({
'odoo_id': room_type_bind.odoo_id.id,
'backend_id': backend_id,
quota = room_type_bind.default_quota
if from_channel and quota > 0:
quota -= 1
self.env['hotel.room.type.availability'].create({
'room_type_id': room_type_bind.odoo_id.id,
'date': ndate_str,
'channel_avail': avail,
'channel_pushed': False,
'channel_bind_ids': [(0, False, {
'channel_avail': avail,
'channel_pushed': False,
'backend_id': backend_id,
'quota': quota,
})]
})
@job(default_channel='root.channel')
@@ -285,8 +288,6 @@ class ChannelBindingHotelRoomTypeAvailabilityListener(Component):
@skip_if(lambda self, record, **kwargs: self.no_connector_export(record))
def on_fix_channel_availability(self, record, fields=None):
if any(record.channel_bind_ids):
import wdb;
wdb.set_trace()
for binding in record.channel_bind_ids:
record.refresh_availability(
record.checkin,