# -*- coding: utf-8 -*- # © 2014-2015 ACSONE SA/NV () # License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl.html). from collections import defaultdict, OrderedDict import datetime import dateutil import logging import re import time import traceback import pytz from openerp import api, exceptions, fields, models, _ from openerp.tools.safe_eval import safe_eval from .aep import AccountingExpressionProcessor as AEP from .aggregate import _sum, _avg, _min, _max from .accounting_none import AccountingNone from openerp.exceptions import UserError from .simple_array import SimpleArray _logger = logging.getLogger(__name__) class DataError(Exception): def __init__(self, name, msg): self.name = name self.msg = msg class AutoStruct(object): def __init__(self, **kwargs): for k, v in kwargs.items(): setattr(self, k, v) class ExplodedKpiItem(object): def __init__(self, account_id): pass class KpiMatrix(object): def __init__(self): # { period: {kpi: vals} self._kpi_vals = defaultdict(dict) # { period: {kpi: {account_id: vals}}} self._kpi_exploded_vals = defaultdict(dict) # { period: localdict } self._localdict = {} # { kpi: set(account_ids) } self._kpis = OrderedDict() def set_kpi_vals(self, period, kpi, vals): self._kpi_vals[period][kpi] = vals if kpi not in self._kpis: self._kpis[kpi] = set() def set_kpi_exploded_vals(self, period, kpi, account_id, vals): exploded_vals = self._kpi_exploded_vals[period] if kpi not in exploded_vals: exploded_vals[kpi] = {} exploded_vals[kpi][account_id] = vals self._kpis[kpi].add(account_id) def set_localdict(self, period, localdict): self._localdict[period] = localdict def iter_kpi_vals(self, period): for kpi, vals in self._kpi_vals[period].iteritems(): yield kpi.name, kpi, vals kpi_exploded_vals = self._kpi_exploded_vals[period] if kpi not in kpi_exploded_vals: continue for account_id, account_id_vals in \ kpi_exploded_vals[kpi].iteritems(): yield "%s:%s" % (kpi.name, account_id), kpi, account_id_vals def iter_kpis(self): for kpi, account_ids in self._kpis.iteritems(): yield kpi.name, kpi for account_id in account_ids: yield "%s:%s" % (kpi.name, account_id), kpi def _get_selection_label(selection, value): for v, l in selection: if v == value: return l return '' def _utc_midnight(d, tz_name, add_day=0): d = fields.Datetime.from_string(d) + datetime.timedelta(days=add_day) utc_tz = pytz.timezone('UTC') context_tz = pytz.timezone(tz_name) local_timestamp = context_tz.localize(d, is_dst=False) return fields.Datetime.to_string(local_timestamp.astimezone(utc_tz)) def _python_var(var_str): return re.sub(r'\W|^(?=\d)', '_', var_str).lower() def _is_valid_python_var(name): return re.match("[_A-Za-z][_a-zA-Z0-9]*$", name) class MisReportKpi(models.Model): """ A KPI is an element (ie a line) of a MIS report. In addition to a name and description, it has an expression to compute it based on queries defined in the MIS report. It also has various informations defining how to render it (numeric or percentage or a string, a prefix, a suffix, divider) and how to render comparison of two values of the KPI. KPI's have a sequence and are ordered inside the MIS report. """ _name = 'mis.report.kpi' name = fields.Char(size=32, required=True, string='Name') description = fields.Char(required=True, string='Description', translate=True) multi = fields.Boolean() expression = fields.Char( compute='_compute_expression', inverse='_inverse_expression') expression_ids = fields.One2many('mis.report.kpi.expression', 'kpi_id') default_css_style = fields.Char(string='Default CSS style') css_style = fields.Char(string='CSS style expression') type = fields.Selection([('num', _('Numeric')), ('pct', _('Percentage')), ('str', _('String'))], required=True, string='Type', default='num') divider = fields.Selection([('1e-6', _('µ')), ('1e-3', _('m')), ('1', _('1')), ('1e3', _('k')), ('1e6', _('M'))], string='Factor', default='1') dp = fields.Integer(string='Rounding', default=0) prefix = fields.Char(size=16, string='Prefix') suffix = fields.Char(size=16, string='Suffix') compare_method = fields.Selection([('diff', _('Difference')), ('pct', _('Percentage')), ('none', _('None'))], required=True, string='Comparison Method', default='pct') sequence = fields.Integer(string='Sequence', default=100) report_id = fields.Many2one('mis.report', string='Report', ondelete='cascade') _order = 'sequence, id' @api.one @api.constrains('name') def _check_name(self): if not _is_valid_python_var(self.name): raise exceptions.Warning(_('The name must be a valid ' 'python identifier')) @api.onchange('name') def _onchange_name(self): if self.name and not _is_valid_python_var(self.name): return { 'warning': { 'title': 'Invalid name %s' % self.name, 'message': 'The name must be a valid python identifier' } } @api.multi def _compute_expression(self): for kpi in self: kpi.expression = '' for expression in kpi.expression_ids: if expression.subkpi_id: kpi.expression += '%s :\n' % expression.subkpi_id.name kpi.expression += '%s\n' % expression.name @api.multi def _inverse_expression(self): for kpi in self: if kpi.multi: raise UserError('Can not update a multi kpi from the kpi line') if kpi.expression_ids: kpi.expression_ids[0].write({ 'name': kpi.expression, 'subkpi_id': None}) for expression in kpi.expression_ids[1:]: expression.unlink() else: kpi.write({ 'expression_ids': [(0, 0, { 'name': kpi.expression })] }) @api.onchange('multi') def _onchange_multi(self): for kpi in self: if not kpi.multi: if kpi.expression_ids: kpi.expression = kpi.expression_ids[0].name else: kpi.expression = None else: expressions = [] for subkpi in kpi.report_id.subkpi_ids: expressions.append((0, 0, { 'name': kpi.expression, 'subkpi_id': subkpi.id, })) kpi.expression_ids = expressions @api.onchange('description') def _onchange_description(self): """ construct name from description """ if self.description and not self.name: self.name = _python_var(self.description) @api.onchange('type') def _onchange_type(self): if self.type == 'num': self.compare_method = 'pct' self.divider = '1' self.dp = 0 elif self.type == 'pct': self.compare_method = 'diff' self.divider = '1' self.dp = 0 elif self.type == 'str': self.compare_method = 'none' self.divider = '' self.dp = 0 def render(self, lang_id, value): """ render a KPI value as a unicode string, ready for display """ assert len(self) == 1 if value is None or value == AccountingNone: return '' elif self.type == 'num': return self._render_num(lang_id, value, self.divider, self.dp, self.prefix, self.suffix) elif self.type == 'pct': return self._render_num(lang_id, value, 0.01, self.dp, '', '%') else: return unicode(value) def render_comparison(self, lang_id, value, base_value, average_value, average_base_value): """ render the comparison of two KPI values, ready for display If the difference is 0, an empty string is returned. """ assert len(self) == 1 if value is None: value = AccountingNone if base_value is None: base_value = AccountingNone if self.type == 'pct': delta = value - base_value if delta and round(delta, self.dp) != 0: return self._render_num( lang_id, delta, 0.01, self.dp, '', _('pp'), sign='+') elif self.type == 'num': if value and average_value: value = value / float(average_value) if base_value and average_base_value: base_value = base_value / float(average_base_value) if self.compare_method == 'diff': delta = value - base_value if delta and round(delta, self.dp) != 0: return self._render_num( lang_id, delta, self.divider, self.dp, self.prefix, self.suffix, sign='+') elif self.compare_method == 'pct': if base_value and round(base_value, self.dp) != 0: delta = (value - base_value) / abs(base_value) if delta and round(delta, self.dp) != 0: return self._render_num( lang_id, delta, 0.01, self.dp, '', '%', sign='+') return '' def _render_num(self, lang_id, value, divider, dp, prefix, suffix, sign='-'): divider_label = _get_selection_label( self._columns['divider'].selection, divider) if divider_label == '1': divider_label = '' # format number following user language value = round(value / float(divider or 1), dp) or 0 value = self.env['res.lang'].browse(lang_id).format( '%%%s.%df' % (sign, dp), value, grouping=True) value = u'%s\N{NARROW NO-BREAK SPACE}%s\N{NO-BREAK SPACE}%s%s' % \ (prefix or '', value, divider_label, suffix or '') value = value.replace('-', u'\N{NON-BREAKING HYPHEN}') return value class MisReportSubkpi(models.Model): _name = 'mis.report.subkpi' _order = 'sequence' sequence = fields.Integer() report_id = fields.Many2one('mis.report') name = fields.Char(required=True) expression_ids = fields.One2many('mis.report.kpi.expression', 'subkpi_id') @api.multi def unlink(self): for subkpi in self: subkpi.expression_ids.unlink() return super(MisReportSubkpi, self).unlink() class MisReportKpiExpression(models.Model): """ A KPI Expression is an expression of a line of a MIS report Kpi. It's used to compute the kpi value. """ _name = 'mis.report.kpi.expression' _order = 'sequence, name' sequence = fields.Integer( related='subkpi_id.sequence', store=True, readonly=True) name = fields.Char(string='Expression') kpi_id = fields.Many2one('mis.report.kpi') subkpi_id = fields.Many2one( 'mis.report.subkpi', readonly=True) class MisReportQuery(models.Model): """ A query to fetch arbitrary data for a MIS report. A query works on a model and has a domain and list of fields to fetch. At runtime, the domain is expanded with a "and" on the date/datetime field. """ _name = 'mis.report.query' @api.one @api.depends('field_ids') def _compute_field_names(self): field_names = [field.name for field in self.field_ids] self.field_names = ', '.join(field_names) name = fields.Char(size=32, required=True, string='Name') model_id = fields.Many2one('ir.model', required=True, string='Model') field_ids = fields.Many2many('ir.model.fields', required=True, string='Fields to fetch') field_names = fields.Char(compute='_compute_field_names', string='Fetched fields name') aggregate = fields.Selection([('sum', _('Sum')), ('avg', _('Average')), ('min', _('Min')), ('max', _('Max'))], string='Aggregate') date_field = fields.Many2one('ir.model.fields', required=True, string='Date field', domain=[('ttype', 'in', ('date', 'datetime'))]) domain = fields.Char(string='Domain') report_id = fields.Many2one('mis.report', string='Report', ondelete='cascade') _order = 'name' @api.one @api.constrains('name') def _check_name(self): if not _is_valid_python_var(self.name): raise exceptions.Warning(_('The name must be a valid ' 'python identifier')) class MisReport(models.Model): """ A MIS report template (without period information) The MIS report holds: * a list of explicit queries; the result of each query is stored in a variable with same name as a query, containing as list of data structures populated with attributes for each fields to fetch; when queries have an aggregate method and no fields to group, it returns a data structure with the aggregated fields * a list of KPI to be evaluated based on the variables resulting from the accounting data and queries (KPI expressions can references queries and accounting expression - see AccoutingExpressionProcessor) """ _name = 'mis.report' name = fields.Char(required=True, string='Name', translate=True) description = fields.Char(required=False, string='Description', translate=True) query_ids = fields.One2many('mis.report.query', 'report_id', string='Queries', copy=True) kpi_ids = fields.One2many('mis.report.kpi', 'report_id', string='KPI\'s', copy=True) subkpi_ids = fields.One2many( 'mis.report.subkpi', 'report_id', string="Sub KPI") @api.one def copy(self, default=None): default = dict(default or {}) default['name'] = _('%s (copy)') % self.name return super(MisReport, self).copy(default) # TODO: kpi name cannot be start with query name @api.multi def _prepare_aep(self, company): self.ensure_one() aep = AEP(self.env) for kpi in self.kpi_ids: aep.parse_expr(kpi.expression) aep.done_parsing(company) return aep @api.multi def _fetch_queries(self, date_from, date_to, get_additional_query_filter=None): self.ensure_one() res = {} for query in self.query_ids: model = self.env[query.model_id.model] eval_context = { 'env': self.env, 'time': time, 'datetime': datetime, 'dateutil': dateutil, # deprecated 'uid': self.env.uid, 'context': self.env.context, } domain = query.domain and \ safe_eval(query.domain, eval_context) or [] if get_additional_query_filter: domain.extend(get_additional_query_filter(query)) if query.date_field.ttype == 'date': domain.extend([(query.date_field.name, '>=', date_from), (query.date_field.name, '<=', date_to)]) else: datetime_from = _utc_midnight( date_from, self._context.get('tz', 'UTC')) datetime_to = _utc_midnight( date_to, self._context.get('tz', 'UTC'), add_day=1) domain.extend([(query.date_field.name, '>=', datetime_from), (query.date_field.name, '<', datetime_to)]) field_names = [f.name for f in query.field_ids] if not query.aggregate: data = model.search_read(domain, field_names) res[query.name] = [AutoStruct(**d) for d in data] elif query.aggregate == 'sum': data = model.read_group( domain, field_names, []) s = AutoStruct(count=data[0]['__count']) for field_name in field_names: v = data[0][field_name] setattr(s, field_name, v) res[query.name] = s else: data = model.search_read(domain, field_names) s = AutoStruct(count=len(data)) if query.aggregate == 'min': agg = _min elif query.aggregate == 'max': agg = _max elif query.aggregate == 'avg': agg = _avg for field_name in field_names: setattr(s, field_name, agg([d[field_name] for d in data])) res[query.name] = s return res @api.multi def _compute(self, kpi_matrix, period_key, lang_id, aep, date_from, date_to, target_move, company, subkpis_filter, get_additional_move_line_filter=None, get_additional_query_filter=None): """ Evaluate a report for a given period, populating a KpiMatrix. :param kpi_matrix: the KpiMatrix object to be populated :param kpi_matrix_period: the period key to use when populating the KpiMatrix :param lang_id: id of a res.lang object :param aep: an AccountingExpressionProcessor instance created using _prepare_aep() :param date_from, date_to: the starting and ending date :param target_move: all|posted :param company: :param get_additional_move_line_filter: a bound method that takes no arguments and returns a domain compatible with account.move.line :param get_additional_query_filter: a bound method that takes a single query argument and returns a domain compatible with the query underlying model For each kpi, it calls set_kpi_vals and set_kpi_exploded_vals with vals being a tuple with the evaluation result for sub-kpis, or a DataError object if the evaluation failed. When done, it also calls set_localdict to store the local values that served for the computation of the period. """ self.ensure_one() localdict = { 'registry': self.pool, 'sum': _sum, 'min': _min, 'max': _max, 'len': len, 'avg': _avg, 'AccountingNone': AccountingNone, } localdict.update(self._fetch_queries( date_from, date_to, get_additional_query_filter)) additional_move_line_filter = None if get_additional_move_line_filter: additional_move_line_filter = get_additional_move_line_filter() aep.do_queries(date_from, date_to, target_move, company, additional_move_line_filter) compute_queue = self.kpi_ids recompute_queue = [] while True: for kpi in compute_queue: vals = [] has_error = False for expression in kpi.expression_ids: if expression.subkpi_id and \ subkpis_filter and \ expression.subkpi_id not in subkpis_filter: continue try: kpi_eval_expression = aep.replace_expr(expression.name) vals.append(safe_eval(kpi_eval_expression, localdict)) except ZeroDivisionError: has_error = True vals.append(DataError( '#DIV/0', '\n\n%s' % (traceback.format_exc(),))) except (NameError, ValueError): has_error = True recompute_queue.append(kpi) vals.append(DataError( '#ERR', '\n\n%s' % (traceback.format_exc(),))) except: has_error = True vals.append(DataError( '#ERR', '\n\n%s' % (traceback.format_exc(),))) if len(vals) == 1 and isinstance(vals[0], SimpleArray): vals = vals[0] else: vals = SimpleArray(vals) kpi_matrix.set_kpi_vals(period_key, kpi, vals) if has_error: continue # no error, set it in localdict so it can be used # in computing other kpis localdict[kpi.name] = vals # let's compute the exploded values by account # we assume there will be no errors, because it is a # the same as the kpi, just filtered on one account; # I'd say if we have an exception in this part, it's bug... # TODO FIXME: do this only if requested for this KPI for account_id in aep.get_accounts_in_expr(kpi.expression): account_id_vals = [] for expression in kpi.expression_ids: if expression.subkpi_id and \ subkpis_filter and \ expression.subkpi_id not in subkpis_filter: continue kpi_eval_expression = \ aep.replace_expr(expression.name, account_ids_filter=[account_id]) account_id_vals.\ append(safe_eval(kpi_eval_expression, localdict)) kpi_matrix.set_kpi_exploded_vals(period_key, kpi, account_id, account_id_vals) if len(recompute_queue) == 0: # nothing to recompute, we are done break if len(recompute_queue) == len(compute_queue): # could not compute anything in this iteration # (ie real Value errors or cyclic dependency) # so we stop trying break # try again compute_queue = recompute_queue recompute_queue = [] kpi_matrix.set_localdict(period_key, localdict) class MisReportInstancePeriod(models.Model): """ A MIS report instance has the logic to compute a report template for a given date period. Periods have a duration (day, week, fiscal period) and are defined as an offset relative to a pivot date. """ @api.one @api.depends('report_instance_id.pivot_date', 'type', 'offset', 'duration') def _compute_dates(self): self.date_from = False self.date_to = False self.valid = False d = fields.Date.from_string(self.report_instance_id.pivot_date) if self.type == 'd': date_from = d + datetime.timedelta(days=self.offset) date_to = date_from + \ datetime.timedelta(days=self.duration - 1) self.date_from = fields.Date.to_string(date_from) self.date_to = fields.Date.to_string(date_to) self.valid = True elif self.type == 'w': date_from = d - datetime.timedelta(d.weekday()) date_from = date_from + datetime.timedelta(days=self.offset * 7) date_to = date_from + \ datetime.timedelta(days=(7 * self.duration) - 1) self.date_from = fields.Date.to_string(date_from) self.date_to = fields.Date.to_string(date_to) self.valid = True elif self.type == 'date_range': date_range_obj = self.env['date.range'] current_periods = date_range_obj.search( [('type_id', '=', self.date_range_type_id.id), ('date_start', '<=', d), ('date_end', '>=', d), ('company_id', '=', self.report_instance_id.company_id.id)]) if current_periods: all_periods = date_range_obj.search( [('type_id', '=', self.date_range_type_id.id), ('company_id', '=', self.report_instance_id.company_id.id)], order='date_start') all_period_ids = [p.id for p in all_periods] p = all_period_ids.index(current_periods[0].id) + self.offset if p >= 0 and p + self.duration <= len(all_period_ids): periods = all_periods[p:p + self.duration] self.date_from = periods[0].date_start self.date_to = periods[-1].date_end self.valid = True _name = 'mis.report.instance.period' name = fields.Char(size=32, required=True, string='Description', translate=True) type = fields.Selection([('d', _('Day')), ('w', _('Week')), ('date_range', _('Date Range')) ], required=True, string='Period type') date_range_type_id = fields.Many2one( comodel_name='date.range.type', string='Date Range Type') offset = fields.Integer(string='Offset', help='Offset from current period', default=-1) duration = fields.Integer(string='Duration', help='Number of periods', default=1) date_from = fields.Date(compute='_compute_dates', string="From") date_to = fields.Date(compute='_compute_dates', string="To") valid = fields.Boolean(compute='_compute_dates', type='boolean', string='Valid') sequence = fields.Integer(string='Sequence', default=100) report_instance_id = fields.Many2one('mis.report.instance', string='Report Instance', ondelete='cascade') comparison_column_ids = fields.Many2many( comodel_name='mis.report.instance.period', relation='mis_report_instance_period_rel', column1='period_id', column2='compare_period_id', string='Compare with') normalize_factor = fields.Integer( string='Factor', help='Factor to use to normalize the period (used in comparison', default=1) subkpi_ids = fields.Many2many( 'mis.report.subkpi', string="Sub KPI") _order = 'sequence, id' _sql_constraints = [ ('duration', 'CHECK (duration>0)', 'Wrong duration, it must be positive!'), ('normalize_factor', 'CHECK (normalize_factor>0)', 'Wrong normalize factor, it must be positive!'), ('name_unique', 'unique(name, report_instance_id)', 'Period name should be unique by report'), ] @api.multi def _get_additional_move_line_filter(self): """ Prepare a filter to apply on all move lines This filter is applied with a AND operator on all accounting expression domains. This hook is intended to be inherited, and is useful to implement filtering on analytic dimensions or operational units. Returns an Odoo domain expression (a python list) compatible with account.move.line.""" self.ensure_one() return [] @api.multi def _get_additional_query_filter(self, query): """ Prepare an additional filter to apply on the query This filter is combined to the query domain with a AND operator. This hook is intended to be inherited, and is useful to implement filtering on analytic dimensions or operational units. Returns an Odoo domain expression (a python list) compatible with the model of the query.""" self.ensure_one() return [] @api.multi def drilldown(self, expr): self.ensure_one() # TODO FIXME: drilldown by account if AEP.has_account_var(expr): aep = AEP(self.env) aep.parse_expr(expr) aep.done_parsing(self.report_instance_id.company_id) domain = aep.get_aml_domain_for_expr( expr, self.date_from, self.date_to, self.report_instance_id.target_move, self.report_instance_id.company_id) domain.extend(self._get_additional_move_line_filter()) return { 'name': expr + ' - ' + self.name, 'domain': domain, 'type': 'ir.actions.act_window', 'res_model': 'account.move.line', 'views': [[False, 'list'], [False, 'form']], 'view_type': 'list', 'view_mode': 'list', 'target': 'current', } else: return False @api.multi def _compute(self, kpi_matrix, lang_id, aep): """ Compute and render a mis report instance period It returns a dictionary keyed on kpi.name with a list of dictionaries with the following values (one item in the list for each subkpi): * val: the evaluated kpi, or None if there is no data or an error * val_r: the rendered kpi as a string, or #ERR, #DIV * val_c: a comment (explaining the error, typically) * style: the css style of the kpi (may change in the future!) * prefix: a prefix to display in front of the rendered value * suffix: a prefix to display after rendered value * dp: the decimal precision of the kpi * is_percentage: true if the kpi is of percentage type (may change in the future!) * expr: the kpi expression * drilldown: true if the drilldown method of mis.report.instance.period is going to do something useful in this kpi """ self.ensure_one() # first invoke the compute method on the mis report template # passing it all the information regarding period and filters self.report_instance_id.report_id._compute( kpi_matrix, self, lang_id, aep, self.date_from, self.date_to, self.report_instance_id.target_move, self.report_instance_id.company_id, self.subkpi_ids, self._get_additional_move_line_filter, self._get_additional_query_filter, ) # second, render it to something that can be used by the widget res = {} for kpi_name, kpi, vals in kpi_matrix.iter_kpi_vals(self): res[kpi_name] = [] try: # TODO FIXME check css_style evaluation wrt subkpis kpi_style = None if kpi.css_style: kpi_style = safe_eval(kpi.css_style, kpi_matrix.get_localdict(self)) except: _logger.warning("error evaluating css stype expression %s", kpi.css_style, exc_info=True) kpi_style = None default_vals = { 'style': kpi_style, 'prefix': kpi.prefix, 'suffix': kpi.suffix, 'dp': kpi.dp, 'is_percentage': kpi.type == 'pct', 'period_id': self.id, 'expr': kpi.expression, # TODO FIXME } for idx, subkpi_val in enumerate(vals): vals = default_vals.copy() if isinstance(subkpi_val, DataError): vals.update({ 'val': subkpi_val.name, 'val_r': subkpi_val.name, 'val_c': subkpi_val.msg, 'drilldown': False, }) else: # TODO FIXME: has_account_var on each subkpi expression? drilldown = (subkpi_val is not AccountingNone and AEP.has_account_var(kpi.expression)) if kpi.multi: expression = kpi.expression_ids[idx].name else: expression = kpi.expression # TODO FIXME: check we have meaningfulname for exploded # kpis comment = kpi_name + " = " + expression vals.update({ 'val': (None if subkpi_val is AccountingNone else subkpi_val), 'val_r': kpi.render(lang_id, subkpi_val), 'val_c': comment, 'drilldown': drilldown, }) res[kpi_name].append(vals) return res class MisReportInstance(models.Model): """The MIS report instance combines everything to compute a MIS report template for a set of periods.""" @api.one @api.depends('date') def _compute_pivot_date(self): if self.date: self.pivot_date = self.date else: self.pivot_date = fields.Date.context_today(self) @api.model def _default_company(self): return self.env['res.company'].\ _company_default_get('mis.report.instance') _name = 'mis.report.instance' name = fields.Char(required=True, string='Name', translate=True) description = fields.Char(required=False, string='Description', translate=True) date = fields.Date(string='Base date', help='Report base date ' '(leave empty to use current date)') pivot_date = fields.Date(compute='_compute_pivot_date', string="Pivot date") report_id = fields.Many2one('mis.report', required=True, string='Report') period_ids = fields.One2many('mis.report.instance.period', 'report_instance_id', required=True, string='Periods', copy=True) target_move = fields.Selection([('posted', 'All Posted Entries'), ('all', 'All Entries')], string='Target Moves', required=True, default='posted') company_id = fields.Many2one(comodel_name='res.company', string='Company', default=_default_company, required=True) landscape_pdf = fields.Boolean(string='Landscape PDF') @api.one def copy(self, default=None): default = dict(default or {}) default['name'] = _('%s (copy)') % self.name return super(MisReportInstance, self).copy(default) def _format_date(self, lang_id, date): # format date following user language date_format = self.env['res.lang'].browse(lang_id).date_format return datetime.datetime.strftime( fields.Date.from_string(date), date_format) @api.multi def preview(self): assert len(self) == 1 view_id = self.env.ref('mis_builder.' 'mis_report_instance_result_view_form') return { 'type': 'ir.actions.act_window', 'res_model': 'mis.report.instance', 'res_id': self.id, 'view_mode': 'form', 'view_type': 'form', 'view_id': view_id.id, 'target': 'current', } @api.multi def print_pdf(self): self.ensure_one() return { 'name': 'MIS report instance QWEB PDF report', 'model': 'mis.report.instance', 'type': 'ir.actions.report.xml', 'report_name': 'mis_builder.report_mis_report_instance', 'report_type': 'qweb-pdf', 'context': self.env.context, } @api.multi def export_xls(self): self.ensure_one() return { 'name': 'MIS report instance XLSX report', 'model': 'mis.report.instance', 'type': 'ir.actions.report.xml', 'report_name': 'mis.report.instance.xlsx', 'report_type': 'xlsx', 'context': self.env.context, } @api.multi def display_settings(self): assert len(self.ids) <= 1 view_id = self.env.ref('mis_builder.mis_report_instance_view_form') return { 'type': 'ir.actions.act_window', 'res_model': 'mis.report.instance', 'res_id': self.id if self.id else False, 'view_mode': 'form', 'view_type': 'form', 'views': [(view_id.id, 'form')], 'view_id': view_id.id, 'target': 'current', } @api.multi def compute(self): self.ensure_one() aep = self.report_id._prepare_aep(self.company_id) # fetch user language only once # TODO: is this necessary? lang = self.env.user.lang if not lang: lang = 'en_US' lang_id = self.env['res.lang'].search([('code', '=', lang)]).id # compute kpi values for each period kpi_values_by_period_ids = {} kpi_matrix = KpiMatrix() for period in self.period_ids: if not period.valid: continue kpi_values = period._compute(kpi_matrix, lang_id, aep) kpi_values_by_period_ids[period.id] = kpi_values # prepare header and content header = [{ 'kpi_name': '', 'cols': [] }, { 'kpi_name': '', 'cols': [] }] content = [] rows_by_kpi_name = {} for kpi_name, kpi in kpi_matrix.iter_kpis(): rows_by_kpi_name[kpi_name] = { # TODO FIXME 'kpi_name': kpi.description if ':' not in kpi_name else kpi_name, 'cols': [], 'default_style': kpi.default_css_style } content.append(rows_by_kpi_name[kpi_name]) # populate header and content for period in self.period_ids: if not period.valid: continue # add the column header if period.duration > 1 or period.type == 'w': # from, to date_from = self._format_date(lang_id, period.date_from) date_to = self._format_date(lang_id, period.date_to) header_date = _('from %s to %s') % (date_from, date_to) else: header_date = self._format_date(lang_id, period.date_from) subkpis = period.subkpi_ids or \ period.report_instance_id.report_id.subkpi_ids header[0]['cols'].append(dict( name=period.name, date=header_date, colspan=len(subkpis) or 1, )) if subkpis: for subkpi in subkpis: header[1]['cols'].append(dict( name=subkpi.name, colspan=1, )) else: header[1]['cols'].append(dict( name="", colspan=1, )) # add kpi values kpi_values = kpi_values_by_period_ids[period.id] for kpi_name in kpi_values: rows_by_kpi_name[kpi_name]['cols'] += kpi_values[kpi_name] # add comparison columns for compare_col in period.comparison_column_ids: compare_kpi_values = \ kpi_values_by_period_ids.get(compare_col.id) if compare_kpi_values: # add the comparison column header header[0]['cols'].append( dict(name=_('%s vs %s') % (period.name, compare_col.name), date='')) # add comparison values for kpi in self.report_id.kpi_ids: rows_by_kpi_name[kpi.name]['cols'].append({ 'val_r': kpi.render_comparison( lang_id, kpi_values[kpi.name]['val'], compare_kpi_values[kpi.name]['val'], period.normalize_factor, compare_col.normalize_factor) }) return { 'header': header, 'content': content, }