1 # -*- coding: utf-8 -*-
2 ##############################################################################
4 # OpenERP, Open Source Management Solution
5 # Copyright (C) 2004-2010 Tiny SPRL (<http://tiny.be>).
7 # This program is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU Affero General Public License as
9 # published by the Free Software Foundation, either version 3 of the
10 # License, or (at your option) any later version.
12 # This program is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU Affero General Public License for more details.
17 # You should have received a copy of the GNU Affero General Public License
18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
20 ##############################################################################
22 from datetime import datetime
23 from dateutil.relativedelta import relativedelta
27 from osv import fields
28 from tools.translate import _
29 from tools import DEFAULT_SERVER_DATE_FORMAT, DEFAULT_SERVER_DATETIME_FORMAT
32 class procurement_order(osv.osv):
33 _inherit = 'procurement.order'
35 def run_scheduler(self, cr, uid, automatic=False, use_new_cursor=False, context=None):
36 ''' Runs through scheduler.
37 @param use_new_cursor: False or the dbname
39 self._procure_confirm(cr, uid, use_new_cursor=use_new_cursor, context=context)
40 self._procure_orderpoint_confirm(cr, uid, automatic=automatic,\
41 use_new_cursor=use_new_cursor, context=context)
43 def _procure_confirm(self, cr, uid, ids=None, use_new_cursor=False, context=None):
45 Call the scheduler to check the procurement order
47 @param self: The object pointer
48 @param cr: The current row, from the database cursor,
49 @param uid: The current user ID for security checks
50 @param ids: List of selected IDs
51 @param use_new_cursor: False or the dbname
52 @param context: A standard dictionary for contextual values
53 @return: Dictionary of values
60 cr = pooler.get_db(use_new_cursor).cursor()
61 wf_service = netsvc.LocalService("workflow")
63 procurement_obj = self.pool.get('procurement.order')
65 ids = procurement_obj.search(cr, uid, [('state', '=', 'exception')], order="date_planned")
67 wf_service.trg_validate(uid, 'procurement.order', id, 'button_restart', cr)
70 company = self.pool.get('res.users').browse(cr, uid, uid, context=context).company_id
71 maxdate = (datetime.today() + relativedelta(days=company.schedule_range)).strftime(tools.DEFAULT_SERVER_DATE_FORMAT)
72 start_date = fields.datetime.now()
79 ids = procurement_obj.search(cr, uid, [('state', '=', 'confirmed'), ('procure_method', '=', 'make_to_order')], offset=offset, limit=500, order='priority, date_planned', context=context)
80 for proc in procurement_obj.browse(cr, uid, ids, context=context):
81 if maxdate >= proc.date_planned:
82 wf_service.trg_validate(uid, 'procurement.order', proc.id, 'button_check', cr)
87 if proc.state == 'exception':
88 report.append(_('PROC %d: on order - %3.2f %-5s - %s') % \
89 (proc.id, proc.product_qty, proc.product_uom.name,
90 proc.product_id.name))
101 ids = procurement_obj.search(cr, uid, [('state', '=', 'confirmed'), ('procure_method', '=', 'make_to_stock')], offset=offset)
102 for proc in procurement_obj.browse(cr, uid, ids):
103 if maxdate >= proc.date_planned:
104 wf_service.trg_validate(uid, 'procurement.order', proc.id, 'button_check', cr)
105 report_ids.append(proc.id)
110 if proc.state == 'exception':
111 report.append(_('PROC %d: from stock - %3.2f %-5s - %s') % \
112 (proc.id, proc.product_qty, proc.product_uom.name,
113 proc.product_id.name,))
121 end_date = fields.datetime.now()
123 # Chatter: old res.request is now a chatter on res.users, id=uid
124 summary = _("""Here is the procurement scheduling report.
128 Total Procurements processed: %d
129 Procurements with exceptions: %d
130 Skipped Procurements (scheduled date outside of scheduler range) %d
132 Exceptions:\n""") % (start_date, end_date, report_total, report_except, report_later)
133 summary += '\n'.join(report)
134 self.pool.get('res.users').message_append_note(cr, uid, [uid], body=summary, context=context)
146 def _prepare_automatic_op_procurement(self, cr, uid, product, warehouse, location_id, context=None):
147 return {'name': _('Automatic OP: %s') % (product.name,),
148 'origin': _('SCHEDULER'),
149 'date_planned': datetime.today().strftime(DEFAULT_SERVER_DATETIME_FORMAT),
150 'product_id': product.id,
151 'product_qty': -product.virtual_available,
152 'product_uom': product.uom_id.id,
153 'location_id': location_id,
154 'company_id': warehouse.company_id.id,
155 'procure_method': 'make_to_order',}
157 def create_automatic_op(self, cr, uid, context=None):
159 Create procurement of virtual stock < 0
161 @param self: The object pointer
162 @param cr: The current row, from the database cursor,
163 @param uid: The current user ID for security checks
164 @param context: A standard dictionary for contextual values
165 @return: Dictionary of values
169 product_obj = self.pool.get('product.product')
170 proc_obj = self.pool.get('procurement.order')
171 warehouse_obj = self.pool.get('stock.warehouse')
172 wf_service = netsvc.LocalService("workflow")
174 warehouse_ids = warehouse_obj.search(cr, uid, [], context=context)
175 products_ids = product_obj.search(cr, uid, [('purchase_ok', '=', True)], order='id', context=context)
177 for warehouse in warehouse_obj.browse(cr, uid, warehouse_ids, context=context):
178 context['warehouse'] = warehouse
179 # Here we check products availability.
180 # We use the method 'read' for performance reasons, because using the method 'browse' may crash the server.
181 for product_read in product_obj.read(cr, uid, products_ids, ['virtual_available'], context=context):
182 if product_read['virtual_available'] >= 0.0:
185 product = product_obj.browse(cr, uid, [product_read['id']], context=context)[0]
186 if product.supply_method == 'buy':
187 location_id = warehouse.lot_input_id.id
188 elif product.supply_method == 'produce':
189 location_id = warehouse.lot_stock_id.id
192 proc_id = proc_obj.create(cr, uid,
193 self._prepare_automatic_op_procurement(cr, uid, product, warehouse, location_id, context=context),
195 wf_service.trg_validate(uid, 'procurement.order', proc_id, 'button_confirm', cr)
196 wf_service.trg_validate(uid, 'procurement.order', proc_id, 'button_check', cr)
199 def _get_orderpoint_date_planned(self, cr, uid, orderpoint, start_date, context=None):
200 date_planned = start_date + \
201 relativedelta(days=orderpoint.product_id.seller_delay or 0.0)
202 return date_planned.strftime(DEFAULT_SERVER_DATE_FORMAT)
204 def _prepare_orderpoint_procurement(self, cr, uid, orderpoint, product_qty, context=None):
205 return {'name': orderpoint.name,
206 'date_planned': self._get_orderpoint_date_planned(cr, uid, orderpoint, datetime.today(), context=context),
207 'product_id': orderpoint.product_id.id,
208 'product_qty': product_qty,
209 'company_id': orderpoint.company_id.id,
210 'product_uom': orderpoint.product_uom.id,
211 'location_id': orderpoint.location_id.id,
212 'procure_method': 'make_to_order',
213 'origin': orderpoint.name}
215 def _procure_orderpoint_confirm(self, cr, uid, automatic=False,\
216 use_new_cursor=False, context=None, user_id=False):
218 Create procurement based on Orderpoint
219 use_new_cursor: False or the dbname
221 @param self: The object pointer
222 @param cr: The current row, from the database cursor,
223 @param user_id: The current user ID for security checks
224 @param context: A standard dictionary for contextual values
225 @param param: False or the dbname
226 @return: Dictionary of values
232 cr = pooler.get_db(use_new_cursor).cursor()
233 orderpoint_obj = self.pool.get('stock.warehouse.orderpoint')
234 location_obj = self.pool.get('stock.location')
235 procurement_obj = self.pool.get('procurement.order')
236 wf_service = netsvc.LocalService("workflow")
241 self.create_automatic_op(cr, uid, context=context)
243 ids = orderpoint_obj.search(cr, uid, [], offset=offset, limit=100)
244 for op in orderpoint_obj.browse(cr, uid, ids, context=context):
245 if op.procurement_id.state != 'exception':
246 if op.procurement_id and op.procurement_id.purchase_id and op.procurement_id.purchase_id.state in ('draft', 'confirmed'):
248 prods = location_obj._product_virtual_get(cr, uid,
249 op.location_id.id, [op.product_id.id],
250 {'uom': op.product_uom.id})[op.product_id.id]
252 if prods < op.product_min_qty:
253 qty = max(op.product_min_qty, op.product_max_qty)-prods
255 reste = qty % op.qty_multiple
257 qty += op.qty_multiple - reste
261 if op.product_id.type not in ('consu'):
262 if op.procurement_draft_ids:
263 # Check draft procurement related to this order point
264 pro_ids = [x.id for x in op.procurement_draft_ids]
265 procure_datas = procurement_obj.read(
266 cr, uid, pro_ids, ['id', 'product_qty'], context=context)
268 for proc_data in procure_datas:
269 if to_generate >= proc_data['product_qty']:
270 wf_service.trg_validate(uid, 'procurement.order', proc_data['id'], 'button_confirm', cr)
271 procurement_obj.write(cr, uid, [proc_data['id']], {'origin': op.name}, context=context)
272 to_generate -= proc_data['product_qty']
278 proc_id = procurement_obj.create(cr, uid,
279 self._prepare_orderpoint_procurement(cr, uid, op, qty, context=context),
281 wf_service.trg_validate(uid, 'procurement.order', proc_id,
282 'button_confirm', cr)
283 wf_service.trg_validate(uid, 'procurement.order', proc_id,
285 orderpoint_obj.write(cr, uid, [op.id],
286 {'procurement_id': proc_id}, context=context)
290 if user_id and report:
291 # Chatter: old res.request is now a chatter on res.users, id=uid
292 self.pool.get('res.users').message_append_note(cr, uid, [user_id], body='\n'.join(report), subject=_('Orderpoint report'), context=context)
300 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: