oaup9/o2web/source/x_component_FindDesigner/PatternWorker.js

var _worker = self;
var _action = {
    _checkRequest: function(s,f){
        if (this.request.readyState === XMLHttpRequest.DONE) {
            if (this.request.status === 200) {
                this._doneRequest(s);
            } else {
                this._errorRequest(f);
            }
        }
    },
    _createRequest: function(s, f){
        var request = new XMLHttpRequest();
        request.addEventListener("readystatechange",function(){
            if (this.readyState === XMLHttpRequest.DONE) {
                if (this.status === 200) {
                    var json = JSON.parse(this.responseText);
                    var xToken = this.getResponseHeader(_worker.findData.tokenName);
                    if (xToken){
                        json.xToken = xToken;
                    }
                    if (s) s(json);
                } else {
                    if (f) f(this, this.responseText);
                }
            }
        });
        return request
    },
    sendRequest: function(data){
        return new Promise(function(s, f){
            var request = this._createRequest(s, f);
            var method = data.method;
            var noCache = !!data.noCache;
            var async = !!data.loadAsync;
            var withCredentials = !!data.credentials;
            var url = data.address;
            var body = data.body;
            var debug = data.debug;
            var token = data.token;

            if (noCache) url = url+(((url.indexOf("?")!==-1) ? "&" : "?")+(new Date()).getTime());

            request.open(method, url, async);

            request.withCredentials = withCredentials;
            request.setRequestHeader("Content-Type", "application/json; charset=utf-8");
            request.setRequestHeader("Accept", "text/html,application/json,*/*");
            if (debug) request.setRequestHeader("x-debugger", "true");
            if (token){
                request.setRequestHeader(_worker.findData.tokenName, token);
                request.setRequestHeader("authorization", token);
            }

            request.send(body);
        }.bind(this));
    },

    _doneRequest: function(s){
        var json = JSON.parse(this.request.responseText);
        var xToken = this.request.getResponseHeader(_worker.findData.tokenName);
        if (xToken){
            json.xToken = xToken;
        }
        if (s) s(json);
        // _worker.postMessage({"type": "done", "data": json});
        // _worker.close();
    },
    _errorRequest: function(f){
        if (s) s(this.request, this.request.responseText);
        // _worker.postMessage({"type":"error", "data": {"status":  this.request.status, "statusText":  this.request.statusText, "responseText":this.request.responseText}});
        // _worker.close();
    }
};

_worker.action = _action;

_worker._receiveMessageReply = function(){
    _worker.postMessage({
        "type": "receive"
    });
};
_worker._readyMessageReply = function(){
    _worker.postMessage({
        "type": "ready",
        "count": this.filterOptionList.length
    });
};

_worker._getRequestOption = function(data, par){
    if (par){
        Object.keys(par).forEach(function(k){
            data.url = data.url.replace("{"+k+"}", par[k]);
        });
    }
    return {
        "method": data.method||"get",
        "noCache": false,
        "loadAsync": true,
        "credentials": true,
        "address": data.url,
        "body": data.body || "",
        "debug": data.debug || _worker.findData.debug,
        "token": data.token || _worker.findData.token
    };
};

_worker._createFilterOption = function(moduleType, appId, desingerType, desingerId){
    var filterOption = JSON.parse(_worker.filterOptionTemplete);
    filterOption.moduleList.push({
        "moduleType": moduleType,
        "moduleAppList": [{"appId": appId, "designerList": [{"desingerType": desingerType, "designerIdList": [desingerId]}]}]
    });
    this.filterOptionList.push(filterOption);
    return filterOption;
};
_worker._getDesingerModule = function(id, restful, par, moduleType, desingerType){
    var p = _worker.action.sendRequest(_worker._getRequestOption({"url": restful, "debug": _worker.findData.debug, "token": _worker.findData.token }, par));
    return p.then(function(json){
        list = json.data;
        list.forEach(function(designer){
            _worker._createFilterOption(moduleType, id, desingerType, designer.id)
        });
    }, function(){});
};

_worker._getDesinger_processPlatform = function(id){
    var promiseArr = [];
    if (_worker.findData.filterOption.designerTypes.indexOf("script")!=-1){    //所有脚本
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listProcessScript, {"applicationId": id}, "processPlatform", "script"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("form")!=-1){      //所有表单
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listProcessForm, {"applicationId": id}, "processPlatform", "form"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("process")!=-1){   //所有流程
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listProcessProcess, {"applicationId": id}, "processPlatform", "process"));
    }
    return promiseArr;
};

_worker._getDesinger_cms = function(id){
    var promiseArr = [];
    if (_worker.findData.filterOption.designerTypes.indexOf("script")!=-1){    //所有脚本
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listCmsScript, {"flag": id}, "cms", "script"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("form")!=-1){      //所有表单
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listCmsForm, {"appId": id}, "cms", "form"));
    }
    return promiseArr;
};

