fix: 消息页面ui重构

This commit is contained in:
Tim
2025-08-22 12:21:10 +08:00
parent d34ed3c058
commit 4af10ecf79
5 changed files with 588 additions and 624 deletions
+480
View File
@@ -0,0 +1,480 @@
<template>
<div class="chat-container">
<div v-if="!loading && otherParticipant" class="chat-header">
<NuxtLink to="/message-box" class="back-button">
<i class="fas fa-arrow-left"></i>
</NuxtLink>
<h2 class="participant-name">{{ otherParticipant.username }}</h2>
</div>
<div class="messages-list" ref="messagesListEl">
<div v-if="loading" class="loading-container">加载中...</div>
<div v-else-if="error" class="error-container">{{ error }}</div>
<template v-else>
<div class="load-more-container" v-if="hasMoreMessages">
<button @click="loadMoreMessages" :disabled="loadingMore" class="load-more-button">
{{ loadingMore ? '加载中...' : '查看更多消息' }}
</button>
</div>
<BaseTimeline :items="messages">
<template #item="{ item }">
<div class="message-timestamp">
{{ TimeManager.format(item.createdAt) }}
</div>
<div class="message-content">
<div class="message-text" v-html="renderMarkdown(item.content)"></div>
</div>
</template>
</BaseTimeline>
</template>
</div>
<div class="message-input-area">
<MessageEditor :loading="sending" @submit="sendMessage" />
</div>
</div>
</template>
<script setup>
import {
ref,
onMounted,
onUnmounted,
nextTick,
computed,
watch,
onActivated,
onDeactivated,
} from 'vue'
import { useRoute } from 'vue-router'
import { getToken, fetchCurrentUser } from '~/utils/auth'
import { toast } from '~/main'
import { renderMarkdown } from '~/utils/markdown'
import MessageEditor from '~/components/MessageEditor.vue'
import { useWebSocket } from '~/composables/useWebSocket'
import { useUnreadCount } from '~/composables/useUnreadCount'
import TimeManager from '~/utils/time'
import BaseTimeline from '~/components/BaseTimeline.vue'
const config = useRuntimeConfig()
const route = useRoute()
const API_BASE_URL = config.public.apiBaseUrl
const { connect, disconnect, subscribe, isConnected } = useWebSocket()
const { fetchUnreadCount: refreshGlobalUnreadCount } = useUnreadCount()
let subscription = null
const messages = ref([])
const participants = ref([])
const loading = ref(true)
const sending = ref(false)
const error = ref(null)
const conversationId = route.params.id
const currentUser = ref(null)
const messagesListEl = ref(null)
let lastMessageEl = null
const currentPage = ref(0)
const totalPages = ref(0)
const loadingMore = ref(false)
let scrollInterval = null
const hasMoreMessages = computed(() => currentPage.value < totalPages.value - 1)
const otherParticipant = computed(() => {
if (!currentUser.value || participants.value.length === 0) {
return null
}
return participants.value.find((p) => p.id !== currentUser.value.id)
})
function isSentByCurrentUser(message) {
return message.sender.id === currentUser.value?.id
}
function handleAvatarError(event) {
event.target.src = '/default-avatar.svg'
}
// No changes needed here, as renderMarkdown is now imported.
// The old function is removed.
async function fetchMessages(page = 0) {
if (page === 0) {
loading.value = true
messages.value = []
} else {
loadingMore.value = true
}
error.value = null
const token = getToken()
if (!token) {
toast.error('请先登录')
loading.value = false
return
}
try {
const response = await fetch(
`${API_BASE_URL}/api/messages/conversations/${conversationId}?page=${page}&size=20`,
{
headers: { Authorization: `Bearer ${token}` },
},
)
if (!response.ok) throw new Error('无法加载消息')
const conversationData = await response.json()
const pageData = conversationData.messages
if (page === 0) {
participants.value = conversationData.participants
}
// Since the backend sorts by descending, we need to reverse for correct chat order
const newMessages = pageData.content.reverse().map((item) => ({
...item,
src: item.sender.avatar,
iconClick: () => {
navigateTo(`/users/${item.sender.id}`, { replace: true })
},
}))
const list = messagesListEl.value
const oldScrollHeight = list ? list.scrollHeight : 0
if (page === 0) {
messages.value = newMessages
} else {
messages.value = [...newMessages, ...messages.value]
}
currentPage.value = pageData.number
totalPages.value = pageData.totalPages
// Scrolling is now fully handled by the watcher
await nextTick()
if (page > 0 && list) {
const newScrollHeight = list.scrollHeight
list.scrollTop = newScrollHeight - oldScrollHeight
}
} catch (e) {
error.value = e.message
toast.error(e.message)
} finally {
loading.value = false
loadingMore.value = false
}
}
async function loadMoreMessages() {
if (hasMoreMessages.value && !loadingMore.value) {
await fetchMessages(currentPage.value + 1)
}
}
async function sendMessage(content, clearInput) {
if (!content.trim()) return
const recipient = otherParticipant.value
if (!recipient) {
toast.error('无法确定收信人')
return
}
sending.value = true
const token = getToken()
try {
const response = await fetch(`${API_BASE_URL}/api/messages`, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
Authorization: `Bearer ${token}`,
},
body: JSON.stringify({
recipientId: recipient.id,
content: content,
}),
})
if (!response.ok) throw new Error('发送失败')
const newMessage = await response.json()
messages.value.push(newMessage)
clearInput()
// Use a more reliable scroll approach
setTimeout(() => {
scrollToBottom()
}, 100)
} catch (e) {
toast.error(e.message)
} finally {
sending.value = false
}
}
async function markConversationAsRead() {
const token = getToken()
if (!token) return
try {
await fetch(`${API_BASE_URL}/api/messages/conversations/${conversationId}/read`, {
method: 'POST',
headers: { Authorization: `Bearer ${token}` },
})
// After marking as read, refresh the global unread count
refreshGlobalUnreadCount()
} catch (e) {
console.error('Failed to mark conversation as read', e)
}
}
function scrollToBottom() {
if (messagesListEl.value) {
const element = messagesListEl.value
// 強制滾動到底部,使用 smooth 行為確保視覺效果
element.scrollTop = element.scrollHeight
// 再次確認滾動位置
setTimeout(() => {
if (element.scrollTop < element.scrollHeight - element.clientHeight) {
element.scrollTop = element.scrollHeight
}
}, 50)
}
}
watch(
messages,
async (newMessages) => {
if (newMessages.length === 0) return
await nextTick()
// Simple, reliable scroll to bottom
setTimeout(() => {
scrollToBottom()
}, 100)
},
{ deep: true },
)
onMounted(async () => {
currentUser.value = await fetchCurrentUser()
if (currentUser.value) {
await fetchMessages(0)
await markConversationAsRead()
const token = getToken()
if (token && !isConnected.value) {
connect(token)
}
} else {
toast.error('请先登录')
loading.value = false
}
})
watch(isConnected, (newValue) => {
if (newValue) {
// 等待一小段时间确保连接稳定
setTimeout(() => {
subscription = subscribe(`/topic/conversation/${conversationId}`, (message) => {
// 避免重复显示当前用户发送的消息
if (message.sender.id !== currentUser.value.id) {
messages.value.push(message)
// 实时收到消息时自动标记为已读
markConversationAsRead()
setTimeout(() => {
scrollToBottom()
}, 100)
}
})
}, 500)
}
})
onActivated(async () => {
// This will be called every time the component is activated (navigated to)
if (currentUser.value) {
await fetchMessages(0)
await markConversationAsRead()
// 確保滾動到底部 - 使用多重延遲策略
await nextTick()
setTimeout(() => {
scrollToBottom()
}, 100)
setTimeout(() => {
scrollToBottom()
}, 300)
setTimeout(() => {
scrollToBottom()
}, 500)
if (!isConnected.value) {
const token = getToken()
if (token) connect(token)
}
}
})
onDeactivated(() => {
if (subscription) {
subscription.unsubscribe()
subscription = null
}
disconnect()
})
onUnmounted(() => {
if (subscription) {
subscription.unsubscribe()
subscription = null
}
disconnect()
})
</script>
<style scoped>
.chat-container {
display: flex;
flex-direction: column;
height: calc(100vh - 80px); /* Adjust based on your header/footer height */
margin: 0 auto;
border: 1px solid var(--border-color);
border-radius: 8px;
overflow: hidden;
background-color: var(--bg-color);
position: relative;
}
.chat-header {
display: flex;
align-items: center;
padding: 10px 20px;
border-bottom: 1px solid var(--border-color);
background-color: var(--bg-color-soft);
}
.back-button {
font-size: 18px;
color: var(--text-color-primary);
margin-right: 15px;
cursor: pointer;
}
.participant-name {
font-size: 18px;
font-weight: 600;
margin: 0;
}
.messages-list {
position: absolute;
top: 60px; /* Header height */
bottom: 250px; /* Increased space for input area */
left: 0;
right: 0;
overflow-y: auto;
padding: 20px;
padding-bottom: 40px; /* Extra padding at bottom */
display: flex;
flex-direction: column;
gap: 20px;
}
.load-more-container {
text-align: center;
margin-bottom: 20px;
}
.load-more-button {
background-color: var(--bg-color-soft);
border: 1px solid var(--border-color);
color: var(--text-color-primary);
padding: 8px 16px;
border-radius: 20px;
cursor: pointer;
transition: background-color 0.2s;
}
.load-more-button:hover {
background-color: var(--border-color);
}
.message-item {
display: flex;
gap: 10px;
}
.message-avatar {
width: 40px;
height: 40px;
border-radius: 50%;
align-self: flex-end;
}
.message-content {
display: flex;
flex-direction: column;
}
.message-text {
font-size: 15px;
line-height: 1.5;
word-wrap: break-word;
}
.message-text :deep(p) {
margin: 0;
}
.message-timestamp {
font-size: 11px;
color: var(--text-color-secondary);
margin-top: 5px;
opacity: 0.6;
}
/* Sent messages */
.message-item.sent {
align-self: flex-end;
flex-direction: row-reverse;
}
.message-item.sent .message-timestamp {
text-align: right;
}
/* Received messages */
.message-item.received {
align-self: flex-start;
}
.message-item.received .message-content {
align-items: flex-start;
}
.message-item.received .message-bubble {
background-color: var(--bg-color-soft);
border: 1px solid var(--border-color);
border-bottom-left-radius: 4px;
}
.message-input-area {
position: absolute;
bottom: 0;
left: 0;
right: 0;
min-height: 200px;
max-height: 400px;
padding: 10px 20px;
border-top: 1px solid var(--border-color);
background-color: var(--bg-color);
box-sizing: border-box;
overflow: visible;
}
.loading-container,
.error-container {
text-align: center;
padding: 50px;
color: var(--text-color-secondary);
}
</style>
+351
View File
@@ -0,0 +1,351 @@
<template>
<div class="messages-container">
<div v-if="loading" class="loading-message">
<l-hatch size="28" stroke="4" speed="3.5" color="var(--primary-color)"></l-hatch>
</div>
<div v-else-if="error" class="error-container">
<div class="error-text">{{ error }}</div>
</div>
<div v-else-if="conversations.length === 0" class="empty-container">
<div class="empty-text">暂无会话</div>
</div>
<div v-else class="conversations-list">
<div
v-for="convo in conversations"
:key="convo.id"
class="conversation-item"
@click="goToConversation(convo.id)"
>
<div class="conversation-avatar">
<img
:src="getOtherParticipant(convo)?.avatar || '/default-avatar.svg'"
:alt="getOtherParticipant(convo)?.username || '用户'"
class="avatar-img"
@error="handleAvatarError"
/>
</div>
<div class="conversation-content">
<div class="conversation-header">
<div class="participant-name">
{{ getOtherParticipant(convo)?.username || '未知用户' }}
</div>
<div class="message-time">
{{ formatTime(convo.lastMessage?.createdAt || convo.createdAt) }}
</div>
</div>
<div class="last-message-row">
<div class="last-message">
{{
convo.lastMessage ? stripMarkdownLength(convo.lastMessage.content, 100) : '暂无消息'
}}
</div>
<div v-if="convo.unreadCount > 0" class="unread-count-badge">
{{ convo.unreadCount }}
</div>
</div>
</div>
</div>
</div>
</div>
</template>
<script setup>
import { ref, onMounted, onUnmounted, watch, onActivated } from 'vue'
import { useRouter } from 'vue-router'
import { getToken, fetchCurrentUser } from '~/utils/auth'
import { toast } from '~/main'
import { useWebSocket } from '~/composables/useWebSocket'
import { useUnreadCount } from '~/composables/useUnreadCount'
import TimeManager from '~/utils/time'
import { stripMarkdownLength } from '~/utils/markdown'
const config = useRuntimeConfig()
const conversations = ref([])
const loading = ref(true)
const error = ref(null)
const router = useRouter()
const currentUser = ref(null)
const API_BASE_URL = config.public.apiBaseUrl
const { connect, disconnect, subscribe, isConnected } = useWebSocket()
const { fetchUnreadCount: refreshGlobalUnreadCount } = useUnreadCount()
let subscription = null
async function fetchConversations() {
const token = getToken()
if (!token) {
toast.error('请先登录')
return
}
try {
const response = await fetch(`${API_BASE_URL}/api/messages/conversations`, {
method: 'GET',
headers: { Authorization: `Bearer ${token}` },
})
if (!response.ok) {
throw new Error(`HTTP error! status: ${response.status}`)
}
const data = await response.json()
conversations.value = data
} catch (e) {
error.value = '无法加载会话列表。'
} finally {
loading.value = false
}
}
// 获取对话中的另一个参与者(非当前用户)
function getOtherParticipant(conversation) {
if (!currentUser.value || !conversation.participants) return null
return conversation.participants.find((p) => p.id !== currentUser.value.id)
}
// 格式化时间
function formatTime(timeString) {
if (!timeString) return ''
return TimeManager.format(timeString)
}
// 头像加载失败处理
function handleAvatarError(event) {
event.target.src = '/default-avatar.svg'
}
onActivated(async () => {
loading.value = true
currentUser.value = await fetchCurrentUser()
if (currentUser.value) {
await fetchConversations()
refreshGlobalUnreadCount() // Refresh global count when entering the list
const token = getToken()
if (token && !isConnected.value) {
connect(token)
}
} else {
loading.value = false
}
})
watch(isConnected, (newValue) => {
if (newValue && currentUser.value) {
const destination = `/topic/user/${currentUser.value.id}/messages`
// 清理旧的订阅
if (subscription) {
subscription.unsubscribe()
}
subscription = subscribe(destination, (message) => {
fetchConversations()
})
}
})
onUnmounted(() => {
if (subscription) {
subscription.unsubscribe()
}
disconnect()
})
function goToConversation(id) {
router.push(`/message-box/${id}`)
}
</script>
<style scoped>
.messages-container {
margin: 0 auto;
padding: 20px;
}
.loading-message {
display: flex;
justify-content: center;
align-items: center;
height: 300px;
}
.messages-header {
margin-bottom: 24px;
}
.messages-title {
font-size: 28px;
font-weight: 600;
color: #1a1a1a;
margin: 0;
}
.loading-container,
.error-container,
.empty-container {
display: flex;
justify-content: center;
align-items: center;
min-height: 200px;
}
.loading-text,
.error-text,
.empty-text {
font-size: 16px;
color: #666;
}
.error-text {
color: #e53e3e;
}
.conversations-list {
}
.conversation-item {
display: flex;
align-items: center;
padding: 8px 10px;
cursor: pointer;
transition: background-color 0.2s ease;
}
.conversation-item:hover {
background-color: var(--menu-selected-background-color);
}
.conversation-avatar {
flex-shrink: 0;
margin-right: 12px;
}
.avatar-img {
width: 40px;
height: 40px;
border-radius: 50%;
object-fit: cover;
}
.conversation-content {
flex: 1;
min-width: 0;
}
.conversation-header {
display: flex;
justify-content: space-between;
align-items: center;
margin-bottom: 6px;
}
.participant-name {
font-size: 16px;
font-weight: 600;
color: #2d3748;
truncate: true;
}
.message-time {
font-size: 12px;
color: #a0aec0;
flex-shrink: 0;
margin-left: 12px;
}
.last-message-row {
display: flex;
justify-content: space-between;
align-items: center;
}
.last-message {
font-size: 14px;
color: #4a5568;
line-height: 1.4;
overflow: hidden;
text-overflow: ellipsis;
white-space: nowrap;
flex-grow: 1;
padding-right: 10px; /* Add some space between message and badge */
}
.unread-count-badge {
background-color: #f56c6c;
color: white;
font-size: 12px;
font-weight: bold;
padding: 2px 8px;
border-radius: 12px;
line-height: 1.5;
flex-shrink: 0;
}
/* 响应式设计 */
@media (max-width: 768px) {
.messages-container {
padding: 16px 12px;
}
.messages-title {
font-size: 24px;
}
.conversations-list {
max-height: 500px;
}
.conversation-item {
padding: 12px 16px;
}
.avatar-img {
width: 40px;
height: 40px;
}
.participant-name {
font-size: 15px;
}
.message-time {
font-size: 11px;
}
.last-message {
font-size: 13px;
}
}
@media (max-width: 480px) {
.messages-container {
padding: 12px 8px;
}
.conversations-list {
max-height: 400px;
}
.conversation-item {
padding: 10px 12px;
}
.avatar-img {
width: 36px;
height: 36px;
}
.conversation-avatar {
margin-right: 12px;
}
}
/* 大屏幕设备 */
@media (min-width: 1024px) {
.conversations-list {
max-height: 700px;
}
}
</style>