fronend/js/newData.js

getUserId();

const DEFAULT = 2;
const ONDEMAND = 4;
const AUTO = 8;
const FAST = 16;
const PASSIVE = 32;

var RANK_TBL_ROW_COUNT = 4;

var lastTimeRank0 = "";
var lastTimeRank1 = "";
var lastTimeRank2 = "";
var lastTimeRank3 = "";
var lastTimeRank4 = "";


/***
 * DataObject DO
 * @param cname
 * @param serverJsonObj
 * @constructor
 */
var DataObject = function(cname, serverJsonObj){
    this.ctlName = cname;
    this.jsonObj = serverJsonObj;
    this.getVal = function (key) {
        return jsonObj[key];
    };
    this.serVal = function (key, val) {
        jsonObj[key] = val;
    };

};

/***
 * DataObjectList
 * @param name
 * @constructor
 */
var DataObjectList = function(name){
    this.ctlName = name;
    this.list = null;
    this.isSorted = false;
    this.preSort = [];
    /***
     * sorting
     * @param comparator (a,b)  =====>  a - b
     */
    this.sortBy = function(comparator){
        preSort = new Array();
        for (let i = 0; i < list.length; i++) preSort.push(list[i]);
        quickSort(preSort, 0, preSort.length - 1, function(l, r){});
    };

    function clearData() {
        isSorted = false;
        preSort = null;
        list = null;
    }

    this.len = function() {
        if(list == null) return 0;
        return list.length;
    };

    this.mergeJsonData = function (data, extdata) {
        list = new Array();
        for (let i = 0; i < data.length; i++) this.addObject(data[i]);
    };

    this.addObject = function (jsonObj) {
        list.push(new DataObject(ctlName, jsonObj));
    };

    this.assignJsonData = function (data) {
        clearData();
        mergeJsonData(data);
    };
    this.getRaw = function (index) {
        return list[index];
    };
    this.getSorted = function (index) {
        if(!isSorted) return null;
        return preSort[index];
    };
    this.quickSort = function (a,left,right,comp){
        if(left>right){ //一定要有这个判断，因为有递归left和i-1，若没有这个判断条件，该函数会进入无限死错位递归
            return;
        }

        var i=left,
            j=right,
            pivot=a[left]; //基准总是取序列开头的元素

        while(i!=j){
            while((comp(a[j],pivot) > 0)&&i<j){j--}
            while((comp(a[j],pivot) <= 0)&&i<j){i++}
            if(i<j){  //如果i==j跳出外层while
                var t=a[i];
                a[i]=a[j];
                a[j]=t;
            }
        }

        a[left]=a[i];//交换基准数和k位置上的数
        a[i]=pivot;

        quicksort(a,left,i-1,comp);
        quicksort(a,i+1,right,comp);
    };
};

/***
 * DOService
 * @param controlName
 * @constructor
 */
var DataObjectService = function(controlName, syncType, extparm){
    this.ctlName    = controlName;
    // 2=default 4=on-demand, 8=auto, 16:fast, 32=passive
    this.syncType   = syncType;
    this.extParm    = extparm;
    this.isDefault  =  ((syncType & DEFAULT)  !== 0);
    this.isOnDemand = ((syncType & ONDEMAND)  !== 0);
    this.isAuto =     ((syncType & AUTO)  !== 0);
    this.isFast =     ((syncType & FAST) !== 0);
    this.isPassive =  ((syncType & PASSIVE) !== 0);
    this.failedCount = 0;
    this.list = new DataObjectList(controlName);
    this.autoUpdateTimer = 0;
    this.autoInterval = 1000;

    function setUpInterval() {
        //URL + exparm
        if(this.autoUpdateTimer != 0) clearInterval(this.autoUpdateTimer);
        this.autoUpdateTimer = setInterval(this.selfUpdateTick, this.autoInterval);
        setTimeout(this.selfUpdateTick, 100);
    }

    this.init = function(){
        this.appUrl = "/server/"+ controlName + "/list" + extparm;
        if(!this.isFast || this.isOnDemand){
            this.autoInterval = 30000;
        }

        if(this.isFast) {
            this.appUrl = "/server/"+ controlName + "/get" + extparm;
        }

        if(this.isAuto){
            // timer
            setUpInterval();
        }
    };

    this.stopTimers = function () {
        clearInterval(this.autoUpdateTimer);
        this.autoUpdateTimer = 0;
    };

    this.selfUpdateTick = function(){
        get_data(this.appUrl, this.onDataReceived);
    };

    this.onDemandUpdate = function(){
        get_data(this.appUrl, this.onDataReceived);
    };

    this.onDataReceived = function(data, sta){
        let output = first_parse(this, obj);
        if (output.list == undefined || output.list.length == 0) {
            this.failedCount++;
            if(this.failedCount > 100){
                this.failedCount = 0;
                this.stopTimers();
                console.log("【错误次数过多");
                setTimeout(this.setUpInterval, 10000);
            }
            if(this.failedCount == 2) {
                send_alert("没有数据，请尝试重新加载！【DataService】: ctlName[" + controlName + "],  extParm[" + extparm + "]");
            }
        }else{
            this.list.assignJsonData(output.list);
        }
    };

    this.passiveUpdate = function(data){
        this.failedCount = 0;
        this.list.assignJsonData(data);
    };

    this.init();
};

