perf: core模块获取用户名称

This commit is contained in:
fit2cloud-chenyw 2023-11-01 12:35:58 +08:00
parent 9ed7d63113
commit 3af1fcd2a5
4 changed files with 37 additions and 23 deletions

View File

@ -31,6 +31,7 @@ import io.dataease.license.config.XpackInteract;
import io.dataease.model.BusiNodeRequest; import io.dataease.model.BusiNodeRequest;
import io.dataease.model.BusiNodeVO; import io.dataease.model.BusiNodeVO;
import io.dataease.operation.manage.CoreOptRecentManage; import io.dataease.operation.manage.CoreOptRecentManage;
import io.dataease.system.manage.CoreUserManage;
import io.dataease.utils.*; import io.dataease.utils.*;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
@ -71,6 +72,9 @@ public class DatasetGroupManage {
@Autowired(required = false) @Autowired(required = false)
private UserApi userApi; private UserApi userApi;
@Resource
private CoreUserManage coreUserManage;
@Resource @Resource
private CoreOptRecentManage coreOptRecentManage; private CoreOptRecentManage coreOptRecentManage;
@ -232,13 +236,13 @@ public class DatasetGroupManage {
DataSetBarVO dataSetBarVO = coreDataSetExtMapper.queryBarInfo(id); DataSetBarVO dataSetBarVO = coreDataSetExtMapper.queryBarInfo(id);
// get creator // get creator
if (userApi != null) { if (userApi != null) {
UserFormVO userFormVO = userApi.queryById(Long.valueOf(dataSetBarVO.getCreateBy())); String userName = coreUserManage.getUserName(Long.valueOf(dataSetBarVO.getCreateBy()));
if (userFormVO != null) { if (StringUtils.isNotBlank(userName)) {
dataSetBarVO.setCreator(userFormVO.getName()); dataSetBarVO.setCreator(userName);
} }
UserFormVO userFormVOUpdateBy = userApi.queryById(Long.valueOf(dataSetBarVO.getUpdateBy())); String updateUserName = coreUserManage.getUserName(Long.valueOf(dataSetBarVO.getUpdateBy()));
if (userFormVOUpdateBy != null) { if (StringUtils.isNotBlank(updateUserName)) {
dataSetBarVO.setUpdater(userFormVOUpdateBy.getName()); dataSetBarVO.setUpdater(updateUserName);
} }
} }
dataSetBarVO.setDatasourceDTOList(getDatasource(id)); dataSetBarVO.setDatasourceDTOList(getDatasource(id));

View File

@ -14,8 +14,6 @@ import io.dataease.api.ds.DatasourceApi;
import io.dataease.api.ds.vo.*; import io.dataease.api.ds.vo.*;
import io.dataease.api.permissions.auth.api.InteractiveAuthApi; import io.dataease.api.permissions.auth.api.InteractiveAuthApi;
import io.dataease.api.permissions.auth.dto.BusiResourceEditor; import io.dataease.api.permissions.auth.dto.BusiResourceEditor;
import io.dataease.api.permissions.user.api.UserApi;
import io.dataease.api.permissions.user.vo.UserFormVO;
import io.dataease.commons.constants.TaskStatus; import io.dataease.commons.constants.TaskStatus;
import io.dataease.commons.utils.CommonThreadPool; import io.dataease.commons.utils.CommonThreadPool;
import io.dataease.constant.DataSourceType; import io.dataease.constant.DataSourceType;
@ -34,13 +32,13 @@ import io.dataease.datasource.provider.ApiUtils;
import io.dataease.datasource.provider.CalciteProvider; import io.dataease.datasource.provider.CalciteProvider;
import io.dataease.datasource.provider.ExcelUtils; import io.dataease.datasource.provider.ExcelUtils;
import io.dataease.datasource.request.DatasourceRequest; import io.dataease.datasource.request.DatasourceRequest;
import io.dataease.datasource.type.Pg;
import io.dataease.engine.constant.SQLConstants; import io.dataease.engine.constant.SQLConstants;
import io.dataease.exception.DEException; import io.dataease.exception.DEException;
import io.dataease.i18n.Translator; import io.dataease.i18n.Translator;
import io.dataease.license.config.XpackInteract; import io.dataease.license.config.XpackInteract;
import io.dataease.model.BusiNodeRequest; import io.dataease.model.BusiNodeRequest;
import io.dataease.model.BusiNodeVO; import io.dataease.model.BusiNodeVO;
import io.dataease.system.manage.CoreUserManage;
import io.dataease.utils.*; import io.dataease.utils.*;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
@ -89,11 +87,13 @@ public class DatasourceServer implements DatasourceApi {
private CoreDsFinishPageMapper coreDsFinishPageMapper; private CoreDsFinishPageMapper coreDsFinishPageMapper;
@Resource @Resource
private DatasetDataManage datasetDataManage; private DatasetDataManage datasetDataManage;
@Autowired(required = false)
private UserApi userApi;
@Autowired(required = false) @Autowired(required = false)
private InteractiveAuthApi interactiveAuthApi; private InteractiveAuthApi interactiveAuthApi;
@Resource
private CoreUserManage coreUserManage;
@Override @Override
public List<DatasourceDTO> query(String keyWord) { public List<DatasourceDTO> query(String keyWord) {
return null; return null;
@ -311,16 +311,16 @@ public class DatasourceServer implements DatasourceApi {
private static void checkParams(String configurationStr) { private static void checkParams(String configurationStr) {
DatasourceConfiguration configuration = JsonUtil.parseObject(configurationStr, DatasourceConfiguration.class); DatasourceConfiguration configuration = JsonUtil.parseObject(configurationStr, DatasourceConfiguration.class);
if(configuration.getInitialPoolSize() < configuration.getMinPoolSize()){ if (configuration.getInitialPoolSize() < configuration.getMinPoolSize()) {
DEException.throwException("初始连接数不能小于最小连接数!"); DEException.throwException("初始连接数不能小于最小连接数!");
} }
if(configuration.getInitialPoolSize() > configuration.getMaxPoolSize()){ if (configuration.getInitialPoolSize() > configuration.getMaxPoolSize()) {
DEException.throwException("初始连接数不能大于最大连接数!"); DEException.throwException("初始连接数不能大于最大连接数!");
} }
if(configuration.getMaxPoolSize() < configuration.getMinPoolSize()){ if (configuration.getMaxPoolSize() < configuration.getMinPoolSize()) {
DEException.throwException("最大连接数不能小于最小连接数!"); DEException.throwException("最大连接数不能小于最小连接数!");
} }
if(configuration.getQueryTimeout() < 0){ if (configuration.getQueryTimeout() < 0) {
DEException.throwException("查询超时不能小于0"); DEException.throwException("查询超时不能小于0");
} }
} }
@ -540,12 +540,8 @@ public class DatasourceServer implements DatasourceApi {
} }
datasourceDTO.setConfiguration(new String(Base64.getEncoder().encode(datasourceDTO.getConfiguration().getBytes()))); datasourceDTO.setConfiguration(new String(Base64.getEncoder().encode(datasourceDTO.getConfiguration().getBytes())));
if (userApi != null) { datasourceDTO.setCreator(coreUserManage.getUserName(Long.valueOf(datasourceDTO.getCreateBy())));
UserFormVO userFormVO = userApi.queryById(Long.valueOf(datasourceDTO.getCreateBy()));
if (userFormVO != null) {
datasourceDTO.setCreator(userFormVO.getName());
}
}
return datasourceDTO; return datasourceDTO;
} }
@ -882,7 +878,7 @@ public class DatasourceServer implements DatasourceApi {
List<DatasetTableDTO> datasetTableDTOS = ApiUtils.getTables(datasourceRequest); List<DatasetTableDTO> datasetTableDTOS = ApiUtils.getTables(datasourceRequest);
for (int i = 0; i < pager.getRecords().size(); i++) { for (int i = 0; i < pager.getRecords().size(); i++) {
for (int i1 = 0; i1 < datasetTableDTOS.size(); i1++) { for (int i1 = 0; i1 < datasetTableDTOS.size(); i1++) {
if(pager.getRecords().get(i).getTableName().equalsIgnoreCase(datasetTableDTOS.get(i1).getTableName())){ if (pager.getRecords().get(i).getTableName().equalsIgnoreCase(datasetTableDTOS.get(i1).getTableName())) {
pager.getRecords().get(i).setName(datasetTableDTOS.get(i1).getName()); pager.getRecords().get(i).setName(datasetTableDTOS.get(i1).getName());
} }
} }

View File

@ -0,0 +1,14 @@
package io.dataease.system.manage;
import io.dataease.license.config.XpackInteract;
import org.springframework.stereotype.Component;
@Component
public class CoreUserManage {
@XpackInteract(value = "coreUserManage", replace = true)
public String getUserName(Long uid) {
return "管理员";
}
}

@ -1 +1 @@
Subproject commit c2c4436bac4d300e5297ff1854fd6d45e01435ad Subproject commit 7a4f9a2de62a8ff0b544f2660bef3838cc09d6de