Compare commits
2 Commits
9b545b442d
...
cd4693bad4
| Author | SHA1 | Date | |
|---|---|---|---|
| cd4693bad4 | |||
| 74878a131b |
@ -2,3 +2,4 @@ MP_API_BASE_URL=http://localhost:8080
|
|||||||
MP_CACHE_PREFIX=development
|
MP_CACHE_PREFIX=development
|
||||||
MP_WX_APP_ID=wx93af55767423938e
|
MP_WX_APP_ID=wx93af55767423938e
|
||||||
MP_CORP_ID=wwe3fb2faa52cf9dfb
|
MP_CORP_ID=wwe3fb2faa52cf9dfb
|
||||||
|
MP_TIM_SDK_APP_ID=1600123876
|
||||||
|
|||||||
@ -1,3 +1,4 @@
|
|||||||
MP_API_BASE_URL=http://192.168.60.2:8080
|
MP_API_BASE_URL=http://192.168.60.2:8080
|
||||||
MP_CACHE_PREFIX=development
|
MP_CACHE_PREFIX=development
|
||||||
MP_WX_APP_ID=wx93af55767423938e
|
MP_WX_APP_ID=wx93af55767423938e
|
||||||
|
MP_TIM_SDK_APP_ID=1600072268
|
||||||
|
|||||||
3
.vscode/settings.json
vendored
Normal file
3
.vscode/settings.json
vendored
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"kiroAgent.configureMCP": "Disabled"
|
||||||
|
}
|
||||||
12
App.vue
12
App.vue
@ -1,5 +1,7 @@
|
|||||||
<script>
|
<script>
|
||||||
import useAccountStore from "@/store/account.js";
|
import useAccountStore from "@/store/account.js";
|
||||||
|
import { globalTimChatManager } from "@/utils/tim-chat.js";
|
||||||
|
|
||||||
export default {
|
export default {
|
||||||
onLaunch: function () {
|
onLaunch: function () {
|
||||||
// 需在 pinia 安装后再获取 store，避免 getActivePinia 报错
|
// 需在 pinia 安装后再获取 store，避免 getActivePinia 报错
|
||||||
@ -12,6 +14,16 @@ export default {
|
|||||||
},
|
},
|
||||||
onHide: function () {
|
onHide: function () {
|
||||||
console.log("App Hide");
|
console.log("App Hide");
|
||||||
|
// 小程序退出时退出腾讯IM登录
|
||||||
|
try {
|
||||||
|
if (globalTimChatManager && globalTimChatManager.tim) {
|
||||||
|
console.log('小程序退出，开始退出腾讯IM');
|
||||||
|
globalTimChatManager.destroy();
|
||||||
|
console.log('腾讯IM退出成功');
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('退出腾讯IM失败:', error);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
</script>
|
</script>
|
||||||
|
|||||||
35
index.html
35
index.html
@ -1,20 +1,21 @@
|
|||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html lang="zh-CN">
|
<html lang="zh-CN">
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8" />
|
<head>
|
||||||
<script>
|
<meta charset="UTF-8" />
|
||||||
var coverSupport = 'CSS' in window && typeof CSS.supports === 'function' && (CSS.supports('top: env(a)') ||
|
<script>
|
||||||
CSS.supports('top: constant(a)'))
|
var coverSupport = 'CSS' in window && typeof CSS.supports === 'function' && (CSS.supports('top: env(a)') ||
|
||||||
document.write(
|
CSS.supports('top: constant(a)'))
|
||||||
'<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0' +
|
document.write(
|
||||||
(coverSupport ? ', viewport-fit=cover' : '') + '" />')
|
'<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0' +
|
||||||
</script>
|
(coverSupport ? ', viewport-fit=cover' : '') + '" />')
|
||||||
<title></title>
|
</script>
|
||||||
<!--preload-links-->
|
<title></title>
|
||||||
<!--app-context-->
|
</head>
|
||||||
</head>
|
|
||||||
<body>
|
<body>
|
||||||
<div id="app"><!--app-html--></div>
|
<div id="app"><!--app-html--></div>
|
||||||
<script type="module" src="/main.js"></script>
|
<script type="module" src="/main.js"></script>
|
||||||
</body>
|
</body>
|
||||||
|
|
||||||
</html>
|
</html>
|
||||||
@ -6,6 +6,13 @@
|
|||||||
"navigationBarTitleText": "消息"
|
"navigationBarTitleText": "消息"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"path": "pages/message/index",
|
||||||
|
"style": {
|
||||||
|
"navigationBarTitleText": "聊天",
|
||||||
|
"enablePullDownRefresh": false
|
||||||
|
}
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"path": "pages/case/case",
|
"path": "pages/case/case",
|
||||||
"style": {
|
"style": {
|
||||||
|
|||||||
@ -1,4 +1,9 @@
|
|||||||
|
// SCSS 变量定义
|
||||||
|
$font-size-text: 28rpx;
|
||||||
|
$font-size-tip: 24rpx;
|
||||||
|
$font-size-title: 32rpx;
|
||||||
|
$text-color-sub: #999;
|
||||||
|
$primary-color: #0877F1;
|
||||||
|
|
||||||
.chat-page {
|
.chat-page {
|
||||||
position: fixed;
|
position: fixed;
|
||||||
@ -1232,4 +1237,3 @@
|
|||||||
0%, 100% { transform: translateY(0); }
|
0%, 100% { transform: translateY(0); }
|
||||||
50% { transform: translateY(-10rpx); }
|
50% { transform: translateY(-10rpx); }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -293,47 +293,8 @@ const cancelRecord = () => {
|
|||||||
stopRecordUtil(recorderManager);
|
stopRecordUtil(recorderManager);
|
||||||
};
|
};
|
||||||
|
|
||||||
// 发送病情描述消息
|
|
||||||
const sendSymptomMessage = async () => {
|
|
||||||
const symptomMessage = createCustomMessage("symptom", {
|
|
||||||
content: "发送了病情描述",
|
|
||||||
symptomContent: "患者主诉：头痛、发热、咳嗽3天。既往史：无特殊。现病史：3天前开始出现头痛，伴有发热，体温最高38.5℃，同时有干咳症状。",
|
|
||||||
hasVisitedHospital: "yes",
|
|
||||||
selectedDiseases: [{ text: "感冒" }, { text: "上呼吸道感染" }],
|
|
||||||
images: ["/static/home/photo.png"],
|
|
||||||
}, props.formatTime);
|
|
||||||
|
|
||||||
await sendCustomMessage(symptomMessage);
|
|
||||||
};
|
|
||||||
|
|
||||||
// 发送处方单消息
|
|
||||||
const sendPrescriptionMessage = async () => {
|
|
||||||
const prescriptionMessage = createCustomMessage("prescription", {
|
|
||||||
content: "医生开了处方",
|
|
||||||
diagnosis: "上呼吸道感染",
|
|
||||||
medicines: [
|
|
||||||
{ name: "阿莫西林胶囊", spec: "0.25g×20粒", count: 2 },
|
|
||||||
{ name: "甲硝唑片", spec: "0.5mg×20片", count: 2 },
|
|
||||||
],
|
|
||||||
}, props.formatTime);
|
|
||||||
|
|
||||||
await sendCustomMessage(prescriptionMessage);
|
|
||||||
};
|
|
||||||
|
|
||||||
// 发送续方申请消息
|
|
||||||
const sendRefillMessage = async () => {
|
|
||||||
const refillMessage = createCustomMessage("refill", {
|
|
||||||
content: "发送了续方申请",
|
|
||||||
patientName: props.patientInfo.name,
|
|
||||||
gender: props.patientInfo.gender,
|
|
||||||
age: props.patientInfo.age,
|
|
||||||
diagnosis: "慢性胃炎，脾胃虚弱",
|
|
||||||
prescriptionType: "中药处方",
|
|
||||||
prescriptionDesc: "共14剂，每日1剂，1剂分2次服用，饭后温服",
|
|
||||||
}, props.formatTime);
|
|
||||||
|
|
||||||
await sendCustomMessage(refillMessage);
|
|
||||||
};
|
|
||||||
|
|
||||||
// 发送问卷调查消息
|
// 发送问卷调查消息
|
||||||
const sendSurveyMessage = async () => {
|
const sendSurveyMessage = async () => {
|
||||||
|
|||||||
@ -1,43 +0,0 @@
|
|||||||
<template>
|
|
||||||
<view class="consultation-bar-wrapper">
|
|
||||||
<!-- 问诊功能栏：仅问诊结束后显示 -->
|
|
||||||
<view class="consultation-bar">
|
|
||||||
<view class="consultation-info">
|
|
||||||
<view class="consultation-icon">
|
|
||||||
<uni-icons type="chatboxes" size="24" color="#0877F1"></uni-icons>
|
|
||||||
</view>
|
|
||||||
<view class="consultation-details">
|
|
||||||
<text class="consultation-title">图文问诊</text>
|
|
||||||
<!-- <text class="consultation-price">¥{{ doctor.price }}/次</text> -->
|
|
||||||
</view>
|
|
||||||
</view>
|
|
||||||
<button class="consultation-btn" @click="toConsult">
|
|
||||||
问诊医生
|
|
||||||
</button>
|
|
||||||
</view>
|
|
||||||
</view>
|
|
||||||
</template>
|
|
||||||
|
|
||||||
<script setup>
|
|
||||||
const props = defineProps({
|
|
||||||
doctor: { type: Object, default: () => ({}) },
|
|
||||||
});
|
|
||||||
|
|
||||||
function toConsult() {
|
|
||||||
if (props.doctor.doctorId) {
|
|
||||||
uni.navigateTo({
|
|
||||||
url: `/pages-home/consultation/select-patient?doctorId=${props.doctor.doctorId}`
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<style scoped lang="scss">
|
|
||||||
@import "../chat.scss";
|
|
||||||
|
|
||||||
.consultation-bar-wrapper {
|
|
||||||
flex-shrink: 0;
|
|
||||||
padding: 24rpx 30rpx;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
@ -12,7 +12,6 @@
|
|||||||
<text class="waiting-title">等待医生接诊.....</text>
|
<text class="waiting-title">等待医生接诊.....</text>
|
||||||
</view>
|
</view>
|
||||||
<view class="doctor-avatar-outer">
|
<view class="doctor-avatar-outer">
|
||||||
<!-- chatInfo.avatar || -->
|
|
||||||
<image class="doctor-avatar" :src="avatar" mode="aspectFill">
|
<image class="doctor-avatar" :src="avatar" mode="aspectFill">
|
||||||
</image>
|
</image>
|
||||||
</view>
|
</view>
|
||||||
|
|||||||
@ -3,7 +3,6 @@
|
|||||||
<text v-if="message.type === 'TIMTextElem'" class="message-text">
|
<text v-if="message.type === 'TIMTextElem'" class="message-text">
|
||||||
{{ message.payload.text }}
|
{{ message.payload.text }}
|
||||||
</text>
|
</text>
|
||||||
|
|
||||||
<!-- 图片消息 -->
|
<!-- 图片消息 -->
|
||||||
<image
|
<image
|
||||||
v-else-if="message.type === 'TIMImageElem'"
|
v-else-if="message.type === 'TIMImageElem'"
|
||||||
@ -62,8 +61,8 @@
|
|||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
|
|
||||||
<!-- 自定义消息卡片 -->
|
|
||||||
<template v-else-if="message.type === 'TIMCustomElem'">
|
<!-- <template v-else-if="message.type === 'TIMCustomElem'">
|
||||||
<view
|
<view
|
||||||
class="card-avatar-row"
|
class="card-avatar-row"
|
||||||
@click="() => console.log('点击头像', message)"
|
@click="() => console.log('点击头像', message)"
|
||||||
@ -75,13 +74,13 @@
|
|||||||
@viewDetail="$emit('viewDetail', $event)"
|
@viewDetail="$emit('viewDetail', $event)"
|
||||||
/>
|
/>
|
||||||
</view>
|
</view>
|
||||||
</template>
|
</template> -->
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
<script setup>
|
<script setup>
|
||||||
import { computed } from "vue";
|
import { computed } from "vue";
|
||||||
import { getParsedCustomMessage } from "@/utils/chat-utils.js";
|
import { getParsedCustomMessage } from "@/utils/chat-utils.js";
|
||||||
import MessageCard from "./message-card/message-card.vue";
|
// import MessageCard from "./message-card/message-card.vue";
|
||||||
|
|
||||||
const props = defineProps({
|
const props = defineProps({
|
||||||
message: Object,
|
message: Object,
|
||||||
|
|||||||
@ -174,12 +174,6 @@ const submitEvaluation = async () => {
|
|||||||
emit('popupStatusChange', false);
|
emit('popupStatusChange', false);
|
||||||
}
|
}
|
||||||
loading.value = false
|
loading.value = false
|
||||||
|
|
||||||
// // 触发评价提交事件
|
|
||||||
// emit('evaluationSubmitted', {
|
|
||||||
// rating: evaluationRating.value,
|
|
||||||
// comment: evaluationComment.value
|
|
||||||
// });
|
|
||||||
};
|
};
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
|
|||||||
62
pages/message/hooks/use-group-chat.js
Normal file
62
pages/message/hooks/use-group-chat.js
Normal file
@ -0,0 +1,62 @@
|
|||||||
|
import { ref, computed } from 'vue'
|
||||||
|
import { onShow, onUnload } from '@dcloudio/uni-app'
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 简单的群聊hook
|
||||||
|
* @param {string} groupID 群组ID
|
||||||
|
*/
|
||||||
|
export default function useGroupChat(groupID) {
|
||||||
|
const groupInfo = ref({})
|
||||||
|
const members = ref([])
|
||||||
|
|
||||||
|
// 群聊成员映射
|
||||||
|
const chatMember = computed(() => {
|
||||||
|
const res = {}
|
||||||
|
members.value.forEach(member => {
|
||||||
|
res[member.id] = {
|
||||||
|
name: member.name,
|
||||||
|
avatar: member.avatar || '/static/default-avatar.png'
|
||||||
|
}
|
||||||
|
})
|
||||||
|
return res
|
||||||
|
})
|
||||||
|
|
||||||
|
// 获取群聊信息
|
||||||
|
async function getGroupInfo() {
|
||||||
|
const gid = typeof groupID === 'string' ? groupID : groupID.value
|
||||||
|
if (!gid) return
|
||||||
|
|
||||||
|
try {
|
||||||
|
// 这里可以调用API获取群聊信息
|
||||||
|
// const res = await getGroupDetail(gid)
|
||||||
|
// if (res && res.success) {
|
||||||
|
// groupInfo.value = res.data
|
||||||
|
// members.value = res.data.members || []
|
||||||
|
// }
|
||||||
|
|
||||||
|
// 暂时使用本地数据
|
||||||
|
groupInfo.value = {
|
||||||
|
groupID: gid,
|
||||||
|
name: '群聊',
|
||||||
|
status: 'active'
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('获取群聊信息失败:', error)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
onShow(() => {
|
||||||
|
getGroupInfo()
|
||||||
|
})
|
||||||
|
|
||||||
|
onUnload(() => {
|
||||||
|
// 清理资源
|
||||||
|
})
|
||||||
|
|
||||||
|
return {
|
||||||
|
groupInfo,
|
||||||
|
members,
|
||||||
|
chatMember,
|
||||||
|
getGroupInfo
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -1,24 +1,8 @@
|
|||||||
<template>
|
<template>
|
||||||
<view class="chat-page">
|
<view class="chat-page">
|
||||||
<head-card
|
|
||||||
v-if="chatRoomStatus.isWaiting"
|
|
||||||
:doctorInfo="doctorInfo"
|
|
||||||
:order="currentOrder"
|
|
||||||
@addSymptomDescription="addSymptomDescription()"
|
|
||||||
/>
|
|
||||||
|
|
||||||
<!-- 倒计时显示 -->
|
|
||||||
<view
|
|
||||||
v-if="chatRoomCountDown && showCountdown"
|
|
||||||
class="consult-countdown-bar"
|
|
||||||
>
|
|
||||||
<text class="countdown-text">问诊剩余时间：{{ chatRoomCountDown }}</text>
|
|
||||||
</view>
|
|
||||||
|
|
||||||
<!-- 聊天消息区域 -->
|
<!-- 聊天消息区域 -->
|
||||||
<scroll-view
|
<scroll-view
|
||||||
class="chat-content"
|
class="chat-content"
|
||||||
:class="{ 'chat-content-compressed': waitingForDoctor }"
|
|
||||||
scroll-y="true"
|
scroll-y="true"
|
||||||
enhanced="true"
|
enhanced="true"
|
||||||
bounces="false"
|
bounces="false"
|
||||||
@ -30,7 +14,6 @@
|
|||||||
<!-- 加载更多提示 -->
|
<!-- 加载更多提示 -->
|
||||||
<view class="load-more-tip" v-if="messageList.length >= 15">
|
<view class="load-more-tip" v-if="messageList.length >= 15">
|
||||||
<view class="loading" v-if="isLoadingMore">
|
<view class="loading" v-if="isLoadingMore">
|
||||||
<text class="loading-icon">⏳</text>
|
|
||||||
<text class="loading-text">加载中...</text>
|
<text class="loading-text">加载中...</text>
|
||||||
</view>
|
</view>
|
||||||
<view class="load-tip" v-else-if="!isCompleted">
|
<view class="load-tip" v-else-if="!isCompleted">
|
||||||
@ -64,13 +47,6 @@
|
|||||||
<view v-if="isSystemMessage(message)">
|
<view v-if="isSystemMessage(message)">
|
||||||
<SystemMessage :message="message" />
|
<SystemMessage :message="message" />
|
||||||
</view>
|
</view>
|
||||||
<view v-else-if="isSpecialMessage(message)">
|
|
||||||
<special-message
|
|
||||||
:doctorInfo="doctorInfo"
|
|
||||||
:message="message"
|
|
||||||
@popupStatusChange="handleEvaluationPopupStatusChange"
|
|
||||||
/>
|
|
||||||
</view>
|
|
||||||
|
|
||||||
<!-- 消息内容 -->
|
<!-- 消息内容 -->
|
||||||
<view v-else class="message-content">
|
<view v-else class="message-content">
|
||||||
@ -131,31 +107,15 @@
|
|||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
</scroll-view>
|
</scroll-view>
|
||||||
<!-- 评价组件 -->
|
|
||||||
|
|
||||||
<!-- 聊天输入组件 -->
|
<!-- 聊天输入组件 -->
|
||||||
<ChatInput
|
<ChatInput
|
||||||
v-if="!isClosed && !isEvaluationPopupOpen && !showDescriptionPopup"
|
v-if="!isEvaluationPopupOpen"
|
||||||
:timChatManager="timChatManager"
|
:timChatManager="timChatManager"
|
||||||
:chatRoomBusiness="chatRoomBusiness"
|
|
||||||
:formatTime="formatTime"
|
:formatTime="formatTime"
|
||||||
@scrollToBottom="scrollToBottom"
|
@scrollToBottom="scrollToBottom"
|
||||||
@messageSent="scrollToBottom"
|
@messageSent="scrollToBottom"
|
||||||
/>
|
/>
|
||||||
<!-- 问诊功能栏组件 -->
|
|
||||||
<ConsultationBar
|
|
||||||
v-if="isClosed && doctorInfo && !isEvaluationPopupOpen"
|
|
||||||
:doctor="doctorInfo"
|
|
||||||
/>
|
|
||||||
<!-- 病情描述弹窗 -->
|
|
||||||
<DescriptionPopup
|
|
||||||
:orderId="currentOrder ? currentOrder.orderId : ''"
|
|
||||||
:accountId="account ? account.id : ''"
|
|
||||||
:visible="showDescriptionPopup"
|
|
||||||
:isIMMode="true"
|
|
||||||
@close="showDescriptionPopup = false"
|
|
||||||
@submit="handleSubmitDescription"
|
|
||||||
/>
|
|
||||||
</view>
|
</view>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
@ -169,7 +129,6 @@ import {
|
|||||||
startIMMonitoring,
|
startIMMonitoring,
|
||||||
stopIMMonitoring,
|
stopIMMonitoring,
|
||||||
} from "@/utils/im-status-manager.js";
|
} from "@/utils/im-status-manager.js";
|
||||||
import { updateLastMessageId } from "@/api/consult-order.js";
|
|
||||||
import {
|
import {
|
||||||
getVoiceUrl,
|
getVoiceUrl,
|
||||||
validateVoiceUrl,
|
validateVoiceUrl,
|
||||||
@ -183,14 +142,10 @@ import {
|
|||||||
handleViewDetail,
|
handleViewDetail,
|
||||||
checkIMConnectionStatus,
|
checkIMConnectionStatus,
|
||||||
} from "@/utils/chat-utils.js";
|
} from "@/utils/chat-utils.js";
|
||||||
import useChatBusiness from "./hooks/use-chat-business";
|
import useGroupChat from "./hooks/use-group-chat";
|
||||||
import DescriptionPopup from "./components/description-popup.vue";
|
|
||||||
import HeadCard from "./components/head-card.vue";
|
|
||||||
import MessageTypes from "./components/message-types.vue";
|
import MessageTypes from "./components/message-types.vue";
|
||||||
import ChatInput from "./components/chat-input.vue";
|
import ChatInput from "./components/chat-input.vue";
|
||||||
import ConsultationBar from "./components/consultation-bar.vue";
|
|
||||||
import SystemMessage from "./components/system-message.vue";
|
import SystemMessage from "./components/system-message.vue";
|
||||||
import SpecialMessage from "./components/special-message/index.vue";
|
|
||||||
|
|
||||||
const timChatManager = globalTimChatManager;
|
const timChatManager = globalTimChatManager;
|
||||||
|
|
||||||
@ -200,27 +155,14 @@ const { initIMAfterLogin } = useAccountStore();
|
|||||||
|
|
||||||
const groupId = ref("");
|
const groupId = ref("");
|
||||||
const {
|
const {
|
||||||
chatRoomBusiness,
|
|
||||||
getChatBusiness,
|
|
||||||
currentOrder,
|
|
||||||
chatRoomStatus,
|
|
||||||
getCurrentOrder,
|
|
||||||
chatRoomCountDown,
|
|
||||||
showCountdown,
|
|
||||||
doctorInfo,
|
|
||||||
isClosed,
|
|
||||||
chatMember,
|
chatMember,
|
||||||
} = useChatBusiness(groupId);
|
getGroupInfo
|
||||||
|
} = useGroupChat(groupId);
|
||||||
|
|
||||||
// 动态设置导航栏标题
|
// 动态设置导航栏标题
|
||||||
const updateNavigationTitle = () => {
|
const updateNavigationTitle = () => {
|
||||||
const doctorName =
|
|
||||||
chatRoomBusiness.value && chatRoomBusiness.value.doctorName
|
|
||||||
? chatRoomBusiness.value.doctorName
|
|
||||||
: "";
|
|
||||||
const title = doctorName ? `${doctorName}医生云工作室` : "问诊咨询";
|
|
||||||
uni.setNavigationBarTitle({
|
uni.setNavigationBarTitle({
|
||||||
title: title,
|
title: "群聊"
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -234,12 +176,6 @@ const chatInfo = ref({
|
|||||||
// 评价弹窗状态
|
// 评价弹窗状态
|
||||||
const isEvaluationPopupOpen = ref(false);
|
const isEvaluationPopupOpen = ref(false);
|
||||||
|
|
||||||
// 医生名字
|
|
||||||
const doctorName = ref("");
|
|
||||||
const showDescriptionPopup = ref(false);
|
|
||||||
// 用户头像
|
|
||||||
const userAvatar = ref("/static/center/user-avatar.png");
|
|
||||||
|
|
||||||
// 消息列表相关状态
|
// 消息列表相关状态
|
||||||
const messageList = ref([]);
|
const messageList = ref([]);
|
||||||
const isLoading = ref(false);
|
const isLoading = ref(false);
|
||||||
@ -248,192 +184,49 @@ const scrollIntoView = ref("");
|
|||||||
// 分页加载相关状态
|
// 分页加载相关状态
|
||||||
const isLoadingMore = ref(false);
|
const isLoadingMore = ref(false);
|
||||||
const isCompleted = ref(false);
|
const isCompleted = ref(false);
|
||||||
const lastFirstMessageId = ref(""); // 记录加载前的第一条消息ID，用于加载后定位
|
const lastFirstMessageId = ref("");
|
||||||
|
|
||||||
// 问诊相关状态
|
|
||||||
const consultationEnded = ref(false);
|
|
||||||
const waitingForDoctor = ref(false); // 是否等待接诊
|
|
||||||
const consultationEndTime = ref(null); // 问诊结束时间戳
|
|
||||||
|
|
||||||
// 判断是否为系统消息
|
// 判断是否为系统消息
|
||||||
function isSystemMessage(message) {
|
function isSystemMessage(message) {
|
||||||
const description = message.payload?.description;
|
const description = message.payload?.description;
|
||||||
|
|
||||||
return (
|
return (
|
||||||
message.type === "TIMCustomElem" && description === "SYSTEM_NOTIFICATION"
|
message.type === "TIMCustomElem" && description === "SYSTEM_NOTIFICATION"
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
function isSpecialMessage(message) {
|
|
||||||
const description = message.payload?.description;
|
|
||||||
return (
|
|
||||||
message.type === "TIMCustomElem" &&
|
|
||||||
["PATIENT_RATE_MESSAGE"].includes(description)
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 获取消息气泡样式类
|
// 获取消息气泡样式类
|
||||||
function getBubbleClass(message) {
|
function getBubbleClass(message) {
|
||||||
// 如果是自定义消息（包含消息卡片），根据flow决定气泡样式
|
|
||||||
if (message.type === "TIMCustomElem") {
|
if (message.type === "TIMCustomElem") {
|
||||||
return message.flow === "out" ? "user-bubble" : "doctor-bubble-blue";
|
return message.flow === "out" ? "user-bubble" : "doctor-bubble-blue";
|
||||||
}
|
}
|
||||||
// 其他消息根据flow判断
|
|
||||||
return message.flow === "out" ? "user-bubble" : "doctor-bubble";
|
return message.flow === "out" ? "user-bubble" : "doctor-bubble";
|
||||||
}
|
}
|
||||||
|
|
||||||
// 保存问诊状态到本地存储
|
|
||||||
function saveConsultationStatus() {
|
|
||||||
const orderId = uni.getStorageSync("currentOrderId");
|
|
||||||
const doctorId = uni.getStorageSync("currentDoctorId");
|
|
||||||
const patientId = uni.getStorageSync("currentPatientId");
|
|
||||||
|
|
||||||
if (orderId && doctorId && patientId) {
|
|
||||||
const consultationKey = `consultation_${orderId}_${doctorId}_${patientId}`;
|
|
||||||
const status = {
|
|
||||||
waitingForDoctor: waitingForDoctor.value,
|
|
||||||
consultationEndTime: consultationEndTime.value,
|
|
||||||
consultationEnded: consultationEnded.value,
|
|
||||||
orderId,
|
|
||||||
doctorId,
|
|
||||||
patientId,
|
|
||||||
};
|
|
||||||
uni.setStorageSync(consultationKey, status);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 从本地存储恢复问诊状态
|
|
||||||
function restoreConsultationStatus() {
|
|
||||||
const orderId = uni.getStorageSync("currentOrderId");
|
|
||||||
const doctorId = uni.getStorageSync("currentDoctorId");
|
|
||||||
const patientId = uni.getStorageSync("currentPatientId");
|
|
||||||
|
|
||||||
if (orderId && doctorId && patientId) {
|
|
||||||
const consultationKey = `consultation_${orderId}_${doctorId}_${patientId}`;
|
|
||||||
const savedStatus = uni.getStorageSync(consultationKey);
|
|
||||||
|
|
||||||
if (savedStatus) {
|
|
||||||
const now = Date.now();
|
|
||||||
|
|
||||||
if (
|
|
||||||
savedStatus.consultationEnded ||
|
|
||||||
(savedStatus.consultationEndTime &&
|
|
||||||
now >= savedStatus.consultationEndTime)
|
|
||||||
) {
|
|
||||||
consultationEnded.value = true;
|
|
||||||
} else if (
|
|
||||||
!savedStatus.waitingForDoctor &&
|
|
||||||
savedStatus.consultationEndTime
|
|
||||||
) {
|
|
||||||
consultationEndTime.value = savedStatus.consultationEndTime;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
consultationEndTime.value = null;
|
|
||||||
consultationEnded.value = false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 处理问诊结束
|
|
||||||
async function handleConsultationEnd(message) {
|
|
||||||
// 从聊天业务信息中获取订单ID
|
|
||||||
const orderId = chatRoomBusiness.value.businessId;
|
|
||||||
|
|
||||||
const lastMessageId = message.ID;
|
|
||||||
|
|
||||||
console.log("更新最后一条消息ID:", {
|
|
||||||
orderId,
|
|
||||||
lastMessageId,
|
|
||||||
messageType: message.type,
|
|
||||||
status: message.payload?.data,
|
|
||||||
chatRoomBusiness: chatRoomBusiness.value,
|
|
||||||
currentOrder: currentOrder.value,
|
|
||||||
});
|
|
||||||
|
|
||||||
if (orderId && lastMessageId) {
|
|
||||||
// 调用API更新订单的最后一条消息ID
|
|
||||||
const result = await updateLastMessageId({
|
|
||||||
orderId,
|
|
||||||
lastMessageId,
|
|
||||||
});
|
|
||||||
|
|
||||||
if (result && result.success) {
|
|
||||||
console.log("最后一条消息ID更新成功:", result);
|
|
||||||
} else {
|
|
||||||
console.error("最后一条消息ID更新失败:", result);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 页面加载
|
// 页面加载
|
||||||
onLoad((options) => {
|
onLoad((options) => {
|
||||||
groupId.value = options.groupID || "";
|
groupId.value = options.groupID || "";
|
||||||
// 清空消息列表，准备加载新群聊的消息
|
|
||||||
messageList.value = [];
|
messageList.value = [];
|
||||||
// 重置加载状态，确保新聊天室可以加载
|
|
||||||
isLoading.value = false;
|
isLoading.value = false;
|
||||||
if (options.conversationID) {
|
if (options.conversationID) {
|
||||||
chatInfo.value.conversationID = options.conversationID;
|
chatInfo.value.conversationID = options.conversationID;
|
||||||
// 立即设置当前会话ID，防止消息混淆
|
|
||||||
timChatManager.setConversationID(options.conversationID);
|
timChatManager.setConversationID(options.conversationID);
|
||||||
console.log("设置当前会话ID:", options.conversationID);
|
console.log("设置当前会话ID:", options.conversationID);
|
||||||
}
|
}
|
||||||
if (options.userID) {
|
if (options.userID) {
|
||||||
chatInfo.value.userID = options.userID;
|
chatInfo.value.userID = options.userID;
|
||||||
}
|
}
|
||||||
if (options.doctorName) {
|
|
||||||
doctorName.value = decodeURIComponent(options.doctorName);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 保存问诊参数
|
|
||||||
if (options.orderId) uni.setStorageSync("currentOrderId", options.orderId);
|
|
||||||
if (options.doctorId) uni.setStorageSync("currentDoctorId", options.doctorId);
|
|
||||||
if (options.patientId)
|
|
||||||
uni.setStorageSync("currentPatientId", options.patientId);
|
|
||||||
// 保存lastMessageId用于消息定位
|
|
||||||
if (options.lastMessageId) {
|
|
||||||
uni.setStorageSync("targetMessageId", options.lastMessageId);
|
|
||||||
}
|
|
||||||
// 从群聊ID提取医生ID
|
|
||||||
if (!chatInfo.value.userID && options.conversationID) {
|
|
||||||
const groupId = options.conversationID;
|
|
||||||
if (groupId.startsWith("GROUP")) {
|
|
||||||
const actualGroupId = groupId.replace("GROUP", "");
|
|
||||||
const parts = actualGroupId.split("_");
|
|
||||||
if (parts.length >= 1) {
|
|
||||||
chatInfo.value.userID = parts[0];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
checkLoginAndInitTIM();
|
checkLoginAndInitTIM();
|
||||||
restoreConsultationStatus();
|
|
||||||
updateNavigationTitle();
|
updateNavigationTitle();
|
||||||
});
|
});
|
||||||
|
|
||||||
// 检查登录状态并初始化IM
|
// 检查登录状态并初始化IM
|
||||||
const checkLoginAndInitTIM = async () => {
|
const checkLoginAndInitTIM = async () => {
|
||||||
if (!account.value || !openid.value) {
|
|
||||||
uni.showModal({
|
|
||||||
title: "提示",
|
|
||||||
content: "请先登录后再进入聊天",
|
|
||||||
showCancel: false,
|
|
||||||
confirmText: "去登录",
|
|
||||||
success: () => {
|
|
||||||
uni.redirectTo({
|
|
||||||
url: "/pages/login/login",
|
|
||||||
});
|
|
||||||
},
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!isIMInitialized.value) {
|
if (!isIMInitialized.value) {
|
||||||
uni.showLoading({
|
uni.showLoading({
|
||||||
title: "连接中...",
|
title: "连接中...",
|
||||||
});
|
});
|
||||||
const success = await initIMAfterLogin(openid.value);
|
const success = await initIMAfterLogin(openid.value);
|
||||||
uni.hideLoading();
|
uni.hideLoading();
|
||||||
|
|
||||||
if (!success) {
|
if (!success) {
|
||||||
uni.showToast({
|
uni.showToast({
|
||||||
title: "IM连接失败，请重试",
|
title: "IM连接失败，请重试",
|
||||||
@ -447,20 +240,16 @@ const checkLoginAndInitTIM = async () => {
|
|||||||
});
|
});
|
||||||
const reconnected = await timChatManager.ensureIMConnection();
|
const reconnected = await timChatManager.ensureIMConnection();
|
||||||
uni.hideLoading();
|
uni.hideLoading();
|
||||||
|
|
||||||
if (!reconnected) {
|
if (!reconnected) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
initTIMCallbacks();
|
initTIMCallbacks();
|
||||||
};
|
};
|
||||||
|
|
||||||
// 初始化IM回调函数（使用全局已初始化的IM管理器）
|
// 初始化IM回调函数
|
||||||
const initTIMCallbacks = async () => {
|
const initTIMCallbacks = async () => {
|
||||||
// 设置当前页面的回调函数
|
|
||||||
timChatManager.setCallback("onSDKReady", () => {
|
timChatManager.setCallback("onSDKReady", () => {
|
||||||
// SDK准备就绪后，只有在消息列表为空且未在加载中时才加载消息列表
|
|
||||||
if (messageList.value.length === 0 && !isLoading.value) {
|
if (messageList.value.length === 0 && !isLoading.value) {
|
||||||
loadMessageList();
|
loadMessageList();
|
||||||
}
|
}
|
||||||
@ -469,7 +258,6 @@ const initTIMCallbacks = async () => {
|
|||||||
timChatManager.setCallback("onSDKNotReady", () => {});
|
timChatManager.setCallback("onSDKNotReady", () => {});
|
||||||
|
|
||||||
timChatManager.setCallback("onMessageReceived", (message) => {
|
timChatManager.setCallback("onMessageReceived", (message) => {
|
||||||
// tim-chat.js层已经做了会话过滤，这里再次验证消息归属
|
|
||||||
console.log("页面收到消息:", {
|
console.log("页面收到消息:", {
|
||||||
messageID: message.ID,
|
messageID: message.ID,
|
||||||
conversationID: message.conversationID,
|
conversationID: message.conversationID,
|
||||||
@ -478,20 +266,13 @@ const initTIMCallbacks = async () => {
|
|||||||
flow: message.flow,
|
flow: message.flow,
|
||||||
});
|
});
|
||||||
|
|
||||||
// 二次验证：确保消息属于当前群聊
|
// 验证消息属于当前群聊
|
||||||
if (message.conversationID !== chatInfo.value.conversationID) {
|
if (message.conversationID !== chatInfo.value.conversationID) {
|
||||||
console.log("⚠️ 消息不属于当前群聊，已过滤:", {
|
console.log("⚠️ 消息不属于当前群聊，已过滤");
|
||||||
messageConversationID: message.conversationID,
|
|
||||||
currentConversationID: chatInfo.value.conversationID,
|
|
||||||
});
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isSystemMessage(message)) {
|
// 检查消息是否已存在
|
||||||
judgeReloadOrder(message);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 检查消息是否已存在，避免重复添加
|
|
||||||
const existingMessage = messageList.value.find(
|
const existingMessage = messageList.value.find(
|
||||||
(msg) => msg.ID === message.ID
|
(msg) => msg.ID === message.ID
|
||||||
);
|
);
|
||||||
@ -499,40 +280,15 @@ const initTIMCallbacks = async () => {
|
|||||||
messageList.value.push(message);
|
messageList.value.push(message);
|
||||||
console.log("✓ 添加消息到列表，当前消息数量:", messageList.value.length);
|
console.log("✓ 添加消息到列表，当前消息数量:", messageList.value.length);
|
||||||
nextTick(() => {
|
nextTick(() => {
|
||||||
// 延迟滚动，确保DOM完全渲染
|
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
scrollToBottom();
|
scrollToBottom();
|
||||||
}, 100);
|
}, 100);
|
||||||
});
|
});
|
||||||
} else {
|
|
||||||
console.log("消息已存在，跳过添加:", message.ID);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 监听系统消息
|
|
||||||
if (message.type === "TIMCustomElem") {
|
|
||||||
const status = message.payload?.data;
|
|
||||||
|
|
||||||
if (status === "pending") {
|
|
||||||
consultationEnded.value = false;
|
|
||||||
saveConsultationStatus();
|
|
||||||
} else if (status === "active") {
|
|
||||||
consultationEnded.value = false;
|
|
||||||
saveConsultationStatus();
|
|
||||||
} else if (
|
|
||||||
["rejected", "completed", "cancelled", "问诊已结束"].includes(status)
|
|
||||||
) {
|
|
||||||
consultationEnded.value = true;
|
|
||||||
saveConsultationStatus();
|
|
||||||
console.log("问诊结束，准备更新最后一条消息ID:", message);
|
|
||||||
handleConsultationEnd(message);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
timChatManager.setCallback("onMessageSent", (data) => {
|
timChatManager.setCallback("onMessageSent", (data) => {
|
||||||
const { messageID, status } = data;
|
const { messageID, status } = data;
|
||||||
|
|
||||||
// 更新消息状态
|
|
||||||
const message = messageList.value.find((msg) => msg.ID === messageID);
|
const message = messageList.value.find((msg) => msg.ID === messageID);
|
||||||
if (message) {
|
if (message) {
|
||||||
message.status = status;
|
message.status = status;
|
||||||
@ -557,7 +313,6 @@ const initTIMCallbacks = async () => {
|
|||||||
const seenIds = new Set();
|
const seenIds = new Set();
|
||||||
|
|
||||||
messages.forEach((message) => {
|
messages.forEach((message) => {
|
||||||
// 严格验证：消息必须属于当前群聊
|
|
||||||
const belongsToCurrentConversation =
|
const belongsToCurrentConversation =
|
||||||
message.conversationID === chatInfo.value.conversationID;
|
message.conversationID === chatInfo.value.conversationID;
|
||||||
|
|
||||||
@ -568,12 +323,6 @@ const initTIMCallbacks = async () => {
|
|||||||
) {
|
) {
|
||||||
seenIds.add(message.ID);
|
seenIds.add(message.ID);
|
||||||
uniqueMessages.push(message);
|
uniqueMessages.push(message);
|
||||||
} else if (!belongsToCurrentConversation) {
|
|
||||||
console.log("⚠️ 过滤掉不属于当前群聊的消息:", {
|
|
||||||
messageID: message.ID,
|
|
||||||
messageConversationID: message.conversationID,
|
|
||||||
currentConversationID: chatInfo.value.conversationID,
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -583,53 +332,33 @@ const initTIMCallbacks = async () => {
|
|||||||
messages.length,
|
messages.length,
|
||||||
"条，过滤后",
|
"条，过滤后",
|
||||||
uniqueMessages.length,
|
uniqueMessages.length,
|
||||||
"条消息",
|
"条消息"
|
||||||
data.isRefresh ? "(后台刷新)" : ""
|
|
||||||
);
|
);
|
||||||
|
|
||||||
// 同步分页状态
|
|
||||||
isCompleted.value = data.isCompleted || false;
|
isCompleted.value = data.isCompleted || false;
|
||||||
isLoadingMore.value = false;
|
isLoadingMore.value = false;
|
||||||
console.log("【onMessageListLoaded】同步状态完成");
|
|
||||||
console.log(" isCompleted =", isCompleted.value);
|
|
||||||
console.log(" isPullUp =", data.isPullUp);
|
|
||||||
|
|
||||||
nextTick(() => {
|
nextTick(() => {
|
||||||
// 如果是后台刷新，不进行滚动操作，保持用户当前位置
|
|
||||||
if (data.isRefresh) {
|
if (data.isRefresh) {
|
||||||
console.log("后台刷新完成，保持当前滚动位置");
|
console.log("后台刷新完成，保持当前滚动位置");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 如果是上拉加载，需要定位到加载前的第一条消息（保持用户阅读位置）
|
|
||||||
if (data.isPullUp && lastFirstMessageId.value) {
|
if (data.isPullUp && lastFirstMessageId.value) {
|
||||||
console.log(
|
console.log(
|
||||||
" 上拉加载完成，定位到加载前的第一条消息:",
|
"上拉加载完成，定位到加载前的第一条消息:",
|
||||||
lastFirstMessageId.value
|
lastFirstMessageId.value
|
||||||
);
|
);
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
scrollIntoView.value = `msg-${lastFirstMessageId.value}`;
|
scrollIntoView.value = `msg-${lastFirstMessageId.value}`;
|
||||||
console.log(" ✅ 已定位到消息:", lastFirstMessageId.value);
|
|
||||||
// 清除记录
|
|
||||||
lastFirstMessageId.value = "";
|
lastFirstMessageId.value = "";
|
||||||
}, 100);
|
}, 100);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 检查是否有目标消息需要定位
|
if (!data.isPullUp) {
|
||||||
const targetMessageId = uni.getStorageSync("targetMessageId");
|
|
||||||
if (targetMessageId && !data.isPullUp) {
|
|
||||||
// 延迟执行滚动，确保DOM完全渲染
|
|
||||||
setTimeout(() => {
|
|
||||||
scrollToMessage(targetMessageId);
|
|
||||||
// 清除存储的目标消息ID
|
|
||||||
uni.removeStorageSync("targetMessageId");
|
|
||||||
}, 300);
|
|
||||||
} else if (!data.isPullUp) {
|
|
||||||
// 延迟执行滚动到底部，增加延迟时间并多次尝试确保滚动成功
|
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
scrollToBottom();
|
scrollToBottom();
|
||||||
// 再次尝试确保滚动到底部
|
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
scrollToBottom();
|
scrollToBottom();
|
||||||
}, 100);
|
}, 100);
|
||||||
@ -646,16 +375,12 @@ const initTIMCallbacks = async () => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
// 检查IM是否已经初始化，如果已初始化则直接加载消息列表
|
|
||||||
// 使用 nextTick 确保会话ID已经设置完成
|
|
||||||
nextTick(() => {
|
nextTick(() => {
|
||||||
if (timChatManager.tim && timChatManager.isLoggedIn) {
|
if (timChatManager.tim && timChatManager.isLoggedIn) {
|
||||||
// 添加短暂延迟，确保前面的状态设置完成
|
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
loadMessageList();
|
loadMessageList();
|
||||||
}, 50);
|
}, 50);
|
||||||
} else if (timChatManager.tim) {
|
} else if (timChatManager.tim) {
|
||||||
// 等待登录完成
|
|
||||||
let checkCount = 0;
|
let checkCount = 0;
|
||||||
const checkInterval = setInterval(() => {
|
const checkInterval = setInterval(() => {
|
||||||
checkCount++;
|
checkCount++;
|
||||||
@ -663,13 +388,10 @@ const initTIMCallbacks = async () => {
|
|||||||
clearInterval(checkInterval);
|
clearInterval(checkInterval);
|
||||||
loadMessageList();
|
loadMessageList();
|
||||||
} else if (checkCount > 10) {
|
} else if (checkCount > 10) {
|
||||||
// 10秒超时
|
|
||||||
clearInterval(checkInterval);
|
clearInterval(checkInterval);
|
||||||
showMessage("IM登录超时，请重新进入");
|
showMessage("IM登录超时，请重新进入");
|
||||||
}
|
}
|
||||||
}, 1000);
|
}, 1000);
|
||||||
} else {
|
|
||||||
// showMessage("IM连接异常，请重新进入");
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@ -687,7 +409,6 @@ const loadMessageList = () => {
|
|||||||
);
|
);
|
||||||
isLoading.value = true;
|
isLoading.value = true;
|
||||||
|
|
||||||
// 显示加载提示
|
|
||||||
uni.showLoading({
|
uni.showLoading({
|
||||||
title: "加载中...",
|
title: "加载中...",
|
||||||
mask: false,
|
mask: false,
|
||||||
@ -716,11 +437,10 @@ const loadMessageList = () => {
|
|||||||
|
|
||||||
// 语音播放相关
|
// 语音播放相关
|
||||||
let currentAudioContext = null;
|
let currentAudioContext = null;
|
||||||
const playingVoiceId = ref(null); // 当前正在播放的语音消息ID
|
const playingVoiceId = ref(null);
|
||||||
|
|
||||||
// 播放语音
|
// 播放语音
|
||||||
const playVoice = (message) => {
|
const playVoice = (message) => {
|
||||||
// 如果正在播放同一条语音，则停止播放
|
|
||||||
if (playingVoiceId.value === message.ID && currentAudioContext) {
|
if (playingVoiceId.value === message.ID && currentAudioContext) {
|
||||||
currentAudioContext.stop();
|
currentAudioContext.stop();
|
||||||
currentAudioContext.destroy();
|
currentAudioContext.destroy();
|
||||||
@ -729,7 +449,6 @@ const playVoice = (message) => {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 停止之前正在播放的语音
|
|
||||||
if (currentAudioContext) {
|
if (currentAudioContext) {
|
||||||
currentAudioContext.stop();
|
currentAudioContext.stop();
|
||||||
currentAudioContext.destroy();
|
currentAudioContext.destroy();
|
||||||
@ -739,7 +458,6 @@ const playVoice = (message) => {
|
|||||||
const voiceUrl = getVoiceUrl(message);
|
const voiceUrl = getVoiceUrl(message);
|
||||||
if (!validateVoiceUrl(voiceUrl)) return;
|
if (!validateVoiceUrl(voiceUrl)) return;
|
||||||
|
|
||||||
// 设置当前播放的语音ID
|
|
||||||
playingVoiceId.value = message.ID;
|
playingVoiceId.value = message.ID;
|
||||||
|
|
||||||
currentAudioContext = createAudioContext(voiceUrl);
|
currentAudioContext = createAudioContext(voiceUrl);
|
||||||
@ -758,7 +476,6 @@ const playVoice = (message) => {
|
|||||||
const scrollToBottom = () => {
|
const scrollToBottom = () => {
|
||||||
if (messageList.value.length > 0) {
|
if (messageList.value.length > 0) {
|
||||||
const lastMessage = messageList.value[messageList.value.length - 1];
|
const lastMessage = messageList.value[messageList.value.length - 1];
|
||||||
console.log(lastMessage);
|
|
||||||
scrollIntoView.value = ``;
|
scrollIntoView.value = ``;
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
scrollIntoView.value = `msg-${lastMessage.ID}`;
|
scrollIntoView.value = `msg-${lastMessage.ID}`;
|
||||||
@ -766,53 +483,11 @@ const scrollToBottom = () => {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
// 滚动到指定消息
|
|
||||||
const scrollToMessage = (messageId, retryCount = 0) => {
|
|
||||||
if (!messageId) {
|
|
||||||
console.warn("scrollToMessage: messageId is empty");
|
|
||||||
scrollToBottom();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
// 检查消息是否存在于当前消息列表中
|
|
||||||
const targetMessageIndex = messageList.value.findIndex(
|
|
||||||
(msg) => msg.ID === messageId
|
|
||||||
);
|
|
||||||
if (targetMessageIndex !== -1) {
|
|
||||||
// 计算目标滚动位置：目标消息前5条消息
|
|
||||||
const scrollToIndex = Math.max(0, targetMessageIndex - 5);
|
|
||||||
const targetScrollMessage = messageList.value[scrollToIndex];
|
|
||||||
|
|
||||||
if (targetScrollMessage) {
|
|
||||||
scrollIntoView.value = `msg-${targetScrollMessage.ID}`;
|
|
||||||
|
|
||||||
// 延迟检查是否滚动成功，如果没有成功则重试
|
|
||||||
setTimeout(() => {
|
|
||||||
if (retryCount < 3) {
|
|
||||||
scrollIntoView.value = `msg-${targetScrollMessage.ID}`;
|
|
||||||
retryCount++;
|
|
||||||
setTimeout(() => scrollToMessage(messageId, retryCount), 200);
|
|
||||||
}
|
|
||||||
}, 100);
|
|
||||||
} else {
|
|
||||||
// 如果计算出的位置没有消息，滚动到底部
|
|
||||||
scrollToBottom();
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
scrollToBottom();
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
// 关闭功能栏
|
// 关闭功能栏
|
||||||
const closeMorePanel = () => {
|
const closeMorePanel = () => {
|
||||||
uni.$emit("closeMorePanel");
|
uni.$emit("closeMorePanel");
|
||||||
};
|
};
|
||||||
|
|
||||||
// 处理评价弹窗状态变化
|
|
||||||
const handleEvaluationPopupStatusChange = (isOpen) => {
|
|
||||||
console.log("评价弹窗状态变化:", isOpen);
|
|
||||||
isEvaluationPopupOpen.value = isOpen;
|
|
||||||
};
|
|
||||||
|
|
||||||
// 滚动事件
|
// 滚动事件
|
||||||
const onScroll = throttle((e) => {
|
const onScroll = throttle((e) => {
|
||||||
// 滚动处理
|
// 滚动处理
|
||||||
@ -827,9 +502,7 @@ const handleScrollToUpper = async () => {
|
|||||||
"isCompleted=",
|
"isCompleted=",
|
||||||
isCompleted.value
|
isCompleted.value
|
||||||
);
|
);
|
||||||
console.log(" 消息数量:", messageList.value.length);
|
|
||||||
|
|
||||||
// 如果正在加载或已加载全部，不处理
|
|
||||||
if (isLoadingMore.value || isCompleted.value) {
|
if (isLoadingMore.value || isCompleted.value) {
|
||||||
console.log(
|
console.log(
|
||||||
" ⏭️ 跳过加载：isLoadingMore=",
|
" ⏭️ 跳过加载：isLoadingMore=",
|
||||||
@ -840,13 +513,11 @@ const handleScrollToUpper = async () => {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 如果消息数量少于15条，说明第一页还没加载完，不加载更多
|
|
||||||
if (messageList.value.length < 15) {
|
if (messageList.value.length < 15) {
|
||||||
console.log(" ⏭️ 消息数量不足15条，跳过加载更多");
|
console.log(" ⏭️ 消息数量不足15条，跳过加载更多");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 记录加载前的第一条消息ID，用于加载后定位
|
|
||||||
if (messageList.value.length > 0) {
|
if (messageList.value.length > 0) {
|
||||||
lastFirstMessageId.value = messageList.value[0].ID;
|
lastFirstMessageId.value = messageList.value[0].ID;
|
||||||
console.log(" 📍 记录当前第一条消息ID:", lastFirstMessageId.value);
|
console.log(" 📍 记录当前第一条消息ID:", lastFirstMessageId.value);
|
||||||
@ -867,11 +538,6 @@ const handleScrollToUpper = async () => {
|
|||||||
if (result.message === "已加载全部消息") {
|
if (result.message === "已加载全部消息") {
|
||||||
console.log(" ✅ 已加载全部消息");
|
console.log(" ✅ 已加载全部消息");
|
||||||
isCompleted.value = true;
|
isCompleted.value = true;
|
||||||
} else if (result.message !== "正在加载中") {
|
|
||||||
uni.showToast({
|
|
||||||
title: result.message || "加载失败",
|
|
||||||
icon: "none",
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@ -886,54 +552,11 @@ const handleScrollToUpper = async () => {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
// 补充病情描述
|
|
||||||
const addSymptomDescription = () => {
|
|
||||||
console.log("添加病情描述: addSymptomDescription");
|
|
||||||
if (checkIMConnectionStatus(timChatManager)) {
|
|
||||||
console.log("添加病情描述: checkIMConnectionStatus");
|
|
||||||
showDescriptionPopup.value = true;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
// 处理病情描述提交
|
|
||||||
const handleSubmitDescription = async (descriptionData) => {
|
|
||||||
showDescriptionPopup.value = false;
|
|
||||||
// 更新订单信息
|
|
||||||
currentOrder.value = {
|
|
||||||
...currentOrder.value,
|
|
||||||
...descriptionData,
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
async function judgeReloadOrder(message) {
|
|
||||||
try {
|
|
||||||
const extension = JSON.parse(message.payload.extension);
|
|
||||||
const orderId = extension.orderId || "";
|
|
||||||
const orderStatus = extension.orderStatus || "";
|
|
||||||
const isSameOrder =
|
|
||||||
orderId && currentOrder.value && orderId === currentOrder.value.orderId;
|
|
||||||
const isSameStatus =
|
|
||||||
orderStatus &&
|
|
||||||
currentOrder.value &&
|
|
||||||
orderStatus === currentOrder.value.orderStatus;
|
|
||||||
const isExpired = extension.notifyType === "CHAT_GROUP_EXPIRE"; // 会话到达结束时间
|
|
||||||
if (
|
|
||||||
isExpired ||
|
|
||||||
orderId ||
|
|
||||||
!isSameOrder ||
|
|
||||||
(isSameOrder && !isSameStatus)
|
|
||||||
) {
|
|
||||||
await getChatBusiness();
|
|
||||||
getCurrentOrder();
|
|
||||||
}
|
|
||||||
} catch (e) {}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 页面显示
|
// 页面显示
|
||||||
onShow(() => {
|
onShow(() => {
|
||||||
if (!account.value || !openid.value) {
|
if (!account.value || !openid.value) {
|
||||||
uni.redirectTo({
|
uni.redirectTo({
|
||||||
url: "/pages/login/login",
|
url: "/pages-center/login/login",
|
||||||
});
|
});
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@ -944,13 +567,11 @@ onShow(() => {
|
|||||||
timChatManager.ensureIMConnection();
|
timChatManager.ensureIMConnection();
|
||||||
}
|
}
|
||||||
|
|
||||||
// 启动IM状态监控
|
|
||||||
startIMMonitoring(30000);
|
startIMMonitoring(30000);
|
||||||
});
|
});
|
||||||
|
|
||||||
// 页面隐藏
|
// 页面隐藏
|
||||||
onHide(() => {
|
onHide(() => {
|
||||||
// 停止IM状态监控
|
|
||||||
stopIMMonitoring();
|
stopIMMonitoring();
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -964,30 +585,8 @@ onUnmounted(() => {
|
|||||||
timChatManager.setCallback("onMessageListLoaded", null);
|
timChatManager.setCallback("onMessageListLoaded", null);
|
||||||
timChatManager.setCallback("onError", null);
|
timChatManager.setCallback("onError", null);
|
||||||
});
|
});
|
||||||
|
|
||||||
// 监听 chatRoomBusiness 变化，更新导航栏标题
|
|
||||||
watch(
|
|
||||||
chatRoomBusiness,
|
|
||||||
() => {
|
|
||||||
updateNavigationTitle();
|
|
||||||
},
|
|
||||||
{
|
|
||||||
deep: true,
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
watch(
|
|
||||||
showDescriptionPopup,
|
|
||||||
(val) => {
|
|
||||||
console.log("病情描述弹窗状态变化:", val, Date.now());
|
|
||||||
},
|
|
||||||
{
|
|
||||||
immediate: true,
|
|
||||||
}
|
|
||||||
);
|
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<style scoped lang="scss">
|
<style scoped lang="scss">
|
||||||
@import "./chat.scss";
|
@import "./chat.scss";
|
||||||
</style>
|
</style>
|
||||||
|
|
||||||
|
|||||||
@ -1,9 +1,501 @@
|
|||||||
<template>
|
<template>
|
||||||
<div>message</div>
|
<view class="message-page">
|
||||||
|
<!-- 消息列表 -->
|
||||||
|
<scroll-view
|
||||||
|
class="message-list"
|
||||||
|
scroll-y="true"
|
||||||
|
refresher-enabled
|
||||||
|
:refresher-triggered="refreshing"
|
||||||
|
@refresherrefresh="handleRefresh"
|
||||||
|
@scrolltolower="handleLoadMore"
|
||||||
|
>
|
||||||
|
<!-- 加载状态 -->
|
||||||
|
<view
|
||||||
|
v-if="loading && conversationList.length === 0"
|
||||||
|
class="loading-container"
|
||||||
|
>
|
||||||
|
<text class="loading-text">加载中...</text>
|
||||||
|
</view>
|
||||||
|
|
||||||
|
<!-- 消息列表项 -->
|
||||||
|
<view
|
||||||
|
v-for="conversation in conversationList"
|
||||||
|
:key="conversation.conversationID"
|
||||||
|
class="message-item"
|
||||||
|
@click="handleClickConversation(conversation)"
|
||||||
|
>
|
||||||
|
<view class="avatar-container">
|
||||||
|
<image
|
||||||
|
class="avatar"
|
||||||
|
:src="conversation.avatar || '/static/default-avatar.png'"
|
||||||
|
mode="aspectFill"
|
||||||
|
/>
|
||||||
|
<view v-if="conversation.unreadCount > 0" class="unread-badge">
|
||||||
|
<text class="unread-text">{{
|
||||||
|
conversation.unreadCount > 99 ? "99+" : conversation.unreadCount
|
||||||
|
}}</text>
|
||||||
|
</view>
|
||||||
|
</view>
|
||||||
|
|
||||||
|
<view class="content">
|
||||||
|
<view class="header">
|
||||||
|
<text class="name">{{ conversation.name || "未知群聊" }}</text>
|
||||||
|
<text class="time">{{
|
||||||
|
formatMessageTime(conversation.lastMessageTime)
|
||||||
|
}}</text>
|
||||||
|
</view>
|
||||||
|
<view class="message-preview">
|
||||||
|
<text class="preview-text">{{
|
||||||
|
conversation.lastMessage || "暂无消息"
|
||||||
|
}}</text>
|
||||||
|
</view>
|
||||||
|
</view>
|
||||||
|
</view>
|
||||||
|
|
||||||
|
<!-- 空状态 -->
|
||||||
|
<view
|
||||||
|
v-if="!loading && conversationList.length === 0"
|
||||||
|
class="empty-container"
|
||||||
|
>
|
||||||
|
<image class="empty-image" src="/static/empty.svg" mode="aspectFit" />
|
||||||
|
<text class="empty-text">暂无消息</text>
|
||||||
|
</view>
|
||||||
|
|
||||||
|
<!-- 加载更多 -->
|
||||||
|
<view v-if="hasMore && conversationList.length > 0" class="load-more">
|
||||||
|
<text class="load-more-text">{{
|
||||||
|
loadingMore ? "加载中..." : "上拉加载更多"
|
||||||
|
}}</text>
|
||||||
|
</view>
|
||||||
|
</scroll-view>
|
||||||
|
</view>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
<script>
|
<script setup>
|
||||||
|
import { ref } from "vue";
|
||||||
|
import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
||||||
|
import { storeToRefs } from "pinia";
|
||||||
|
import useAccountStore from "@/store/account.js";
|
||||||
|
import { globalTimChatManager } from "@/utils/tim-chat.js";
|
||||||
|
|
||||||
|
// 获取登录状态
|
||||||
|
const { account, openid, isIMInitialized } = storeToRefs(useAccountStore());
|
||||||
|
const { initIMAfterLogin } = useAccountStore();
|
||||||
|
|
||||||
|
// 状态
|
||||||
|
const conversationList = ref([]);
|
||||||
|
const loading = ref(false);
|
||||||
|
const loadingMore = ref(false);
|
||||||
|
const hasMore = ref(false);
|
||||||
|
const refreshing = ref(false);
|
||||||
|
|
||||||
|
// 初始化IM
|
||||||
|
const initIM = async () => {
|
||||||
|
if (!isIMInitialized.value) {
|
||||||
|
uni.showLoading({
|
||||||
|
title: "连接中...",
|
||||||
|
});
|
||||||
|
const success = await initIMAfterLogin(openid.value);
|
||||||
|
uni.hideLoading();
|
||||||
|
|
||||||
|
if (!success) {
|
||||||
|
uni.showToast({
|
||||||
|
title: "IM连接失败，请重试",
|
||||||
|
icon: "none",
|
||||||
|
});
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
} else if (globalTimChatManager && !globalTimChatManager.isLoggedIn) {
|
||||||
|
uni.showLoading({
|
||||||
|
title: "重连中...",
|
||||||
|
});
|
||||||
|
const reconnected = await globalTimChatManager.ensureIMConnection();
|
||||||
|
uni.hideLoading();
|
||||||
|
|
||||||
|
if (!reconnected) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 加载会话列表
|
||||||
|
const loadConversationList = async () => {
|
||||||
|
if (loading.value) return;
|
||||||
|
|
||||||
|
loading.value = true;
|
||||||
|
|
||||||
|
try {
|
||||||
|
console.log("开始加载群聊列表");
|
||||||
|
|
||||||
|
// 检查 globalTimChatManager 是否存在
|
||||||
|
if (!globalTimChatManager || !globalTimChatManager.getGroupList) {
|
||||||
|
throw new Error("IM管理器未初始化");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 直接调用getGroupList，它会自动等待SDK就绪
|
||||||
|
const result = await globalTimChatManager.getGroupList();
|
||||||
|
|
||||||
|
if (result && result.success && result.groupList) {
|
||||||
|
conversationList.value = result.groupList
|
||||||
|
.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,
|
||||||
|
}))
|
||||||
|
.sort((a, b) => b.lastMessageTime - a.lastMessageTime);
|
||||||
|
|
||||||
|
console.log(
|
||||||
|
"群聊列表加载成功，共",
|
||||||
|
conversationList.value.length,
|
||||||
|
"个会话"
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
console.error("加载群聊列表失败:", result);
|
||||||
|
uni.showToast({
|
||||||
|
title: "加载失败，请重试",
|
||||||
|
icon: "none",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error("加载会话列表失败:", error);
|
||||||
|
uni.showToast({
|
||||||
|
title: error.message || "加载失败，请重试",
|
||||||
|
icon: "none",
|
||||||
|
});
|
||||||
|
} finally {
|
||||||
|
loading.value = false;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// 提取消息预览文本
|
||||||
|
const extractMessagePreview = (message) => {
|
||||||
|
if (!message) return "暂无消息";
|
||||||
|
|
||||||
|
const payload = message.payload;
|
||||||
|
if (!payload) return "暂无消息";
|
||||||
|
|
||||||
|
// 文本消息
|
||||||
|
if (message.type === "TIMTextElem") {
|
||||||
|
return payload.text || "暂无消息";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 图片消息
|
||||||
|
if (message.type === "TIMImageElem") {
|
||||||
|
return "[图片]";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 语音消息
|
||||||
|
if (message.type === "TIMSoundElem") {
|
||||||
|
return "[语音]";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 视频消息
|
||||||
|
if (message.type === "TIMVideoFileElem") {
|
||||||
|
return "[视频]";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 文件消息
|
||||||
|
if (message.type === "TIMFileElem") {
|
||||||
|
return "[文件]";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 自定义消息
|
||||||
|
if (message.type === "TIMCustomElem") {
|
||||||
|
const description = payload.description;
|
||||||
|
if (description === "SYSTEM_NOTIFICATION") {
|
||||||
|
return "[系统消息]";
|
||||||
|
}
|
||||||
|
return "[消息]";
|
||||||
|
}
|
||||||
|
|
||||||
|
return "暂无消息";
|
||||||
|
};
|
||||||
|
|
||||||
|
// 设置消息监听，实时更新列表
|
||||||
|
const setupMessageListener = () => {
|
||||||
|
if (!globalTimChatManager) return;
|
||||||
|
|
||||||
|
globalTimChatManager.setCallback("onMessageReceived", (message) => {
|
||||||
|
console.log("消息列表页面收到新消息:", message);
|
||||||
|
|
||||||
|
// 找到对应的会话并更新
|
||||||
|
const conversationID = message.conversationID;
|
||||||
|
const conversationIndex = conversationList.value.findIndex(
|
||||||
|
(conv) => conv.conversationID === conversationID
|
||||||
|
);
|
||||||
|
|
||||||
|
if (conversationIndex !== -1) {
|
||||||
|
// 更新现有会话
|
||||||
|
const conversation = conversationList.value[conversationIndex];
|
||||||
|
conversation.lastMessage = extractMessagePreview(message);
|
||||||
|
conversation.lastMessageTime = message.lastTime || Date.now();
|
||||||
|
conversation.unreadCount = (conversation.unreadCount || 0) + 1;
|
||||||
|
|
||||||
|
// 将该会话移到顶部
|
||||||
|
const [updatedConversation] = conversationList.value.splice(
|
||||||
|
conversationIndex,
|
||||||
|
1
|
||||||
|
);
|
||||||
|
conversationList.value.unshift(updatedConversation);
|
||||||
|
|
||||||
|
console.log("已更新会话:", conversation.name);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
// 格式化消息时间
|
||||||
|
const formatMessageTime = (timestamp) => {
|
||||||
|
if (!timestamp) return "";
|
||||||
|
|
||||||
|
const now = Date.now();
|
||||||
|
const diff = now - timestamp;
|
||||||
|
const date = new Date(timestamp);
|
||||||
|
|
||||||
|
// 1分钟内
|
||||||
|
if (diff < 60 * 1000) {
|
||||||
|
return "刚刚";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 1小时内
|
||||||
|
if (diff < 60 * 60 * 1000) {
|
||||||
|
return `${Math.floor(diff / (60 * 1000))}分钟前`;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 今天
|
||||||
|
const today = new Date();
|
||||||
|
if (date.toDateString() === today.toDateString()) {
|
||||||
|
return `${String(date.getHours()).padStart(2, "0")}:${String(
|
||||||
|
date.getMinutes()
|
||||||
|
).padStart(2, "0")}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 昨天
|
||||||
|
const yesterday = new Date(today);
|
||||||
|
yesterday.setDate(yesterday.getDate() - 1);
|
||||||
|
if (date.toDateString() === yesterday.toDateString()) {
|
||||||
|
return "昨天";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 今年
|
||||||
|
if (date.getFullYear() === today.getFullYear()) {
|
||||||
|
return `${date.getMonth() + 1}月${date.getDate()}日`;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 其他
|
||||||
|
return `${date.getFullYear()}年${date.getMonth() + 1}月${date.getDate()}日`;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 点击会话
|
||||||
|
const handleClickConversation = (conversation) => {
|
||||||
|
console.log("点击会话:", conversation);
|
||||||
|
|
||||||
|
// 跳转到聊天页面
|
||||||
|
uni.navigateTo({
|
||||||
|
url: `/pages/message/index?conversationID=${conversation.conversationID}&groupID=${conversation.groupID}`,
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
// 加载更多
|
||||||
|
const handleLoadMore = () => {
|
||||||
|
if (loadingMore.value || !hasMore.value) return;
|
||||||
|
|
||||||
|
loadingMore.value = true;
|
||||||
|
// TODO: 实现分页加载
|
||||||
|
setTimeout(() => {
|
||||||
|
loadingMore.value = false;
|
||||||
|
}, 1000);
|
||||||
|
};
|
||||||
|
|
||||||
|
// 下拉刷新
|
||||||
|
const handleRefresh = async () => {
|
||||||
|
refreshing.value = true;
|
||||||
|
|
||||||
|
try {
|
||||||
|
await loadConversationList();
|
||||||
|
} finally {
|
||||||
|
refreshing.value = false;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// 页面加载
|
||||||
|
onLoad(() => {
|
||||||
|
console.log("消息列表页面加载");
|
||||||
|
});
|
||||||
|
|
||||||
|
// 页面显示
|
||||||
|
onShow(async () => {
|
||||||
|
try {
|
||||||
|
// 初始化IM
|
||||||
|
const imReady = await initIM();
|
||||||
|
if (!imReady) {
|
||||||
|
console.error("IM初始化失败");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 先设置消息监听
|
||||||
|
setupMessageListener();
|
||||||
|
|
||||||
|
// 加载消息列表
|
||||||
|
await loadConversationList();
|
||||||
|
} catch (error) {
|
||||||
|
console.error("页面初始化失败:", error);
|
||||||
|
uni.showToast({
|
||||||
|
title: "初始化失败，请重试",
|
||||||
|
icon: "none",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
// 页面隐藏
|
||||||
|
onHide(() => {
|
||||||
|
// 移除消息监听
|
||||||
|
if (globalTimChatManager) {
|
||||||
|
globalTimChatManager.setCallback("onMessageReceived", null);
|
||||||
|
}
|
||||||
|
});
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<style>
|
<style scoped lang="scss">
|
||||||
|
.message-page {
|
||||||
|
width: 100%;
|
||||||
|
height: 100vh;
|
||||||
|
background-color: #f5f5f5;
|
||||||
|
}
|
||||||
|
|
||||||
|
.message-list {
|
||||||
|
width: 100%;
|
||||||
|
height: 100%;
|
||||||
|
}
|
||||||
|
|
||||||
|
.loading-container,
|
||||||
|
.empty-container {
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: center;
|
||||||
|
padding: 100rpx 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
.loading-text {
|
||||||
|
font-size: 28rpx;
|
||||||
|
color: #999;
|
||||||
|
}
|
||||||
|
|
||||||
|
.empty-image {
|
||||||
|
width: 200rpx;
|
||||||
|
height: 200rpx;
|
||||||
|
margin-bottom: 20rpx;
|
||||||
|
}
|
||||||
|
|
||||||
|
.empty-text {
|
||||||
|
font-size: 28rpx;
|
||||||
|
color: #999;
|
||||||
|
}
|
||||||
|
|
||||||
|
.message-item {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
padding: 24rpx 32rpx;
|
||||||
|
background-color: #fff;
|
||||||
|
border-bottom: 1rpx solid #f0f0f0;
|
||||||
|
|
||||||
|
&:active {
|
||||||
|
background-color: #f5f5f5;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
.avatar-container {
|
||||||
|
position: relative;
|
||||||
|
margin-right: 24rpx;
|
||||||
|
}
|
||||||
|
|
||||||
|
.avatar {
|
||||||
|
width: 96rpx;
|
||||||
|
height: 96rpx;
|
||||||
|
border-radius: 8rpx;
|
||||||
|
}
|
||||||
|
|
||||||
|
.unread-badge {
|
||||||
|
position: absolute;
|
||||||
|
top: -8rpx;
|
||||||
|
right: -8rpx;
|
||||||
|
min-width: 32rpx;
|
||||||
|
height: 32rpx;
|
||||||
|
padding: 0 8rpx;
|
||||||
|
background-color: #ff4d4f;
|
||||||
|
border-radius: 16rpx;
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: center;
|
||||||
|
}
|
||||||
|
|
||||||
|
.unread-text {
|
||||||
|
font-size: 20rpx;
|
||||||
|
color: #fff;
|
||||||
|
line-height: 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
.content {
|
||||||
|
flex: 1;
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
justify-content: center;
|
||||||
|
min-width: 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
.header {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: space-between;
|
||||||
|
margin-bottom: 8rpx;
|
||||||
|
}
|
||||||
|
|
||||||
|
.name {
|
||||||
|
font-size: 32rpx;
|
||||||
|
font-weight: 500;
|
||||||
|
color: #333;
|
||||||
|
flex: 1;
|
||||||
|
overflow: hidden;
|
||||||
|
text-overflow: ellipsis;
|
||||||
|
white-space: nowrap;
|
||||||
|
}
|
||||||
|
|
||||||
|
.time {
|
||||||
|
font-size: 24rpx;
|
||||||
|
color: #999;
|
||||||
|
margin-left: 16rpx;
|
||||||
|
flex-shrink: 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
.message-preview {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
}
|
||||||
|
|
||||||
|
.preview-text {
|
||||||
|
font-size: 28rpx;
|
||||||
|
color: #999;
|
||||||
|
overflow: hidden;
|
||||||
|
text-overflow: ellipsis;
|
||||||
|
white-space: nowrap;
|
||||||
|
}
|
||||||
|
|
||||||
|
.load-more {
|
||||||
|
padding: 20rpx 0;
|
||||||
|
text-align: center;
|
||||||
|
}
|
||||||
|
|
||||||
|
.load-more-text {
|
||||||
|
font-size: 24rpx;
|
||||||
|
color: #999;
|
||||||
|
}
|
||||||
</style>
|
</style>
|
||||||
1
static/home/avatar.svg
Normal file
1
static/home/avatar.svg
Normal file
File diff suppressed because one or more lines are too long
|
After Width: | Height: | Size: 5.4 KiB |
@ -2,7 +2,7 @@ import { ref } from "vue";
|
|||||||
import { defineStore } from "pinia";
|
import { defineStore } from "pinia";
|
||||||
import api from '@/utils/api';
|
import api from '@/utils/api';
|
||||||
import { toast } from '@/utils/widget';
|
import { toast } from '@/utils/widget';
|
||||||
import { getInitIMPromise, clearInitIMPromise } from "@/utils/tim-chat.js";
|
import { initGlobalTIM, globalTimChatManager } from "@/utils/tim-chat.js";
|
||||||
const env = __VITE_ENV__;
|
const env = __VITE_ENV__;
|
||||||
|
|
||||||
|
|
||||||
@ -12,8 +12,10 @@ export default defineStore("accountStore", () => {
|
|||||||
const loading = ref(false)
|
const loading = ref(false)
|
||||||
// IM 相关
|
// IM 相关
|
||||||
const openid = ref("");
|
const openid = ref("");
|
||||||
|
const isIMInitialized = ref(false);
|
||||||
// 医生信息
|
// 医生信息
|
||||||
const doctorInfo = ref(null);
|
const doctorInfo = ref(null);
|
||||||
|
|
||||||
async function login(phoneCode = '') {
|
async function login(phoneCode = '') {
|
||||||
if (loading.value) return;
|
if (loading.value) return;
|
||||||
loading.value = true;
|
loading.value = true;
|
||||||
@ -38,6 +40,18 @@ export default defineStore("accountStore", () => {
|
|||||||
account.value = res.data;
|
account.value = res.data;
|
||||||
openid.value = res.data.openid;
|
openid.value = res.data.openid;
|
||||||
await getDoctorInfo(openid.value);
|
await getDoctorInfo(openid.value);
|
||||||
|
|
||||||
|
// 登录成功后初始化腾讯IM
|
||||||
|
try {
|
||||||
|
console.log('开始初始化腾讯IM，userID:', res.data.openid);
|
||||||
|
await initGlobalTIM(res.data.openid);
|
||||||
|
isIMInitialized.value = true;
|
||||||
|
console.log('腾讯IM初始化成功');
|
||||||
|
} catch (imError) {
|
||||||
|
console.error('腾讯IM初始化失败:', imError);
|
||||||
|
// IM初始化失败不影响登录流程
|
||||||
|
}
|
||||||
|
|
||||||
return res.data
|
return res.data
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -47,6 +61,7 @@ export default defineStore("accountStore", () => {
|
|||||||
}
|
}
|
||||||
loading.value = false
|
loading.value = false
|
||||||
}
|
}
|
||||||
|
|
||||||
async function getDoctorInfo() {
|
async function getDoctorInfo() {
|
||||||
try {
|
try {
|
||||||
const res = await api('getCorpMemberData', {
|
const res = await api('getCorpMemberData', {
|
||||||
@ -60,5 +75,39 @@ export default defineStore("accountStore", () => {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return { account, openid, doctorInfo, login, getDoctorInfo }
|
async function initIMAfterLogin(userID) {
|
||||||
|
if (isIMInitialized.value) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
try {
|
||||||
|
await initGlobalTIM(userID);
|
||||||
|
isIMInitialized.value = true;
|
||||||
|
return true;
|
||||||
|
} catch (error) {
|
||||||
|
console.error('IM初始化失败:', error);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 退出登录
|
||||||
|
async function logout() {
|
||||||
|
try {
|
||||||
|
// 退出腾讯IM
|
||||||
|
if (globalTimChatManager && globalTimChatManager.tim) {
|
||||||
|
console.log('开始退出腾讯IM');
|
||||||
|
await globalTimChatManager.destroy();
|
||||||
|
console.log('腾讯IM退出成功');
|
||||||
|
}
|
||||||
|
} catch (error) {
|
||||||
|
console.error('退出腾讯IM失败:', error);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 清空账户信息
|
||||||
|
account.value = null;
|
||||||
|
openid.value = "";
|
||||||
|
isIMInitialized.value = false;
|
||||||
|
doctorInfo.value = null;
|
||||||
|
}
|
||||||
|
|
||||||
|
return { account, openid, isIMInitialized, doctorInfo, login, getDoctorInfo, initIMAfterLogin, logout }
|
||||||
})
|
})
|
||||||
@ -28,6 +28,11 @@ const urlsConfig = {
|
|||||||
},
|
},
|
||||||
wecom: {
|
wecom: {
|
||||||
addContactWay: 'addContactWay'
|
addContactWay: 'addContactWay'
|
||||||
|
},
|
||||||
|
im: {
|
||||||
|
getUserSig: 'getUserSig',
|
||||||
|
sendSystemMessage: "sendSystemMessage",
|
||||||
|
getChatRecordsByGroupId: "getChatRecordsByGroupId"
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
798
utils/chat-utils.js
Normal file
798
utils/chat-utils.js
Normal file
@ -0,0 +1,798 @@
|
|||||||
|
/**
|
||||||
|
* 聊天相关工具函数
|
||||||
|
*/
|
||||||
|
|
||||||
|
// 通用消息提示
|
||||||
|
export const showMessage = (title, icon = 'none') => {
|
||||||
|
uni.showToast({
|
||||||
|
title,
|
||||||
|
icon,
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
// 检查问诊状态
|
||||||
|
export const checkConsultationStatus = (waitingForDoctor, consultationEnded) => {
|
||||||
|
if (waitingForDoctor) {
|
||||||
|
showMessage("等待医生接诊中，无法发送消息");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (consultationEnded) {
|
||||||
|
showMessage("问诊已结束，无法发送消息");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
//
|
||||||
|
// 检查IM连接状态
|
||||||
|
export const checkIMConnection = (timChatManager) => {
|
||||||
|
if (!timChatManager.tim || !timChatManager.isLoggedIn) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 发送消息前的通用验证
|
||||||
|
export const validateBeforeSend = (waitingForDoctor, consultationEnded, timChatManager) => {
|
||||||
|
if (!checkConsultationStatus(waitingForDoctor, consultationEnded)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!checkIMConnection(timChatManager)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 获取语音文件URL
|
||||||
|
export const getVoiceUrl = (message) => {
|
||||||
|
let voiceUrl = '';
|
||||||
|
if (message.payload && message.payload.url) {
|
||||||
|
voiceUrl = message.payload.url;
|
||||||
|
} else if (message.payload && message.payload.file) {
|
||||||
|
voiceUrl = message.payload.file;
|
||||||
|
} else if (message.payload && message.payload.tempFilePath) {
|
||||||
|
voiceUrl = message.payload.tempFilePath;
|
||||||
|
} else if (message.payload && message.payload.filePath) {
|
||||||
|
voiceUrl = message.payload.filePath;
|
||||||
|
}
|
||||||
|
return voiceUrl;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 验证语音URL格式
|
||||||
|
export const validateVoiceUrl = (voiceUrl) => {
|
||||||
|
if (!voiceUrl) {
|
||||||
|
console.error('语音文件URL不存在');
|
||||||
|
showMessage('语音文件不存在');
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!voiceUrl.startsWith('http') && !voiceUrl.startsWith('wxfile://') && !voiceUrl.startsWith('/')) {
|
||||||
|
console.error('语音文件URL格式不正确:', voiceUrl);
|
||||||
|
showMessage('语音文件格式错误');
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 创建音频上下文
|
||||||
|
export const createAudioContext = (voiceUrl) => {
|
||||||
|
const audioContext = uni.createInnerAudioContext();
|
||||||
|
audioContext.src = voiceUrl;
|
||||||
|
|
||||||
|
audioContext.onPlay(() => {
|
||||||
|
console.log('语音开始播放');
|
||||||
|
});
|
||||||
|
|
||||||
|
audioContext.onEnded(() => {
|
||||||
|
console.log('语音播放结束');
|
||||||
|
});
|
||||||
|
|
||||||
|
audioContext.onError((err) => {
|
||||||
|
console.error('语音播放失败:', err);
|
||||||
|
console.error('错误详情:', {
|
||||||
|
errMsg: err.errMsg,
|
||||||
|
errno: err.errno,
|
||||||
|
src: voiceUrl
|
||||||
|
});
|
||||||
|
showMessage('语音播放失败');
|
||||||
|
});
|
||||||
|
|
||||||
|
return audioContext;
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 时间相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 验证时间戳格式
|
||||||
|
* @param {number|string} timestamp - 时间戳
|
||||||
|
* @returns {boolean} 是否为有效时间戳
|
||||||
|
*/
|
||||||
|
export const validateTimestamp = (timestamp) => {
|
||||||
|
if (!timestamp) return false;
|
||||||
|
|
||||||
|
const num = Number(timestamp);
|
||||||
|
if (isNaN(num)) return false;
|
||||||
|
|
||||||
|
// 检查是否为有效的时间戳范围（1970年到2100年）
|
||||||
|
const minTimestamp = 0;
|
||||||
|
const maxTimestamp = 4102444800000; // 2100年1月1日
|
||||||
|
|
||||||
|
return num >= minTimestamp && num <= maxTimestamp;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 格式化时间 - 今天/昨天显示文字，其他显示日期 + 空格 + 24小时制时间
|
||||||
|
* @param {number|string} timestamp - 时间戳
|
||||||
|
* @returns {string} 格式化后的时间字符串
|
||||||
|
*/
|
||||||
|
export const formatTime = (timestamp) => {
|
||||||
|
// 验证时间戳
|
||||||
|
if (!validateTimestamp(timestamp)) {
|
||||||
|
return "未知时间";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 确保时间戳是毫秒级
|
||||||
|
let timeInMs = timestamp;
|
||||||
|
if (timestamp < 1000000000000) {
|
||||||
|
// 如果时间戳小于这个值，可能是秒级时间戳
|
||||||
|
timeInMs = timestamp * 1000;
|
||||||
|
}
|
||||||
|
|
||||||
|
const date = new Date(timeInMs);
|
||||||
|
const now = new Date();
|
||||||
|
|
||||||
|
// 验证日期是否有效
|
||||||
|
if (isNaN(date.getTime())) {
|
||||||
|
return "未知时间";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 格式化时间：HH:MM (24小时制)
|
||||||
|
const hours = String(date.getHours()).padStart(2, "0");
|
||||||
|
const minutes = String(date.getMinutes()).padStart(2, "0");
|
||||||
|
const timeStr = `${hours}:${minutes}`;
|
||||||
|
|
||||||
|
// 检查是否是今天
|
||||||
|
if (date.toDateString() === now.toDateString()) {
|
||||||
|
return `${timeStr}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 检查是否是昨天
|
||||||
|
const yesterday = new Date(now);
|
||||||
|
yesterday.setDate(yesterday.getDate() - 1);
|
||||||
|
if (date.toDateString() === yesterday.toDateString()) {
|
||||||
|
return `昨天 ${timeStr}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 其他日期显示完整日期
|
||||||
|
const month = String(date.getMonth() + 1).padStart(2, "0");
|
||||||
|
const day = String(date.getDate()).padStart(2, "0");
|
||||||
|
const dateStr = `${month}/${day}`;
|
||||||
|
|
||||||
|
return `${dateStr} ${timeStr}`;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 计算时间差
|
||||||
|
* @param {number|string} startTime - 开始时间戳
|
||||||
|
* @param {number|string} endTime - 结束时间戳
|
||||||
|
* @returns {object} 包含天、小时、分钟、秒的时间差对象
|
||||||
|
*/
|
||||||
|
export const calculateTimeDiff = (startTime, endTime) => {
|
||||||
|
if (!validateTimestamp(startTime) || !validateTimestamp(endTime)) {
|
||||||
|
return { days: 0, hours: 0, minutes: 0, seconds: 0 };
|
||||||
|
}
|
||||||
|
|
||||||
|
let startMs = startTime;
|
||||||
|
let endMs = endTime;
|
||||||
|
|
||||||
|
if (startTime < 1000000000000) startMs = startTime * 1000;
|
||||||
|
if (endTime < 1000000000000) endMs = endTime * 1000;
|
||||||
|
|
||||||
|
const diffMs = Math.abs(endMs - startMs);
|
||||||
|
|
||||||
|
const days = Math.floor(diffMs / (1000 * 60 * 60 * 24));
|
||||||
|
const hours = Math.floor((diffMs % (1000 * 60 * 60 * 24)) / (1000 * 60 * 60));
|
||||||
|
const minutes = Math.floor((diffMs % (1000 * 60 * 60)) / (1000 * 60));
|
||||||
|
const seconds = Math.floor((diffMs % (1000 * 60)) / 1000);
|
||||||
|
|
||||||
|
return { days, hours, minutes, seconds };
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 格式化倒计时
|
||||||
|
* @param {number|string} endTime - 结束时间戳
|
||||||
|
* @param {number|string} currentTime - 当前时间戳（可选，默认使用当前时间）
|
||||||
|
* @returns {string} 格式化后的倒计时字符串
|
||||||
|
*/
|
||||||
|
export const formatCountdown = (endTime, currentTime = Date.now()) => {
|
||||||
|
const diff = calculateTimeDiff(currentTime, endTime);
|
||||||
|
|
||||||
|
if (diff.days > 0) {
|
||||||
|
return `${diff.days}天${diff.hours}时${diff.minutes}分`;
|
||||||
|
} else if (diff.hours > 0) {
|
||||||
|
return `${diff.hours}时${diff.minutes}分${diff.seconds}秒`;
|
||||||
|
} else if (diff.minutes > 0) {
|
||||||
|
return `${diff.minutes}分${diff.seconds}秒`;
|
||||||
|
} else {
|
||||||
|
return `${diff.seconds}秒`;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 媒体选择相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查并请求相册权限
|
||||||
|
* @returns {Promise<boolean>} 是否有权限
|
||||||
|
*/
|
||||||
|
const checkAlbumPermission = () => {
|
||||||
|
return new Promise((resolve) => {
|
||||||
|
uni.getSetting({
|
||||||
|
success: (res) => {
|
||||||
|
const authStatus = res.authSetting['scope.album'];
|
||||||
|
|
||||||
|
if (authStatus === undefined) {
|
||||||
|
// 未授权过，会自动弹出授权窗口
|
||||||
|
resolve(true);
|
||||||
|
} else if (authStatus === false) {
|
||||||
|
// 已拒绝授权，需要引导用户手动开启
|
||||||
|
uni.showModal({
|
||||||
|
title: '需要相册权限',
|
||||||
|
content: '请在设置中开启相册权限，以便选择图片',
|
||||||
|
confirmText: '去设置',
|
||||||
|
success: (modalRes) => {
|
||||||
|
if (modalRes.confirm) {
|
||||||
|
uni.openSetting({
|
||||||
|
success: (settingRes) => {
|
||||||
|
if (settingRes.authSetting['scope.album']) {
|
||||||
|
resolve(true);
|
||||||
|
} else {
|
||||||
|
resolve(false);
|
||||||
|
}
|
||||||
|
},
|
||||||
|
fail: () => {
|
||||||
|
resolve(false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
resolve(false);
|
||||||
|
}
|
||||||
|
},
|
||||||
|
fail: () => {
|
||||||
|
resolve(false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
// 已授权
|
||||||
|
resolve(true);
|
||||||
|
}
|
||||||
|
},
|
||||||
|
fail: () => {
|
||||||
|
// 获取设置失败，尝试直接调用
|
||||||
|
resolve(true);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 选择媒体文件
|
||||||
|
* @param {object} options - 选择选项
|
||||||
|
* @param {function} onSuccess - 成功回调
|
||||||
|
* @param {function} onFail - 失败回调
|
||||||
|
*/
|
||||||
|
export const chooseMedia = async (options, onSuccess, onFail) => {
|
||||||
|
// 如果需要从相册选择，先检查权限
|
||||||
|
const sourceType = options.sourceType || ['album', 'camera'];
|
||||||
|
if (sourceType.includes('album')) {
|
||||||
|
const hasPermission = await checkAlbumPermission();
|
||||||
|
if (!hasPermission) {
|
||||||
|
console.log('用户未授予相册权限');
|
||||||
|
if (onFail) {
|
||||||
|
onFail({ errMsg: '未授权相册权限' });
|
||||||
|
}
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
uni.chooseMedia({
|
||||||
|
count: options.count || 1,
|
||||||
|
mediaType: options.mediaType || ['image'],
|
||||||
|
sizeType: options.sizeType || ['original', 'compressed'],
|
||||||
|
sourceType: sourceType,
|
||||||
|
success: function (res) {
|
||||||
|
console.log('选择媒体成功:', res);
|
||||||
|
if (onSuccess) onSuccess(res);
|
||||||
|
},
|
||||||
|
fail: function (err) {
|
||||||
|
// 用户取消选择
|
||||||
|
if (err.errMsg.includes('cancel')) {
|
||||||
|
console.log('用户取消选择');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 权限相关错误
|
||||||
|
if (err.errMsg.includes('permission') || err.errMsg.includes('auth') || err.errMsg.includes('拒绝')) {
|
||||||
|
console.error('相册权限被拒绝:', err);
|
||||||
|
uni.showModal({
|
||||||
|
title: '需要相册权限',
|
||||||
|
content: '请在设置中开启相册权限后重试',
|
||||||
|
confirmText: '去设置',
|
||||||
|
success: (modalRes) => {
|
||||||
|
if (modalRes.confirm) {
|
||||||
|
uni.openSetting();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
if (onFail) {
|
||||||
|
onFail(err);
|
||||||
|
}
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 其他错误
|
||||||
|
console.error('选择媒体失败:', err);
|
||||||
|
if (onFail) {
|
||||||
|
onFail(err);
|
||||||
|
} else {
|
||||||
|
showMessage('选择图片失败，请重试');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 选择图片
|
||||||
|
* @param {function} onSuccess - 成功回调
|
||||||
|
* @param {function} onFail - 失败回调
|
||||||
|
*/
|
||||||
|
export const chooseImage = (onSuccess, onFail) => {
|
||||||
|
chooseMedia({
|
||||||
|
count: 1,
|
||||||
|
mediaType: ['image'],
|
||||||
|
sizeType: ['original', 'compressed'],
|
||||||
|
sourceType: ['album', 'camera']
|
||||||
|
}, onSuccess, onFail);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 拍照
|
||||||
|
* @param {function} onSuccess - 成功回调
|
||||||
|
* @param {function} onFail - 失败回调
|
||||||
|
*/
|
||||||
|
export const takePhoto = (onSuccess, onFail) => {
|
||||||
|
chooseMedia({
|
||||||
|
count: 1,
|
||||||
|
mediaType: ['image'],
|
||||||
|
sizeType: ['original', 'compressed'],
|
||||||
|
sourceType: ['camera']
|
||||||
|
}, onSuccess, onFail);
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 录音相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 初始化录音管理器
|
||||||
|
* @param {object} options - 录音选项
|
||||||
|
* @param {function} onStop - 录音结束回调
|
||||||
|
* @param {function} onError - 录音错误回调
|
||||||
|
* @returns {object} 录音管理器实例
|
||||||
|
*/
|
||||||
|
export const initRecorderManager = (options = {}, onStop, onError) => {
|
||||||
|
const recorderManager = wx.getRecorderManager();
|
||||||
|
|
||||||
|
// 监听录音结束事件
|
||||||
|
recorderManager.onStop((res) => {
|
||||||
|
console.log('录音成功，结果:', res);
|
||||||
|
if (onStop) onStop(res);
|
||||||
|
});
|
||||||
|
|
||||||
|
// 监听录音错误事件
|
||||||
|
recorderManager.onError((err) => {
|
||||||
|
console.error('录音失败:', err);
|
||||||
|
if (onError) {
|
||||||
|
onError(err);
|
||||||
|
} else {
|
||||||
|
showMessage("录音失败");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return recorderManager;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 开始录音
|
||||||
|
* @param {object} recorderManager - 录音管理器
|
||||||
|
* @param {object} options - 录音参数
|
||||||
|
*/
|
||||||
|
export const startRecord = (recorderManager, options = {}) => {
|
||||||
|
if (!recorderManager) {
|
||||||
|
console.error('录音管理器未初始化');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const recordOptions = {
|
||||||
|
duration: 60000, // 录音的时长，单位 ms，最大值 600000（10 分钟）
|
||||||
|
sampleRate: 44100, // 采样率
|
||||||
|
numberOfChannels: 1, // 录音通道数
|
||||||
|
encodeBitRate: 192000, // 编码码率
|
||||||
|
format: 'aac', // 音频格式
|
||||||
|
...options
|
||||||
|
};
|
||||||
|
|
||||||
|
recorderManager.start(recordOptions);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 停止录音
|
||||||
|
* @param {object} recorderManager - 录音管理器
|
||||||
|
*/
|
||||||
|
export const stopRecord = (recorderManager) => {
|
||||||
|
if (!recorderManager) {
|
||||||
|
console.error('录音管理器未初始化');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
recorderManager.stop();
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 消息发送相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建自定义消息
|
||||||
|
* @param {string} messageType - 消息类型
|
||||||
|
* @param {object} data - 消息数据
|
||||||
|
* @param {function} formatTime - 时间格式化函数
|
||||||
|
* @returns {object} 自定义消息对象
|
||||||
|
*/
|
||||||
|
export const createCustomMessage = (messageType, data, formatTime) => {
|
||||||
|
return {
|
||||||
|
messageType,
|
||||||
|
time: formatTime(Date.now()),
|
||||||
|
...data
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送自定义消息的通用方法
|
||||||
|
* @param {object} messageData - 消息数据
|
||||||
|
* @param {object} timChatManager - IM管理器
|
||||||
|
* @param {function} validateBeforeSend - 发送前验证函数
|
||||||
|
* @param {function} onSuccess - 成功回调
|
||||||
|
*/
|
||||||
|
export const sendCustomMessage = async (messageData, timChatManager, validateBeforeSend, onSuccess) => {
|
||||||
|
if (!validateBeforeSend()) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const result = await timChatManager.sendCustomMessage(messageData);
|
||||||
|
|
||||||
|
if (result && result.success) {
|
||||||
|
if (onSuccess) onSuccess();
|
||||||
|
} else {
|
||||||
|
console.error('发送自定义消息失败:', result?.error);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送消息的通用方法
|
||||||
|
* @param {string} messageType - 消息类型
|
||||||
|
* @param {any} data - 消息数据
|
||||||
|
* @param {object} timChatManager - IM管理器
|
||||||
|
* @param {function} validateBeforeSend - 发送前验证函数
|
||||||
|
* @param {function} onSuccess - 成功回调
|
||||||
|
*/
|
||||||
|
export const sendMessage = async (messageType, data, timChatManager, validateBeforeSend, onSuccess, cloudCustomData) => {
|
||||||
|
if (!validateBeforeSend()) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
let result;
|
||||||
|
|
||||||
|
switch (messageType) {
|
||||||
|
case 'text':
|
||||||
|
result = await timChatManager.sendTextMessage(data, cloudCustomData);
|
||||||
|
break;
|
||||||
|
case 'image':
|
||||||
|
result = await timChatManager.sendImageMessage(data, cloudCustomData);
|
||||||
|
break;
|
||||||
|
case 'voice':
|
||||||
|
result = await timChatManager.sendVoiceMessage(data.file, data.duration,cloudCustomData);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
console.error('未知的消息类型:', messageType);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (result && result.success) {
|
||||||
|
if (onSuccess) onSuccess();
|
||||||
|
} else {
|
||||||
|
console.error('发送消息失败:', result?.error);
|
||||||
|
showMessage('发送失败，请重试');
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 状态检查相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查IM连接状态
|
||||||
|
* @param {object} timChatManager - IM管理器
|
||||||
|
* @param {function} onError - 错误回调
|
||||||
|
* @returns {boolean} 连接状态
|
||||||
|
*/
|
||||||
|
export const checkIMConnectionStatus = (timChatManager, onError) => {
|
||||||
|
if (!timChatManager.tim || !timChatManager.isLoggedIn) {
|
||||||
|
const errorMsg = "IM连接异常，请重新进入";
|
||||||
|
if (onError) {
|
||||||
|
onError(errorMsg);
|
||||||
|
} else {
|
||||||
|
showMessage(errorMsg);
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查是否显示时间分割线
|
||||||
|
* @param {object} message - 当前消息
|
||||||
|
* @param {number} index - 消息索引
|
||||||
|
* @param {Array} messageList - 消息列表
|
||||||
|
* @returns {boolean} 是否显示时间分割线
|
||||||
|
*/
|
||||||
|
export const shouldShowTime = (message, index, messageList) => {
|
||||||
|
if (index === 0) return true;
|
||||||
|
|
||||||
|
const prevMessage = messageList[index - 1];
|
||||||
|
|
||||||
|
// 使用工具函数验证时间戳
|
||||||
|
if (!validateTimestamp(message.lastTime) || !validateTimestamp(prevMessage.lastTime)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
const timeDiff = message.lastTime - prevMessage.lastTime;
|
||||||
|
|
||||||
|
return timeDiff > 5 * 60 * 1000; // 5分钟显示一次时间
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 预览图片
|
||||||
|
* @param {string} url - 图片URL
|
||||||
|
*/
|
||||||
|
export const previewImage = (url) => {
|
||||||
|
uni.previewImage({
|
||||||
|
urls: [url],
|
||||||
|
current: url,
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 录音相关工具方法 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检查录音时长并处理
|
||||||
|
* @param {object} res - 录音结果
|
||||||
|
* @param {Function} onTimeTooShort - 时间太短的回调
|
||||||
|
* @returns {boolean} 录音时长是否有效
|
||||||
|
*/
|
||||||
|
export const checkRecordingDuration = (res, onTimeTooShort = null) => {
|
||||||
|
const duration = Math.floor(res.duration / 1000);
|
||||||
|
if (duration < 1) {
|
||||||
|
console.log('录音时间太短，取消发送');
|
||||||
|
if (onTimeTooShort) {
|
||||||
|
onTimeTooShort();
|
||||||
|
} else {
|
||||||
|
showMessage('说话时间太短');
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 防抖和节流工具 ====================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 防抖函数
|
||||||
|
* @param {Function} func - 要防抖的函数
|
||||||
|
* @param {number} wait - 等待时间（毫秒）
|
||||||
|
* @returns {Function} 防抖后的函数
|
||||||
|
*/
|
||||||
|
export const debounce = (func, wait = 300) => {
|
||||||
|
let timeout;
|
||||||
|
return function executedFunction(...args) {
|
||||||
|
const later = () => {
|
||||||
|
clearTimeout(timeout);
|
||||||
|
func(...args);
|
||||||
|
};
|
||||||
|
clearTimeout(timeout);
|
||||||
|
timeout = setTimeout(later, wait);
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 节流函数
|
||||||
|
* @param {Function} func - 要节流的函数
|
||||||
|
* @param {number} limit - 限制时间（毫秒）
|
||||||
|
* @returns {Function} 节流后的函数
|
||||||
|
*/
|
||||||
|
export const throttle = (func, limit = 300) => {
|
||||||
|
let inThrottle;
|
||||||
|
return function executedFunction(...args) {
|
||||||
|
if (!inThrottle) {
|
||||||
|
func.apply(this, args);
|
||||||
|
inThrottle = true;
|
||||||
|
setTimeout(() => inThrottle = false, limit);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
// ==================== 自定义消息解析相关工具方法 ====================
|
||||||
|
|
||||||
|
// 自定义消息解析缓存
|
||||||
|
const customMessageCache = new Map();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 解析自定义消息（带缓存）
|
||||||
|
* @param {object} message - 消息对象
|
||||||
|
* @param {function} formatTime - 时间格式化函数
|
||||||
|
* @returns {object} 解析后的消息对象
|
||||||
|
*/
|
||||||
|
export const parseCustomMessage = (message, formatTime) => {
|
||||||
|
// 使用消息ID作为缓存键
|
||||||
|
const cacheKey = message.ID;
|
||||||
|
|
||||||
|
// 检查缓存
|
||||||
|
if (customMessageCache.has(cacheKey)) {
|
||||||
|
return customMessageCache.get(cacheKey);
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
const customData = JSON.parse(message.payload.data);
|
||||||
|
const parsedMessage = {
|
||||||
|
messageType: customData.messageType,
|
||||||
|
content: customData.content,
|
||||||
|
symptomContent: customData.symptomContent,
|
||||||
|
hasVisitedHospital: customData.hasVisitedHospital,
|
||||||
|
selectedDiseases: customData.selectedDiseases,
|
||||||
|
images: customData.images,
|
||||||
|
medicines: customData.medicines,
|
||||||
|
diagnosis: customData.diagnosis,
|
||||||
|
prescriptionType: customData.prescriptionType,
|
||||||
|
prescriptionDesc: customData.prescriptionDesc,
|
||||||
|
tcmPrescription: customData.tcmPrescription, // 新增中药处方字段
|
||||||
|
patientName: customData.patientName,
|
||||||
|
gender: customData.gender,
|
||||||
|
age: customData.age,
|
||||||
|
surveyTitle: customData.surveyTitle,
|
||||||
|
surveyDescription: customData.surveyDescription,
|
||||||
|
surveyName: customData.surveyName,
|
||||||
|
estimatedTime: customData.estimatedTime,
|
||||||
|
reward: customData.reward,
|
||||||
|
note: customData.note,
|
||||||
|
orderId: customData.orderId, // 新增订单ID字段
|
||||||
|
timestamp: customData.timestamp, // 新增时间戳字段
|
||||||
|
conversationID: message.conversationID, // 保留conversationID
|
||||||
|
time: formatTime(message.lastTime),
|
||||||
|
};
|
||||||
|
|
||||||
|
// 缓存解析结果
|
||||||
|
customMessageCache.set(cacheKey, parsedMessage);
|
||||||
|
return parsedMessage;
|
||||||
|
} catch (error) {
|
||||||
|
const fallbackMessage = {
|
||||||
|
messageType: "unknown",
|
||||||
|
content: "未知消息类型",
|
||||||
|
};
|
||||||
|
|
||||||
|
// 缓存错误结果，避免重复解析
|
||||||
|
customMessageCache.set(cacheKey, fallbackMessage);
|
||||||
|
return fallbackMessage;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 清理消息缓存
|
||||||
|
*/
|
||||||
|
export const clearMessageCache = () => {
|
||||||
|
customMessageCache.clear();
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取解析后的自定义消息（带缓存）
|
||||||
|
* @param {object} message - 消息对象
|
||||||
|
* @param {function} formatTime - 时间格式化函数
|
||||||
|
* @returns {object} 解析后的消息对象
|
||||||
|
*/
|
||||||
|
export const getParsedCustomMessage = (message, formatTime) => {
|
||||||
|
return parseCustomMessage(message, formatTime);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 处理查看详情
|
||||||
|
* @param {object} message - 解析后的消息对象
|
||||||
|
* @param {object} patientInfo - 患者信息
|
||||||
|
*/
|
||||||
|
export const handleViewDetail = (message, patientInfo) => {
|
||||||
|
if (message.messageType === "symptom") {
|
||||||
|
uni.showModal({
|
||||||
|
title: "完整病情描述",
|
||||||
|
content: message.symptomContent,
|
||||||
|
showCancel: false,
|
||||||
|
confirmText: "知道了",
|
||||||
|
});
|
||||||
|
} else if (message.messageType === "prescription") {
|
||||||
|
// 处理处方单详情查看
|
||||||
|
let content = `患者：${patientInfo.name}\n诊断：${message.diagnosis || '无'}\n\n`;
|
||||||
|
|
||||||
|
if (message.prescriptionType === '中药处方' && message.tcmPrescription) {
|
||||||
|
content += `处方类型：中药处方\n处方详情：${message.tcmPrescription.description}\n`;
|
||||||
|
if (message.tcmPrescription.usage) {
|
||||||
|
content += `用法用量：${message.tcmPrescription.usage}\n`;
|
||||||
|
}
|
||||||
|
} else if (message.prescriptionType === '西药处方' && message.medicines) {
|
||||||
|
content += `处方类型：西药处方\n药品清单：\n`;
|
||||||
|
const medicineDetails = message.medicines
|
||||||
|
.map((med) => `${med.name} ${med.spec} ×${med.count}`)
|
||||||
|
.join("\n");
|
||||||
|
content += medicineDetails + "\n";
|
||||||
|
|
||||||
|
// 添加用法用量
|
||||||
|
const usageDetails = message.medicines
|
||||||
|
.filter(med => med.usage)
|
||||||
|
.map(med => `${med.name}：${med.usage}`)
|
||||||
|
.join("\n");
|
||||||
|
if (usageDetails) {
|
||||||
|
content += `\n用法用量：\n${usageDetails}\n`;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
content += `\n开方时间：${message.time}`;
|
||||||
|
|
||||||
|
uni.showModal({
|
||||||
|
title: "处方详情",
|
||||||
|
content: content,
|
||||||
|
showCancel: false,
|
||||||
|
confirmText: "知道了",
|
||||||
|
});
|
||||||
|
} else if (message.messageType === "refill") {
|
||||||
|
// 处理续方申请详情查看
|
||||||
|
let content = `患者：${message.patientName} ${message.gender} ${message.age}岁\n诊断：${message.diagnosis}\n\n`;
|
||||||
|
|
||||||
|
if (message.prescriptionType === "中药处方") {
|
||||||
|
content += `处方类型：${message.prescriptionType}\n处方详情：${message.prescriptionDesc}`;
|
||||||
|
} else {
|
||||||
|
const medicineDetails = message.medicines
|
||||||
|
.map((med) => `${med.name} ${med.spec} ${med.count}\n${med.usage}`)
|
||||||
|
.join("\n\n");
|
||||||
|
content += `药品清单：\n${medicineDetails}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
uni.showModal({
|
||||||
|
title: "续方申请详情",
|
||||||
|
content: content,
|
||||||
|
showCancel: false,
|
||||||
|
confirmText: "知道了",
|
||||||
|
});
|
||||||
|
} else if (message.messageType === "survey") {
|
||||||
|
// 处理问卷调查详情查看或跳转
|
||||||
|
uni.showModal({
|
||||||
|
title: "问卷调查",
|
||||||
|
content: `${message.surveyTitle}\n\n${message.surveyDescription
|
||||||
|
}\n\n问卷名称：${message.surveyName}\n预计用时：${message.estimatedTime}${message.reward ? "\n完成奖励：" + message.reward : ""
|
||||||
|
}${message.note ? "\n\n说明：" + message.note : ""}`,
|
||||||
|
confirmText: "去填写",
|
||||||
|
cancelText: "稍后再说",
|
||||||
|
success: (res) => {
|
||||||
|
if (res.confirm) {
|
||||||
|
// 这里可以跳转到问卷页面
|
||||||
|
uni.showToast({
|
||||||
|
title: "正在跳转到问卷页面",
|
||||||
|
icon: "none",
|
||||||
|
});
|
||||||
|
}
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
};
|
||||||
@ -1,8 +1,7 @@
|
|||||||
import {
|
import {
|
||||||
checkGlobalIMStatus,
|
checkGlobalIMStatus,
|
||||||
ensureGlobalIMConnection,
|
ensureGlobalIMConnection,
|
||||||
getGlobalIMLoginStatus,
|
getGlobalIMLoginStatus
|
||||||
setGlobalIMCallback
|
|
||||||
} from './tim-chat.js'
|
} from './tim-chat.js'
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@ -1,13 +1,21 @@
|
|||||||
// 引入腾讯IM SDK
|
// 引入腾讯IM SDK
|
||||||
import TIM from 'tim-wx-sdk'
|
import TIM from 'tim-wx-sdk'
|
||||||
import TIMUploadPlugin from 'tim-upload-plugin'
|
import TIMUploadPlugin from 'tim-upload-plugin'
|
||||||
import { getUserSig, sendSystemMessage, getChatRecordsByGroupId } from '../api/corp/im.js'
|
import api from './api.js'
|
||||||
|
|
||||||
const env = __VITE_ENV__;
|
const env = __VITE_ENV__;
|
||||||
|
|
||||||
// 腾讯IM配置 - SDKAppID 必须是 number 类型，使用 Number() 转换
|
// 腾讯IM配置 - SDKAppID 必须是 number 类型，使用 Number() 转换
|
||||||
const TIM_CONFIG = {
|
const TIM_CONFIG = {
|
||||||
SDKAppID: Number(env.APP_TIM_SDK_APP_ID), // 患者端 IM SDKAppID
|
SDKAppID: Number(env.MP_TIM_SDK_APP_ID), // 患者端 IM SDKAppID
|
||||||
|
}
|
||||||
|
|
||||||
|
// 验证配置
|
||||||
|
if (!TIM_CONFIG.SDKAppID || isNaN(TIM_CONFIG.SDKAppID)) {
|
||||||
|
console.error('❌ TIM SDK配置错误: MP_TIM_SDK_APP_ID未定义或无效', {
|
||||||
|
envValue: env.MP_TIM_SDK_APP_ID,
|
||||||
|
parsedValue: TIM_CONFIG.SDKAppID
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// IM连接配置常量
|
// IM连接配置常量
|
||||||
@ -79,17 +87,17 @@ class TimChatManager {
|
|||||||
onConversationListUpdated: null
|
onConversationListUpdated: null
|
||||||
}
|
}
|
||||||
|
|
||||||
// 绑定事件处理函数
|
// 绑定事件处理函数
|
||||||
this.boundEventHandlers = {
|
this.boundEventHandlers = {
|
||||||
onSDKReady: this.onSDKReady.bind(this),
|
onSDKReady: this.onSDKReady.bind(this),
|
||||||
onSDKNotReady: this.onSDKNotReady.bind(this),
|
onSDKNotReady: this.onSDKNotReady.bind(this),
|
||||||
onMessageReceived: this.onMessageReceived.bind(this),
|
onMessageReceived: this.onMessageReceived.bind(this),
|
||||||
onMessageSentSucceeded: this.onMessageSentSucceeded.bind(this),
|
onMessageSentSucceeded: this.onMessageSentSucceeded.bind(this),
|
||||||
onMessageSentFailed: this.onMessageSentFailed.bind(this),
|
onMessageSentFailed: this.onMessageSentFailed.bind(this),
|
||||||
onConversationListUpdated: this.onConversationListUpdated.bind(this),
|
onConversationListUpdated: this.onConversationListUpdated.bind(this),
|
||||||
onNetStateChange: this.onNetStateChange.bind(this),
|
onNetStateChange: this.onNetStateChange.bind(this),
|
||||||
onKickedOut: this.onKickedOut.bind(this)
|
onKickedOut: this.onKickedOut.bind(this)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ============== 资源管理方法 ==============
|
// ============== 资源管理方法 ==============
|
||||||
@ -155,8 +163,12 @@ class TimChatManager {
|
|||||||
if (!TIM) {
|
if (!TIM) {
|
||||||
throw new Error('TIM SDK 未正确导入')
|
throw new Error('TIM SDK 未正确导入')
|
||||||
}
|
}
|
||||||
|
// 验证 SDKAppID
|
||||||
|
if (!TIM_CONFIG.SDKAppID || isNaN(TIM_CONFIG.SDKAppID)) {
|
||||||
|
throw new Error(`TIM SDK配置错误: SDKAppID无效 (${TIM_CONFIG.SDKAppID})，请检查环境变量 MP_TIM_SDK_APP_ID`)
|
||||||
|
}
|
||||||
|
|
||||||
|
console.log('创建TIM实例，SDKAppID:', TIM_CONFIG.SDKAppID)
|
||||||
this.tim = TIM.create({ SDKAppID: TIM_CONFIG.SDKAppID })
|
this.tim = TIM.create({ SDKAppID: TIM_CONFIG.SDKAppID })
|
||||||
|
|
||||||
// 等待TIM实例初始化完成
|
// 等待TIM实例初始化完成
|
||||||
@ -268,7 +280,7 @@ class TimChatManager {
|
|||||||
// 超时不算致命错误，尝试继续
|
// 超时不算致命错误，尝试继续
|
||||||
resolve()
|
resolve()
|
||||||
} else {
|
} else {
|
||||||
console.log(`等待SDK Ready... ${Math.floor(elapsed/1000)}/${Math.floor(timeout/1000)}秒`)
|
console.log(`等待SDK Ready... ${Math.floor(elapsed / 1000)}/${Math.floor(timeout / 1000)}秒`)
|
||||||
setTimeout(checkSDKReady, checkInterval)
|
setTimeout(checkSDKReady, checkInterval)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -290,17 +302,17 @@ class TimChatManager {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// 逐个注册事件监听器，如果某个注册失败则继续注册其他的
|
// 逐个注册事件监听器，如果某个注册失败则继续注册其他的
|
||||||
const events = [
|
const events = [
|
||||||
{ event: TIM.EVENT.SDK_READY, handler: this.boundEventHandlers.onSDKReady },
|
{ event: TIM.EVENT.SDK_READY, handler: this.boundEventHandlers.onSDKReady },
|
||||||
{ event: TIM.EVENT.SDK_NOT_READY, handler: this.boundEventHandlers.onSDKNotReady },
|
{ event: TIM.EVENT.SDK_NOT_READY, handler: this.boundEventHandlers.onSDKNotReady },
|
||||||
{ event: TIM.EVENT.MESSAGE_RECEIVED, handler: this.boundEventHandlers.onMessageReceived },
|
{ event: TIM.EVENT.MESSAGE_RECEIVED, handler: this.boundEventHandlers.onMessageReceived },
|
||||||
{ event: TIM.EVENT.MESSAGE_SENT_SUCCEEDED, handler: this.boundEventHandlers.onMessageSentSucceeded },
|
{ event: TIM.EVENT.MESSAGE_SENT_SUCCEEDED, handler: this.boundEventHandlers.onMessageSentSucceeded },
|
||||||
{ event: TIM.EVENT.MESSAGE_SENT_FAILED, handler: this.boundEventHandlers.onMessageSentFailed },
|
{ event: TIM.EVENT.MESSAGE_SENT_FAILED, handler: this.boundEventHandlers.onMessageSentFailed },
|
||||||
{ event: TIM.EVENT.CONVERSATION_LIST_UPDATED, handler: this.boundEventHandlers.onConversationListUpdated },
|
{ event: TIM.EVENT.CONVERSATION_LIST_UPDATED, handler: this.boundEventHandlers.onConversationListUpdated },
|
||||||
{ event: TIM.EVENT.NET_STATE_CHANGE, handler: this.boundEventHandlers.onNetStateChange },
|
{ event: TIM.EVENT.NET_STATE_CHANGE, handler: this.boundEventHandlers.onNetStateChange },
|
||||||
{ event: TIM.EVENT.KICKED_OUT, handler: this.boundEventHandlers.onKickedOut }
|
{ event: TIM.EVENT.KICKED_OUT, handler: this.boundEventHandlers.onKickedOut }
|
||||||
]
|
]
|
||||||
|
|
||||||
events.forEach(({ event, handler }) => {
|
events.forEach(({ event, handler }) => {
|
||||||
if (event && handler && typeof this.tim.on === 'function') {
|
if (event && handler && typeof this.tim.on === 'function') {
|
||||||
@ -377,9 +389,9 @@ class TimChatManager {
|
|||||||
// 获取 userSig
|
// 获取 userSig
|
||||||
async getUserSig(userID) {
|
async getUserSig(userID) {
|
||||||
try {
|
try {
|
||||||
const response = await getUserSig(userID)
|
const response = await api('getUserSig', { userId: userID })
|
||||||
if (response?.success && response?.data?.userSig) {
|
if (response?.success && response?.data) {
|
||||||
return response.data.userSig
|
return response.data
|
||||||
}
|
}
|
||||||
throw new Error('获取 userSig 失败: 接口返回数据格式错误')
|
throw new Error('获取 userSig 失败: 接口返回数据格式错误')
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@ -503,7 +515,7 @@ class TimChatManager {
|
|||||||
// 首次检查延迟
|
// 首次检查延迟
|
||||||
const firstDelay = IM_CONNECTION_CONFIG.LOGIN_CHECK_FIRST_DELAY
|
const firstDelay = IM_CONNECTION_CONFIG.LOGIN_CHECK_FIRST_DELAY
|
||||||
this.loginCheckInterval = setTimeout(checkStatus, firstDelay)
|
this.loginCheckInterval = setTimeout(checkStatus, firstDelay)
|
||||||
console.log(`🔍 登录状态检测已启动，首次检查将在${firstDelay/1000}秒后进行`)
|
console.log(`🔍 登录状态检测已启动，首次检查将在${firstDelay / 1000}秒后进行`)
|
||||||
}
|
}
|
||||||
|
|
||||||
// 停止登录状态检测
|
// 停止登录状态检测
|
||||||
@ -723,20 +735,20 @@ class TimChatManager {
|
|||||||
|
|
||||||
// 缓存功能已移除
|
// 缓存功能已移除
|
||||||
|
|
||||||
// 判断是否为当前会话的消息（必须有currentConversationID且匹配才显示）
|
// 判断是否为当前会话的消息（必须有currentConversationID且匹配才显示）
|
||||||
const isCurrentConversation = this.currentConversationID &&
|
const isCurrentConversation = this.currentConversationID &&
|
||||||
messageConversationID === this.currentConversationID
|
messageConversationID === this.currentConversationID
|
||||||
|
|
||||||
console.log('消息会话匹配检查:', {
|
console.log('消息会话匹配检查:', {
|
||||||
isCurrentConversation,
|
isCurrentConversation,
|
||||||
hasCurrentConversationID: !!this.currentConversationID,
|
hasCurrentConversationID: !!this.currentConversationID,
|
||||||
conversationIDMatch: messageConversationID === this.currentConversationID
|
conversationIDMatch: messageConversationID === this.currentConversationID
|
||||||
})
|
})
|
||||||
|
|
||||||
if (isCurrentConversation) {
|
if (isCurrentConversation) {
|
||||||
// 当前会话的消息，触发回调
|
// 当前会话的消息，触发回调
|
||||||
console.log('✓ 消息属于当前会话，触发显示')
|
console.log('✓ 消息属于当前会话，触发显示')
|
||||||
this.triggerCallback('onMessageReceived', convertedMessage)
|
this.triggerCallback('onMessageReceived', convertedMessage)
|
||||||
|
|
||||||
// 处理已读状态
|
// 处理已读状态
|
||||||
if (this.currentConversationID) {
|
if (this.currentConversationID) {
|
||||||
@ -899,7 +911,7 @@ class TimChatManager {
|
|||||||
uni.removeStorageSync('account')
|
uni.removeStorageSync('account')
|
||||||
uni.removeStorageSync('openid')
|
uni.removeStorageSync('openid')
|
||||||
uni.reLaunch({
|
uni.reLaunch({
|
||||||
url: '/pages/login/login'
|
url: '/pages-center/login/login'
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
@ -964,7 +976,7 @@ class TimChatManager {
|
|||||||
})
|
})
|
||||||
}, INTERVAL)
|
}, INTERVAL)
|
||||||
|
|
||||||
console.log(`💓 心跳检测已启动（间隔${INTERVAL/1000}秒，最多失败${MAX_HEARTBEAT_FAIL}次）`)
|
console.log(`💓 心跳检测已启动（间隔${INTERVAL / 1000}秒，最多失败${MAX_HEARTBEAT_FAIL}次）`)
|
||||||
}
|
}
|
||||||
|
|
||||||
// 停止心跳检测
|
// 停止心跳检测
|
||||||
@ -1017,15 +1029,24 @@ class TimChatManager {
|
|||||||
|
|
||||||
if (!this.isLoggedIn) {
|
if (!this.isLoggedIn) {
|
||||||
console.log('SDK未ready，等待SDK初始化...')
|
console.log('SDK未ready，等待SDK初始化...')
|
||||||
|
let waitTime = 0
|
||||||
|
const maxWaitTime = 30000 // 最多等待30秒
|
||||||
|
const checkInterval = 1000 // 每秒检查一次
|
||||||
|
|
||||||
const checkSDKReady = () => {
|
const checkSDKReady = () => {
|
||||||
if (this.isLoggedIn) {
|
if (this.isLoggedIn) {
|
||||||
console.log('SDK已ready，开始获取群聊列表')
|
console.log('SDK已ready，开始获取群聊列表')
|
||||||
this.getGroupListInternal().then(resolve).catch(reject)
|
this.getGroupListInternal().then(resolve).catch(reject)
|
||||||
|
} else if (waitTime >= maxWaitTime) {
|
||||||
|
console.error('等待SDK就绪超时')
|
||||||
|
reject(new Error('SDK初始化超时，请检查网络连接'))
|
||||||
} else {
|
} else {
|
||||||
console.log('SDK仍未ready，继续等待...')
|
waitTime += checkInterval
|
||||||
setTimeout(checkSDKReady, 1000)
|
console.log(`等待SDK就绪... (${Math.floor(waitTime / 1000)}/${Math.floor(maxWaitTime / 1000)}秒)`)
|
||||||
|
setTimeout(checkSDKReady, checkInterval)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
checkSDKReady()
|
checkSDKReady()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -1039,7 +1060,15 @@ class TimChatManager {
|
|||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
console.log('开始获取群聊列表')
|
console.log('开始获取群聊列表')
|
||||||
|
|
||||||
this.tim.getConversationList().then(async (conversationResponse) => {
|
// 确保SDK已就绪再调用getConversationList
|
||||||
|
const ensureSDKReady = () => {
|
||||||
|
if (!this.isLoggedIn) {
|
||||||
|
console.log('SDK未就绪，等待中...')
|
||||||
|
setTimeout(ensureSDKReady, 500)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
this.tim.getConversationList().then(async (conversationResponse) => {
|
||||||
console.clear()
|
console.clear()
|
||||||
console.log('获取会话列表成功:', conversationResponse)
|
console.log('获取会话列表成功:', conversationResponse)
|
||||||
const groupConversations = conversationResponse.data.conversationList.filter(conversation => {
|
const groupConversations = conversationResponse.data.conversationList.filter(conversation => {
|
||||||
@ -1121,7 +1150,7 @@ class TimChatManager {
|
|||||||
name: conversation.groupProfile.name,
|
name: conversation.groupProfile.name,
|
||||||
doctorId,
|
doctorId,
|
||||||
patientName,
|
patientName,
|
||||||
avatar: '/static/home/doctor.png',
|
avatar: '/static/home/avatar.svg',
|
||||||
lastMessage: '获取失败',
|
lastMessage: '获取失败',
|
||||||
lastMessageTime: Date.now(),
|
lastMessageTime: Date.now(),
|
||||||
unreadCount: conversation.unreadCount || 0,
|
unreadCount: conversation.unreadCount || 0,
|
||||||
@ -1145,6 +1174,10 @@ class TimChatManager {
|
|||||||
error: imError
|
error: imError
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 开始检查SDK就绪状态
|
||||||
|
ensureSDKReady()
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1264,7 +1297,7 @@ class TimChatManager {
|
|||||||
console.log('创建问诊群聊成功:', imResponse)
|
console.log('创建问诊群聊成功:', imResponse)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await sendSystemMessage(groupID, 'pending')
|
await api('sendSystemMessage', { groupID, status: 'pending' })
|
||||||
console.log('pending系统消息发送成功')
|
console.log('pending系统消息发送成功')
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error('pending系统消息发送失败:', error)
|
console.error('pending系统消息发送失败:', error)
|
||||||
@ -1426,9 +1459,7 @@ class TimChatManager {
|
|||||||
console.log(" groupID:", groupID, "count:", count, "skip:", skip, "isPullUp:", isPullUp)
|
console.log(" groupID:", groupID, "count:", count, "skip:", skip, "isPullUp:", isPullUp)
|
||||||
|
|
||||||
// 调用本地接口获取聊天记录
|
// 调用本地接口获取聊天记录
|
||||||
const response = await getChatRecordsByGroupId(groupID, count, skip)
|
const response = await api('getChatRecordsByGroupId', { groupID, count, skip })
|
||||||
|
|
||||||
console.log(" 📥 收到本地API响应:", response)
|
|
||||||
|
|
||||||
if (response && response.success && response.data && response.data.records) {
|
if (response && response.success && response.data && response.data.records) {
|
||||||
const dbMessages = response.data.records
|
const dbMessages = response.data.records
|
||||||
@ -2591,14 +2622,14 @@ const getGroupList = async () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 进入群聊
|
// 进入群聊
|
||||||
const enterChatGroupRoom = async (chatGroup, navigateType = 'navigateTo' , viewType) => {
|
const enterChatGroupRoom = async (chatGroup, navigateType = 'navigateTo', viewType) => {
|
||||||
const groupListResult = await globalTimChatManager.getGroupList();
|
const groupListResult = await globalTimChatManager.getGroupList();
|
||||||
const groupList = groupListResult && Array.isArray(groupListResult.groupList) ? groupListResult.groupList : [];
|
const groupList = groupListResult && Array.isArray(groupListResult.groupList) ? groupListResult.groupList : [];
|
||||||
let group = groupList.find(g => g.groupID === chatGroup.groupID);
|
let group = groupList.find(g => g.groupID === chatGroup.groupID);
|
||||||
|
|
||||||
const navigateFn = ['navigateTo', 'redirectTo', 'reLaunch'].includes(navigateType) ? navigateType : 'navigateTo'
|
const navigateFn = ['navigateTo', 'redirectTo', 'reLaunch'].includes(navigateType) ? navigateType : 'navigateTo'
|
||||||
uni[navigateFn]({
|
uni[navigateFn]({
|
||||||
url: `/pages/message/index?conversationID=GROUP${chatGroup.groupID}&groupID=${chatGroup.groupID}&conversationType=GROUP&viewType=${viewType}`,
|
url: `/pages-im/IM/index?conversationID=GROUP${chatGroup.groupID}&groupID=${chatGroup.groupID}&conversationType=GROUP&viewType=${viewType}`,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user