From 03909f2113b50569e4ace6da6633d63b3969d989 Mon Sep 17 00:00:00 2001
From: AlexPForgeFlow <alex.paris@forgeflow.com>
Date: Thu, 31 Oct 2024 17:28:16 +0100
Subject: [PATCH 1/3] [16.0][IMP] ddmrp: add RFQ qty info inside of the DLT
 Horizon

---
 ddmrp/models/stock_buffer.py      | 24 +++++++++++++-----------
 ddmrp/views/stock_buffer_view.xml | 18 ++++++++++++++++++
 2 files changed, 31 insertions(+), 11 deletions(-)

diff --git a/ddmrp/models/stock_buffer.py b/ddmrp/models/stock_buffer.py
index 19093bdfb..052fcbbef 100644
--- a/ddmrp/models/stock_buffer.py
+++ b/ddmrp/models/stock_buffer.py
@@ -1196,6 +1196,12 @@ def _compute_product_vendor_code(self):
         help="Request for Quotation total quantity that is planned outside of "
         "the DLT horizon.",
     )
+    rfq_inside_dlt_qty = fields.Float(
+        string="RFQ Qty (Inside DLT)",
+        readonly=True,
+        help="Request for Quotation total quantity that is planned inside of "
+        "the DLT horizon.",
+    )
     net_flow_position = fields.Float(
         digits="Product Unit of Measure",
         readonly=True,
@@ -1679,17 +1685,13 @@ def _calc_incoming_dlt_qty(self):
             outside_dlt_moves = self._search_stock_moves_incoming(outside_dlt=True)
             rec.incoming_outside_dlt_qty = sum(outside_dlt_moves.mapped("product_qty"))
             if rec.item_type == "purchased":
-                cut_date = rec._get_incoming_supply_date_limit()
-                # FIXME: filter using order_id.state while
-                #  https://github.com/odoo/odoo/pull/58966 is not merged.
-                #  Can be changed in v14.
-                pols = rec.purchase_line_ids.filtered(
-                    lambda l: l.date_planned > fields.Datetime.to_datetime(cut_date)
-                    and l.order_id.state in ("draft", "sent")
-                )
-                rec.rfq_outside_dlt_qty = sum(pols.mapped("product_qty"))
+                pols_outside_dlt = rec._get_rfq_dlt(outside_dlt=True)
+                rec.rfq_outside_dlt_qty = sum(pols_outside_dlt.mapped("product_qty"))
+                pols_inside_dlt = rec._get_rfq_dlt()
+                rec.rfq_inside_dlt_qty = sum(pols_inside_dlt.mapped("product_qty"))
             else:
                 rec.rfq_outside_dlt_qty = 0.0
+                rec.rfq_inside_dlt_qty = 0.0
             rec.incoming_total_qty = rec.incoming_dlt_qty + rec.incoming_outside_dlt_qty
         return True
 
@@ -1843,12 +1845,12 @@ def _get_rfq_dlt(self, outside_dlt=False):
         if not outside_dlt:
             pols = self.purchase_line_ids.filtered(
                 lambda l: l.date_planned <= fields.Datetime.to_datetime(cut_date)
-                and l.state in ("draft", "sent")
+                and l.state in ("draft", "sent", "to approve")
             )
         else:
             pols = self.purchase_line_ids.filtered(
                 lambda l: l.date_planned > fields.Datetime.to_datetime(cut_date)
-                and l.state in ("draft", "sent")
+                and l.state in ("draft", "sent", "to approve")
             )
         return pols
 
diff --git a/ddmrp/views/stock_buffer_view.xml b/ddmrp/views/stock_buffer_view.xml
index 5993f6792..fce375013 100644
--- a/ddmrp/views/stock_buffer_view.xml
+++ b/ddmrp/views/stock_buffer_view.xml
@@ -89,6 +89,15 @@
                     type="object"
                     attrs="{'invisible':[('rfq_outside_dlt_qty', '=', 0)]}"
                 />
+                <field name="rfq_inside_dlt_qty" optional="hide" />
+                <button
+                    title="Some RFQs are inside of the DLT Horizon and waiting validation to be accounted into the NFP.
+                    Press this button to display them."
+                    name="action_view_supply_rfq_inside_dlt_window"
+                    icon="fa-warning"
+                    type="object"
+                    attrs="{'invisible':[('rfq_inside_dlt_qty', '=', 0)]}"
+                />
                 <button
                     title="No stock available in source location for distributed buffer"
                     name="action_dummy"
@@ -472,6 +481,15 @@
                                         type="object"
                                         attrs="{'invisible': ['|', ('qualified_demand', '=', 0), ('qualified_demand_mrp_move_ids', '=', [])]}"
                                     />
+                                    <field name="rfq_inside_dlt_qty" invisible="1" />
+                                    <button
+                                        title="Some RFQs are inside of the DLT Horizon and waiting validation to be accounted into the NFP.
+                                        Press this button to display them."
+                                        name="action_view_supply_rfq_inside_dlt_window"
+                                        icon="fa-warning"
+                                        type="object"
+                                        attrs="{'invisible':[('rfq_inside_dlt_qty', '=', 0)]}"
+                                    />
                                 </div>
                                 <field name="net_flow_position" />
                                 <label for="net_flow_position_percent" />

From b747a1b9dddb8ae1f41ee4feead0c1a2dd7f14e9 Mon Sep 17 00:00:00 2001
From: AlexPForgeFlow <alex.paris@forgeflow.com>
Date: Mon, 4 Nov 2024 16:34:14 +0100
Subject: [PATCH 2/3] [16.0][IMP] ddmrp: refactor method _quantity_in_progress
 to use _get_rfq_dlt logic

---
 ddmrp/models/stock_buffer.py | 35 ++++++++++++++++-------------------
 1 file changed, 16 insertions(+), 19 deletions(-)

diff --git a/ddmrp/models/stock_buffer.py b/ddmrp/models/stock_buffer.py
index 052fcbbef..9d8cfd46c 100644
--- a/ddmrp/models/stock_buffer.py
+++ b/ddmrp/models/stock_buffer.py
@@ -158,18 +158,11 @@ def _quantity_in_progress(self):
         """Return Quantities that are not yet in virtual stock but should
         be deduced from buffers (example: purchases created from buffers)"""
         res = {}.fromkeys(self.ids, 0.0)
-        polines = self.env["purchase.order.line"].search(
-            [
-                ("state", "in", ("draft", "sent", "to approve")),
-                ("buffer_ids", "in", self.ids),
-            ]
-        )
-        for poline in polines:
-            for buffer in poline.buffer_ids:
-                if buffer.id not in self.ids:
-                    continue
-                res[buffer.id] += poline.product_uom._compute_quantity(
-                    poline.product_qty, buffer.product_uom, round=False
+        for buffer in self:
+            polines = buffer._get_rfq_dlt(dlt_interval=None)
+            for line in polines:
+                res[buffer.id] += line.product_uom._compute_quantity(
+                    line.product_qty, buffer.product_uom, round=False
                 )
         return res
 
@@ -1685,9 +1678,9 @@ def _calc_incoming_dlt_qty(self):
             outside_dlt_moves = self._search_stock_moves_incoming(outside_dlt=True)
             rec.incoming_outside_dlt_qty = sum(outside_dlt_moves.mapped("product_qty"))
             if rec.item_type == "purchased":
-                pols_outside_dlt = rec._get_rfq_dlt(outside_dlt=True)
+                pols_outside_dlt = rec._get_rfq_dlt(dlt_interval="outside")
                 rec.rfq_outside_dlt_qty = sum(pols_outside_dlt.mapped("product_qty"))
-                pols_inside_dlt = rec._get_rfq_dlt()
+                pols_inside_dlt = rec._get_rfq_dlt(dlt_interval="inside")
                 rec.rfq_inside_dlt_qty = sum(pols_inside_dlt.mapped("product_qty"))
             else:
                 rec.rfq_outside_dlt_qty = 0.0
@@ -1839,19 +1832,23 @@ def action_view_supply_moves(self):
         result["domain"] = [("id", "in", moves.ids)]
         return result
 
-    def _get_rfq_dlt(self, outside_dlt=False):
+    def _get_rfq_dlt(self, dlt_interval=None):
         self.ensure_one()
         cut_date = self._get_incoming_supply_date_limit()
-        if not outside_dlt:
+        if dlt_interval == "inside":
             pols = self.purchase_line_ids.filtered(
                 lambda l: l.date_planned <= fields.Datetime.to_datetime(cut_date)
                 and l.state in ("draft", "sent", "to approve")
             )
-        else:
+        elif dlt_interval == "outside":
             pols = self.purchase_line_ids.filtered(
                 lambda l: l.date_planned > fields.Datetime.to_datetime(cut_date)
                 and l.state in ("draft", "sent", "to approve")
             )
+        else:
+            pols = self.purchase_line_ids.filtered(
+                lambda l: l.state in ("draft", "sent", "to approve")
+            )
         return pols
 
     def action_view_supply_moves_inside_dlt_window(self):
@@ -1870,7 +1867,7 @@ def action_view_supply_moves_outside_dlt_window(self):
 
     def action_view_supply_rfq_inside_dlt_window(self):
         result = self.env["ir.actions.actions"]._for_xml_id("purchase.purchase_rfq")
-        pols = self._get_rfq_dlt()
+        pols = self._get_rfq_dlt(dlt_interval="inside")
         pos = pols.mapped("order_id")
         result["context"] = {}
         result["domain"] = [("id", "in", pos.ids)]
@@ -1878,7 +1875,7 @@ def action_view_supply_rfq_inside_dlt_window(self):
 
     def action_view_supply_rfq_outside_dlt_window(self):
         result = self.env["ir.actions.actions"]._for_xml_id("purchase.purchase_rfq")
-        pols = self._get_rfq_dlt(outside_dlt=True)
+        pols = self._get_rfq_dlt(dlt_interval="outside")
         pos = pols.mapped("order_id")
         result["context"] = {}
         result["domain"] = [("id", "in", pos.ids)]

From 2a3f8e375c5a8260d917b44b917e1b89c499d559 Mon Sep 17 00:00:00 2001
From: AlexPForgeFlow <alex.paris@forgeflow.com>
Date: Mon, 18 Nov 2024 15:19:22 +0100
Subject: [PATCH 3/3] [16.0][IMP] ddmrp: add RFQ total qty

---
 ddmrp/models/stock_buffer.py      | 7 +++++++
 ddmrp/views/stock_buffer_view.xml | 1 +
 2 files changed, 8 insertions(+)

diff --git a/ddmrp/models/stock_buffer.py b/ddmrp/models/stock_buffer.py
index 9d8cfd46c..aeda383a3 100644
--- a/ddmrp/models/stock_buffer.py
+++ b/ddmrp/models/stock_buffer.py
@@ -1195,6 +1195,11 @@ def _compute_product_vendor_code(self):
         help="Request for Quotation total quantity that is planned inside of "
         "the DLT horizon.",
     )
+    rfq_total_qty = fields.Float(
+        string="RFQ Total Qty",
+        readonly=True,
+        help="Request for Quotation total quantity that is planned",
+    )
     net_flow_position = fields.Float(
         digits="Product Unit of Measure",
         readonly=True,
@@ -1682,9 +1687,11 @@ def _calc_incoming_dlt_qty(self):
                 rec.rfq_outside_dlt_qty = sum(pols_outside_dlt.mapped("product_qty"))
                 pols_inside_dlt = rec._get_rfq_dlt(dlt_interval="inside")
                 rec.rfq_inside_dlt_qty = sum(pols_inside_dlt.mapped("product_qty"))
+                rec.rfq_total_qty = rec.rfq_inside_dlt_qty + rec.rfq_outside_dlt_qty
             else:
                 rec.rfq_outside_dlt_qty = 0.0
                 rec.rfq_inside_dlt_qty = 0.0
+                rec.rfq_total_qty = 0.0
             rec.incoming_total_qty = rec.incoming_dlt_qty + rec.incoming_outside_dlt_qty
         return True
 
diff --git a/ddmrp/views/stock_buffer_view.xml b/ddmrp/views/stock_buffer_view.xml
index fce375013..4bd0a9f04 100644
--- a/ddmrp/views/stock_buffer_view.xml
+++ b/ddmrp/views/stock_buffer_view.xml
@@ -80,6 +80,7 @@
                     type="object"
                     attrs="{'invisible':[('incoming_outside_dlt_qty', '=', 0)]}"
                 />
+                <field name="rfq_total_qty" optional="hide" />
                 <field name="rfq_outside_dlt_qty" invisible="1" />
                 <button
                     title="Some RFQ quantities are outside of the DLT Horizon and may require rescheduling.