Merge lp:~unifield-team/unifield-wm/us-311 into lp:unifield-wm

[Quentin THEURET @Amaris]

[lp:~unifield-team/unifield-wm/us-311]

2537. By Quentin THEURET @Amaris on 2015-06-04

US-311 [FIX] Force check of state of the Internal request when the OUT is done

=== modified file 'msf_outgoing/msf_outgoing.py'
--- msf_outgoing/msf_outgoing.py	2015-06-03 15:29:06 +0000
+++ msf_outgoing/msf_outgoing.py	2015-06-04 14:18:29 +0000
@@ -3199,6 +3199,9 @@
             delivered_pack = self.browse(cr, uid, delivered_pack_id, context=context)
             res[picking.id] = {'delivered_picking': delivered_pack.id or False}
 
+            if picking.type == 'out' and picking.sale_id and picking.sale_id.procurement_request:
+                wf_service.trg_write(uid, 'sale.order', picking.sale_id.id, cr)
+
         return res
 
     @check_cp_rw

=== modified file 'purchase_override/purchase.py'
--- purchase_override/purchase.py	2015-05-29 15:29:07 +0000
+++ purchase_override/purchase.py	2015-06-04 14:18:29 +0000
@@ -1216,6 +1216,7 @@
                     'created_by_rfq_line': l.order_id.rfq_ok and l.id or False,
                     'po_cft': l.order_id.rfq_ok and 'rfq' or 'po',
                     'sync_sourced_origin': l.instance_sync_order_ref and l.instance_sync_order_ref.name or False,
+                    #'is_line_split': l.is_line_split,
                     'name': '[%s] %s' % (l.product_id.default_code, l.product_id.name)}
 
             new_line_id = sol_obj.create(cr, uid, vals, context=context)
@@ -1444,6 +1445,7 @@
                                   'nomen_sub_4': line.nomen_sub_4 and line.nomen_sub_4.id or False,
                                   'nomen_sub_5': line.nomen_sub_5 and line.nomen_sub_5.id or False,
                                   'confirmed_delivery_date': line_confirmed,
+                                  #'is_line_split': line.is_line_split,
                                   }
                     """
                     UFTP-336: Update the analytic distribution at FO line when

=== modified file 'purchase_override/wizard/split_order_line.py'
--- purchase_override/wizard/split_order_line.py	2014-09-19 12:18:46 +0000
+++ purchase_override/wizard/split_order_line.py	2015-06-04 14:18:29 +0000
@@ -133,8 +133,16 @@
                                     'so_back_update_dest_pol_id_sale_order_line': split.purchase_line_id.id,
                                     }
                     new_so_line_id = so_line_obj.copy(cr, uid, split.corresponding_so_line_id_split_po_line_wizard.id, so_copy_data, context=dict(context, keepDateAndDistrib=True))
+                    so_line_obj.write(cr, uid, new_so_line_id, {
+                        'supplier': split.corresponding_so_line_id_split_po_line_wizard.supplier.id,
+                        'type': 'make_to_order',
+                        'is_line_split': True,
+                    }, context=context)
                     # change the initial qty on the initial FO line
-                    so_line_obj.write(cr, uid, split.corresponding_so_line_id_split_po_line_wizard.id, {'product_uom_qty': split.original_qty - split.new_line_qty, 'product_uos_qty': split.original_qty - split.new_line_qty}, context=dict(context, keepDateAndDistrib=True))
+                    so_line_obj.write(cr, uid, split.corresponding_so_line_id_split_po_line_wizard.id, {
+                        'product_uom_qty': split.original_qty - split.new_line_qty,
+                        'product_uos_qty': split.original_qty - split.new_line_qty,
+                    }, context=dict(context, keepDateAndDistrib=True))
                     # call the new procurement creation method
                     so_obj.action_ship_proc_create(cr, uid, [split.corresponding_so_id_split_po_line_wizard.id], context=context)
                     # run the procurement, the make_po function detects the link to original po

=== modified file 'sale_override/sale.py'
--- sale_override/sale.py	2015-05-29 15:29:07 +0000
+++ sale_override/sale.py	2015-06-04 14:18:29 +0000
@@ -2201,7 +2201,8 @@
                 'created_by_rfq_line': fields.many2one('purchase.order.line', string='Created by RfQ line'),
                 'dpo_line_id': fields.many2one('purchase.order.line', string='DPO line'),
                 'sync_sourced_origin': fields.char(string='Sync. Origin', size=256),
-                'cancel_split_ok': fields.boolean(
+                'cancel_split_ok': fields.float(
+                    digits=(16,2),
                     string='Cancel split',
                     help='If the line has been canceled/removed on the splitted FO',
                 ),
@@ -2313,7 +2314,8 @@
                     pick_obj.validate(cr, uid, [pick.id])
 
             if line.original_line_id:
-                self.write(cr, uid, [line.original_line_id.id], {'cancel_split_ok': True}, context=context)
+                cancel_split_qty = line.original_line_id.cancel_split_ok + line.product_uom_qty
+                self.write(cr, uid, [line.original_line_id.id], {'cancel_split_ok': cancel_split_qty}, context=context)
 
             # UFTP-82:
             # do not delete cancelled IR line from PO cancelled

=== modified file 'unifield_tests/tests/resourcing.py'
--- unifield_tests/tests/resourcing.py	2015-03-17 09:46:54 +0000
+++ unifield_tests/tests/resourcing.py	2015-06-04 14:18:29 +0000
@@ -293,23 +293,26 @@
         :param po_ids: List of ID of purchase.order to validate
         :return The list of ID of purchase.order validated
         """
