import store from '@/store'
var webSocket = null;
var globalCallback = null;//定義外部接收數(shù)據(jù)的回調(diào)函數(shù)

//初始化websocket
export function initWebSocket (url) {
  //判斷瀏覽器是否支持websocket
  if ("WebSocket" in window) {
    webSocket = new WebSocket(url);//創(chuàng)建socket對(duì)象
  } else {
    alert("該瀏覽器不支持websocket!");
  }
  //打開(kāi)
  webSocket.onopen = function () {
    webSocketOpen();
  };
  //收信
  webSocket.onmessage = function (msg) {
    webSocketOnMessage(msg);
  };
  //關(guān)閉
  webSocket.onclose = function () {
    webSocketClose();
  };
  //連接發(fā)生錯(cuò)誤的回調(diào)方法
  webSocket.onerror = function () {
    console.log("WebSocket連接發(fā)生錯(cuò)誤");
  };
}

//連接socket建立時(shí)觸發(fā)
export function webSocketOpen () {
  console.log("WebSocket連接成功");
}

//客戶(hù)端接收服務(wù)端數(shù)據(jù)時(shí)觸發(fā),e為接受的數(shù)據(jù)對(duì)象
export function webSocketOnMessage (e) {
  // 存儲(chǔ)在store中，然后在聊天界面中監(jiān)控變化 自動(dòng)拿取收到的信息
  store.commit('user/SET_WS_MSG', e)
}

//發(fā)送數(shù)據(jù)
export function webSocketSend (data) {
  console.log('發(fā)送數(shù)據(jù)');
  //在這里根據(jù)自己的需要轉(zhuǎn)換數(shù)據(jù)格式
  webSocket.send(JSON.stringify(data));
}

//關(guān)閉socket
export function webSocketClose () {
  webSocket.close()
  console.log("對(duì)話連接已關(guān)閉");
  // }
}


//在其他需要socket地方調(diào)用的函數(shù)，用來(lái)發(fā)送數(shù)據(jù)及接受數(shù)據(jù)
export function sendSock (agentData, callback) {
  globalCallback = callback;//此callback為在其他地方調(diào)用時(shí)定義的接收socket數(shù)據(jù)的函數(shù)，此關(guān)重要。
  //下面的判斷主要是考慮到socket連接可能中斷或者其他的因素，可以重新發(fā)送此條消息。
  switch (webSocket.readyState) {
    //CONNECTING：值為0，表示正在連接。
    case webSocket.CONNECTING:
      setTimeout(function () {
        console.log('正在連接。。。');
        webSocketSend(agentData, callback);
      }, 1000);
      break;
    //OPEN：值為1，表示連接成功，可以通信了。
    case webSocket.OPEN:
      console.log('連接成功');
      webSocketSend(agentData);
      break;
    //CLOSING：值為2，表示連接正在關(guān)閉。
    case webSocket.CLOSING:
      setTimeout(function () {
        console.log('連接關(guān)閉中');
        webSocketSend(agentData, callback);
      }, 1000);
      break;
    //CLOSED：值為3，表示連接已經(jīng)關(guān)閉，或者打開(kāi)連接失敗。
    case webSocket.CLOSED:
      console.log('連接關(guān)閉/打開(kāi)失敗');
      // do something
      break;
    default:
      // this never happens
      break;
  }
}

//將初始化socket函數(shù)、發(fā)送（接收）數(shù)據(jù)的函數(shù)、關(guān)閉連接的函數(shù)export出去
export default {
  initWebSocket,
  webSocketClose,
  sendSock
};

let state = {
 webSocketMsg: ''
};

//修改state
const mutations = {
    // 存儲(chǔ)websocket推送的消息
    SET_WS_MSG: (state, msg) => {
        state.webSocketMsg = msg
    }
}
//提交異動(dòng)mutations。 如果在接受塊出現(xiàn)問(wèn)題，可以把這個(gè)加上去看看
//const actions = {
 //   webSockets ({ commit }) {
 //      commit('SET_WS_MSG', 2)
 //   }
//}

//獲取state的狀態(tài)
const getters = {
    webSocketMsg: state => state.user.webSocketMsg
}

export default getters

<script>
import { initWebSocket, sendSock, webSocketClose } from '@/utils/websocket.js'
export default {
  data() {
    return {
     // 這個(gè)地址是后端給的，用來(lái)連接websocket。 加密wss 未加密ws
      wsUrl:'ws://地址',
    }
  },
  // 從store中獲取接收到的信息
  computed: {
    getSocketMsg() {
      return this.$store.state.user.webSocketMsg
    },
  },
  //監(jiān)控 getSocketMsg 是否有接收到數(shù)據(jù)
  watch: {
    getSocketMsg: {
      handler: function (val) {
        this.getConfigResult(val)
      },
    },
    //這一步是我對(duì)我聊天框的css設(shè)計(jì)，大家可以不用寫(xiě)，需要的時(shí)候再參考。
    //我將接收到的信息和發(fā)出的信息都存儲(chǔ)到obList中，然后通過(guò)監(jiān)控?cái)?shù)值變化，使聊天定位始終位于底部（css中 overflow: auto;）
    obList: {
      handler: function (val) {
        this.$nextTick(() => {
          this.$refs.chatContent.scrollTop = this.$refs.chatContent.scrollHeight
        })
      },
    },
    immediate: true,
  },
  methods: {
    // 點(diǎn)擊按鈕-建立聊天連接
    customerDialog() {
      initWebSocket(this.wsUrl)
    },
    // 接收socket回調(diào)函數(shù)返回?cái)?shù)據(jù)的方法,這個(gè)函數(shù)是我在監(jiān)控接受數(shù)據(jù)的時(shí)候調(diào)用的（上面的watch中）
    getConfigResult(val) { },

 // 點(diǎn)擊發(fā)送按鈕 發(fā)送信息---發(fā)送信息的格式要和后端確認(rèn)
    sending() {
      sendSock('發(fā)送的信息')
    },
    // 處理聊天框關(guān)閉事件
    handleClose() {
     //關(guān)閉連接
      webSocketClose()
    },
  },
}
</script>