From 384d63761026d2414b3c95b118f118954ddf2dda Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Wed, 9 Apr 2025 14:21:43 +0700
Subject: [PATCH] fix rabbit

---
 src/services/rabbitmq.ts | 62 +++++++++++++++++++++-------------------
 1 file changed, 33 insertions(+), 29 deletions(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 8640472c..7785b03a 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -123,15 +123,17 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
     relations: ["commandType", "commandRecives"],
   });
   if (!command) return true;
-  sendWebSocket(
-    "send-command-notification",
-    {
-      success: true,
-      message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`,
-      payload: command,
-    },
-    { userId: user.sub ?? "" },
-  ).catch(console.error);
+  if (user) {
+    sendWebSocket(
+      "send-command-notification",
+      {
+        success: true,
+        message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`,
+        payload: command,
+      },
+      { userId: user?.sub },
+    ).catch(console.error);
+  }
   const path = commandTypePath(command.commandType.code);
   if (path == null) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบประเภทคำสั่งนี้ในระบบ");
   return await new CallAPI()
@@ -166,30 +168,32 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
       console.log("[AMQ] Excecute Command Success");
       Object.assign(command, { status, lastUpdateUserId, lastUpdateFullName, lastUpdatedAt });
       const result = await repo.save(command).catch((e) => console.log(e));
-
-      sendWebSocket(
-        "send-command-notification",
-        {
-          success: true,
-          message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`,
-          payload: command,
-        },
-        { userId: user.sub ?? "" },
-      ).catch(console.error);
-
+      if(user){
+        sendWebSocket(
+          "send-command-notification",
+          {
+            success: true,
+            message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`,
+            payload: command,
+          },
+          { userId: user?.sub},
+        ).catch(console.error);
+      }
       return !!result;
     })
     .catch((e) => {
       console.error(e);
-      sendWebSocket(
-        "send-command-notification",
-        {
-          success: false,
-          message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด`,
-          payload: command,
-        },
-        { userId: user.sub ?? "" },
-      ).catch(console.error);
+      if(user){
+        sendWebSocket(
+          "send-command-notification",
+          {
+            success: false,
+            message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด`,
+            payload: command,
+          },
+          { userId: user?.sub},
+        ).catch(console.error);
+      }
       return false;
     });
 }