From 1d487206daf2b86821bf715f29823a2d477849ad Mon Sep 17 00:00:00 2001
From: merdan <merdan.m@gmail.com>
Date: Fri, 14 Jul 2023 11:25:32 +0500
Subject: [PATCH] cartitems also entered

---
 bagisto_models/product.go | 30 ++++++++++++++++++++++++++++++
 main.go                   |  2 +-
 2 files changed, 31 insertions(+), 1 deletion(-)

diff --git a/bagisto_models/product.go b/bagisto_models/product.go
index c1e7fa4..e7cc75a 100644
--- a/bagisto_models/product.go
+++ b/bagisto_models/product.go
@@ -152,6 +152,36 @@ func GetFlatSources(db *gorm.DB) ([]ProductAttributeValue, error) {
 	return productSources, nil
 }
 
+func GetCartSource(db *gorm.DB) ([]ProductAttributeValue, error) {
+	var wishlistSources []ProductAttributeValue
+	var cartSources []ProductAttributeValue
+	var productSources []ProductAttributeValue
+
+	err := db.Joins("JOIN wishlist wp ON product_attribute_values.product_id = wp.product_id").
+		Joins("JOIN marketplace_products mp ON product_attribute_values.product_id = mp.product_id").
+		Find(&wishlistSources, "mp.marketplace_seller_id=1 AND product_attribute_values.text_value IS NOT NULL AND product_attribute_values.attribute_id=31").Error
+
+	if err != nil {
+		log.Println(err.Error())
+
+	} else {
+		productSources = append(productSources, wishlistSources...)
+	}
+
+	err = db.Joins("JOIN cart_items ci ON product_attribute_values.product_id = ci.product_id").
+		Joins("JOIN marketplace_products mp ON product_attribute_values.product_id = mp.product_id").
+		Find(&cartSources, "mp.marketplace_seller_id=1 AND product_attribute_values.text_value IS NOT NULL AND product_attribute_values.attribute_id=31").Error
+
+	if err != nil {
+		log.Println(err.Error())
+
+	} else {
+		productSources = append(productSources, cartSources...)
+	}
+
+	return productSources, nil
+}
+
 //func DisableProducts (db *gorm.DB) error {
 //	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
 //	defer cancel()
diff --git a/main.go b/main.go
index 15d3196..154382f 100644
--- a/main.go
+++ b/main.go
@@ -82,7 +82,7 @@ func worker(db *gorm.DB, stopCh <-chan struct{}, updatePeriod time.Duration) {
 			return
 		case <-ticker.C:
 
-			result, err := bagisto_models.GetFlatSources(db)
+			result, err := bagisto_models.GetCartSource(db)
 			if err != nil {
 				log.Println("Error retrieving products:", err)
 				continue