Seems like the basic query feature is now working for Segment with dy…

…namic rule based query
amitavroy · Jan 5, 2025 · 0d1bd95 · 0d1bd95
1 parent 8d60310
commit 0d1bd95
Show file tree

Hide file tree

Showing 5 changed files with 69 additions and 4 deletions.
diff --git a/app/Domain/Segment/Rules/MinimumPurchaseValueRule.php b/app/Domain/Segment/Rules/MinimumPurchaseValueRule.php
@@ -2,9 +2,16 @@
 
 namespace App\Domain\Segment\Rules;
 
+use Illuminate\Database\Eloquent\Builder;
+
 class MinimumPurchaseValueRule implements SegmentRuleInterface
 {
-    public function execute(): void {}
+    public function execute(Builder $query): void
+    {
+        $query->whereHas('orders', function ($query) {
+            $query->where('total_amount', '>', 1000);
+        });
+    }
 
     public function getFriendlyName(): string
     {

diff --git a/app/Domain/Segment/Rules/SegmentRuleInterface.php b/app/Domain/Segment/Rules/SegmentRuleInterface.php
@@ -2,9 +2,11 @@
 
 namespace App\Domain\Segment\Rules;
 
+use Illuminate\Database\Eloquent\Builder;
+
 interface SegmentRuleInterface
 {
     public function getFriendlyName(): string;
 
-    public function execute(): void;
+    public function execute(Builder $query): void;
 }
diff --git a/app/Domain/Segment/Rules/TotalPurchaseValueRule.php b/app/Domain/Segment/Rules/TotalPurchaseValueRule.php
@@ -2,9 +2,19 @@
 
 namespace App\Domain\Segment\Rules;
 
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Support\Facades\DB;
+
 class TotalPurchaseValueRule implements SegmentRuleInterface
 {
-    public function execute(): void {}
+    public function execute(Builder $query): void
+    {
+        $query->whereHas('orders', function ($query) {
+            $query->select(DB::raw('SUM(total_amount) as total_sum'))
+                ->groupBy('user_id')
+                ->havingRaw('SUM(total_amount) >= ?', [1000]);
+        });
+    }
 
     public function getFriendlyName(): string
     {

diff --git a/app/Domain/Segment/Services/SegmentRuleService.php b/app/Domain/Segment/Services/SegmentRuleService.php
@@ -2,16 +2,20 @@
 
 namespace App\Domain\Segment\Services;
 
+use App\Domain\Segment\Models\Segment;
 use App\Domain\Segment\Rules\MinimumPurchaseValueRule;
 use App\Domain\Segment\Rules\TotalPurchaseValueRule;
+use App\Services\UserService;
+use Exception;
+use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Support\Collection;
 
 class SegmentRuleService
 {
     /**
      * @return Collection<string, string>
      */
-    public function getRuleMapping(): Collection
+    private function getRuleMapping(): Collection
     {
         return collect([
             'total_purchase_value' => TotalPurchaseValueRule::class,
@@ -37,4 +41,26 @@ public function getRuleNames(): Collection
 
         return $ruleNames;
     }
+
+    /**
+     * @throws Exception
+     */
+    public function segmentQuery(Segment $segment): Builder
+    {
+        $query = app(UserService::class)->getBaseUserQueryForSegment();
+
+        $rules = collect($segment->rules);
+
+        $rules->each(function ($rule) use ($query) {
+            $allowedRules = $this->getRuleMapping();
+
+            if (! $allowedRules->has($rule['rule_name'])) {
+                throw new Exception('No such rule exist');
+            }
+
+            app($allowedRules[$rule['rule_name']])->execute($query);
+        });
+
+        return $query;
+    }
 }
diff --git a/app/Services/UserService.php b/app/Services/UserService.php
@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Services;
+
+use App\Enum\UserRole;
+use App\Models\User;
+use Illuminate\Database\Eloquent\Builder;
+
+class UserService
+{
+    /**
+     * @return Builder<User>
+     */
+    public function getBaseUserQueryForSegment(): Builder
+    {
+        return User::query()
+            ->withSum('orders', 'total_amount')
+            ->where('role', UserRole::CUSTOMER->value);
+    }
+}