BJ_ZTEITS-Developers / parking-cloud-yudao

Commit 7a0a5f0f9a8f7d55cc23e1a9f1b7fd92871fa9b1

Authored by 芋道源码
Committed by Gitee
2 parents f510ae5c ebfcec4c

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

Merge pull request !1010 from puhui999/develop
Inline Side-by-side
Showing 2 changed files with 6 additions and 4 deletions
sql/mysql/mall-promotion-kefu.sql
  View file @7a0a5f0
@@ -3,7 +3,7 @@ CREATE TABLE `promotion_kefu_conversation` ( @@ -3,7 +3,7 @@ CREATE TABLE `promotion_kefu_conversation` (
3 `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号', 3 `id` bigint NOT NULL AUTO_INCREMENT COMMENT '编号',
4 `user_id` bigint NOT NULL COMMENT '会话所属用户', 4 `user_id` bigint NOT NULL COMMENT '会话所属用户',
5 `last_message_time` datetime NOT NULL COMMENT '最后聊天时间', 5 `last_message_time` datetime NOT NULL COMMENT '最后聊天时间',
6 - `last_message_content` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '最后聊天内容', 6 + `last_message_content` varchar(2048) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '最后聊天内容',
7 `last_message_content_type` int NOT NULL COMMENT '最后发送的消息类型', 7 `last_message_content_type` int NOT NULL COMMENT '最后发送的消息类型',
8 `admin_pinned` bit(1) NOT NULL DEFAULT b'0' COMMENT '管理端置顶', 8 `admin_pinned` bit(1) NOT NULL DEFAULT b'0' COMMENT '管理端置顶',
9 `user_deleted` bit(1) NOT NULL DEFAULT b'0' COMMENT '用户是否可见', 9 `user_deleted` bit(1) NOT NULL DEFAULT b'0' COMMENT '用户是否可见',
@@ -27,7 +27,7 @@ CREATE TABLE `promotion_kefu_message` ( @@ -27,7 +27,7 @@ CREATE TABLE `promotion_kefu_message` (
27 `receiver_id` bigint DEFAULT NULL COMMENT '接收人编号', 27 `receiver_id` bigint DEFAULT NULL COMMENT '接收人编号',
28 `receiver_type` int DEFAULT NULL COMMENT '接收人类型', 28 `receiver_type` int DEFAULT NULL COMMENT '接收人类型',
29 `content_type` int NOT NULL COMMENT '消息类型', 29 `content_type` int NOT NULL COMMENT '消息类型',
30 - `content` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '消息', 30 + `content` varchar(2048) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '消息',
31 `read_status` bit(1) NOT NULL DEFAULT b'0' COMMENT '是否已读', 31 `read_status` bit(1) NOT NULL DEFAULT b'0' COMMENT '是否已读',
32 `creator` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '创建者', 32 `creator` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '创建者',
33 `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', 33 `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/kefu/KeFuMessageServiceImpl.java
  View file @7a0a5f0
@@ -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 }