let global_callback = null
let socket = '' // 存儲 WebSocket 連接.
let timeoutObj = null  // 心跳定時器
let serverTimoutObj = null // 服務(wù)超時定時關(guān)閉
let lockReconnect = false // 是否真正建立了連接
let timeoutnum = null // 重新連接的定時器，  沒連接上會一直重連，設(shè)置延遲避免請求過多
const socketConfig = {
  url: '',
  retryTimeout: 20000 // 心跳時間 暫定20s
}
export const sendWebsocket = function (agentData, callback) {
  global_callback = callback
  socketOnSend(agentData)
}
export const initWebSocket = function (url) {
  let weburl = url || socketConfig.url
  if (window.WebSocket) { return }
  if (!socket) {
    socket = new WebSocket(weburl)
    socketOnOpen()
    socketOnClose()
    socketOnError()
    socketOnMessage()
  }
}
/**
 * 關(guān)閉websocket函數(shù)
 */
export const closeWebsocket = function () {
  if (socket) {
    socket.close()
  }
  clearTimeout(timeoutObj)
  clearTimeout(serverTimoutObj)
}
function socketOnSend(data) {
  socket.send(data)
}
function socketOnOpen() {
  socket.onopen = () => {
    console.log('socket連接成功')
    start()
  }
}
// 開啟心跳
function start() {
  timeoutObj && clearTimeout(timeoutObj)
  serverTimoutObj && clearTimeout(serverTimoutObj)
  timeoutObj = setTimeout(() => {
    // 這里發(fā)送一個心跳，后端收到后返回一個心跳消息
    if (socket.readyState === 1) {
      // 如果連接正常  給后端發(fā)送指定消息
      socket.send('')
      console.log('發(fā)送消息')
    } else {
      // 重連
      reconnect()
    }
    serverTimoutObj = setTimeout(() => {
      // 超時關(guān)閉連接
      socket.close()
    }, socketConfig.retryTimeout);
  }, socketConfig.retryTimeout);
}
// 重連
function reconnect() {
  if (lockReconnect) {
    return
  }
  lockReconnect = true
  timeoutnum && clearTimeout(timeoutnum)
  timeoutnum = setTimeout(() => {
    initWebSocket()
    lockReconnect = false
  }, 5000);
}
function socketOnClose() {
  socket.onclose = () => {
    console.log('socket已經(jīng)關(guān)閉')
  }
}
function socketOnError() {
  socket.onerror = () => {
    reconnect()
    console.log('socket 連接失敗')
  }
}
function socketOnMessage() {
  socket.onmessage = (e) => {
    global_callback(e.data)
    reset()
  }
}
// 重置心跳
function reset() {
  // 清除時間
  clearTimeout(timeoutObj)
  clearTimeout(serverTimoutObj)
  // 重啟心跳
  start()
}

 import { closeSock} from "@/api/socket";
 export default {
 	destoryed () {
 		closeSock()
 	}
 }