diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index e8322ef..0e31422 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -59,7 +59,7 @@ public class MessageConsumerService implements RocketMQListener { // ... [保持原有响应处理逻辑] if (ObjectUtil.isNotEmpty(responseStr)) { JSONObject response = JSONObject.parseObject(responseStr); - //logger.info("消息成功发送并得到响应:{}", response); + logger.info("消息成功发送并得到响应:{}", response); if (response.getInteger("code") != 200) { // TODO: 如果需要处理错误,您可以在这里添加逻辑 wxtsUtil.sendNotify("消息发送失败: " + responseStr); diff --git a/src/main/java/cn/van/business/util/WXUtil.java b/src/main/java/cn/van/business/util/WXUtil.java index 09c4d15..9a0b2d1 100644 --- a/src/main/java/cn/van/business/util/WXUtil.java +++ b/src/main/java/cn/van/business/util/WXUtil.java @@ -58,7 +58,7 @@ public class WXUtil { jdidToWxidMap.put(admin2.getUnionId(), admin2.getWxid()); //wxTsUtil.sendNotify("initSuperAdmins 初始化完成"); //发送通知到微信 - sendTextMessage(default_super_admin_wxid,"Jarvis 重启完成", 1, default_super_admin_wxid); + sendTextMessage(default_super_admin_wxid,"Jarvis 重启完成 ✅ ", 1, default_super_admin_wxid); }