merge: ragil-before-sso from development-before-sso

internal/modules/inventory/product-warehouses/services/product_warehouse.service.go

@@ -49,8 +49,30 @@ func (s productWarehouseService) GetAll(c *fiber.Ctx, params *validation.Query)
 		return nil, 0, err
 	}
 
+	if params.ProductId > 0 {
+		isProductExist, err := s.Repository.IsProductExist(c.Context(), params.ProductId)
+		if err != nil {
+			return nil, 0, err
+		}
+		if !isProductExist {
+			return nil, 0, fiber.NewError(fiber.StatusNotFound, "Product not found")
+		}
+	}
+
+	if params.WarehouseId > 0 {
+		isWarehouseExist, err := s.Repository.IsWarehouseExist(c.Context(), params.WarehouseId)
+		if err != nil {
+			return nil, 0, err
+		}
+		if !isWarehouseExist {
+			return nil, 0, fiber.NewError(fiber.StatusNotFound, "Warehouse not found")
+		}
+	}
+
 	offset := (params.Page - 1) * params.Limit
 
+	cleanFlags := utils.ParseFlags(params.Flags)
+
 	productWarehouses, total, err := s.Repository.GetAll(c.Context(), offset, params.Limit, func(db *gorm.DB) *gorm.DB {
 		db = s.withRelations(db)
 
@@ -62,6 +84,12 @@ func (s productWarehouseService) GetAll(c *fiber.Ctx, params *validation.Query)
 			db = db.Where("warehouse_id = ?", params.WarehouseId)
 		}
 
+		if len(cleanFlags) > 0 {
+			db = db.Joins("JOIN products ON products.id = product_warehouses.product_id").
+				Joins("JOIN flags ON flags.flagable_id = products.id AND flags.flagable_type = ?", "products").
+				Where("flags.name IN ?", cleanFlags)
+		}
+
 		return db.Order("created_at DESC").Order("updated_at DESC")
 	})