diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 968c3052..6f379825 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -123,12 +123,20 @@ async function handler(msg: amqp.ConsumeMessage): Promise { relations: ["commandType", "commandRecives"], }); if (!command) return true; + let waiting_message = `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`; + let success_message = `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`; + let error_message = `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด` + if(command.commandType?.code == "C-PM-47"){ + waiting_message = `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}`; + success_message = `ระบบออกคำสั่งเลขที่ ${command.commandNo} เสร็จสิ้น`; + error_message = `ระบบออกคำสั่งเลขที่ ${command.commandNo} ผิดพลาด`; + } if (user) { sendWebSocket( "send-command-notification", { success: true, - message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`, + message: waiting_message, payload: command, }, { userId: user?.sub }, @@ -137,7 +145,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise { const path = commandTypePath(command.commandType.code); if (path == null) throw new HttpError(HttpStatusCode.NOT_FOUND, "ไม่พบประเภทคำสั่งนี้ในระบบ"); return await new CallAPI() - + .PostData( { headers: { authorization: token }, @@ -173,7 +181,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise { "send-command-notification", { success: true, - message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`, + message: success_message, payload: command, }, { userId: user?.sub }, @@ -188,7 +196,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise { "send-command-notification", { success: false, - message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด`, + message: error_message, payload: command, }, { userId: user?.sub }, diff --git a/src/services/webSocket.ts b/src/services/webSocket.ts index 2f9b42ff..36359cd8 100644 --- a/src/services/webSocket.ts +++ b/src/services/webSocket.ts @@ -45,7 +45,8 @@ export async function sendWebSocket( }, ) { if (!io) initWebSocket(); - + // console.log( `🔔 :`,data.message); + for (let [id, session] of io.of("/").sockets) { const user: { sub: string;