// import socket from "@/utils/websocket.js" import config from "./config.js" import { getStorageSync } from "./common.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 } 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) } }) socket.emit('login', getStorageSync('userId')); // console.log("getStorageSync('userId')" , getStorageSync('userId')) socket.on('lever_trade', (msg) => { // if (filtration(msg)) { // console.log('lever_trade 133 = ' , JSON.parse(msg.tradesList)) // const tradesList = JSON.parse(msg.tradesList) // const obj = Object.assign({} , msg , {tradesList:tradesList}) // store.commit('websocket/set_lever_trade', obj) // } const trades_all = JSON.parse(msg.trades_all) const obj = Object.assign({} , msg , {tradesList:trades_all}) store.commit('websocket/set_lever_trade', obj) }) }) 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 {} }