From 8b35f2370134cfe2c24e9db309fc5bd9aa605997 Mon Sep 17 00:00:00 2001
From: Martin Trigaux <mat@openerp.com>
Date: Thu, 21 Nov 2013 16:28:23 +0100
Subject: [PATCH] [ADD] procurement: add skip_exception parameter on scheduler
 allowing to have more frequent scheduler only testing confirmed picking

bzr revid: mat@openerp.com-20131121152823-vphwy0jv9b02ajk2
---
 addons/procurement/procurement_data.xml | 12 ++++++++++++
 addons/procurement/schedulers.py        | 18 ++++++++++--------
 2 files changed, 22 insertions(+), 8 deletions(-)

diff --git a/addons/procurement/procurement_data.xml b/addons/procurement/procurement_data.xml
index 52503e76c44..d8bd6c37dc3 100644
--- a/addons/procurement/procurement_data.xml
+++ b/addons/procurement/procurement_data.xml
@@ -14,6 +14,18 @@
             <field eval="'run_scheduler'" name="function"/>
             <field eval="'(False,True)'" name="args"/>
         </record>
+        <record forcecreate="True" id="ir_cron_scheduler_action_fast" model="ir.cron">
+            <field name="name">Run fast mrp scheduler (without exception)</field>
+            <field eval="False" name="active"/>
+            <field name="user_id" ref="base.user_root"/>
+            <field name="interval_number">4</field>
+            <field name="interval_type">hours</field>
+            <field name="numbercall">-1</field>
+            <field eval="False" name="doall"/>
+            <field eval="'procurement.order'" name="model"/>
+            <field eval="'run_scheduler'" name="function"/>
+            <field eval="'(False,True,True)'" name="args"/>
+        </record>
         
         <record id="sequence_mrp_op_type" model="ir.sequence.type">
             <field name="name">Stock orderpoint</field>
diff --git a/addons/procurement/schedulers.py b/addons/procurement/schedulers.py
index 6f326ccf1c5..cd6388743ee 100644
--- a/addons/procurement/schedulers.py
+++ b/addons/procurement/schedulers.py
@@ -32,17 +32,17 @@ from openerp import tools
 class procurement_order(osv.osv):
     _inherit = 'procurement.order'
 
-    def run_scheduler(self, cr, uid, automatic=False, use_new_cursor=False, context=None):
+    def run_scheduler(self, cr, uid, automatic=False, use_new_cursor=False, skip_exception=False, context=None):
         ''' Runs through scheduler.
         @param use_new_cursor: False or the dbname
         '''
         if use_new_cursor:
             use_new_cursor = cr.dbname
-        self._procure_confirm(cr, uid, use_new_cursor=use_new_cursor, context=context)
+        self._procure_confirm(cr, uid, use_new_cursor=use_new_cursor, skip_exception=skip_exception, context=context)
         self._procure_orderpoint_confirm(cr, uid, automatic=automatic,\
                 use_new_cursor=use_new_cursor, context=context)
 
-    def _procure_confirm(self, cr, uid, ids=None, use_new_cursor=False, context=None):
+    def _procure_confirm(self, cr, uid, ids=None, use_new_cursor=False, skip_exception=False, context=None):
         '''
         Call the scheduler to check the procurement order
 
@@ -51,6 +51,7 @@ class procurement_order(osv.osv):
         @param uid: The current user ID for security checks
         @param ids: List of selected IDs
         @param use_new_cursor: False or the dbname
+        @param skip_exception: boolean
         @param context: A standard dictionary for contextual values
         @return:  Dictionary of values
         '''
@@ -61,11 +62,12 @@ class procurement_order(osv.osv):
                 cr = openerp.registry(use_new_cursor).db.cursor()
 
             procurement_obj = self.pool.get('procurement.order')
-            if not ids:
-                ids = procurement_obj.search(cr, uid, [('state', '=', 'exception')], order="date_planned")
-            self.signal_button_restart(cr, uid, ids)
-            if use_new_cursor:
-                cr.commit()
+            if not skip_exception:
+                if not ids:
+                    ids = procurement_obj.search(cr, uid, [('state', '=', 'exception')], order="date_planned")
+                self.signal_button_restart(cr, uid, ids)
+                if use_new_cursor:
+                    cr.commit()
             company = self.pool.get('res.users').browse(cr, uid, uid, context=context).company_id
             maxdate = (datetime.today() + relativedelta(days=company.schedule_range)).strftime(tools.DEFAULT_SERVER_DATE_FORMAT)
             start_date = fields.datetime.now()