hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Merge branch 'feat/socket-message-type' into develop

Browse source
This commit is contained in:
Methapon2001 2025-04-01 11:35:42 +07:00
commit 65ba3c73e2
1 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/services/rabbitmq.ts
View file

@ -126,6 +126,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
sendWebSocket( sendWebSocket(
"send-command-notification", "send-command-notification",
{ {
success: true,
message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`, message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`,
payload: command, payload: command,
}, },
@ -169,6 +170,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
sendWebSocket( sendWebSocket(
"send-command-notification", "send-command-notification",
{ {
success: true,
message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`, message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`,
payload: command, payload: command,
}, },
@ -179,6 +181,15 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
}) })
.catch((e) => { .catch((e) => {
console.error(e); console.error(e);
sendWebSocket(
"send-command-notification",
{
success: false,
message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด`,
payload: command,
},
{ userId: user.sub },
).catch(console.error);
return false; return false;
}); });
} }