213 lines
7.3 KiB
JavaScript
213 lines
7.3 KiB
JavaScript
|
/**
|
|||
|
|
* 会话列表与群组详细信息合并工具
|
|||
|
|
*
|
|||
|
|
* 功能：
|
|||
|
|
* 1. 从 conversationList 中提取所有 groupID
|
|||
|
|
* 2. 调用后端 getGroupList 接口获取群组详细信息
|
|||
|
|
* 3. 合并会话数据和患者信息
|
|||
|
|
* 4. 过滤掉后端不存在的会话
|
|||
|
|
*/
|
|||
|
|
|
|||
|
|
import api from "@/utils/api.js"
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 合并会话列表和群组详细信息
|
|||
|
|
*
|
|||
|
|
* @param {Array} conversationList - 前端会话列表
|
|||
|
|
* @param {Object} options - 可选参数
|
|||
|
|
* @param {string} options.corpId - 企业ID（可选）
|
|||
|
|
* @param {string} options.teamId - 团队ID（可选）
|
|||
|
|
* @param {string} options.keyword - 搜索关键词（可选）
|
|||
|
|
* @returns {Promise<Array>} 合并后的会话列表
|
|||
|
|
*/
|
|||
|
|
export async function mergeConversationWithGroupDetails(conversationList, options = {}) {
|
|||
|
|
try {
|
|||
|
|
// 1. 参数校验
|
|||
|
|
if (!Array.isArray(conversationList) || conversationList.length === 0) {
|
|||
|
|
console.log('会话列表为空，无需合并')
|
|||
|
|
return []
|
|||
|
|
}
|
|||
|
|
// 2. 提取所有 groupID
|
|||
|
|
const groupIds = conversationList
|
|||
|
|
.map(conv => conv.groupID);
|
|||
|
|
if (groupIds.length === 0) {
|
|||
|
|
console.log('没有有效的 groupID，无需合并')
|
|||
|
|
return []
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
console.log('提取到的 groupID 列表:', groupIds)
|
|||
|
|
|
|||
|
|
// 3. 调用后端接口获取群组详细信息
|
|||
|
|
const requestData = {
|
|||
|
|
groupIds,
|
|||
|
|
...options // 支持传入额外的查询参数（corpId, teamId, keyword等）
|
|||
|
|
}
|
|||
|
|
const response = await api('getGroupList', requestData)
|
|||
|
|
// 4. 检查响应
|
|||
|
|
if (!response || !response.success) {
|
|||
|
|
console.error('获取群组详细信息失败:', response?.message || '未知错误')
|
|||
|
|
return []
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const groupDetailsMap = createGroupDetailsMap(response.data?.list || [])
|
|||
|
|
console.log('获取到的群组详细信息数量:', Object.keys(groupDetailsMap).size)
|
|||
|
|
|
|||
|
|
// 5. 合并数据并过滤
|
|||
|
|
const mergedList = conversationList
|
|||
|
|
.map(conversation => mergeConversationData(conversation, groupDetailsMap))
|
|||
|
|
.filter(item => item !== null) // 过滤掉后端不存在的会话
|
|||
|
|
|
|||
|
|
console.log('合并后的会话列表数量:', mergedList.length)
|
|||
|
|
console.log('过滤掉的会话数量:', conversationList.length - mergedList.length)
|
|||
|
|
|
|||
|
|
// 6. 格式化并排序会话列表
|
|||
|
|
const formattedList = mergedList
|
|||
|
|
.map((group) => ({
|
|||
|
|
conversationID: group.conversationID || `GROUP${group.groupID}`,
|
|||
|
|
groupID: group.groupID,
|
|||
|
|
name: group.patientName
|
|||
|
|
? `${group.patientName}的问诊`
|
|||
|
|
: group.name || "问诊群聊",
|
|||
|
|
avatar: group.avatar || "/static/default-avatar.png",
|
|||
|
|
lastMessage: group.lastMessage || "暂无消息",
|
|||
|
|
lastMessageTime: group.lastMessageTime || Date.now(),
|
|||
|
|
unreadCount: group.unreadCount || 0,
|
|||
|
|
doctorId: group.doctorId,
|
|||
|
|
patientName: group.patientName,
|
|||
|
|
patientSex: group.patientSex,
|
|||
|
|
patientAge: group.patientAge,
|
|||
|
|
orderStatus: group.orderStatus,
|
|||
|
|
}))
|
|||
|
|
.sort((a, b) => b.lastMessageTime - a.lastMessageTime)
|
|||
|
|
|
|||
|
|
return formattedList
|
|||
|
|
|
|||
|
|
} catch (error) {
|
|||
|
|
console.error('合并会话列表失败:', error)
|
|||
|
|
// 发生错误时返回空数组，避免影响页面渲染
|
|||
|
|
return []
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 创建群组详细信息映射表
|
|||
|
|
*
|
|||
|
|
* @param {Array} groupDetailsList - 后端返回的群组详细信息列表
|
|||
|
|
* @returns {Map} groupID -> 群组详细信息的映射
|
|||
|
|
*/
|
|||
|
|
function createGroupDetailsMap(groupDetailsList) {
|
|||
|
|
const map = new Map()
|
|||
|
|
|
|||
|
|
groupDetailsList.forEach(groupDetail => {
|
|||
|
|
if (groupDetail.groupId) {
|
|||
|
|
map.set(groupDetail.groupId, groupDetail)
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
return map
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 合并单个会话数据
|
|||
|
|
*
|
|||
|
|
* @param {Object} conversation - 前端会话数据
|
|||
|
|
* @param {Map} groupDetailsMap - 群组详细信息映射表
|
|||
|
|
* @returns {Object|null} 合并后的会话数据，如果后端不存在则返回 null
|
|||
|
|
*/
|
|||
|
|
function mergeConversationData(conversation, groupDetailsMap) {
|
|||
|
|
const groupDetail = groupDetailsMap.get(conversation.groupID)
|
|||
|
|
|
|||
|
|
// 如果后端没有该群组信息，返回 null（会被过滤掉）
|
|||
|
|
if (!groupDetail) {
|
|||
|
|
console.log(`会话 ${conversation.groupID} 在后端不存在，已过滤`)
|
|||
|
|
return null
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 合并数据
|
|||
|
|
return {
|
|||
|
|
// 保留原有的会话信息
|
|||
|
|
...conversation,
|
|||
|
|
|
|||
|
|
// 合并后端的群组信息
|
|||
|
|
_id: groupDetail._id,
|
|||
|
|
corpId: groupDetail.corpId,
|
|||
|
|
teamId: groupDetail.teamId,
|
|||
|
|
customerId: groupDetail.customerId,
|
|||
|
|
doctorId: groupDetail.doctorId,
|
|||
|
|
patientId: groupDetail.patientId,
|
|||
|
|
orderStatus: groupDetail.orderStatus,
|
|||
|
|
|
|||
|
|
// 合并患者信息（优先使用后端数据）
|
|||
|
|
patientName: groupDetail.patientName || conversation.patientName,
|
|||
|
|
patientSex: groupDetail.patient?.sex,
|
|||
|
|
patientAge: groupDetail.patient?.age,
|
|||
|
|
patientMobile: groupDetail.patient?.mobile,
|
|||
|
|
patientAvatar: groupDetail.patient?.avatar || conversation.avatar,
|
|||
|
|
|
|||
|
|
// 合并团队信息
|
|||
|
|
teamName: groupDetail.team?.name,
|
|||
|
|
teamMemberList: groupDetail.team?.memberList,
|
|||
|
|
teamDescription: groupDetail.team?.description,
|
|||
|
|
|
|||
|
|
// 时间信息
|
|||
|
|
createdAt: groupDetail.createdAt,
|
|||
|
|
updatedAt: groupDetail.updatedAt,
|
|||
|
|
|
|||
|
|
// 更新显示名称（使用后端的患者信息）
|
|||
|
|
name: formatConversationName(groupDetail),
|
|||
|
|
|
|||
|
|
// 更新头像
|
|||
|
|
avatar: groupDetail.patient?.avatar || conversation.avatar || '/static/default-avatar.png'
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 格式化会话显示名称
|
|||
|
|
*
|
|||
|
|
* @param {Object} groupDetail - 群组详细信息
|
|||
|
|
* @returns {string} 格式化后的名称
|
|||
|
|
*/
|
|||
|
|
function formatConversationName(groupDetail) {
|
|||
|
|
const patientName = groupDetail.patientName || '患者'
|
|||
|
|
const sex = groupDetail.patient?.sex === 1 ? '男' : groupDetail.patient?.sex === 2 ? '女' : ''
|
|||
|
|
const age = groupDetail.patient?.age ? `${groupDetail.patient.age}岁` : ''
|
|||
|
|
|
|||
|
|
// 拼接名称：患者名 性别 年龄
|
|||
|
|
const nameParts = [patientName, sex, age].filter(part => part)
|
|||
|
|
const displayName = nameParts.join(' ')
|
|||
|
|
|
|||
|
|
return `${displayName}的问诊`
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 批量合并会话列表（支持分页）
|
|||
|
|
*
|
|||
|
|
* @param {Array} conversationList - 前端会话列表
|
|||
|
|
* @param {Object} options - 可选参数
|
|||
|
|
* @param {number} options.batchSize - 每批处理的数量（默认50）
|
|||
|
|
* @returns {Promise<Array>} 合并后的会话列表
|
|||
|
|
*/
|
|||
|
|
export async function mergeConversationWithGroupDetailsBatch(conversationList, options = {}) {
|
|||
|
|
const { batchSize = 50, ...otherOptions } = options
|
|||
|
|
|
|||
|
|
if (!Array.isArray(conversationList) || conversationList.length === 0) {
|
|||
|
|
return []
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 分批处理
|
|||
|
|
const batches = []
|
|||
|
|
for (let i = 0; i < conversationList.length; i += batchSize) {
|
|||
|
|
batches.push(conversationList.slice(i, i + batchSize))
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
console.log(`会话列表分为 ${batches.length} 批处理，每批 ${batchSize} 条`)
|
|||
|
|
|
|||
|
|
// 并发处理所有批次
|
|||
|
|
const results = await Promise.all(
|
|||
|
|
batches.map(batch => mergeConversationWithGroupDetails(batch, otherOptions))
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
// 合并所有结果
|
|||
|
|
return results.flat()
|
|||
|
|
}
|