this.include({'type':'service', name:'o2ExcelUtilsV2'});
this.include({'type':'service', name:'o2PathDataUtils'});
MWF.xDesktop.requireApp("query.Query", "Importer", null, false);
/** @classdesc Importer 数据中心的导入模型。
* @class
* @o2cn 导入模型
* @o2category QueryImporter
* @o2range {QueryImporter}
* @hideconstructor
* @example
* //在导入模型的事件中获取该类
* var view = this.target;
* */
MWF.QMultiImporter = new Class(
{
Implements: [Options, Events],
Extends: MWF.widget.Common,
options: {
"style": "default"
},
initialize: function(container, json, options, app, parentMacro){
//json格式
// var json = { //使用哪些导入模型
// name: '合同信息', //下载的文件
// importers: [{ //使用哪些导入模型
// application: app, //导入模型所在应用
// name: '项目基本信息', //导入模型名称
// dataType: 'master', //第一主文档，多个master按顺序，第一个为第一主文档
// matchKeys: ['subject'] //和数据库中匹配的字段，判断导入的文档是否已经存在，进一步执行修改还是新增操作。
// },
// {
// application: app, //导入模型所在应用
// name: '外包信息', //导入模型名称
// dataType: 'master', //第二主文档
// matchMasterKeys: [{ //和主文档的关联字段
// master: 'subject', //第一主文档的字段
// slave: 'subject', //本表的字段
// }], //和主文档关联的字段名称
// },
// {
// application: app,
// name: '单一地区',
// dataType: 'slave', //下层数据
// keepOldDataKeys: ['textfield_9_0'], //dataType为slave时有效。如果有这个配置，则保留原有数据，否则置空。根据这个字段匹配导入的数据，匹配到的修改，否则新增。如果没有这个字段，则完全覆盖。
// path: 'datatemplate_9_0', //数据路径，数据表格:id.data，数据模板写id
// matchMasterKeys: [{ //和主文档的关联字段
// master: 'subject', //主文档的字段
// slave: 'subject', //本表的字段
// }], //和主文档关联的字段名称
// }, {
// application: app,
// name: '付款信息',
// dataType: 'slave', //下层数据
// clearWithEmpty: false, //修改的时候，在主文档中有数据，是否要清空本表对应的字段
// path: 'datatable_9.data', //数据路径，数据表格:id.data，数据模板写id
// matchMasterKeys: [{ //和主文档的关联字段
// master: 'subject', //主文档的字段
// slave: 'subject', //本表的字段
// }], //和主文档关联的字段名称
// }]
// };
this.setOptions(options);
this.path = "../x_component_query_Query/$Importer/";
this.cssPath = "../x_component_query_Query/$Importer/"+this.options.style+"/css.wcss";
this._loadCss();
this.lp = MWF.xApplication.query.Query.LP;
this.app = app;
this.json = json;
this.container = container;
this.parentMacro = parentMacro;
this.lookupAction = MWF.Actions.get("x_query_assemble_surface");
},
load: function(){
return new Promise((resolve)=>{
var ps = this.json.importers.map( (importerJSON)=>{
var importer = new MWF.QMultiImporter.Importer(
this.container,
importerJSON,
this.options,
this.app,
this.parentMacro
);
importer.multiImporter = this;
return importer.load();
});
return Promise.all(ps).then((arr)=>{
this.importerList = [...arr];
this.fireEvent("queryLoad");
resolve(this);
return this;
});
});
},
checkImporters: function(){
for( var i=1; i<this.importerList.length; i++ ){
var impoter = this.importerList[i];
if( !impoter.json.application ){
throw new Error(`存在未设置导入模型应用的配置（application）`);
}
if( !impoter.json.name ){
throw new Error(`存在未设置导入模型名称的配置（name）`);
}
if( !impoter.json.dataType ){
throw new Error(`存在未设置导入模型类型的配置（dataType）`);
}
if( !['master', 'slave'].includes(impoter.json.dataType) ){
throw new Error(`数据类型超过了限制（dataType的值应该限定为"master"和"slave"）`);
}
}
var mainType = this.getTargetType();
var mainTarget = this.getTarget();
var masters = this.importerList.filter((importer)=>{
return importer.isMaster();
});
if(masters.length > 1){
for( var i=1; i<masters.length; i++ ){
var impoter = masters[i];
if( mainType !== impoter.json.type ){
throw new Error(`主文档的导入类型（导入目标为内容管理或流程）不唯一`);
}
var target = impoter.json.type === 'cms' ? impoter.json.data.category : impoter.json.data.process;
if( mainTarget.id !== target.id ){
throw new Error(`主文档的导入目标不一致（${mainTarget.name}，${target.name}）`);
}
if( !impoter.json.matchMasterKeys || impoter.json.matchMasterKeys.length === 0 ){
throw new Error(`第二主文档（master）未设置和主文档的匹配关系（matchMasterKeys）`);
}
}
}
var slaves = this.importerList.filter((importer)=>{
return !importer.isMaster();
});
if(slaves.length > 0){
for( var i=1; i<slaves.length; i++ ){
var impoter = slaves[i];
if( !impoter.json.path ){
throw new Error(`从文档（slave）未设置路径（path）`);
}
if( !impoter.json.matchMasterKeys || impoter.json.matchMasterKeys.length === 0 ){
throw new Error(`从文档（slave）未设置和主文档的匹配关系（matchMasterKeys）`);
}
}
}
},
getMainImporter: function(){
if( this.mainImporter ){
return this.mainImporter;
}
var masters = this.importerList.filter((importer)=>{
return importer.isMaster();
});
this.mainImporter = masters.length ? masters[0] : this.importerList[0];
return this.mainImporter;
},
getTargetType: function(){
//导入的类型，cms还是process
return this.getMainImporter().json.type;
},
getTarget: function(){
var mainImpoter = this.getMainImporter();
return mainImpoter.json.type === 'cms' ?
mainImpoter.json.data.category :
mainImpoter.json.data.process;
},
getPathDataHandler: function (data) {
return new MWF.PathDataHandler({
type: this.getTargetType(),
processIdType: (data.workCompletedId && 'workCompleted') || (data.workId && 'work') || 'job'
});
},
createLoadding: function(){
this.loadingAreaNode = new Element("div", {"styles": this.css.viewLoadingAreaNode}).inject(this.contentAreaNode);
new Element("div", {"styles": {"height": "5px"}}).inject(this.loadingAreaNode);
var loadingNode = new Element("div", {"styles": this.css.viewLoadingNode}).inject(this.loadingAreaNode);
new Element("div", {"styles": this.css.viewLoadingIconNode}).inject(loadingNode);
var loadingTextNode = new Element("div", {"styles": this.css.viewLoadingTextNode}).inject(loadingNode);
loadingTextNode.set("text", "loading...");
},
copyView: function(){
// {
// "type": "cms",
// "viewName": "合同档案",
// "categoryList": [{
// "name": "合同档案",
// "id": "f4bc07cb-fefd-4eb0-9a1e-d7795f8d9816"
// }],
// "processList": [{
// "name": "指标流程",
// "alias": "",
// "id": "205d2d6d-8ed7-49e2-b788-1f35446a59da"
// }],
// "fieldList": ["subject"]
// }
var importer = this.getMainImporter();
var type = this.getTargetType();
var body = {
type: type,
viewName: this.json.name,
fieldList: this.getMatchKeys()
};
if( body.fieldList.length === 0 ){
return;
}
switch (type){
case 'cms':
body.categoryList = [importer.json.data.category]; break;
case 'process':
body.processList = [importer.json.data.process]; break;
default:
this.notice('导入失败，导入模型的导入目标设置成了数据表，请联系管理员！', 'error');
return;
}
this.matchViewJson = o2.Actions.load('x_program_center').InvokeAction.execute('o2ExcelViewCopyer', body, (json)=>{
return {
view: json.newViewId,
application: json.application
};
});
},
getMatchKeys: function(){
return this.importerList.map((importer)=>{
return this.getMatchKeysWithImporter(importer);
}).flat(Infinity).unique();
},
getMatchKeysWithImporter: function(importer){
if( importer.json.matchKeys ){
return importer.json.matchKeys || [];
}else if(importer.json.matchMasterKeys){
return (importer.json.matchMasterKeys || []).map((matchKey)=>{
return matchKey.master;
});
}
},
getDateColIndexArray: function (){
return this.importerList.map((importer)=>{
return importer.getDateColIndexArray();
});
},
importFromExcel: function(){
// var masters = this.json.importers.filter((importer)=>{return importer.dataType === 'master';});
// if(masters.length > 1){
// this.notice('导入失败，有两个以上导入模型同时为主数据模型，请联系管理员！', 'error');
// return;
// }
var p = !this.importerList ? this.load() : null;
Promise.resolve(p).then(()=>{
try{
this.checkImporters();
}catch (e) {
this.app.notice(e.message, 'error');
console.error(e);
return;
}
this.copyView();
this.excelImporter = new MWF.QMultiImporter.ExcelImporter({
dateColIndexes: this.getDateColIndexArray(),
needSheetName: true
});
this.progressDialog = new MWF.QMultiImporter.ProgressDialog(this);
this.progressDialog.multipleImporter = this;
var ps = [], count=0;
this.excelImporter.execute( function (importedDataList) {
this.importerList.forEach((importer)=>{
var dataExisted = importedDataList.some((imp)=>{
return imp.name === importer.json.name;
});
if(!dataExisted){
var errorText = `导入模型"${importer.json.name}"在导入的Excel文件中未找到同名的sheet表。
请重新下载模板再填写数据重复此操作。`;
this.app.notice(errorText, 'error');
throw new Error(errorText);
}
});
var checkOpenDlg = ()=>{
count++;
if( importedDataList.length === count ){
this.progressDialog.openDlg();
}
};
importedDataList.forEach((importedData, i)=>{
var {name, data} = importedData;
var importer = this.importerList.find((imp)=>{
return imp.json.name === name;
});
if( !importer ){
console.warn(`未找到名称为${name}的导入模型，跳过该sheet表的数据导入。`);
checkOpenDlg();
}else{
var p = importer.importFromExcel(data, this.progressDialog, ()=>{
checkOpenDlg();
});
ps.push(p);
}
});
Promise.all(ps).then((arr)=>{
var hasError = arr.some((result)=>{
return result.status === 'error';
});
hasError ? this.openErrorDlg(arr) : this.doImportData(arr);
});
}.bind(this));
});
},
objectToString: function (obj, type) {
if(!obj)return "";
var arr = [];
Object.each(obj, function (value, key) {
if( type === "style" ){
arr.push( key + ":"+ value +";" )
}else{
arr.push( key + "='"+ value +"'" )
}
})
return arr.join( " " )
},
openErrorDlg : function(resultList){
if(this.progressDialog)this.progressDialog.close();
var _self = this;
var div = new Element("div", { style : "padding:10px;" });
var dlg = o2.DL.open({
"style" : "user",
"title": this.lp.importFail,
"content": div,
"offset": {"y": 0},
"isMax": true,
"width": 1000,
"height": 700,
"buttonList": [
// {
// "type": "exportWithError",
// "text": this.lp.exportExcel,
// "action": function () { _self.exportWithImportDataToExcel(); }
// },
{
"type": "cancel",
"text": this.lp.cancel,
"action": function () { dlg.close(); }
}
],
"onPostShow": function () {
var contentStyles = Object.clone( this.css.contentStyles );
if( !contentStyles[ "border-bottom" ] && !contentStyles[ "border" ] )contentStyles[ "border-bottom" ] = "1px solid #eee";
var contentStyleStr = this.objectToString( Object.merge( contentStyles, {"text-align":"left"}) , "style" );
var htmlArray = [];
resultList.forEach((result)=>{
htmlArray.push(`<div style='font-size:16px;margin-bottom:5px;'>${result.importer.json.name}：</div>`)
htmlArray.push("<table "+ this.objectToString( this.css.properties ) +" style='"+this.objectToString( this.css.tableStyles, "style" )+"'>");
if(result.status==='error'){
htmlArray.push( result.importer._getErrorHeadHtml() );
htmlArray.push( result.importer._getErrorContentHtml() );
}else{
htmlArray.push(
`<tr><td style=${contentStyleStr}><div style='color:green;'>校验通过</div></td></tr>`
);
}
htmlArray.push( "</table>" );
htmlArray.push("<div style='height:15px;'></div>")
})
div.set("html" , htmlArray.join(''));
}.bind(this),
"onPostClose": function(){
dlg = null;
}.bind(this)
});
},
openResultDlg : function(resultList){
if(this.progressDialog)this.progressDialog.close();
var _self = this;
var div = new Element("div", { style : "flex:1;height: calc( 100% - 30px );" });
var dlg = o2.DL.open({
"style" : "user",
"title": '导入详情',
"content": div,
"offset": {"y": 0},
"isMax": true,
"width": '90%',
"height": '90%',
"buttonList": [
{
"type": "cancel",
"text": '关闭',
"action": function () { dlg.close(); }
}
],
"onPostShow": function () {
MWF.xDesktop.requireApp("query.Query", "Statement", function () {
debugger;
this.statement = new MWF.xApplication.query.Query.Statement(dlg.content.getFirst(), {
"statementName" : "o2ExcelMultipleImportDataLog",
"filter": [
{
"path":"o.mainLogId", //查询语句格式为jpql使用o.title，为原生sql中使用xtitle
"comparison":"equals",
"value": this.log.id,
"formatType":"textValue"
}
]
}, {}, this.app, this.parentMacro);
}.bind(this));
}.bind(this),
"onPostClose": function(){
dlg = null;
}.bind(this)
});
},
getBusinessData : function(importer, d){
var data;
switch(importer.json.type){
case 'cms': data = d.docData; break;
case 'process': data = d.data; break;
default: data = d.srcData; break;
}
return data;
},
parseData: function(resultList){
console.log('resultList', resultList);
var masters = resultList.filter((r)=>{return r.importer.isMaster();});
var mainResult = masters[0] || null;
resultList.forEach((result)=>{
if( result !== mainResult ){
if( result.importer.isMaster() ){
result.masterDataMap = this.masterToMasterDataMap(result);
}else{
result.masterDataMap = this.slaveToMasterDataMap(result);
}
}
});
//处理主数据
if(mainResult){
var r = mainResult.importer;
var masterData = r.getData();
masterData.forEach((d)=>{
d.sheetNames = [r.json.name];
});
resultList.forEach((result)=>{
if( result === mainResult ){
return;
}
var matchMasterKeys = result.importer.json.matchMasterKeys;
masterData.forEach((d)=>{
var data = this.getBusinessData(r, d);
var key = matchMasterKeys.map((obj)=>{ return data[obj.master]; }).join('_');
if( result.masterDataMap[key] ){
d.sheetNames.push(result.importer.json.name);
if(result.importer.isMaster()){
var doc = result.masterDataMap[key].doc;
this._mergeObject(data, doc);
}else{
this.setDataWithPath(data, result.importer.json.path, result.masterDataMap[key].list);
}
delete result.masterDataMap[key];
}else if(result.importer.json.clearWithEmpty){
if(result.importer.isMaster()){
var emptyData = result.importer.getEmptyData();
this._mergeObject(data, emptyData);
}else{
this.setDataWithPath(data, result.importer.json.path, []);
}
}
});
});
mainResult.masterData = masterData;
}
//处理没有主数据的从数据
resultList.forEach((result)=>{
if( result === mainResult ){
return;
}
var importer = result.importer;
var matchMasterKeys = importer.json.matchMasterKeys;
var masterBusinessData = [];
Object.each(result.masterDataMap, (d, key)=>{
var data;
if( result.importer.isMaster() ){
if( d.doc ){
data = d.doc;
matchMasterKeys.forEach((obj)=>{
if( obj.master !== obj.slave ){
data[obj.master] = data[obj.slave];
}
});
masterBusinessData.push(data);
}
}else{
if( d.list && d.list.length > 0 ){
data = {};
matchMasterKeys.forEach((obj)=>{
data[obj.master] = d.list[0][obj.slave];
});
this.setDataWithPath(data, d.path, d.list);
masterBusinessData.push(data);
}
}
});
result.masterBusinessData = masterBusinessData;
});
},
_mergeObject : function(oldObj, newObj){
for( var fieldName in newObj ){
if( !oldObj.hasOwnProperty( fieldName ) ){
oldObj[fieldName] = newObj[ fieldName ];
}
}
},
masterToMasterDataMap: function (secondMasterResult){
var r = secondMasterResult.importer;
var slaveDataList = r.getData();
var map = {};
var matchMasterKeys = r.json.matchMasterKeys;
slaveDataList.forEach((d)=>{
var data = this.getBusinessData(r, d);
var key = matchMasterKeys.map((obj)=>{ return data[obj.slave]; }).join('_');
!map[key] && (map[key] = {key: key, path:r.json.path, doc: data});
});
return map;
},
slaveToMasterDataMap: function(slaveResult){
var r = slaveResult.importer;
var slaveDataList = r.getData();
var map = {};
var matchMasterKeys = r.json.matchMasterKeys;
slaveDataList.forEach((d)=>{
var data = this.getBusinessData(r, d);
var key = matchMasterKeys.map((obj)=>{ return data[obj.slave]; }).join('_');
!map[key] && (map[key] = {key: key, path:r.json.path, list: []});
map[key].list.push(data);
});
return map;
},
matchDoc: function (result){
if( !this.matchViewJson ){
return;
}
var matchKeys = this.getMatchKeysWithImporter(result.importer);
if( !matchKeys.length ){
return;
}
var allList = [];
var matchObjList = matchKeys.map((key)=>{
var list = [];
if( result.masterData ){
list = result.masterData.map((data)=>{
return this.getDataWithPath(data.docData || data.data || data.srcData, key);
});
allList = allList.concat(list);
}else if(result.masterDataMap){
Object.each(result.masterDataMap, (data, key1)=>{
if( data.list ){
data.list.forEach((d)=>{
list.push( this.getDataWithPath(d, key));
allList = allList.concat(list);
});
}else if(data.doc){
list.push( this.getDataWithPath(data.doc, key));
allList = allList.concat(list);
}
});
}
return {key: key, list: list.filter((d)=>{ return !!d; }).unique()};
});
if( !allList.length ){
return;
}
return Promise.resolve(this.matchViewJson).then((viewJson)=>{
viewJson.filter = matchObjList.map((matchObj)=>{
return {
"logic":"and",
"path": matchObj.key,
"comparison":"in",
"value": matchObj.list.join(','),
"formatType":"textValue"
};
});
return o2.api.view.lookup(viewJson).then((data)=>{
//data 为返回的数据。
var map = {};
data.grid.forEach((row)=>{
var mapKey = matchKeys.map(key=>{
return row.data[key];
}).join('_');
map[mapKey] = row;
});
if( result.masterData ){
result.masterData.forEach((data)=>{
var mapKey = matchKeys.map(key=>{
return this.getDataWithPath(data.docData || data.data || data.srcData, key);
}).join('_');
!!map[mapKey] && this._setDataWithViewData(map[mapKey], data);
});
}else if(result.masterBusinessData){
result.masterBusinessData.forEach((data)=>{
var mapKey = matchKeys.map(key=>{
return this.getDataWithPath(data, key);
}).join('_');
!!map[mapKey] && this._setDataWithViewData(map[mapKey], data);
});
}
});
});
},
_setDataWithViewData: function (viewData, data){
data.id = viewData.bundle;
!!viewData.data.workId && (data.workId = viewData.data.workId);
!!viewData.data.workCompletedId && (data.workCompletedId = viewData.data.workCompletedId);
!!viewData.data.completed && (data.completed = viewData.data.completed);
},
parseOperation: function(resultList){
var mainImporter = this.getMainImporter();
resultList.forEach((result)=>{
if( result.importer === mainImporter ){
result.operationPaths = resultList.filter(item=>{
return item.importer.hasOperation();
}).map((item)=>{
return item.importer.json.path;
});
}else if( result.importer.hasOperation() ){
result.operationPaths = [result.importer.json.path];
}
});
},
doImportData: function(resultList){
debugger;
resultList.forEach((r)=>{
if( r.importer !== this.getMainImporter() ){
r.importer.progressBar.hide();
}else{
r.importer.progressBar.setMessageTitle(`正在往“${this.getTarget().name}”导入数据`);
}
})
// if(this.progressDialog)this.progressDialog.close();
//创建数据
//再次校验数据（计算的内容）
var date = new Date();
this.parseData(resultList);
this.parseOperation(resultList);
//总导入主文档数
this.totalCount = 0;
resultList.forEach( (result)=>{
if( result.masterData ) {
result.totalCount = result.masterData.length;
this.totalCount += result.totalCount;
}else if(result.masterDataMap){
result.totalCount = Object.keys(result.masterDataMap).length;
this.totalCount += result.totalCount;
}
})
if(this.totalCount === 0){
if(this.progressDialog)this.progressDialog.close();
this.notice('从Excel文件中未获取到需要导入的数据，导入结束', 'error')
}
var actionPromises = [];
var completedCount = 0;
var checkAllCompleted = ()=>{
completedCount++;
if( resultList.length === completedCount ){
Promise.allSettled(actionPromises).then(() => {
this._saveLog();
});
}
}
//保存主数据
resultList.forEach( (result)=>{
var p = this.matchDoc(result);
Promise.resolve(p).then(()=>{
console.log(result.masterData || result.masterBusinessData);
if( result.masterData ){
result.masterData.forEach((d)=>{
var promise;
switch (this.getTargetType()) {
case 'cms':
promise = !!d.id ? this.updateDocument(result, d) : this.createDocument(result, d); break;
case 'process':
promise = !!d.id ? this.updateWork(result, d) : this.createWork(result, d); break;
}
actionPromises.push(promise);
});
}else{
var isMaster = result.importer.isMaster();
result.masterBusinessData.forEach((d)=>{
if(!d.id){
this.logFailure(result, d, '根据关键字未在系统和主表中匹配到主数据。');
}else{
var promise;
switch (this.getTargetType()) {
case 'cms':
promise = isMaster ? this.updateDocument(result, d, true) : this.updateDocumentPartData(result, d); break;
case 'process':
promise = isMaster ? this.updateWork(result, d, true) : this.updateWorkPartData(result, d); break;
}
actionPromises.push(promise);
}
});
}
checkAllCompleted();
})
});
},
getErrorText: function (xhr) {
var responseJSON = JSON.parse( (err.xhr || err).responseText || '' );
return responseJSON.message; //message为错误提示文本
},
getKeepOldDataConfigs: function(data){
if(this.keepOldDataConfig)return this.keepOldDataConfig;
this.keepOldDataConfig = this.json.importers.filter((importer)=>{
return importer.keepOldDataKeys && importer.keepOldDataKeys.length > 0;
});
return this.keepOldDataConfig;
},
getPathDataMatchId: function (data){
return this.getTargetType() === 'process' ?
data.workCompletedId || data.workId || data.id :
data.id;
},
handleKeepOldData: function (result, data){
var configs = this.getKeepOldDataConfigs();
var d = data.docData || data.data || data.srcData || data;
return configs.map(config => {
var pathData = this.getDataWithPath(d, config.path) || [];
if( pathData.length ){
var handler = this.getPathDataHandler( data );
var id = this.getPathDataMatchId(data);
var p = handler.get(id, config.path.split('.')) || [];
p.then((json)=>{
var oldData = json.data || [];
var needPushData = [];
pathData.forEach(newObj=>{
var matchOldObj = oldData.find(oldObj=>{
var isMatch = true;
for( var i=0; i<config.keepOldDataKeys.length; i++ ){
var key = config.keepOldDataKeys[i];
if( !newObj[key] || newObj[key] !== oldObj[key] ){
isMatch = false;
}
}
return isMatch;
});
if( matchOldObj ){
for(var key in newObj){
matchOldObj[key] = newObj[key];
}
}else{
needPushData.push(newObj);
}
});
if(needPushData.length > 0){
oldData.push(...needPushData);
}
this.setDataWithPath(d, config.path, oldData);
});
return p;
}
});
},
handleOperation: function (result, data) {
var operationPaths = result.operationPaths;
if( !operationPaths || !operationPaths.length ){
return [];
}
//处理从数据中带操作的 $operation 包含覆盖/新增
var d = data.docData || data.data || data.srcData || data;
return operationPaths.map( (operationPath)=>{
var pathData = this.getDataWithPath(d, operationPath) || [];
var pathImporter = this._getImporterWithPath(operationPath);
if( !pathData.length && pathImporter?.json.clearWithEmpty ){
return;
}
var hasCover = pathData.some(item=>{
return item.$operation === '覆盖';
});
if( !hasCover ){
var handler = this.getPathDataHandler( data );
var id = this.getPathDataMatchId(data);
var p = handler.get(id, operationPath.split('.')) || [];
p.then((json)=>{
var oldData = json.data || [];
oldData = oldData.concat(pathData);
this.setDataWithPath(d, operationPath, oldData);
});
return p;
}
});
},
_getImporterWithPath: function (path){
return this.importerList.find(function(importer){
return importer.json.path === path;
});
},
updateDocumentPartData: function(result, data){
var ps1 = this.handleOperation(result, data);
return Promise.all(ps1).then(() => {
var ps2 = this.handleKeepOldData(result, data);
return Promise.all(ps2).then(()=> {
const method = o2.Actions.load('x_cms_assemble_control').DataAction.updateWithDocument;
return method(data.id, data, (json) => {
return this.logSuccess(result, data, '修改数据');
}, (xhr) => {
this.logFailure(result, data, this.getErrorText(xhr));
return true;
});
});
})
},
updateDocument: function(result, data, partFlag){
var ps1 = this.handleOperation(result, data);
return Promise.all(ps1).then(() => {
var ps2 = this.handleKeepOldData(result, data);
return Promise.all(ps2).then(()=>{
const method = o2.Actions.load('x_cms_assemble_control').DataAction.updateWithDocument;
return method(data.id, partFlag ? data : data.docData, (json)=>{
return this.logSuccess(result, data, '修改数据');
}, (xhr)=>{
this.logFailure(result, data, this.getErrorText(xhr));
return true;
});
});
})
},
createDocument: function(result, data){
const method = o2.Actions.load('x_cms_assemble_control').DocumentAction.persist_publishContent;
return method(data, (json)=>{
data.id = json.data.id;
return this.logSuccess(result, data, '创建文档');
}, (xhr)=>{
this.logFailure(result, data, this.getErrorText(xhr));
return true;
});
},
updateWorkPartData: function(result, data){
var ps1 = this.handleOperation(result, data);
return Promise.all(ps1).then(() => {
var ps2 = this.handleKeepOldData(result, data);
return Promise.all(ps2).then(()=> {
const method = o2.Actions.load('x_processplatform_assemble_surface').DataAction.updateWithJob;
return method(data.id, data, (json) => {
return this.logSuccess(result, data, '修改数据');
}, (xhr) => {
this.logFailure(result, data, this.getErrorText(xhr))
return true;
})
});
})
},
updateWork: function(result, data, partFlag){
var ps1 = this.handleOperation(result, data);
return Promise.all(ps1).then(() => {
var ps2 = this.handleKeepOldData(result, data);
return Promise.all(ps2).then(()=> {
const method = o2.Actions.load('x_processplatform_assemble_surface').DataAction.updateWithJob;
return method(data.id, partFlag ? data : data.data, (json) => {
return this.logSuccess(result, data, '修改数据');
}, (xhr) => {
this.logFailure(result, data, this.getErrorText(xhr))
return true;
})
});
})
},
createWork: function(result, data){
var mainImpoter = this.getMainImporter();
if( mainImpoter.json.data.processStatus === "completed" ){
this._createWorkCompleted(result, data);
}else{
this._createWork(result, data);
}
},
_createWorkCompleted: function(result, data){
const method = o2.Actions.load('x_processplatform_assemble_surface').WorkCompletedAction.create;
return method(this.getTarget().id, data, (json)=>{
data.id = json.data.id;
return this.logSuccess(result, data, '发起流程(结束)');
}, (xhr)=>{
this.logFailure(result, data, this.getErrorText(xhr));
return true;
});
},
_createWork: function(result, data){
const method = o2.Actions.load('x_processplatform_assemble_surface').WorkAction.create;
return method(this.getTarget().id, data, (json)=>{
data.id = json.data[0].job;
return this.logSuccess(result, data, '发起流程');
}, (xhr)=>{
this.logFailure(result, data, this.getErrorText(xhr));
return true;
});
},
logFailure: function(result, data, errorText){
return this._addlog(result, data, null, errorText);
},
logSuccess: function(result, data, operationType){
return this._addlog(result, data, operationType);
},
_addlog: function(result, data, operationType, errorText, saveFlag){
var importer = result.importer;
var mainImpoter = this.getMainImporter();
if(!this.log){
this.log = {
"person": layout.session.user.distinguishedName,
"fileName": this.excelImporter.file.name,
"totalCount": this.totalCount,
"successCount": 0,
"failureCount": 0,
"importerName": this.importerList.map((importer)=>{return importer.json.name}),
"importer": this.importerList.map((importer)=>{return importer.json.id}),
"targetType": mainImpoter.json.type,
"targetName": this.getTarget().name,
"targetId": this.getTarget().id,
}
!errorText ? this.log.successCount++ : this.log.failureCount++;
mainImpoter.progressBar.showImporting(this.log);
this.logTable = new o2.api.Table('o2ExcelMultipleImportLog');
this.logTable.addRow(this.log, (json)=>{
this.log.id = json.data.id;
return importer.saveLog(this.log, data, operationType, errorText);
}, null, false);
}else{
!errorText ? this.log.successCount++ : this.log.failureCount++;
mainImpoter.progressBar.showImporting(this.log);
if(!!saveFlag)this.logTable.updateRow(this.log.id, this.log);
return importer.saveLog(this.log, data, operationType, errorText);
}
},
_saveLog: function(){
if(this.log && this.logTable){
return this.logTable.updateRow(this.log.id, this.log, null, null, false);
}
},
getDataWithPath: function(obj, path){
var idList = path.split(".");
idList = idList.map( function(d){ return d.test(/^\d+$/) ? d.toInt() : d; });
var lastIndex = idList.length - 1;
for(var i=0; i<=lastIndex; i++){
var id = idList[i];
if( !id && id !== 0 )return null;
if( ["object","array"].contains(o2.typeOf(obj)) ){
if( i === lastIndex ){
return obj[id];
}else{
obj = obj[id];
}
}else{
return null;
}
}
},
setDataWithPath: function(obj, path, data){
var isNumberString = function(string){
return string.toInt().toString() === string;
}
var names = path.split(".");
var d = obj;
Array.each(names, function (n, idx) {
if( idx === names.length -1 )return;
if ( !d[n] ){
var value = isNumberString( names[idx+1] ) ? [] : {};
var n1 = isNumberString( n ) ? n.toInt() : n;
d[n1] = value;
d = d[n1];
}else{
d = d[n];
}
}.bind(this));
d[names[names.length -1]] = data;
},
exportWithImportDataToExcel : function ( importData ) {
if( !this.excelExporter ){
this.excelExporter = new MWF.QMultiImporter.ExcelExporter();
}
var exportTo = function () {
var resultArr = [];
var titleArr = this.getTitleArray();
titleArr.push( this.lp.validationInfor );
resultArr.push( titleArr );
if( importData ){
importData.each( function (lineData, lineIndex) {
var array = [];
if( o2.typeOf(lineData)==="array" ) {
lineData.each(function (d, i) {
array.push((d || '').replace(/ /g, "\n"));
});
}else if(o2.typeOf(lineData)==="object"){
this.json.data.columnList.each( function (columnJson, i) {
array.push( lineData[columnJson.path] || "" )
}.bind(this));
if( lineData["o2ErrorText"] ){
array.push( lineData["o2ErrorText"] );
}
}
resultArr.push( array );
}.bind(this));
}else{
this.rowList.each( function( row, lineIndex ){
var lineData = row.importedData;
var array = [];
for( var i=0; i<lineData.length; i++ ){
var d = ( lineData[i] || '' ).replace(/ /g, "\n");
array.push( d );
}
// lineData.each( function (d, i) {
// array.push( ( d || '' ).replace(/ /g, "\n") );
// });
array.push( row.errorTextListExcel ? row.errorTextListExcel.join("\n") : "" );
resultArr.push( array );
}.bind(this));
}
var colWidthArray = this.getColWidthArray();
colWidthArray.push(260);
var arg = {
data : resultArr,
colWidthArray : colWidthArray,
title : this.getFileName()
};
this.fireEvent("export", [arg]);
this.excelExporter.execute(
arg.data,
arg.title,
arg.colWidthArray,
this.getDateIndexArray()
)
}.bind(this);
if( !this.importerJsonList ){
this.getImporterJsonList( function () {
exportTo();
}.bind(this))
}else{
exportTo();
}
},
downloadTemplate: function(fileName, callback){
var p = !this.importerList ? this.load() : null;
return Promise.resolve(p).then(()=>{
var args = this.importerList.map((importer)=>{
return {
data : [importer.getTitleArray()],
sheetName: importer.getFileName(),
colWidthArray : importer.getColWidthArray(),
dateIndexArray: importer.getDateIndexArray()
};
});
//if(callback)callback(args);
var excelExporter = new MWF.QMultiImporter.ExcelExporter({
fileName: this.getFileName(fileName),
worksheet: args.map((arg)=>{
return {
isTemplate: true,
sheetName: arg.sheetName,
colWidthArray: arg.colWidthArray,
dateIndexArray: arg.dateIndexArray
};
})
});
return excelExporter.execute(
args.map( (arg)=> {return arg.data;} ),
callback
);
});
},
getFileName: function(fileName){
var title = fileName || this.json.name;
var titleA = title.split(".");
if( ["xls","xlst"].contains( titleA[titleA.length-1].toLowerCase() ) ){
titleA.splice( titleA.length-1 );
}
title = titleA.join(".");
return title;
},
//api 使用 开始
confirm: function (type, e, title, text, width, height, ok, cancel, callback, mask, style) {
this.app.confirm(type, e, title, text, width, height, ok, cancel, callback, mask, style)
},
alert: function (type, title, text, width, height) {
this.app.alert(type, "center", title, text, width, height);
},
notice: function (content, type, target, where, offset, option) {
this.app.notice(content, type, target, where, offset, option)
}
//api 使用 结束
});
MWF.QMultiImporter.Importer = new Class({
Extends: MWF.QImporter,
load: function( callback ){
//this.excelUtils = new MWF.xApplication.query.Query.Importer.ExcelUtils();
var ps = [this.getImporterJSON(), this.loadMacro()];
return Promise.all(ps).then(()=>{
this._loadModuleEvents();
this.fireEvent("queryLoad");
//this.importFromExcel();
if(callback)callback();
return this;
});
},
isMaster: function (){
return this.json.dataType === 'master';
},
hasOperation: function(){
if( this.isMaster() ){
return false;
}
return this.json.data.columnList.some((column)=>{
return column.path === "$operation";
});
},
getEmptyData: function(){
var data = {};
this.json.data.columnList.each( function (columnJson, i) {
var dataType = this.json.type === "dynamicTable" ? columnJson.dataType_Querytable : columnJson.dataType_CMSProcess;
var value;
switch ( dataType ) {
case "string":
value = ''; break;
case "stringList":
value = []; break;
case "number":
case "integer":
case "long":
case "double":
value = ''; break;
case "numberList":
case "integerList":
case "longList":
case "doubleList":
value = []; break;
case "date":
case "dateTime":
value = ''; break;
case "dateList":
case "dateTimeList":
value = []; break;
case "boolean":
value = ''; break;
case "booleanList":
value = []; break;
case "json":
case "stringMap":
value = ''; break;
default:
value = ''; break;
}
this.multiImporter.setDataWithPath(data, columnJson.path, value);
}.bind(this));
return data;
},
getSampleData: function (d){
var mainImporter = this.multiImporter.getMainImporter();
var data = this.multiImporter.getBusinessData(mainImporter, d) || d;
var sampleData = [];
var columnList = mainImporter.json.data.columnList;
for( var i=0; i<columnList.length && i<10; i++ ){
var column = columnList[i];
sampleData.push({
t: column.displayName,
v: this.multiImporter.getDataWithPath(data, column.path) || ''
});
}
return sampleData;
},
saveLog: function(mainLog, data, operationType, errorText){
if( !this.logTable )this.logTable = new o2.api.Table("o2ExcelMultipleImportDataLog");
// {
// "person": "",
// "fileName": "",
// "sheetName": "",
// "status": "",
// "errorText": "",
// "importerName": "",
// "importer": "",
// "targetType": "",
// "targetName": "",
// "targetId": "",
// "data": "",
// "docId": "",
// "mainLogId": ""
// }
var log = {
...mainLog,
sheetName: data.sheetNames?.length ? data.sheetNames.join(', ') : this.json.name,
status: !errorText ? 'success' : 'failure',
errorText: errorText || '',
importerName: this.json.name,
importer: this.json.id,
data: JSON.stringify(data),
sampleData: JSON.stringify(this.getSampleData(data)),
docId: data.id,
mainLogId: mainLog.id,
operationType: operationType
}
delete log.id;
return this.logTable.addRow(log);
},
importFromExcel: function (importedData, progressDialog, callback){
return new Promise((resolve)=>{
if( this.importerJson && this.json ){
this._importFromExcel(importedData, progressDialog, resolve, callback);
}else{
this.load(()=>{
this._importFromExcel(importedData, progressDialog, resolve, callback);
});
}
});
},
_importFromExcel: function( importedData, progressDialog, resolve, callback){
this.rowList = [];
this.identityMapImported = {};
this.personMapImported = {};
this.unitMapImported = {};
this.groupMapImported = {};
this.lookupAction.getUUID( function (json){
this.recordId = json.data;
}.bind(this), null, false);
importedData = importedData.filter(function (array) {
for( var i=0; i<array.length; i++ ){
if(array[i])return true;
}
return false;
});
if( !importedData.length ){
if(callback)callback();
resolve({status: 'success', importer: this});
}
var titleLength = importedData[0].length;
importedData.each(function (array) {
for( var i=0; i<titleLength; i++){
if( typeOf(array[i]) === "null" )array[i] = "";
}
});
progressDialog.addEvent('postShow', function(){
this.progressBar = new MWF.QMultiImporter.ProgressBar(this, progressDialog);
this.progressBar.showCheckData();
var level = this.getTitleLevel();
if( importedData.length >= level ){
importedData.splice(0, level);
this.importedData = importedData;
}else{
this.importedData = [];
}
this.fireEvent("beforeImport", [this.importedData]);
Promise.resolve( this.importedData.promise ).then(function () {
this.listOrgDataFromDb(
this.getImportedOrgData(),
function () {
this.importedData.each( function( lineData, lineIndex ){
this.rowList.push( new MWF.QMultiImporter.Row( this, lineData, lineIndex ) );
}.bind(this));
var isValid = this.json.enableValid ? this.checkImportedData() : this.checkNecessaryImportedData();
Promise.resolve(isValid).then(function ( isValid1 ) {
if( isValid1 ){
//this.doImportData(resolve);
resolve({status: 'success', importer: this});
}else{
//this.openImportedErrorDlg();
this.progressBar.setMessageText('导入失败：校验未通过');
resolve({status: 'error', importer: this});
}
}.bind(this));
}.bind(this)
);
}.bind(this));
this.progressBar.importerId = this.importerId;
}.bind(this));
if(callback)callback();
},
//**适配老版本，新版本中已修改 start
loadMacro: function (callback) {
return new Promise((resolve) => {
MWF.require("MWF.xScript.Macro", function () {
this.Macro = new MWF.Macro.ViewContext(this);
if (callback) callback();
resolve();
}.bind(this));
})
},
getImporterJSON: function(callback){
return new Promise( (resolve, reject)=> {
if( this.importerJson && this.json ){
resolve(this.json);
if (callback) callback();
}else{
if (this.json.name){
this.lookupAction.getImportModel(this.json.name, this.json.application, function(json){
this.importerId = json.data.id;
this.importerJson = JSON.decode(json.data.data);
json.data.data = this.importerJson;
this.json = Object.merge(this.json, json.data);
resolve(this.json);
if (callback) callback();
}.bind(this));
}else{
this.lookupAction.getImportModelById(this.json.id, function(json){
this.importerId = json.data.id;
this.importerJson = JSON.decode(json.data.data);
json.data.data = this.importerJson;
this.json.application = json.data.query;
this.json = Object.merge(this.json, json.data);
resolve(this.json);
if (callback) callback();
}.bind(this));
}
}
});
},
_getErrorHeadHtml: function () {
var htmlArray = [];
var titleStyle = this.objectToString( this.css.titleStyles, "style" );
var vaildTitleStyles = this.objectToString( this.css.vaildTitleStyles, "style" );
htmlArray.push( "<tr>" );
this.json.data.columnList.each( function (columnJson, i) {
htmlArray.push( "<th style='"+titleStyle+"'>"+o2.txt(columnJson.displayName)+"</th>" );
});
htmlArray.push( "<th style='"+vaildTitleStyles+"'> "+this.lp.validationInfor +"</th>" );
htmlArray.push( "</tr>" );
return htmlArray.join("");
},
_getErrorContentHtml: function (){
var htmlArray = [];
var contentStyles = Object.clone( this.css.contentStyles );
if( !contentStyles[ "border-bottom" ] && !contentStyles[ "border" ] )contentStyles[ "border-bottom" ] = "1px solid #eee";
var contentStyle = this.objectToString( Object.merge( contentStyles, {"text-align":"left"}) , "style" );
var validContentStyles = this.objectToString( this.css.validContentStyles, "style" );
this.rowList.each( function( row, lineIndex ){
var lineData = row.importedData;
htmlArray.push( "<tr>" );
this.json.data.columnList.each( function (columnJson, i) {
var d = lineData[ i ];
var text = typeOf(d) === "string" ? ( d || '' ).replace(/ /g,"<br/>") : d;
htmlArray.push( "<td style='"+contentStyle+"'>"+ o2.txt(text) +"</td>" ); //换行符
});
htmlArray.push( "<td style='"+validContentStyles+"'>"+( row.errorTextList ? row.errorTextList.join("<br/>") : "" )+"</td>" );
htmlArray.push( "</tr>" );
}.bind(this));
return htmlArray.join("");
},
getTitleData: function (){
var titleDataParsed = [];
this.getTitleArray().each(function (title, i){
var text = o2.typeOf(title) === 'object' ? title.text : title;
var texts = ( text || " " ).split('\\');
titleDataParsed.push( texts );
});
return titleDataParsed;
},
getTitleLevel: function (){
var maxTitleLevel = 1;
this.getTitleArray().each(function (title, i){
var text = o2.typeOf(title) === 'object' ? title.text : title;
var texts = ( text || " " ).split('\\');
maxTitleLevel = Math.max( maxTitleLevel, texts.length );
});
return maxTitleLevel;
},
getTitleArray: function(){
return this.json.data.columnList.map( function (columnJson, i) {
var obj = {
text: columnJson.displayName
};
if( columnJson.optionScript ){
obj.options = this.Macro.exec(columnJson.optionScript, this);
}
return obj;
}.bind(this));
}
//**适配老版本，新版本中已修改 end
});
MWF.QMultiImporter.Row = new Class({
Extends: MWF.QImporter.Row,
checkCMS : function( notCheckName ){
if( !this.importer.isMaster() ){
return;
}
var lp = this.lp;
var errorTextList = [];
var errorTextListExcel = [];
var data = this.document.identity;
if(!data){
errorTextList.push( this.getCol("identity", false) + lp.noDrafter + lp.fullstop );
errorTextListExcel.push( this.getCol("identity", true) + lp.noDrafter + lp.fullstop );
}else if(data.split("@").getLast().toLowerCase() !== "i"){
errorTextList.push( this.getCol("identity", false) + '"'+ data +'"'+ lp.drafterIsNotIdentity + lp.fullstop );
errorTextListExcel.push( this.getCol("identity", true) + '"'+ data +'"'+ lp.drafterIsNotIdentity + lp.fullstop );
}
data = this.document.publishTime;
if(!data){
errorTextList.push(this.getCol("publishTime", false) + lp.noPublishTime + lp.fullstop );
errorTextListExcel.push(this.getCol("publishTime", false) + lp.noPublishTime + lp.fullstop );
}else if( ! new Date(data).isValid() ){
errorTextList.push(this.getCol("publishTime", false) + '"'+ data +'"'+ lp.publishTimeFormatError + lp.fullstop );
errorTextListExcel.push(this.getCol("publishTime", false) + '"'+ data +'"'+ lp.publishTimeFormatError + lp.fullstop );
}
data = this.document.title;
if( data && data.length > 70){
errorTextList.push(this.getCol("title", false) + '"'+ data +'"'+ lp.cmsTitleLengthInfor + lp.fullstop );
errorTextListExcel.push(this.getCol("title", false) + '"'+ data +'"'+ + lp.cmsTitleLengthInfor + lp.fullstop );
}
data = this.document.summary;
if( data && data.length > 70 ){
errorTextList.push(this.getCol("summary", false) + '"'+ data +'"'+ lp.cmsSummaryLengthInfor + lp.fullstop );
errorTextListExcel.push( this.getCol("summary", false) + '"'+ data +'"'+ lp.cmsSummaryLengthInfor + lp.fullstop );
}
this.errorTextList = this.errorTextList.concat( errorTextList );
this.errorTextListExcel = this.errorTextListExcel.concat( errorTextListExcel );
if(errorTextList.length > 0){
return false;
}
return true;
},
checkProcess : function( notCheckName ){
if( this.importer.isMaster() ){
return;
}
var lp = this.lp;
var json = this.importer.json;
var columnText = lp.importValidationColumnText;
var columnTextExcel = lp.importValidationColumnTextExcel;
var errorTextList = [];
var errorTextListExcel = [];
var data = this.work.identity;
if(!data){
errorTextList.push( this.getCol("identity", false) + lp.noDrafter + lp.fullstop );
errorTextListExcel.push( this.getCol("identity", true) + lp.noDrafter + lp.fullstop );
}else if(data.split("@").getLast().toLowerCase() !== "i"){
errorTextList.push( this.getCol("identity", false) + '"'+ data +'"'+ lp.drafterIsNotIdentity + lp.fullstop );
errorTextListExcel.push( this.getCol("identity", true) + '"'+ data +'"'+ lp.drafterIsNotIdentity + lp.fullstop );
}
if( json.data.processStatus === "completed" ){
if(!this.work.form){
errorTextList.push( lp.noForm + lp.fullstop );
errorTextListExcel.push( lp.noForm + lp.fullstop );
}
data = this.work.startTime;
if(!data){
errorTextList.push(this.getCol("startTime", false) + lp.noStartTime + lp.fullstop );
errorTextListExcel.push(this.getCol("startTime", false) + lp.noStartTime + lp.fullstop );
}else if( ! new Date(data).isValid() ){
errorTextList.push(this.getCol("startTime", false) + '"'+ data +'"'+ lp.startTimeFormatError + lp.fullstop );
errorTextListExcel.push(this.getCol("startTime", false) + '"'+ data +'"'+ lp.startTimeFormatError + lp.fullstop );
}
data = this.work.completeTime;
if(!data){
errorTextList.push(this.getCol("completeTime", false) + lp.noEndTime + lp.fullstop );
errorTextListExcel.push(this.getCol("completeTime", false) + lp.noEndTime + lp.fullstop );
}else if( ! new Date(data).isValid() ){
errorTextList.push(this.getCol("completeTime", false) + '"'+ data +'"'+ lp.endTimeFormatError + lp.fullstop );
errorTextListExcel.push(this.getCol("completeTime", false) + '"'+ data +'"'+ lp.endTimeFormatError + lp.fullstop );
}
}
this.errorTextList = this.errorTextList.concat( errorTextList );
this.errorTextListExcel = this.errorTextListExcel.concat( errorTextListExcel );
if(errorTextList.length > 0){
return false;
}
return true;
},
//适配老版本，新版本中已修改 start
checkValid : function(){
var lp = this.lp;
var columnText = lp.importValidationColumnText;
var columnTextExcel = lp.importValidationColumnTextExcel;
var errorTextList = [];
var errorTextListExcel = [];
var excelUtils = MWF.ExcelUtilsV2 || this.importer.excelUtils;
this.importer.json.data.columnList.each( function (columnJson, i) {
var colName = excelUtils.index2ColName( i );
var colInfor = columnText.replace( "{n}", (i+1)+"("+colName+")" );
var colInforExcel = columnTextExcel.replace( "{n}", colName );
var value = this.importedData[i] || "";
var dataType = this.importer.json.type === "dynamicTable" ? columnJson.dataType_Querytable : columnJson.dataType_CMSProcess;
if( !columnJson.allowEmpty && !value ){
errorTextList.push( colInfor + lp.canNotBeEmpty + lp.fullstop );
errorTextListExcel.push( colInforExcel + lp.canNotBeEmpty + lp.fullstop );
}
if( columnJson.validInOption && columnJson.optionScript && value ){
var options = this.importer.Macro.exec(columnJson.optionScript, this);
if( !options.contains(value) ){
errorTextList.push( colInfor + lp.notInOptions +":"+ options.join(",") + lp.fullstop );
errorTextListExcel.push( colInforExcel + lp.notInOptions +":"+ options.join(",") + lp.fullstop );
}
}
if( columnJson.validFieldType !== false && value ){
switch ( dataType ) {
case "string":
case "stringList":
if( columnJson.isName ){
var arr = this.stringToArray(value);
arr.each( function(d, idx){
var obj = this.importer.getOrgData( d );
if( obj.errorText ){
errorTextList.push( colInfor + obj.errorText + lp.fullstop );
errorTextListExcel.push( colInforExcel + obj.errorText + lp.fullstop );
}
}.bind(this));
}
break;
case "number":
case "integer":
case "long":
case "double":
value = value.replace(/ /g,"");
if (isNaN(value)){
errorTextList.push( colInfor + value + lp.notValidNumber + lp.fullstop );
errorTextListExcel.push( colInforExcel + value + lp.notValidNumber + lp.fullstop );
}
break;
case "numberList":
case "integerList":
case "longList":
case "doubleList":
var arr = this.stringToArray(value);
arr.each( function(d, idx){
if (isNaN(d)){
errorTextList.push( colInfor + d + lp.notValidNumber + lp.fullstop );
errorTextListExcel.push( colInforExcel + d + lp.notValidNumber + lp.fullstop );
}
}.bind(this));
break;
case "date":
case "dateTime":
value = value.replace(/ /g,"");
if( !( new Date(value).isValid() )){
errorTextList.push(colInfor + value + lp.notValidDate + lp.fullstop );
errorTextListExcel.push( colInforExcel + value + lp.notValidDate + lp.fullstop );
}
break;
case "dateList":
case "dateTimeList":
var arr = this.stringToArray(value);
arr.each( function(d, idx){
if( !( new Date(d).isValid() )){
errorTextList.push(colInfor + d + lp.notValidDate + lp.fullstop );
errorTextListExcel.push( colInforExcel + d + lp.notValidDate + lp.fullstop );
}
}.bind(this));
break;
case "boolean":
value = value.replace(/ /g,"");
if( !["true","false"].contains(value.trim().toLowerCase()) ){
errorTextList.push(colInfor + value + lp.notValidBoolean + lp.fullstop );
errorTextListExcel.push( colInforExcel + value + lp.notValidBoolean + lp.fullstop );
}
break;
case "booleanList":
var arr = this.stringToArray(value);
arr.each( function(d, idx){
if( !["true","false"].contains(d.trim().toLowerCase())){
errorTextList.push(colInfor + d + lp.notValidBoolean + lp.fullstop );
errorTextListExcel.push( colInforExcel + d + lp.notValidBoolean + lp.fullstop );
}
}.bind(this));
break;
case "json":
case "stringMap":
value = value.replace(/ /g,"");
try{
var d = JSON.parse(value);
}catch (e) {
errorTextList.push(colInfor + value + lp.notValidJson + lp.fullstop );
errorTextListExcel.push( colInforExcel + value + lp.notValidJson + lp.fullstop );
}
break;
default:
break;
}
}
}.bind(this));
this.errorTextList = this.errorTextList.concat( errorTextList );
this.errorTextListExcel = this.errorTextListExcel.concat( errorTextListExcel );
if(this.errorTextList.length>0){
return false;
}
var p = this.createData();
return Promise.resolve( p ).then(function (flag) {
this.importer.json.data.calculateFieldList.each( function (fieldJson, i) {
if( !fieldJson.path )return;
if( fieldJson.isName ){
var sourceData = this.calculateFieldDataMap[fieldJson.path];
var arr = typeOf( sourceData ) === "array" ? sourceData : [sourceData];
arr = typeOf( arr ) === "array" ? arr : [arr];
arr.each(function (d, idx) {
if( !d )return d;
var a;
switch (typeOf( d )) {
case "string":
a = d; break;
case "object":
a = d.distinguishedName || d.unique || d.employee; break;
}
if( !a )return d;
var obj = this.importer.getOrgData( a );
if( obj.errorText ){
var errorText = (fieldJson.displayName || fieldJson.path) + ":" + obj.errorText + lp.fullstop;
errorTextList.push( errorText );
errorTextListExcel.push( errorText );
}
}.bind(this));
}
}.bind(this));
this.errorTextList = this.errorTextList.concat( errorTextList );
this.errorTextListExcel = this.errorTextListExcel.concat( errorTextListExcel );
if( this.errorTextList.length > 0 )return false;
if( this.importer.json.type === "cms" ){
this.checkCMS( true );
}else if( this.importer.json.type === "process" ){
this.checkProcess( true );
}
if(this.errorTextList.length>0){
return false;
}
return true;
}.bind(this));
},
checkNecessary: function(){
var lp = this.lp;
var columnText = lp.importValidationColumnText;
var columnTextExcel = lp.importValidationColumnTextExcel;
var errorTextList = [];
var errorTextListExcel = [];
var excelUtils = MWF.ExcelUtilsV2 || this.importer.excelUtils;
this.importer.json.data.columnList.each( function (columnJson, i) {
var colName = excelUtils.index2ColName( i );
var colInfor = columnText.replace( "{n}", (i+1)+"("+colName+")" );
var colInforExcel = columnTextExcel.replace( "{n}", colName );
var value = this.importedData[i] || "";
var dataType = this.importer.json.type === "dynamicTable" ? columnJson.dataType_Querytable : columnJson.dataType_CMSProcess;
if( columnJson.validFieldType !== false && value ){
switch ( dataType ) {
case "json":
case "stringMap":
value = value.replace(/ /g,"");
try{
var d = JSON.parse(value);
}catch (e) {
errorTextList.push(colInfor + value + lp.notValidJson + lp.fullstop );
errorTextListExcel.push( colInforExcel + value + lp.notValidJson + lp.fullstop );
}
break;
default:
break;
}
}
}.bind(this));
this.errorTextList = this.errorTextList.concat( errorTextList );
this.errorTextListExcel = this.errorTextListExcel.concat( errorTextListExcel );
if(this.errorTextList.length>0){
return false;
}
var p = this.createData();
return Promise.resolve(p).then(function () {
if( this.importer.json.type === "cms" ){
this.checkCMS();
}else if( this.importer.json.type === "process" ){
this.checkProcess();
}
if(this.errorTextList.length>0){
return false;
}
return true;
}.bind(this))
},
getCol: function(key, isExcel){
var text, lp = this.lp;
var excelUtils = MWF.ExcelUtilsV2 || this.importer.excelUtils;
if( this.pathIndexMap && typeOf(this.pathIndexMap[key]) === "number"){
var i = this.pathIndexMap[key];
if( isExcel ){
text = lp.importValidationColumnTextExcel;
return text.replace( "{n}", excelUtils.index2ColName( i ) );
}else{
text = lp.importValidationColumnText;
return text.replace( "{n}", i+1 );
}
}
return "";
}
//适配老版本，新版本中已修改 end
});
//MWF.xDesktop.requireApp("Template", "utils.ExcelUtilsV2", null, false);
MWF.QMultiImporter.ExcelImporter = new Class({
Extends: MWF.ExcelImporter
});
MWF.QMultiImporter.ExcelExporter = new Class({
Extends: MWF.ExcelExporter
});
MWF.QMultiImporter.ProgressDialog = new Class({
Implements: [Options, Events],
Extends: o2.widget.Common,
options: {
zindex: null,
disableDetailButton: false
},
initialize : function( importer, options ){
this.setOptions(options);
this.lp = MWF.xApplication.query.Query.LP;
this.css = importer.css;
},
openDlg: function () {
var _self = this;
this.contentNode = new Element("div",{"styles": this.css.processContentNode});
var opt = {
"style" : "user",
"title": this.lp.importRecordDetail,
"content": this.contentNode,
"offset": {"y": 0},
"isMax": false,
"width": 500,
"height": 400,
"zindex": this.options.zindex,
"buttonList": [
{
"type": "openImportRecordDetail",
"text": this.lp.openImportRecordDetail,
"action": function () { _self.multipleImporter.openResultDlg(); }
},
{
"type": "cancel",
"text": this.lp.close,
"action": function () { this.dlg.close(); }.bind(this)
}
],
"onPostShow": function(){
this.fireEvent("postShow");
}.bind(this),
"onPostLoad": function () {
this.titleAction.hide();
this.button.hide();
},
"onPostClose": function(){
this.dlg = null;
}.bind(this)
};
if( this.options.disableDetailButton ){
opt.buttonList.splice(0, 1);
}
this.dlg = o2.DL.open(opt);
},
showCloseAction: function(){
this.dlg.titleAction.show();
this.dlg.button.show();
// if( this.bottomNode )this.bottomNode.show();
// if( this.topCloseAction )this.topCloseAction.show();
// this.setSize();
},
close: function(){
this.dlg.close();
}
});
MWF.QMultiImporter.ProgressBar = new Class({
Extends: MWF.QImporter.ProgressBar,
initialize : function( importer, dlg, options ){
this.setOptions(options);
this.importer = importer;
this.dlg = dlg;
this.actions = this.importer.lookupAction;
this.lp = MWF.xApplication.query.Query.LP;
this.css = importer.css;
this.container = dlg.contentNode;
this.titleNode = new Element('div', {
text: this.importer.json.name,
style: 'color:#666'
}).inject(this.container);
this.contentNode = new Element('div', {style: 'margin-bottom:10px;'}).inject(this.container);
this.status = "ready";
this.lp = Object.assign(this.lp, {
"openImportRecordDetail": "查看导入日志",
"importSuccess" : "导入文档成功！",
"importPartSuccessTitle": "部分导入成功",
"importFailTitle": "导入失败",
"checkDataTitle": "数据导入",
"checkDataContent": "正在检查数据...",
"importDataTitle": "正在导入数据",
"importDataContent": "开始导入文档，共{count}条",
"readyToImportData": "正在准备导入文档",
"readyToImportData1": "正在准备导入文档...",
"importSpeed": "条/秒",
"importingDataContent": "正导入文档: {speed}条/秒,共{total}条,剩余{remaining}条",
"importingDataErrorContent": ",出错{errorCount}条",
})
},
hide: function (){
this.titleNode.hide();
this.contentNode.hide();
},
showImporting: function( log, callback ){
// this.node.show();
this.setContentHtml();
if( !this.currentDate )this.currentDate = new Date();
var executeCount = log.successCount + log.failureCount;
if( log.totalCount > executeCount ){ //导入中
//this.setMessageTitle( this.lp.importDataTitle );
this.setMessageText( this.lp.importDataContent.replace( "{count}", log.totalCount ) );
this.updateProgress( log );
}else{ //已经结束, 状态有 "导入成功","部分成功","导入失败"
this.transferComplete( log );
if( callback )callback( log );
}
// this.setSize();
},
updateProgress: function(log){
//status, data.executeCount, data.count, data.failCount
var lp = this.lp;
var total = log.totalCount;
var processed = log.successCount + log.failureCount;
var failCount = log.failureCount;
var percent = 100*(processed/total);
var sendDate = new Date();
var lastDate = this.lastTime || this.currentDate;
var ms = sendDate.getTime() - lastDate.getTime();
var speed = ( (processed - ( this.lastProcessed || 0 )) * 1000)/ms ;
var u = lp.importSpeed;
speed = speed.round(2);
this.progressPercentNode.setStyle("width", ""+percent+"%");
var text = lp.importingDataContent.replace("{speed}",(speed === Infinity || speed === -Infinity) ? '' : speed).replace("{total}",total).replace("{remaining}",( total - processed ));
text += failCount ? lp.importingDataErrorContent.replace("{errorCount}",failCount) : "";
this.progressInforNode.set("text", text);
this.lastProcessed = processed;
this.lastTime = new Date();
},
transferComplete: function( log ){
var lp = this.lp;
var sendDate = new Date();
var ms = sendDate.getTime()-this.currentDate.getTime();
if(ms<1000)ms = 1000;
var timeStr = "";
if (ms>3600000){
var h = ms/3600000;
var m_s = ms % 3600000;
var m = m_s / 60000;
var s_s = m_s % 60000;
var s = s_s/1000;
timeStr = ""+h.toInt()+lp.hour+m.toInt()+lp.mintue+s.toInt()+lp.second;
}else if (ms>60000){
var m = ms / 60000;
var s_s = ms % 60000;
var s = s_s/1000;
timeStr = ""+m.toInt()+lp.mintue+s.toInt()+lp.second;
}else{
var s = ms/1000;
timeStr = ""+s.toInt()+lp.second;
}
if( log.totalCount === log.successCount ){
var size = log.totalCount;
var speed = (size * 1000)/ms ;
var u = lp.importSpeed;
speed = speed.round(2);
this.setMessageTitle( lp.importSuccessTitle );
var text = lp.importSuccessContent.replace("{total}",size).replace("{speed}",speed).replace("{timeStr}",timeStr);
this.setMessageText( text );
}else if(log.successCount > 0){
var size = log.totalCount;
var speed = (size * 1000)/ms ;
var u = lp.importSpeed;
speed = speed.round(2);
this.setMessageTitle( lp.importPartSuccessTitle );
var text = lp.importPartSuccessContent.replace("{total}",size).replace("{speed}",speed).replace("{errorCount}",log.failureCount).replace("{timeStr}",timeStr);
this.setMessageText( text );
}else{ //导入失败
var size = log.totalCount;
this.setMessageTitle( lp.importFailTitle );
var text = lp.importFailContent.replace("{errorInfo}",log.distribution || "").replace("{total}",size).replace("{timeStr}",timeStr);
this.setMessageText( text );
}
this.clearMessageProgress();
this.showCloseAction();
},
showCloseAction: function(){
this.dlg.dlg.titleAction.show();
this.dlg.dlg.button.show();
},
close: function(){
this.dlg.dlg.close();
},
setMessageTitle: function( text){
//this.dlg.titleText.set("text", text);
this.titleNode.textContent = text;
}
});
source