From 58e080264dff0365683d56e9c42581a0b84d8634 Mon Sep 17 00:00:00 2001
From: Allenxy <13762749+chaosallen@user.noreply.gitee.com>
Date: Sat, 11 Jan 2025 20:10:26 +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

---
 .../mq/RabbitMQ/RabbitQueueListener.java      | 23 ++++++++++++++-----
 .../impl/ModSetupResultServiceImpl.java       |  5 +++-
 2 files changed, 21 insertions(+), 7 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 c06fbe2..547ab04 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
@@ -3,7 +3,11 @@ package com.fizz.business.mq.RabbitMQ;
 import cn.hutool.json.JSONUtil;
 import com.fizz.business.constants.CommonConstants;
 import com.fizz.business.constants.enums.WsTypeEnum;
+import com.fizz.business.service.ModSetupResultService;
+import com.fizz.business.service.impl.ModSetupResultServiceImpl;
 import com.fizz.business.utils.WebSocketUtil;
+import com.fizz.business.vo.ModSetupResultKeyVO;
+import com.fizz.business.vo.ModSetupResultVO;
 import com.google.common.collect.Lists;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
@@ -20,6 +24,9 @@ import java.util.Map;
 public class RabbitQueueListener {
 
     public static List<String> measureList = Lists.newArrayList();
+
+    ModSetupResultService modSetupResultService;
+
     private Double LastRolledLength = 0d;
 //    @RabbitListener(queues = CommonConstants.RabbitMQ.RECEIVE_MODEL)
 //    @RabbitHandler
@@ -56,13 +63,17 @@ public class RabbitQueueListener {
         // 获取 messageId
         String messageId = (String) headers.get("amqp_messageId");
 
-        // 根据 messageId 进行不同的消息处理
-        System.out.println("Received message with ID: " + messageId);
-        System.out.println("Message Content: " + message);
-
-        // 处理消息逻辑
+        // 处理消息逻辑 todo
         if ("someUniqueMessageId".equals(messageId)) {
-            // 针对特定的消息ID进行处理
+
+            List<ModSetupResultVO> setup = modSetupResultService.getSetupByCoilid(message);
+
+
+            ModSetupResultKeyVO modSetupResultKeyVO = new ModSetupResultKeyVO();
+            modSetupResultKeyVO.setKey(ModSetupResultServiceImpl.WS_EKY);
+            modSetupResultKeyVO.setLists(setup);
+            //socket
+            WebSocketUtil.sendMessage(WsTypeEnum.calc_setup_result,JSONUtil.toJsonStr(modSetupResultKeyVO));
         } else {
             // 默认的处理逻辑
         }
diff --git a/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java b/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
index 57fe6e1..cc805dd 100644
--- a/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
+++ b/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
@@ -33,6 +33,7 @@ public class ModSetupResultServiceImpl extends ServiceImpl<ModSetupResultMapper,
     @Resource
     RabbitTemplate rabbitTemplate;
 
+    public static String  WS_EKY = "";
 
     @Override
     public List<ModSetupResultVO> list(ModSetupResultForm form) {
@@ -89,7 +90,9 @@ public class ModSetupResultServiceImpl extends ServiceImpl<ModSetupResultMapper,
 //        new Thread(() -> mockCalcResult(form.getCoilid(), resultString)).start();
 
         // 返回值会先返回给调用者
-        return form.getCoilid() + timestampMillis;
+        String string = form.getCoilid() + timestampMillis;
+        WS_EKY = string;
+        return string;
     }
 
     private void mockCalcResult(String coilid, String string) {