# -*- encoding: utf-8 -*- ############################################################################## # # Copyright (C) 2015 ICTSTUDIO (<http://www.ictstudio.eu>). # # 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/>. # ############################################################################## from openerp import models, fields, api, _ from openerp.exceptions import Warning from openerp.tools import float_compare import logging _logger = logging.getLogger(__name__) class StockWarehouseTransfer(models.Model): _name = 'stock.warehouse.transfer' _description = 'Stock Warehouse Transfer' _inherit = ['mail.thread', 'ir.needaction_mixin'] @api.model def _get_default_name(self): return self.env['ir.sequence'].get('stock.warehouse.transfer') @api.model def _get_default_date(self): return fields.Date.context_today(self) @api.model def _get_default_state(self): return 'draft' @api.multi @api.depends('pickings.state') def _calc_transfer_state(self): for rec in self: if rec.pickings: picking_states = [p.state for p in rec.pickings] if 'done' in picking_states: rec.state = 'done' else: rec.state = 'draft' name = fields.Char( string='Referencia', default=_get_default_name) date = fields.Date( string='Fecha', default=_get_default_date) source_warehouse = fields.Many2one( comodel_name='stock.warehouse', string='Déposito de Origen') dest_warehouse = fields.Many2one( comodel_name='stock.warehouse', string='Déposito de Destino') state = fields.Selection( selection=[ ('draft', 'Borrador'), ('done', 'Hecho')], string='Status', default=_get_default_state, store=True, compute=_calc_transfer_state) lines = fields.One2many( comodel_name='stock.warehouse.transfer.line', inverse_name='transfer', string='Lineas de Transferencia') pickings = fields.One2many( comodel_name='stock.picking', inverse_name='transfer', string='Transferencia Relacionada') company_id = fields.Many2one( comodel_name='res.company', string='Compania', required=True, default=lambda self: self.env['res.company']._company_default_get( 'stock.warehouse.transfer')) def get_transfer_picking_type(self): self.ensure_one() picking_types = self.env['stock.picking.type'].search( [ ('default_location_src_id', '=', self.source_warehouse.lot_stock_id.id), ('code', '=', 'outgoing') ] ) if not picking_types: _logger.error("No picking type found") #TODO: Exception Raise return picking_types and picking_types[0] @api.multi def get_picking_vals(self): self.ensure_one() picking_type = self.get_transfer_picking_type() picking_vals = { 'picking_type_id' : picking_type.id, 'transfer' : self.id, 'origin': self.name } return picking_vals @api.multi def action_create_picking(self): for rec in self: picking_vals = rec.get_picking_vals() _logger.debug("Picking Vals: %s", picking_vals) picking = rec.pickings.create(picking_vals) if not picking: _logger.error("Error Creating Picking") #TODO: Add Exception pc_group = rec._get_procurement_group() for line in rec.lines: move_vals = line.get_move_vals(picking, pc_group) if move_vals: _logger.debug("Move Vals: %s", move_vals) product = self.env['product.product'].browse(move_vals['product_id']) location = self.env['stock.location'].browse(move_vals['location_id']) uom = self.env['stock.location'].browse(move_vals['location_id']) if product.type == 'product': uom_record = product.uom_id qty_available = self.get_location_qty(product.id, move_vals['location_id']) compare_qty = float_compare(qty_available, move_vals['product_uom_qty'], precision_rounding=uom_record.rounding) if compare_qty == -1: warn_msg = _('Estas intentando transferir %.2f %s de %s pero el déposito de origen posee %.2f %s disponible!') % \ (move_vals['product_uom_qty'], uom_record.name, product.name, max(0,qty_available), uom_record.name) raise Warning(_("No hay stock suficiente: "),_(warn_msg)) move_id = self.env['stock.move'].create(move_vals) move_id.action_done() @api.multi def get_location_qty(self, product_id, location_id): location_ids = self.env['stock.location'].search([('active','=',True),('usage','=','internal')]) for id in location_ids: suma = 0 quant_ids = self.env['stock.quant'].search([('product_id','=', product_id),('location_id','=',location_id)]) if quant_ids: for quant_id in quant_ids: suma = suma + quant_id.qty return suma @api.model def _prepare_procurement_group(self): return {'name': self.name} @api.model def _get_procurement_group(self): pc_groups = self.env['procurement.group'].search( [ ('name', '=', self.name) ] ) if pc_groups: pc_group = pc_groups[0] else: pc_vals = self._prepare_procurement_group() pc_group = self.env['procurement.group'].create(pc_vals) return pc_group or False