forked from github/dataease
1716 lines
84 KiB
Java
1716 lines
84 KiB
Java
package io.dataease.service.chart;
|
||
|
||
import com.google.gson.Gson;
|
||
import com.google.gson.reflect.TypeToken;
|
||
import io.dataease.auth.api.dto.CurrentUserDto;
|
||
import io.dataease.auth.entity.SysUserEntity;
|
||
import io.dataease.auth.service.AuthUserService;
|
||
import io.dataease.base.domain.*;
|
||
import io.dataease.base.mapper.ChartViewMapper;
|
||
import io.dataease.base.mapper.ext.ExtChartGroupMapper;
|
||
import io.dataease.base.mapper.ext.ExtChartViewMapper;
|
||
import io.dataease.commons.constants.ColumnPermissionConstants;
|
||
import io.dataease.commons.constants.CommonConstants;
|
||
import io.dataease.commons.constants.JdbcConstants;
|
||
import io.dataease.commons.utils.AuthUtils;
|
||
import io.dataease.commons.utils.BeanUtils;
|
||
import io.dataease.commons.utils.CommonBeanFactory;
|
||
import io.dataease.commons.utils.LogUtil;
|
||
import io.dataease.controller.request.chart.*;
|
||
import io.dataease.controller.request.datasource.DatasourceRequest;
|
||
import io.dataease.controller.response.ChartDetail;
|
||
import io.dataease.controller.response.DataSetDetail;
|
||
import io.dataease.dto.chart.*;
|
||
import io.dataease.dto.dataset.DataSetTableDTO;
|
||
import io.dataease.dto.dataset.DataSetTableUnionDTO;
|
||
import io.dataease.dto.dataset.DataTableInfoDTO;
|
||
import io.dataease.i18n.Translator;
|
||
import io.dataease.listener.util.CacheUtils;
|
||
import io.dataease.provider.ProviderFactory;
|
||
import io.dataease.provider.datasource.DatasourceProvider;
|
||
import io.dataease.provider.query.QueryProvider;
|
||
import io.dataease.service.dataset.DataSetTableFieldsService;
|
||
import io.dataease.service.dataset.DataSetTableService;
|
||
import io.dataease.service.dataset.DataSetTableUnionService;
|
||
import io.dataease.service.dataset.PermissionService;
|
||
import io.dataease.service.datasource.DatasourceService;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.apache.commons.lang3.ObjectUtils;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
import org.springframework.stereotype.Service;
|
||
|
||
import javax.annotation.Resource;
|
||
import java.math.BigDecimal;
|
||
import java.math.RoundingMode;
|
||
import java.text.SimpleDateFormat;
|
||
import java.util.*;
|
||
import java.util.concurrent.locks.ReentrantLock;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* @Author gin
|
||
* @Date 2021/3/1 12:34 下午
|
||
*/
|
||
@Service
|
||
public class ChartViewService {
|
||
@Resource
|
||
private ChartViewMapper chartViewMapper;
|
||
@Resource
|
||
private ExtChartViewMapper extChartViewMapper;
|
||
@Resource
|
||
private DataSetTableService dataSetTableService;
|
||
@Resource
|
||
private DatasourceService datasourceService;
|
||
@Resource
|
||
private DataSetTableFieldsService dataSetTableFieldsService;
|
||
@Resource
|
||
private ExtChartGroupMapper extChartGroupMapper;
|
||
@Resource
|
||
private DataSetTableUnionService dataSetTableUnionService;
|
||
@Resource
|
||
private PermissionService permissionService;
|
||
@Resource
|
||
private AuthUserService authUserService;
|
||
|
||
//默认使用非公平
|
||
private ReentrantLock lock = new ReentrantLock();
|
||
|
||
public ChartViewWithBLOBs save(ChartViewWithBLOBs chartView) {
|
||
checkName(chartView);
|
||
long timestamp = System.currentTimeMillis();
|
||
chartView.setUpdateTime(timestamp);
|
||
if (ObjectUtils.isEmpty(chartView.getId())) {
|
||
chartView.setId(UUID.randomUUID().toString());
|
||
chartView.setCreateBy(AuthUtils.getUser().getUsername());
|
||
chartView.setCreateTime(timestamp);
|
||
chartView.setUpdateTime(timestamp);
|
||
chartViewMapper.insertSelective(chartView);
|
||
} else {
|
||
chartViewMapper.updateByPrimaryKeySelective(chartView);
|
||
}
|
||
Optional.ofNullable(chartView.getId()).ifPresent(id -> {
|
||
CacheUtils.remove(JdbcConstants.VIEW_CACHE_KEY, id);
|
||
});
|
||
return getOneWithPermission(chartView.getId());
|
||
}
|
||
|
||
public List<ChartViewDTO> list(ChartViewRequest chartViewRequest) {
|
||
chartViewRequest.setUserId(String.valueOf(AuthUtils.getUser().getUserId()));
|
||
return extChartViewMapper.search(chartViewRequest);
|
||
}
|
||
|
||
public List<ChartViewDTO> listAndGroup(ChartViewRequest chartViewRequest) {
|
||
chartViewRequest.setUserId(String.valueOf(AuthUtils.getUser().getUserId()));
|
||
List<ChartViewDTO> charts = extChartViewMapper.search(chartViewRequest);
|
||
charts.forEach(ele -> ele.setIsLeaf(true));
|
||
// 获取group下的子group
|
||
ChartGroupRequest chartGroupRequest = new ChartGroupRequest();
|
||
chartGroupRequest.setLevel(null);
|
||
chartGroupRequest.setType("group");
|
||
chartGroupRequest.setPid(chartViewRequest.getSceneId());
|
||
chartGroupRequest.setUserId(String.valueOf(AuthUtils.getUser().getUserId()));
|
||
chartGroupRequest.setSort("name asc,create_time desc");
|
||
List<ChartGroupDTO> groups = extChartGroupMapper.search(chartGroupRequest);
|
||
List<ChartViewDTO> group = groups.stream().map(ele -> {
|
||
ChartViewDTO dto = new ChartViewDTO();
|
||
BeanUtils.copyBean(dto, ele);
|
||
dto.setIsLeaf(false);
|
||
dto.setType("group");
|
||
return dto;
|
||
}).collect(Collectors.toList());
|
||
group.addAll(charts);
|
||
return group;
|
||
}
|
||
|
||
public List<ChartViewDTO> search(ChartViewRequest chartViewRequest) {
|
||
String userId = String.valueOf(AuthUtils.getUser().getUserId());
|
||
chartViewRequest.setUserId(userId);
|
||
chartViewRequest.setSort("name asc");
|
||
List<ChartViewDTO> ds = extChartViewMapper.search(chartViewRequest);
|
||
if (CollectionUtils.isEmpty(ds)) {
|
||
return ds;
|
||
}
|
||
|
||
TreeSet<String> ids = new TreeSet<>();
|
||
ds.forEach(ele -> {
|
||
ele.setIsLeaf(true);
|
||
ele.setPid(ele.getSceneId());
|
||
ids.add(ele.getPid());
|
||
});
|
||
|
||
List<ChartViewDTO> group = new ArrayList<>();
|
||
ChartGroupRequest chartGroupRequest = new ChartGroupRequest();
|
||
chartGroupRequest.setUserId(userId);
|
||
chartGroupRequest.setIds(ids);
|
||
List<ChartGroupDTO> search = extChartGroupMapper.search(chartGroupRequest);
|
||
while (CollectionUtils.isNotEmpty(search)) {
|
||
ids.clear();
|
||
search.forEach(ele -> {
|
||
ChartViewDTO dto = new ChartViewDTO();
|
||
BeanUtils.copyBean(dto, ele);
|
||
dto.setIsLeaf(false);
|
||
dto.setType("group");
|
||
group.add(dto);
|
||
ids.add(ele.getPid());
|
||
});
|
||
chartGroupRequest.setIds(ids);
|
||
search = extChartGroupMapper.search(chartGroupRequest);
|
||
}
|
||
|
||
List<ChartViewDTO> res = new ArrayList<>();
|
||
Map<String, ChartViewDTO> map = new TreeMap<>();
|
||
group.forEach(ele -> map.put(ele.getId(), ele));
|
||
Iterator<Map.Entry<String, ChartViewDTO>> iterator = map.entrySet().iterator();
|
||
while (iterator.hasNext()) {
|
||
res.add(iterator.next().getValue());
|
||
}
|
||
res.sort(Comparator.comparing(ChartViewDTO::getName));
|
||
res.addAll(ds);
|
||
return res;
|
||
}
|
||
|
||
public ChartViewWithBLOBs get(String id) {
|
||
return chartViewMapper.selectByPrimaryKey(id);
|
||
}
|
||
|
||
public ChartViewDTO getOneWithPermission(String id) {
|
||
String userId = AuthUtils.getUser() != null ? String.valueOf(AuthUtils.getUser().getUserId()) : "NONE";
|
||
return extChartViewMapper.searchOneWithPrivileges(userId, id);
|
||
}
|
||
|
||
public void delete(String id) {
|
||
chartViewMapper.deleteByPrimaryKey(id);
|
||
}
|
||
|
||
public void deleteBySceneId(String sceneId) {
|
||
ChartViewExample chartViewExample = new ChartViewExample();
|
||
chartViewExample.createCriteria().andSceneIdEqualTo(sceneId);
|
||
chartViewMapper.deleteByExample(chartViewExample);
|
||
}
|
||
|
||
public ChartViewDTO getData(String id, ChartExtRequest request) throws Exception {
|
||
ChartViewDTO view = this.getOneWithPermission(id);
|
||
// 如果是从仪表板获取视图数据，则仪表板的查询模式，查询结果的数量，覆盖视图对应的属性
|
||
if (CommonConstants.VIEW_QUERY_FROM.PANEL.equals(request.getQueryFrom()) && CommonConstants.VIEW_RESULT_MODE.CUSTOM.equals(request.getResultMode())) {
|
||
view.setResultMode(request.getResultMode());
|
||
view.setResultCount(request.getResultCount());
|
||
}
|
||
return calcData(view, request, request.isCache());
|
||
}
|
||
|
||
// private void checkPermissions(List<? extends ChartViewFieldBaseDTO> chartViewFieldDTOS, List<DatasetTableField> fields, List<String> desensitizationList, Boolean alowDesensitization) throws Exception {
|
||
// String filedName = "";
|
||
// for (ChartViewFieldBaseDTO chartViewFieldDTO : chartViewFieldDTOS) {
|
||
// if (alowDesensitization) {
|
||
// if (!fields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList()).contains(chartViewFieldDTO.getDataeaseName())) {
|
||
// filedName = filedName + chartViewFieldDTO.getName() + " ,";
|
||
// }
|
||
// } else {
|
||
// if (desensitizationList.contains(chartViewFieldDTO.getDataeaseName()) || !fields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList()).contains(chartViewFieldDTO.getDataeaseName())) {
|
||
// filedName = filedName + chartViewFieldDTO.getName() + " ,";
|
||
// }
|
||
// }
|
||
// }
|
||
// filedName = filedName.endsWith(",") ? filedName.substring(0, filedName.length() - 1) : filedName;
|
||
// if (StringUtils.isNotEmpty(filedName)) {
|
||
// throw new Exception("以下字段没有权限: " + filedName);
|
||
// }
|
||
// }
|
||
|
||
public ChartViewDTO calcData(ChartViewDTO view, ChartExtRequest requestList, boolean cache) throws Exception {
|
||
if (ObjectUtils.isEmpty(view)) {
|
||
throw new RuntimeException(Translator.get("i18n_chart_delete"));
|
||
}
|
||
List<ChartViewFieldDTO> xAxis = new Gson().fromJson(view.getXAxis(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
if (StringUtils.equalsIgnoreCase(view.getType(), "table-pivot")) {
|
||
List<ChartViewFieldDTO> xAxisExt = new Gson().fromJson(view.getXAxisExt(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
xAxis.addAll(xAxisExt);
|
||
}
|
||
List<ChartViewFieldDTO> yAxis = new Gson().fromJson(view.getYAxis(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
if (StringUtils.equalsIgnoreCase(view.getType(), "chart-mix")) {
|
||
List<ChartViewFieldDTO> yAxisExt = new Gson().fromJson(view.getYAxisExt(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
yAxis.addAll(yAxisExt);
|
||
}
|
||
List<ChartViewFieldDTO> extStack = new Gson().fromJson(view.getExtStack(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
List<ChartViewFieldDTO> extBubble = new Gson().fromJson(view.getExtBubble(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
List<ChartFieldCustomFilterDTO> fieldCustomFilter = new Gson().fromJson(view.getCustomFilter(), new TypeToken<List<ChartFieldCustomFilterDTO>>() {
|
||
}.getType());
|
||
List<ChartViewFieldDTO> drill = new Gson().fromJson(view.getDrillFields(), new TypeToken<List<ChartViewFieldDTO>>() {
|
||
}.getType());
|
||
|
||
|
||
DatasetTableField datasetTableFieldObj = DatasetTableField.builder().tableId(view.getTableId()).checked(Boolean.TRUE).build();
|
||
List<DatasetTableField> fields = dataSetTableFieldsService.list(datasetTableFieldObj);
|
||
// 获取数据集,需校验权限
|
||
DataSetTableDTO table = dataSetTableService.getWithPermission(view.getTableId(), requestList.getUser());
|
||
checkPermission("use", table, requestList.getUser());
|
||
|
||
//列权限
|
||
List<String> desensitizationList = new ArrayList<>();
|
||
List<DatasetTableField> columnPermissionFields = permissionService.filterColumnPermissons(fields, desensitizationList, table.getId(), requestList.getUser());
|
||
//将没有权限的列删掉
|
||
List<String> dataeaseNames = columnPermissionFields.stream().map(DatasetTableField::getDataeaseName).collect(Collectors.toList());
|
||
dataeaseNames.add("*");
|
||
fieldCustomFilter = fieldCustomFilter.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
extStack = extStack.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
extBubble = extBubble.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
drill = drill.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
|
||
|
||
//行权限
|
||
List<ChartFieldCustomFilterDTO> rowPermissionFields = permissionService.getCustomFilters(fields, table, requestList.getUser());
|
||
fieldCustomFilter.addAll(rowPermissionFields);
|
||
|
||
for (ChartFieldCustomFilterDTO ele : fieldCustomFilter) {
|
||
ele.setField(dataSetTableFieldsService.get(ele.getId()));
|
||
}
|
||
|
||
if (CollectionUtils.isEmpty(xAxis) && CollectionUtils.isEmpty(yAxis)) {
|
||
return emptyChartViewDTO(view);
|
||
}
|
||
|
||
switch (view.getType()) {
|
||
case "text":
|
||
case "gauge":
|
||
case "liquid":
|
||
xAxis = new ArrayList<>();
|
||
yAxis = yAxis.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
if (CollectionUtils.isEmpty(yAxis)) {
|
||
return emptyChartViewDTO(view);
|
||
}
|
||
break;
|
||
case "table-info":
|
||
yAxis = new ArrayList<>();
|
||
xAxis = xAxis.stream().filter(item -> dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
if (CollectionUtils.isEmpty(xAxis)) {
|
||
return emptyChartViewDTO(view);
|
||
}
|
||
break;
|
||
case "table-normal":
|
||
xAxis = xAxis.stream().filter(item -> dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
yAxis = yAxis.stream().filter(item -> dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
break;
|
||
default:
|
||
xAxis = xAxis.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
yAxis = yAxis.stream().filter(item -> !desensitizationList.contains(item.getDataeaseName()) && dataeaseNames.contains(item.getDataeaseName())).collect(Collectors.toList());
|
||
}
|
||
|
||
// 过滤来自仪表板的条件
|
||
List<ChartExtFilterRequest> extFilterList = new ArrayList<>();
|
||
//组件过滤条件
|
||
if (ObjectUtils.isNotEmpty(requestList.getFilter())) {
|
||
for (ChartExtFilterRequest request : requestList.getFilter()) {
|
||
// 解析多个fieldId,fieldId是一个逗号分隔的字符串
|
||
String fieldId = request.getFieldId();
|
||
if (StringUtils.isNotEmpty(fieldId)) {
|
||
String[] fieldIds = fieldId.split(",");
|
||
for (String fId : fieldIds) {
|
||
ChartExtFilterRequest filterRequest = new ChartExtFilterRequest();
|
||
BeanUtils.copyBean(filterRequest, request);
|
||
filterRequest.setFieldId(fId);
|
||
|
||
DatasetTableField datasetTableField = dataSetTableFieldsService.get(fId);
|
||
if (datasetTableField == null) {
|
||
continue;
|
||
}
|
||
if (!desensitizationList.contains(datasetTableField.getDataeaseName()) && dataeaseNames.contains(datasetTableField.getDataeaseName())) {
|
||
filterRequest.setDatasetTableField(datasetTableField);
|
||
if (StringUtils.equalsIgnoreCase(datasetTableField.getTableId(), view.getTableId())) {
|
||
if (CollectionUtils.isNotEmpty(filterRequest.getViewIds())) {
|
||
if (filterRequest.getViewIds().contains(view.getId())) {
|
||
extFilterList.add(filterRequest);
|
||
}
|
||
} else {
|
||
extFilterList.add(filterRequest);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
//联动过滤条件联动条件全部加上
|
||
if (ObjectUtils.isNotEmpty(requestList.getLinkageFilters())) {
|
||
for (ChartExtFilterRequest request : requestList.getLinkageFilters()) {
|
||
DatasetTableField datasetTableField = dataSetTableFieldsService.get(request.getFieldId());
|
||
if (!desensitizationList.contains(datasetTableField.getDataeaseName()) && dataeaseNames.contains(datasetTableField.getDataeaseName())) {
|
||
request.setDatasetTableField(datasetTableField);
|
||
if (StringUtils.equalsIgnoreCase(datasetTableField.getTableId(), view.getTableId())) {
|
||
if (CollectionUtils.isNotEmpty(request.getViewIds())) {
|
||
if (request.getViewIds().contains(view.getId())) {
|
||
extFilterList.add(request);
|
||
}
|
||
} else {
|
||
extFilterList.add(request);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 下钻
|
||
List<ChartExtFilterRequest> drillFilters = new ArrayList<>();
|
||
boolean isDrill = false;
|
||
List<ChartDrillRequest> drillRequest = requestList.getDrill();
|
||
if (CollectionUtils.isNotEmpty(drillRequest) && (drill.size() > drillRequest.size())) {
|
||
for (int i = 0; i < drillRequest.size(); i++) {
|
||
ChartDrillRequest request = drillRequest.get(i);
|
||
for (ChartDimensionDTO dto : request.getDimensionList()) {
|
||
ChartViewFieldDTO chartViewFieldDTO = drill.get(i);
|
||
// 将钻取值作为条件传递，将所有钻取字段作为xAxis并加上下一个钻取字段
|
||
if (StringUtils.equalsIgnoreCase(dto.getId(), chartViewFieldDTO.getId())) {
|
||
isDrill = true;
|
||
DatasetTableField datasetTableField = dataSetTableFieldsService.get(dto.getId());
|
||
ChartViewFieldDTO d = new ChartViewFieldDTO();
|
||
BeanUtils.copyBean(d, datasetTableField);
|
||
|
||
ChartExtFilterRequest drillFilter = new ChartExtFilterRequest();
|
||
drillFilter.setFieldId(dto.getId());
|
||
drillFilter.setValue(new ArrayList<String>() {{
|
||
add(dto.getValue());
|
||
}});
|
||
drillFilter.setOperator("in");
|
||
drillFilter.setDatasetTableField(datasetTableField);
|
||
extFilterList.add(drillFilter);
|
||
|
||
drillFilters.add(drillFilter);
|
||
|
||
if (!checkDrillExist(xAxis, extStack, d, view)) {
|
||
xAxis.add(d);
|
||
}
|
||
if (i == drillRequest.size() - 1) {
|
||
ChartViewFieldDTO nextDrillField = drill.get(i + 1);
|
||
if (!checkDrillExist(xAxis, extStack, nextDrillField, view)) {
|
||
xAxis.add(nextDrillField);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 判断连接方式，直连或者定时抽取 table.mode
|
||
DatasourceRequest datasourceRequest = new DatasourceRequest();
|
||
List<String[]> data = new ArrayList<>();
|
||
if (table.getMode() == 0) {// 直连
|
||
Datasource ds = datasourceService.get(table.getDataSourceId());
|
||
if (ObjectUtils.isEmpty(ds)) {
|
||
throw new RuntimeException(Translator.get("i18n_datasource_delete"));
|
||
}
|
||
if (StringUtils.isNotEmpty(ds.getStatus()) && ds.getStatus().equalsIgnoreCase("Error")) {
|
||
throw new Exception(Translator.get("i18n_invalid_ds"));
|
||
}
|
||
DatasourceProvider datasourceProvider = ProviderFactory.getProvider(ds.getType());
|
||
datasourceRequest.setDatasource(ds);
|
||
DataTableInfoDTO dataTableInfoDTO = new Gson().fromJson(table.getInfo(), DataTableInfoDTO.class);
|
||
QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType());
|
||
if (StringUtils.equalsIgnoreCase(table.getType(), "db")) {
|
||
datasourceRequest.setTable(dataTableInfoDTO.getTable());
|
||
if (StringUtils.equalsIgnoreCase("text", view.getType()) || StringUtils.equalsIgnoreCase("gauge", view.getType()) || StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLSummary(dataTableInfoDTO.getTable(), yAxis, fieldCustomFilter, extFilterList, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
datasourceRequest.setQuery(qp.getSQLStack(dataTableInfoDTO.getTable(), xAxis, yAxis, fieldCustomFilter, extFilterList, extStack, ds, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
datasourceRequest.setQuery(qp.getSQLScatter(dataTableInfoDTO.getTable(), xAxis, yAxis, fieldCustomFilter, extFilterList, extBubble, ds, view));
|
||
} else if (StringUtils.equalsIgnoreCase("table-info", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLTableInfo(dataTableInfoDTO.getTable(), xAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
} else {
|
||
datasourceRequest.setQuery(qp.getSQL(dataTableInfoDTO.getTable(), xAxis, yAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(table.getType(), "sql")) {
|
||
if (StringUtils.equalsIgnoreCase("text", view.getType()) || StringUtils.equalsIgnoreCase("gauge", view.getType()) || StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLSummaryAsTmp(dataTableInfoDTO.getSql(), yAxis, fieldCustomFilter, extFilterList, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpStack(dataTableInfoDTO.getSql(), xAxis, yAxis, fieldCustomFilter, extFilterList, extStack, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpScatter(dataTableInfoDTO.getSql(), xAxis, yAxis, fieldCustomFilter, extFilterList, extBubble, view));
|
||
} else if (StringUtils.equalsIgnoreCase("table-info", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpTableInfo(dataTableInfoDTO.getSql(), xAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
} else {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmp(dataTableInfoDTO.getSql(), xAxis, yAxis, fieldCustomFilter, extFilterList, view));
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(table.getType(), "custom")) {
|
||
DataTableInfoDTO dt = new Gson().fromJson(table.getInfo(), DataTableInfoDTO.class);
|
||
List<DataSetTableUnionDTO> list = dataSetTableUnionService.listByTableId(dt.getList().get(0).getTableId());
|
||
String sql = dataSetTableService.getCustomSQLDatasource(dt, list, ds);
|
||
if (StringUtils.equalsIgnoreCase("text", view.getType()) || StringUtils.equalsIgnoreCase("gauge", view.getType()) || StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLSummaryAsTmp(sql, yAxis, fieldCustomFilter, extFilterList, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpStack(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, extStack, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpScatter(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, extBubble, view));
|
||
} else if (StringUtils.equalsIgnoreCase("table-info", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpTableInfo(sql, xAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
} else {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmp(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, view));
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(table.getType(), "union")) {
|
||
DataTableInfoDTO dt = new Gson().fromJson(table.getInfo(), DataTableInfoDTO.class);
|
||
Map<String, Object> sqlMap = dataSetTableService.getUnionSQLDatasource(dt, ds);
|
||
String sql = (String) sqlMap.get("sql");
|
||
|
||
if (StringUtils.equalsIgnoreCase("text", view.getType()) || StringUtils.equalsIgnoreCase("gauge", view.getType()) || StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLSummaryAsTmp(sql, yAxis, fieldCustomFilter, extFilterList, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpStack(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, extStack, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpScatter(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, extBubble, view));
|
||
} else if (StringUtils.equalsIgnoreCase("table-info", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmpTableInfo(sql, xAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
} else {
|
||
datasourceRequest.setQuery(qp.getSQLAsTmp(sql, xAxis, yAxis, fieldCustomFilter, extFilterList, view));
|
||
}
|
||
}
|
||
data = datasourceProvider.getData(datasourceRequest);
|
||
} else if (table.getMode() == 1) {// 抽取
|
||
// 连接doris，构建doris数据源查询
|
||
Datasource ds = (Datasource) CommonBeanFactory.getBean("DorisDatasource");
|
||
DatasourceProvider datasourceProvider = ProviderFactory.getProvider(ds.getType());
|
||
datasourceRequest.setDatasource(ds);
|
||
String tableName = "ds_" + table.getId().replaceAll("-", "_");
|
||
datasourceRequest.setTable(tableName);
|
||
QueryProvider qp = ProviderFactory.getQueryProvider(ds.getType());
|
||
if (StringUtils.equalsIgnoreCase("text", view.getType()) || StringUtils.equalsIgnoreCase("gauge", view.getType()) || StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLSummary(tableName, yAxis, fieldCustomFilter, extFilterList, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
datasourceRequest.setQuery(qp.getSQLStack(tableName, xAxis, yAxis, fieldCustomFilter, extFilterList, extStack, ds, view));
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
datasourceRequest.setQuery(qp.getSQLScatter(tableName, xAxis, yAxis, fieldCustomFilter, extFilterList, extBubble, ds, view));
|
||
} else if (StringUtils.equalsIgnoreCase("table-info", view.getType())) {
|
||
datasourceRequest.setQuery(qp.getSQLTableInfo(tableName, xAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
} else {
|
||
datasourceRequest.setQuery(qp.getSQL(tableName, xAxis, yAxis, fieldCustomFilter, extFilterList, ds, view));
|
||
}
|
||
// 仪表板有参数不实用缓存
|
||
if (!cache || CollectionUtils.isNotEmpty(requestList.getFilter())
|
||
|| CollectionUtils.isNotEmpty(requestList.getLinkageFilters())
|
||
|| CollectionUtils.isNotEmpty(requestList.getDrill()) || CollectionUtils.isNotEmpty(rowPermissionFields) || fields.size() != columnPermissionFields.size()) {
|
||
data = datasourceProvider.getData(datasourceRequest);
|
||
} else {
|
||
try {
|
||
data = cacheViewData(datasourceProvider, datasourceRequest, view.getId());
|
||
} catch (Exception e) {
|
||
LogUtil.error(e);
|
||
} finally {
|
||
// 如果当前对象被锁 且 当前线程冲入次数 > 0 则释放锁
|
||
if (lock.isLocked() && lock.getHoldCount() > 0) {
|
||
lock.unlock();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 同比/环比计算，通过对比类型和数据设置，计算出对应指标的结果，然后替换结果data数组中的对应元素
|
||
// 如果因维度变化（如时间字段缺失，时间字段的展示格式变化）导致无法计算结果的，则结果data数组中的对应元素全置为null
|
||
// 根据不同图表类型，获得需要替换的指标index array
|
||
for (int i = 0; i < yAxis.size(); i++) {
|
||
ChartViewFieldDTO chartViewFieldDTO = yAxis.get(i);
|
||
ChartFieldCompareDTO compareCalc = chartViewFieldDTO.getCompareCalc();
|
||
if (ObjectUtils.isEmpty(compareCalc)) {
|
||
continue;
|
||
}
|
||
if (StringUtils.isNotEmpty(compareCalc.getType())
|
||
&& !StringUtils.equalsIgnoreCase(compareCalc.getType(), "none")) {
|
||
String compareFieldId = compareCalc.getField();// 选中字段
|
||
String resultData = compareCalc.getResultData();// 数据设置
|
||
// 获取选中字段以及下标
|
||
List<ChartViewFieldDTO> checkedField = new ArrayList<>(xAxis);
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
checkedField.addAll(extStack);
|
||
}
|
||
int timeIndex = 0;// 时间字段下标
|
||
ChartViewFieldDTO timeField = null;
|
||
for (int j = 0; j < checkedField.size(); j++) {
|
||
if (StringUtils.equalsIgnoreCase(checkedField.get(j).getId(), compareFieldId)) {
|
||
timeIndex = j;
|
||
timeField = checkedField.get(j);
|
||
}
|
||
}
|
||
// 计算指标对应的下标
|
||
int dataIndex = 0;// 数据字段下标
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
dataIndex = xAxis.size() + extStack.size() + i;
|
||
} else {
|
||
dataIndex = xAxis.size() + i;
|
||
}
|
||
// 无选中字段，或者选中字段已经不在维度list中，或者选中字段日期格式不符合对比类型的，直接将对应数据置为null
|
||
if (ObjectUtils.isEmpty(timeField) || !checkCalcType(timeField.getDateStyle(), compareCalc.getType())) {
|
||
// set null
|
||
for (String[] item : data) {
|
||
item[dataIndex] = null;
|
||
}
|
||
} else {
|
||
// 计算 同比/环比
|
||
// 1，处理当期数据；2，根据type计算上一期数据；3，根据resultData计算结果
|
||
Map<String, String> currentMap = new LinkedHashMap<>();
|
||
for (String[] item : data) {
|
||
String[] dimension = Arrays.copyOfRange(item, 0, checkedField.size());
|
||
currentMap.put(StringUtils.join(dimension, "-"), item[dataIndex]);
|
||
}
|
||
|
||
for (int index = 0; index < data.size(); index++) {
|
||
String[] item = data.get(index);
|
||
String cTime = item[timeIndex];
|
||
String cValue = item[dataIndex];
|
||
|
||
// 获取计算后的时间，并且与所有维度拼接
|
||
String lastTime = calcLastTime(cTime, compareCalc.getType(), timeField.getDateStyle(), timeField.getDatePattern());
|
||
String[] dimension = Arrays.copyOfRange(item, 0, checkedField.size());
|
||
dimension[timeIndex] = lastTime;
|
||
|
||
String lastValue = currentMap.get(StringUtils.join(dimension, "-"));
|
||
if (StringUtils.isEmpty(cValue) || StringUtils.isEmpty(lastValue)) {
|
||
item[dataIndex] = null;
|
||
} else {
|
||
if (StringUtils.equalsIgnoreCase(resultData, "sub")) {
|
||
item[dataIndex] = new BigDecimal(cValue).subtract(new BigDecimal(lastValue)).toString();
|
||
} else if (StringUtils.equalsIgnoreCase(resultData, "percent")) {
|
||
if (new BigDecimal(lastValue).compareTo(BigDecimal.ZERO) == 0) {
|
||
item[dataIndex] = null;
|
||
} else {
|
||
item[dataIndex] = new BigDecimal(cValue)
|
||
.divide(new BigDecimal(lastValue), 2, RoundingMode.HALF_UP)
|
||
.subtract(new BigDecimal(1))
|
||
.setScale(2, RoundingMode.HALF_UP)
|
||
.toString();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 构建结果
|
||
Map<String, Object> map = new TreeMap<>();
|
||
// 图表组件可再扩展
|
||
Map<String, Object> mapChart = new HashMap<>();
|
||
if (StringUtils.equalsIgnoreCase(view.getRender(), "echarts")) {
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
mapChart = transStackChartData(xAxis, yAxis, view, data, extStack, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
mapChart = transScatterData(xAxis, yAxis, view, data, extBubble, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "radar")) {
|
||
mapChart = transRadarChartData(xAxis, yAxis, view, data, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "text")
|
||
|| StringUtils.containsIgnoreCase(view.getType(), "gauge")
|
||
|| StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
mapChart = transNormalChartData(xAxis, yAxis, view, data, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "chart-mix")) {
|
||
mapChart = transMixChartData(xAxis, yAxis, view, data, isDrill);
|
||
} else {
|
||
mapChart = transChartData(xAxis, yAxis, view, data, isDrill);
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(view.getRender(), "antv")) {
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "bar-stack")) {
|
||
mapChart = transStackChartDataAntV(xAxis, yAxis, view, data, extStack, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "line-stack")) {
|
||
mapChart = transStackChartDataAntV(xAxis, yAxis, view, data, extStack, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "scatter")) {
|
||
mapChart = transScatterDataAntV(xAxis, yAxis, view, data, extBubble, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "radar")) {
|
||
mapChart = transRadarChartDataAntV(xAxis, yAxis, view, data, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "text")
|
||
|| StringUtils.containsIgnoreCase(view.getType(), "gauge")
|
||
|| StringUtils.equalsIgnoreCase("liquid", view.getType())) {
|
||
mapChart = transNormalChartData(xAxis, yAxis, view, data, isDrill);
|
||
} else if (StringUtils.containsIgnoreCase(view.getType(), "chart-mix")) {
|
||
mapChart = transMixChartDataAntV(xAxis, yAxis, view, data, isDrill);
|
||
} else {
|
||
mapChart = transChartDataAntV(xAxis, yAxis, view, data, isDrill);
|
||
}
|
||
}
|
||
|
||
// table组件，明细表，也用于导出数据
|
||
Map<String, Object> mapTableNormal = transTableNormal(xAxis, yAxis, view, data, extStack, desensitizationList);
|
||
|
||
map.putAll(mapChart);
|
||
map.putAll(mapTableNormal);
|
||
|
||
List<DatasetTableField> sourceFields = dataSetTableFieldsService.getFieldsByTableId(view.getTableId());
|
||
map.put("sourceFields", sourceFields);
|
||
|
||
ChartViewDTO dto = new ChartViewDTO();
|
||
BeanUtils.copyBean(dto, view);
|
||
dto.setData(map);
|
||
dto.setSql(datasourceRequest.getQuery());
|
||
|
||
dto.setDrill(isDrill);
|
||
dto.setDrillFilters(drillFilters);
|
||
return dto;
|
||
}
|
||
|
||
private ChartViewDTO emptyChartViewDTO(ChartViewDTO view) {
|
||
ChartViewDTO dto = new ChartViewDTO();
|
||
BeanUtils.copyBean(dto, view);
|
||
return dto;
|
||
}
|
||
|
||
private boolean checkCalcType(String dateStyle, String calcType) {
|
||
switch (dateStyle) {
|
||
case "y":
|
||
return StringUtils.equalsIgnoreCase(calcType, "year_mom");
|
||
case "y_M":
|
||
return StringUtils.equalsIgnoreCase(calcType, "month_mom")
|
||
|| StringUtils.equalsIgnoreCase(calcType, "year_yoy");
|
||
case "y_M_d":
|
||
return StringUtils.equalsIgnoreCase(calcType, "day_mom")
|
||
|| StringUtils.equalsIgnoreCase(calcType, "month_yoy")
|
||
|| StringUtils.equalsIgnoreCase(calcType, "year_yoy");
|
||
}
|
||
return false;
|
||
}
|
||
|
||
private String calcLastTime(String cTime, String type, String dateStyle, String datePattern) {
|
||
try {
|
||
String lastTime = null;
|
||
Calendar calendar = Calendar.getInstance();
|
||
if (StringUtils.equalsIgnoreCase(type, ChartConstants.YEAR_MOM)) {
|
||
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy");
|
||
Date date = simpleDateFormat.parse(cTime);
|
||
calendar.setTime(date);
|
||
calendar.add(Calendar.YEAR, -1);
|
||
lastTime = simpleDateFormat.format(calendar.getTime());
|
||
} else if (StringUtils.equalsIgnoreCase(type, ChartConstants.MONTH_MOM)) {
|
||
SimpleDateFormat simpleDateFormat = null;
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM");
|
||
}
|
||
Date date = simpleDateFormat.parse(cTime);
|
||
calendar.setTime(date);
|
||
calendar.add(Calendar.MONTH, -1);
|
||
lastTime = simpleDateFormat.format(calendar.getTime());
|
||
} else if (StringUtils.equalsIgnoreCase(type, ChartConstants.YEAR_YOY)) {
|
||
SimpleDateFormat simpleDateFormat = null;
|
||
if (StringUtils.equalsIgnoreCase(dateStyle, "y_M")) {
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM");
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(dateStyle, "y_M_d")) {
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
||
}
|
||
}
|
||
Date date = simpleDateFormat.parse(cTime);
|
||
calendar.setTime(date);
|
||
calendar.add(Calendar.YEAR, -1);
|
||
lastTime = simpleDateFormat.format(calendar.getTime());
|
||
} else if (StringUtils.equalsIgnoreCase(type, ChartConstants.DAY_MOM)) {
|
||
SimpleDateFormat simpleDateFormat = null;
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
||
}
|
||
Date date = simpleDateFormat.parse(cTime);
|
||
calendar.setTime(date);
|
||
calendar.add(Calendar.DAY_OF_MONTH, -1);
|
||
lastTime = simpleDateFormat.format(calendar.getTime());
|
||
} else if (StringUtils.equalsIgnoreCase(type, ChartConstants.MONTH_YOY)) {
|
||
SimpleDateFormat simpleDateFormat = null;
|
||
if (StringUtils.equalsIgnoreCase(dateStyle, "y_M")) {
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM");
|
||
}
|
||
} else if (StringUtils.equalsIgnoreCase(dateStyle, "y_M_d")) {
|
||
if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy/MM/dd");
|
||
} else {
|
||
simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
||
}
|
||
}
|
||
Date date = simpleDateFormat.parse(cTime);
|
||
calendar.setTime(date);
|
||
calendar.add(Calendar.MONTH, -1);
|
||
lastTime = simpleDateFormat.format(calendar.getTime());
|
||
}
|
||
return lastTime;
|
||
} catch (Exception e) {
|
||
return cTime;
|
||
}
|
||
}
|
||
|
||
private boolean checkDrillExist(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> extStack, ChartViewFieldDTO dto, ChartViewWithBLOBs view) {
|
||
if (CollectionUtils.isNotEmpty(xAxis)) {
|
||
for (ChartViewFieldDTO x : xAxis) {
|
||
if (StringUtils.equalsIgnoreCase(x.getId(), dto.getId())) {
|
||
return true;
|
||
}
|
||
}
|
||
}
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "stack") && CollectionUtils.isNotEmpty(extStack)) {
|
||
for (ChartViewFieldDTO x : extStack) {
|
||
if (StringUtils.equalsIgnoreCase(x.getId(), dto.getId())) {
|
||
return true;
|
||
}
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 避免缓存击穿
|
||
* 虽然流量不一定能够达到击穿的水平
|
||
*
|
||
* @param datasourceProvider
|
||
* @param datasourceRequest
|
||
* @param viewId
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public List<String[]> cacheViewData(DatasourceProvider datasourceProvider, DatasourceRequest datasourceRequest, String viewId) throws Exception {
|
||
List<String[]> result;
|
||
Object cache = CacheUtils.get(JdbcConstants.VIEW_CACHE_KEY, viewId);
|
||
if (cache == null) {
|
||
if (lock.tryLock()) {// 获取锁成功
|
||
try {
|
||
result = datasourceProvider.getData(datasourceRequest);
|
||
if (result != null) {
|
||
CacheUtils.put(JdbcConstants.VIEW_CACHE_KEY, viewId, result, null, null);
|
||
}
|
||
} catch (Exception e) {
|
||
LogUtil.error(e);
|
||
throw e;
|
||
} finally {
|
||
lock.unlock();
|
||
}
|
||
} else {//获取锁失败
|
||
Thread.sleep(100);//避免CAS自旋频率过大 占用cpu资源过高
|
||
result = cacheViewData(datasourceProvider, datasourceRequest, viewId);
|
||
}
|
||
} else {
|
||
result = (List<String[]>) cache;
|
||
}
|
||
return result;
|
||
}
|
||
|
||
// AntV
|
||
private Map<String, Object> transChartDataAntV(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<AxisChartDataAntVDTO> datas = new ArrayList<>();
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] row = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(row[i]);
|
||
} else {
|
||
a.append(row[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "table")) {
|
||
for (int i = 0; i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
axisChartDataDTO.setField(a.toString());
|
||
axisChartDataDTO.setName(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(row[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
if (j > -1) {
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[i]) ? null : new BigDecimal(row[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
axisChartDataDTO.setCategory(yAxis.get(j).getName());
|
||
}
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
} else {
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
axisChartDataDTO.setField(a.toString());
|
||
axisChartDataDTO.setName(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(row[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[i]) ? null : new BigDecimal(row[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
axisChartDataDTO.setCategory(yAxis.get(j).getName());
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
}
|
||
}
|
||
map.put("datas", datas);
|
||
return map;
|
||
}
|
||
|
||
// AntV柱状堆叠图
|
||
private Map<String, Object> transStackChartDataAntV(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, List<ChartViewFieldDTO> extStack, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<AxisChartDataAntVDTO> datas = new ArrayList<>();
|
||
|
||
if (CollectionUtils.isNotEmpty(extStack)) {
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] row = data.get(i1);
|
||
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(row[i]);
|
||
} else {
|
||
a.append(row[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
axisChartDataDTO.setField(a.toString());
|
||
axisChartDataDTO.setCategory(row[xAxis.size()]);
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int k = 0; k < xAxis.size(); k++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(k).getId());
|
||
chartDimensionDTO.setValue(row[k]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
if (CollectionUtils.isNotEmpty(yAxis)) {
|
||
int valueIndex = xAxis.size() + extStack.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(0).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[valueIndex]) ? null : new BigDecimal(row[valueIndex]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
} else {
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
} else {
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] row = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(row[i]);
|
||
} else {
|
||
a.append(row[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
axisChartDataDTO.setField(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(row[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[i]) ? null : new BigDecimal(row[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
axisChartDataDTO.setCategory(yAxis.get(j).getName());
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
}
|
||
}
|
||
map.put("datas", datas);
|
||
return map;
|
||
}
|
||
|
||
//AntV scatter
|
||
private Map<String, Object> transScatterDataAntV(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, List<ChartViewFieldDTO> extBubble, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<AxisChartDataAntVDTO> datas = new ArrayList<>();
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] row = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(row[i]);
|
||
} else {
|
||
a.append(row[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
axisChartDataDTO.setField(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(row[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[i]) ? null : new BigDecimal(row[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
axisChartDataDTO.setCategory(yAxis.get(j).getName());
|
||
// pop
|
||
if (CollectionUtils.isNotEmpty(extBubble)) {
|
||
try {
|
||
axisChartDataDTO.setPopSize(StringUtils.isEmpty(row[xAxis.size() + yAxis.size()]) ? null : new BigDecimal(row[xAxis.size() + yAxis.size()]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setPopSize(new BigDecimal(0));
|
||
}
|
||
}
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
}
|
||
map.put("datas", datas);
|
||
return map;
|
||
}
|
||
|
||
// antv radar
|
||
private Map<String, Object> transRadarChartDataAntV(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<AxisChartDataAntVDTO> datas = new ArrayList<>();
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] row = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(row[i]);
|
||
} else {
|
||
a.append(row[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
axisChartDataDTO.setField(a.toString());
|
||
axisChartDataDTO.setName(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(row[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(row[i]) ? null : new BigDecimal(row[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
axisChartDataDTO.setCategory(yAxis.get(j).getName());
|
||
datas.add(axisChartDataDTO);
|
||
}
|
||
}
|
||
map.put("datas", datas);
|
||
return map;
|
||
}
|
||
|
||
// antV组合图形
|
||
private Map<String, Object> transMixChartDataAntV(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(y.getChartType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] d = data.get(i1);
|
||
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
AxisChartDataAntVDTO axisChartDataDTO = new AxisChartDataAntVDTO();
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int ii = 0; ii < xAxis.size(); ii++) {
|
||
if (ii == xAxis.size() - 1) {
|
||
a.append(d[ii]);
|
||
} else {
|
||
a.append(d[ii]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
axisChartDataDTO.setName(a.toString());
|
||
axisChartDataDTO.setField(a.toString());
|
||
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(d[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
series.get(j).getData().add(axisChartDataDTO);
|
||
}
|
||
}
|
||
|
||
map.put("datas", series);
|
||
return map;
|
||
}
|
||
|
||
// 基础图形
|
||
private Map<String, Object> transChartData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(view.getType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] d = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
AxisChartDataDTO axisChartDataDTO = new AxisChartDataDTO();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(d[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
series.get(j).getData().add(axisChartDataDTO);
|
||
}
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// 组合图形
|
||
private Map<String, Object> transMixChartData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(y.getChartType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] d = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
AxisChartDataDTO axisChartDataDTO = new AxisChartDataDTO();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(d[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
series.get(j).getData().add(axisChartDataDTO);
|
||
}
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// 常规图形
|
||
private Map<String, Object> transNormalChartData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(view.getType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (String[] d : data) {
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
int j = i - xAxis.size();
|
||
try {
|
||
series.get(j).getData().add(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
series.get(j).getData().add(new BigDecimal(0));
|
||
}
|
||
}
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// radar图
|
||
private Map<String, Object> transRadarChartData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(view.getType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (String[] d : data) {
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
int j = i - xAxis.size();
|
||
try {
|
||
series.get(j).getData().add(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
series.get(j).getData().add(new BigDecimal(0));
|
||
}
|
||
}
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// 堆叠图
|
||
private Map<String, Object> transStackChartData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, List<ChartViewFieldDTO> extStack, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<String> stack = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
|
||
if (CollectionUtils.isNotEmpty(extStack)) {
|
||
AxisChartDataDTO defaultAxisChartDataDTO = new AxisChartDataDTO();
|
||
BigDecimal defaultValue = StringUtils.containsIgnoreCase(view.getType(), "line") ? new BigDecimal(0) : null;
|
||
defaultAxisChartDataDTO.setValue(defaultValue);
|
||
// 构建横轴
|
||
for (String[] d : data) {
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
}
|
||
x = x.stream().distinct().collect(Collectors.toList());
|
||
// 构建堆叠
|
||
for (String[] d : data) {
|
||
stack.add(d[xAxis.size()]);
|
||
}
|
||
stack = stack.stream().distinct().collect(Collectors.toList());
|
||
for (String s : stack) {
|
||
Series series1 = new Series();
|
||
series1.setName(s);
|
||
series1.setType(view.getType());
|
||
List<Object> list = new ArrayList<>();
|
||
for (int i = 0; i < x.size(); i++) {
|
||
list.add(defaultAxisChartDataDTO);
|
||
}
|
||
series1.setData(list);
|
||
series.add(series1);
|
||
}
|
||
for (Series ss : series) {
|
||
for (int i = 0; i < x.size(); i++) {
|
||
for (String[] row : data) {
|
||
String stackColumn = row[xAxis.size()];
|
||
if (StringUtils.equals(ss.getName(), stackColumn)) {
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(row[xAxis.size() - 1]);
|
||
} else {
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
if (j == xAxis.size() - 1) {
|
||
a.append(row[j]);
|
||
} else {
|
||
a.append(row[j]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
if (StringUtils.equals(a.toString(), x.get(i))) {
|
||
if (row.length > xAxis.size() + extStack.size()) {
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
AxisChartDataDTO axisChartDataDTO = new AxisChartDataDTO();
|
||
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(0).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
|
||
for (int k = 0; k < xAxis.size(); k++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(k).getId());
|
||
chartDimensionDTO.setValue(row[k]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(extStack.get(0).getId());
|
||
chartDimensionDTO.setValue(row[xAxis.size()]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
String s = row[xAxis.size() + extStack.size()];
|
||
if (StringUtils.isNotEmpty(s)) {
|
||
axisChartDataDTO.setValue(new BigDecimal(s));
|
||
ss.getData().set(i, axisChartDataDTO);
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(view.getType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] d = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
AxisChartDataDTO axisChartDataDTO = new AxisChartDataDTO();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(d[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
axisChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
axisChartDataDTO.setQuotaList(quotaList);
|
||
try {
|
||
axisChartDataDTO.setValue(StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]));
|
||
} catch (Exception e) {
|
||
axisChartDataDTO.setValue(new BigDecimal(0));
|
||
}
|
||
series.get(j).getData().add(axisChartDataDTO);
|
||
}
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
}
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// 散点图
|
||
private Map<String, Object> transScatterData(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, List<ChartViewFieldDTO> extBubble, boolean isDrill) {
|
||
Map<String, Object> map = new HashMap<>();
|
||
|
||
List<String> x = new ArrayList<>();
|
||
List<Series> series = new ArrayList<>();
|
||
for (ChartViewFieldDTO y : yAxis) {
|
||
Series series1 = new Series();
|
||
series1.setName(y.getName());
|
||
series1.setType(view.getType());
|
||
series1.setData(new ArrayList<>());
|
||
series.add(series1);
|
||
}
|
||
for (int i1 = 0; i1 < data.size(); i1++) {
|
||
String[] d = data.get(i1);
|
||
|
||
StringBuilder a = new StringBuilder();
|
||
if (isDrill) {
|
||
a.append(d[xAxis.size() - 1]);
|
||
} else {
|
||
for (int i = 0; i < xAxis.size(); i++) {
|
||
if (i == xAxis.size() - 1) {
|
||
a.append(d[i]);
|
||
} else {
|
||
a.append(d[i]).append("\n");
|
||
}
|
||
}
|
||
}
|
||
x.add(a.toString());
|
||
for (int i = xAxis.size(); i < xAxis.size() + yAxis.size(); i++) {
|
||
List<ChartDimensionDTO> dimensionList = new ArrayList<>();
|
||
List<ChartQuotaDTO> quotaList = new ArrayList<>();
|
||
ScatterChartDataDTO scatterChartDataDTO = new ScatterChartDataDTO();
|
||
|
||
for (int j = 0; j < xAxis.size(); j++) {
|
||
ChartDimensionDTO chartDimensionDTO = new ChartDimensionDTO();
|
||
chartDimensionDTO.setId(xAxis.get(j).getId());
|
||
chartDimensionDTO.setValue(d[j]);
|
||
dimensionList.add(chartDimensionDTO);
|
||
}
|
||
scatterChartDataDTO.setDimensionList(dimensionList);
|
||
|
||
int j = i - xAxis.size();
|
||
ChartQuotaDTO chartQuotaDTO = new ChartQuotaDTO();
|
||
chartQuotaDTO.setId(yAxis.get(j).getId());
|
||
quotaList.add(chartQuotaDTO);
|
||
scatterChartDataDTO.setQuotaList(quotaList);
|
||
|
||
if (CollectionUtils.isNotEmpty(extBubble) && extBubble.size() > 0) {
|
||
try {
|
||
scatterChartDataDTO.setValue(new Object[]{
|
||
a.toString(),
|
||
StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i]),
|
||
StringUtils.isEmpty(d[xAxis.size() + yAxis.size()]) ? null : new BigDecimal(d[xAxis.size() + yAxis.size()])
|
||
});
|
||
} catch (Exception e) {
|
||
scatterChartDataDTO.setValue(new Object[]{a.toString(), new BigDecimal(0), new BigDecimal(0)});
|
||
}
|
||
} else {
|
||
try {
|
||
scatterChartDataDTO.setValue(new Object[]{
|
||
a.toString(),
|
||
StringUtils.isEmpty(d[i]) ? null : new BigDecimal(d[i])
|
||
});
|
||
} catch (Exception e) {
|
||
scatterChartDataDTO.setValue(new Object[]{a.toString(), new BigDecimal(0)});
|
||
}
|
||
}
|
||
series.get(j).getData().add(scatterChartDataDTO);
|
||
}
|
||
}
|
||
|
||
map.put("x", x);
|
||
map.put("series", series);
|
||
return map;
|
||
}
|
||
|
||
// 表格
|
||
private Map<String, Object> transTableNormal(List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, ChartViewWithBLOBs view, List<String[]> data, List<ChartViewFieldDTO> extStack, List<String> desensitizationList) {
|
||
Map<String, Object> map = new TreeMap<>();
|
||
List<ChartViewFieldDTO> fields = new ArrayList<>();
|
||
List<Map<String, Object>> tableRow = new ArrayList<>();
|
||
if (ObjectUtils.isNotEmpty(xAxis)) {
|
||
fields.addAll(xAxis);
|
||
}
|
||
if (StringUtils.containsIgnoreCase(view.getType(), "stack")) {
|
||
if (ObjectUtils.isNotEmpty(extStack)) {
|
||
fields.addAll(extStack);
|
||
}
|
||
}
|
||
fields.addAll(yAxis);
|
||
data.forEach(ele -> {
|
||
Map<String, Object> d = new HashMap<>();
|
||
for (int i = 0; i < fields.size(); i++) {
|
||
if (CollectionUtils.isNotEmpty(desensitizationList) && desensitizationList.contains(fields.get(i).getDataeaseName())) {
|
||
d.put(fields.get(i).getDataeaseName(), ColumnPermissionConstants.Desensitization_desc);
|
||
continue;
|
||
}
|
||
|
||
ChartViewFieldDTO chartViewFieldDTO = fields.get(i);
|
||
if (chartViewFieldDTO.getDeType() == 0 || chartViewFieldDTO.getDeType() == 1) {
|
||
d.put(fields.get(i).getDataeaseName(), StringUtils.isEmpty(ele[i]) ? "" : ele[i]);
|
||
} else if (chartViewFieldDTO.getDeType() == 2 || chartViewFieldDTO.getDeType() == 3) {
|
||
d.put(fields.get(i).getDataeaseName(), StringUtils.isEmpty(ele[i]) ? null : new BigDecimal(ele[i]).setScale(2, RoundingMode.HALF_UP));
|
||
}
|
||
}
|
||
tableRow.add(d);
|
||
});
|
||
map.put("fields", fields);
|
||
map.put("tableRow", tableRow);
|
||
return map;
|
||
}
|
||
|
||
private void checkName(ChartViewWithBLOBs chartView) {
|
||
ChartViewExample chartViewExample = new ChartViewExample();
|
||
ChartViewExample.Criteria criteria = chartViewExample.createCriteria();
|
||
if (StringUtils.isNotEmpty(chartView.getId())) {
|
||
criteria.andIdNotEqualTo(chartView.getId());
|
||
}
|
||
if (StringUtils.isNotEmpty(chartView.getSceneId())) {
|
||
criteria.andSceneIdEqualTo(chartView.getSceneId());
|
||
}
|
||
if (StringUtils.isNotEmpty(chartView.getName())) {
|
||
criteria.andNameEqualTo(chartView.getName());
|
||
}
|
||
}
|
||
|
||
public ChartDetail getChartDetail(String id) {
|
||
ChartDetail chartDetail = new ChartDetail();
|
||
ChartViewWithBLOBs chartViewWithBLOBs = chartViewMapper.selectByPrimaryKey(id);
|
||
chartDetail.setChart(chartViewWithBLOBs);
|
||
if (ObjectUtils.isNotEmpty(chartViewWithBLOBs)) {
|
||
DataSetDetail datasetDetail = dataSetTableService.getDatasetDetail(chartViewWithBLOBs.getTableId());
|
||
chartDetail.setTable(datasetDetail.getTable());
|
||
chartDetail.setDatasource(datasetDetail.getDatasource());
|
||
}
|
||
return chartDetail;
|
||
}
|
||
|
||
public List<ChartView> viewsByIds(List<String> viewIds) {
|
||
ChartViewExample example = new ChartViewExample();
|
||
example.createCriteria().andIdIn(viewIds);
|
||
return chartViewMapper.selectByExample(example);
|
||
}
|
||
|
||
public ChartViewWithBLOBs findOne(String id) {
|
||
return chartViewMapper.selectByPrimaryKey(id);
|
||
}
|
||
|
||
public String chartCopy(String id, String panelId) {
|
||
String newChartId = UUID.randomUUID().toString();
|
||
extChartViewMapper.chartCopy(newChartId, id, panelId);
|
||
return newChartId;
|
||
}
|
||
|
||
public String searchAdviceSceneId(String panelId) {
|
||
return extChartViewMapper.searchAdviceSceneId(AuthUtils.getUser().getUserId().toString(), panelId);
|
||
}
|
||
|
||
public String checkSameDataSet(String viewIdSource, String viewIdTarget) {
|
||
if (extChartViewMapper.checkSameDataSet(viewIdSource, viewIdTarget) == 1) {
|
||
return "YES";
|
||
} else {
|
||
return "NO";
|
||
}
|
||
}
|
||
|
||
// check permission
|
||
private void checkPermission(String needPermission, DataSetTableDTO table, Long userId) {
|
||
if (ObjectUtils.isEmpty(table)) {
|
||
throw new RuntimeException(Translator.get("i18n_dataset_delete"));
|
||
}
|
||
SysUserEntity user = AuthUtils.getUser();
|
||
user = userId != null ? authUserService.getUserById(userId) : user;
|
||
if (!user.getIsAdmin()) {
|
||
if (ObjectUtils.isEmpty(table.getPrivileges()) || !table.getPrivileges().contains(needPermission)) {
|
||
throw new RuntimeException(Translator.get("i18n_dataset_no_permission"));
|
||
}
|
||
}
|
||
}
|
||
}
|