chat.js

import $U from "./util.js";
import $H from './request.js';
class chat {constructor(arg) {this.url = arg.urlthis.isOnline = falsethis.socket = null// 获取当前用户相关信息let user = $U.getStorage('user');this.user = user ? JSON.parse(user) : {},// 初始化聊天对象this.TO = false;// 连接和监听if (this.user.token) {this.connectSocket()}}// 连接socketconnectSocket() {console.log(this.user);this.socket = uni.connectSocket({url: this.url + '?token=' + this.user.token,complete: () => {}})// 监听连接成功this.socket.onOpen(() => this.onOpen())// 监听接收信息this.socket.onMessage((res) => this.onMessage(res))// 监听断开this.socket.onClose(() => this.onClose())// 监听错误this.socket.onError(() => this.onError())}// 监听打开onOpen() {// 用户状态上线this.isOnline = true;console.log('socket连接成功');// 获取用户离线消息}// 监听关闭onClose() {// 用户下线this.isOnline = false;this.socket = null;console.log('socket连接关闭');}// 监听消息onMessage(data) {console.log('监听消息', data);}// 监听连接错误onError() {// 用户下线this.isOnline = false;this.socket = null;console.log('socket连接错误');}// 关闭连接close() {this.socket.close()}// 创建聊天对象createChatObject(detail) {this.TO = detail;console.log('创建聊天对象', this.TO)}// 销毁聊天对象destoryChatObject() {this.TO = false}// 组织发送信息格式formatSendData(params) {return {id: 0, // 唯一id，后端生成，用于撤回指定消息from_avatar: this.user.avatar, // 发送者头像from_name: this.user.nickname || this.user.username, // 发送者昵称from_id: this.user.id, // 发送者idto_id: params.to_id || this.TO.id, // 接收人/群 idto_name: params.to_name || this.TO.name, // 接收人/群 名称to_avatar: params.to_avatar || this.TO.avatar, // 接收人/群 头像chat_type: params.chat_type || this.TO.chat_type, // 接收类型type: params.type, // 消息类型data: params.data, // 消息内容options: params.options ? params.options : {}, // 其他参数create_time: (new Date()).getTime(), // 创建时间isremove: 0, // 是否撤回sendStatus: params.sendStatus ? params.sendStatus : "pending" // 发送状态，success发送成功,fail发送失败,pending发送中}}// 发送信息send(message) {return new Promise((result, reject) => {// 添加消息历史记录this.addChatDetail();let { data,k } = this.addChatDetail(message, true);// 更新会话列表 this.updateChatList(message);// 验证是否上线if(!this.checkOnLine()) return reject('未上线');$H.post('/chat/send', {to_id: this.TO.id,type: message.type,chat_type: this.TO.chat_type,data: message.data,}).then(res => {// 发送成功message.id = res.id message.sendStatus = 'success'// 更新指定历史记录this.updateChatDetail(message,k);result(res);}).catch(err => {// 发送失败message.sendStatus = 'fail'// 更新指定历史记录this.updateChatDetail(message,k);// 断线重连提示result(err);});})}// 验证是否上线checkOnLine(){if(!this.isOnline){// 断线重连提示this.reconnectConfirm();return false;}return true;}// 断线重连提示reconnectConfirm(){uni.showModal({title: '你已经断线，是否重新连接？',content: '重新连接',success: res => {if(res.confirm){this.connectSocket();}},});}// 添加聊天记录addChatDetail(message,isSend=true){console.log('添加到聊天记录');if(!id){return {data:{},k:0}}// 获取对方idlet id = isSend ? message.to_id : message.from_id;// key值：chetDetail_当前用户id_会话类型_接收人/群idlet key = `chetDetail_${this.user.id}_${message.chat_type}_${id}`;// 获取原来的聊天记录let list = this.getChatdetail(key)console.log('获取原来的聊天记录',list);// 标识message.key = 'k'+list.length;list.push(message);// 加入存储console.log('加入存储',k);this.setStorage(key,list);// 返回return {data:message,k:message.k}}// 更新指定历史记录async updateChatDetail(message,k,isSend=true){// 获取对方idlet id = isSend ? message.to_id : message.from_id// key值：chetDetail_当前用户id_会话类型_接收人/群idlet key = `chetDetail_${this.user.id}_${message.chat_type}_${id}`;// 获取原来的聊天记录let list = this.getChatdetail(key);// 根据k查找对应聊天记录let index = list.findIndex(item=>item.k === k);if(index === -1) return;list[index] = message;// 存储this.setStorage(key,list);}// 获取聊天记录getChatdetail(key=false){key = key ? key : `chatDetail_${this.user.id}_${this.TO.chat_type}_${this.TO.id}`;return this.getStorage(key);}// 获取聊天记录getChatList(message,isSend=true){// 获取本地存储会话列表let list = this.getChatList();// 是否处在当前聊天中let isCurrentChat = false// 接收人/群 id/头像/昵称let id = 0;let avatar = '';let name = '';// 判断私聊还是群聊if(message.chat_type === 'user'){ // 私聊isCurrentChat = this.TO ? (isSend ? this.TO.id === message.to_id : message.from_id) : false;id = isSend ? message.to_id : message.from_id;avatar = isSend ? message.to_avatar : message.from_avatarname = isSend ? message.to_name : message.from_name}else{// 群聊}// 会话是否存在let index = list.findIndex(item=>{return  item.chat_type === message.chat_type && item.id === id;})// 最后一条消息展现形式let data = isSend ? message.data : `${message.from_name}:${message.data}`;// 未读数是否 +1let noreadnum = (isSend || isCurrentChat) ? 0 : 1;// 会话不存在 创建会话if(index === -1){let chatItem = {id,  // 接收人/群 idchat_type:message.chat_type, // 接收类型 user 单聊 group群聊name, // 接收人/群 昵称avatar, // 接收人/群 头像update_time:(new Date()).getTime(), // 最后发送的时间data, // 最后一条消息的内容type:message.type,noreadnum:1, // 未读数istop:false, // 是否置顶shownickname:0, // 是否显示昵称nowarn:0, // 是否免打扰strongwarn:0, //  是否强提醒}if(message.chat_type === 'group'){chatItem = {...chatItem,user_id:0, // 管理员idremark:'', // 群公告invite_confirm:0 // 邀请确认}}}else{// 存在，更新会话// 拿到当前会话let item = list[index]// 更新改会话最后一条消息时间，内容，类型item.update_time = (new Date()).getTime();item.data = data;item.type = message.type;// 未读数更新item.noreadnum += noreadnum// 置顶会话list = this.listToFirst(list,index);}// 存储let key = `chatlist_${this.user.id}`;this.setStorage(key,list);// 更新未读数// 更新vuex中的聊天会话列表uni.$emit('onUpdateChatList',list);return list;/*** {id:1,  // 接收人/群 idchat_type:'user', // 接收类型 user 单聊 group群聊name:'昵称', // 接收人/群 昵称avatar:"/static/images/demo/demo6.jpg", // 接收人/群 头像type:'',// 最后一条消息类型update_time:1628069958, // 最后发送的时间data:"你好啊，哈哈哈", // 最后一条消息的内容noreadnum:1, // 未读数istop:false, // 是否置顶shownickname:0, // 是否显示昵称nowarn:0, // 是否免打扰strongwarn:0, //  是否强提醒user_id://管理员id，remark:'公告', // 群公告invite_confirm:0, // 邀请确认},**/}// 获取本地存储会话列表getChatList(){let key = `chatlist_${this.user.id}`;return this.getStorage(key);}// 获取存储getStorage(key){let list = $U.getStorage(key);return list ? JSON.parse(list) : [];}// 设置存储setStorage(key,value){return $U.setStorage(key,JSON.stringify(value));}// 数组置顶listToFirst(arr,index){if(index != 0){arr.unshift(arr.splice(index,1)[0]);}return arr;}
}
export default chat

感谢大家观看，我们下次见