fix : chat modules, notifications

ci4/app/Models/Chat/ChatDeparmentModel.php

@@ -59,7 +59,7 @@ class ChatDeparmentModel extends Model
                     'chat_departments.id',
                     'chat_departments.name',
                     'chat_departments.display',
-                    'chat_department_users.user_id'
+                    'chat_department_users.user_id',
                 ]
             )
             ->join(

ci4/app/Models/Chat/ChatMessageModel.php

@@ -118,4 +118,27 @@ class ChatMessageModel extends Model
             ->where("receiver_id", auth()->user()->id)->update();
         return $messagesFromReceiver;
     }
+    public function set_chat_department_messages_as_read(int $chat_id): int
+    {
+        $chatDepartmentModel = model(ChatDeparmentModel::class);
+        $chatModel = model(ChatModel::class);
+
+        if(auth()->user()->cliente_id){
+            $messagesFromReceiver = $this->builder()
+            ->set("viewed", true)
+            ->where("chat_id", $chat_id)
+            ->whereNotIn("sender_id", [auth()->user()->id])->update();
+        }else{
+            $chat_department_id = $chatModel->find($chat_id)->chat_department_id;
+            $users_in_chat = array_map(fn($x) => $x->id, $chatDepartmentModel->getChatDepartmentUsers($chat_department_id));
+            $messagesFromReceiver = $this->builder()
+            ->set("viewed", true)
+            ->where("chat_id", $chat_id)
+            ->whereNotIn("sender_id", $users_in_chat)
+            ->update();
+        }
+        
+        return $messagesFromReceiver;
+    }
+
 }

ci4/app/Models/Chat/ChatModel.php

@@ -2,6 +2,9 @@
 
 namespace App\Models\Chat;
 
+use App\Models\Facturas\FacturaModel;
+use App\Models\Pedidos\PedidoModel;
+use App\Models\Presupuestos\PresupuestoModel;
 use App\Models\Usuarios\UserModel;
 use CodeIgniter\Model;
 use stdClass;
@@ -11,7 +14,7 @@ class ChatModel extends Model
     protected $table            = 'chats';
     protected $primaryKey       = 'id';
     protected $useAutoIncrement = true;
-    protected $returnType       = 'array';
+    protected $returnType       = 'object';
     protected $useSoftDeletes   = false;
     protected $protectFields    = true;
     protected $allowedFields    = [
@@ -204,14 +207,18 @@ class ChatModel extends Model
         ])
         ->join("chat_departments","chat_departments.id = chats.chat_department_id","left")
         ->join("pedidos","pedidos.id = chats.pedido_id","left")
-        ->join("chat_messages","pedidos.id = chats.pedido_id","left")
-        ->whereNotIn("chat_messages.sender_id",[auth()->user()->id])
         ->whereIn("pedidos.id",$pedidos)
         ->get()->getResultObject();
         $chatMessageModel = model(ChatMessageModel::class);
-        
+        $count = 0;
         foreach ($results as $row) {
-            $row->messages = $chatMessageModel->get_chat_messages($row->chatId);
+            $messages = $chatMessageModel->get_chat_messages($row->chatId);
+            foreach ($messages as $key => $message) {
+                if($message->sender_id != auth()->user()->id && $message->viewed == false){
+                    $count++;
+                }
+            }
+            $row->unreadMessages=$count;
         }
         return $results;
     }
@@ -227,14 +234,18 @@ class ChatModel extends Model
         ])
         ->join("chat_departments","chat_departments.id = chats.chat_department_id","left")
         ->join("facturas","facturas.id = chats.factura_id","left")
-        ->join("chat_messages","chats.id = chat_messages.chat_id","left")
-        ->whereNotIn("chat_messages.sender_id",[auth()->user()->id])
         ->whereIn("facturas.id",$facturas)
         ->get()->getResultObject();
         $chatMessageModel = model(ChatMessageModel::class);
-        
+        $count = 0;
         foreach ($results as $row) {
-            $row->messages = $chatMessageModel->get_chat_messages($row->chatId);
+            $messages = $chatMessageModel->get_chat_messages($row->chatId);
+            foreach ($messages as $key => $message) {
+                if($message->sender_id != auth()->user()->id && $message->viewed == false){
+                    $count++;
+                }
+            }
+            $row->unreadMessages=$count;
         }
         return $results;
     }
