Merge branch 'production' into change/feature/promotion-program

1 files changed, 29 insertions, 35 deletions

diff --git a/indoteknik_custom/models/solr/product_product.py b/indoteknik_custom/models/solr/product_product.py
index 31a0026d..03eaaf13 100644
--- a/indoteknik_custom/models/solr/product_product.py
+++ b/indoteknik_custom/models/solr/product_product.py
@@ -1,10 +1,11 @@
-from odoo import models, fields
+from odoo import models, fields, api
 from datetime import datetime
 
 
 class ProductProduct(models.Model):
     _inherit = 'product.product'
 
+    unpublished = fields.Boolean(string='Unpublished')
     last_update_solr = fields.Datetime(string='Last Update Solr')
     desc_update_solr = fields.Char(string='Desc Update Solr')
 
@@ -24,6 +25,7 @@ class ProductProduct(models.Model):
     def variant_solr_flag_to_solr(self, limit=500):
         variant_products = self.search([('solr_flag', '=', 2)], limit=limit)
         for product in variant_products:
+            product.product_tmpl_id._create_solr_queue('_sync_product_template_to_solr')
             product.product_tmpl_id._create_solr_queue('_sync_price_to_solr')
             product.solr_flag = 1
 
@@ -63,7 +65,8 @@ class ProductProduct(models.Model):
                 'search_rank_weekly_i': variant.product_tmpl_id.search_rank_weekly,
                 'attributes': [x.name for x in variant.product_template_attribute_value_ids],
                 'has_product_info_b': True,
-                'publish_b': variant.product_tmpl_id.active and variant.product_tmpl_id.type == 'product',
+                'publish_b': not variant.unpublished,
+                'qty_sold_f': variant.qty_sold
             })
 
             self.solr().add(docs=[document], softCommit=True)
@@ -74,24 +77,12 @@ class ProductProduct(models.Model):
 
     def _sync_price_to_solr(self):
         solr_model = self.env['apache.solr']
+        TIER_NUMBERS = ['1_v2', '2_v2', '3_v2', '4_v2', '5_v2']
 
         for variant in self:
-            price_excl_after_disc = price_excl = discount = tax = 0
-            flashsale_data = {}
-
-            if price_excl_after_disc == 0 or variant._get_website_price_after_disc_and_tax() < price_excl_after_disc:
-                price_excl = variant._get_website_price_exclude_tax()
-                price_excl_after_disc = variant._get_website_price_after_disc_and_tax()
-                tax = variant._get_website_tax()
-                discount = variant._get_website_disc(0)
-                flashsale_data = variant.with_context(price_for="web")._get_flashsale_price()
+            flashsale_data = variant.with_context(price_for="web")._get_flashsale_price()
 
-                price_excl_v2 = variant._v2_get_website_price_exclude_tax()
-                price_excl_after_disc_v2 = variant._v2_get_website_price_after_disc_and_tax()
-                tax_v2 = variant._v2_get_website_tax()
-
-            document = solr_model.get_doc('variants', variant.id)
-            document.update({
+            flashsale_doc = {
                 "id": variant.id,
                 "flashsale_id_i": flashsale_data.get('flashsale_id', 0),
                 "flashsale_tag_s": flashsale_data.get('flashsale_tag', ''),
@@ -101,25 +92,19 @@ class ProductProduct(models.Model):
                 "flashsale_base_price_f": flashsale_data.get('flashsale_base_price', 0),
                 "flashsale_discount_f": flashsale_data.get('flashsale_discount', 0),
                 "flashsale_price_f": flashsale_data.get('flashsale_price', 0),
-                "price_f": price_excl,
-                "discount_f": discount,
-                "price_discount_f": price_excl_after_disc,
-                "tax_f": tax,
-                "price_v2_f": price_excl_v2,
-                "price_discount_v2_f": price_excl_after_disc_v2,
-                "tax_v2_f": tax_v2,
-            })
-
-            for tier_number in [1, 2, 3, '1_v2', '2_v2', '3_v2', '4_v2', '5_v2']:
+            }
+            
+            price_doc = {}
+            
+            for tier_number in TIER_NUMBERS:
                 tier = variant._get_pricelist_tier(tier_number)
-                document.update({
-                    f"discount_tier{tier_number}_f": tier.get(f'discount_tier{tier_number}', 0),
-                    f"price_tier{tier_number}_f": tier.get(f'price_tier{tier_number}', 0),
-                })
-
-            # for tier_number in [1, 2, 3, '1_v2', '2_v2', '3_v2', '4_v2', '5_v2']:
-            #     tier = tier_data[tier_number]
+                price_doc[f"discount_tier{tier_number}_f"] = tier.get(f'discount_tier{tier_number}', 0)
+                price_doc[f"price_tier{tier_number}_f"] = tier.get(f'price_tier{tier_number}', 0)
 
+            document = solr_model.get_doc('variants', variant.id)
+            document['id'] = variant.id
+            document.update(flashsale_doc)
+            document.update(price_doc)
             document.update({"has_price_info_b": True})
 
             self.solr().add(docs=[document], softCommit=True)
@@ -185,4 +170,13 @@ class ProductProduct(models.Model):
             
             results.append(result)
         
-        return results
\ No newline at end of file
+        return results
+    
+    @api.constrains('unpublished')
+    def _constrains_unpublished(self):
+        for rec in self:
+            if rec.product_variant_count == 1:
+                rec.product_tmpl_id.unpublished = rec.unpublished
+            
+            rec.product_tmpl_id._create_solr_queue_sync_product_template()
+    
\ No newline at end of file