add all controllers logic

2026-03-11 17:53:15 -04:00
parent 3e6c577085
commit 2ef71cc92b
421 changed files with 12009 additions and 5211 deletions
@@ -0,0 +1,115 @@
+<?php
+
+namespace App\Services\Messaging;
+
+use App\Models\Message;
+use App\Models\User;
+use Illuminate\Contracts\Pagination\LengthAwarePaginator;
+
+class MessageQueryService
+{
+    public function getUserRoleName(int $userId): ?string
+    {
+        $user = User::query()->with('roles')->find($userId);
+        if (!$user) {
+            return null;
+        }
+
+        $role = $user->roles->sortBy('id')->first();
+        return $role ? (string) $role->name : null;
+    }
+
+    public function inbox(int $userId, array $filters, int $page, int $perPage): LengthAwarePaginator
+    {
+        return $this->baseQuery($filters)
+            ->where('recipient_id', $userId)
+            ->whereIn('status', ['sent', 'received'])
+            ->paginate($perPage, ['*'], 'page', $page);
+    }
+
+    public function sent(int $userId, array $filters, int $page, int $perPage): LengthAwarePaginator
+    {
+        return $this->baseQuery($filters)
+            ->where('sender_id', $userId)
+            ->where('status', 'sent')
+            ->paginate($perPage, ['*'], 'page', $page);
+    }
+
+    public function drafts(int $userId, array $filters, int $page, int $perPage): LengthAwarePaginator
+    {
+        return $this->baseQuery($filters)
+            ->where('sender_id', $userId)
+            ->where('status', 'draft')
+            ->paginate($perPage, ['*'], 'page', $page);
+    }
+
+    public function trash(int $userId, array $filters, int $page, int $perPage): LengthAwarePaginator
+    {
+        return $this->baseQuery($filters)
+            ->where('status', 'trashed')
+            ->where(function ($q) use ($userId) {
+                $q->where('sender_id', $userId)
+                    ->orWhere('recipient_id', $userId);
+            })
+            ->paginate($perPage, ['*'], 'page', $page);
+    }
+
+    public function receivedAndMarkRead(int $userId): array
+    {
+        $messages = Message::query()
+            ->with(['sender', 'recipient'])
+            ->where('recipient_id', $userId)
+            ->orderByDesc('sent_datetime')
+            ->get();
+
+        $ids = $messages
+            ->where('read_status', false)
+            ->pluck('id')
+            ->all();
+
+        if (!empty($ids)) {
+            Message::query()
+                ->whereIn('id', $ids)
+                ->update([
+                    'read_status' => 1,
+                    'read_datetime' => now(),
+                ]);
+        }
+
+        return $messages->all();
+    }
+
+    public function findForUser(int $messageId): ?Message
+    {
+        return Message::query()
+            ->with(['sender', 'recipient'])
+            ->find($messageId);
+    }
+
+    private function baseQuery(array $filters)
+    {
+        $query = Message::query()->with(['sender', 'recipient']);
+
+        if (!empty($filters['priority'])) {
+            $query->where('priority', $filters['priority']);
+        }
+
+        if (isset($filters['read_status'])) {
+            $query->where('read_status', (int) $filters['read_status']);
+        }
+
+        if (!empty($filters['search'])) {
+            $term = '%' . $filters['search'] . '%';
+            $query->where(function ($q) use ($term) {
+                $q->where('subject', 'like', $term)
+                    ->orWhere('message', 'like', $term);
+            });
+        }
+
+        $sortBy = $filters['sort_by'] ?? 'sent_datetime';
+        $sortDir = strtolower((string) ($filters['sort_dir'] ?? 'desc')) === 'asc' ? 'asc' : 'desc';
+        $query->orderBy($sortBy, $sortDir);
+
+        return $query;
+    }
+}