Compare commits
11 Commits
| Author | SHA1 | Date |
|---|---|---|
Zhenfei.Li
|
ace734892b | 4 years ago |
|
Zhenfei.Li
|
d38bf72a17 | 4 years ago |
|
Zhenfei.Li
|
2a6bf0d85a | 4 years ago |
|
Zhenfei.Li
|
f4c9b19b3e | 4 years ago |
|
Zhenfei.Li
|
12f34ffe59 | 4 years ago |
|
Zhenfei.Li
|
403141ec7a | 4 years ago |
|
Zhenfei.Li
|
9db8157fa2 | 4 years ago |
|
Zhenfei.Li
|
9d45c51b10 | 4 years ago |
|
Zhenfei.Li
|
c7c2d59324 | 4 years ago |
|
Zhenfei.Li
|
02199a96c8 | 4 years ago |
|
Zhenfei.Li
|
bd0a897a39 | 4 years ago |
30 changed files with 900 additions and 109 deletions
Binary file not shown.
@ -0,0 +1,28 @@
|
||||
package com.fr.plugin.decision.dialect.postgre; |
||||
|
||||
import com.fr.data.core.db.dialect.Dialect; |
||||
import com.fr.data.core.db.dialect.base.key.column.typetosql.AbstractDialectColumnType2SQLExecutor; |
||||
import com.fr.data.core.db.dialect.base.key.column.typetosql.DialectColumnType2SQLParameter; |
||||
import com.fr.data.core.db.dialect.util.DialectUtils; |
||||
|
||||
public class PostgreDialectColumnType2SQLExecutor extends AbstractDialectColumnType2SQLExecutor { |
||||
public PostgreDialectColumnType2SQLExecutor(){ |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public String execute(DialectColumnType2SQLParameter dialectColumnType2SQLParameter, Dialect dialect) { |
||||
int columnType = dialectColumnType2SQLParameter.getColumnType(); |
||||
String columnSize = dialectColumnType2SQLParameter.getParameter(); |
||||
switch(columnType) { |
||||
case 8: |
||||
return "double precision"; |
||||
case 12: |
||||
return "varchar(" + columnSize + ")"; |
||||
case 91: |
||||
return "date"; |
||||
default: |
||||
return DialectUtils.getTypeName(columnType); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,80 @@
|
||||
package com.fr.plugin.decision.request.handler; |
||||
|
||||
import com.finebi.activate.foundation.StableManager; |
||||
import com.finebi.common.api.vo.table.FineBusinessTable; |
||||
import com.finebi.common.api.vo.table.FineExcelBusinessTable; |
||||
import com.finebi.direct.common.api.cell.context.CellCreator; |
||||
import com.finebi.foundation.api.service.context.BaseContext; |
||||
import com.fr.json.JSONObject; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.plugin.decision.utils.JdbcUtils; |
||||
import com.fr.web.utils.WebUtils; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.sql.Connection; |
||||
import java.util.List; |
||||
import java.sql.SQLException; |
||||
import java.sql.DatabaseMetaData; |
||||
import java.util.ArrayList; |
||||
import java.sql.ResultSet; |
||||
|
||||
public class CheckNameHandler extends HWAbstractHandler { |
||||
public static final String PATH="/excelmng/check/name"; |
||||
@Override |
||||
protected void deal(HttpServletRequest req, HttpServletResponse res, JSONObject para, JSONObject result) throws Exception { |
||||
|
||||
String connection = para.getString("connection"); |
||||
|
||||
Connection conn = JdbcUtils.getConnection(connection); |
||||
|
||||
if (conn == null){ |
||||
FineLoggerFactory.getLogger().error("HW_excel校验重名：数据链接 " + connection + " 获取异常" ); |
||||
WebUtils.printAsJSON(res, new JSONObject().put("status","fail").put("errorText","获取数据连接异常")); |
||||
return; |
||||
} |
||||
List<String> tables = getTables(conn); |
||||
|
||||
JSONObject finalResult = JSONObject.create(); |
||||
|
||||
ArrayList<String> excelList = new ArrayList<String>(); |
||||
|
||||
List<FineBusinessTable> allTables = CellCreator.getCellProvider().tableCell().getAllTableWithoutAuth(); |
||||
allTables.forEach(fineBusinessTable -> { |
||||
if (fineBusinessTable instanceof FineExcelBusinessTable) { |
||||
excelList.add(fineBusinessTable.getName()); |
||||
} |
||||
}); |
||||
|
||||
tables.retainAll(excelList); |
||||
|
||||
WebUtils.printAsJSON(res, finalResult.put("checkResult", tables)); |
||||
} |
||||
|
||||
@Override |
||||
public String getPath() { |
||||
return PATH; |
||||
} |
||||
|
||||
/** |
||||
* service获取集合 |
||||
*/ |
||||
private static BaseContext getContext() { |
||||
return StableManager.getContext(); |
||||
} |
||||
|
||||
/**获取数据库中所有表名称 |
||||
* @param conn |
||||
* @return |
||||
* @throws SQLException |
||||
*/ |
||||
private static List<String> getTables(Connection conn) throws SQLException { |
||||
DatabaseMetaData databaseMetaData = conn.getMetaData(); |
||||
ResultSet tables = databaseMetaData.getTables(null, null, "%", null); |
||||
ArrayList<String> tablesList = new ArrayList<String>(); |
||||
while (tables.next()) { |
||||
tablesList.add(tables.getString("TABLE_NAME")); |
||||
} |
||||
return tablesList; |
||||
} |
||||
} |
||||
@ -0,0 +1,81 @@
|
||||
package com.fr.plugin.decision.request.handler; |
||||
|
||||
import com.finebi.activate.foundation.StableManager; |
||||
import com.finebi.common.api.vo.table.FineBusinessTable; |
||||
import com.finebi.common.api.vo.table.FineExcelBusinessTable; |
||||
import com.finebi.dashboard.impl.service.helper.FineDashBoardTableHelper; |
||||
import com.finebi.direct.burger.api.service.FineUserInfoService; |
||||
import com.finebi.direct.common.api.cell.context.CellCreator; |
||||
import com.finebi.common.api.cell.user.authority.UserAuthority; |
||||
import com.finebi.direct.common.impl.engine.BurgerTableDataCellImpl; |
||||
import com.finebi.foundation.api.service.FineService; |
||||
import com.finebi.foundation.api.service.context.BaseContext; |
||||
import com.finebi.burger.api.bean.configuration.table.page.ConfLimitInfo; |
||||
import com.finebi.burger.api.bean.configuration.table.page.ConfPageInfo; |
||||
import com.finebi.foundation.api.structure.result.BIDetailResult; |
||||
import com.finebi.foundation.constant.BICommonConstants; |
||||
import com.finebi.widget.direct.impl.provider.authority.AuthorityUserHelper; |
||||
import com.fr.json.JSONObject; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.plugin.decision.utils.JdbcUtils; |
||||
import com.fr.web.utils.WebUtils; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.sql.Connection; |
||||
import java.sql.DatabaseMetaData; |
||||
import java.sql.ResultSet; |
||||
import java.sql.SQLException; |
||||
import java.util.ArrayList; |
||||
import java.util.List; |
||||
import java.util.Optional; |
||||
|
||||
public class CheckSizeHandler extends HWAbstractHandler { |
||||
public static final String PATH="/excelmng/check/size"; |
||||
@Override |
||||
protected void deal(HttpServletRequest req, HttpServletResponse res, JSONObject para, JSONObject result) throws Exception { |
||||
JSONObject finalResult = JSONObject.create(); |
||||
|
||||
ArrayList<JSONObject> excelList = new ArrayList<JSONObject>(); |
||||
|
||||
List<FineBusinessTable> allTables = CellCreator.getCellProvider().tableCell().getAllTableWithoutAuth(); |
||||
allTables.forEach(fineBusinessTable -> { |
||||
if (fineBusinessTable instanceof FineExcelBusinessTable) { |
||||
try { |
||||
UserAuthority authorityUser = getFineUserInfoService().getUserAuthority(req); |
||||
Optional<BIDetailResult> data = new BurgerTableDataCellImpl().getRealDataWithAuth(fineBusinessTable, new ConfLimitInfo(500000, new ConfPageInfo()), authorityUser); |
||||
BIDetailResult detailResult = data.get(); |
||||
|
||||
JSONObject excel = JSONObject.create(); |
||||
excel.put("transferName", fineBusinessTable.getTransferName()). |
||||
put("rowCount", detailResult.totalRowSize()); |
||||
excelList.add(excel); |
||||
} catch(Exception e){ |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
}); |
||||
|
||||
WebUtils.printAsJSON(res, finalResult.put("data", excelList)); |
||||
} |
||||
|
||||
@Override |
||||
public String getPath() { |
||||
return PATH; |
||||
} |
||||
|
||||
protected static FineUserInfoService getFineUserInfoService() { |
||||
return getBean(FineUserInfoService.class); |
||||
} |
||||
|
||||
private static <T extends FineService> T getBean(Class<T> annotatedClass) { |
||||
return getContext().getServiceBean(annotatedClass); |
||||
} |
||||
|
||||
/** |
||||
* service获取集合 |
||||
*/ |
||||
private static BaseContext getContext() { |
||||
return StableManager.getContext(); |
||||
} |
||||
} |
||||
@ -0,0 +1,217 @@
|
||||
package com.fr.plugin.decision.request.handler; |
||||
|
||||
import com.finebi.activate.foundation.StableManager; |
||||
import com.finebi.burger.api.bean.configuration.table.field.FineBusinessField; |
||||
import com.finebi.burger.api.bean.configuration.table.page.ConfLimitInfo; |
||||
import com.finebi.burger.api.bean.configuration.table.page.ConfPageInfo; |
||||
import com.finebi.burger.api.request.configuration.table.DataBaseAddTableItemRequestBean; |
||||
import com.finebi.burger.api.request.configuration.table.DataBaseAddTableRequestBean; |
||||
import com.finebi.burger.api.response.configuration.table.TableAddResponseBean; |
||||
import com.finebi.common.api.vo.pack.FineBusinessPackage; |
||||
import com.finebi.common.api.vo.relation.FineBusinessRelation; |
||||
import com.finebi.common.api.vo.table.FineDBBusinessTable; |
||||
import com.finebi.direct.burger.api.service.FineTableService; |
||||
import com.finebi.direct.burger.api.service.FineUserInfoService; |
||||
import com.finebi.common.api.cell.user.authority.UserAuthority; |
||||
import com.finebi.direct.common.impl.engine.BurgerTableDataCellImpl; |
||||
import com.finebi.foundation.api.reponse.FineRespond; |
||||
import com.finebi.foundation.api.service.FineService; |
||||
import com.finebi.foundation.api.service.context.BaseContext; |
||||
import com.finebi.foundation.api.structure.result.BIDetailResult; |
||||
import com.finebi.utils.CompareUtils; |
||||
import com.fr.decision.webservice.v10.user.UserService; |
||||
import com.fr.json.JSONArray; |
||||
import com.fr.json.JSONObject; |
||||
import com.fr.log.FineLoggerFactory; |
||||
import com.fr.plugin.decision.HWUtils; |
||||
import com.fr.plugin.decision.core.ActionFactory; |
||||
import com.fr.plugin.decision.core.ExcelDmlBean; |
||||
import com.fr.plugin.decision.core.action.ExcelDmlAction; |
||||
import com.fr.plugin.decision.dao.ExcelLinkService; |
||||
import com.fr.plugin.decision.utils.JdbcUtils; |
||||
import com.fr.stable.StringUtils; |
||||
import com.fr.third.fasterxml.jackson.core.JsonGenerationException; |
||||
import com.fr.third.fasterxml.jackson.databind.JsonMappingException; |
||||
import com.fr.third.fasterxml.jackson.databind.ObjectMapper; |
||||
import com.finebi.direct.common.api.cell.context.CellCreator; |
||||
import com.finebi.common.api.vo.table.FineBusinessTable; |
||||
import com.finebi.common.api.vo.table.FineExcelBusinessTable; |
||||
import com.fr.web.utils.WebUtils; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
|
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.io.IOException; |
||||
import java.sql.Connection; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.Optional; |
||||
|
||||
public class UpgradeHandler extends HWAbstractHandler { |
||||
public static final String PATH="/excelmng/upgrade"; |
||||
@Override |
||||
protected void deal(HttpServletRequest req, HttpServletResponse res, JSONObject para, JSONObject result) throws Exception { |
||||
|
||||
String connection = para.getString("connection"); |
||||
UserAuthority authorityUser = getFineUserInfoService().getUserAuthority(req); |
||||
|
||||
Connection conn = JdbcUtils.getConnection(connection); |
||||
|
||||
if (conn == null){ |
||||
FineLoggerFactory.getLogger().error("HW_excel导入：数据链接 " + connection + " 获取异常" ); |
||||
WebUtils.printAsJSON(res, new JSONObject().put("status","fail").put("errorText","获取数据连接异常")); |
||||
return; |
||||
} |
||||
|
||||
final String createUser = UserService.getInstance().getCurrentUserIdFromCookie(req); |
||||
|
||||
JSONArray importDbResult = JSONArray.create(); |
||||
JSONArray addDbResult = JSONArray.create(); |
||||
JSONObject finalResult = JSONObject.create(); |
||||
|
||||
List<FineBusinessTable> allTables = CellCreator.getCellProvider().tableCell().getAllTableWithoutAuth(); |
||||
allTables.stream().filter(fineBusinessTable -> fineBusinessTable instanceof FineExcelBusinessTable).limit(15).forEach(fineBusinessTable -> { |
||||
Map<String, List> values = new HashMap<String, List>(); |
||||
JSONArray items = JSONArray.create(); |
||||
|
||||
List<FineBusinessField> fields = ((FineExcelBusinessTable) fineBusinessTable).getExcelFields(); |
||||
|
||||
try { |
||||
Optional<BIDetailResult> optionalBIDetailResult = new BurgerTableDataCellImpl().getRealDataWithAuth(fineBusinessTable, new ConfLimitInfo(500000, new ConfPageInfo(500000, 1)), authorityUser); |
||||
BIDetailResult detailResult = optionalBIDetailResult.get(); |
||||
values = HWUtils.getValues(fields, detailResult); |
||||
for(int i = 0; i < fields.size(); i++){ |
||||
FineBusinessField field = fields.get(i); |
||||
JSONObject item = new JSONObject(); |
||||
item.put("colLength", "8000"); |
||||
item.put("colName", field.getName()); |
||||
item.put("colType", this.getFieldSqlType(field.getType())); |
||||
item.put("excelCol", i); |
||||
item.put("id", field.getId()); |
||||
items.put(item); |
||||
} |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
|
||||
String schema = ""; |
||||
String tableName = fineBusinessTable.getName(); |
||||
|
||||
ExcelDmlAction excelDmlAction = ActionFactory.getInstance().create("add"); |
||||
|
||||
excelDmlAction.setExcelDmlBean( new ExcelDmlBean(connection, schema, tableName, items, values) ); |
||||
|
||||
try { |
||||
JSONObject dmlResult = excelDmlAction.execute(); |
||||
importDbResult.put(dmlResult); |
||||
|
||||
if (StringUtils.equals("success", dmlResult.getString("status")) && dmlResult.getBoolean("addLink")) { |
||||
ExcelLinkService.getInstance().addLink(tableName, connection, schema, tableName, createUser); |
||||
FineLoggerFactory.getLogger().info("HW_excel导入：FineDB 新增数据成功" + tableName); |
||||
} |
||||
|
||||
if (StringUtils.equals("success", dmlResult.getString("status")) || StringUtils.contains(dmlResult.getString("errorText"), "existed")) { |
||||
ObjectMapper mapper = new ObjectMapper(); |
||||
JSONObject table = JSONObject.create().put("tableName", fineBusinessTable.getName()).put("connectionName", connection); |
||||
JSONArray tables = JSONArray.create().put(table); |
||||
JSONObject tablesBean = JSONObject.create().put("tables", tables); |
||||
try{ |
||||
Optional<FineBusinessPackage> packageIdWithoutAuth = CellCreator.getCellProvider().packageCell().getPackageByTableNameWithoutAuth(tableName); |
||||
FineBusinessPackage businessPackage = packageIdWithoutAuth.get(); |
||||
String packId = businessPackage.getId(); |
||||
|
||||
List<FineBusinessRelation> fineBusinessRelations = CellCreator.getCellProvider().relationPathCell().getRelationsByTableNameWithoutAuth(fineBusinessTable.getName()); |
||||
|
||||
CellCreator.getCellProvider().tableCell().removeTable(fineBusinessTable.getName(), CellCreator.getCellProvider().userCellProvider().authorityCell().getSuperAuthority()); |
||||
|
||||
try { |
||||
String tableString = tablesBean.toString(); |
||||
FineBusinessTable[] businessTables = createBusinessTablesFromDBNewAddTableInfo(mapper.readValue(tableString, DataBaseAddTableRequestBean.class), authorityUser.getUser().getInfo().getUserId()); |
||||
TableAddResponseBean responed = getTableService().addNewTable(packId, authorityUser, businessTables); |
||||
CellCreator.getCellProvider().relationPathCell().addRelations(fineBusinessRelations, authorityUser); |
||||
addDbResult.put(FineRespond.success(responed)); |
||||
} catch (JsonMappingException e) { |
||||
e.printStackTrace(); |
||||
} catch (JsonGenerationException e) { |
||||
e.printStackTrace(); |
||||
} catch (IOException e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} catch(Exception e){ |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
} catch(Exception e){ |
||||
e.printStackTrace(); |
||||
} |
||||
}); |
||||
|
||||
WebUtils.printAsJSON(res, finalResult.put("importDbResult", importDbResult).put("addDbResult", addDbResult)); |
||||
} |
||||
|
||||
@Override |
||||
public String getPath() { |
||||
return PATH; |
||||
} |
||||
|
||||
protected static FineTableService getTableService() { |
||||
return getBean(FineTableService.class); |
||||
} |
||||
|
||||
private static <T extends FineService> T getBean(Class<T> annotatedClass) { |
||||
return getContext().getServiceBean(annotatedClass); |
||||
} |
||||
/** |
||||
* service获取集合 |
||||
*/ |
||||
private static BaseContext getContext() { |
||||
return StableManager.getContext(); |
||||
} |
||||
|
||||
private int getFieldSqlType(int fieldType) { |
||||
if (CompareUtils.isEqual(fieldType, 16)) { |
||||
return 12; |
||||
} else if (CompareUtils.isEqual(fieldType, 32)) { |
||||
return 8; |
||||
} else if (CompareUtils.isEqual(fieldType, 48)) { |
||||
return 91; |
||||
} |
||||
return 12; |
||||
} |
||||
|
||||
public static FineBusinessTable[] createBusinessTablesFromDBNewAddTableInfo(DataBaseAddTableRequestBean bean, String userId) { |
||||
List<DataBaseAddTableItemRequestBean> items = bean.getTables(); |
||||
FineBusinessTable[] businessTables = new FineBusinessTable[items.size()]; |
||||
for (int i = 0; i < businessTables.length; i++) { |
||||
DataBaseAddTableItemRequestBean item = items.get(i); |
||||
FineBusinessTable table = createBusinessTableByItem(item, userId); |
||||
businessTables[i] = table; |
||||
} |
||||
return businessTables; |
||||
} |
||||
|
||||
private static FineBusinessTable createBusinessTableByItem(DataBaseAddTableItemRequestBean item, String userId) { |
||||
|
||||
return createDBBusinessTable(item, userId); |
||||
} |
||||
|
||||
private static FineBusinessTable createDBBusinessTable(DataBaseAddTableItemRequestBean item, String userId) { |
||||
FineDBBusinessTable table = new FineDBBusinessTable(); |
||||
table.setConnectionName(item.getConnectionName()); |
||||
table.setTableName(item.getDbTableName()); |
||||
table.setCreateByWithId(userId); |
||||
String tableName = getTableNameWithConnection(item); |
||||
table.setId(tableName); |
||||
table.setName(tableName); |
||||
return table; |
||||
} |
||||
|
||||
private static String getTableNameWithConnection(DataBaseAddTableItemRequestBean itemBean) { |
||||
return itemBean.getDbTableName(); |
||||
} |
||||
|
||||
protected static FineUserInfoService getFineUserInfoService() { |
||||
return getBean(FineUserInfoService.class); |
||||
} |
||||
} |
||||
@ -0,0 +1,15 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?> |
||||
<module type="JAVA_MODULE" version="4"> |
||||
<component name="NewModuleRootManager"> |
||||
<output url="file://$USER_HOME$/env/direct-bi/WEB-INF/plugins/plugin-com.fr.plugin.hw.import.excel-2.0.0/classes" /> |
||||
<output-test url="file://$MODULE_DIR$/../../../../direct-bi/nuclear-maven/classes/test/main" /> |
||||
<exclude-output /> |
||||
<content url="file://$MODULE_DIR$"> |
||||
<sourceFolder url="file://$MODULE_DIR$/java" isTestSource="false" /> |
||||
</content> |
||||
<orderEntry type="inheritedJdk" /> |
||||
<orderEntry type="sourceFolder" forTests="false" /> |
||||
<orderEntry type="library" name="lib" level="project" /> |
||||
<orderEntry type="module" module-name="direct-common-adapter" /> |
||||
</component> |
||||
</module> |
||||
@ -0,0 +1,66 @@
|
||||
!(function () { |
||||
var UpgradePane = BI.inherit(BI.Widget, { |
||||
props: { |
||||
baseCls: "dec-mng-check" |
||||
}, |
||||
|
||||
_store: function () { |
||||
return BI.Models.getModel("dec.model.mng.check"); |
||||
}, |
||||
|
||||
watch: { |
||||
result: function (items) { |
||||
this.list.populate(this._createItems(items)); |
||||
this.count.setText("excel表总数: " + BI.size(items)); |
||||
} |
||||
}, |
||||
|
||||
render: function () { |
||||
var self = this; |
||||
return { |
||||
type: "bi.vertical", |
||||
width: 640, |
||||
hgap: 50, |
||||
vgap: 50, |
||||
items: [{ |
||||
type: "bi.center_adapt", |
||||
items: [{ |
||||
type: "bi.button", |
||||
width: 200, |
||||
text: "检测所有excel的大小", |
||||
handler: self.store.getResult |
||||
}] |
||||
}, { |
||||
type: "bi.center_adapt", |
||||
items: [{ |
||||
type: "bi.label", |
||||
text: "excel表总数: 0", |
||||
ref: function (_ref) { |
||||
self.count = _ref; |
||||
} |
||||
}] |
||||
}, { |
||||
type: "bi.vertical", |
||||
ref: function (_ref) { |
||||
self.list = _ref; |
||||
} |
||||
}] |
||||
}; |
||||
}, |
||||
|
||||
_createItems: function (items) { |
||||
return BI.map(items, function (idx, item) { |
||||
var text = "【" + item.transferName + "】数据量: " + item.rowCount; |
||||
return { |
||||
type: "bi.horizontal", |
||||
items: [{ |
||||
type: "bi.label", |
||||
textAlign: "left", |
||||
text: text |
||||
}] |
||||
} |
||||
}); |
||||
} |
||||
}); |
||||
BI.shortcut("dec.mng.check", UpgradePane); |
||||
})(); |
||||
@ -0,0 +1,19 @@
|
||||
!(function () { |
||||
var Model = BI.inherit(Fix.Model, { |
||||
state: function () { |
||||
return { |
||||
result: [] |
||||
}; |
||||
}, |
||||
|
||||
actions: { |
||||
getResult: function () { |
||||
var self = this; |
||||
Dec.HW.checkSize({}, function (res) { |
||||
self.model.result = res.data; |
||||
}); |
||||
} |
||||
} |
||||
}); |
||||
BI.model("dec.model.mng.check", Model); |
||||
})(); |
||||
@ -0,0 +1,148 @@
|
||||
!(function () { |
||||
var UpgradePane = BI.inherit(BI.Widget, { |
||||
props: { |
||||
baseCls: "dec-mng-upgrade" |
||||
}, |
||||
|
||||
_store: function () { |
||||
return BI.Models.getModel("dec.model.mng.upgrade"); |
||||
}, |
||||
|
||||
watch: { |
||||
addDbResult: function (v) { |
||||
this.addList.populate(this._createAddItems(v)); |
||||
}, |
||||
importDbResult: function (v) { |
||||
this.importList.populate(this._createImportItems(v)); |
||||
} |
||||
}, |
||||
|
||||
beforeInit: function (callback) { |
||||
this.store.initData(callback); |
||||
}, |
||||
|
||||
render: function () { |
||||
var self = this; |
||||
return { |
||||
type: "bi.vertical", |
||||
width: 640, |
||||
vgap: 15, |
||||
items: [{ |
||||
type: "bi.vertical_adapt", |
||||
items: [{ |
||||
type: "bi.label", |
||||
textAlign: "right", |
||||
cls: "dec-font-weight-bold", |
||||
text: "数据源:", |
||||
title: "数据源", |
||||
width: 100 |
||||
}, { |
||||
el: { |
||||
type: "bi.text_value_combo", |
||||
lgap: 4, |
||||
cls: "bi-border", |
||||
textAlign: "left", |
||||
items: this.model.connectionItems, |
||||
width: 480, |
||||
height: 22, |
||||
ref: function (_ref) { |
||||
self.connection = _ref; |
||||
} |
||||
}, |
||||
lgap: 10 |
||||
}] |
||||
}, { |
||||
type: "bi.center_adapt", |
||||
items: [{ |
||||
type: "bi.button", |
||||
width: 200, |
||||
text: "重名检测", |
||||
handler: function () { |
||||
Dec.HW.checkName({ |
||||
connection: self.connection.getValue()[0] |
||||
}, function (res) { |
||||
var tip = "以下excel与数据库中已存在的表重名:" |
||||
BI.each(res.checkResult, function (i, tableName) { |
||||
tip += "\n" + tableName; |
||||
}) |
||||
BI.Msg.toast(tip, { |
||||
autoClose: false, |
||||
level: "warning" |
||||
}); |
||||
}); |
||||
} |
||||
}, { |
||||
type: "bi.button", |
||||
width: 200, |
||||
text: "升级旧Excel", |
||||
handler: function () { |
||||
Dec.HW.upgrade({ |
||||
connection: self.connection.getValue()[0] |
||||
}, function (res) { |
||||
self.store.setAddDbResult(res.addDbResult); |
||||
self.store.setImportDbResult(res.importDbResult); |
||||
}); |
||||
} |
||||
}] |
||||
}, { |
||||
type: "bi.vertical", |
||||
items: [{ |
||||
type: "bi.label", |
||||
text: "------Excel导入成数据库表报错信息------", |
||||
textAlign: "left" |
||||
}, { |
||||
type: "bi.button_group", |
||||
height: 300, |
||||
items: [], |
||||
layouts: [{ |
||||
type: "bi.vertical", |
||||
scrolly: true |
||||
}], |
||||
ref: function (_ref) { |
||||
self.importList = _ref; |
||||
} |
||||
}, { |
||||
type: "bi.label", |
||||
text: "------从数据库表创建到自助数据集报错信息------", |
||||
textAlign: "left" |
||||
}, { |
||||
type: "bi.button_group", |
||||
height: 300, |
||||
items: [], |
||||
layouts: [{ |
||||
type: "bi.vertical", |
||||
scrolly: true |
||||
}], |
||||
ref: function (_ref) { |
||||
self.addList = _ref; |
||||
} |
||||
}] |
||||
}] |
||||
}; |
||||
}, |
||||
|
||||
_createAddItems: function (array) { |
||||
var items = BI.filter(array, function (idx, item) { |
||||
return !item.success; |
||||
}); |
||||
return BI.map(items, function (idx, item) { |
||||
return { |
||||
type: "bi.label", |
||||
textAlign: "left", |
||||
text: item.errorMsg |
||||
} |
||||
}); |
||||
}, |
||||
|
||||
_createImportItems: function (array) { |
||||
return BI.map(array, function (idx, item) { |
||||
return { |
||||
type: "bi.label", |
||||
textAlign: "left", |
||||
text: item.status === "failed" ? item.errorText : item.text |
||||
} |
||||
}) |
||||
} |
||||
}); |
||||
BI.shortcut("dec.mng.upgrade", UpgradePane); |
||||
})(); |
||||
@ -0,0 +1,33 @@
|
||||
!(function () { |
||||
var Model = BI.inherit(Fix.Model, { |
||||
state: function () { |
||||
return { |
||||
connectionItems: [], |
||||
addDbResult: [], |
||||
importDbResult: [] |
||||
}; |
||||
}, |
||||
|
||||
actions: { |
||||
initData: function (callback) { |
||||
var self = this; |
||||
Dec.Utils.getConnections(function (res) { |
||||
self.model.connectionItems = BI.map(res, function (i, val) { |
||||
return { |
||||
text: val.connectionName || "", |
||||
value: val.connectionName || "" |
||||
}; |
||||
}); |
||||
callback(); |
||||
}); |
||||
}, |
||||
setAddDbResult: function (result) { |
||||
this.model.addDbResult = result; |
||||
}, |
||||
setImportDbResult: function (result) { |
||||
this.model.importDbResult = result; |
||||
} |
||||
} |
||||
}); |
||||
BI.model("dec.model.mng.upgrade", Model); |
||||
})(); |
||||
Loading…
Reference in new issue