+        po_obj = db.get('purchase.order')
+        pol_obj = db.get('purchase.order.line')
+
         # Add an analytic distribution on PO lines that have no
-        no_ana_line_ids = self.pol_obj.search([
+        no_ana_line_ids = pol_obj.search([
             ('order_id', 'in', po_ids),
             ('analytic_distribution_id', '=', False),
         ])
-        self.pol_obj.write(no_ana_line_ids, {
+        pol_obj.write(no_ana_line_ids, {
             'analytic_distribution_id': self.get_record(db, 'distrib_1'),
         })
 
         # Check if the PO is draft
         for po_id in po_ids:
-            po_state = self.po_obj.read(po_id, ['state'])['state']
+            po_state = po_obj.read(po_id, ['state'])['state']
             self.assert_(po_state == 'draft', msg="""
 The state of the generated PO is %s - Should be 'draft'""" % po_state)
             # Validate the PO
             db.exec_workflow('purchase.order', 'purchase_confirm', po_id)
-            po_state = self.po_obj.browse(po_id).state
+            po_state = po_obj.browse(po_id).state
             self.assert_(po_state == 'confirmed', msg="""
 The state of the generated PO is %s - Should be 'confirmed'""" % po_state)
 
@@ -325,16 +328,18 @@
         :param dcd: Delivery confirmed date to set
         :return: The list of ID of purchase.order confirmed
         """
+        po_obj = db.get('purchase.order')
+
         if not dcd:
             dcd = time.strftime('%Y-%m-%d')
 
-        self.po_obj.write(po_ids, {'delivery_confirmed_date': dcd})
+        po_obj.write(po_ids, {'delivery_confirmed_date': dcd})
 
         for po_id in po_ids:
             """
             1/ Check if the PO are in 'confirmed' state
             """
-            po_state = self.po_obj.read(po_id, ['state'])['state']
+            po_state = po_obj.read(po_id, ['state'])['state']
             self.assert_(
                 po_state == 'confirmed',
                 "The state of the generated PO is %s - Should be 'confirmed'" % po_state,
@@ -342,11 +347,11 @@
             """
             2/ Confirm the PO
             """
-            self.po_obj.confirm_button([po_id])
+            po_obj.confirm_button([po_id])
             """
             3/ Check if all PO are now in 'approved' state
             """
-            po_state = self.po_obj.read(po_id, ['state'])['state']
+            po_state = po_obj.read(po_id, ['state'])['state']
             self.assert_(
                 po_state == 'approved',
                 "The state of the generated PO is %s - Should be 'approved'" % po_state,

=== added file 'unifield_tests/tests/test_us_311.py'
--- unifield_tests/tests/test_us_311.py	1970-01-01 00:00:00 +0000
+++ unifield_tests/tests/test_us_311.py	2015-06-04 14:18:29 +0000
@@ -0,0 +1,669 @@
+#!/usr/bin/env python
+# -*- coding: utf8 -*-
+
+__author__ = 'qt'
+
+from resourcing import ResourcingTest
+
+
+class US311Test(ResourcingTest):
+
+    def setUp(self):
+        """
+        1/ Create an IR with two lines at project:
+           * One with 18 PCE of product 1
+           * One with 25 PCE of product 2
+        2/ Validate the IR
+        3/ Source all lines to the coordo
+        4/ Validate the PO
+        5/ Sync.
+        6/ At coordo, validate the FO
+        7/ Source the two lines to an external supplier
+        8/ On the generated PO, split the line of 25 PCE to two lines:
+           * One line with 15 PCE
+           * One line with 10 PCE
+        """
+        super(US311Test, self).setUp()
+        # Project objects mapper
+        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_pick_obj = self.p1.get('stock.picking')
+        self.p_move_obj = self.p1.get('stock.move')
+        self.p_partner_obj = self.p1.get('res.partner')
+        # Coordo objects mapper
+        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_pick_obj = self.c1.get('stock.picking')
+        self.c_move_obj = self.c1.get('stock.move')
+        self.c_partner_obj = self.c1.get('res.partner')
+
+        # Products
+        self.p_prd1_id = self.get_record(self.p1, 'prod_log_1')
+        self.p_prd2_id = self.get_record(self.p1, 'prod_log_2')
+        self.p_prd3_id = self.get_record(self.p1, 'prod_log_3')
+        self.c_prd1_id = self.get_record(self.c1, 'prod_log_1')
+        self.c_prd2_id = self.get_record(self.c1, 'prod_log_2')
+        self.c_prd3_id = self.get_record(self.c1, 'prod_log_3')
+
+        # Get Project and Coordo partners
+        project_name = self.get_db_partner_name(self.p1)
+        coordo_name = self.get_db_partner_name(self.c1)
+        c_proj_ids = self.c_partner_obj.search([('name', '=', project_name)])
+        p_coordo_ids = self.p_partner_obj.search([('name', '=', coordo_name)])
+
+        self.assert_(
+            c_proj_ids,
+            "No project partner found in Coordination",
+        )
+        self.assert_(
+            p_coordo_ids,
+            "No coordination partner found in Project",
+        )
+        self.c_prj_id = c_proj_ids[0]
+        self.p_crd_id = p_coordo_ids[0]
+
+        # Prepare values for IR
+        uom_pce_id = self.get_record(self.p1, 'product_uom_unit', module='product')
+        distrib_id = self.create_analytic_distribution(self.p1)
+
+        """
+        1/ Create an IR with two lines at project:
+           * One with 18 PCE of product 1
+           * One with 25 PCE of product 2
+        """
+        ir_values = {
+            'procurement_request': True,
+            'location_requestor_id': self.get_record(self.p1, 'external_cu'),
+        }
+        self.p_ir_id = self.p_so_obj.create(ir_values)
+        l1_values = {
+            'order_id': self.p_ir_id,
+            'product_id': self.p_prd1_id,
+            'product_uom': uom_pce_id,
+            'product_uom_qty': 18.00,
+            'type': 'make_to_order',
+            'price_unit': 1.00,
+        }
+        self.p_irl1_id = self.p_sol_obj.create(l1_values)
+
+        l2_values = l1_values.copy()
+        l2_values.update({
+            'product_id': self.p_prd2_id,
+            'product_uom_qty': 25.00,
+        })
+        self.p_irl2_id = self.p_sol_obj.create(l2_values)
+
+        """
+        2/ Validate the IR
+        """
+        self.p1.exec_workflow('sale.order', 'procurement_validate', self.p_ir_id)
+
+        """
+        3/ Source all lines to the coordo
+        """
+        self.p_sol_obj.write([self.p_irl1_id, self.p_irl2_id], {
+            'po_cft': 'po',
+            'supplier': self.p_crd_id,
+        })
+        self.p_sol_obj.confirmLine([self.p_irl1_id, self.p_irl2_id])
+
+        # Run the scheduler
+        self.p_ir_id = self.run_auto_pos_creation(self.p1, order_to_check=self.p_ir_id)
+        line_ids = self.p_sol_obj.search([('order_id', '=', self.p_ir_id)])
+        not_sourced = True
+        while not_sourced:
+            not_sourced = False
+            for line in self.p_sol_obj.browse(line_ids):
+                if line.procurement_id.state != 'running':
+                    not_source = True
+            if not_sourced:
+                time.sleep(1)
+
+        po_ids = set()
+        po_line_ids = []
+        for line in self.p_sol_obj.browse(line_ids):
+            po_line_ids.extend(self.p_pol_obj.search([
+                ('procurement_id', '=', line.procurement_id.id),
+            ]))
+
+        for po_line in self.p_pol_obj.read(po_line_ids, ['order_id']):
+            po_ids.add(po_line['order_id'][0])
+
+        self.p_po_id = po_ids and list(po_ids)[0] or False
+        self.p_po_name = self.p_po_obj.read(self.p_po_id, ['name'])['name']
+
+        """
+        4/ Validate the PO
+        """
+        self._validate_po(self.p1, [self.p_po_id])
+
+        """
+        5/ Sync.
+        """
+        self.synchronize(self.p1)
+        self.synchronize(self.c1)
+
+        """
+        6/ At coordo, validate the FO
+        """
+        self.c_fo_id = None
+        self.c_fo_ids = self.c_so_obj.search([('client_order_ref', 'like', self.p_po_name)])
+        for c_fo_id in self.c_fo_ids:
+            self.assert_(
+                self.c_so_obj.read(c_fo_id, ['state'])['state'] == 'draft',
+                "The FO at Coordo is not 'Draft'.",
+            )
+            self.c_fo_id = c_fo_id
+
+        # Validate the Field order
+        self.c1.exec_workflow('sale.order', 'order_validated', self.c_fo_id)
+
+        """
+        7/ Source the two lines to an external supplier
+        """
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_fo_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)
+
+        # Get the generated PO
+        self.c_fo_id = self.run_auto_pos_creation(self.c1, order_to_check=self.c_fo_id)
+        line_ids = self.c_sol_obj.search([('order_id', '=', self.c_fo_id)])
+        po_ids = set()
+        po_line_ids = []
+        self.c_pol_18 = None
+        self.c_pol_25 = None
+        self.c_pol_10 = None
+        self.c_pol_15 = None
+        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', 'product_qty']):
+            po_ids.add(po_line['order_id'][0])
+            self.c_po_id = po_line['order_id'][0]
+            if po_line['product_qty'] == 18.00:
+                self.c_pol_18 = po_line['id']
+            elif po_line['product_qty'] == 25.00:
+                self.c_pol_25 = po_line['id']
+
+        self.assert_(
+            self.c_pol_18,
+            "Line with 18 PCE not found on PO",
+        )
+        self.assert_(
+            self.c_pol_25,
+            "Line with 25 PCE not found on PO",
+        )
+
+        """
+        8/ On the generated PO, split the line of 25 PCE to two lines:
+           * One line with 15 PCE
+           * One line with 10 PCE
+        """
+        split_obj = self.c1.get('split.purchase.order.line.wizard')
+        split_id = split_obj.create({
+            'purchase_line_id': self.c_pol_25,
+            'original_qty': 25.00,
+            'old_line_qty': 10.00,
+            'new_line_qty': 15.00,
+        })
+        split_obj.split_line([split_id])
+
+        line_ids = self.c_pol_obj.search([('order_id', 'in', list(po_ids))])
+        for pol in self.c_pol_obj.browse(line_ids):
+            if pol.product_qty == 18.00:
+                self.c_pol_18 = pol.id
+            elif pol.product_qty == 10.00:
+                self.c_pol_10 = pol.id
+            elif pol.product_qty == 15.00:
+                self.c_pol_15 = pol.id
+
+        self.assert_(
+            self.c_pol_18 and self.c_pol_10 and self.c_pol_15,
+            "Not all needed PO lines are found",
+        )
+
+    def tearDown(self):
+        """
+        """
+        super(US311Test, self).tearDown()
+
+    def run_flow(self):
+        """
+        Confirm the PO, then process the IN and the P/P/S at Coordo
+        Sync
+        """
+        # Validate the PO
+        self._validate_po(self.c1, [self.c_po_id])
+
+        # Confirm the PO
+        self._confirm_po(self.c1, [self.c_po_id])
+
+        # Process the IN
+        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 association to PO - Should be 1" % len(c_in_ids),
+        )
+        proc_obj = self.c1.get('stock.incoming.processor')
+        proc_res = self.c_pick_obj.action_process(c_in_ids)
+        proc_id = proc_res.get('res_id')
+        proc_obj.copy_all([proc_id])
+        proc_obj.do_incoming_shipment([proc_id])
+
+        # Process P/P/S
+        c_out_ids = self.c_pick_obj.search([('sale_id', '=', self.c_fo_id), ('type', '=', 'out'), ('state', '=', 'assigned')])
+        self.assert_(
+            len(c_out_ids) == 1,
+            "There are %s OUT/PICK associated to FO - Should be 1" % len(c_out_ids),
+        )
+        out_proc_obj = self.c1.get('outgoing.delivery.processor')
+        conv_res = self.c_pick_obj.convert_to_standard(c_out_ids)
+        out_id = conv_res.get('res_id')
+        proc_res = self.c_pick_obj.action_process([out_id])
+        out_proc_obj.copy_all([proc_res.get('res_id')])
+        out_proc_obj.do_partial([proc_res.get('res_id')])
+
+        self.synchronize(self.c1)
+        self.synchronize(self.p1)
+
+    def close_flow(self):
+        """
+        Process the IN and the OUT at project
+        """
+        # Process the IN
+        proc_obj = self.p1.get('stock.incoming.processor')
+        for in_id in self.p_in_ids:
+            proc_res = self.p_pick_obj.action_process([in_id])
+            proc_id = proc_res.get('res_id')
+            proc_obj.copy_all([proc_id])
+            proc_obj.do_incoming_shipment([proc_id])
+
+        # Process the OUT
+        out_proc_obj = self.p1.get('outgoing.delivery.processor')
+        for out_id in self.out_ids:
+            proc_res = self.p_pick_obj.action_process([out_id])
+            out_proc_obj.copy_all([proc_res.get('res_id')])
+            out_proc_obj.do_partial([proc_res.get('res_id')])
+
+        self.assert_(
+            self.p_so_obj.browse(self.p_ir_id).state == 'done',
+            "The Internal request is not Closed",
+        )
+
+    def test_cancel_new_splitted_line(self):
+        """
+        Cancel the new line after the split, confirm the PO, process the IN and the P/P/S
+        at coordo, then sync.
+        At project, check the number of lines in OUT.
+        Process the IN and the OUT.
+        """
+        # Cancel the PO line
+        res = self.c_pol_obj.ask_unlink(self.c_pol_15)
+        self.assert_(
+            res.get('res_id', False) and res.get('res_model', False) == 'purchase.order.line.unlink.wizard',
+            "There is no wizard displayed when cancel a PO line that sources a FO/IR line",
+        )
+        w_res = self.c1.get('purchase.order.line.unlink.wizard').just_cancel(res.get('res_id'))
+
+        self.run_flow()
+
+        # Check IR quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        for line in self.p_so_obj.browse(self.p_ir_id).order_line:
+            if line.state == 'done':
+                continue
+            if line.product_id.id == self.p_prd1_id:
+                prd1_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd2_id:
+                prd2_qty += line.product_uom_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 10.00,
+            "The quantities on IR moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check IN quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        ir_name = self.p_so_obj.read(self.p_ir_id, ['name'])['name']
+        self.p_in_ids = self.p_pick_obj.search([
+            ('type', '=', 'in'),
+            ('origin', 'like', ir_name),
+        ])
+        for pick in self.p_pick_obj.browse(self.p_in_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 10.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check OUT quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        self.out_ids = self.p_pick_obj.search([('sale_id', '=', self.p_ir_id), ('type', '=', 'out')])
+        for pick in self.p_pick_obj.browse(self.out_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 10.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        self.close_flow()
+
+    def test_cancel_all_splitted_lines(self):
+        """
+        Cancel the splitted line, confirm the PO, process the IN and the P/P/S
+        at coordo, then sync.
+        At project, check the number of lines in OUT.
+        Process the IN and the OUT.
+        """
+        # Cancel the PO lines
+        res = self.c_pol_obj.ask_unlink(self.c_pol_10)
+        self.assert_(
+            res.get('res_id', False) and res.get('res_model', False) == 'purchase.order.line.unlink.wizard',
+            "There is no wizard displayed when cancel a PO line that sources a FO/IR line",
+        )
+        w_res = self.c1.get('purchase.order.line.unlink.wizard').just_cancel(res.get('res_id'))
+        res = self.c_pol_obj.ask_unlink(self.c_pol_15)
+        self.assert_(
+            res.get('res_id', False) and res.get('res_model', False) == 'purchase.order.line.unlink.wizard',
+            "There is no wizard displayed when cancel a PO line that sources a FO/IR line",
+        )
+        w_res = self.c1.get('purchase.order.line.unlink.wizard').just_cancel(res.get('res_id'))
+
+        self.run_flow()
+
+        # Check IR quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        for line in self.p_so_obj.browse(self.p_ir_id).order_line:
+            if line.state == 'done':
+                continue
+            if line.product_id.id == self.p_prd1_id:
+                prd1_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd2_id:
+                prd2_qty += line.product_uom_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 0.00,
+            "The quantities on IR moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check IN quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        ir_name = self.p_so_obj.read(self.p_ir_id, ['name'])['name']
+        self.p_in_ids = self.p_pick_obj.search([
+            ('type', '=', 'in'),
+            ('origin', 'like', ir_name),
+        ])
+        for pick in self.p_pick_obj.browse(self.p_in_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 0.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check OUT quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        self.out_ids = self.p_pick_obj.search([('sale_id', '=', self.p_ir_id), ('type', '=', 'out')])
+        for pick in self.p_pick_obj.browse(self.out_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 0.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        self.close_flow()
+
+    def test_cancel_original_splitted_line_more_on_new_line(self):
+        """
+        Cancel the splitted line, confirm the PO, process the IN and the P/P/S
+        at coordo, then sync.
+        At project, check the number of lines in OUT.
+        Process the IN and the OUT.
+        """
+        # Add quantities on new line
+        self.c_pol_obj.write(self.c_pol_15, {'product_qty': 50.0})
+        # Cancel the PO line
+        res = self.c_pol_obj.ask_unlink(self.c_pol_10)
+        self.assert_(
+            res.get('res_id', False) and res.get('res_model', False) == 'purchase.order.line.unlink.wizard',
+            "There is no wizard displayed when cancel a PO line that sources a FO/IR line",
+        )
+        w_res = self.c1.get('purchase.order.line.unlink.wizard').just_cancel(res.get('res_id'))
+
+        self.run_flow()
+
+        # Check IR quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        for line in self.p_so_obj.browse(self.p_ir_id).order_line:
+            if line.state == 'done':
+                continue
+            if line.product_id.id == self.p_prd1_id:
+                prd1_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd2_id:
+                prd2_qty += line.product_uom_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 50.00,
+            "The quantities on IR moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check IN quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        ir_name = self.p_so_obj.read(self.p_ir_id, ['name'])['name']
+        self.p_in_ids = self.p_pick_obj.search([
+            ('type', '=', 'in'),
+            ('origin', 'like', ir_name),
+        ])
+        for pick in self.p_pick_obj.browse(self.p_in_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 50.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check OUT quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        self.out_ids = self.p_pick_obj.search([('sale_id', '=', self.p_ir_id), ('type', '=', 'out')])
+        for pick in self.p_pick_obj.browse(self.out_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 50.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        self.close_flow()
+
+    def test_cancel_original_splitted_line(self):
+        """
+        Cancel the splitted line, confirm the PO, process the IN and the P/P/S
+        at coordo, then sync.
+        At project, check the number of lines in OUT.
+        Process the IN and the OUT.
+        """
+        # Cancel the PO line
+        res = self.c_pol_obj.ask_unlink(self.c_pol_10)
+        self.assert_(
+            res.get('res_id', False) and res.get('res_model', False) == 'purchase.order.line.unlink.wizard',
+            "There is no wizard displayed when cancel a PO line that sources a FO/IR line",
+        )
+        w_res = self.c1.get('purchase.order.line.unlink.wizard').just_cancel(res.get('res_id'))
+
+        self.run_flow()
+
+        # Check IR quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        for line in self.p_so_obj.browse(self.p_ir_id).order_line:
+            if line.state == 'done':
+                continue
+            if line.product_id.id == self.p_prd1_id:
+                prd1_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd2_id:
+                prd2_qty += line.product_uom_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00,
+            "The quantities on IR moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check IN quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        ir_name = self.p_so_obj.read(self.p_ir_id, ['name'])['name']
+        self.p_in_ids = self.p_pick_obj.search([
+            ('type', '=', 'in'),
+            ('origin', 'like', ir_name),
+        ])
+        for pick in self.p_pick_obj.browse(self.p_in_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        # Check OUT quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        self.out_ids = self.p_pick_obj.search([('sale_id', '=', self.p_ir_id), ('type', '=', 'out')])
+        for pick in self.p_pick_obj.browse(self.out_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s)" % (prd1_qty, prd2_qty),
+        )
+
+        self.close_flow()
+
+    def test_change_product_on_splitted_line(self):
+        """
+        Change the product of the splitted line, confirm the PO, process the
+        IN and the P/P/S at coordo, then sync.
+        At project, check the product of lines in OUT.
+        Process the IN and the OUT.
+        """
+        # Change the product of the splitted line
+        self.c_pol_obj.write(self.c_pol_10, {'product_id': self.c_prd3_id})
+
+        self.run_flow()
+
+        # Check IR quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        prd3_qty = 0.00
+        for line in self.p_so_obj.browse(self.p_ir_id).order_line:
+            if line.product_id.id == self.p_prd1_id:
+                prd1_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd2_id:
+                prd2_qty += line.product_uom_qty
+            elif line.product_id.id == self.p_prd3_id:
+                prd3_qty += line.product_uom_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00 and prd3_qty == 10.00,
+            "The quantities on IR moves are not good. (PRD1: %s - PRD2: %s - PRD3: %s)" % (prd1_qty, prd2_qty, prd3_qty),
+        )
+
+        # Check IN quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        prd3_qty = 0.00
+        ir_name = self.p_so_obj.read(self.p_ir_id, ['name'])['name']
+        self.p_in_ids = self.p_pick_obj.search([
+            ('type', '=', 'in'),
+            ('origin', 'like', ir_name),
+        ])
+        for pick in self.p_pick_obj.browse(self.p_in_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+                elif move.product_id.id == self.p_prd3_id:
+                    prd3_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00 and prd3_qty == 10.00,
+            "The quantities on IN moves are not good. (PRD1: %s - PRD2: %s - PRD3: %s)" % (prd1_qty, prd2_qty, prd3_qty),
+        )
+
+        # Check OUT quantities
+        prd1_qty = 0.00
+        prd2_qty = 0.00
+        prd3_qty = 0.00
+        self.out_ids = self.p_pick_obj.search([('sale_id', '=', self.p_ir_id), ('type', '=', 'out')])
+        for pick in self.p_pick_obj.browse(self.out_ids):
+            for move in pick.move_lines:
+                if move.product_id.id == self.p_prd1_id:
+                    prd1_qty += move.product_qty
+                elif move.product_id.id == self.p_prd2_id:
+                    prd2_qty += move.product_qty
+                elif move.product_id.id == self.p_prd3_id:
+                    prd3_qty += move.product_qty
+
+        self.assert_(
+            prd1_qty == 18.00 and prd2_qty == 15.00 and prd3_qty == 10.00,
+            "The quantities on OUT moves are not good. (PRD1: %s - PRD2: %s - PRD3: %s)" % (prd1_qty, prd2_qty, prd3_qty),
+        )
+
+        self.close_flow()
+
+def get_test_class():
+    return US311Test