fix: 聊天（已实现图文消息对话）

store/chat/chat.js

@@ -1,11 +1,15 @@
+import {getMessagesByRoomIdApi} from "@/request/api/im";
+
 /**
  * 聊天消息管理器
- * @type {{currentRoomId: null, unreadCounts: {}, messageCache: {}, roomMessages: {}, enterRoom(*): void, leaveRoom(): void, getCurrentRoomId(): *, increaseUnreadCount(*): void, resetUnreadCount(*): void, getUnreadCount(*): *, getAllUnreadCount(): *, notifyUnreadChange(): void, cacheMessage(*, *): void, addMessageToRoom(*, *): void, getRoomMessages(*): *, handleIncomingMessage(*): void}}
+ * @type {{currentRoomId: null, lastMessageId: null, unreadCounts: {}, messageCache: {}, roomMessages: {}, enterRoom(*): void, leaveRoom(): void, getCurrentRoomId(): *, increaseUnreadCount(*): void, resetUnreadCount(*): void, getUnreadCount(*): *, getAllUnreadCount(): *, loadHistory(): *, getMessageType(): *, notifyUnreadChange(): void,, addMessageToRoom(*, *): void, getRoomMessages(*): *, handleIncomingMessage(*): void}}
  */
 const ChatManager = {
   // 当前房间ID
   currentRoomId: null,
 
+  lastMessageId: 0,
+
   // 存储未读消息数 { roomId: count }
   unreadCounts: {},
 
@@ -19,19 +23,9 @@ const ChatManager = {
   enterRoom(roomId) {
     this.currentRoomId = roomId;
     uni.setStorageSync('currentRoomId', roomId);
-    console.log(`进入房间: ${roomId}`);
-
+    console.log(`进入房间`);
     // 重置当前房间的未读消息
     this.resetUnreadCount(roomId);
-
-    // 如果有缓存消息，则触发事件，然后清除缓存
-    if (this.messageCache[roomId]) {
-      const cachedMessages = this.messageCache[roomId];
-      cachedMessages.forEach(message => {
-        this.addMessageToRoom(roomId, message);
-      });
-      delete this.messageCache[roomId];
-    }
   },
 
   // 离开聊天室
@@ -83,25 +77,152 @@ const ChatManager = {
     });
   },
 
