diff --git a/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java b/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java index e0f8c59f54..271619b33c 100644 --- a/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java +++ b/backend/src/main/java/io/dataease/service/dataset/DataSetTableService.java @@ -57,7 +57,7 @@ import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; -;import static io.dataease.commons.constants.ColumnPermissionConstants.Desensitization_desc; +import static io.dataease.commons.constants.ColumnPermissionConstants.Desensitization_desc; /** * @Author gin @@ -110,7 +110,8 @@ public class DataSetTableService { } private void extractData(DataSetTableRequest datasetTable) throws Exception { - if (datasetTable.getMode() == 1 && StringUtils.isNotEmpty(datasetTable.getSyncType()) && datasetTable.getSyncType().equalsIgnoreCase("sync_now")) { + if (datasetTable.getMode() == 1 && StringUtils.isNotEmpty(datasetTable.getSyncType()) + && datasetTable.getSyncType().equalsIgnoreCase("sync_now")) { DataSetTaskRequest dataSetTaskRequest = new DataSetTaskRequest(); DatasetTableTask datasetTableTask = new DatasetTableTask(); datasetTableTask.setTableId(datasetTable.getId()); @@ -130,7 +131,8 @@ public class DataSetTableService { if (StringUtils.isEmpty(datasetTable.getId())) { if (datasetTable.isMergeSheet()) { - Map> map = datasetTable.getSheets().stream().collect(Collectors.groupingBy(ExcelSheetData::getFieldsMd5)); + Map> map = datasetTable.getSheets().stream() + .collect(Collectors.groupingBy(ExcelSheetData::getFieldsMd5)); for (String s : map.keySet()) { DataSetTableRequest sheetTable = new DataSetTableRequest(); BeanUtils.copyBean(sheetTable, datasetTable); @@ -141,7 +143,8 @@ public class DataSetTableService { sheetTable.setName(excelSheetDataList.get(0).getDatasetName()); checkName(sheetTable); excelSheetDataList.forEach(excelSheetData -> { - String[] fieldArray = excelSheetData.getFields().stream().map(TableFiled::getFieldName).toArray(String[]::new); + String[] fieldArray = excelSheetData.getFields().stream().map(TableFiled::getFieldName) + .toArray(String[]::new); if (checkIsRepeat(fieldArray)) { DataEaseException.throwException(Translator.get("i18n_excel_field_repeat")); } @@ -156,11 +159,13 @@ public class DataSetTableService { datasetIdList.add(sheetTable.getId()); } datasetIdList.forEach(datasetId -> { - commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetId, "all_scope", "初始导入", null, datasetIdList)); + commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetId, "all_scope", "初始导入", + null, datasetIdList)); }); } else { for (ExcelSheetData sheet : datasetTable.getSheets()) { - String[] fieldArray = sheet.getFields().stream().map(TableFiled::getFieldName).toArray(String[]::new); + String[] fieldArray = sheet.getFields().stream().map(TableFiled::getFieldName) + .toArray(String[]::new); if (checkIsRepeat(fieldArray)) { DataEaseException.throwException(Translator.get("i18n_excel_field_repeat")); } @@ -183,7 +188,8 @@ public class DataSetTableService { datasetIdList.add(sheetTable.getId()); } datasetIdList.forEach(datasetId -> { - commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetId, "all_scope", "初始导入", null, datasetIdList)); + commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetId, "all_scope", "初始导入", + null, datasetIdList)); }); } @@ -191,11 +197,13 @@ public class DataSetTableService { } List excelSheetDataList = new ArrayList<>(); - List oldFields = datasetTable.getSheets().get(0).getFields().stream().map(TableFiled::getRemarks).collect(Collectors.toList()); + List oldFields = datasetTable.getSheets().get(0).getFields().stream().map(TableFiled::getRemarks) + .collect(Collectors.toList()); for (ExcelSheetData sheet : datasetTable.getSheets()) { - //替换时, + // 替换时, if (datasetTable.getEditType() == 0) { - List newFields = sheet.getFields().stream().map(TableFiled::getRemarks).collect(Collectors.toList()); + List newFields = sheet.getFields().stream().map(TableFiled::getRemarks) + .collect(Collectors.toList()); if (!oldFields.equals(newFields)) { DataEaseException.throwException(Translator.get("i18n_excel_column_inconsistent")); } @@ -216,9 +224,12 @@ public class DataSetTableService { int update = datasetTableMapper.updateByPrimaryKeySelective(datasetTable); // 替換時,先不刪除旧字段;同步成功后再删除 if (datasetTable.getEditType() == 0) { - commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetTable.getId(), "all_scope", "替换", saveExcelTableField(datasetTable.getId(), datasetTable.getSheets().get(0).getFields(), false), Arrays.asList(datasetTable.getId()))); + commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetTable.getId(), "all_scope", "替换", + saveExcelTableField(datasetTable.getId(), datasetTable.getSheets().get(0).getFields(), false), + Arrays.asList(datasetTable.getId()))); } else if (datasetTable.getEditType() == 1) { - commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetTable.getId(), "add_scope", "追加", null, Arrays.asList(datasetTable.getId()))); + commonThreadPool.addTask(() -> extractDataService.extractExcelData(datasetTable.getId(), "add_scope", "追加", + null, Arrays.asList(datasetTable.getId()))); } } @@ -285,7 +296,8 @@ public class DataSetTableService { DatasourceRequest datasourceRequest = new DatasourceRequest(); datasourceRequest.setDatasource(dorisDatasource); DDLProvider ddlProvider = ProviderFactory.getDDLProvider(dorisDatasource.getType()); - if (StringUtils.equalsIgnoreCase("custom", table.getType()) || StringUtils.equalsIgnoreCase("union", table.getType())) { + if (StringUtils.equalsIgnoreCase("custom", table.getType()) + || StringUtils.equalsIgnoreCase("union", table.getType())) { datasourceRequest.setQuery(ddlProvider.dropView(dorisTableName)); jdbcProvider.exec(datasourceRequest); datasourceRequest.setQuery(ddlProvider.dropView(DorisTableUtils.dorisTmpName(dorisTableName))); @@ -402,7 +414,8 @@ public class DataSetTableService { return datasourceProvider.getTableFileds(datasourceRequest); } - public Map> getFieldsFromDE(DataSetTableRequest dataSetTableRequest) throws Exception { + public Map> getFieldsFromDE(DataSetTableRequest dataSetTableRequest) + throws Exception { DatasetTableField datasetTableField = DatasetTableField.builder().build(); datasetTableField.setTableId(dataSetTableRequest.getId()); datasetTableField.setChecked(Boolean.TRUE); @@ -441,10 +454,11 @@ public class DataSetTableService { return map; } - - public Map getPreviewData(DataSetTableRequest dataSetTableRequest, Integer page, Integer pageSize, List extFields) throws Exception { + public Map getPreviewData(DataSetTableRequest dataSetTableRequest, Integer page, Integer pageSize, + List extFields) throws Exception { Map map = new HashMap<>(); - DatasetTableField datasetTableField = DatasetTableField.builder().tableId(dataSetTableRequest.getId()).checked(Boolean.TRUE).build(); + DatasetTableField datasetTableField = DatasetTableField.builder().tableId(dataSetTableRequest.getId()) + .checked(Boolean.TRUE).build(); List fields = dataSetTableFieldsService.list(datasetTableField); if (CollectionUtils.isNotEmpty(extFields)) { fields.addAll(extFields); @@ -456,7 +470,7 @@ public class DataSetTableService { return map; } DatasetTable datasetTable = datasetTableMapper.selectByPrimaryKey(dataSetTableRequest.getId()); - //列权限 + // 列权限 List desensitizationList = new ArrayList<>(); fields = permissionService.filterColumnPermissons(fields, desensitizationList, datasetTable.getId(), null); if (CollectionUtils.isEmpty(fields)) { @@ -465,19 +479,20 @@ public class DataSetTableService { map.put("page", new DataSetPreviewPage()); return map; } - //行权限 + // 行权限 List customFilter = permissionService.getCustomFilters(fields, datasetTable, null); String[] fieldArray = fields.stream().map(DatasetTableField::getDataeaseName).toArray(String[]::new); DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); - List data = new ArrayList<>(); DataSetPreviewPage dataSetPreviewPage = new DataSetPreviewPage(); dataSetPreviewPage.setShow(Integer.valueOf(dataSetTableRequest.getRow())); dataSetPreviewPage.setPage(page); dataSetPreviewPage.setPageSize(pageSize); - int realSize = Integer.parseInt(dataSetTableRequest.getRow()) < pageSize ? Integer.parseInt(dataSetTableRequest.getRow()) : pageSize; + int realSize = Integer.parseInt(dataSetTableRequest.getRow()) < pageSize + ? Integer.parseInt(dataSetTableRequest.getRow()) + : pageSize; if (page == Integer.parseInt(dataSetTableRequest.getRow()) / pageSize + 1) { realSize = Integer.parseInt(dataSetTableRequest.getRow()) % pageSize; } @@ -496,8 +511,8 @@ public class DataSetTableService { String table = dataTableInfoDTO.getTable(); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); datasourceRequest.setPage(page); @@ -514,7 +529,8 @@ public class DataSetTableService { } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); datasourceRequest.setPageable(false); dataSetPreviewPage.setTotal(datasourceProvider.getData(datasourceRequest).size()); } catch (Exception e) { @@ -532,7 +548,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); try { data.addAll(jdbcProvider.getData(datasourceRequest)); @@ -541,7 +558,8 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_ds_error") + "->" + e.getMessage()); } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); dataSetPreviewPage.setTotal(jdbcProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -564,7 +582,8 @@ public class DataSetTableService { String sql = dataTableInfoDTO.getSql(); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); + datasourceRequest.setQuery( + qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); map.put("sql", datasourceRequest.getQuery()); datasourceRequest.setPage(page); datasourceRequest.setFetchSize(Integer.parseInt(dataSetTableRequest.getRow())); @@ -580,7 +599,8 @@ public class DataSetTableService { } try { datasourceRequest.setPageable(false); - datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); + datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); dataSetPreviewPage.setTotal(datasourceProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -597,7 +617,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); try { data.addAll(jdbcProvider.getData(datasourceRequest)); @@ -606,7 +627,8 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_ds_error") + "->" + e.getMessage()); } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); dataSetPreviewPage.setTotal(jdbcProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -624,7 +646,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); try { data.addAll(jdbcProvider.getData(datasourceRequest)); @@ -633,7 +656,8 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_ds_error") + "->" + e.getMessage()); } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); dataSetPreviewPage.setTotal(jdbcProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -650,7 +674,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); DataTableInfoDTO dt = new Gson().fromJson(datasetTable.getInfo(), DataTableInfoDTO.class); - List list = dataSetTableUnionService.listByTableId(dt.getList().get(0).getTableId()); + List list = dataSetTableUnionService + .listByTableId(dt.getList().get(0).getTableId()); String sql = ""; try { @@ -660,7 +685,8 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_ds_error") + "->" + e.getMessage()); } QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); + datasourceRequest.setQuery( + qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); map.put("sql", datasourceRequest.getQuery()); datasourceRequest.setPage(page); datasourceRequest.setFetchSize(Integer.parseInt(dataSetTableRequest.getRow())); @@ -676,7 +702,8 @@ public class DataSetTableService { } try { datasourceRequest.setPageable(false); - datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); + datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); dataSetPreviewPage.setTotal(datasourceProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -689,7 +716,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); try { data.addAll(jdbcProvider.getData(datasourceRequest)); @@ -699,7 +727,8 @@ public class DataSetTableService { } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); dataSetPreviewPage.setTotal(jdbcProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -726,7 +755,8 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_ds_error") + "->" + e.getMessage()); } QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); + datasourceRequest.setQuery( + qp.createQuerySQLWithPage(sql, fields, page, pageSize, realSize, false, customFilter)); map.put("sql", datasourceRequest.getQuery()); datasourceRequest.setPage(page); datasourceRequest.setFetchSize(Integer.parseInt(dataSetTableRequest.getRow())); @@ -742,7 +772,8 @@ public class DataSetTableService { } try { datasourceRequest.setPageable(false); - datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); + datasourceRequest.setQuery(qp.createQuerySqlWithLimit(sql, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, customFilter)); dataSetPreviewPage.setTotal(datasourceProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -755,7 +786,8 @@ public class DataSetTableService { datasourceRequest.setDatasource(ds); String table = DorisTableUtils.dorisName(dataSetTableRequest.getId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - datasourceRequest.setQuery(qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); + datasourceRequest.setQuery( + qp.createQueryTableWithPage(table, fields, page, pageSize, realSize, false, ds, customFilter)); map.put("sql", datasourceRequest.getQuery()); try { data.addAll(jdbcProvider.getData(datasourceRequest)); @@ -765,7 +797,8 @@ public class DataSetTableService { } try { - datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); + datasourceRequest.setQuery(qp.createQueryTableWithLimit(table, fields, + Integer.valueOf(dataSetTableRequest.getRow()), false, ds, customFilter)); dataSetPreviewPage.setTotal(jdbcProvider.getData(datasourceRequest).size()); } catch (Exception e) { logger.error(e.getMessage()); @@ -880,8 +913,12 @@ public class DataSetTableService { // 获取每个字段在当前de数据库中的name,作为sql查询后的remarks返回前端展示 for (DatasetTableField datasetTableField : fieldList) { for (TableFiled tableFiled : fields) { - if (StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), DorisTableUtils.dorisFieldName(datasetTableField.getTableId() + "_" + datasetTableField.getDataeaseName())) - || StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), DorisTableUtils.dorisFieldNameShort(datasetTableField.getTableId() + "_" + datasetTableField.getOriginName()))) { + if (StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), + DorisTableUtils.dorisFieldName( + datasetTableField.getTableId() + "_" + datasetTableField.getDataeaseName())) + || StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), + DorisTableUtils.dorisFieldNameShort(datasetTableField.getTableId() + "_" + + datasetTableField.getOriginName()))) { tableFiled.setRemarks(datasetTableField.getName()); break; } @@ -898,7 +935,8 @@ public class DataSetTableService { public Map getCustomPreview(DataSetTableRequest dataSetTableRequest) throws Exception { DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); - List list = dataSetTableUnionService.listByTableId(dataTableInfoDTO.getList().get(0).getTableId()); + List list = dataSetTableUnionService + .listByTableId(dataTableInfoDTO.getList().get(0).getTableId()); String sql; DatasourceRequest datasourceRequest = new DatasourceRequest(); @@ -935,11 +973,15 @@ public class DataSetTableService { // 获取每个字段在当前de数据库中的name,作为sql查询后的remarks返回前端展示 List checkedFieldList = new ArrayList<>(); - dataTableInfoDTO.getList().forEach(ele -> checkedFieldList.addAll(dataSetTableFieldsService.getListByIds(ele.getCheckedFields()))); + dataTableInfoDTO.getList().forEach( + ele -> checkedFieldList.addAll(dataSetTableFieldsService.getListByIds(ele.getCheckedFields()))); for (DatasetTableField datasetTableField : checkedFieldList) { for (TableFiled tableFiled : fields) { - if (StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), DorisTableUtils.dorisFieldName(datasetTableField.getTableId() + "_" + datasetTableField.getDataeaseName())) - || StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), DorisTableUtils.dorisFieldName(datasetTableField.getTableId() + "_" + datasetTableField.getOriginName()))) { + if (StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), + DorisTableUtils.dorisFieldName( + datasetTableField.getTableId() + "_" + datasetTableField.getDataeaseName())) + || StringUtils.equalsIgnoreCase(tableFiled.getFieldName(), DorisTableUtils.dorisFieldName( + datasetTableField.getTableId() + "_" + datasetTableField.getOriginName()))) { tableFiled.setRemarks(datasetTableField.getName()); break; } @@ -967,7 +1009,10 @@ public class DataSetTableService { if (CollectionUtils.isEmpty(fields)) { throw new RuntimeException(Translator.get("i18n_cst_ds_tb_or_field_deleted")); } - String[] array = fields.stream().map(f -> table + "." + f.getDataeaseName() + " AS " + DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getDataeaseName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> table + "." + f.getDataeaseName() + " AS " + + DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getDataeaseName())) + .toArray(String[]::new); customInfo.put(table, array); }); DataTableInfoCustomUnion first = dataTableInfoDTO.getList().get(0); @@ -994,25 +1039,32 @@ public class DataSetTableService { join.append(convertUnionTypeToSQL(dto.getSourceUnionRelation())) .append(DorisTableUtils.dorisName(dto.getTargetTableId())) .append(" ON ") - .append(DorisTableUtils.dorisName(dto.getSourceTableId())).append(".").append(sourceField.getDataeaseName()) + .append(DorisTableUtils.dorisName(dto.getSourceTableId())).append(".") + .append(sourceField.getDataeaseName()) .append(" = ") - .append(DorisTableUtils.dorisName(dto.getTargetTableId())).append(".").append(targetField.getDataeaseName()); + .append(DorisTableUtils.dorisName(dto.getTargetTableId())).append(".") + .append(targetField.getDataeaseName()); } } } if (StringUtils.isEmpty(f)) { throw new RuntimeException(Translator.get("i18n_custom_ds_delete")); } - return MessageFormat.format("SELECT {0} FROM {1}", f, DorisTableUtils.dorisName(first.getTableId())) + join.toString(); + return MessageFormat.format("SELECT {0} FROM {1}", f, DorisTableUtils.dorisName(first.getTableId())) + + join.toString(); } else { - if (StringUtils.isEmpty(StringUtils.join(customInfo.get(DorisTableUtils.dorisName(first.getTableId())), ","))) { + if (StringUtils + .isEmpty(StringUtils.join(customInfo.get(DorisTableUtils.dorisName(first.getTableId())), ","))) { throw new RuntimeException(Translator.get("i18n_custom_ds_delete")); } - return MessageFormat.format("SELECT {0} FROM {1}", StringUtils.join(customInfo.get(DorisTableUtils.dorisName(first.getTableId())), ","), DorisTableUtils.dorisName(first.getTableId())); + return MessageFormat.format("SELECT {0} FROM {1}", + StringUtils.join(customInfo.get(DorisTableUtils.dorisName(first.getTableId())), ","), + DorisTableUtils.dorisName(first.getTableId())); } } - public String getCustomSQLDatasource(DataTableInfoDTO dataTableInfoDTO, List list, Datasource ds) { + public String getCustomSQLDatasource(DataTableInfoDTO dataTableInfoDTO, List list, + Datasource ds) { DatasourceTypes datasourceTypes = DatasourceTypes.valueOf(ds.getType()); String keyword = datasourceTypes.getKeywordPrefix() + "%s" + datasourceTypes.getKeywordSuffix(); Map customInfo = new TreeMap<>(); @@ -1026,7 +1078,10 @@ public class DataSetTableService { if (CollectionUtils.isEmpty(fields)) { throw new RuntimeException(Translator.get("i18n_cst_ds_tb_or_field_deleted")); } - String[] array = fields.stream().map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getOriginName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + + DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getOriginName())) + .toArray(String[]::new); customInfo.put(table, array); } DataTableInfoCustomUnion first = dataTableInfoDTO.getList().get(0); @@ -1052,15 +1107,19 @@ public class DataSetTableService { DEException.throwException(Translator.get("i18n_dataset_field_delete")); } DatasetTable sourceTable = datasetTableMapper.selectByPrimaryKey(dto.getSourceTableId()); - String sourceTableName = new Gson().fromJson(sourceTable.getInfo(), DataTableInfoDTO.class).getTable(); + String sourceTableName = new Gson().fromJson(sourceTable.getInfo(), DataTableInfoDTO.class) + .getTable(); DatasetTable targetTable = datasetTableMapper.selectByPrimaryKey(dto.getTargetTableId()); - String targetTableName = new Gson().fromJson(targetTable.getInfo(), DataTableInfoDTO.class).getTable(); + String targetTableName = new Gson().fromJson(targetTable.getInfo(), DataTableInfoDTO.class) + .getTable(); join.append(convertUnionTypeToSQL(dto.getSourceUnionRelation())) .append(String.format(keyword, targetTableName)) .append(" ON ") - .append(String.format(keyword, sourceTableName)).append(".").append(String.format(keyword, sourceField.getOriginName())) + .append(String.format(keyword, sourceTableName)).append(".") + .append(String.format(keyword, sourceField.getOriginName())) .append(" = ") - .append(String.format(keyword, targetTableName)).append(".").append(String.format(keyword, targetField.getOriginName())); + .append(String.format(keyword, targetTableName)).append(".") + .append(String.format(keyword, targetField.getOriginName())); } } } @@ -1072,7 +1131,8 @@ public class DataSetTableService { if (StringUtils.isEmpty(StringUtils.join(customInfo.get(tableName), ","))) { throw new RuntimeException(Translator.get("i18n_custom_ds_delete")); } - return MessageFormat.format("SELECT {0} FROM {1}", StringUtils.join(customInfo.get(tableName), ","), String.format(keyword, tableName)); + return MessageFormat.format("SELECT {0} FROM {1}", StringUtils.join(customInfo.get(tableName), ","), + String.format(keyword, tableName)); } } @@ -1109,11 +1169,15 @@ public class DataSetTableService { String table = DorisTableUtils.dorisName(tableId); DatasetTable datasetTable = datasetTableMapper.selectByPrimaryKey(tableId); if (ObjectUtils.isEmpty(datasetTable)) { - DEException.throwException(Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); + DEException.throwException( + Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); } List fields = dataSetTableFieldsService.getListByIdsEach(unionDTO.getCurrentDsField()); - String[] array = fields.stream().map(f -> table + "." + f.getDataeaseName() + " AS " + DorisTableUtils.dorisFieldName(tableId + "_" + f.getDataeaseName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> table + "." + f.getDataeaseName() + " AS " + + DorisTableUtils.dorisFieldName(tableId + "_" + f.getDataeaseName())) + .toArray(String[]::new); checkedInfo.put(table, array); checkedFields.addAll(fields); // 获取child的fields和union @@ -1149,12 +1213,16 @@ public class DataSetTableService { for (int i = 0; i < unionParamDTO.getUnionFields().size(); i++) { UnionItemDTO unionItemDTO = unionParamDTO.getUnionFields().get(i); // 通过field id取得field详情,并且以第一组为准,寻找dataset table - DatasetTableField parentField = dataSetTableFieldsService.get(unionItemDTO.getParentField().getId()); - DatasetTableField currentField = dataSetTableFieldsService.get(unionItemDTO.getCurrentField().getId()); + DatasetTableField parentField = dataSetTableFieldsService + .get(unionItemDTO.getParentField().getId()); + DatasetTableField currentField = dataSetTableFieldsService + .get(unionItemDTO.getCurrentField().getId()); - join.append(DorisTableUtils.dorisName(parentTable.getId())).append(".").append(parentField.getDataeaseName()) + join.append(DorisTableUtils.dorisName(parentTable.getId())).append(".") + .append(parentField.getDataeaseName()) .append(" = ") - .append(DorisTableUtils.dorisName(currentTable.getId())).append(".").append(currentField.getDataeaseName()); + .append(DorisTableUtils.dorisName(currentTable.getId())).append(".") + .append(currentField.getDataeaseName()); if (i < unionParamDTO.getUnionFields().size() - 1) { join.append(" AND "); } @@ -1163,13 +1231,16 @@ public class DataSetTableService { if (StringUtils.isEmpty(f)) { DEException.throwException(Translator.get("i18n_union_ds_no_checked")); } - sql = MessageFormat.format("SELECT {0} FROM {1}", f, DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())) + join.toString(); + sql = MessageFormat.format("SELECT {0} FROM {1}", f, + DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())) + join.toString(); } else { - String f = StringUtils.join(checkedInfo.get(DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())), ","); + String f = StringUtils.join(checkedInfo.get(DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())), + ","); if (StringUtils.isEmpty(f)) { throw new RuntimeException(Translator.get("i18n_union_ds_no_checked")); } - sql = MessageFormat.format("SELECT {0} FROM {1}", f, DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())); + sql = MessageFormat.format("SELECT {0} FROM {1}", f, + DorisTableUtils.dorisName(union.get(0).getCurrentDs().getId())); } Map map = new HashMap<>(); map.put("sql", sql); @@ -1179,18 +1250,23 @@ public class DataSetTableService { } // 递归计算出所有子级的checkedFields和unionParam - private void getUnionSQLDorisJoin(List childrenDs, Map checkedInfo, List unionList, List checkedFields) { + private void getUnionSQLDorisJoin(List childrenDs, Map checkedInfo, + List unionList, List checkedFields) { for (int i = 0; i < childrenDs.size(); i++) { UnionDTO unionDTO = childrenDs.get(i); String tableId = unionDTO.getCurrentDs().getId(); String table = DorisTableUtils.dorisName(tableId); DatasetTable datasetTable = datasetTableMapper.selectByPrimaryKey(tableId); if (ObjectUtils.isEmpty(datasetTable)) { - DEException.throwException(Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); + DEException.throwException( + Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); } List fields = dataSetTableFieldsService.getListByIdsEach(unionDTO.getCurrentDsField()); - String[] array = fields.stream().map(f -> table + "." + f.getDataeaseName() + " AS " + DorisTableUtils.dorisFieldName(tableId + "_" + f.getDataeaseName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> table + "." + f.getDataeaseName() + " AS " + + DorisTableUtils.dorisFieldName(tableId + "_" + f.getDataeaseName())) + .toArray(String[]::new); checkedInfo.put(table, array); checkedFields.addAll(fields); @@ -1212,17 +1288,24 @@ public class DataSetTableService { List unionList = new ArrayList<>(); List checkedFields = new ArrayList<>(); String sql = ""; - String tableName = new Gson().fromJson(datasetTableMapper.selectByPrimaryKey(union.get(0).getCurrentDs().getId()).getInfo(), DataTableInfoDTO.class).getTable(); + String tableName = new Gson() + .fromJson(datasetTableMapper.selectByPrimaryKey(union.get(0).getCurrentDs().getId()).getInfo(), + DataTableInfoDTO.class) + .getTable(); for (UnionDTO unionDTO : union) { DatasetTable datasetTable = datasetTableMapper.selectByPrimaryKey(unionDTO.getCurrentDs().getId()); String table = new Gson().fromJson(datasetTable.getInfo(), DataTableInfoDTO.class).getTable(); String tableId = unionDTO.getCurrentDs().getId(); if (ObjectUtils.isEmpty(datasetTable)) { - DEException.throwException(Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); + DEException.throwException( + Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); } List fields = dataSetTableFieldsService.getListByIdsEach(unionDTO.getCurrentDsField()); - String[] array = fields.stream().map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + DorisTableUtils.dorisFieldNameShort(tableId + "_" + f.getOriginName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + + DorisTableUtils.dorisFieldNameShort(tableId + "_" + f.getOriginName())) + .toArray(String[]::new); checkedInfo.put(table, array); checkedFields.addAll(fields); // 获取child的fields和union @@ -1253,19 +1336,24 @@ public class DataSetTableService { DatasetTable parentTable = datasetTableMapper.selectByPrimaryKey(pField.getTableId()); String parentTableName = new Gson().fromJson(parentTable.getInfo(), DataTableInfoDTO.class).getTable(); DatasetTable currentTable = datasetTableMapper.selectByPrimaryKey(cField.getTableId()); - String currentTableName = new Gson().fromJson(currentTable.getInfo(), DataTableInfoDTO.class).getTable(); + String currentTableName = new Gson().fromJson(currentTable.getInfo(), DataTableInfoDTO.class) + .getTable(); join.append(" ").append(joinType).append(" ").append(String.format(keyword, currentTableName)) .append(" ON "); for (int i = 0; i < unionParamDTO.getUnionFields().size(); i++) { UnionItemDTO unionItemDTO = unionParamDTO.getUnionFields().get(i); // 通过field id取得field详情,并且以第一组为准,寻找dataset table - DatasetTableField parentField = dataSetTableFieldsService.get(unionItemDTO.getParentField().getId()); - DatasetTableField currentField = dataSetTableFieldsService.get(unionItemDTO.getCurrentField().getId()); + DatasetTableField parentField = dataSetTableFieldsService + .get(unionItemDTO.getParentField().getId()); + DatasetTableField currentField = dataSetTableFieldsService + .get(unionItemDTO.getCurrentField().getId()); - join.append(String.format(keyword, parentTableName)).append(".").append(String.format(keyword, parentField.getOriginName())) + join.append(String.format(keyword, parentTableName)).append(".") + .append(String.format(keyword, parentField.getOriginName())) .append(" = ") - .append(String.format(keyword, currentTableName)).append(".").append(String.format(keyword, currentField.getOriginName())); + .append(String.format(keyword, currentTableName)).append(".") + .append(String.format(keyword, currentField.getOriginName())); if (i < unionParamDTO.getUnionFields().size() - 1) { join.append(" AND "); } @@ -1300,20 +1388,25 @@ public class DataSetTableService { } // 递归计算出所有子级的checkedFields和unionParam - private void getUnionSQLDatasourceJoin(List childrenDs, Map checkedInfo, List unionList, String keyword, List checkedFields) { + private void getUnionSQLDatasourceJoin(List childrenDs, Map checkedInfo, + List unionList, String keyword, List checkedFields) { for (int i = 0; i < childrenDs.size(); i++) { UnionDTO unionDTO = childrenDs.get(i); DatasetTable datasetTable = datasetTableMapper.selectByPrimaryKey(unionDTO.getCurrentDs().getId()); String tableId = unionDTO.getCurrentDs().getId(); if (ObjectUtils.isEmpty(datasetTable)) { - DEException.throwException(Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); + DEException.throwException( + Translator.get("i18n_custom_ds_delete") + String.format(":table id [%s]", tableId)); } String table = new Gson().fromJson(datasetTable.getInfo(), DataTableInfoDTO.class).getTable(); List fields = dataSetTableFieldsService.getListByIdsEach(unionDTO.getCurrentDsField()); - String[] array = fields.stream().map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + DorisTableUtils.dorisFieldNameShort(tableId + "_" + f.getOriginName())).toArray(String[]::new); + String[] array = fields.stream() + .map(f -> String.format(keyword, table) + "." + String.format(keyword, f.getOriginName()) + " AS " + + DorisTableUtils.dorisFieldNameShort(tableId + "_" + f.getOriginName())) + .toArray(String[]::new); checkedInfo.put(table, array); checkedFields.addAll(fields); @@ -1366,7 +1459,8 @@ public class DataSetTableService { DatasourceRequest datasourceRequest = new DatasourceRequest(); datasourceRequest.setDatasource(ds); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); - String sqlAsTable = qp.createSQLPreview(new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class).getSql(), null); + String sqlAsTable = qp.createSQLPreview( + new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class).getSql(), null); datasourceRequest.setQuery(sqlAsTable); fields = datasourceProvider.fetchResultField(datasourceRequest); } else if (StringUtils.equalsIgnoreCase(datasetTable.getType(), "excel")) { @@ -1374,12 +1468,15 @@ public class DataSetTableService { } else if (StringUtils.equalsIgnoreCase(datasetTable.getType(), "custom")) { if (datasetTable.getMode() == 1) { // save field - DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); + DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), + DataTableInfoDTO.class); List list = dataTableInfoDTO.getList(); List fieldList = new ArrayList<>(); list.forEach(ele -> { - List listByIds = dataSetTableFieldsService.getListByIdsEach(ele.getCheckedFields()); - listByIds.forEach(f -> f.setDataeaseName(DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getDataeaseName()))); + List listByIds = dataSetTableFieldsService + .getListByIdsEach(ele.getCheckedFields()); + listByIds.forEach(f -> f.setDataeaseName( + DorisTableUtils.dorisFieldName(ele.getTableId() + "_" + f.getDataeaseName()))); fieldList.addAll(listByIds); }); for (int i = 0; i < fieldList.size(); i++) { @@ -1392,7 +1489,8 @@ public class DataSetTableService { dataSetTableFieldsService.batchEdit(fieldList); // custom 创建doris视图 if (datasetTable.getMode() == 1) { - createDorisView(DorisTableUtils.dorisName(datasetTable.getId()), getCustomSQLDoris(dataTableInfoDTO, dataSetTableUnionService.listByTableId(dataTableInfoDTO.getList().get(0).getTableId()))); + createDorisView(DorisTableUtils.dorisName(datasetTable.getId()), getCustomSQLDoris(dataTableInfoDTO, + dataSetTableUnionService.listByTableId(dataTableInfoDTO.getList().get(0).getTableId()))); } return; } else { @@ -1400,21 +1498,26 @@ public class DataSetTableService { DatasourceRequest datasourceRequest = new DatasourceRequest(); datasourceRequest.setDatasource(ds); DataTableInfoDTO dt = new Gson().fromJson(datasetTable.getInfo(), DataTableInfoDTO.class); - List list = dataSetTableUnionService.listByTableId(dt.getList().get(0).getTableId()); + List list = dataSetTableUnionService + .listByTableId(dt.getList().get(0).getTableId()); String sqlAsTable = getCustomSQLDatasource(dt, list, ds); datasourceRequest.setQuery(sqlAsTable); fields = datasourceProvider.fetchResultField(datasourceRequest); - DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); + DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), + DataTableInfoDTO.class); List listField = dataTableInfoDTO.getList(); List fieldList = new ArrayList<>(); listField.forEach(ele -> { - List listByIds = dataSetTableFieldsService.getListByIdsEach(ele.getCheckedFields()); + List listByIds = dataSetTableFieldsService + .getListByIdsEach(ele.getCheckedFields()); fieldList.addAll(listByIds); }); for (DatasetTableField field : fieldList) { for (TableFiled tableFiled : fields) { - if (StringUtils.equalsIgnoreCase(DorisTableUtils.dorisFieldName(field.getTableId() + "_" + field.getOriginName()), tableFiled.getFieldName())) { + if (StringUtils.equalsIgnoreCase( + DorisTableUtils.dorisFieldName(field.getTableId() + "_" + field.getOriginName()), + tableFiled.getFieldName())) { tableFiled.setRemarks(field.getName()); break; } @@ -1428,7 +1531,8 @@ public class DataSetTableService { DatasourceRequest datasourceRequest = new DatasourceRequest(); datasourceRequest.setDatasource(ds); // save field - DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), DataTableInfoDTO.class); + DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(dataSetTableRequest.getInfo(), + DataTableInfoDTO.class); Map sqlMap = getUnionSQLDoris(dataTableInfoDTO); String sql = (String) sqlMap.get("sql"); List fieldList = (List) sqlMap.get("field"); @@ -1441,7 +1545,9 @@ public class DataSetTableService { fields = datasourceProvider.fetchResultField(datasourceRequest); for (DatasetTableField field : fieldList) { for (TableFiled tableFiled : fields) { - if (StringUtils.equalsIgnoreCase(DorisTableUtils.dorisFieldName(field.getTableId() + "_" + field.getDataeaseName()), tableFiled.getFieldName())) { + if (StringUtils.equalsIgnoreCase( + DorisTableUtils.dorisFieldName(field.getTableId() + "_" + field.getDataeaseName()), + tableFiled.getFieldName())) { tableFiled.setRemarks(field.getName()); break; } @@ -1463,7 +1569,9 @@ public class DataSetTableService { for (DatasetTableField field : fieldList) { for (TableFiled tableFiled : fields) { - if (StringUtils.equalsIgnoreCase(DorisTableUtils.dorisFieldNameShort(field.getTableId() + "_" + field.getOriginName()), tableFiled.getFieldName())) { + if (StringUtils.equalsIgnoreCase( + DorisTableUtils.dorisFieldNameShort(field.getTableId() + "_" + field.getOriginName()), + tableFiled.getFieldName())) { tableFiled.setRemarks(field.getName()); break; } @@ -1484,8 +1592,10 @@ public class DataSetTableService { // 物理字段名设定为唯一,查询当前数据集下是否已存在该字段,存在则update,不存在则insert DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample(); // 字段名一致,认为字段没有改变 - datasetTableFieldExample.createCriteria().andTableIdEqualTo(datasetTable.getId()).andOriginNameEqualTo(filed.getFieldName()); - List datasetTableFields = datasetTableFieldMapper.selectByExample(datasetTableFieldExample); + datasetTableFieldExample.createCriteria().andTableIdEqualTo(datasetTable.getId()) + .andOriginNameEqualTo(filed.getFieldName()); + List datasetTableFields = datasetTableFieldMapper + .selectByExample(datasetTableFieldExample); if (CollectionUtils.isNotEmpty(datasetTableFields)) { datasetTableField.setId(datasetTableFields.get(0).getId()); datasetTableField.setOriginName(filed.getFieldName()); @@ -1526,7 +1636,8 @@ public class DataSetTableService { } // delete 数据库中多余的字段 DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample(); - datasetTableFieldExample.createCriteria().andTableIdEqualTo(datasetTable.getId()).andExtFieldEqualTo(0).andOriginNameNotIn(originNameList); + datasetTableFieldExample.createCriteria().andTableIdEqualTo(datasetTable.getId()).andExtFieldEqualTo(0) + .andOriginNameNotIn(originNameList); datasetTableFieldMapper.deleteByExample(datasetTableFieldExample); } } @@ -1560,7 +1671,8 @@ public class DataSetTableService { } } - public DatasetTableIncrementalConfig incrementalConfig(DatasetTableIncrementalConfig datasetTableIncrementalConfig) { + public DatasetTableIncrementalConfig incrementalConfig( + DatasetTableIncrementalConfig datasetTableIncrementalConfig) { if (StringUtils.isEmpty(datasetTableIncrementalConfig.getTableId())) { return new DatasetTableIncrementalConfig(); } @@ -1581,7 +1693,6 @@ public class DataSetTableService { return incrementalConfig(datasetTableIncrementalConfig); } - public void saveIncrementalConfig(DatasetTableIncrementalConfig datasetTableIncrementalConfig) throws Exception { if (datasetTableIncrementalConfig == null || StringUtils.isEmpty(datasetTableIncrementalConfig.getTableId())) { return; @@ -1608,21 +1719,25 @@ public class DataSetTableService { return o1.getColumnIndex().compareTo(o2.getColumnIndex()); }); - List originNameFileds = datasetTableFields.stream().map(DatasetTableField::getOriginName).collect(Collectors.toList()); + List originNameFileds = datasetTableFields.stream().map(DatasetTableField::getOriginName) + .collect(Collectors.toList()); Datasource ds = datasourceMapper.selectByPrimaryKey(datasetTable.getDataSourceId()); QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType()); DatasourceProvider datasourceProvider = ProviderFactory.getProvider(ds.getType()); DatasourceRequest datasourceRequest = new DatasourceRequest(); datasourceRequest.setDatasource(ds); - if (StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd()) && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd().replace(" ", ""))) {// 增量添加 - String sql = datasetTableIncrementalConfig.getIncrementalAdd().replace(lastUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()) + if (StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd()) + && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalAdd().replace(" ", ""))) {// 增量添加 + String sql = datasetTableIncrementalConfig.getIncrementalAdd() + .replace(lastUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()) .replace(currentUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()); datasourceRequest.setQuery(qp.wrapSql(sql)); List sqlFileds = new ArrayList<>(); try { - datasourceProvider.fetchResultField(datasourceRequest).stream().map(TableFiled::getFieldName).forEach(filed -> { - sqlFileds.add(filed); - }); + datasourceProvider.fetchResultField(datasourceRequest).stream().map(TableFiled::getFieldName) + .forEach(filed -> { + sqlFileds.add(filed); + }); } catch (Exception e) { DataEaseException.throwException(Translator.get("i18n_check_sql_error") + e.getMessage()); } @@ -1631,13 +1746,16 @@ public class DataSetTableService { DataEaseException.throwException(Translator.get("i18n_sql_add_not_matching") + sqlFileds.toString()); } } - if (StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalDelete()) && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalDelete().replace(" ", ""))) {// 增量删除 - String sql = datasetTableIncrementalConfig.getIncrementalDelete().replace(lastUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()) + if (StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalDelete()) + && StringUtils.isNotEmpty(datasetTableIncrementalConfig.getIncrementalDelete().replace(" ", ""))) {// 增量删除 + String sql = datasetTableIncrementalConfig.getIncrementalDelete() + .replace(lastUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()) .replace(currentUpdateTime, Long.valueOf(System.currentTimeMillis()).toString()); datasourceRequest.setQuery(qp.wrapSql(sql)); List sqlFileds = new ArrayList<>(); try { - datasourceProvider.fetchResultField(datasourceRequest).stream().map(TableFiled::getFieldName).forEach(filed -> sqlFileds.add(filed)); + datasourceProvider.fetchResultField(datasourceRequest).stream().map(TableFiled::getFieldName) + .forEach(filed -> sqlFileds.add(filed)); } catch (Exception e) { DataEaseException.throwException(Translator.get("i18n_check_sql_error") + e.getMessage()); } @@ -1686,7 +1804,8 @@ public class DataSetTableService { if (StringUtils.isNotEmpty(tableId) && editType == 1) { List datasetTableFields = dataSetTableFieldsService.getFieldsByTableId(tableId); - datasetTableFields.stream().filter(datasetTableField -> datasetTableField.getExtField() == 0).collect(Collectors.toList()); + datasetTableFields.stream().filter(datasetTableField -> datasetTableField.getExtField() == 0) + .collect(Collectors.toList()); datasetTableFields.sort((o1, o2) -> { if (o1.getColumnIndex() == null) { return -1; @@ -1696,7 +1815,8 @@ public class DataSetTableService { } return o1.getColumnIndex().compareTo(o2.getColumnIndex()); }); - List oldFields = datasetTableFields.stream().map(DatasetTableField::getOriginName).collect(Collectors.toList()); + List oldFields = datasetTableFields.stream().map(DatasetTableField::getOriginName) + .collect(Collectors.toList()); for (ExcelSheetData excelSheetData : excelSheetDataList) { List fields = excelSheetData.getFields(); List newFields = fields.stream().map(TableFiled::getRemarks).collect(Collectors.toList()); @@ -1711,7 +1831,9 @@ public class DataSetTableService { } else { retrunSheetDataList = excelSheetDataList; } - retrunSheetDataList = retrunSheetDataList.stream().filter(excelSheetData -> CollectionUtils.isNotEmpty(excelSheetData.getFields())).collect(Collectors.toList()); + retrunSheetDataList = retrunSheetDataList.stream() + .filter(excelSheetData -> CollectionUtils.isNotEmpty(excelSheetData.getFields())) + .collect(Collectors.toList()); // save file String excelId = UUID.randomUUID().toString(); String filePath = saveFile(file, excelId); @@ -1738,7 +1860,8 @@ public class DataSetTableService { return excelFileData; } - private List parseExcel2(String filename, InputStream inputStream, boolean isPreview) throws Exception { + private List parseExcel2(String filename, InputStream inputStream, boolean isPreview) + throws Exception { List excelSheetDataList = new ArrayList<>(); String suffix = filename.substring(filename.lastIndexOf(".") + 1); if (StringUtils.equalsIgnoreCase(suffix, "xls")) { @@ -1754,7 +1877,8 @@ public class DataSetTableService { inputStream.close(); excelSheetDataList.forEach(excelSheetData -> { List> data = excelSheetData.getData(); - String[] fieldArray = excelSheetData.getFields().stream().map(TableFiled::getFieldName).toArray(String[]::new); + String[] fieldArray = excelSheetData.getFields().stream().map(TableFiled::getFieldName) + .toArray(String[]::new); List> jsonArray = new ArrayList<>(); if (CollectionUtils.isNotEmpty(data)) { jsonArray = data.stream().map(ele -> { @@ -1772,7 +1896,8 @@ public class DataSetTableService { return excelSheetDataList; } - private Map parseExcel(String filename, InputStream inputStream, boolean isPreview) throws Exception { + private Map parseExcel(String filename, InputStream inputStream, boolean isPreview) + throws Exception { String suffix = filename.substring(filename.lastIndexOf(".") + 1); List fields = new ArrayList<>(); List data = new ArrayList<>(); @@ -1925,7 +2050,6 @@ public class DataSetTableService { return map; } - private String readCell(Cell cell, boolean cellType, TableFiled tableFiled) { if (cell == null) { return ""; @@ -1939,7 +2063,8 @@ public class DataSetTableService { double eps = 1e-10; if (value - Math.floor(value) < eps) { if (cellType) { - if (StringUtils.isEmpty(tableFiled.getFieldType()) || tableFiled.getFieldType().equalsIgnoreCase("TEXT")) { + if (StringUtils.isEmpty(tableFiled.getFieldType()) + || tableFiled.getFieldType().equalsIgnoreCase("TEXT")) { tableFiled.setFieldType("LONG"); } } @@ -1990,7 +2115,8 @@ public class DataSetTableService { double eps = 1e-10; if (value - Math.floor(value) < eps) { if (cellType) { - if (StringUtils.isEmpty(tableFiled.getFieldType()) || tableFiled.getFieldType().equalsIgnoreCase("TEXT")) { + if (StringUtils.isEmpty(tableFiled.getFieldType()) + || tableFiled.getFieldType().equalsIgnoreCase("TEXT")) { tableFiled.setFieldType("LONG"); } } @@ -2048,13 +2174,17 @@ public class DataSetTableService { public void updateDatasetTableStatus() { List qrtzSchedulerStates = qrtzSchedulerStateMapper.selectByExample(null); - List activeQrtzInstances = qrtzSchedulerStates.stream().filter(qrtzSchedulerState -> qrtzSchedulerState.getLastCheckinTime() + qrtzSchedulerState.getCheckinInterval() + 1000 > utilMapper.currentTimestamp()).map(QrtzSchedulerStateKey::getInstanceName).collect(Collectors.toList()); + List activeQrtzInstances = qrtzSchedulerStates.stream() + .filter(qrtzSchedulerState -> qrtzSchedulerState.getLastCheckinTime() + + qrtzSchedulerState.getCheckinInterval() + 1000 > utilMapper.currentTimestamp()) + .map(QrtzSchedulerStateKey::getInstanceName).collect(Collectors.toList()); List jobStoppeddDatasetTables = new ArrayList<>(); DatasetTableExample example = new DatasetTableExample(); example.createCriteria().andSyncStatusEqualTo(JobStatus.Underway.name()); datasetTableMapper.selectByExample(example).forEach(datasetTable -> { - if (StringUtils.isEmpty(datasetTable.getQrtzInstance()) || !activeQrtzInstances.contains(datasetTable.getQrtzInstance().substring(0, datasetTable.getQrtzInstance().length() - 13))) { + if (StringUtils.isEmpty(datasetTable.getQrtzInstance()) || !activeQrtzInstances.contains( + datasetTable.getQrtzInstance().substring(0, datasetTable.getQrtzInstance().length() - 13))) { jobStoppeddDatasetTables.add(datasetTable); } }); @@ -2066,7 +2196,8 @@ public class DataSetTableService { DatasetTable record = new DatasetTable(); record.setSyncStatus(JobStatus.Error.name()); example.clear(); - example.createCriteria().andSyncStatusEqualTo(JobStatus.Underway.name()).andIdIn(jobStoppeddDatasetTables.stream().map(DatasetTable::getId).collect(Collectors.toList())); + example.createCriteria().andSyncStatusEqualTo(JobStatus.Underway.name()) + .andIdIn(jobStoppeddDatasetTables.stream().map(DatasetTable::getId).collect(Collectors.toList())); datasetTableMapper.updateByExampleSelective(record, example); DatasetTableTaskLog datasetTableTaskLog = new DatasetTableTaskLog(); @@ -2074,8 +2205,10 @@ public class DataSetTableService { datasetTableTaskLog.setInfo("Job stopped due to system error."); DatasetTableTaskLogExample datasetTableTaskLogExample = new DatasetTableTaskLogExample(); - datasetTableTaskLogExample.createCriteria().andStatusEqualTo(JobStatus.Underway.name()).andTableIdIn(jobStoppeddDatasetTables.stream().map(DatasetTable::getId).collect(Collectors.toList())); - List taskIds = datasetTableTaskLogMapper.selectByExample(datasetTableTaskLogExample).stream().map(DatasetTableTaskLog::getTaskId).collect(Collectors.toList()); + datasetTableTaskLogExample.createCriteria().andStatusEqualTo(JobStatus.Underway.name()) + .andTableIdIn(jobStoppeddDatasetTables.stream().map(DatasetTable::getId).collect(Collectors.toList())); + List taskIds = datasetTableTaskLogMapper.selectByExample(datasetTableTaskLogExample).stream() + .map(DatasetTableTaskLog::getTaskId).collect(Collectors.toList()); datasetTableTaskLogMapper.updateByExampleSelective(datasetTableTaskLog, datasetTableTaskLogExample); dataSetTableTaskService.updateTaskStatus(taskIds, JobStatus.Error); diff --git a/backend/src/main/resources/i18n/messages_en_US.properties b/backend/src/main/resources/i18n/messages_en_US.properties index 3dd0773369..a4d73c1fec 100644 --- a/backend/src/main/resources/i18n/messages_en_US.properties +++ b/backend/src/main/resources/i18n/messages_en_US.properties @@ -116,3 +116,4 @@ i18n_rp_exist=Row permission of the same type already exists i18n_field_name_repeat=Field name can't repeat i18n_calc_field_error=Field expression error i18n_cp_exist=Column permission of the same type already exists +connection_failed=Connection Failed \ No newline at end of file diff --git a/backend/src/main/resources/i18n/messages_zh_CN.properties b/backend/src/main/resources/i18n/messages_zh_CN.properties index f17e5ae3f7..2179e63f7b 100644 --- a/backend/src/main/resources/i18n/messages_zh_CN.properties +++ b/backend/src/main/resources/i18n/messages_zh_CN.properties @@ -115,3 +115,4 @@ i18n_rp_exist=已有同类型的行权限存在 i18n_field_name_repeat=字段名不能重复 i18n_calc_field_error=字段表达式语法错误 i18n_cp_exist=已有同类型的列权限存在 +connection_failed=连接失败 diff --git a/backend/src/main/resources/i18n/messages_zh_TW.properties b/backend/src/main/resources/i18n/messages_zh_TW.properties index 6b3fbf9867..49b17f5dde 100644 --- a/backend/src/main/resources/i18n/messages_zh_TW.properties +++ b/backend/src/main/resources/i18n/messages_zh_TW.properties @@ -116,3 +116,4 @@ i18n_rp_exist=已有同類型的行權限存在 i18n_field_name_repeat=字段名不能重復 i18n_calc_field_error=字段表達式語法錯誤 i18n_cp_exist=已有同類型的列權限存在 +connection_failed=連接失敗 diff --git a/frontend/src/components/DeDrag/index.vue b/frontend/src/components/DeDrag/index.vue index a53416fd9d..15419e187b 100644 --- a/frontend/src/components/DeDrag/index.vue +++ b/frontend/src/components/DeDrag/index.vue @@ -539,6 +539,20 @@ export default { curGap() { return (this.canvasStyleData.panel.gap === 'yes' && this.element.auxiliaryMatrix) ? this.componentGap : 0 }, + miniWidth() { + return this.element.auxiliaryMatrix ? this.curCanvasScale.matrixStyleWidth * (this.element.miniSizex || 1) : 0 + }, + miniHeight() { + if (this.element.auxiliaryMatrix) { + if (this.element.component === 'de-number-range') { + return this.element.auxiliaryMatrix ? this.curCanvasScale.matrixStyleHeight * (this.element.miniSizey || 2) : 0 + } else { + return this.element.auxiliaryMatrix ? this.curCanvasScale.matrixStyleHeight * (this.element.miniSizey || 1) : 0 + } + } else { + return 0 + } + }, ...mapState([ 'editor', 'curCanvasScale', @@ -1190,8 +1204,10 @@ export default { newH = restrictToBounds(newH, 0, this.parentHeight) } // 外部传参限制大小 - newW = restrictToBounds(newW, this.minW || 0, this.maxW) - newH = restrictToBounds(newH, this.minH || 0, this.maxH) + // newW = restrictToBounds(newW, this.minW || 0, this.maxW) + // newH = restrictToBounds(newH, this.minH || 0, this.maxH) + newW = restrictToBounds(newW, this.miniWidth || 0, this.maxW) + newH = restrictToBounds(newH, this.miniHeight || 0, this.maxH) // 纵横比 if (this.lockAspectRatio) { // console.log(this.lockAspectRatio, this.aspectFactor) diff --git a/frontend/src/components/canvas/components/Editor/EditBar.vue b/frontend/src/components/canvas/components/Editor/EditBar.vue index d1d34c4f3f..881914e264 100644 --- a/frontend/src/components/canvas/components/Editor/EditBar.vue +++ b/frontend/src/components/canvas/components/Editor/EditBar.vue @@ -102,6 +102,16 @@ export default { linkageInfo() { return this.targetLinkageInfo[this.element.propValue.viewId] }, + miniHeight() { + let miniHeight = this.curComponent.miniSizey || 1 + if (this.element.component === 'de-number-range') { + miniHeight = this.curComponent.miniSizey || 2 + } + return miniHeight + }, + miniWidth() { + return this.curComponent.miniSizex || 1 + }, ...mapState([ 'menuTop', 'menuLeft', @@ -146,6 +156,8 @@ export default { this.curComponent.y = Math.round(this.curComponent.style.top / this.curCanvasScale.matrixStyleOriginHeight) + 1 this.curComponent.sizex = Math.round(this.curComponent.style.width / this.curCanvasScale.matrixStyleOriginWidth) this.curComponent.sizey = Math.round(this.curComponent.style.height / this.curCanvasScale.matrixStyleOriginHeight) + this.curComponent.sizey = this.curComponent.sizey > this.miniHeight ? this.curComponent.sizey : this.miniHeight + this.curComponent.sizex = this.curComponent.sizex > this.miniWidth ? this.curComponent.sizex : this.miniWidth this.curComponent.auxiliaryMatrix = true this.$emit('amAddItem') } diff --git a/frontend/src/components/canvas/components/Editor/index.vue b/frontend/src/components/canvas/components/Editor/index.vue index b5ff7bcd48..2584a9ed8b 100644 --- a/frontend/src/components/canvas/components/Editor/index.vue +++ b/frontend/src/components/canvas/components/Editor/index.vue @@ -939,7 +939,8 @@ export default { 'curLinkageView', 'doSnapshotIndex', 'componentGap', - 'mobileLayoutStatus' + 'mobileLayoutStatus', + 'curCanvasScale' ]) }, watch: { diff --git a/frontend/src/components/canvas/custom-component/component-list.js b/frontend/src/components/canvas/custom-component/component-list.js index ab36a8611e..77e109b029 100644 --- a/frontend/src/components/canvas/custom-component/component-list.js +++ b/frontend/src/components/canvas/custom-component/component-list.js @@ -11,6 +11,8 @@ export const BASE_MOBILE_STYLE = { y: 1, sizex: 6, sizey: 4, + miniSizex: 1, + miniSizey: 1, auxiliaryMatrix: true } @@ -158,7 +160,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 2 + sizey: 2, + miniSizex: 1, + miniSizey: 1 }, { id: '10002', @@ -181,7 +185,9 @@ const list = [ textAlign: '', color: '', backgroundColor: '' - } + }, + miniSizex: 1, + miniSizey: 1 }, { id: '10003', @@ -199,7 +205,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 6 + sizey: 6, + miniSizex: 1, + miniSizey: 1 }, { id: '10003-1', @@ -215,7 +223,9 @@ const list = [ width: 600, height: 300, borderRadius: '' - } + }, + miniSizex: 1, + miniSizey: 1 }, { id: '10004', @@ -237,7 +247,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 6 + sizey: 6, + miniSizex: 1, + miniSizey: 1 }, { id: '10005', @@ -256,7 +268,9 @@ const list = [ y: 36, sizex: 10, sizey: 6, - auxiliaryMatrix: true + auxiliaryMatrix: true, + miniSizex: 1, + miniSizey: 1 }, { id: '10006', @@ -285,7 +299,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 10 + sizey: 10, + miniSizex: 1, + miniSizey: 1 }, { id: '30001', @@ -322,7 +338,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 2 + sizey: 2, + miniSizex: 1, + miniSizey: 1 }, { id: '20001', @@ -341,7 +359,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 5 + sizey: 5, + miniSizex: 1, + miniSizey: 1 }, { id: '20002', @@ -360,7 +380,9 @@ const list = [ x: 1, y: 1, sizex: 10, - sizey: 5 + sizey: 5, + miniSizex: 1, + miniSizey: 1 } ] diff --git a/frontend/src/components/widget/DeWidget/DeSelectGrid.vue b/frontend/src/components/widget/DeWidget/DeSelectGrid.vue index 17c719eb5c..2fa8a45e49 100644 --- a/frontend/src/components/widget/DeWidget/DeSelectGrid.vue +++ b/frontend/src/components/widget/DeWidget/DeSelectGrid.vue @@ -127,14 +127,20 @@ export default { }, 'element.options.attrs.multiple': function(value, old) { if (typeof old === 'undefined' || value === old) return - // if (!this.inDraw) { - this.value = value ? [] : null - this.element.options.value = '' - // } + if (!this.inDraw) { + this.value = value ? [] : null + this.element.options.value = '' + } else { + this.value = this.fillValueDerfault() + } this.show = false this.$nextTick(() => { this.show = true + if (value) { + this.checkAll = this.value.length === this.datas.length + this.isIndeterminate = this.value.length > 0 && this.value.length < this.datas.length + } }) } }, diff --git a/frontend/src/components/widget/serviceImpl/ButtonSureServiceImpl.js b/frontend/src/components/widget/serviceImpl/ButtonSureServiceImpl.js index f09e501732..5b0f627444 100644 --- a/frontend/src/components/widget/serviceImpl/ButtonSureServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/ButtonSureServiceImpl.js @@ -25,7 +25,9 @@ const drawPanel = { }, value: '测试按钮' }, - component: 'de-button' + component: 'de-button', + miniSizex: 1, + miniSizey: 1 } class ButtonSureServiceImpl extends WidgetService { diff --git a/frontend/src/components/widget/serviceImpl/NumberRangeServiceImpl.js b/frontend/src/components/widget/serviceImpl/NumberRangeServiceImpl.js index d6f17ad8ce..c00ec6df99 100644 --- a/frontend/src/components/widget/serviceImpl/NumberRangeServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/NumberRangeServiceImpl.js @@ -34,7 +34,9 @@ const drawPanel = { textAlign: '', color: '' }, - component: 'de-number-range' + component: 'de-number-range', + miniSizex: 1, + miniSizey: 2 } class NumberRangeServiceImpl extends WidgetService { diff --git a/frontend/src/components/widget/serviceImpl/NumberSelectGridServiceImpl.js b/frontend/src/components/widget/serviceImpl/NumberSelectGridServiceImpl.js index d2fa26cf67..96742074c7 100644 --- a/frontend/src/components/widget/serviceImpl/NumberSelectGridServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/NumberSelectGridServiceImpl.js @@ -24,7 +24,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'tree-filter', - component: 'de-select-grid' + component: 'de-select-grid', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/NumberSelectServiceImpl.js b/frontend/src/components/widget/serviceImpl/NumberSelectServiceImpl.js index ae9fc4c3b0..c21b235663 100644 --- a/frontend/src/components/widget/serviceImpl/NumberSelectServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/NumberSelectServiceImpl.js @@ -24,7 +24,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'tree-filter', - component: 'de-select' + component: 'de-select', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TextInputServiceImpl.js b/frontend/src/components/widget/serviceImpl/TextInputServiceImpl.js index fb1f76e006..99b1de205d 100644 --- a/frontend/src/components/widget/serviceImpl/TextInputServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TextInputServiceImpl.js @@ -19,7 +19,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'text-filter', - component: 'de-input-search' + component: 'de-input-search', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TextSelectGridServiceImpl.js b/frontend/src/components/widget/serviceImpl/TextSelectGridServiceImpl.js index 3c3726c7fc..7b1a90cc3f 100644 --- a/frontend/src/components/widget/serviceImpl/TextSelectGridServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TextSelectGridServiceImpl.js @@ -24,7 +24,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'text-filter', - component: 'de-select-grid' + component: 'de-select-grid', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TextSelectServiceImpl.js b/frontend/src/components/widget/serviceImpl/TextSelectServiceImpl.js index b32371bd62..ad2a8132cb 100644 --- a/frontend/src/components/widget/serviceImpl/TextSelectServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TextSelectServiceImpl.js @@ -24,7 +24,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'text-filter', - component: 'de-select' + component: 'de-select', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TimeDateRangeServiceImpl.js b/frontend/src/components/widget/serviceImpl/TimeDateRangeServiceImpl.js index fe1b64d7f8..7817769a66 100644 --- a/frontend/src/components/widget/serviceImpl/TimeDateRangeServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TimeDateRangeServiceImpl.js @@ -33,7 +33,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'time-filter', - component: 'de-date' + component: 'de-date', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TimeDateServiceImpl.js b/frontend/src/components/widget/serviceImpl/TimeDateServiceImpl.js index 6fe77bdd38..8c79246e64 100644 --- a/frontend/src/components/widget/serviceImpl/TimeDateServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TimeDateServiceImpl.js @@ -44,7 +44,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'time-filter', - component: 'de-date' + component: 'de-date', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TimeMonthServiceImpl.js b/frontend/src/components/widget/serviceImpl/TimeMonthServiceImpl.js index ba5d06fe6a..41ee83ad9e 100644 --- a/frontend/src/components/widget/serviceImpl/TimeMonthServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TimeMonthServiceImpl.js @@ -39,7 +39,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'time-filter', - component: 'de-date' + component: 'de-date', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/components/widget/serviceImpl/TimeQuarterServiceImpl.js b/frontend/src/components/widget/serviceImpl/TimeQuarterServiceImpl.js index d03dc41d49..7592655e34 100644 --- a/frontend/src/components/widget/serviceImpl/TimeQuarterServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TimeQuarterServiceImpl.js @@ -28,7 +28,9 @@ const drawPanel = { textAlign: '', color: '' }, - component: 'de-quarter' + component: 'de-quarter', + miniSizex: 1, + miniSizey: 1 } class TimeQuarterServiceImpl extends WidgetService { diff --git a/frontend/src/components/widget/serviceImpl/TimeYearServiceImpl.js b/frontend/src/components/widget/serviceImpl/TimeYearServiceImpl.js index f0da98280c..b8a7f817f9 100644 --- a/frontend/src/components/widget/serviceImpl/TimeYearServiceImpl.js +++ b/frontend/src/components/widget/serviceImpl/TimeYearServiceImpl.js @@ -38,7 +38,9 @@ const dialogPanel = { manualModify: false }, defaultClass: 'time-filter', - component: 'de-date' + component: 'de-date', + miniSizex: 1, + miniSizey: 1 } const drawPanel = { type: 'custom', diff --git a/frontend/src/views/chart/chart/line/line_antv.js b/frontend/src/views/chart/chart/line/line_antv.js index 816085ebf2..66e8c9b84c 100644 --- a/frontend/src/views/chart/chart/line/line_antv.js +++ b/frontend/src/views/chart/chart/line/line_antv.js @@ -157,8 +157,10 @@ export function baseAreaOptionAntV(plot, container, chart, action) { size: parseInt(s.lineSymbolSize), shape: s.lineSymbol } - options.lineStyle = { - lineWidth: parseInt(s.lineWidth) + options.line = { + style: { + lineWidth: parseInt(s.lineWidth) + } } } } diff --git a/frontend/src/views/system/plugin/dynamic.vue b/frontend/src/views/system/plugin/dynamic.vue index 35763dbb58..d75169ab9a 100644 --- a/frontend/src/views/system/plugin/dynamic.vue +++ b/frontend/src/views/system/plugin/dynamic.vue @@ -1,5 +1,5 @@