CBB3/library/Event/SocketEvent.js

/// +----------------------------------------------------------------------
// | HTTP 全局监听口[监听远程执行之后]
// +----------------------------------------------------------------------
// | Copyright (c) 2016-2017 ，Lioc All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: Mr Table <admin@hjf.pw>
// +----------------------------------------------------------------------
import md5 from "../vendor/md5.js";
import Message from "../socket/Message.js";
// #ifndef APP-PLUS
import store from "@/store/index.js";
//#endif
class SocketEvent {
	app = null;
	// #ifdef APP-PLUS-NVUE
	allApp = null;
	//#endif
	constructor(app) {
	    this.app = app;
		// #ifdef APP-PLUS-NVUE
		this.allApp = getApp()
		//#endif
	}
	/**
	 * 打开项目
	 * @param {Object} res
	 */
	onOpen(res) {
		uni.$emit('socketOpen',res);
		// #ifdef APP-PLUS-NVUE
		let user = allApp.$store.state.user;
		//#endif
		// #ifndef APP-PLUS-NVUE
		let user = store.state.user;
		//#endif
		if(user != null) {
			this.app.webSocket.send(new Message(user.token,"auth",true),
			(res)=>{
				let data = JSON.parse(res);
				if(data.type == 'auth_yes') {
					
				}
				
				if(data.type == 'auth_error') {
					//store.commit('loginOut');
				//	uni.showToast({ 'title'	: data.msg,duration : 3000,icon:'none'});
				}
				
				this.app.request.get("chatBagenum").then(res=>{
					if(res.code == 200) {
						// #ifdef APP-PLUS-NVUE
						allApp.$store.commit('setTxbagenum',res.data);
						//#endif
						// #ifndef APP-PLUS-NVUE
						store.commit('setTxbagenum',res.data);
						//#endif
					}
				}).catch((err)=>{
					
				});
				
			},()=>{
				console.log('测试失败了');
			});
		}
	}
	onMessage(res) {
		if(res.code == 'chat' || res.code == 'group_chat') {
			// #ifdef APP-PLUS-NVUE
			let bagenum = allApp.$store.state.txbagenum;
			//bagenum.count ++;
			bagenum.chatCount ++;
			allApp.$store.commit('setTxbagenum',bagenum);
			//#endif
			// #ifndef APP-PLUS-NVUE
			let bagenum = store.state.txbagenum;
			//bagenum.count ++;
			bagenum.chatCount ++;
			store.commit('setTxbagenum',bagenum);
			//#endif
		
		}
		
		//对方添加好友
		if(res.code == 'friend_add') {
			if(this.app.utils.isJSON(res.data)) {
				var data= JSON.parse(res.data);
				// #ifdef APP-PLUS-NVUE
				//消息提示
				let bagenumAr = allApp.$store.state.txbagenum;
				bagenumAr.applyCount ++;
				allApp.$store.commit('setTxbagenum',bagenumAr);
				//#endif
				// #ifndef APP-PLUS-NVUE
				//消息提示
				let bagenumAr = store.state.txbagenum;
				bagenumAr.applyCount ++;
				store.commit('setTxbagenum',bagenumAr);
				//#endif
				
			}
		}
		
		//申请进群
		if(res.code == 'group_add') {
			
		}
		
		
		uni.$emit('socketMessage',res);
		return '';
	}
	
	onError(res) {
		uni.$emit('socketClose',res);
	}
	
	onStop(res) {
		uni.$emit('socketClose',res);
	}
	
	onClose(res) {
		uni.$emit('socketClose',res);
	}
	onSendError(res){
		uni.$emit('socketSendError',res);
	}
	onSendSuccess(res) {
		uni.$emit('socketSendSuccess',res);
	}
	
	onHeartBeat(res){
		uni.$emit('socketHeartBeat',res);
	}
}

export default SocketEvent;