-  // 缓存消息（当收到消息但不在该房间时）
-  cacheMessage(roomId, message) {
-    if (!this.messageCache[roomId]) {
-      this.messageCache[roomId] = [];
-    }
-    this.messageCache[roomId].push(message);
-  },
-
   // 添加消息到房间
   addMessageToRoom(roomId, message) {
     if (!this.roomMessages[roomId]) {
       this.roomMessages[roomId] = [];
     }
     this.roomMessages[roomId].push(message);
+    console.log('addMessageToRoom', this.roomMessages[roomId])
   },
 
   // 获取房间消息
   getRoomMessages(roomId) {
+    let that = this;
+    this.roomMessages[roomId] = [];
+    getMessagesByRoomIdApi({
+      room_id: roomId,
+      last_message_id: 0,
+    }).then((res) => {
+      that.roomMessages[roomId] = that.checkMessage(res.data.result.list);
+      that.lastMessageId = res.data.result.last_message_id;
+      console.log(that.roomMessages[roomId], 'roomMessages')
+
+      uni.$emit('load-room-message', 1);
+      return this.roomMessages[roomId] || [];
+    })
     return this.roomMessages[roomId] || [];
+
+  },
+
+  checkMessage(message, type = 0) {
+    if (type === 1) {
+      return {
+        id: message.id,
+        sender: message.sender_user_id,
+        type: this.getMessageType(message.message_type),
+        content: message.content,
+        duration: message.duration,
+        time: this.formatTime(message.send_time),
+        timestamp: message.send_time
+      };
+    }
+    return message.map(item => {
+      return {
+        id: item.id,
+        sender: item.sender_user_id,
+        type: this.getMessageType(item.message_type),
+        content: item?.message_content || item.content,
+        duration: item.duration,
+        time: item?.created_at_text || item.send_time,
+        timestamp: item?.created_at || item.send_time
+      };
+    });
+  },
+
+  // 根据消息类型ID获取类型名称
+  getMessageType(typeId) {
+    const types = {
+      0: 'text',
+      1: 'image',
+      2: 'audio',
+      3: 'video',
+      4: 'prescription',
+      5: 'file'
+    };
+    return types[typeId];
+  },
+
+  // 格式化时间
+  formatTime(timestamp) {
+    let date;
+
+    // 处理不同输入类型
+    if (typeof timestamp === 'number') {
+      // 数字直接作为时间戳处理
+      date = new Date(timestamp);
+    } else if (timestamp instanceof Date) {
+      // Date对象直接使用
+      date = timestamp;
+    } else if (typeof timestamp === 'string') {
+      // 字符串类型：尝试转换为时间戳
+      const parsed = Date.parse(timestamp);
+      if (isNaN(parsed)) {
+        // 转换失败则使用当前时间
+        date = new Date();
+      } else {
+        date = new Date(parsed);
+      }
+    } else {
+      // 其他类型使用当前时间
+      date = new Date();
+    }
+
+    const now = new Date();
+    const diff = now - date; // 时间差（毫秒）
+    const seconds = Math.floor(diff / 1000);
+
+    // 定义星期几的名称
+    const weekdays = ['日', '一', '二', '三', '四', '五', '六'];
+    const currentWeekday = date.getDay(); // 0=周日,1=周一,...,6=周六
+
+    // 格式化时间函数 (补零)
+    const formatTime = (num) => num.toString().padStart(2, '0');
+    const formattedTime = `${formatTime(date.getHours())}:${formatTime(date.getMinutes())}`;
+
+    if (seconds < 60) {
+      return '刚刚';
+    } else if (seconds < 3600) {
+      return Math.floor(seconds / 60) + '分钟前';
+    } else if (seconds < 7200) { // 1-2小时
+      return Math.floor(seconds / 3600) + '小时前';
+    } else if (seconds < 86400) { // 2-24小时
+      return formattedTime;
+    } else if (seconds < 172800) { // 1-2天（昨天）
+      return `昨天 ${formattedTime}`;
+    } else if (seconds < 259200) { // 2-3天（前天）
+      return `前天 ${formattedTime}`;
+    } else if (seconds < 604800) { // 3-7天内（本周X）
+      return `周${weekdays[currentWeekday]} ${formattedTime}`;
+    } else if (seconds < 1209600) { // 7-14天（上周X）
+      return `上周${weekdays[currentWeekday]} ${formattedTime}`;
+    } else if (seconds < 2592000) { // 14天-1个月
+      return Math.floor(seconds / 86400) + '天前';
+    } else if (seconds < 31536000) { // 1个月-1年
+      return Math.floor(seconds / 2592000) + '个月前';
+    } else { // 超过1年
+      return `${date.getFullYear()}-${formatTime(date.getMonth() + 1)}-${formatTime(date.getDate())}`;
+    }
+  },
+
+  loadHistory(roomId) {
+    let that = this;
+    getMessagesByRoomIdApi({
+      room_id: roomId,
+      last_message_id: that.lastMessageId,
+    }).then((res) => {
+
+      if (res.data.result.list?.length === 0) {
+        // 没有更多历史消息
+        uni.$emit('no-more-history');
+        return;
+      }
+      that.roomMessages[roomId] = [...that.checkMessage(res.data.result.list),  ...that.roomMessages[roomId]];
+      that.lastMessageId = res.data.result.last_message_id;
+
+      uni.$emit('load-room-message');
+      return res.data.result.list
+    })
   },
 
   // 处理收到的消息
@@ -110,15 +231,14 @@ const ChatManager = {
     const currentRoomId = this.getCurrentRoomId();
 
     // 添加消息到房间
-    this.addMessageToRoom(roomId, message);
+    this.addMessageToRoom(roomId, this.checkMessage(message, 1));
 
     // 如果当前在消息所属的房间，直接显示
     if (currentRoomId === roomId) {
       // 通知聊天页面显示消息
-      uni.$emit('new-room-message', message);
+      uni.$emit('new-room-message', this.checkMessage(message, 1));
     } else {
       // 不在当前房间，缓存消息并增加未读消息数
-      this.cacheMessage(roomId, message);
       this.increaseUnreadCount(roomId);
     }
   }