consumer模块完成度95%，安卓端大部分页面能正常获取数据，页面样式显示基本正常，逐渐完善；消费者端的积分、余额、评价、优惠券等小模块正在完善

pages/mall/consumer/chat.uvue

@@ -165,6 +165,8 @@ function getCurrentTime(): string {
 
 function setupRealtimeSubscription(): void {
 	console.log('开始建立聊天实时订阅...')
+	console.log('当前用户ID:', currentUserId.value, '商家ID:', merchantId.value)
+	
 	const filter = ({
 		event: 'INSERT',
 		schema: 'public',
@@ -173,41 +175,80 @@ function setupRealtimeSubscription(): void {
 
 	realtimeChannel = supa.channel('public:ml_chat_messages')
 		.on('postgres_changes', filter, (payload: any) => {
+			console.log('=== 收到实时订阅回调 ===')
 			const payloadObj = (payload instanceof UTSJSONObject) ? (payload as UTSJSONObject) : (JSON.parse(JSON.stringify(payload ?? {})) as UTSJSONObject)
 			const newMsgAny = payloadObj.get('new')
-			if (newMsgAny == null) return
+			if (newMsgAny == null) {
+				console.log('newMsgAny 为空，跳过')
+				return
+			}
 			const newMsg = (newMsgAny instanceof UTSJSONObject) ? (newMsgAny as UTSJSONObject) : (JSON.parse(JSON.stringify(newMsgAny)) as UTSJSONObject)
 			console.log('收到新消息:', newMsg)
 
 			const senderId = newMsg.getString('sender_id') ?? ''
 			const receiverId = newMsg.getString('receiver_id') ?? ''
+			const msgId = newMsg.getString('id') ?? ''
+			const content = newMsg.getString('content') ?? ''
+			
+			console.log('=== 消息详情 ===')
+			console.log('消息ID:', msgId)
+			console.log('发送者ID:', senderId)
+			console.log('接收者ID:', receiverId)
+			console.log('当前用户ID:', currentUserId.value)
+			console.log('商家ID:', merchantId.value)
+			console.log('消息内容:', content)
 
-			if (senderId === currentUserId.value) {
+			// 检查消息是否已经在列表中（避免重复）
+			for (let i = 0; i < messages.value.length; i++) {
+				if (messages.value[i].id == msgId) {
+					console.log('消息已存在，跳过')
+					return
+				}
+			}
+
+			// 判断消息类型
+			const isMyMessage = (senderId == currentUserId.value)
+			const isForMe = (receiverId == currentUserId.value)
+			const isRelatedToCurrentChat = (senderId == merchantId.value || receiverId == merchantId.value)
+			
+			console.log('=== 条件判断 ===')
+			console.log('isMyMessage:', isMyMessage)
+			console.log('isForMe:', isForMe)
+			console.log('isRelatedToCurrentChat:', isRelatedToCurrentChat)
+
+			// 如果消息与当前聊天无关，跳过
+			if (!isRelatedToCurrentChat) {
+				console.log('消息与当前聊天无关，跳过')
 				return
 			}
 
-			if (receiverId === currentUserId.value) {
-				if (merchantId.value != '' && senderId !== merchantId.value) {
-					return
-				}
-
+			// 如果是自己发送的消息，或者是发给自己的消息，都显示
+			if (isMyMessage || isForMe) {
 				const createdAt = newMsg.getString('created_at') ?? new Date().toISOString()
 				const date = new Date(createdAt)
 				const timeStr = `${date.getHours().toString().padStart(2, '0')}:${date.getMinutes().toString().padStart(2, '0')}`
 
 				const incomingMsg: UiChatMessage = {
-					id: newMsg.getString('id') ?? Date.now().toString(),
-					type: 'received',
-					content: newMsg.getString('content') ?? '',
+					id: msgId,
+					type: isMyMessage ? 'sent' : 'received',
+					content: content,
 					time: timeStr
 				}
 
+				console.log('=== 添加新消息到列表 ===')
+				console.log('消息类型:', incomingMsg.type)
+				console.log('消息内容:', incomingMsg.content)
 				messages.value.push(incomingMsg)
 				scrollToBottom()
+			} else {
+				console.log('条件不满足，不添加消息')
 			}
 		})
 		.subscribe((status: string, err: any | null) => {
 			console.log('订阅状态:', status)
+			if (err != null) {
+				console.log('订阅错误:', err)
+			}
 		})
 }
 
@@ -221,21 +262,27 @@ async function loadChatHistory(): Promise<void> {
 		return
 	}
 
-	messages.value = rawMsgs.reverse().map((m: ChatMessage): UiChatMessage => {
+	// 使用 for 循环替代 map
+	const uiMessages: UiChatMessage[] = []
+	for (let i = rawMsgs.length - 1; i >= 0; i--) {
+		const m = rawMsgs[i]
 		const date = new Date(m.created_at ?? new Date().toISOString())
 		const timeStr = `${date.getHours().toString().padStart(2, '0')}:${date.getMinutes().toString().padStart(2, '0')}`
 
 		const sender = m.sender_id ?? ''
 		const msgType = (currentUserId.value != '' && sender == currentUserId.value) ? 'sent' : 'received'
 		const rawId = (m.id ?? '').toString()
-		const msgId = rawId !== '' ? rawId : Date.now().toString()
-		return {
+		const msgId = rawId != '' ? rawId : Date.now().toString() + i.toString()
+		
+		const uiMsg: UiChatMessage = {
 			id: msgId,
 			type: msgType,
 			content: m.content ?? '',
 			time: timeStr
 		}
-	})
+		uiMessages.push(uiMsg)
+	}
+	messages.value = uiMessages
 
 	setTimeout(() => {
 		scrollToBottom()
@@ -288,22 +335,13 @@ const sendMessage = async () => {
     const content = inputMessage.value.trim()
     if (content == '') return
     
-    // 添加发送的消息 (乐观更新)
-    const newMessage: UiChatMessage = {
-        id: Date.now().toString(),
-        type: 'sent',
-        content: content,
-        time: getCurrentTime()
-    }
-    
-    messages.value.push(newMessage)
+    // 清空输入框
     inputMessage.value = ''
     
-    // 滚动到底部
-    scrollToBottom()
-
     // 发送到 Supabase
     if (merchantId.value != '') {
+        // 不使用乐观更新，等待实时订阅推送
+        // 这样可以确保多端同步
         const success = await supabaseService.sendMessage(merchantId.value, content)
         if (!success) {
             uni.showToast({