1

2025-12-05 22:35:51 +08:00
parent ee67d1ae8f
commit 8445b500ae
5 changed files with 68 additions and 7 deletions
--- a/src/main/java/cn/van/business/mq/MessageConsumerService.java
+++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java
@@ -61,8 +61,9 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
                Integer msgType = data.getInteger("msgType");
                String fromWxid = data.getString("fromWxid");
                Boolean hiddenTime = data.getBoolean("hiddenTime");
+                String touser = data.getString("touser"); // 获取接收人参数

-                wxtsUtil.sendWxTextMessage(wxid, content, msgType, fromWxid, hiddenTime);
+                wxtsUtil.sendWxTextMessage(wxid, content, msgType, fromWxid, hiddenTime, touser);