szugift-fe/sourcecode/h5app/vue/src/connector/basic-service.js

/**
 *
 *  Basic
 *  所有页面的共用基础功能
 *  // TODO: 文件名可能需要修改
 *  // TODO: failing ES-Lint
 *  // TODO: Automated Test
 *
 *  dependency:
 *  jQuery (ajax, selector)
 *
 *  @ jason.lu
 * */

import 'whatwg-fetch';

var BasicFunction = new (function () {

    this.Queue = {
        THRESHOLD: 1000,
        IS_LOADED: false,
        nowuse: 0, SVR_URL: "/server/",
        groupsCount: 0, groups: [],
        shouldStop: false,
        backup: ["/server/",
            "http://127.0.0.1:8866/server/",
            "http://south.niimei.com:8866/server/",
            "https://4.niimei.com/server/"],
        list: [], temporary: 0, errorCount: 0
    };

    this.Users = {list: []};
    this.Sectors = {list: []};
    this.AlertClosingTimeout = 0;

    this.loglog = function (a) {
        console.log(a);
    };

    this.logwarn = function (obj) {
        console.warn(obj);
    };

    this.logerror = function (obj) {
        console.warn(obj);
    };

    this.logtrace = function () {
        console.trace();
    };

    this.logverbose = function () {
        // Not Echoing
    };

    this.asserThat = function(cond, why) {
        console.assert(cond, why);
    };


    this.goajax = function (jqObject) {
        return fetch(jqObject.url, {
            method: 'POST',
            headers: {
                'Content-Type': 'application/json',
                //'x-doiby-authenticate' : 'CISICMIEINAOQPMDPWIDNENU'
            },
            body: jqObject.data
        });
    };

    this.utils_get_param = function (name) {
        var reg = new RegExp("(^|&)" + name + "=([^&]*)(&|$)");
        var r = window.location.search.substr(1).match(reg);
        if (r != null) return unescape(r[2]);
        return null;
    };

    this.reloadPage = function () {
        location.reload()
    };

    this.get_server_url = function () {
        // AJAX
        this.output = this.goajax({url: this.Queue.SVR_URL + "fcFlow/list", timeout: 1000})
            .then(this.checkStatus)
            .then(this.parseJson)
            .then(this.onReachServer)
            .catch(this.onCheckFail);
        // .then(BasicFunction.onCheckFail);
    };

    this.onReachServer = function (checkResponse) {
        BasicFunction.Queue.IS_LOADED = true;
        BasicFunction.logwarn("Using SERVER : ");
        BasicFunction.logwarn(BasicFunction.Queue.SVR_URL);
        setTimeout(BasicFunction.parse_queue, 50, BasicFunction);
    };

    this.onCheckFail = function (errmsg) {
        if (BasicFunction.Queue.nowuse === BasicFunction.Queue.backup.length - 1) {
            BasicFunction.logwarn("Backup Failed : " + BasicFunction.Queue.backup[BasicFunction.Queue.nowuse]);
            BasicFunction.logwarn(this);
            var out = "";
            BasicFunction.Queue.backup.forEach(function (val, index, arr) {
                out += index + ":[" +val +"] \n";
            });
            BasicFunction.logerror("抱歉， 服务器连接失败! \n 请确认 "+ out +" 其中之一可用");
        } else {
            BasicFunction.loglog(errmsg);
            BasicFunction.Queue.nowuse++;
            BasicFunction.Queue.SVR_URL = BasicFunction.Queue.backup[BasicFunction.Queue.nowuse];
            // AJAX
            BasicFunction.goajax({url: BasicFunction.Queue.SVR_URL + "fcFlow/list", timeout: 1000})
                .then(BasicFunction.checkStatus)
                .then(BasicFunction.parseJson)
                .then(BasicFunction.onReachServer)
                .catch(BasicFunction.onCheckFail);
            //.fail(BasicFunction.onCheckFail).done(BasicFunction.onReachServer);
        }
    };

    this.get_data = function (url, callback, scope) {
        BasicFunction.Queue.list.push({url: url, callback: callback, gid: -1, scope: scope});
    };

    this.new_data_group = function (groupName, callback) {
        var gid = -1;
        BasicFunction.Queue.groups.forEach(function (val) {
            if (val.groupName === groupName) {
                gid = val.gid;
            }
        });
        if (gid === -1) {
            gid = BasicFunction.Queue.groupsCount;
            BasicFunction.Queue.groupsCount++;
            BasicFunction.Queue.groups.push({
                gid: gid, groupName: groupName, callme: callback, counter: 0
            });
        }
        return gid;
    };

    this.group_get_data = function (groupName, url, callback) {
        var gid = -1;
        BasicFunction.Queue.groups.forEach(function (val) {
            if (val.groupName === groupName) {
                gid = val.gid;
            }
        });
        if (gid === -1) {
            BasicFunction.send_alert("Group 方法使用错误！！！")
        }
        BasicFunction.Queue.list.push({url: url, callback: callback, gid: gid});
    };

    this.parse_queue = function () {
        BasicFunction.logverbose("Queue Length : " + BasicFunction.Queue.list.length);

        if (BasicFunction.Queue.temporary > new Date().getTime()) {
            for (let i = 0; i < BasicFunction.Queue.list.length; i++) {
                BasicFunction.Queue.list.pop();
            }
        }

        BasicFunction.Queue.temporary = 0;

        if (BasicFunction.Queue.list.length > 0) {
            let one = BasicFunction.Queue.list.pop();
            if (one.gid === -1) {
                request_data(one.url, one.callback, one.scope);
            } else {
                g_request_data(one.url, one.callback, one.gid, one.scope);
            }
        }
        if (BasicFunction.Queue.shouldStop === false) {
            setTimeout(BasicFunction.parse_queue, 50);
        }
    };

    this.parseJSON = function(response) {
        return response.json();
    };

    this.checkStatus = function(response) {
        if (response.status >= 200 && response.status < 300) {
            return response;
        }

        const error = new Error(response.statusText);
        error.response = response;
        throw error;
    };

    function request_data(url, callback, scope) {
        BasicFunction.goajax({
            url: BasicFunction.Queue.SVR_URL + url,
            apiName: url,
            sendTime: new Date()
        }).then(BasicFunction.checkStatus)
          .then(BasicFunction.parseJson)
          .then(function(response){return response.json()})
          .then(callback)
          .catch(BasicFunction.on_fail);
    }

    function g_request_data(url, callback, gid) {
        BasicFunction.goajax({
            url: BasicFunction.Queue.SVR_URL + url,
            apiName: url,
            sendTime: new Date(),
            gid: gid,
            callme: callback
        }).then(BasicFunction.checkStatus)
        .then(BasicFunction.parseJson)
        .then(function(response){return response.json()})
        .then(BasicFunction.onReqeustDataReceived)
        .then(callback)
        .catch(BasicFunction.on_fail);
    }

    this.on_gp_success = function(response) {
        var obj = response.json();
        return obj;
    };

    this.onReqeustDataReceived = function(responseJson) {
        console.warn(responseJson);
        var a = responseJson;
        if (!BasicFunction.check_if_authfail(a)) {
            const error = new Error(responseJson.statusText);
            error.response = responseJson;
            throw error;
        }
        if (!BasicFunction.check_if_success(a)) {
            const error = new Error(responseJson.statusText);
            error.response = responseJson;
            throw error;
        }
        return responseJson;
        //     BasicFunction.setCookieWithTimeout("doibyUser", "", -10);
        //     location.href = "sign-in1.html?from=entrance-5&msg=server-redirect-detected";
        //     return;
    };

    this.check_if_authfail = function (errormsg) {
        BasicFunction.logerror(errormsg);
        var a = errormsg;
        if (a == null || typeof a !== "string") {
            return false;
        } else {
            if (a.indexOf("login?from=") > 0 || a.startsWith("<!DOCTYPE html>") || a.indexOf("<!-- SME::LOGINPAGE -->") > 0) {
                return true;
            }
        }
        return false;
    };

    this.check_if_success = function (response) {
        // this == BasicFunction
        BasicFunction.loglog("---------------Check-If-Success----------------");
        var a = response.json();
        var b = response.status;
        if (typeof a === "string") {
            try {
                a = JSON.parse(a);
            } catch (e) {
                BasicFunction.logwarn("=----------   异常   -----------=");
                BasicFunction.logwarn(a);
                BasicFunction.logwarn("=----------------------------=");
                BasicFunction.send_alert("信息失败 : 1 : " + e);
                return;
            }
        } else if (typeof a === "undefined") {
            BasicFunction.logwarn("=----------   异常   -----------=");
            BasicFunction.logwarn(a);
            BasicFunction.logwarn("=------------------------------=");
            BasicFunction.logwarn(b);
            BasicFunction.logwarn("=------------------------------=");
            BasicFunction.send_alert("信息失败 - 2 " );
            return;
        }
        if (a.ret === "10000") {
            return true;
        } else {
            BasicFunction.logtrace();
            BasicFunction.logerror(b);
            BasicFunction.logerror(JSON.stringify(a));
            BasicFunction.send_alert("查询失败 : 请参阅控制台输出! ");
        }

        return false;
    };

    this.on_fail = function (msg) {
        BasicFunction.Queue.errorCount += 1;
        if (BasicFunction.Queue.errorCount >= 10) {
            BasicFunction.Queue.errorCount = 0;
            BasicFunction.Queue.temporary = new Date().getTime() + 30 * 1000;
            BasicFunction.Queue.shouldStop = true;
            BasicFunction.logwarn("-----  Too many failure, temporary stop HTTP ------");
            BasicFunction.send_alert("很抱歉，网络错误数量过多，暂时终止HTTP功能30s");
        }
        BasicFunction.send_alert(" 很抱歉，网络错误，请查看 Console");
        BasicFunction.logwarn("-----   网络请求失败 ---------");
        BasicFunction.logwarn("-----------msg-------------");
        BasicFunction.logwarn(JSON.stringify(msg));
        BasicFunction.logwarn("----------------------------");
    };

    this.first_parse = function (ajax, obj) {
        if (typeof obj === "string") {
            obj = JSON.parse(obj);
        }

        if (typeof obj !== "object") {
            BasicFunction.logwarn(ajax);
            throw "Error ! Parsing JSON failed ." + JSON.stringify(obj);
        }

        if (obj.ret === "10000") {
            return obj.model;
        } else {
            BasicFunction.logwarn(ajax);
            throw "Error ! Server returned error." + JSON.stringify(obj);
        }
    };

    this.send_alert = function (a, b) {


        if (BasicFunction.Queue.shouldStop) return;

        if (BasicFunction.AlertClosingTimeout > 0) {
            clearTimeout(BasicFunction.AlertClosingTimeout);
        }

        BasicFunction.logwarn(a);
        BasicFunction.logwarn(b);

        // alert(a +"\n"+ b);

        BasicFunction.AlertClosingTimeout = setTimeout(function () {
            //$("#mpAlert").hide();
        }, 10000);

    };

    this.getUserName = function (uid) {
        var uname = null;
        BasicFunction.Users.list.forEach(function (val, aid) {
            BasicFunction.loglog(aid);
            if (val.worker.staffId === uid) {
                uname = val.worker.staffName;
            }
        });
        if (uname == null) {
            if (uid !== 0) {
                BasicFunction.get_data("oaStaff/list?staffId=" + uid, BasicFunction.on_username_retn);
                return "[用户:" + uid + "]";
            } else return "[用户:" + uid + "]";
        } else {
            return uname;
        }
    };

    this.on_username_retn = function (obj) {
        var uid = this.url.substring(this.url.indexOf("staffId=") + 8);
        let ruid = parseInt(uid);
        var out = BasicFunction.first_parse(this, obj);
        if (out.list.length > 0) {
            BasicFunction.Users.list.push({
                uid: ruid, worker: out.list[0]
            });
        }
    };

    this.setCookieWithTimeout = function (name, value, liveMinutes) {
        if (liveMinutes === undefined || liveMinutes == null) {
            liveMinutes = 60 * 2;
        }
        if (typeof (liveMinutes) !== 'number') {
            liveMinutes = 60 * 2;//默认120分钟
        }
        var minutes = liveMinutes * 60 * 1000;
        var exp = new Date();
        exp.setTime(exp.getTime() + minutes + 8 * 3600 * 1000);
        //path=/表示全站有效，而不是当前页
        document.cookie = name + "=" + value + ";path=/;expires=" + exp.toUTCString();
    };

    this.setCookie = function (c_name, value, expiredays) {
        var exdate = new Date();
        exdate.setDate(exdate.getDate() + expiredays);
        document.cookie = c_name + "=" + escape(value) +
            ((expiredays == null) ? "" : ";expires=" + exdate.toGMTString())
    };

    this.getCookie = function (c_name) {
        if (document.cookie.length > 0) {
            var c_start = document.cookie.indexOf(c_name + "=");
            if (c_start !== -1) {
                c_start = c_start + c_name.length + 1;
                var c_end = document.cookie.indexOf(";", c_start);
                if (c_end === -1) c_end = document.cookie.length;
                return unescape(document.cookie.substring(c_start, c_end))
            }
        }
        return "";
    };

    /*this.userId = utils_get_param("userId");

    this.getUserId = function() {
         BasicFunction.loglog("Original  USERID : " + userId);
        var use = getCookie("doibyUser");
        if (use == null || use === undefined || use.length <= 0) {
            location.href = "sign-in1.html?from=entrance-1&msg=nologin-mustauth";
            return;
        }
         BasicFunction.loglog("Got UID From COOKIE : " + use);
        try {
            var mm = parseInt(use);
            if (mm > 0) {
                BasicFunction.userId = mm;
            }
        } catch (e) {
            location.href = "sign-in1.html?from=entrance-1&msg=cookie-wrong-format";
            return;
        }

         BasicFunction.loglog("Got UserId Eventually : " + userId);
    };*/

    this.get_server_url();
    //this.on_document_load();
})();

window.BasicFunction = BasicFunction;

export {
    BasicFunction
};