var SinglePage = function () {
    this.modules = [];
};

var Module = function(chartContainerSelector, dataCtlName){
    this.selector = chartContainerSelector;
    this.dataCtl = dataCtlName;
    this.activeData = null;
    this.lastActive = 0;
    this.tickInterval = 1000;
    /***
     * bindData to UI
     * @param data DataObjectList
     */
    this.setData = function (data) {
        if(data.ctlName == this.dataCtl){
            console.log(`-------- Module ${this.selector} got data ----------- `);
            this.activeData = data;
            this.drawData(this.activeData);
        }else{
            console.log(`-------- Module ${this.selector} cannot use data of ${data.ctlName} ----------- `);
        }
    };
    this.init = function () {
        // do init
        this.setupInterval();
    };
    this.tick = function () {
        // do tick
    };
    this.setupInterval = function () {
        // do tick
        if(this.tickInterval != 0) clearInterval(this.tickInterval);
        this.tickInterval = setInterval(this.tick, this.tickInterval);
    };
    this.drawData = function () {
        // do drawData
    };
};

var RedRankTable = new Module("#table-rank", "fcBiWorkerDaily");

RedRankTable.slideLen = 16;
RedRankTable.slides   = 0;
RedRankTable.parts    = 4;
RedRankTable.partLen  = 4;
RedRankTable.curSlide = 0;

RedRankTable.drawData = function (data) {
    // showSlide
    this.showSlide(this.curSlide, data);
};

RedRankTable.showSlide = function (slide, data) {
    this.parts = 3;
    for(var part = 0; part < this.parts; part++){
        this.showPart(slide, part, data);
    }
};

RedRankTable.showPart = function(slide, part, data){
    var htmlbody = "", row;
    var lpos = this.slide * this.slideLen + part * this.partLen;
    var rpos = this.slide * this.slideLen + (part+1) * this.partLen;
    for (var i = lpos; i < rpos; i++) {
        row = this.getDataRow(htmlbody, data.getRaw(i));
        htmlbody += row;
    }
    //if (localCache() !== htmlbody) {
    $(this.selector + "-" + part).html(htmlbody);
    //    lastTimeRank1 = htmlbody;
    //}
    //console.log(htmlbody);
};

RedRankTable.tickInterval = 10000;
RedRankTable.tick = function(){
    var totalDataLen = this.activeData != null ? this.activeData.len() : 0;
    if(this.slides != Math.ceil(totalDataLen / this.slideLen)){
        this.slides = Math.ceil(totalDataLen / this.slideLen);
        this.curSlide = 0;
    } else {
        this.curSlide = (this.curSlide + 1) % this.slides;
    }
};

RedRankTable.getDataRow = function(htmlbody, dataObj) {
    if (dataObj == null || typeof dataObj === "undefined") {
        htmlbody += "<tr>";
        htmlbody += `<tr>
                    <td> - </td>
                    <td> 0 </td>
                    <td> 0 </td>
                    <td> 0 </td>
                </tr>`;
        htmlbody += "</tr>";
        return htmlbody;
    }
    htmlbody += "<tr>";
    htmlbody += `<tr>
                    <td style="background-color: ${dataObj.getVal("color")}">${getUserName(dataObj.getVal("id"))}</td>
                    <td style="background-color: ${dataObj.getVal("color")}">${dataObj.getVal("failNum")}</td>
                    <td style="background-color: ${dataObj.getVal("color")}">${dataObj.getVal("passNum")}</td>
                    <td style="background-color: ${dataObj.getVal("color")}">${dataObj.getVal("failRate") + '%'}</td>
                </tr>`;
    htmlbody += "</tr>";
    return htmlbody;
}
RedRankTable.init();

