【缺陷修复】mall: 修复客服中心页面接收到消息时,重复调用了多次获取会话接口的问题

pull/675/head
puhui999 2025-01-22 18:10:51 +08:00
parent fef86bcc56
commit 39106843f3
1 changed files with 38 additions and 33 deletions

View File

@ -37,40 +37,45 @@ const { data, close, open } = useWebSocket(server.value, {
})
/** 监听 WebSocket 数据 */
watchEffect(() => {
if (!data.value) {
return
watch(
() => data.value,
(newData) => {
if (!newData) return
try {
// 1.
if (newData === 'pong') return
// 2.1 type
const jsonMessage = JSON.parse(newData)
const type = jsonMessage.type
if (!type) {
message.error('未知的消息类型:' + newData)
return
}
// 2.2 KEFU_MESSAGE_TYPE
if (type === WebSocketMessageTypeConstants.KEFU_MESSAGE_TYPE) {
const message = JSON.parse(jsonMessage.content)
//
kefuStore.updateConversation(message.conversationId)
//
keFuChatBoxRef.value?.refreshMessageList(message)
return
}
// 2.3 KEFU_MESSAGE_ADMIN_READ
if (type === WebSocketMessageTypeConstants.KEFU_MESSAGE_ADMIN_READ) {
//
kefuStore.updateConversationStatus(jsonParse(jsonMessage.content))
}
} catch (error) {
console.error(error)
}
},
{
immediate: false //
}
try {
// 1.
if (data.value === 'pong') {
return
}
// 2.1 type
const jsonMessage = JSON.parse(data.value)
const type = jsonMessage.type
if (!type) {
message.error('未知的消息类型:' + data.value)
return
}
// 2.2 KEFU_MESSAGE_TYPE
if (type === WebSocketMessageTypeConstants.KEFU_MESSAGE_TYPE) {
const message = JSON.parse(jsonMessage.content)
//
kefuStore.updateConversation(message.conversationId)
//
keFuChatBoxRef.value?.refreshMessageList(message)
return
}
// 2.3 KEFU_MESSAGE_ADMIN_READ
if (type === WebSocketMessageTypeConstants.KEFU_MESSAGE_ADMIN_READ) {
//
kefuStore.updateConversationStatus(jsonParse(jsonMessage.content))
}
} catch (error) {
console.error(error)
}
})
)
// ======================= WebSocket end =======================
/** 加载指定会话的消息列表 */