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<ModSetupResultVO> 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("计算失败"));
         }
     }