mirror of
https://github.com/OCA/stock-logistics-warehouse.git
synced 2025-01-21 14:27:28 +02:00
ea37305faa
* Update README. * Fixes: DEFAULT_SERVER_DATETIME_FORMAT, PERCENT variables and sale price calculation.
112 lines
4.7 KiB
Python
112 lines
4.7 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Copyright 2017 Eficent Business and IT Consulting Services S.L.
|
|
# (http://www.eficent.com)
|
|
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl.html).
|
|
|
|
from openerp import api, fields, models
|
|
from openerp.tools import DEFAULT_SERVER_DATETIME_FORMAT
|
|
from datetime import datetime, timedelta
|
|
|
|
|
|
class StockWarehouse(models.Model):
|
|
_inherit = 'stock.warehouse'
|
|
|
|
cycle_count_rule_ids = fields.Many2many(
|
|
comodel_name='stock.cycle.count.rule',
|
|
relation='warehouse_cycle_count_'
|
|
'rule_rel',
|
|
column1='warehouse_id',
|
|
column2='rule_id',
|
|
string='Cycle Count Rules')
|
|
cycle_count_planning_horizon = fields.Integer(
|
|
string='Cycle Count Planning Horizon (in days)',
|
|
help='Cycle Count planning horizon in days. Only the counts inside '
|
|
'the horizon will be created.')
|
|
counts_for_accuracy_qty = fields.Integer(
|
|
string='Inventories for location accuracy calculation',
|
|
default=1,
|
|
help='Number of latest inventories used to calculate location '
|
|
'accuracy')
|
|
|
|
@api.one
|
|
def get_horizon_date(self):
|
|
date = datetime.today()
|
|
delta = timedelta(self.cycle_count_planning_horizon)
|
|
date_horizon = date + delta
|
|
return date_horizon
|
|
|
|
@api.model
|
|
def _get_cycle_count_locations_search_domain(self):
|
|
wh_parent_left = self.view_location_id.parent_left
|
|
wh_parent_right = self.view_location_id.parent_right
|
|
domain = [('parent_left', '>', wh_parent_left),
|
|
('parent_right', '<', wh_parent_right),
|
|
('cycle_count_disabled', '=', False)]
|
|
return domain
|
|
|
|
@api.model
|
|
def _search_cycle_count_locations(self):
|
|
locations = self.env['stock.location'].search(
|
|
self._get_cycle_count_locations_search_domain())
|
|
return locations
|
|
|
|
@api.model
|
|
def _cycle_count_rules_to_compute(self):
|
|
rules = self.cycle_count_rule_ids.search([
|
|
('rule_type', '!=', 'zero')])
|
|
return rules
|
|
|
|
@api.one
|
|
def action_compute_cycle_count_rules(self):
|
|
''' Apply the rule in all the sublocations of a given warehouse(s) and
|
|
returns a list with required dates for the cycle count of each
|
|
location '''
|
|
proposed_cycle_counts = []
|
|
locations = self._search_cycle_count_locations()
|
|
rules = self._cycle_count_rules_to_compute()
|
|
if locations:
|
|
for rule in rules:
|
|
proposed_cycle_counts.extend(rule.compute_rule(locations))
|
|
if proposed_cycle_counts:
|
|
locations = list(set([d['location'] for d in
|
|
proposed_cycle_counts]))
|
|
for loc in locations:
|
|
proposed_for_loc = filter(lambda x: x['location'] == loc,
|
|
proposed_cycle_counts)
|
|
earliest_date = min([d['date'] for d in proposed_for_loc])
|
|
cycle_count_proposed = filter(lambda x: x['date'] ==
|
|
earliest_date,
|
|
proposed_for_loc)[0]
|
|
domain = [('location_id', '=', loc.id),
|
|
('state', 'in', ['draft'])]
|
|
existing_cycle_counts = self.env['stock.cycle.count'].search(
|
|
domain)
|
|
if existing_cycle_counts and cycle_count_proposed['date'] <\
|
|
existing_cycle_counts.date_deadline:
|
|
self.env['stock.cycle.count'].create({
|
|
'date_deadline': cycle_count_proposed['date'],
|
|
'location_id': cycle_count_proposed['location'].id,
|
|
'cycle_count_rule_id': cycle_count_proposed[
|
|
'rule_type'].id,
|
|
'state': 'draft'
|
|
})
|
|
existing_cycle_counts.state = 'cancelled'
|
|
delta = datetime.strptime(
|
|
cycle_count_proposed['date'],
|
|
DEFAULT_SERVER_DATETIME_FORMAT) - datetime.today()
|
|
if not existing_cycle_counts and \
|
|
delta.days < self.cycle_count_planning_horizon:
|
|
self.env['stock.cycle.count'].create({
|
|
'date_deadline': cycle_count_proposed['date'],
|
|
'location_id': cycle_count_proposed['location'].id,
|
|
'cycle_count_rule_id': cycle_count_proposed[
|
|
'rule_type'].id,
|
|
'state': 'draft'
|
|
})
|
|
|
|
@api.model
|
|
def cron_cycle_count(self):
|
|
whs = self.search([])
|
|
whs.action_compute_cycle_count_rules()
|
|
return True
|