From 8c0c5f80406bbf2537dfdb6ef2c4b0b2ed4681c8 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Mon, 7 Jul 2025 11:14:34 +0700
Subject: [PATCH] add response websocket

---
 src/services/rabbitmq.ts | 26 ++++++++++++++++++++++----
 1 file changed, 22 insertions(+), 4 deletions(-)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 44b2e626..7da207c2 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -394,7 +394,18 @@ async function handler_org(msg: amqp.ConsumeMessage): Promise<boolean> {
   const child2Repository = AppDataSource.getRepository(OrgChild2);
   const child3Repository = AppDataSource.getRepository(OrgChild3);
   const child4Repository = AppDataSource.getRepository(OrgChild4);
-
+  const { data, token, user } = JSON.parse(msg.content.toString());
+  const { id, status, lastUpdateUserId, lastUpdateFullName, lastUpdatedAt } = data;
+  if (user) {
+    sendWebSocket(
+      "send-publish-org",
+      {
+        success: true,
+        message: `ระบบกำลังทำการแพร่โครงสร้างหน่วยงาน`,
+      },
+      { userId: user?.sub },
+    ).catch(console.error);
+  }
   const orgRevisionPublish = await repoOrgRevision
     .createQueryBuilder("orgRevision")
     .where("orgRevision.orgRevisionIsDraft = false")
@@ -418,8 +429,6 @@ async function handler_org(msg: amqp.ConsumeMessage): Promise<boolean> {
     orgRevisionDraft.orgRevisionIsDraft = false;
     await repoOrgRevision.save(orgRevisionDraft);
   }
-  const { data, token, user } = JSON.parse(msg.content.toString());
-  const { id, status, lastUpdateUserId, lastUpdateFullName, lastUpdatedAt } = data;
   try {
     const posMaster = await repoPosmaster.find({
       where: { orgRevisionId: id },
@@ -1443,7 +1452,16 @@ async function handler_org_draft(msg: amqp.ConsumeMessage): Promise<boolean> {
   const child2Repository = AppDataSource.getRepository(OrgChild2);
   const child3Repository = AppDataSource.getRepository(OrgChild3);
   const child4Repository = AppDataSource.getRepository(OrgChild4);
-
+  if (user) {
+    sendWebSocket(
+      "send-publish-org",
+      {
+        success: true,
+        message: `ระบบกำลังทำการสร้างโครงสร้างหน่วยงาน`,
+      },
+      { userId: user?.sub },
+    ).catch(console.error);
+  }
   try {
     //cone tree
     if (