diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts index 23adf4ef..7a0afa53 100644 --- a/src/services/rabbitmq.ts +++ b/src/services/rabbitmq.ts @@ -149,7 +149,9 @@ async function handler(msg: amqp.ConsumeMessage): Promise { .map((x) => ({ refId: x.refId, commandNo: command.commandNo, - commandYear: command.commandYear, + commandYear: command.commandYear > 2500 + ? command.commandYear + : command.commandYear + 543, commandId: command.id, remark: command.positionDetail, amount: x.amount,