BiKing/utils/websocket.js

// import socket from "@/utils/websocket.js"
import config from "./config.js"


let socket_api = `${config.socketUrl}:2000`
// import io from '@/js_sdk/hyoga-uni-socket_io/uni-socket.io.js';
import io from '@hyoga/uni-socket.io';
import store from '@/store'
import {
	decimalNum
} from "./common.js"




const nums = (arr = []) => {
	const att = arr.map(el => {
		return el[1]
	})
	const num = Math.max.apply(null, att)
	arr.forEach(el => {
		let n = (el[1] / num * 100).toFixed(2);
		el[2] = n > 100 ? 100 : n;
	})
	return arr
}

export const startSocketkkk = () => {
	const socket = io(socket_api);
	console.log('ws startSocketkkk ', socket);
	socket.on('connect', () => {
		console.log('ws 已连接');
		socket.on('market_depth', (message) => {
			// 收到服务器推送的消息，可以跟进自身业务进行操作
			console.log('market_depth 收到服务器消息', message)
		})

		socket.on('daymarket', (message) => {
			// 收到服务器推送的消息，可以跟进自身业务进行操作
			console.log('daymarket 收到服务器消息', message)
		})
	})

	socket.on("error", (error) => {
		console.log('error 收到服务器消息', error)
	})

}

let socket = null

const filtration = (msg) => {
	if (store.getters.currencyVal.legal_id == msg.legal_id && store.getters.currencyVal.currency_id ==
		msg.currency_id) {
		return true
	} else {
		return false
	}
}
// closeSocket();
export const startSocket = (data) => {
	console.log('closeSocket 初始化')
	closeSocket();
	socket = io(socket_api, {
		query: {},
		transports: ['websocket', 'polling'],
		timeout: 5000,
	});
	socket.on('connect', () => {
		socket.on('market_depth', (msg) => {
			if (filtration(msg)) {
				// console.log('market_depth = ' , msg)
				// 收到服务器推送的消息，可以跟进自身业务进行操作
				// var buyIn = msg.bids.slice(0, 7);
				store.commit('websocket/set_bids', nums(msg.bids))
				// var out = msg.asks.slice(0, 7);
				store.commit('websocket/set_asks', nums(msg.asks))
			}
		})
		socket.on('daymarket', (msg) => {
			// 收到服务器推送的消息，可以跟进自身业务进行操作
			if (filtration(msg)) {
				store.commit('websocket/set_daymarket', msg)
			}
		})


	})



	return false
	if (socketObj[data.type]) {
		socketObj[data.type].disconnect();
		socketObj[data.type] = null
	};
	socketObj[data.type] = io(socket_api, {
		query: {},
		transports: ['websocket', 'polling'],
		timeout: 5000,
	});
	socketObj[data.type].on(data.type, (msg) => {
		if (store.getters.currencyVal.legal_id == msg.legal_id && store.getters.currencyVal.currency_id ==
			msg.currency_id) {
			if (msg.type == 'market_depth') {
				// var buyIn = msg.bids.slice(0, 7);
				store.commit('websocket/set_bids', nums(msg.bids))
				// var out = msg.asks.slice(0, 7);
				store.commit('websocket/set_asks', nums(msg.asks))
			}
			if (msg.type == 'daymarket') {
				// state.daymarket = msg;
				store.commit('websocket/set_daymarket', msg)
			}

		}

	});
}

export const closeSocket = () => {
	try {
		socket && socket.disconnect()
		socket = null;
	} catch {}
}