From e97afcbaff4e3d05d80ed84e69b47fdbb61f4034 Mon Sep 17 00:00:00 2001 From: "1437892690@qq.com" <1437892690@qq.com> Date: Fri, 7 Nov 2025 19:42:38 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E4=B8=80=E4=B8=AA=E5=90=8C=E6=AD=A5balantflow=E8=87=AA?= =?UTF-8?q?=E5=AE=9A=E4=B9=89=E8=A7=86=E5=9B=BE=E6=95=B0=E6=8D=AE=E5=88=B0?= =?UTF-8?q?mongodb=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 关联 #[1421065807429632]增加一个同步balantflow自定义视图数据到mongodb接口 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1421065807429632 --- ...CiEntityDataToMongoDBForBalantFlowApi.java | 22 ++++++++++--------- 1 file changed, 12 insertions(+), 10 deletions(-) diff --git a/src/main/java/neatlogic/module/cmdb/api/synccientity/BatchSyncCiEntityDataToMongoDBForBalantFlowApi.java b/src/main/java/neatlogic/module/cmdb/api/synccientity/BatchSyncCiEntityDataToMongoDBForBalantFlowApi.java index 5f7f0d1e..4b8f09cf 100644 --- a/src/main/java/neatlogic/module/cmdb/api/synccientity/BatchSyncCiEntityDataToMongoDBForBalantFlowApi.java +++ b/src/main/java/neatlogic/module/cmdb/api/synccientity/BatchSyncCiEntityDataToMongoDBForBalantFlowApi.java @@ -547,14 +547,6 @@ public class BatchSyncCiEntityDataToMongoDBForBalantFlowApi extends PrivateApiCo JSONArray subset = fieldObj.getJSONArray("subset"); if (CollectionUtils.isNotEmpty(subset)) { JSONObject jsonObj = new JSONObject(); - JSONObject subDictionaryObj = ciId2DictionaryMap.get(ciId); - if (MapUtils.isNotEmpty(subDictionaryObj)) { - String _OBJ_CATEGORY = subDictionaryObj.getString("_OBJ_CATEGORY"); - jsonObj.put("_OBJ_CATEGORY", _OBJ_CATEGORY); - String _OBJ_TYPE = subDictionaryObj.getString("_OBJ_TYPE"); - jsonObj.put("_OBJ_TYPE", _OBJ_TYPE); - } - JSONArray jsonArray = new JSONArray(); for (int j = 0; j < subset.size(); j++) { JSONObject subObj = subset.getJSONObject(j); if (MapUtils.isNotEmpty(subObj)) { @@ -624,8 +616,18 @@ public class BatchSyncCiEntityDataToMongoDBForBalantFlowApi extends PrivateApiCo } } } - jsonArray.add(jsonObj); - dataObj.put(name, jsonArray); + if (MapUtils.isNotEmpty(jsonObj)) { + JSONObject subDictionaryObj = ciId2DictionaryMap.get(ciId); + if (MapUtils.isNotEmpty(subDictionaryObj)) { + String _OBJ_CATEGORY = subDictionaryObj.getString("_OBJ_CATEGORY"); + jsonObj.put("_OBJ_CATEGORY", _OBJ_CATEGORY); + String _OBJ_TYPE = subDictionaryObj.getString("_OBJ_TYPE"); + jsonObj.put("_OBJ_TYPE", _OBJ_TYPE); + } + JSONArray jsonArray = new JSONArray(); + jsonArray.add(jsonObj); + dataObj.put(name, jsonArray); + } } else { Long attrId = fieldObj.getLong("attrId"); for (int k = 0; k < attrList.size(); k++) { -- Gitee