_worker._getDesinger_portal = function(id){
    var promiseArr = [];
    if (_worker.findData.filterOption.designerTypes.indexOf("script")!=-1){    //所有脚本
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listPortalScript, {"portalId": id}, "portal", "script"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("page")!=-1){      //所有表单
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listPortalPage, {"portalId": id}, "portal", "page"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("widget")!=-1){   //所有流程
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listPortalWidget, {"portalId": id}, "portal", "widget"));
    }
    return promiseArr;
};

_worker._getDesinger_query = function(id){
    var promiseArr = [];
    if (_worker.findData.filterOption.designerTypes.indexOf("view")!=-1){    //所有脚本
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listQueryView, {"flag": id}, "query", "view"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("stat")!=-1){      //所有表单
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listQueryStat, {"flag": id}, "query", "stat"));
    }
    if (_worker.findData.filterOption.designerTypes.indexOf("statement")!=-1){   //所有流程
        promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listQueryStatement, {"flag": id}, "query", "statement"));
    }
    return promiseArr;
};

_worker._getDesinger_service = function(id){
    var promiseArr = [];
    if (_worker.findData.filterOption.designerTypes.indexOf("script")!=-1){    //所有脚本
        if (id=="invoke"){
            promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listInvoke, null, "service", "script"));
        }else if (id=="script"){
            promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listScript, null, "service", "script"));
        }else{
            promiseArr.push(_worker._getDesingerModule(id, _worker.findData.actions.listAgent, null, "service", "script"));
        }
    }
    return promiseArr;
};


_worker._listApplication = function(type){
    switch (type){
        case "processPlatform":
            return this.action.sendRequest(_worker._getRequestOption({"url": this.findData.actions.listProcess, "debug": this.findData.debug, "token": this.findData.token }));
        case "cms":
            return this.action.sendRequest(_worker._getRequestOption({"url": this.findData.actions.listCms, "debug": this.findData.debug, "token": this.findData.token }));
        case "portal":
            return this.action.sendRequest(_worker._getRequestOption({"url": this.findData.actions.listPortal, "debug": this.findData.debug, "token": this.findData.token }));
        case "query":
            return this.action.sendRequest(_worker._getRequestOption({"url": this.findData.actions.listQuery, "debug": this.findData.debug, "token": this.findData.token }));
    }

};
_worker._parseFindModule = function(moduleList){
    var promiseArr = [];
    moduleList.forEach(function(module){
        if (module.moduleType==="service"){
            if (!module.flagList || !module.flagList.length){

                var filterOption = JSON.parse(_worker.filterOptionTemplete);
                filterOption.moduleList.push({
                    "moduleType": module.moduleType,
                    "moduleAppList": [{"appId": "invoke"}]
                });
                this.filterOptionList.push(filterOption);

                filterOption = JSON.parse(_worker.filterOptionTemplete);
                filterOption.moduleList.push({
                    "moduleType": module.moduleType,
                    "moduleAppList": [{"appId": "agent"}]
                });
                this.filterOptionList.push(filterOption);

                filterOption = JSON.parse(_worker.filterOptionTemplete);
                filterOption.moduleList.push({
                    "moduleType": module.moduleType,
                    "moduleAppList": [{"appId": "script"}]
                });
                this.filterOptionList.push(filterOption);

                //promiseArr.push(Promise.resolve(""));
                promiseArr = promiseArr.concat(_worker["_getDesinger_"+module.moduleType]("invoke"));
                promiseArr = promiseArr.concat(_worker["_getDesinger_"+module.moduleType]("agent"));
                promiseArr = promiseArr.concat(_worker["_getDesinger_"+module.moduleType]("script"));
            }else{
                module.flagList.forEach(function(flag){
                    if (!flag.designerList || !flag.designerList.length){
                        promiseArr = promiseArr.concat(_worker["_getDesinger_"+module.moduleType](flag.id));
                    }else{
                        flag.designerList.forEach(function(designer){
                            var filterOption = _worker._createFilterOption(module.moduleType, flag.id, designer.desingerType, designer.id)
                            promiseArr = promiseArr.concat(Promise.resolve(filterOption));
                        });
                    }
                });
            }
        }else{
            if (!module.flagList || !module.flagList.length){
                var p = _worker._listApplication(module.moduleType);
                promiseArr.push(p.then(function(json){

                    // json.data.forEach(function(app){
                    //     var filterOption = JSON.parse(_worker.filterOptionTemplete);
                    //     filterOption.moduleList.push({
                    //         "moduleType": module.moduleType,
                    //         "moduleAppList": [{"appId": app.id}]
                    //     });
                    //     this.filterOptionList.push(filterOption);
                    // });
                    // return Promise.resolve("");
                    //临时处理


                    var pArr = [];
                    json.data.forEach(function(app){
                        pArr = pArr.concat(_worker["_getDesinger_"+module.moduleType](app.id));
                    });
                    return Promise.all(pArr);
                }, function(){}));

            }else{
                module.flagList.forEach(function(flag){
                    if (!flag.designerList || !flag.designerList.length){
                        promiseArr = promiseArr.concat(_worker["_getDesinger_"+module.moduleType](flag.id));
                    }else{
                        flag.designerList.forEach(function(designer){
                            var filterOption = _worker._createFilterOption(module.moduleType, flag.id, designer.desingerType, designer.id)
                            promiseArr = promiseArr.concat(Promise.resolve(filterOption));
                        });
                    }
                });
            }
        }
    }.bind(this));
    return promiseArr;
}

