From 84edbccb1b10c1ef0bbd69632a63716a9ea7ba8a Mon Sep 17 00:00:00 2001
From: MerCry <jiong1114>
Date: Tue, 24 Feb 2026 11:17:46 +0800
Subject: [PATCH] =?UTF-8?q?fix(TASK-031):=20=E4=BF=AE=E5=A4=8D=20Java=208?=
 =?UTF-8?q?=20=E5=85=BC=E5=AE=B9=E6=80=A7=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将 Map.of() 替换为 HashMap

- 添加 HashMap import
---
 .../service/impl/MessageRouterServiceImpl.java | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/wecom/robot/service/impl/MessageRouterServiceImpl.java b/src/main/java/com/wecom/robot/service/impl/MessageRouterServiceImpl.java
index 2a75e1e..bda8152 100644
--- a/src/main/java/com/wecom/robot/service/impl/MessageRouterServiceImpl.java
+++ b/src/main/java/com/wecom/robot/service/impl/MessageRouterServiceImpl.java
@@ -15,6 +15,7 @@ import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
@@ -129,15 +130,14 @@ public class MessageRouterServiceImpl implements MessageRouterService {
         log.info("[AC-MCA-10] 分发到人工客服: sessionId={}, manualCsId={}",
                 session.getSessionId(), session.getManualCsId());
 
-        Map<String, Object> wsMessage = Map.of(
-                "type", "customer_message",
-                "sessionId", session.getSessionId(),
-                "content", message.getContent(),
-                "msgType", message.getMsgType(),
-                "customerId", message.getCustomerId(),
-                "channelType", message.getChannelType(),
-                "timestamp", System.currentTimeMillis()
-        );
+        Map<String, Object> wsMessage = new HashMap<>();
+        wsMessage.put("type", "customer_message");
+        wsMessage.put("sessionId", session.getSessionId());
+        wsMessage.put("content", message.getContent());
+        wsMessage.put("msgType", message.getMsgType());
+        wsMessage.put("customerId", message.getCustomerId());
+        wsMessage.put("channelType", message.getChannelType());
+        wsMessage.put("timestamp", System.currentTimeMillis());
 
         webSocketService.notifyNewMessage(session.getSessionId(), 
                 createWxCallbackMessage(message));