|
|
@@ -1,491 +0,0 @@
|
|
|
-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){
|
|
|
- this.preSort = new Array();
|
|
|
- for (let i = 0; i < this.list.length; i++) this.preSort.push(list[i]);
|
|
|
- quickSort(this.preSort, 0, this.preSort.length - 1, function(l, r){});
|
|
|
- };
|
|
|
-
|
|
|
- this.clearData = function () {
|
|
|
- this.isSorted = false;
|
|
|
- this.preSort = null;
|
|
|
- this.list = null;
|
|
|
- }
|
|
|
-
|
|
|
- this.len = function() {
|
|
|
- if(this.list == null) return 0;
|
|
|
- return this.list.length;
|
|
|
- };
|
|
|
-
|
|
|
- this.mergeJsonData = function (data, extdata) {
|
|
|
- this.list = new Array();
|
|
|
- for (let i = 0; i < data.length; i++) this.addObject(data[i]);
|
|
|
- };
|
|
|
-
|
|
|
- this.addObject = function (jsonObj) {
|
|
|
- this.list.push(new DataObject(this.ctlName, jsonObj));
|
|
|
- };
|
|
|
-
|
|
|
- this.assignJsonData = function (data) {
|
|
|
- this.clearData();
|
|
|
- this.mergeJsonData(data);
|
|
|
- };
|
|
|
- this.getRaw = function (index) {
|
|
|
- if(this.list == null) return null;
|
|
|
- return this.list[index];
|
|
|
- };
|
|
|
- this.getSorted = function (index) {
|
|
|
- if(this.list == null) return null;
|
|
|
- if(!this.isSorted) return this.getRaw(index);
|
|
|
- return this.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;
|
|
|
- this.callerThis = this;
|
|
|
-
|
|
|
- this.setUpInterval = function() {
|
|
|
- //URL + exparm
|
|
|
- if(this.autoUpdateTimer != 0) clearInterval(this.autoUpdateTimer);
|
|
|
- this.autoUpdateTimer = setInterval(this.selfUpdateTick, this.autoInterval, this);
|
|
|
- setTimeout(this.selfUpdateTick, 1000, this);
|
|
|
- }
|
|
|
-
|
|
|
- this.init = function(){
|
|
|
- this.appUrl = controlName + "/list" + extparm;
|
|
|
- if(!this.isFast || this.isOnDemand){
|
|
|
- this.autoInterval = 300;
|
|
|
- }
|
|
|
-
|
|
|
- if(this.isFast) {
|
|
|
- this.appUrl = controlName + "/get" + extparm;
|
|
|
- }
|
|
|
-
|
|
|
- if(this.isAuto){
|
|
|
- // timer
|
|
|
- this.setUpInterval();
|
|
|
- }
|
|
|
- };
|
|
|
-
|
|
|
- this.stopTimers = function () {
|
|
|
- clearInterval(this.autoUpdateTimer);
|
|
|
- this.autoUpdateTimer = 0;
|
|
|
- };
|
|
|
-
|
|
|
- /***
|
|
|
- * Automatica Update Tick, where obj is a replacement for "this" where "this" might be incorrect
|
|
|
- * @param obj : DataObjectService
|
|
|
- */
|
|
|
- this.selfUpdateTick = function(obj){
|
|
|
- get_data(obj.appUrl, obj.onDataReceived, obj);
|
|
|
- };
|
|
|
-
|
|
|
- this.onDemandUpdate = function(obj){
|
|
|
- get_data(obj.appUrl, obj.onDataReceived, obj);
|
|
|
- };
|
|
|
-
|
|
|
- this.onDataReceived = function(data, sta){
|
|
|
- let obj = this.callerThis;
|
|
|
- if(obj == undefined){console.error("Cannot get callerThis in onDataReceived, please check"); console.error(this)}
|
|
|
- let output = first_parse(this, data);
|
|
|
- if (output.list == undefined || output.list.length == 0) {
|
|
|
- obj.failedCount++;
|
|
|
- if(obj.failedCount > 100){
|
|
|
- obj.failedCount = 0;
|
|
|
- obj.stopTimers();
|
|
|
- console.log("[排行榜返回为空git clone https://github.com/pentaho/mondrian-tck.git次数过多]，暂停刷新");
|
|
|
- }
|
|
|
- if(obj.failedCount == 2) {
|
|
|
- send_alert("排行榜多次返回没有数据，请尝试重新加载！ [" + obj.appUrl +"]");
|
|
|
- }
|
|
|
- }else{
|
|
|
- obj.list.assignJsonData(output.list);
|
|
|
- }
|
|
|
- };
|
|
|
-
|
|
|
- this.getList = function () {
|
|
|
- return this.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) {
|
|
|
- for(var part = 0; part < this.parts; part++){
|
|
|
- this.showPart(slide, part, data);
|
|
|
- }
|
|
|
-};
|
|
|
-
|
|
|
-RedRankTable.showPart = function(slide, part, data){
|
|
|
- var lpos = slide * this.slideLen + (part * this.partLen);
|
|
|
- var rpos = slide * this.slideLen + ((part+1) * this.partLen);
|
|
|
- var partList = [];
|
|
|
- for (var i = lpos; i < rpos; i++) {
|
|
|
- var one = data.getSorted(i);
|
|
|
- if(one == null || one == undefined) {
|
|
|
- partList[partList.length] = {passNum : 0, failNum: 0, failRate: 0, workerId: 0, fcDay: new Date().toLocaleDateString()};
|
|
|
- } else {
|
|
|
- partList[partList.length] = one.jsonObj;
|
|
|
- }
|
|
|
- partList[partList.length - 1].workerName = getUserName(partList[partList.length - 1].workerId);
|
|
|
- if("[用户:"+0+"]" == partList[partList.length - 1].workerName){
|
|
|
- partList[partList.length - 1].workerName = "-";
|
|
|
- }
|
|
|
- partList[partList.length - 1].color = true;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- let k = redrankvue.parting[part].length;
|
|
|
- for(let i = 0; i < k; i++){
|
|
|
- redrankvue.parting[part].pop();
|
|
|
- }
|
|
|
-
|
|
|
- for(let i = 0; i < partList.length; i++){
|
|
|
- redrankvue.parting[part].push(partList[i]);
|
|
|
- }
|
|
|
-};
|
|
|
-
|
|
|
-RedRankTable.tickInterval = 1000;
|
|
|
-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.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.workerDailyService = 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(FlowRealTime.workerDailyService.getList());
|
|
|
- };
|
|
|
-
|
|
|
- this.Action = new (function (parent) {
|
|
|
- this.parent = parent;
|
|
|
- this.doStopSchedule = function () {
|
|
|
- get_data("fcWorkSchedule/stopSchedule?userId=" + userId + "&scheduleId=" + scheduleId, this.parent.UI.showStopSuccess, this.parent);
|
|
|
- };
|
|
|
- this.confirmStopSchedule = function () {
|
|
|
- var out = confirm("真的要下班吗？");
|
|
|
- if (out == true) {
|
|
|
- this.doStopSchedule();
|
|
|
- } else {
|
|
|
- }
|
|
|
- };
|
|
|
- })(this);
|
|
|
-
|
|
|
- this.UI = new (function (parent) {
|
|
|
- this.p = parent;
|
|
|
- this.showClearPanel = function () {
|
|
|
- $("#clearModal").modal('show');
|
|
|
- };
|
|
|
- this.showStopSuccess = function (obj, sta, scope) {
|
|
|
- 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();
|
|
|
- })
|
|
|
- }
|
|
|
- })(this);
|
|
|
-
|
|
|
- var ClearDataControl = new (function (parent) {
|
|
|
- this.p = parent;
|
|
|
- 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, this);
|
|
|
- setTimeout(this.getVerify, 300, this);
|
|
|
- }
|
|
|
-
|
|
|
- this.getVerify = function (obj) {
|
|
|
- if (obj.finished) return;
|
|
|
- get_data("endpoint/heartbeat?flowId=" + flowId, obj.onVerifyResult);
|
|
|
- setTimeout(obj.getVerify, 100, obj);
|
|
|
- };
|
|
|
-
|
|
|
- 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 (obj) {
|
|
|
- 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("请求已经超时！请注意，采集端可能没有执行成功。");
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- })(this);
|
|
|
-
|
|
|
-})();
|
|
|
-
|
|
|
-var redrankvue = new Vue({
|
|
|
- el: '#redrank',
|
|
|
- data: {
|
|
|
- parting:[[{},{},{},{}], [{},{},{},{}], [{},{},{},{}], [{},{},{},{}]],
|
|
|
- title: '本厂今日生产能手榜'
|
|
|
- },
|
|
|
- methods: {
|
|
|
- clicktitle: function () {
|
|
|
- alert("Hello! This is Title");
|
|
|
- }
|
|
|
- }
|
|
|
-});
|
|
|
-
|
|
|
-$(document).ready(function(){
|
|
|
- FlowRealTime.initPage();
|
|
|
- FlowRealTime.UI.bind();
|
|
|
-});
|
jason.lu