_worker._findMessageReply = function(data, option){
    _worker.setTimeout(function(){
        _worker.postMessage(data);
    }, 100);

};
_worker._findOptionReply = function(){
    _worker.postMessage({
        "type": "done"
    });
};



_worker._createFindMessageReplyData = function(module, designer, aliase, pattern){
    return {
        "module": module,
        "appId": designer.appId,
        "appName": designer.appName,
        "designerId": designer.designerId,
        "designerName": designer.designerName,
        "designerType": designer.designerType,
        "designerAliase": aliase,

        "pattern": pattern
    };
};

_worker._setFilterOptionRegex = function(){
    var keyword = _worker.findData.option.keyword;
    if (_worker.findData.option.matchRegExp){
        var flag = (_worker.findData.option.caseSensitive) ? "g" : "gi";
        this.keywordRegexp =  new RegExp(keyword, flag);
    }else{
        var flag = (_worker.findData.option.caseSensitive) ? "g" : "gi";
        keyword = (_worker.findData.option.matchWholeWord) ? "\\b"+keyword+"\\b" : keyword;
        this.keywordRegexp = new RegExp(keyword, flag);
    }
};

_worker._findProcessPlatformParse_script = function(designer){
    if (designer.patternList && designer.patternList.length){
        var action = this.findData.actions.getProcessScript;

        var p = _worker.action.sendRequest(_worker._getRequestOption({"url": action}, {"id": designer.designerId}));
        p.then(function(json){
            designer.patternList.forEach(function(pattern){
                if (pattern.property=="text"){
                    var scriptLines = json.data.text.split(/\n/);
                    pattern.lines.forEach(function(line){
                        var scriptText = scriptLines[line-1];
                        while ((arr = this.keywordRegexp.exec(scriptText)) !== null) {
                            var col = arr.index;
                            var key = arr[0];
                            var value = arr.input;
                            _worker._findMessageReply(_worker._createFindMessageReplyData("processPlatform", designer, json.data.aliase, {
                                "property": pattern.property,
                                "value": value,
                                "line": line,
                                "column": col,
                                "key": key
                            }));
                        }
                    });
                }else{
                    _worker._findMessageReply(_worker._createFindMessageReplyData("processPlatform", designer, json.data.aliase, {
                        "property": pattern.property,
                        "value": json.data[pattern.property]
                    }));
                }
            });
        }, function(){});
    }
};

_worker._findProcessPlatformParse_form = function(designer){

};

_worker._findProcessPlatformParse_process = function(designer){

};

_worker._findProcessPlatformParse = function(resultList){
    resultList.forEach(function(designer){
        switch (designer.designerType){
            case "script":
                _worker._findProcessPlatformParse_script(designer);
                break;
            case "form":
                _worker._findProcessPlatformParse_form(designer);
                break;
            case "process":
                _worker._findProcessPlatformParse_process(designer);
                break;
        }
    });
};


_worker._doFindDesigner = function(option){

        var res = _worker._getRequestOption({
            "method": "post",
            "url": this.findData.actions.findAction,
            "body": JSON.stringify(option),
            "debug": this.findData.debug,
            "token": this.findData.token
        });
        this.action.sendRequest(res).then(function(json){
            if (json.data.processPlatformList && json.data.processPlatformList.length){
                _worker._findProcessPlatformParse(json.data.processPlatformList);
            }
            if (json.data.cmsList && json.data.cmsList.length){

            }
            if (json.data.portalList && json.data.portalList.length){

            }
            if (json.data.queryList && json.data.queryList.length){

            }
            if (json.data.serviceList && json.data.serviceList.length){

            }
            _worker._findOptionReply();
            //_worker._findMessageReply(json.data, option);
        }, function(xhr){
            _worker._findOptionReply(null);
            _worker._findMessageReply(null);
        });



},

_worker._doFindDesignerFromFilterOption = function(){
    this.filterOptionList.forEach(function(option){
        _worker._doFindDesigner(option);
    });
},
onmessage = function(e) {
    this.findData = e.data;
    _worker._setFilterOptionRegex();
    // "parser": "_findProcessPlatformParse",
    //     "actions": _worker.findData.actions,
    //     "option": option,
    //     "pattern": json.data.processPlatformList
    _worker[e.data.parser](e.data.pattern);
}