uni-app 180查看好友朋友圈完善

Posted 2019ab

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了uni-app 180查看好友朋友圈完善相关的知识,希望对你有一定的参考价值。

前端

H5同步APP代码

/common/free-lib/chat.js

import $U from "./util.js";
import $H from './request.js';
import $store from '@/store/index.js';
class chat 
	constructor(arg) 
		this.url = arg.url
		this.isOnline = false
		this.socket = null
		this.reconnectConfirm = 0
		this.isOpenReconnect = false
		// 获取当前用户相关信息
		let user = $U.getStorage('user');
		this.user = user ? JSON.parse(user) : ,
		// 初始化聊天对象
		this.TO = false;
		this.platform = uni.getSystemInfoSync().platform;
		// 创建背景音频管理器
		this.bgAudioManager = uni.getBackgroundAudioManager();
		bgAudioManager.title = '致爱丽丝';
		bgAudioManager.singer = '暂无';
		bgAudioManager.coverImgUrl = 'https://bjetxgzv.cdn.bspapp.com/VKCEYUGU-uni-app-doc/7fbf26a0-4f4a-11eb-b680-7980c8a877b8.png';
		bgAudioManager.src = 'https://bjetxgzv.cdn.bspapp.com/VKCEYUGU-hello-uniapp/2cc220e0-c27a-11ea-9dfb-6da8e309e0d8.mp3';
		// 连接和监听
		if (this.user.token) 
			this.connectSocket()
		
	
	// 断线重连
	reconnect()
		if(this.isOnline)
			return;
		
		if(this.reconnectTime >= 3)
			return this.reconnectConfirm();
		
		this.reconnectTime += 1;
		this.connectSocket();
	
	// 连接socket
	connectSocket() 
		//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连接成功');
		this.reconnectTime = 0;
		this.isOpenReconnect = true;
		// 获取用户离线消息
		this.getMessage();
	
	// 获取离线消息
	getMessage() 
		$H.post('/chat/getmessage');
	
	// 获取聊天记录
	getChatDetail(key = false) 
		key = key ? key : `chatDetail_$this.user.id_$this.TO.chat_type_$this.TO.id`
		return this.getStorage(key)
	
	// 监听关闭
	onClose() 
		// 用户下线
		this.isOnline = false;
		this.socket = null;
		if(this.isOpenReconnect)
			this.reconnect();
		
		//console.log('socket连接关闭');
	
	// 监听消息
	onMessage(data) 
		//console.log('监听消息', data);
		let res = JSON.parse(data.data)
		// 错误
		switch (res.msg) 
			case 'fail':
				return uni.showToast(
					title: res.data,
					icon: 'none'
				);
				break;
			case 'recall': // 撤回消息
				this.handleOnRecall(res.data)
				break;
			case 'updateApplyList': // 新的好友申请
				$store.dispatch('getApply');
				break;
			case 'moment': // 朋友圈更新
				this.handleMoment(res.data)
				break;
			
			default:
				// 处理消息
				this.handleOnMessage(res.data)
				break;
		
	
	// 获取本地存储中的朋友圈动态通知
	getNotice()
		let notice = $U.getStorage('moment_'+this.user.id);
		return notice ? JSON.parse(notice) : 
			avatar:'',
			user_id:0,
			num:0
		
	
	// 处理朋友圈通知
	async handleMoment(message)
		let notice = this.getNotice();
	    switch(message.type)
			case 'new':
			   if(message.user_id !== this.user.id)
				  notice.avatar = message.avatar;
				  notice.user_id = message.user_id;
				  uni.showTabBarRedDot(
					  index:2
				  )
				
			break;
			default:
			if(message.user_id !== this.user.id)
				notice.avatar = message.avatar
				notice.user_id = message.user_id 
				notice.num += 1
			
			if(notice.num > 0)
				uni.setTabBarBadge(
					index:2,
					text:notice.num > 99 ? '99+' : notice.num.toString()
				)
			else
				uni.removeTabBarBadge(
					index:2
				)
			
			break;
		
		uni.$emit('momentNotice',notice);
		$U.setStorage('moment_'+this.user.id,JSON.stringify(notice));
	
	// 读取朋友圈动态
	async readMoments()
		let notice = 
			avatar:'',
			user_id:0,
			num:0
		;
		$U.setStorage('moment_'+this.user.id,JSON.stringify(notice));
		uni.hideTabBarRedDot(
			index:2
		)
		uni.removeTabBarBadge(
			index:2
		)
		uni.$emit('momentNotice',notice);
	
	// 监听撤回消息处理
	async handleOnRecall(message) 
		// 通知聊天页撤回消息
		uni.$emit('onMessage', 
			...message,
			isremove: 1
		)
		// 修改聊天记录
		let id = message.chat_type === 'group' ? message.to_id : message.from_id
		// key值:chatDetail_当前用户id_会话类型_接收人/群id
		let key = `chatDetail_$this.user.id_$message.chat_type_$id`
		// 获取原来的聊天记录
		let list = this.getChatDetail(key)
		// 根据k查找对应聊天记录
		let index = list.findIndex(item => item.id === message.id)
		if (index === -1) return;
		list[index].isremove = 1
		// 存储
		this.setStorage(key, list)
		// 当前会话最后一条消息的显示
		this.updateChatItem(
			id,
			chat_type: message.chat_type
		, (item) => 
			item.data = '对方撤回了一条消息'
			item.update_time = (new Date()).getTime()
			return item
		)
	
	// 处理消息
	async handleOnMessage(message) 
		// 添加消息记录到本地存储中
		let 
			data
		 = this.addChatDetail(message, false)
		// 更新会话列表
		this.updateChatList(data, false)
		// 全局通知
		uni.$emit('onMessage', data)
		// 消息提示
		this.messageNotice()
	

	// 监听连接错误
	onError() 
		// 用户下线
		this.isOnline = false;
		this.socket = null;
		//console.log('socket连接错误');
		
	
	// 消息提示
	messageNotice()
		if(this.platform === 'android')
			uni.vibrateShort();
		else
			uni.vibrateLong();
		
		
		// 提示音
		if(this.bgAudioManager.src)
			this.bgAudioManager.play();
		else
			// 路径
			this.bgAudioManager.src = '/static/notice.mp3';
		
		
	
	// 关闭连接
	close() 
		if(this.socket)
			this.socket.close()
		
		
		this.isOpenReconnect = false
	
	// 创建聊天对象
	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, // 发送者id
			to_id: params.to_id || this.TO.id, // 接收人/群 id
			to_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, onProgress = false) 
		return new Promise(async (result, reject) => 
			// 添加消息历史记录
			// this.addChatDetail();
			let 
				k
			 = this.addChatDetail(message);
			// 更新会话列表 
			this.updateChatList(message);
			// 验证是否上线
			if (!this.checkOnLine()) return reject('未上线');
			// 上传文件
			let isUpload = (message.type !== 'text' && message.type !== 'emoticon' && message.type !==
				'card' && !message.data.startsWith('http://akyan.oss-cn-beijing.aliyuncs.com/'))
            
			let uploadResult = ''
			if (isUpload) 
				uploadResult = await $H.upload('/upload', 
					filePath: message.data
				, onProgress);
				
				if(!uploadResult)
					message.sendStatus = 'fail';
					// 更新指定历史记录
					this.updateChatDetail(message, k);
					// 断线重连提示
					return result(err);
				
			
			
			// 提交到后端
			let data = isUpload ? uploadResult : message.data;
			$H.post('/chat/send', 
				to_id: message.to_id || this.TO.id,
				type:message.type,
				chat_type:message.chat_type || this.TO.chat_type,
				data,
				options: JSON.stringify(message.options)
			).then(res => 
				// 发送成功
				//console.log('chat.js发送成功');
				message.id = res.id
				message.sendStatus = 'success';
				if (message.type === 'video') 
					message.data = res.data;
					message.options = res.options;
				
				// 更新指定历史记录
				//console.log('更新指定历史记录',message);
				this.updateChatDetail(message, k);
				result(res);
			).catch(err => 
				// 发送失败
				//console.log('chat.js发送失败');
				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('添加到聊天记录');
		// 获取对方id
		let id = message.chat_type === 'user' ? (isSend ? message.to_id : message.from_id) : message.to_id;
		if (!id) 
			return 
				data: ,
				k: 0
			
		

		// key值:chatDetail_当前用户id_会话类型_接收人/群id
		uni-app 182查看好友朋友圈完善

uni-app 151修复删除好友朋友圈记录问题

微信输入几个字,就能查看好友朋友圈所有动态!你不会不知道吧

uni-app 161朋友圈查看权限

社交网络好友列表、朋友圈、帖子分享的数据库设计[关闭]

apiCloud 三方分享,微信好友分享,微信朋友圈分享,QQ分享,微博分享