From 61a532cae850cad8bcba8eeec6735f01eb2a6724 Mon Sep 17 00:00:00 2001
From: AdisakKanthawilang <adisak@frappet.com>
Date: Wed, 30 Oct 2024 15:38:29 +0700
Subject: [PATCH 1/2] fix

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

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 15ec316b..8bd75016 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -32,14 +32,14 @@ export async function init() {
     });
   };
 
-  // sendToQueueOrg = (payload: any, persistent = true) => {
-  //   channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
-  // };
+  sendToQueueOrg = (payload: any, persistent = true) => {
+    channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
+  };
 
   console.log("[AMQ] Listening for message...");
 
   createConsumer(queue, channel, handler); //----> (3) Process Consumer
-  // createConsumer(queue_org, channel, handler_org);
+  createConsumer(queue_org, channel, handler_org);
   // createConsumer(queue2, channel, handler2);
 }
 

From 711fa04a7771dc66439c6b62bdc23fcd7bc0dce0 Mon Sep 17 00:00:00 2001
From: waruneeauy <warunee.auy@gmail.com>
Date: Wed, 30 Oct 2024 16:19:14 +0700
Subject: [PATCH 2/2] fixing view workflow

---
 src/controllers/ViewWorkFlowController.ts | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/src/controllers/ViewWorkFlowController.ts b/src/controllers/ViewWorkFlowController.ts
index 7ad87cad..1ca64578 100644
--- a/src/controllers/ViewWorkFlowController.ts
+++ b/src/controllers/ViewWorkFlowController.ts
@@ -33,10 +33,22 @@ export class ViewWorkFlowController extends Controller {
     const lists = await this.metaWorkflowRepository
       .createQueryBuilder("metaWorkflow")
       .select(["metaWorkflow.name", "metaWorkflow.sysName"])
-      .groupBy("metaWorkflow.name")
+      // .groupBy("metaWorkflow.name")
       .getMany();
 
-    return new HttpSuccess(lists);
+    const sys: any = [];
+
+    for (let index = 0; index < lists.length; index++) {
+      const element = await lists[index];
+      if (sys.findIndex((x: any) => x.sysName === element.sysName) === -1) {
+        sys.push({
+          sysName: element.sysName,
+          name: element.name,
+        });
+      }
+    }
+
+    return new HttpSuccess(sys);
   }
 
   @Get("")