Zhenfei.Li
/
plugin-bi-excel-database
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
Browse Source

feat: 增加一键删除，针对碧桂园做一些处理

upgrade-final
Zhenfei.Li 5 years ago
parent
40694215b3
commit
28172c19cc
7 changed files with 75 additions and 53 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. BIN
      fr-plugin-hwExcelExport-1.8.3.zip
  2. 5
      src/main/java/com/fr/plugin/decision/core/ExcelDmlBean.java
  3. 2
      src/main/java/com/fr/plugin/decision/request/handler/CheckSizeHandler.java
  4. 102
      src/main/java/com/fr/plugin/decision/request/handler/UpgradeHandler.java
  5. 9
      src/main/resources/com/fr/plugin/hw/decision/js/pane/left.linklist.js
  6. 8
      src/main/resources/com/fr/plugin/hw/decision/js/pane/left.linklist.model.js
  7. 2
      src/main/resources/com/fr/plugin/hw/decision/js/table.info.model.js

BIN
fr-plugin-hwExcelExport-1.8.3.zip
View File

Binary file not shown.

5
src/main/java/com/fr/plugin/decision/core/ExcelDmlBean.java
Unescape View File

@ -34,7 +34,10 @@ public class ExcelDmlBean {
}
table = new Table(schema, tableName);
rowCount = tableValue.get(tableColName.get(0)).size();
rowCount = 0;
if (tableValue.size() > 0 && tableColName.size() > 0) {
rowCount = tableValue.get(tableColName.get(0)).size();
};
}
public List<Boolean> getTablePrimaryKey() {

2
src/main/java/com/fr/plugin/decision/request/handler/CheckSizeHandler.java
Unescape View File

@ -32,7 +32,7 @@ public class CheckSizeHandler extends HWAbstractHandler {
try {
FineAuthorityUser authorityUser = FineAuthorityUtils.getAuth(req);
Optional<BIDetailResult> data = new BurgerTableDataCellImpl().getRealDataWithAuth(fineBusinessTable, new ConfLimitInfo(30000, new ConfPageInfo()), authorityUser);
Optional<BIDetailResult> data = new BurgerTableDataCellImpl().getRealDataWithAuth(fineBusinessTable, new ConfLimitInfo(500000, new ConfPageInfo()), authorityUser);
BIDetailResult detailResult = data.get();
JSONObject excel = JSONObject.create();

102
src/main/java/com/fr/plugin/decision/request/handler/UpgradeHandler.java
Unescape View File

@ -71,17 +71,18 @@ public class UpgradeHandler extends HWAbstractHandler {
JSONObject finalResult = JSONObject.create();
List<FineBusinessTable> allTables = CellCreator.getCellProvider().tableCell().getAllTableWithoutAuth();
allTables.forEach(fineBusinessTable -> {
allTables.stream().filter(fineBusinessTable -> fineBusinessTable instanceof FineExcelBusinessTable).limit(15).forEach(fineBusinessTable -> {
Map<String, List> values = new HashMap<String, List>();
if (fineBusinessTable instanceof FineExcelBusinessTable) {
JSONArray items = JSONArray.create();
FineAttachment sheetInfo = ((FineExcelBusinessTable) fineBusinessTable).getBaseAttach();
String attachId = sheetInfo.getId();
String fileName = sheetInfo.getFileName();
int sheetNo = 0;
JSONArray items = JSONArray.create();
FineAttachment sheetInfo = ((FineExcelBusinessTable) fineBusinessTable).getBaseAttach();
String attachId = sheetInfo.getId();
String fileName = sheetInfo.getFileName();
int sheetNo = 0;
List<FineBusinessField> fields = ((FineExcelBusinessTable) fineBusinessTable).getExcelFields();
List<FineBusinessField> fields = ((FineExcelBusinessTable) fineBusinessTable).getExcelFields();
try {
if (fileName.endsWith(".xlsx")) {
XSSFWorkbook excelWork = HWUtils.getExcelWork(attachId);
if(excelWork != null){
@ -92,7 +93,7 @@ public class UpgradeHandler extends HWAbstractHandler {
tableCol.put(field.getName(), i);
JSONObject item = new JSONObject();
item.put("colLength", "255");
item.put("colLength", "8000");
item.put("colName", field.getName());
item.put("colType", this.getFieldSqlType(field.getType()));
item.put("excelCol", i);
@ -112,7 +113,7 @@ public class UpgradeHandler extends HWAbstractHandler {
tableCol.put(field.getName(), i);
JSONObject item = new JSONObject();
item.put("colLength", "255");
item.put("colLength", "8000");
item.put("colName", field.getName());
item.put("colType", this.getFieldSqlType(field.getType()));
item.put("excelCol", i);
@ -123,60 +124,61 @@ public class UpgradeHandler extends HWAbstractHandler {
values = HWUtils.get2003SheetContent(sheetAt,0, tableCol);
}
}
} catch (Exception e){
e.printStackTrace();
};
String schema = "";
String tableName = fineBusinessTable.getName();
String schema = "guest";
String tableName = fineBusinessTable.getName();
ExcelDmlAction excelDmlAction = ActionFactory.getInstance().create("add");
ExcelDmlAction excelDmlAction = ActionFactory.getInstance().create("add");
excelDmlAction.setExcelDmlBean( new ExcelDmlBean(connection, schema, tableName, items, values) );
excelDmlAction.setExcelDmlBean( new ExcelDmlBean(connection, schema, tableName, items, values) );
try {
JSONObject dmlResult = excelDmlAction.execute();
importDbResult.put(dmlResult);
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")) && 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"), "exist")) {
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{
FineAuthorityUser authorityUser = FineAuthorityUtils.getAuth(req);
if (StringUtils.equals("success", dmlResult.getString("status")) || StringUtils.contains(dmlResult.getString("errorText"), "exist")) {
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{
FineAuthorityUser authorityUser = FineAuthorityUtils.getAuth(req);
Optional<FineBusinessPackage> packageIdWithoutAuth = CellCreator.getCellProvider().packageCell().getPackageByTableNameWithoutAuth(tableName);
FineBusinessPackage businessPackage = packageIdWithoutAuth.get();
String packId = businessPackage.getId();
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());
List<FineBusinessRelation> fineBusinessRelations = CellCreator.getCellProvider().relationPathCell().getRelationsByTableNameWithoutAuth(fineBusinessTable.getName());
CellCreator.getCellProvider().tableCell().removeTable(fineBusinessTable.getName(), FineAuthorityUser.ROOT_USER_ID);
CellCreator.getCellProvider().tableCell().removeTable(fineBusinessTable.getName(), FineAuthorityUser.ROOT_USER_ID);
// String packId = "__my_analysis__" + fineBusinessTable.getCreateByWithId() + "1";
try {
String tableString = tablesBean.toString();
FineBusinessTable[] businessTables = createBusinessTablesFromDBNewAddTableInfo(mapper.readValue(tableString, DataBaseAddTableRequestBean.class), authorityUser.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){
try {
String tableString = tablesBean.toString();
FineBusinessTable[] businessTables = createBusinessTablesFromDBNewAddTableInfo(mapper.readValue(tableString, DataBaseAddTableRequestBean.class), authorityUser.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();
}
} catch(Exception e){
e.printStackTrace();
}
});

9
src/main/resources/com/fr/plugin/hw/decision/js/pane/left.linklist.js
Unescape View File

@ -45,6 +45,15 @@
self.linkListPane = _ref;
}
}, top: 10, left: 0, right: 0, bottom: 10
}, {
el: {
type: "bi.button",
text: "一键删除",
height: 24,
handler: function () {
self.store.deleteAllLink();
}
}, top: -34, left: 100, right: 50, bottom: -10
}]
};
},

8
src/main/resources/com/fr/plugin/hw/decision/js/pane/left.linklist.model.js
Unescape View File

@ -89,6 +89,14 @@
BI.emptyFn)
},
//删除全部: 仅内部人员使用
deleteAllLink: function(){
var self = this;
BI.each(self.model.linklist, function (i, v) {
self.deleteLink(v.id);
});
},
setSelectedLink: function(v){
this.model.selectedLink = v;
}

2
src/main/resources/com/fr/plugin/hw/decision/js/table.info.model.js
Unescape View File

@ -5,7 +5,7 @@
return {
items: [],
connection: "",
schema: "",
schema: "guest",
tableName: "",
excelItems: [],
infoId: o.infoId,

Write Preview
Loading…
Cancel
Save