From 383a8019a8a1b4c1cce32323c10813991cc8d5c3 Mon Sep 17 00:00:00 2001 From: Allenxy <13762749+chaosallen@user.noreply.gitee.com> Date: Sat, 11 Jan 2025 20:54:09 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E4=B8=8B=E5=8F=91=E9=92=A2=E5=8D=B7?= =?UTF-8?q?=E8=AE=BE=E5=AE=9A=E5=80=BC=E8=AF=B7=E6=B1=82=E5=88=B0=E6=A8=A1?= =?UTF-8?q?=E5=9E=8B=E7=A8=8B=E5=BA=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java b/business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java index 547ab04..a969948 100644 --- a/business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java +++ b/business/src/main/java/com/fizz/business/mq/RabbitMQ/RabbitQueueListener.java @@ -64,7 +64,7 @@ public class RabbitQueueListener { String messageId = (String) headers.get("amqp_messageId"); // 处理消息逻辑 todo - if ("someUniqueMessageId".equals(messageId)) { + if ("TOTAL_PRESET_DONE".equalsIgnoreCase(messageId)) { List setup = modSetupResultService.getSetupByCoilid(message); @@ -74,8 +74,8 @@ public class RabbitQueueListener { modSetupResultKeyVO.setLists(setup); //socket WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr(modSetupResultKeyVO)); - } else { - // 默认的处理逻辑 + } else if ("TOTAL_PRESET_FAILED".equalsIgnoreCase(messageId)) { + WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr("计算失败")); } }