refactor: 优化数据源插件逻辑

This commit is contained in:
junjun 2024-07-31 18:25:08 +08:00
parent ba0100274a
commit 8e6e3d8795
3 changed files with 5 additions and 3 deletions

View File

@ -8,6 +8,7 @@ import io.dataease.extensions.datasource.vo.DatasourceConfiguration;
import io.dataease.extensions.datasource.vo.XpackPluginsDatasourceVO;
import io.dataease.extensions.view.dto.SqlVariableDetails;
import io.dataease.i18n.Translator;
import io.dataease.license.utils.LicenseUtil;
import io.dataease.utils.JsonUtil;
import net.sf.jsqlparser.expression.*;
import net.sf.jsqlparser.expression.operators.conditional.AndExpression;
@ -548,7 +549,7 @@ public class SqlparserUtils {
prefix = datasourceType.getPrefix();
suffix = datasourceType.getSuffix();
} else {
if (pluginManage != null) {
if (LicenseUtil.licenseValid()) {
List<XpackPluginsDatasourceVO> xpackPluginsDatasourceVOS = pluginManage.queryPluginDs();
List<XpackPluginsDatasourceVO> list = xpackPluginsDatasourceVOS.stream().filter(ele -> StringUtils.equals(ele.getType(), value.getType())).toList();
if (ObjectUtils.isNotEmpty(list)) {

View File

@ -26,6 +26,7 @@ import io.dataease.extensions.view.dto.ChartExtFilterDTO;
import io.dataease.extensions.view.dto.ChartExtRequest;
import io.dataease.extensions.view.dto.SqlVariableDetails;
import io.dataease.i18n.Translator;
import io.dataease.license.utils.LicenseUtil;
import io.dataease.system.manage.CorePermissionManage;
import io.dataease.utils.BeanUtils;
import io.dataease.utils.JsonUtil;
@ -374,7 +375,7 @@ public class DatasetSQLManage {
BeanUtils.copyBean(dto, datasourceType);
return dto;
} else {
if (pluginManage != null) {
if (LicenseUtil.licenseValid()) {
List<XpackPluginsDatasourceVO> xpackPluginsDatasourceVOS = pluginManage.queryPluginDs();
List<XpackPluginsDatasourceVO> list = xpackPluginsDatasourceVOS.stream().filter(ele -> StringUtils.equals(ele.getType(), type)).toList();
if (ObjectUtils.isNotEmpty(list)) {

View File

@ -859,7 +859,7 @@ public class DatasourceServer implements DatasourceApi {
private void preCheckDs(DatasourceDTO datasource) throws DEException {
List<String> list = datasourceTypes().stream().map(DatasourceConfiguration.DatasourceType::getType).collect(Collectors.toList());
if (pluginManage != null) {
if (LicenseUtil.licenseValid()) {
List<XpackPluginsDatasourceVO> xpackPluginsDatasourceVOS = pluginManage.queryPluginDs();
xpackPluginsDatasourceVOS.forEach(ele -> list.add(ele.getType()));
}