var FlowRealTime = new (function () {

    this.pgName = "flowDashBoard";
    this.page = new SinglePage(this.pgName);
    this.scheduleId = utils_get_param("scheduleId");
    this.flowId = utils_get_param("flowId");
    if(scheduleId  == null || flowId == null)
    {
        send_alert(`清重新进入本页面！<a href='denglu.html'> 返回主页 </a>`);
        return;
    }
    this.flowPlace = " % flowPlace %";
    this.flowName = " % flowPlace %";

    this.scheduleLoadDataService = new DataObjectService("fcWorkScheduleLoad", ONDEMAND /*AUTO & FAST*/, "?scheduleId=" + scheduleId);
    this.oaStaffService = new DataObjectService("fcWorkScheduleLoad", ONDEMAND, "");
    this.sectorService = new DataObjectService("fcWorkScheduleLoad", ONDEMAND, "");
    this.flowService = new DataObjectService("fcFlow", ONDEMAND, "");
    this.rankData = new DataObjectService("fcBiWorkerDaily", ONDEMAND & AUTO & FAST, "?type=1");

    this.MeduimData = new (function () {
        this.initializeUsers = function(list){
            list.forEach(function (val, it, arr) {
                var isExist = false;
                userIDs.forEach(function (vals) {
                    if (vals == val.userId) {
                        isExist = true;
                    }
                });
                if (!isExist) userIDs.push(val.userId);
            });
        };
    })();

    this.initPage = function() {
        setInterval(this.tick, 1000);
    };

    this.tick = function(){
        RedRankTable.setData(this.rankData.list);
    };

    this.Action = new (function () {
        this.doStopSchedule = function () {
            get_data("fcWorkSchedule/stopSchedule?userId=" + userId + "&scheduleId=" + scheduleId, UI.showStopSuccess);
        };
        this.confirmStopSchedule = function () {
            var out = confirm("真的要下班吗？");
            if (out == true) {
                doStopSchedule();
            } else {
            }
        };
    })();

    this.UI = new (function () {
        this.showClearPanel = function () {
            $("#clearModal").modal('show');
        };
        this.showStopSuccess = function (obj, sta) {
            send_alert("下班操作成功！ <a href='denglu.html'> 点击这里返回控制主页 </a>");
        };
        this.bind = function () {
            $(".confirm-clear-data").click(function(){
                FlowRealTime.ClearDataControl.clearDataOfDeviceId($('#handInput').val());
            });
            $(".open-clear-panel").click(function () {
                FlowRealTime.UI.showClearPanel();
            })
            $(".close-schedule").click(function () {
                FlowRealTime.Action.confirmStopSchedule();
            })
        }
    })();

    var ClearDataControl = new (function () {
        this.finished = true;
        this.executed = false;
        this.directCount = -1;

        this.clearDataOfDeviceId = function (handId) {
            this.executed = false;
            this.directCount = -1;
            this.finished = true;
            var hand = handId;
            var hd = 0;
            if (hand.length > 0) {
                hd = parseInt(hand);
            }
            get_data("endpoint/clearBoard?flowId=" + flowId + "&handheldId=" + hd, this.clearSuccess);
        };

        this.clearSuccess = function (obj, sta) {
            console.warn("-------  手持设备清空  ----------");
            console.warn(obj);
            send_alert("发送清空请求成功, 正在等待采集端进行处理...");
            this.finished = false;
            setTimeout(this.resultVerifyTimeout, 8000);
            setTimeout(this.getVerify, 300);
        }

        this.getVerify = function () {
            if (this.finished) return;
            get_data("endpoint/heartbeat?flowId=" + flowId, this.onVerifyResult);
            setTimeout(this.getVerify, 100);
        };

        this.onVerifyResult = function (obj, sta) {
            var parsed = {};
            if (typeof(obj) === "string") {
                parsed = JSON.parse(obj);
            } else {
                parsed = obj;
            }

            if (typeof(parsed) === "object") {
                if (parsed.ret === "10000") {
                    //ok
                    if (parsed.model == null || parsed.model === undefined) {
                        executed = true;
                        finished = true;
                    } else if (typeof(obj.model) === "object") {
                        // 没有拿到，继续
                        if (obj.model.list != null && obj.model.list.length > 0) {
                            var direct = obj.model.list[0];
                            if (direct.eventType + "" !== "500") {
                                // OK
                                executed = true;
                                finished = true;
                            } else if (direct.arg2 + "" !== "" + $("#handInput").val()) {
                                // OK
                                executed = true;
                                finished = true;
                            } else {
                                directCount = direct.counter;
                            }
                        }
                    }
                }
            }
        }

        this.resultVerifyTimeout = function () {
            finished = true;
            if (executed) {
                // 执行成功
            } else {
                if (directCount >= 0) {
                    get_data("endpoint/ack?counter=" + directCount, function () {
                        console.log("撤销操作成功");
                        console.log(this);
                    });
                    directCount = -1;
                    send_alert("请求已经超时！请注意，采集端可能没有执行成功。即将撤销您的请求。");
                } else {
                    send_alert("请求已经超时！请注意，采集端可能没有执行成功。");
                }
            }
        }
    })();

})();


$(document).ready(function(){
    FlowRealTime.UI.bind();
});