//已连接的客户端
var client = {};
//重连时间间隔
var RECONN_TIME = 10 * 1000;
/**
 *
 * @param username   用户名
 * @param host       主机
 * @param project    项目名
 */
function createWebSocket(username, project) {
    var websocket = null;
    username = encodeURI(username);
    //判断当前浏览器是否支持WebSocket
    if ('WebSocket' in window) {
        websocket = new WebSocket('ws://' + location.host + '/' + project + '/websocket?name='+username);
        client.pms = websocket;
        client.pmsname = username;
        client.pmshost =  location.host;
        client.pmsproject = project;

    } else {
        console.info('当前浏览器 Not support websocket');
    }
    //连接发生错误的回调方法
    websocket.onerror = function () {
        console.info("WebSocket连接发生错误" + project + "-----" + username);
    };

//连接成功建立的回调方法
    websocket.onopen = function () {
        console.info("WebSocket连接成功" + project + "-----" + username);

    }
//接收到消息的回调方法
    websocket.onmessage = function (event) {
        //PMS
        var data = event.data;
        var json = JSON.parse(data);
        console.info(json);
        var service = json.service;   //消息来自哪个服务器 wct or pmd
        var type = json.type;         //消息的类型  1-单耗告警，2-质量告警，0-普通消息
        if(service=="wct"){
            if(type == "1"){

            }else if(type == "2"){

            }
        }else if(service=="pms"){
            if(type=="0"){
                $.messager.alert('提示',  json.content, 'info');
            }

        }


    }

    //连接关闭的回调方法
    websocket.onclose = function () {
        console.info("webSocket已关闭！" + project + "-----" + username);
       if(websocket===client.pms){
            setTimeout(function () {
                console.info("尝试重连pms websocket");
                client.pms = null;
                createWebSocket(client.pmsname,client.pmsproject);
            },RECONN_TIME)

        }
    }
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
    window.onbeforeunload = function () {
        closeWebSocket();
    }

//关闭WebSocket连接
    function closeWebSocket() {
        websocket.close();
    }

}