import WxStorage from "../static/lib/wxStorage.js" //微信Storage
// 需要永久存储，且下次APP启动需要取出的，在state中的变量名
let saveStateKeys = ['userInfo', 'accessToken', 'isLogin'];

// 保存变量到本地存储中
const saveLifeData = function(key, value) {
	// 判断变量名是否在需要存储的数组中
	if (saveStateKeys.indexOf(key) != -1) {
		// 获取本地存储的lifeData对象，将变量添加到对象中
		let tmp = uni.getStorageSync('lifeData');
		// 第一次打开APP，不存在lifeData变量，故放一个{}空对象
		tmp = tmp ? tmp : {};
		tmp[key] = value;
		// 执行这一步后，所有需要存储的变量，都挂载在本地的lifeData对象中
		uni.setStorageSync(key, value);
		uni.setStorageSync('lifeData', tmp);
	}
}
const mutations = {
	$uStore(state, payload) {
		// 判断是否多层级调用，state中为对象存在的情况，诸如user.info.score = 1
		let nameArr = payload.name.split('.');
		let saveKey = '';
		let len = nameArr.length;
		if (nameArr.length >= 2) {
			let obj = state[nameArr[0]];
			for (let i = 1; i < len - 1; i++) {
				obj = obj[nameArr[i]];
			}
			obj[nameArr[len - 1]] = payload.value;
			saveKey = nameArr[0];
		} else {
			// 单层级变量，在state就是一个普通变量的情况
			state[payload.name] = payload.value;
			saveKey = payload.name;
		}
		// 保存变量到本地，见顶部函数定义
		saveLifeData(saveKey, state[saveKey])
	},
	login(state, data) {
		// console.log(data);
		state.loging = data.isit; //登录状态
		if (data.isit) { //写入用户数据
			state.message.useName = data.userName;
			state.puserName = data.userName;
			state.puserID = data.userID;
			state.avatar = data.avatar;
		}
		console.log('登入数据传输成功  开始进入连接')

		var url = 'ws://61.131.136.25:2086/websocket';

		uni.connectSocket({
			url: url
			// url: 'ws://192.168.0.111:2086/websocket'
		});

		var socketOpen = false;

		var heartbeatInterval = null;
		var reconnect = null;



		uni.onSocketOpen(function(res) {
			socketOpen = true;
			console.log('持续连接成功')

			if (reconnect && reconnect != null) {
				clearInterval(reconnect)
			}

			sendSocketMessage();

			// 5秒发送一次心跳
			heartbeatInterval = setInterval(() => {

				console.log('发送心跳中')

				uni.sendSocketMessage({
					data: 'ping'
				});

			}, 5000)

		});


		// 监听连接失败
		uni.onSocketError(function(res) {
			console.log('WebSocket连接打开失败，请检查！');
			//停止发送心跳

			if (heartbeatInterval && heartbeatInterval != null) {
				clearInterval(heartbeatInterval)
			}
			//如果不是人为关闭的话，进行重连
			// if (!_this.isSocketClose) {}
			reconnect = setInterval(() => { // 断线重连

				console.log(`断线重连中...123`)
				// 连接
				uni.connectSocket({
					url: url,
				});

			}, 3000)
		});




		function sendSocketMessage() {
			var data = {
				// type: state.puserName,

				id: state.puserID,
				type: 'login'
			}

			if (socketOpen) {
				uni.sendSocketMessage({
					data: JSON.stringify(data)
				});
			}
		}

		uni.onSocketMessage(function(res) {
			console.log(res.data);
			var data = JSON.parse(res.data)
			if (data.type == 'video') {
				// this.receiveVideo('Receiver', );
				console.log('进入接受 跳转', data.type)
				uni.navigateTo({
					url: '../videoCall/videoCall?state=Receiver&type=' + data.type + '&room=' + data
						.roomId + '&name=' + data.name + '&faqiid=' + data.faqiid
				});
			}
			// console.log('收到服务器内容：' + res.data);
		});


		//储存用户
		WxStorage.set("init", "true");
		WxStorage.set("name", data.userName);
		WxStorage.set("ids", data.userID);
		WxStorage.set("accounts", data.accounts);
		WxStorage.set("pass", data.pass);
	},
	// useWebSocket(state){
	// 	uni.onSocketMessage(function(res) {
	// 		console.log(res.data);
	// 		var data  = JSON.parse(res.data)
	// 		if (data.type == 'video') {
	// 			// this.receiveVideo('Receiver', );
	// 			console.log('进入接受 跳转',data.type)
	// 			uni.navigateTo({
	// 				url: '../videoCall/videoCall?state=Receiver&type=' + data.type +'&room=' + data.roomId + '&name=' + data.name + '&faqiid=' + data.faqiid
	// 			});
	// 		}
	// 		// console.log('收到服务器内容：' + res.data);
	// 	});
	// }
	loginReset(state) { //重置
		state.loging = false;
		state.message.useName = '过客 ';
		WxStorage.clear();
	},
	getUse(state, data) {
		state.puserName = data.userName;
		state.puserID = data.userID;
	},
	getUserData(state, data) {
		state.UserData = data;
	}
}

export default mutations