Merge lp:~unifield-team/unifield-wm/uftp-326 into lp:unifield-wm

[jftempo]

=== modified file '.bzrignore'
--- .bzrignore	2014-10-09 06:56:59 +0000
+++ .bzrignore	2014-10-29 08:35:37 +0000
@@ -1,1 +1,2 @@
 unifield_tests/output.html
+unifield.config

=== modified file 'delivery_mechanism/wizard/enter_reason.py'
--- delivery_mechanism/wizard/enter_reason.py	2014-08-04 15:19:38 +0000
+++ delivery_mechanism/wizard/enter_reason.py	2014-10-29 08:35:37 +0000
@@ -76,9 +76,8 @@
                     pol_qty[move.purchase_line_id.id] += move.product_qty
 
             # if full cancel (no resource), we updated corresponding out and correct po state
-            if cancel_type == 'update_out':
-                picking_obj.cancel_and_update_out(cr, uid, [obj.id], context=context)
-            else:
+            picking_obj.cancel_and_update_out(cr, uid, [obj.id], context=context)
+            if cancel_type != 'update_out':
                 context['pol_qty'] = pol_qty
                 pol_obj.write(cr, uid, pol_ids, {'has_to_be_resourced': True}, context=context)
                 pol_obj.cancel_sol(cr, uid, pol_ids, context=context)

=== modified file 'msf_outgoing/msf_outgoing.py'
--- msf_outgoing/msf_outgoing.py	2014-09-26 13:09:16 +0000
+++ msf_outgoing/msf_outgoing.py	2014-10-29 08:35:37 +0000
@@ -4151,9 +4151,11 @@
             pick_state = move.picking_id.state
             subtype_ok = pick_type == 'out' and (pick_subtype == 'standard' or (pick_subtype == 'picking' and pick_state == 'draft'))
 
-            if pick_type == 'in' and move.purchase_line_id and not pick_cancel:
+            if pick_type == 'in' and move.purchase_line_id:
                 sol_ids = pol_obj.get_sol_ids_from_pol_ids(cr, uid, [move.purchase_line_id.id], context=context)
                 for sol in sol_obj.browse(cr, uid, sol_ids, context=context):
+                    if sol.order_id.procurement_request:
+                        continue
                     diff_qty = uom_obj._compute_qty(cr, uid, move.product_uom.id, move.product_qty, sol.product_uom.id)
                     if move.has_to_be_resourced or move.picking_id.has_to_be_resourced:
                         sol_obj.add_resource_line(cr, uid, sol.id, False, diff_qty, context=context)

=== modified file 'msf_outgoing/wizard/incoming_shipment_processor.py'
--- msf_outgoing/wizard/incoming_shipment_processor.py	2014-09-29 15:30:49 +0000
+++ msf_outgoing/wizard/incoming_shipment_processor.py	2014-10-29 08:35:37 +0000
@@ -152,6 +152,9 @@
         picking_obj = self.pool.get('stock.picking')
         data_obj = self.pool.get('ir.model.data')
 