@@ -250,16 +261,99 @@ class ChatModel extends Model
         ])
         ->join("chat_departments","chat_departments.id = chats.chat_department_id","left")
         ->join("presupuestos","presupuestos.id = chats.presupuesto_id","left")
-        ->join("chat_messages","chats.id = chat_messages.chat_id","left")
-        ->whereNotIn("chat_messages.sender_id",[auth()->user()->id])
         ->whereIn("presupuestos.id",$presupuestos)
         ->get()->getResultObject();
         $chatMessageModel = model(ChatMessageModel::class);
-        
+        $count = 0;
         foreach ($results as $row) {
-            $row->messages = $chatMessageModel->get_chat_messages($row->chatId);
+            $messages = $chatMessageModel->get_chat_messages($row->chatId);
+            foreach ($messages as $key => $message ) {
+                if($message->sender_id != auth()->user()->id && $message->viewed == false){
+                    $count++;
+                }
+            }
+            $row->unreadMessages=$count;
         }
-
+        
         return $results;
     }
+    public function getChatDepartmentNotifications()
+    {
+        $chatMessageModel = model(ChatMessageModel::class);
+        $presupuestoModel = model(PresupuestoModel::class);
+        $facturaModel = model(FacturaModel::class);
+        $pedidoModel = model(PedidoModel::class);
+
+        $q = $this->db->table("chats")
+        ->select([
+            "chats.id as chatId",
+            "chats.pedido_id as pedidoId",
+            "chats.presupuesto_id as presupuestoId",
+            "chats.factura_id as facturaId",
+            "chats.presupuesto_id as presupuestoId",
+            "chats.chat_department_id as chatDepartmentId",
+            "chat_departments.display as chatDisplay",
+        ])
+        ->join("chat_departments","chat_departments.id = chats.chat_department_id","left")
+        ->join("chat_department_users","chat_department_users.chat_department_id = chats.chat_department_id","left")
+        ->where("chat_department_users.user_id",auth()->user()->id);
+        $rows = $q->get()->getResultObject();
+        
+        foreach ($rows as $row) {
+            $messages = $chatMessageModel->get_chat_messages($row->chatId);
+            $count = 0;
+            foreach ($messages as $m) {
+                if($m->viewed == false && $m->sender_id != auth()->user()->id) 
+                    $count++;
+            }
+            if($row->presupuestoId){
+                $row->model = $presupuestoModel->find($row->presupuestoId);
+                $row->uri = "/presupuestos/cosidotapablanda/edit/".$row->presupuestoId;
+                $row->title = $row->presupuestoId;
+                $row->avatar = "PRE";
+                $row->unreadMessages = $count;
+            }
+            elseif($row->pedidoId){
+                $row->model = $pedidoModel->find($row->pedidoId);
+                $row->uri = "/pedidos/edit/".$row->pedidoId;
+                $row->title = $row->pedidoId;
+                $row->avatar = "P";
+                $row->unreadMessages = $count;
+
+            }
+            elseif($row->facturaId){
+                $row->model = $facturaModel->find($row->facturaId);
+                $row->uri = "/facturas/edit/".$row->facturaId;
+                $row->avatar = "F";
+                $row->title = $row->facturaId;
+                $row->unreadMessages = $count;
+            }
+        }
+        return $rows;
+
+    }
+    public function getChatInternalNotifications()
+    {
+        $chatMessageModel = model(ChatMessageModel::class);
+        $userModel = model(UserModel::class);
+        $internalMessages = $chatMessageModel->builder()
+        ->select([
+            "chat_id as chatId",
+            "sender_id",
+            "COUNT(viewed) as unreadMessages",
+        ])
+        ->where("receiver_id",auth()->user()->id)
+        ->where("viewed",false)->get()->getResultObject();
+        foreach ($internalMessages as $m) {
+            if($m->sender_id){
+                $sender = $userModel->find($m->sender_id);
+                $m->model = $sender;
+                $m->title = $sender->username;
+                $m->chatDisplay = ($sender->first_name ?? "")." ".($sender->last_name ?? "");
+                $m->avatar = strtoupper(mb_substr($sender->first_name, 0, 1).mb_substr($sender->last_name, 0, 1));
+                $m->uri = "#";
+            }
+        }
+        return $internalMessages;
+    }
 }