From b035875b12d77d3e161a58afdd908591ef563e2e Mon Sep 17 00:00:00 2001
From: xingjinshuang <xingjs@qq.com>
Date: 星期四, 26 十二月 2024 09:57:21 +0800
Subject: [PATCH] @xingjs@20241226@添加查询管线工具类
---
src/main/java/com/se/simu/service/ProjectRelatedService.java | 2 ++
src/main/java/com/se/simu/controller/ProjectRelatedController.java | 9 +++++++++
src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java | 40 ++++++++++++++++++++++++++++++++++++++++
3 files changed, 51 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/se/simu/controller/ProjectRelatedController.java b/src/main/java/com/se/simu/controller/ProjectRelatedController.java
index 8332b67..969be98 100644
--- a/src/main/java/com/se/simu/controller/ProjectRelatedController.java
+++ b/src/main/java/com/se/simu/controller/ProjectRelatedController.java
@@ -90,5 +90,14 @@
return projectRelatedService.getEntityTypeInfo(entityTypeInfo);
}
+ /**
+ * 鏌ヨ瀹炰綋搴撲笉鍚岀被鍨嬬殑淇℃伅
+ */
+ @ApiOperation("4-鏌ヨ瀹炰綋搴撲笉鍚岀被鍨嬬殑淇℃伅-绠＄嚎")
+ @GetMapping("/entity-pipe-info")
+ public Object getEntityPipeInfo(EntityTypeInfo entityTypeInfo) {
+ return projectRelatedService.getEntityPipeInfo(entityTypeInfo);
+ }
+
}
diff --git a/src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java b/src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java
index e6442cf..9ab2252 100644
--- a/src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java
+++ b/src/main/java/com/se/simu/service/Impl/ProjectRelatedServiceImpl.java
@@ -325,4 +325,44 @@
}
+ @Override
+ public Object getEntityPipeInfo(EntityTypeInfo entityTypeInfo) {
+ HashMap<String, String> headers = new HashMap<>();
+ headers.put("Content-Type", "application/json");
+ String token = (String) CaffeineHelper.get(CacheConstants.USER_CACHE_KEY + "entity_db_token");
+ log.info("token = " + token);
+ // 娣诲姞form鍙傛暟
+ HashMap<String, Object> params = new HashMap<>();
+ // e7e2af87096c45e0a14c0a4855cb0b90
+ params.put("token", token);
+ params.put("start", Objects.nonNull(entityTypeInfo.getStart()) ? entityTypeInfo.getStart() : 1);
+ params.put("containCount", true);
+ params.put("count", Objects.nonNull(entityTypeInfo.getCount()) ? entityTypeInfo.getCount() : 20);
+ params.put("dbid", Objects.nonNull(entityTypeInfo.getDbid()) ? entityTypeInfo.getDbid() : "85257774fdb64e5f99f6778696cad02a");
+ params.put("layerid", "1e677d48-8dff-4975-b9a0-c16500193629");
+ params.put("like", "");
+ params.put("querytype", "entity");
+
+ CompletableFuture<String> postResponse = CustomWebClient.postAsFuture(queryUrl, params, headers, String.class);
+ // 寮傛澶勭悊鍝嶅簲
+ postResponse.thenAccept(response -> {
+ log.info("response: {}", response);
+ if (response.contains("code")) {
+ try {
+ JSONObject postResponseJson = JSONObject.parseObject(response);
+ int statusCode = postResponseJson.getIntValue("code");
+ log.info("statusCode = " + statusCode);
+ String data = postResponseJson.getString("data");
+ log.info("getEntityTypeInfo = " + data);
+ } catch (Exception e) {
+ log.info("Failed to parse JSON: " + e.getMessage());
+ }
+ } else {
+ log.info("No 'code' field in the response: " + response);
+ }
+ });
+ return JSONObject.parseObject(postResponse.join());
+ }
+
+
}
diff --git a/src/main/java/com/se/simu/service/ProjectRelatedService.java b/src/main/java/com/se/simu/service/ProjectRelatedService.java
index 2bca4ef..e5a1ddc 100644
--- a/src/main/java/com/se/simu/service/ProjectRelatedService.java
+++ b/src/main/java/com/se/simu/service/ProjectRelatedService.java
@@ -30,4 +30,6 @@
Object getDbLits();
Object getEntityTypeInfo(EntityTypeInfo entityTypeInfo);
+
+ Object getEntityPipeInfo(EntityTypeInfo entityTypeInfo);
}
--
Gitblit v1.9.3