更新 message-service 通知

message/message-api/src/main/java/cn/reghao/tnb/message/api/dto/msg/VerifyMessage.java

@@ -15,7 +15,7 @@ public class VerifyMessage extends BaseMessage {
     private String title;
     private String content;
 
-    public VerifyMessage(String receiver, String title, String content) {
+    public VerifyMessage(String title, String content, String receiver) {
         super(NotifyType.webhook.getValue(), MsgType.verifyMsg.getValue(), receiver);
         this.title = title;
         this.content = content;

message/message-service/src/main/java/cn/reghao/tnb/message/app/service/MessageConsumer.java

@@ -1,6 +1,7 @@
 package cn.reghao.tnb.message.app.service;
 
 import cn.reghao.jutil.jdk.serializer.JsonConverter;
+import cn.reghao.tnb.common.util.ConstantId;
 import cn.reghao.tnb.message.api.constant.MsgType;
 import cn.reghao.tnb.message.api.dto.msg.RtmpMessage;
 import cn.reghao.tnb.message.app.model.msg.DingMsgUtil;
@@ -8,6 +9,7 @@ import cn.reghao.tnb.message.app.service.notifier.ding.DingMsg;
 import cn.reghao.tnb.message.api.constant.NotifyType;
 import cn.reghao.tnb.message.api.dto.msg.LoginMessage;
 import cn.reghao.tnb.message.api.dto.msg.VerifyMessage;
+import cn.reghao.tnb.user.api.dto.UserMessageDto;
 import cn.reghao.tnb.user.api.iface.UserService;
 import com.google.gson.JsonObject;
 import lombok.extern.slf4j.Slf4j;
@@ -68,5 +70,10 @@ public class MessageConsumer {
             String webhookName = "ding_bdbot";
             notifyService.notify(webhookName, dingMsg);
         }
+
+        String title = "webhook 通知";
+        String content = String.format("发送 %s 消息, 消息内容: %s", msgType.name(), jsonPayload);
+        UserMessageDto userMessageDto = new UserMessageDto(title, content, ConstantId.ANONYMOUS_USER_ID);
+        userService.sendUserMessage(userMessageDto);
     }
 }