public/dataease
1
0
Fork 0
mirror of https://github.com/dataease/dataease.git synced 2026-05-15 05:22:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: 修复API数据源状态错误

Browse Source
This commit is contained in:
taojinlong
2025-02-20 19:37:32 +08:00
committed by taojinlong
parent 7207c94760
commit f70b115b90
2 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/core-backend/src/main/java/io/dataease/datasource/server/DatasourceServer.java
View File

@@ -10,12 +10,10 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import io.dataease.api.dataset.dto.PreviewSqlDTO;
import io.dataease.api.ds.DatasourceApi;
import io.dataease.api.ds.vo.*;
import io.dataease.api.lark.vo.LarkInfoVO;
import io.dataease.api.permissions.relation.api.RelationApi;
import io.dataease.commons.constants.TaskStatus;
import io.dataease.constant.LogOT;
import io.dataease.constant.LogST;
import io.dataease.constant.MessageEnum;
import io.dataease.dataset.manage.DatasetDataManage;
import io.dataease.dataset.utils.TableUtils;
import io.dataease.datasource.dao.auto.entity.*;
@@ -1170,15 +1168,14 @@ public class DatasourceServer implements DatasourceApi {
JsonNode jsonNode = null;
try {
jsonNode = objectMapper.readTree(datasourceDTO.getStatus());
} catch (Exception e) {
DEException.throwException(e);
}
for (JsonNode node : jsonNode) {
if (node.get("name").asText().equals(apiDefinition.getName())) {
status = node.get("status").asText();
for (JsonNode node : jsonNode) {
if (node.get("name").asText().equals(apiDefinition.getName())) {
status = node.get("status").asText();
}
}
apiDefinition.setStatus(status);
} catch (Exception ignore) {
}
apiDefinition.setStatus(status);
}
if (StringUtils.isNotEmpty(status) && status.equalsIgnoreCase("Success")) {
success++;

2
sdk/common/src/main/java/io/dataease/constant/DataSourceType.java
View File

@@ -2,7 +2,7 @@ package io.dataease.constant;
public enum DataSourceType {oracle(1), sqlServer(2), TiDB(3), hive(4), impala(5), mariadb(6), StarRocks(7), ds_doris(8), pg(9), mongo(10), ck(11), db2(12), redshift(13), es(14), API(15),
Excel(16), influxdb(17), sls(18), kingbase(19), mongobi(20), maxcompute(21), presto(22),
dm(23), kylin(24), folder(25), doris(26), mysql(27);
dm(23), kylin(24), folder(25), doris(26), mysql(27), APILark(28);
private final Integer flag;