+        if context is None:
+            context = {}
+
         if not ids:
             raise osv.except_osv(
                 _('Error'),

=== modified file 'sale_override/sale.py'
--- sale_override/sale.py	2014-10-14 14:46:33 +0000
+++ sale_override/sale.py	2014-10-29 08:35:37 +0000
@@ -2300,7 +2300,7 @@
                 proc_obj.write(cr, uid, [proc], {'product_qty': minus_qty}, context=context)
 
         so_to_cancel_id = False
-        if so_obj._get_ready_to_cancel(cr, uid, order, context=context)[order]:
+        if context.get('cancel_type', False) != 'update_out' and so_obj._get_ready_to_cancel(cr, uid, order, context=context)[order]:
             so_to_cancel_id = order
         else:
             wf_service.trg_write(uid, 'sale.order', order, cr)

=== modified file 'stock_override/stock.py'
--- stock_override/stock.py	2014-09-22 14:41:45 +0000
+++ stock_override/stock.py	2014-10-29 08:35:37 +0000
@@ -581,6 +581,13 @@
         # Variables
         wf_service = netsvc.LocalService("workflow")
 
+        if isinstance(ids, (int, long)):
+            ids = [ids]
+
+        if context is None:
+            context = {}
+
+        context['cancel_type'] = 'update_out'
         res = super(stock_picking, self).action_cancel(cr, uid, ids, context=context)
 
         # Re-source the sale.order.line

=== modified file 'unifield_tests/master_data/020_partners.yml'
--- unifield_tests/master_data/020_partners.yml	2014-10-10 08:02:07 +0000
+++ unifield_tests/master_data/020_partners.yml	2014-10-29 08:35:37 +0000
@@ -53,6 +53,8 @@
     supplier: 1
     customer: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external supplier 1
 -
@@ -67,6 +69,8 @@
     supplier: 1
     customer: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external supplier 2
 -
@@ -81,6 +85,8 @@
     supplier: 1
     customer: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external supplier 3
 -
@@ -97,6 +103,8 @@
     customer: 1
     supplier: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external customer 1
 -
@@ -111,6 +119,8 @@
     customer: 1
     supplier: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external customer 2
 -
@@ -125,6 +135,8 @@
     customer: 1
     supplier: 0
     partner_type: 'external'
+    property_account_receivable: account_account_receivable_supplier0
+    property_account_payable: account_account_payable_supplier0
 -
   Create an address for external customer 3
 -

=== modified file 'unifield_tests/tests/connection.py'
--- unifield_tests/tests/connection.py	2014-03-18 13:19:21 +0000
+++ unifield_tests/tests/connection.py	2014-10-29 08:35:37 +0000
@@ -54,6 +54,7 @@
         # Login initialization
         db_name = '%s%s' % (db_prefix, db_suffix)
         self.login(uid, pwd, db_name)
+        self.db_name = db_name
 
 if __name__ == '__main__':
     c = XMLRPCConnection('HQ1C1P1')

=== modified file 'unifield_tests/tests/resourcing.py'
--- unifield_tests/tests/resourcing.py	2014-10-15 09:18:02 +0000
+++ unifield_tests/tests/resourcing.py	2014-10-29 08:35:37 +0000
@@ -53,7 +53,10 @@
         :return True
         :rtype bool
         """
-        pr = self.order_obj.browse(order_to_check).procurement_request
+        order_obj = db.get('sale.order')
+        proc_obj = db.get('procurement.order')
+
+        pr = order_obj.browse(order_to_check).procurement_request
 
         new_order_id = None
         if pr:
@@ -61,15 +64,15 @@
         else:
             state = 'done'
 
-        order_state = self.order_obj.read(order_to_check, ['state'])['state']
+        order_state = order_obj.read(order_to_check, ['state'])['state']
         while order_state != state:
             time.sleep(0.5)
-            order_state = self.order_obj.read(order_to_check, ['state'])['state']
+            order_state = order_obj.read(order_to_check, ['state'])['state']
 
         if pr:
             new_order_id = order_to_check
         else:
-            new_order_ids = self.order_obj.search([
+            new_order_ids = order_obj.search([
                 ('original_so_id_sale_order', '=', order_to_check)
             ])
 
@@ -78,7 +81,7 @@
             if new_order_ids:
                 new_order_id = new_order_ids[0]
 
-        self.proc_obj.run_scheduler()
+        proc_obj.run_scheduler()
 
         return new_order_id
 
@@ -98,7 +101,6 @@
 
         # Prepare values for the field order
         partner_id = self.get_record(db, 'ext_customer_1')
-        p_addr_id = self.get_record(db, 'ext_customer_1_addr')
         order_type = 'regular'
 
         change_vals = self.order_obj.\
@@ -378,4 +380,62 @@
         else:
             return self._get_number_of_fo_valid_lines(db, order_id)
 
+    def create_analytic_distribution(self, db):
+        """
+        Create an analytic distribution
+        :param db: Connection on which the distribution must be created
+        :return: The ID of distribution
+        """
+        distrib_obj = db.get('analytic.distribution')
+        cc_line_obj = db.get('cost.center.distribution.line')
+        fp_line_obj = db.get('funding.pool.distribution.line')
+
+        distrib_id = distrib_obj.create({
+            'name': 'Distrib 2',
+        })
+
+        cc_line1_id = cc_line_obj.create({
+            'name': 'CC Line 1',
+            'amount': 0.0,
+            'percentage': 75.0,
+            'currency_id': self.get_record(db, 'EUR', module='base'),
+            'analytic_id': self.get_record(db, 'analytic_cc1'),
+            'distribution_id': distrib_id,
+            'destination_id': self.get_record(db, 'analytic_account_destination_operation', module='analytic_distribution'),
+        })
+
+        cc_line2_id = cc_line_obj.create({
+            'name': 'CC Line 2',
+            'amount': 0.0,
+            'percentage': 25.0,
+            'currency_id': self.get_record(db, 'EUR', module='base'),
+            'analytic_id': self.get_record(db, 'analytic_cc2'),
+            'distribution_id': distrib_id,
+            'destination_id': self.get_record(db, 'analytic_account_destination_operation', module='analytic_distribution'),
+        })
+
+        fp_line1_id = fp_line_obj.create({
+            'name': 'FP Line 1',
+            'amount': 0.0,
+            'percentage': 75.0,
+            'currency_id': self.get_record(db, 'EUR', module='base'),
+            'analytic_id': self.get_record(db, 'analytic_cc1'),
+            'distribution_id': distrib_id,
+            'cost_center_id': self.get_record(db, 'analytic_cc1'),
+            'destination_id': self.get_record(db, 'analytic_account_destination_operation', module='analytic_distribution'),
+        })
+
+        fp_line2_id = fp_line_obj.create({
+            'name': 'FP Line 2',
+            'amount': 0.0,
+            'percentage': 25.0,
+            'currency_id': self.get_record(db, 'EUR', module='base'),
+            'analytic_id': self.get_record(db, 'analytic_cc2'),
+            'distribution_id': distrib_id,
+            'cost_center_id': self.get_record(db, 'analytic_cc1'),
+            'destination_id': self.get_record(db, 'analytic_account_destination_operation', module='analytic_distribution'),
+        })
+
+        return distrib_id
+
 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== added file 'unifield_tests/tests/test_uftp_324.py'
--- unifield_tests/tests/test_uftp_324.py	1970-01-01 00:00:00 +0000
+++ unifield_tests/tests/test_uftp_324.py	2014-10-29 08:35:37 +0000
@@ -0,0 +1,195 @@
+#!/usr/bin/env python
+# -*- coding: utf8 -*-
+
+__author__ = 'qt'
+
+from resourcing import ResourcingTest
+
+import time
+
+
+class UFTP324Test(ResourcingTest):
+
+    def setUp(self):
+        """
+        Create a PO at Project side to Coordo with
+        two lines.
+        :return:
+        """
+
+        super(UFTP324Test, self).setUp()
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+
+        # C1
+        self.c_so_obj = self.c1.get('sale.order')
+        self.c_sol_obj = self.c1.get('sale.order.line')
+        self.c_po_obj = self.c1.get('purchase.order')
+        self.c_pol_obj = self.c1.get('purchase.order.line')
+        self.c_partner_obj = self.c1.get('res.partner')
+        self.c_lc_obj = self.c1.get('sale.order.leave.close')
+        self.c_so_cancel_obj = self.c1.get('sale.order.cancelation.wizard')
+
+        # P1
+        self.p_so_obj = self.p1.get('sale.order')
+        self.p_sol_obj = self.p1.get('sale.order.line')
+        self.p_po_obj = self.p1.get('purchase.order')
+        self.p_pol_obj = self.p1.get('purchase.order.line')
+        self.p_partner_obj = self.p1.get('res.partner')
+        self.p_lc_obj = self.p1.get('sale.order.leave.close')
+        self.p_so_cancel_obj = self.p1.get('sale.order.cancelation.wizard')
+
+        # Create a PO at P1 with two products to C1
+        # Prepare values for the field order
+        prod_log1_id = self.get_record(self.p1, 'prod_log_1')
+        prod_log2_id = self.get_record(self.p1, 'prod_log_2')
+        uom_pce_id = self.get_record(self.p1, 'product_uom_unit', module='product')
+        location_id = self.get_record(self.p1, 'stock_location_stock', module='stock')
+
+        partner_name = self.get_db_partner_name(self.c1)
+        partner_ids = self.p_partner_obj.search([('name', '=', partner_name)])
+        self.assert_(
+            partner_ids,
+            "No partner found for %s" % self.c1.db_name,
+        )
+
+        distrib_id = self.create_analytic_distribution(self.p1)
+
+        order_values = {
+            'order_type': 'regular',
+            'partner_id': partner_ids[0],
+            'rfq_ok': False,
+            'location_id': location_id,
+            'analytic_distribution_id': distrib_id,
+        }
+
+        change_vals = self.p_po_obj.\
+            onchange_partner_id(None, partner_ids[0], time.strftime('%Y-%m-%d')).get('value', {})
+        order_values.update(change_vals)
+
+        self.p_po_id = self.p_po_obj.create(order_values)
+
+        # Create order lines
+        # First line
+        line_values = {
+            'order_id': self.p_po_id,
+            'product_id': prod_log1_id,
+            'product_uom': uom_pce_id,
+            'product_qty': 10.0,
+            'price_unit': 10.00,
+            'type': 'make_to_order',
+        }
+        self.p_pol_obj.create(line_values)
+
+        # Second line
+        line_values.update({
+            'product_id': prod_log2_id,
+            'product_uom_qty': 20.0,
+            'price_unit': 10.0,
+        })
+        self.p_pol_obj.create(line_values)
+
+        # Validate the sale order
+        self.p1.exec_workflow('purchase.order', 'purchase_confirm', self.p_po_id)
+
+        self.p_po_name = self.p_po_obj.read(self.p_po_id, ['name'])['name']
+
+        # Synchronize
+        self.synchronize(self.p1)
+        self.synchronize(self.c1)
+
+        self.c_so_id = None
+
+        c_so_ids = self.c_so_obj.search([('client_order_ref', 'like', self.p_po_name)])
+        for c_so_id in c_so_ids:
+            self.assert_(
+                self.c_so_obj.read(c_so_id, ['state'])['state'] == 'draft',
+                "The FO at Coordo is not 'Draft'.",
+            )
+            self.c_so_id = c_so_id
+
+        # Validate the sale order
+        self.c1.exec_workflow('sale.order', 'order_validated', self.c_so_id)
+
+        # Source all lines on a Purchase Order to ext_supplier_1
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        self.c_sol_obj.write(line_ids, {
+            'type': 'make_to_order',
+            'po_cft': 'po',
+            'supplier': self.get_record(self.c1, 'ext_supplier_1'),
+        })
+        self.c_sol_obj.confirmLine(line_ids)
+
+        # Run the scheduler
+        self.c_so_id = self.run_auto_pos_creation(self.c1, order_to_check=self.c_so_id)
+
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        not_sourced = True
+        while not_sourced:
+            not_sourced = False
+            for line in self.c_sol_obj.browse(line_ids):
+                if line.procurement_id and line.procurement_id.state != 'running':
+                    not_sourced = True
+            if not_sourced:
+                time.sleep(1)
+
+        po_ids = set()
+        po_line_ids = []
+        for line in self.c_sol_obj.browse(line_ids):
+            if line.procurement_id:
+                po_line_ids.extend(self.c_pol_obj.search([
+                    ('procurement_id', '=', line.procurement_id.id),
+                ]))
+
+        for po_line in self.c_pol_obj.read(po_line_ids, ['order_id']):
+            po_ids.add(po_line['order_id'][0])
+
+            self.c_po_id = po_line['order_id'][0]
+
+    def test_utp_324(self):
+        """
+        Cancel the PO at coordo side, synchronize and check the state of the PO at
+        project side.
+        :return:
+        """
+        wiz_model = 'purchase.order.cancel.wizard'
+        c_wiz_obj = self.c1.get(wiz_model)
+        c_lc_wiz_obj = self.c1.get('sale.order.leave.close')
+        c_cancel_so_wiz_obj = self.c1.get('sale.order.cancelation.wizard')
+
+        # Cancel PO at coordo side
+        c_res = self.c_po_obj.purchase_cancel(self.c_po_id)
+        # Validate cancellation
+        w_res = c_wiz_obj.cancel_po(c_res.get('res_id'))
+        # Close the FO
+        w_line_ids = c_lc_wiz_obj.search([
+            ('wizard_id', '=', w_res.get('res_id')),
+            ('order_id', '=', self.c_so_id),
+        ])
+
+
+        # Choose close it
+        c_lc_wiz_obj.write(w_line_ids, {'action': 'close'})
+        c_cancel_so_wiz_obj.close_fo(w_res.get('res_id'))
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+
+        # Check state of the PO at project side
+        c_so_name = self.c_so_obj.read(self.c_so_id, ['name'])['name']
+        self.p_po_id = self.p_po_obj.search([('partner_ref', 'like', c_so_name)])[0]
+        p_po_state = self.p_po_obj.read(self.p_po_id, ['state'])['state']
+        self.assert_(
+            p_po_state == 'done',
+            "The PO at project side is not closed",
+        )
+        # Check number of lines in PO at project side
+        p_po_line_ids = self.p_pol_obj.search([('order_id', '=', self.p_po_id)])
+        self.assert_(
+            len(p_po_line_ids) == 0,
+            "There is always lines in PO at project side"
+        )
+
+def get_test_class():
+    return UFTP324Test
\ No newline at end of file

=== added file 'unifield_tests/tests/test_uftp_326.py'
--- unifield_tests/tests/test_uftp_326.py	1970-01-01 00:00:00 +0000
+++ unifield_tests/tests/test_uftp_326.py	2014-10-29 08:35:37 +0000
@@ -0,0 +1,266 @@
+#!/usr/bin/env python
+# -*- coding: utf8 -*-
+
+__author__ = 'qt'
+
+from resourcing import ResourcingTest
+
+import time
+
+
+class UFTP326Test(ResourcingTest):
+
+    def setUp(self):
+        """
+        Create a PO at Project side to Coordo with
+        two lines.
+        :return:
+        """
+        super(UFTP326Test, self).setUp()
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+
+        # C1
+        self.c_so_obj = self.c1.get('sale.order')
+        self.c_sol_obj = self.c1.get('sale.order.line')
+        self.c_po_obj = self.c1.get('purchase.order')
+        self.c_pol_obj = self.c1.get('purchase.order.line')
+        self.c_partner_obj = self.c1.get('res.partner')
+        self.c_lc_obj = self.c1.get('sale.order.leave.close')
+        self.c_so_cancel_obj = self.c1.get('sale.order.cancelation.wizard')
+        self.c_pick_obj = self.c1.get('stock.picking')
+        self.c_enter_reason_obj = self.c1.get('enter.reason')
+
+        # Prepare values for the field order
+        prod_log1_id = self.get_record(self.c1, 'prod_log_1')
+        prod_log2_id = self.get_record(self.c1, 'prod_log_2')
+        uom_pce_id = self.get_record(self.c1, 'product_uom_unit', module='product')
+
+        partner_name = self.get_db_partner_name(self.p1)
+        partner_ids = self.c_partner_obj.search([('name', '=', partner_name)])
+        self.assert_(
+            partner_ids,
+            "No partner found for %s" % self.p1.db_name,
+        )
+
+        distrib_id = self.create_analytic_distribution(self.c1)
+
+        order_values = {
+            'order_type': 'regular',
+            'partner_id': partner_ids[0],
+            'procurement_request': False,
+            'analytic_distribution_id': distrib_id,
+        }
+
+        change_vals = self.c_so_obj.\
+            onchange_partner_id(None, partner_ids[0], 'regular').get('value', {})
+        order_values.update(change_vals)
+
+        order_values['ready_to_ship_date'] = time.strftime('%Y-%m-%d')
+
+        self.c_so_id = self.c_so_obj.create(order_values)
+
+        # Create order lines
+        # First line
+        line_values = {
+            'order_id': self.c_so_id,
+            'product_id': prod_log1_id,
+            'product_uom': uom_pce_id,
+            'product_uom_qty': 10.0,
+            'type': 'make_to_order',
+        }
+        self.c_sol_obj.create(line_values)
+
+        # Second line
+        line_values.update({
+            'product_id': prod_log2_id,
+            'product_uom_qty': 20.0,
+        })
+        self.c_sol_obj.create(line_values)
+
+        # Validate the sale order
+        self.c1.exec_workflow('sale.order', 'order_validated', self.c_so_id)
+
+        # Source all lines on a Purchase Order to ext_supplier_1
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        self.c_sol_obj.write(line_ids, {
+            'po_cft': 'po',
+            'supplier': self.get_record(self.c1, 'ext_supplier_1'),
+        })
+        self.c_sol_obj.confirmLine(line_ids)
+
+        # Run the scheduler
+        self.c_so_id = self.run_auto_pos_creation(self.c1, order_to_check=self.c_so_id)
+
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        not_sourced = True
+        while not_sourced:
+            not_sourced = False
+            for line in self.c_sol_obj.browse(line_ids):
+               if line.procurement_id and line.procurement_id.state != 'running':
+                    not_sourced = True
+            if not_sourced:
+                time.sleep(1)
+
+        po_ids = set()
+        po_line_ids = []
+        for line in self.c_sol_obj.browse(line_ids):
+            if line.procurement_id:
+                po_line_ids.extend(self.c_pol_obj.search([
+                    ('procurement_id', '=', line.procurement_id.id),
+                ]))
+
+        for po_line in self.c_pol_obj.read(po_line_ids, ['order_id']):
+            po_ids.add(po_line['order_id'][0])
+
+        self.c_po_id = po_ids and list(po_ids)[0] or False
+        self.c_so_name = self.c_so_obj.read(self.c_so_id, ['name'])['name']
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+        self.synchronize(self.c1)
+
+        # P1
+        self.p_so_obj = self.p1.get('sale.order')
+        self.p_sol_obj = self.p1.get('sale.order.line')
+        self.p_po_obj = self.p1.get('purchase.order')
+        self.p_pol_obj = self.p1.get('purchase.order.line')
+        self.p_partner_obj = self.p1.get('res.partner')
+        self.p_lc_obj = self.p1.get('sale.order.leave.close')
+        self.p_so_cancel_obj = self.p1.get('sale.order.cancelation.wizard')
+
+        self.p_po_id = None
+
+        p_po_ids = self.p_po_obj.search([('partner_ref', 'like', self.c_so_name)])
+        for p_po_id in p_po_ids:
+            self.assert_(
+                self.p_po_obj.read(p_po_id, ['state'])['state'] == 'sourced',
+                "The PO at Project is '%s' - Should be 'sourced'." % self.p_po_obj.read(p_po_id, ['state'])['state'],
+            )
+            self.p_po_id = p_po_id
+
+    def test_cancel_po_at_coordo(self):
+        """
+        Cancel the PO at coordo side.
+        Check if the PO at project side is canceled.
+        :return:
+        """
+        wiz_model = 'purchase.order.cancel.wizard'
+        c_wiz_obj = self.c1.get(wiz_model)
+        c_lc_wiz_obj = self.c1.get('sale.order.leave.close')
+        c_cancel_so_wiz_obj = self.c1.get('sale.order.cancelation.wizard')
+
+        # Cancel PO at coordo side
+        c_res = self.c_po_obj.purchase_cancel(self.c_po_id)
+        # Validate cancellation
+        w_res = c_wiz_obj.cancel_po(c_res.get('res_id'))
+        # Close the FO
+        w_line_ids = c_lc_wiz_obj.search([
+            ('wizard_id', '=', w_res.get('res_id')),
+            ('order_id', '=', self.c_so_id),
+        ])
+
+
+        # Choose close it
+        c_lc_wiz_obj.write(w_line_ids, {'action': 'close'})
+        c_cancel_so_wiz_obj.close_fo(w_res.get('res_id'))
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+
+        # Check state of the PO at project side
+        p_po_state = self.p_po_obj.read(self.p_po_id, ['state'])['state']
+        self.assert_(
+            p_po_state == 'done',
+            "The PO at project side is not closed",
+        )
+        # Check number of lines in PO at project side
+        p_po_line_ids = self.p_pol_obj.search([('order_id', '=', self.p_po_id)])
+        self.assert_(
+            len(p_po_line_ids) == 0,
+            "There is always lines in PO at project side"
+        )
+
+    def cancel_or_resource_in_at_coordo(self, resource=False):
+        """
+        Cancel or Cancel & Resource the IN at coordo side.
+        Check if the PO and the FO at coordo side are canceled.
+        Check if the PO at project side is canceled.
+        :return:
+        """
+        # Validate and confirm the PO
+        self._validate_po(self.c1, [self.c_po_id])
+        self._confirm_po(self.c1, [self.c_po_id])
+
+        # Get the IN associated to this PO
+        c_in_ids = self.c_pick_obj.search([('purchase_id', '=', self.c_po_id), ('type', '=', 'in')])
+        c_out_ids = self.c_pick_obj.search([('sale_id', '=', self.c_so_id), ('type', '=', 'out')])
+        self.assert_(
+            len(c_in_ids) == 1,
+            "There are %s IN associated to PO - Should be 1" % len(c_in_ids),
+        )
+        self.assert_(
+            len(c_out_ids) == 1,
+            "There are %s OUT/PICK associated to FO - Should be 1" % len(c_out_ids),
+        )
+
+        # Cancel the IN
+        wiz_id = self.c_enter_reason_obj.create({
+            'picking_id': c_in_ids[0],
+            'change_reason': 'test_cancel_in_at_coordo',
+        })
+        ctx = {
+            'active_ids': c_in_ids,
+        }
+        if not resource:
+            ctx['cancel_type'] = 'update_out'
+
+        self.c_enter_reason_obj.do_cancel([wiz_id], ctx)
+
+        # Check IN and OUT states
+        in_state = self.c_pick_obj.read(c_in_ids, ['state'])
+        out_state = self.c_pick_obj.read(c_out_ids, ['state'])
+        self.assert_(
+            all([x['state'] == 'cancel' for x in in_state]),
+            "All IN are not canceled",
+        )
+        self.assert_(
+            all([x['state'] == 'cancel' for x in out_state]),
+            "All OUT/PICK are not canceled",
+        )
+
+        # Check PO state
+        po_state = self.c_po_obj.read(self.c_po_id, ['state'])['state']
+        self.assert_(
+            po_state == 'done',
+            "The PO state is '%s' - Should be 'done'" % po_state,
+        )
+
+        # Check FO state
+        fo_state = self.c_so_obj.read(self.c_so_id, ['state'])['state']
+        self.assert_(
+            fo_state == 'done',
+            "The FO state is '%s' - Should be 'done'" % fo_state,
+        )
+
+    def test_cancel_in_at_coordo(self):
+        """
+        Cancel the IN at coordo side.
+        Check if the PO and the FO at coordo side are canceled.
+        Check if the PO at project side is canceled.
+        :return:
+        """
+        self.cancel_or_resource_in_at_coordo()
+
+    def test_resource_in_at_coordo(self):
+        """
+        Cancel & Resource the IN at coordo side.
+        Check if the PO and the FO at coordo side are canceled.
+        Check if the PO at project side is canceled.
+        :return:
+        """
+        self.cancel_or_resource_in_at_coordo(resource=True)
+
+def get_test_class():
+    return UFTP326Test

=== added file 'unifield_tests/tests/test_utp_1007.py'
--- unifield_tests/tests/test_utp_1007.py	1970-01-01 00:00:00 +0000
+++ unifield_tests/tests/test_utp_1007.py	2014-10-29 08:35:37 +0000
@@ -0,0 +1,197 @@
+#!/usr/bin/env python
+# -*- coding: utf8 -*-
+
+__author__ = 'qt'
+
+from resourcing import ResourcingTest
+
+import time
+
+
+class UTP1007Test(ResourcingTest):
+
+    def setUp(self):
+        """
+        Set the test as an IR test
+
+        1/ Create an IR with one line of 100 PCE
+        2/ Source the IR to external partner
+        3/ Validate and confirm the PO
+        4/ Receive 98 PCE
+        5/ Cancel and resource the backorder
+        """
+        super(UTP1007Test, self).setUp()
+        self.c_so_obj = self.c1.get('sale.order')
+        self.c_sol_obj = self.c1.get('sale.order.line')
+        self.c_po_obj = self.c1.get('purchase.order')
+        self.c_pol_obj = self.c1.get('purchase.order.line')
+        self.c_proc_obj = self.c1.get('stock.incoming.processor')
+        self.c_proc_line_obj = self.c1.get('stock.move.in.processor')
+        self.c_pick_obj = self.c1.get('stock.picking')
+        self.c_enter_reason_obj = self.c1.get('enter.reason')
+
+        # Prepare values for the internal request
+        prod_log1_id = self.get_record(self.c1, 'prod_log_1')
+        uom_pce_id = self.get_record(self.c1, 'product_uom_unit', module='product')
+        distrib_id = self.create_analytic_distribution(self.c1)
+
+        """
+        1/ Create an IR with one line of 10
+
+        """
+        order_values = {
+            'procurement_request': True,
+            'location_requestor_id': self.get_record(self.c1, 'stock_location_stock', module='stock'),
+        }
+
+        self.c_so_id = self.c_so_obj.create(order_values)
+
+        # Create order lines
+        # First line
+        line_values = {
+            'order_id': self.c_so_id,
+            'product_id': prod_log1_id,
+            'product_uom': uom_pce_id,
+            'product_uom_qty': 100.0,
+            'type': 'make_to_order',
+        }
+        self.c_sol_obj.create(line_values)
+
+        # Validate the sale order
+        self.c1.exec_workflow('sale.order', 'procurement_validate', self.c_so_id)
+
+        """
+        2/ Source the IR to an external partner
+        """
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        self.c_sol_obj.write(line_ids, {
+            'po_cft': 'po',
+            'supplier': self.get_record(self.c1, 'ext_supplier_1'),
+        })
+        self.c_sol_obj.confirmLine(line_ids)
+
+        # Run the scheduler
+        self.c_so_id = self.run_auto_pos_creation(self.c1, order_to_check=self.c_so_id)
+
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        not_sourced = True
+        while not_sourced:
+            not_sourced = False
+            for line in self.c_sol_obj.browse(line_ids):
+               if line.procurement_id and line.procurement_id.state != 'running':
+                    not_sourced = True
+            if not_sourced:
+                time.sleep(1)
+
+        po_ids = set()
+        po_line_ids = []
+        for line in self.c_sol_obj.browse(line_ids):
+            if line.procurement_id:
+                po_line_ids.extend(self.c_pol_obj.search([
+                    ('procurement_id', '=', line.procurement_id.id),
+                ]))
+
+        for po_line in self.c_pol_obj.read(po_line_ids, ['order_id']):
+            po_ids.add(po_line['order_id'][0])
+
+        self.c_po_id = po_ids and list(po_ids)[0] or False
+        self.c_so_name = self.c_so_obj.read(self.c_so_id, ['name'])['name']
+
+        """
+        3/ Validate and confirm the PO
+        """
+        self._validate_po(self.c1, [self.c_po_id])
+        self._confirm_po(self.c1, [self.c_po_id])
+
+        """
+        4/ Receive 98 PCE
+        """
+        # Get the IN associated to this PO
+        c_in_ids = self.c_pick_obj.search([('purchase_id', '=', self.c_po_id), ('type', '=', 'in')])
+        self.assert_(
+            len(c_in_ids) == 1,
+            "There are %s IN associated to PO - Should be 1" % len(c_in_ids),
+        )
+
+        self.c_in_id = c_in_ids[0]
+
+        wiz_res = self.c_pick_obj.action_process(self.c_in_id)
+        proc_line_ids = self.c_proc_line_obj.search([('wizard_id', '=', wiz_res['res_id'])])
+        self.c_proc_line_obj.write(proc_line_ids, {'quantity': 98.0})
+        bo_res = self.c_proc_obj.do_incoming_shipment([wiz_res['res_id']])
+
+    def test_cancel_bo(self):
+        """
+        Cancel the backorder without resourcing and check the quantity in
+        FO line
+        """
+        # Cancel the back order
+        wiz_id = self.c_enter_reason_obj.create({
+            'picking_id': self.c_in_id,
+            'change_reason': 'test_cancel_bo',
+        })
+        self.c_enter_reason_obj.do_cancel([wiz_id], {
+            'active_ids': [self.c_in_id],
+            'cancel_type': 'update_out',
+        })
+
+        # Check IN state
+        in_state = self.c_pick_obj.read(self.c_in_id, ['state'])['state']
+        self.assert_(
+            in_state == 'cancel',
+            "The BO is not canceled",
+        )
+
+        # Check quantity on the original IR line
+        sol_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        sol_qty = self.c_sol_obj.read(sol_ids[0], ['product_uom_qty'])['product_uom_qty']
+        self.assert_(
+            sol_qty == 100.0,
+            "The quantity on original IR is %s - Should be 100.00" % sol_qty
+        )
+
+    def test_resource_bo(self):
+        """
+        Cancel & Resource the backorder without resourcing and check the
+        quantity in FO line
+        """
+        # Cancel the back order
+        wiz_id = self.c_enter_reason_obj.create({
+            'picking_id': self.c_in_id,
+            'change_reason': 'test_cancel_bo',
+        })
+        self.c_enter_reason_obj.do_cancel([wiz_id], {
+            'active_ids': [self.c_in_id],
+            'cancel_type': '',
+        })
+
+        # Check IN state
+        in_state = self.c_pick_obj.read(self.c_in_id, ['state'])['state']
+        self.assert_(
+            in_state == 'cancel',
+            "The BO is not canceled",
+        )
+
+        # Check quantity on the original IR line
+        sol_ids = self.c_sol_obj.search([('order_id', '=', self.c_so_id)])
+        sol_qty = self.c_sol_obj.read(sol_ids[0], ['product_uom_qty'])['product_uom_qty']
+        self.assert_(
+            sol_qty == 98.0,
+            "The quantity on original IR is %s - Should be 98.00" % sol_qty
+        )
+
+        # Check quantity on new IR line
+        new_ir_ids = self.c_so_obj.search([('parent_order_name', '=', self.c_so_name), ('procurement_request', '=', True)])
+        self.assert_(
+            len(new_ir_ids) == 1,
+            "No new order created after resourcing",
+        )
+        sol_ids = self.c_sol_obj.search([('order_id', '=', new_ir_ids[0])])
+        sol_qty = self.c_sol_obj.read(sol_ids[0], ['product_uom_qty'])['product_uom_qty']
+        self.assert_(
+            sol_qty == 2.0,
+            "The quantity on original IR is %s - Should be 2.00" % sol_qty
+        )
+
+def get_test_class():
+    return UTP1007Test

=== modified file 'unifield_tests/tests/unifield_test.py'
--- unifield_tests/tests/unifield_test.py	2014-10-14 11:44:42 +0000
+++ unifield_tests/tests/unifield_test.py	2014-10-29 08:35:37 +0000
@@ -141,4 +141,45 @@
 
         return False
 
+    def synchronize(self, db=None):
+        '''
+        Connect the 'db' database to the sync. server
+        and run  synchronization.
+        If no database givent in parameters, sync. all
+        databases.
+        :param db: DB connection to synchronize (can be None
+                   or a list.
+        :return: True
+        '''
+        if not db:
+            for db_conn in self.db:
+                self.synchronize(db=db_conn)
+
+        if db and isinstance(db, list):
+            for db_conn in db:
+                self.synchronize(db=db_conn)
+
+        conn_obj = db.get('sync.client.sync_server_connection')
+        sync_obj = db.get('sync.client.sync_manager')
+
+        conn_ids = conn_obj.search([])
+        conn_obj.action_connect(conn_ids)
+        sync_ids = sync_obj.search([])
+        sync_obj.sync(sync_ids)
+
+    def get_db_partner_name(self, db):
+        '''
+        Return the name of partner associated
+        to the company of the database
+        :param db: DB connection of which we
+                   get the partner.
+        :return: Name of the partner associated
+                 to the company of the database
+        '''
+        company_obj = db.get('res.company')
+
+        company_ids = company_obj.search([])
+        return company_obj.browse(company_ids[0]).partner_id.name
+
+
 # vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4:

=== modified file 'unifield_tests/unifield.config'
--- unifield_tests/unifield.config	2014-10-13 07:28:32 +0000
+++ unifield_tests/unifield.config	2014-10-29 08:35:37 +0000
@@ -3,7 +3,7 @@
 port: 8069
 
 [DB]
-db_prefix: unifield_test_
+db_prefix: uftp-326_
 username: admin
 password: admin
 # If tempo_mkdb is True, it means you use mkdb from OpenERP to create DB. If not, you use tempo's one.