822 lines
39 KiB
Python
822 lines
39 KiB
Python
# -*- coding: utf-8 -*-
|
|
##############################################################################
|
|
#
|
|
# OpenERP, Open Source Management Solution
|
|
# Copyright (C) 2004-2009 Tiny SPRL (<http://tiny.be>).
|
|
#
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Affero General Public License as
|
|
# published by the Free Software Foundation, either version 3 of the
|
|
# License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Affero General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Affero General Public License
|
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
#
|
|
##############################################################################
|
|
|
|
import pytz
|
|
from datetime import date, datetime, timedelta
|
|
from dateutil import rrule
|
|
from dateutil.relativedelta import relativedelta
|
|
import itertools
|
|
import math
|
|
from operator import itemgetter
|
|
|
|
from faces import *
|
|
from openerp import tools
|
|
from openerp.osv import fields, osv
|
|
from openerp.tools.float_utils import float_compare
|
|
from openerp.tools.translate import _
|
|
|
|
|
|
class resource_calendar(osv.osv):
|
|
_name = "resource.calendar"
|
|
_description = "Resource Calendar"
|
|
_columns = {
|
|
'name' : fields.char("Name", size=64, required=True),
|
|
'company_id' : fields.many2one('res.company', 'Company', required=False),
|
|
'attendance_ids' : fields.one2many('resource.calendar.attendance', 'calendar_id', 'Working Time'),
|
|
'manager' : fields.many2one('res.users', 'Workgroup Manager'),
|
|
'leave_ids': fields.one2many(
|
|
'resource.calendar.leaves', 'calendar_id', 'Leaves',
|
|
help=''
|
|
),
|
|
}
|
|
_defaults = {
|
|
'company_id': lambda self, cr, uid, context: self.pool.get('res.company')._company_default_get(cr, uid, 'resource.calendar', context=context)
|
|
}
|
|
|
|
# --------------------------------------------------
|
|
# Utility methods
|
|
# --------------------------------------------------
|
|
|
|
def interval_clean(self, intervals):
|
|
""" Utility method that removes overlapping inside datetime intervals.
|
|
|
|
:param list intervals: list of datetime intervals. Each interval is a
|
|
tuple(datetime_from, datetime_to)
|
|
:return list final_list: list of intervals without overlap
|
|
"""
|
|
intervals = sorted(intervals) # TODO: check sorted method
|
|
final_list = []
|
|
working_interval = None
|
|
while intervals:
|
|
current_interval = intervals.pop(0)
|
|
if not working_interval: # init
|
|
working_interval = [current_interval[0], current_interval[1]]
|
|
elif working_interval[1] < current_interval[0]: # interval is disjoint
|
|
final_list.append(tuple(working_interval))
|
|
working_interval = [current_interval[0], current_interval[1]]
|
|
elif working_interval[1] < current_interval[1]: # union of greater intervals
|
|
working_interval[1] = current_interval[1]
|
|
if working_interval: # handle void lists
|
|
final_list.append(tuple(working_interval))
|
|
return final_list
|
|
|
|
def interval_remove_leaves(self, interval, leave_intervals):
|
|
""" Utility method that remove leave intervals from a base interval:
|
|
|
|
- clean the leave intrevals, to have an ordered list of not-overlapping
|
|
intervals
|
|
- initiate the current interval to be the base interval
|
|
- for each leave interval:
|
|
|
|
- finishing before the current interval: skip, go to next
|
|
- beginning after the current interval: skip and get out of the loop
|
|
because we are outside range (leaves are ordered)
|
|
- beginning within the current interval: close the current interval
|
|
and begin a new current interval that begins at the end of the leave
|
|
interval
|
|
- ending within the current interval: update the current interval begin
|
|
to match the leave interval ending
|
|
|
|
:param tuple interval: a tuple (beginning datetime, ending datetime) that
|
|
is the base interval from which the leave intervals
|
|
will be removed
|
|
:param list interval: a list of tuples (beginning datetime, ending datetime)
|
|
that are intervals to remove from the base interval
|
|
:return list final_list: a list of tuples (begin datetime, end datetime)
|
|
that are the remaining valid intervals
|
|
"""
|
|
if not interval:
|
|
return interval
|
|
if leave_intervals is None:
|
|
leave_intervals = []
|
|
final_list = []
|
|
leave_intervals = self.interval_clean(leave_intervals)
|
|
current_interval = [interval[0], interval[1]]
|
|
# print '\tcurrent_intreval', current_interval
|
|
for leave in leave_intervals:
|
|
# print '\thandling leave', leave
|
|
if leave[1] <= current_interval[0]:
|
|
# print '\t\tbefore, skipping'
|
|
continue
|
|
if leave[0] >= current_interval[1]:
|
|
# print '\t\tafter, abort'
|
|
break
|
|
if current_interval[0] < leave[0] < current_interval[1]:
|
|
# print '\t\tbeginning inside'
|
|
current_interval[1] = leave[0]
|
|
final_list.append((current_interval[0], current_interval[1]))
|
|
current_interval = [leave[1], interval[1]]
|
|
if current_interval[0] <= leave[1] <= current_interval[1]:
|
|
# print '\t\tending inside'
|
|
current_interval[0] = leave[1]
|
|
if current_interval and current_interval[0] < interval[1]: # remove intervals moved outside base interval due to leaves
|
|
final_list.append((current_interval[0], current_interval[1]))
|
|
return final_list
|
|
|
|
# --------------------------------------------------
|
|
# Date and hours computation
|
|
# --------------------------------------------------
|
|
|
|
def get_next_day(self, cr, uid, id, day_date, context=None):
|
|
if id is None:
|
|
return day_date + relativedelta(days=1)
|
|
calendar = self.browse(cr, uid, id, context=None)
|
|
weekdays = set()
|
|
for attendance in calendar.attendance_ids:
|
|
weekdays.add(int(attendance.dayofweek))
|
|
weekdays = list(weekdays)
|
|
|
|
if day_date.weekday() in weekdays:
|
|
base_index = weekdays.index(day_date.weekday())
|
|
else:
|
|
base_index = -1
|
|
for weekday in weekdays:
|
|
if weekday > day_date.weekday():
|
|
break
|
|
base_index += 1
|
|
|
|
new_index = (base_index + 1) % len(weekdays)
|
|
days = (weekdays[new_index] - day_date.weekday())
|
|
|
|
if days < 0:
|
|
days = 7 + days
|
|
|
|
return day_date + relativedelta(days=days)
|
|
|
|
def get_previous_day(self, cr, uid, id, day_date, context=None):
|
|
if id is None:
|
|
return day_date + relativedelta(days=-1)
|
|
calendar = self.browse(cr, uid, id, context=None)
|
|
weekdays = set()
|
|
for attendance in calendar.attendance_ids:
|
|
weekdays.add(int(attendance.dayofweek))
|
|
weekdays = list(weekdays)
|
|
weekdays.reverse()
|
|
|
|
if day_date.weekday() in weekdays:
|
|
base_index = weekdays.index(day_date.weekday())
|
|
else:
|
|
base_index = -1
|
|
for weekday in weekdays:
|
|
if weekday < day_date.weekday():
|
|
break
|
|
base_index += 1
|
|
|
|
new_index = (base_index + 1) % len(weekdays)
|
|
days = (weekdays[new_index] - day_date.weekday())
|
|
if days > 0:
|
|
days = days - 7
|
|
|
|
return day_date + relativedelta(days=days)
|
|
|
|
def _get_leave_intervals(self, cr, uid, id, resource_id=None, start_datetime=None, end_datetime=None, context=None):
|
|
"""Get the leaves of the calendar. Leaves can be filtered on the resource,
|
|
the start datetime or the end datetime.
|
|
|
|
:param int resource_id: if set, global + specific leaves will be taken
|
|
into account
|
|
TODO: COMPLETE ME
|
|
"""
|
|
resource_calendar = self.browse(cr, uid, id, context=context)
|
|
leaves = []
|
|
for leave in resource_calendar.leave_ids:
|
|
if resource_id and leave.resource_id and not resource_id == leave.resource_id.id:
|
|
continue
|
|
date_from = datetime.strptime(leave.date_from, tools.DEFAULT_SERVER_DATETIME_FORMAT)
|
|
if start_datetime and date_from < start_datetime:
|
|
continue
|
|
if end_datetime and date_end > end_datetime:
|
|
continue
|
|
date_to = datetime.strptime(leave.date_to, tools.DEFAULT_SERVER_DATETIME_FORMAT)
|
|
leaves.append((date_from, date_to))
|
|
return leaves
|
|
|
|
def get_working_intervals_of_day(self, cr, uid, id, day_date=None, leaves=None, compute_leaves=False, resource_id=None, context=None):
|
|
"""Get the working intervals of the day based on calendar. This method
|
|
handle leaves that come directly from the leaves parameter or can be computed.
|
|
|
|
:param int id: resource.calendar id; take the first one if is a list
|
|
:param date day_date: date object that is the day for which this method
|
|
computes the working intervals; is None, set to today
|
|
:param list leaves: a list of tuples(start_datetime, end_datetime) that
|
|
represent leaves.
|
|
:param boolean compute_leaves: if set and if leaves is None, compute the
|
|
leaves based on calendar and resource.
|
|
If leaves is None and compute_leaves false
|
|
no leaves are taken into account.
|
|
:param int resource_id: the id of the resource to take into account when
|
|
computing the leaves. If not set, only general
|
|
leaves will be computed.
|
|
|
|
:returns list intervals: a list of tuples (start_datetime, end_datetime)
|
|
that are intervals of work
|
|
"""
|
|
if id is None:
|
|
return []
|
|
if isinstance(id, (list, tuple)):
|
|
id = id[0]
|
|
if day_date is None:
|
|
day_date = date.today()
|
|
resource_calendar = self.browse(cr, uid, id, context=context)
|
|
intervals = []
|
|
|
|
# find working intervals
|
|
date_dict = {
|
|
'Y': day_date.year,
|
|
'm': day_date.month,
|
|
'd': day_date.day,
|
|
}
|
|
working_intervals = []
|
|
for calendar_working_day in resource_calendar.attendance_ids:
|
|
if int(calendar_working_day.dayofweek) == day_date.weekday():
|
|
date_dict.update({
|
|
'HF': calendar_working_day.hour_from,
|
|
'HT': calendar_working_day.hour_to,
|
|
})
|
|
date_from = datetime.strptime('%(Y)04d-%(m)02d-%(d)02d %(HF)02d:00:00' % date_dict, '%Y-%m-%d %H:%M:%S')
|
|
date_to = datetime.strptime('%(Y)04d-%(m)02d-%(d)02d %(HT)02d:00:00' % date_dict, '%Y-%m-%d %H:%M:%S')
|
|
working_intervals.append((date_from, date_to))
|
|
|
|
# find leave intervals
|
|
if leaves is None and compute_leaves:
|
|
leaves = self._get_leave_intervals(cr, uid, id, resource_id=resource_id, context=None)
|
|
|
|
# filter according to leaves
|
|
for interval in working_intervals:
|
|
work_intervals = self.interval_remove_leaves(interval, leaves)
|
|
intervals += work_intervals
|
|
|
|
return intervals
|
|
|
|
def get_working_hours_of_date(self, cr, uid, id, day_date=None, leaves=None, compute_leaves=False, resource_id=None, context=None):
|
|
"""Get the working hours of the day based on calendar. This method uses
|
|
get_working_intervals_of_day to have the work intervals of the day. It
|
|
then calculates the number of hours contained in those intervals. """
|
|
res = timedelta()
|
|
intervals = self.get_working_intervals_of_day(cr, uid, id, day_date, leaves, compute_leaves, resource_id, context)
|
|
for interval in intervals:
|
|
res += interval[1] - interval[0]
|
|
return (res.total_seconds() / 3600.0)
|
|
|
|
def schedule_hours(self, cr, uid, id, hours, start_datetime=None, end_datetime=None, compute_leaves=False, resource_id=None, context=None):
|
|
"""
|
|
"""
|
|
if start_datetime is None:
|
|
start_datetime = datetime.now()
|
|
work_hours = 0
|
|
iterations = 0
|
|
final_intervals = []
|
|
|
|
# compute work days
|
|
work_days = set()
|
|
resource_calendar = self.browse(cr, uid, id, context=context)
|
|
for attendance in resource_calendar.attendance_ids:
|
|
work_days.add(int(attendance.dayofweek))
|
|
|
|
# prepare rrule arguments
|
|
rrule_args = {
|
|
'byweekday': work_days,
|
|
'dtstart': start_datetime,
|
|
}
|
|
if end_date:
|
|
rrule_args['until'] = end_datetime
|
|
else:
|
|
rrule_args['count'] = 1024
|
|
|
|
for day in rrule.rrule(rrule.DAILY, **rrule_args):
|
|
working_intervals = self.get_working_intervals_of_day(cr, uid, id, day_date=day, compute_leaves=compute_leaves, resource_id=resource_id, context=context)
|
|
if not working_intervals:
|
|
continue
|
|
# Compute worked hours, compare to requested number of hours
|
|
res = timedelta()
|
|
for interval in working_intervals:
|
|
res += interval[1] - interval[0]
|
|
work_hours += (res.total_seconds() / 3600.0)
|
|
final_intervals += working_intervals
|
|
if float_compare(work_hours, hours * 1.0, precision_digits=2) in (0, 1) or (iterations >= 50):
|
|
break
|
|
iterations += 1
|
|
|
|
return final_intervals
|
|
|
|
def _schedule_days(self, cr, uid, id, days, date=None, compute_leaves=False, resource_id=None, context=None):
|
|
"""Schedule days of work.
|
|
|
|
This method can be used backwards, i.e. scheduling days before a deadline.
|
|
"""
|
|
backwards = False
|
|
if days < 0:
|
|
backwards = True
|
|
days = abs(days)
|
|
intervals = []
|
|
planned_days = 0
|
|
iterations = 0
|
|
current_datetime = date
|
|
|
|
while planned_days < days and iterations < 1000:
|
|
working_intervals = self.get_working_intervals_of_day(cr, uid, id, current_datetime, compute_leaves=compute_leaves, resource_id=resource_id, context=context)
|
|
if id is None or working_intervals: # no calendar -> no working hours, but day is considered as worked
|
|
planned_days += 1
|
|
intervals += working_intervals
|
|
# get next day
|
|
if backwards:
|
|
current_datetime = self.get_previous_day(cr, uid, id, current_datetime)
|
|
else:
|
|
current_datetime = self.get_next_day(cr, uid, id, current_datetime)
|
|
|
|
return (current_datetime, intervals)
|
|
|
|
def schedule_days(self, cr, uid, id, days, date=None, compute_leaves=False, resource_id=None, context=None):
|
|
res = self._schedule_days(cr, uid, id, days, date, compute_leaves, resource_id, context)
|
|
return res[0]
|
|
|
|
# --------------------------------------------------
|
|
# Compaqtibility / to clean / to remove
|
|
# --------------------------------------------------
|
|
|
|
def working_hours_on_day(self, cr, uid, resource_calendar_id, day, context=None):
|
|
""" Compatibility method - will be removed for OpenERP v8
|
|
TDE TODO: hr_payroll/hr_payroll.py
|
|
"""
|
|
return self.get_working_hours_of_date(cr, uid, resource_calendar_id.id, day_date=day, context=None)
|
|
|
|
def _get_leaves(self, cr, uid, id, resource):
|
|
"""Private Method to Calculate resource Leaves days
|
|
|
|
@param id: resource calendar id
|
|
@param resource: resource id for which leaves will ew calculated
|
|
|
|
@return : returns the list of dates, where resource on leave in
|
|
resource.calendar.leaves object (e.g.['%Y-%m-%d', '%Y-%m-%d'])
|
|
"""
|
|
resource_cal_leaves = self.pool.get('resource.calendar.leaves')
|
|
dt_leave = []
|
|
resource_leave_ids = resource_cal_leaves.search(cr, uid, [('calendar_id','=',id), '|', ('resource_id','=',False), ('resource_id','=',resource)])
|
|
#res_leaves = resource_cal_leaves.read(cr, uid, resource_leave_ids, ['date_from', 'date_to'])
|
|
res_leaves = resource_cal_leaves.browse(cr, uid, resource_leave_ids)
|
|
|
|
for leave in res_leaves:
|
|
dtf = datetime.strptime(leave.date_from, '%Y-%m-%d %H:%M:%S')
|
|
dtt = datetime.strptime(leave.date_to, '%Y-%m-%d %H:%M:%S')
|
|
no = dtt - dtf
|
|
[dt_leave.append((dtf + timedelta(days=x)).strftime('%Y-%m-%d')) for x in range(int(no.days + 1))]
|
|
dt_leave.sort()
|
|
|
|
return dt_leave
|
|
|
|
def interval_min_get(self, cr, uid, id, dt_from, hours, resource=False):
|
|
"""
|
|
Calculates the working Schedule from supplied from date to till hours
|
|
will be satisfied based or resource calendar id. If resource is also
|
|
given then it will consider the resource leave also and than will
|
|
calculates resource working schedule
|
|
|
|
@param dt_from: datetime object, start of working scheduled
|
|
@param hours: float, total number working hours needed scheduled from
|
|
start date
|
|
@param resource : Optional Resource id, if supplied than resource leaves
|
|
will also taken into consideration for calculating working
|
|
schedule.
|
|
@return : List datetime object of working schedule based on supplies
|
|
params
|
|
|
|
TDE TODO: used in mrp_operations/mrp_operations.py
|
|
"""
|
|
if not id:
|
|
td = int(hours)*3
|
|
return [(dt_from - timedelta(hours=td), dt_from)]
|
|
dt_leave = self._get_leaves(cr, uid, id, resource)
|
|
dt_leave.reverse()
|
|
todo = hours
|
|
result = []
|
|
maxrecur = 100
|
|
current_hour = dt_from.hour
|
|
while float_compare(todo, 0, 4) and maxrecur:
|
|
cr.execute("select hour_from,hour_to from resource_calendar_attendance where dayofweek='%s' and calendar_id=%s order by hour_from desc", (dt_from.weekday(),id))
|
|
for (hour_from,hour_to) in cr.fetchall():
|
|
leave_flag = False
|
|
if (hour_from<current_hour) and float_compare(todo, 0, 4):
|
|
m = min(hour_to, current_hour)
|
|
if (m-hour_from)>todo:
|
|
hour_from = m-todo
|
|
dt_check = dt_from.strftime('%Y-%m-%d')
|
|
for leave in dt_leave:
|
|
if dt_check == leave:
|
|
dt_check = datetime.strptime(dt_check, '%Y-%m-%d') + timedelta(days=1)
|
|
leave_flag = True
|
|
if leave_flag:
|
|
break
|
|
else:
|
|
d1 = datetime(dt_from.year, dt_from.month, dt_from.day, int(math.floor(hour_from)), int((hour_from%1) * 60))
|
|
d2 = datetime(dt_from.year, dt_from.month, dt_from.day, int(math.floor(m)), int((m%1) * 60))
|
|
result.append((d1, d2))
|
|
current_hour = hour_from
|
|
todo -= (m-hour_from)
|
|
dt_from -= timedelta(days=1)
|
|
current_hour = 24
|
|
maxrecur -= 1
|
|
result.reverse()
|
|
return result
|
|
|
|
# def interval_get(self, cr, uid, id, dt_from, hours, resource=False, byday=True):
|
|
def interval_get_multi(self, cr, uid, date_and_hours_by_cal, resource=False, byday=True):
|
|
""" TDE NOTE: used in mrp_operations/mrp_operations.py and in interval_get() """
|
|
def group(lst, key):
|
|
lst.sort(key=itemgetter(key))
|
|
grouped = itertools.groupby(lst, itemgetter(key))
|
|
return dict([(k, [v for v in itr]) for k, itr in grouped])
|
|
# END group
|
|
|
|
cr.execute("select calendar_id, dayofweek, hour_from, hour_to from resource_calendar_attendance order by hour_from")
|
|
hour_res = cr.dictfetchall()
|
|
hours_by_cal = group(hour_res, 'calendar_id')
|
|
|
|
results = {}
|
|
|
|
for d, hours, id in date_and_hours_by_cal:
|
|
dt_from = datetime.strptime(d, '%Y-%m-%d %H:%M:%S')
|
|
if not id:
|
|
td = int(hours)*3
|
|
results[(d, hours, id)] = [(dt_from, dt_from + timedelta(hours=td))]
|
|
continue
|
|
|
|
dt_leave = self._get_leaves(cr, uid, id, resource)
|
|
todo = hours
|
|
result = []
|
|
maxrecur = 100
|
|
current_hour = dt_from.hour
|
|
while float_compare(todo, 0, 4) and maxrecur:
|
|
for (hour_from,hour_to) in [(item['hour_from'], item['hour_to']) for item in hours_by_cal[id] if item['dayofweek'] == str(dt_from.weekday())]:
|
|
leave_flag = False
|
|
if (hour_to>current_hour) and float_compare(todo, 0, 4):
|
|
m = max(hour_from, current_hour)
|
|
if (hour_to-m)>todo:
|
|
hour_to = m+todo
|
|
dt_check = dt_from.strftime('%Y-%m-%d')
|
|
for leave in dt_leave:
|
|
if dt_check == leave:
|
|
dt_check = datetime.strptime(dt_check, '%Y-%m-%d') + timedelta(days=1)
|
|
leave_flag = True
|
|
if leave_flag:
|
|
break
|
|
else:
|
|
d1 = datetime(dt_from.year, dt_from.month, dt_from.day, int(math.floor(m)), int((m%1) * 60))
|
|
d2 = datetime(dt_from.year, dt_from.month, dt_from.day, int(math.floor(hour_to)), int((hour_to%1) * 60))
|
|
result.append((d1, d2))
|
|
current_hour = hour_to
|
|
todo -= (hour_to - m)
|
|
dt_from += timedelta(days=1)
|
|
current_hour = 0
|
|
maxrecur -= 1
|
|
results[(d, hours, id)] = result
|
|
return results
|
|
|
|
def interval_get(self, cr, uid, id, dt_from, hours, resource=False, byday=True):
|
|
"""Calculates Resource Working Internal Timing Based on Resource Calendar.
|
|
|
|
@param dt_from: start resource schedule calculation.
|
|
@param hours : total number of working hours to be scheduled.
|
|
@param resource: optional resource id, If supplied it will take care of
|
|
resource leave while scheduling.
|
|
@param byday: boolean flag bit enforce day wise scheduling
|
|
|
|
@return : list of scheduled working timing based on resource calendar.
|
|
|
|
TDE NOTE: mrp_operations/mrp_operations.py, crm/crm_lead.py
|
|
"""
|
|
res = self.interval_get_multi(cr, uid, [(dt_from.strftime('%Y-%m-%d %H:%M:%S'), hours, id)], resource, byday)[(dt_from.strftime('%Y-%m-%d %H:%M:%S'), hours, id)]
|
|
return res
|
|
|
|
def interval_hours_get(self, cr, uid, id, dt_from, dt_to, resource=False):
|
|
""" Calculates the Total Working hours based on given start_date to
|
|
end_date, If resource id is supplied that it will consider the source
|
|
leaves also in calculating the hours.
|
|
|
|
@param dt_from : date start to calculate hours
|
|
@param dt_end : date end to calculate hours
|
|
@param resource: optional resource id, If given resource leave will be
|
|
considered.
|
|
|
|
@return : Total number of working hours based dt_from and dt_end and
|
|
resource if supplied.
|
|
"""
|
|
return self._interval_hours_get(cr, uid, id, dt_from, dt_to, resource_id=resource)
|
|
|
|
def _interval_hours_get(self, cr, uid, id, dt_from, dt_to, resource_id=False, timezone_from_uid=None, exclude_leaves=True, context=None):
|
|
""" Calculates the Total Working hours based on given start_date to
|
|
end_date, If resource id is supplied that it will consider the source
|
|
leaves also in calculating the hours.
|
|
|
|
@param dt_from : date start to calculate hours
|
|
@param dt_end : date end to calculate hours
|
|
@param resource_id: optional resource id, If given resource leave will be
|
|
considered.
|
|
@param timezone_from_uid: optional uid, if given we will considerer
|
|
working hours in that user timezone
|
|
@param exclude_leaves: optionnal, if set to True (default) we will exclude
|
|
resource leaves from working hours
|
|
@param context: current request context
|
|
@return : Total number of working hours based dt_from and dt_end and
|
|
resource if supplied.
|
|
|
|
TDE NOTE: used in project_issue/project_issue.py
|
|
"""
|
|
utc_tz = pytz.timezone('UTC')
|
|
local_tz = utc_tz
|
|
|
|
if timezone_from_uid:
|
|
users_obj = self.pool.get('res.users')
|
|
user_timezone = users_obj.browse(cr, uid, timezone_from_uid, context=context).partner_id.tz
|
|
if user_timezone:
|
|
try:
|
|
local_tz = pytz.timezone(user_timezone)
|
|
except pytz.UnknownTimeZoneError:
|
|
pass # fallback to UTC as local timezone
|
|
|
|
def utc_to_local_zone(naive_datetime):
|
|
utc_dt = utc_tz.localize(naive_datetime, is_dst=False)
|
|
return utc_dt.astimezone(local_tz)
|
|
|
|
def float_time_convert(float_val):
|
|
factor = float_val < 0 and -1 or 1
|
|
val = abs(float_val)
|
|
return (factor * int(math.floor(val)), int(round((val % 1) * 60)))
|
|
|
|
# Get slots hours per day
|
|
# {day_of_week: [(8, 12), (13, 17), ...], ...}
|
|
hours_range_per_weekday = {}
|
|
if id:
|
|
cr.execute("select dayofweek, hour_from,hour_to from resource_calendar_attendance where calendar_id=%s order by hour_from", (id,))
|
|
for weekday, hour_from, hour_to in cr.fetchall():
|
|
weekday = int(weekday)
|
|
hours_range_per_weekday.setdefault(weekday, [])
|
|
hours_range_per_weekday[weekday].append((hour_from, hour_to))
|
|
else:
|
|
# considering default working hours (Monday -> Friday, 8 -> 12, 13 -> 17)
|
|
for weekday in range(5):
|
|
hours_range_per_weekday[weekday] = [(8, 12), (13, 17)]
|
|
|
|
## Interval between dt_from - dt_to
|
|
##
|
|
## dt_from dt_to
|
|
## =============|==================|============
|
|
## [ 1 ] [ 2 ] [ 3 ] [ 4 ] [ 5 ]
|
|
##
|
|
## [ : start of range
|
|
## ] : end of range
|
|
##
|
|
## case 1: range end before interval start (skip)
|
|
## case 2: range overlap interval start (fit start to internal)
|
|
## case 3: range within interval
|
|
## case 4: range overlap interval end (fit end to interval)
|
|
## case 5: range start after interval end (skip)
|
|
|
|
interval_start = utc_to_local_zone(dt_from)
|
|
interval_end = utc_to_local_zone(dt_to)
|
|
hours_timedelta = timedelta()
|
|
|
|
# Get leaves for requested resource
|
|
dt_leaves = set([])
|
|
if exclude_leaves and id:
|
|
dt_leaves = set(self._get_leaves(cr, uid, id, resource=resource_id))
|
|
|
|
for day in rrule.rrule(rrule.DAILY, dtstart=interval_start,
|
|
until=interval_end+timedelta(days=1),
|
|
byweekday=hours_range_per_weekday.keys()):
|
|
if exclude_leaves and day.strftime('%Y-%m-%d') in dt_leaves:
|
|
# XXX: futher improve leave management to allow for partial day leave
|
|
continue
|
|
for (range_from, range_to) in hours_range_per_weekday.get(day.weekday(), []):
|
|
range_from_hour, range_from_min = float_time_convert(range_from)
|
|
range_to_hour, range_to_min = float_time_convert(range_to)
|
|
daytime_start = local_tz.localize(day.replace(hour=range_from_hour, minute=range_from_min, second=0, tzinfo=None))
|
|
daytime_end = local_tz.localize(day.replace(hour=range_to_hour, minute=range_to_min, second=0, tzinfo=None))
|
|
|
|
# case 1 & 5: time range out of interval
|
|
if daytime_end < interval_start or daytime_start > interval_end:
|
|
continue
|
|
# case 2 & 4: adjust start, end to fit within interval
|
|
daytime_start = max(daytime_start, interval_start)
|
|
daytime_end = min(daytime_end, interval_end)
|
|
|
|
# case 2+, 4+, 3
|
|
hours_timedelta += (daytime_end - daytime_start)
|
|
|
|
# return timedelta converted to hours
|
|
return (hours_timedelta.days * 24.0 + hours_timedelta.seconds / 3600.0)
|
|
|
|
|
|
class resource_calendar_attendance(osv.osv):
|
|
_name = "resource.calendar.attendance"
|
|
_description = "Work Detail"
|
|
|
|
_columns = {
|
|
'name' : fields.char("Name", size=64, required=True),
|
|
'dayofweek': fields.selection([('0','Monday'),('1','Tuesday'),('2','Wednesday'),('3','Thursday'),('4','Friday'),('5','Saturday'),('6','Sunday')], 'Day of Week', required=True, select=True),
|
|
'date_from' : fields.date('Starting Date'),
|
|
'hour_from' : fields.float('Work from', required=True, help="Start and End time of working.", select=True),
|
|
'hour_to' : fields.float("Work to", required=True),
|
|
'calendar_id' : fields.many2one("resource.calendar", "Resource's Calendar", required=True),
|
|
}
|
|
|
|
_order = 'dayofweek, hour_from'
|
|
|
|
_defaults = {
|
|
'dayofweek' : '0'
|
|
}
|
|
|
|
def hours_time_string(hours):
|
|
""" convert a number of hours (float) into a string with format '%H:%M' """
|
|
minutes = int(round(hours * 60))
|
|
return "%02d:%02d" % divmod(minutes, 60)
|
|
|
|
class resource_resource(osv.osv):
|
|
_name = "resource.resource"
|
|
_description = "Resource Detail"
|
|
_columns = {
|
|
'name' : fields.char("Name", size=64, required=True),
|
|
'code': fields.char('Code', size=16),
|
|
'active' : fields.boolean('Active', help="If the active field is set to False, it will allow you to hide the resource record without removing it."),
|
|
'company_id' : fields.many2one('res.company', 'Company'),
|
|
'resource_type': fields.selection([('user','Human'),('material','Material')], 'Resource Type', required=True),
|
|
'user_id' : fields.many2one('res.users', 'User', help='Related user name for the resource to manage its access.'),
|
|
'time_efficiency' : fields.float('Efficiency Factor', size=8, required=True, help="This field depict the efficiency of the resource to complete tasks. e.g resource put alone on a phase of 5 days with 5 tasks assigned to him, will show a load of 100% for this phase by default, but if we put a efficiency of 200%, then his load will only be 50%."),
|
|
'calendar_id' : fields.many2one("resource.calendar", "Working Time", help="Define the schedule of resource"),
|
|
}
|
|
_defaults = {
|
|
'resource_type' : 'user',
|
|
'time_efficiency' : 1,
|
|
'active' : True,
|
|
'company_id': lambda self, cr, uid, context: self.pool.get('res.company')._company_default_get(cr, uid, 'resource.resource', context=context)
|
|
}
|
|
|
|
|
|
def copy(self, cr, uid, id, default=None, context=None):
|
|
if default is None:
|
|
default = {}
|
|
if not default.get('name', False):
|
|
default.update(name=_('%s (copy)') % (self.browse(cr, uid, id, context=context).name))
|
|
return super(resource_resource, self).copy(cr, uid, id, default, context)
|
|
|
|
def generate_resources(self, cr, uid, user_ids, calendar_id, context=None):
|
|
"""
|
|
Return a list of Resource Class objects for the resources allocated to the phase.
|
|
|
|
TDE NOTE: used in project/project.py
|
|
"""
|
|
resource_objs = {}
|
|
user_pool = self.pool.get('res.users')
|
|
for user in user_pool.browse(cr, uid, user_ids, context=context):
|
|
resource_objs[user.id] = {
|
|
'name' : user.name,
|
|
'vacation': [],
|
|
'efficiency': 1.0,
|
|
}
|
|
|
|
resource_ids = self.search(cr, uid, [('user_id', '=', user.id)], context=context)
|
|
if resource_ids:
|
|
for resource in self.browse(cr, uid, resource_ids, context=context):
|
|
resource_objs[user.id]['efficiency'] = resource.time_efficiency
|
|
resource_cal = resource.calendar_id.id
|
|
if resource_cal:
|
|
leaves = self.compute_vacation(cr, uid, calendar_id, resource.id, resource_cal, context=context)
|
|
resource_objs[user.id]['vacation'] += list(leaves)
|
|
return resource_objs
|
|
|
|
def compute_vacation(self, cr, uid, calendar_id, resource_id=False, resource_calendar=False, context=None):
|
|
"""
|
|
Compute the vacation from the working calendar of the resource.
|
|
|
|
@param calendar_id : working calendar of the project
|
|
@param resource_id : resource working on phase/task
|
|
@param resource_calendar : working calendar of the resource
|
|
|
|
TDE NOTE: used in project/project.py, and in generate_resources
|
|
"""
|
|
resource_calendar_leaves_pool = self.pool.get('resource.calendar.leaves')
|
|
leave_list = []
|
|
if resource_id:
|
|
leave_ids = resource_calendar_leaves_pool.search(cr, uid, ['|', ('calendar_id', '=', calendar_id),
|
|
('calendar_id', '=', resource_calendar),
|
|
('resource_id', '=', resource_id)
|
|
], context=context)
|
|
else:
|
|
leave_ids = resource_calendar_leaves_pool.search(cr, uid, [('calendar_id', '=', calendar_id),
|
|
('resource_id', '=', False)
|
|
], context=context)
|
|
leaves = resource_calendar_leaves_pool.read(cr, uid, leave_ids, ['date_from', 'date_to'], context=context)
|
|
for i in range(len(leaves)):
|
|
dt_start = datetime.strptime(leaves[i]['date_from'], '%Y-%m-%d %H:%M:%S')
|
|
dt_end = datetime.strptime(leaves[i]['date_to'], '%Y-%m-%d %H:%M:%S')
|
|
no = dt_end - dt_start
|
|
[leave_list.append((dt_start + timedelta(days=x)).strftime('%Y-%m-%d')) for x in range(int(no.days + 1))]
|
|
leave_list.sort()
|
|
return leave_list
|
|
|
|
def compute_working_calendar(self, cr, uid, calendar_id=False, context=None):
|
|
"""
|
|
Change the format of working calendar from 'Openerp' format to bring it into 'Faces' format.
|
|
@param calendar_id : working calendar of the project
|
|
|
|
TDE NOTE: used in project/project.py
|
|
"""
|
|
if not calendar_id:
|
|
# Calendar is not specified: working days: 24/7
|
|
return [('fri', '8:0-12:0','13:0-17:0'), ('thu', '8:0-12:0','13:0-17:0'), ('wed', '8:0-12:0','13:0-17:0'),
|
|
('mon', '8:0-12:0','13:0-17:0'), ('tue', '8:0-12:0','13:0-17:0')]
|
|
resource_attendance_pool = self.pool.get('resource.calendar.attendance')
|
|
time_range = "8:00-8:00"
|
|
non_working = ""
|
|
week_days = {"0": "mon", "1": "tue", "2": "wed","3": "thu", "4": "fri", "5": "sat", "6": "sun"}
|
|
wk_days = {}
|
|
wk_time = {}
|
|
wktime_list = []
|
|
wktime_cal = []
|
|
week_ids = resource_attendance_pool.search(cr, uid, [('calendar_id', '=', calendar_id)], context=context)
|
|
weeks = resource_attendance_pool.read(cr, uid, week_ids, ['dayofweek', 'hour_from', 'hour_to'], context=context)
|
|
# Convert time formats into appropriate format required
|
|
# and create a list like [('mon', '8:00-12:00'), ('mon', '13:00-18:00')]
|
|
for week in weeks:
|
|
res_str = ""
|
|
day = None
|
|
if week_days.get(week['dayofweek'],False):
|
|
day = week_days[week['dayofweek']]
|
|
wk_days[week['dayofweek']] = week_days[week['dayofweek']]
|
|
else:
|
|
raise osv.except_osv(_('Configuration Error!'),_('Make sure the Working time has been configured with proper week days!'))
|
|
hour_from_str = hours_time_string(week['hour_from'])
|
|
hour_to_str = hours_time_string(week['hour_to'])
|
|
res_str = hour_from_str + '-' + hour_to_str
|
|
wktime_list.append((day, res_str))
|
|
# Convert into format like [('mon', '8:00-12:00', '13:00-18:00')]
|
|
for item in wktime_list:
|
|
if wk_time.has_key(item[0]):
|
|
wk_time[item[0]].append(item[1])
|
|
else:
|
|
wk_time[item[0]] = [item[0]]
|
|
wk_time[item[0]].append(item[1])
|
|
for k,v in wk_time.items():
|
|
wktime_cal.append(tuple(v))
|
|
# Add for the non-working days like: [('sat, sun', '8:00-8:00')]
|
|
for k, v in wk_days.items():
|
|
if week_days.has_key(k):
|
|
week_days.pop(k)
|
|
for v in week_days.itervalues():
|
|
non_working += v + ','
|
|
if non_working:
|
|
wktime_cal.append((non_working[:-1], time_range))
|
|
return wktime_cal
|
|
|
|
|
|
class resource_calendar_leaves(osv.osv):
|
|
_name = "resource.calendar.leaves"
|
|
_description = "Leave Detail"
|
|
_columns = {
|
|
'name' : fields.char("Name", size=64),
|
|
'company_id' : fields.related('calendar_id','company_id',type='many2one',relation='res.company',string="Company", store=True, readonly=True),
|
|
'calendar_id' : fields.many2one("resource.calendar", "Working Time"),
|
|
'date_from' : fields.datetime('Start Date', required=True),
|
|
'date_to' : fields.datetime('End Date', required=True),
|
|
'resource_id' : fields.many2one("resource.resource", "Resource", help="If empty, this is a generic holiday for the company. If a resource is set, the holiday/leave is only for this resource"),
|
|
}
|
|
|
|
def check_dates(self, cr, uid, ids, context=None):
|
|
leave = self.read(cr, uid, ids[0], ['date_from', 'date_to'])
|
|
if leave['date_from'] and leave['date_to']:
|
|
if leave['date_from'] > leave['date_to']:
|
|
return False
|
|
return True
|
|
|
|
_constraints = [
|
|
(check_dates, 'Error! leave start-date must be lower then leave end-date.', ['date_from', 'date_to'])
|
|
]
|
|
|
|
def onchange_resource(self, cr, uid, ids, resource, context=None):
|
|
result = {}
|
|
if resource:
|
|
resource_pool = self.pool.get('resource.resource')
|
|
result['calendar_id'] = resource_pool.browse(cr, uid, resource, context=context).calendar_id.id
|
|
return {'value': result}
|
|
return {'value': {'calendar_id': []}}
|
|
|
|
|
|
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:
|