Commit b5528bfc15e2765bfeba0537656bb46669d209f4

Authored by puhui999
1 parent 4a395955

MALL-KEFU: 发送消息通知所有管理员更新对话

yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/kefu/KeFuMessageServiceImpl.java
@@ -66,8 +66,10 @@ public class KeFuMessageServiceImpl implements KeFuMessageService { @@ -66,8 +66,10 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
66 // 2.2 更新会话消息冗余 66 // 2.2 更新会话消息冗余
67 conversationService.updateConversationLastMessage(kefuMessage); 67 conversationService.updateConversationLastMessage(kefuMessage);
68 68
69 - // 3. 发送消息 69 + // 3.1 发送消息给会员
70 getSelf().sendAsyncMessageToMember(conversation.getUserId(), KEFU_MESSAGE_TYPE, kefuMessage); 70 getSelf().sendAsyncMessageToMember(conversation.getUserId(), KEFU_MESSAGE_TYPE, kefuMessage);
  71 + // 3.2 通知所有管理员更新对话
  72 + getSelf().sendAsyncMessageToAdmin(KEFU_MESSAGE_TYPE, kefuMessage);
71 return kefuMessage.getId(); 73 return kefuMessage.getId();
72 } 74 }
73 75
@@ -82,7 +84,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService { @@ -82,7 +84,7 @@ public class KeFuMessageServiceImpl implements KeFuMessageService {
82 84
83 // 2. 更新会话消息冗余 85 // 2. 更新会话消息冗余
84 conversationService.updateConversationLastMessage(kefuMessage); 86 conversationService.updateConversationLastMessage(kefuMessage);
85 - // 3. 发送消息 87 + // 3. 通知所有管理员更新对话
86 getSelf().sendAsyncMessageToAdmin(KEFU_MESSAGE_TYPE, kefuMessage); 88 getSelf().sendAsyncMessageToAdmin(KEFU_MESSAGE_TYPE, kefuMessage);
87 return kefuMessage.getId(); 89 return kefuMessage.getId();
88 } 90 }