summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorgaohao <[email protected]>2022-07-07 18:25:49 +0800
committergaohao <[email protected]>2022-07-07 18:25:49 +0800
commit98b27f5a07fdc7607ec9d5c5d25a5a8ecf366a9c (patch)
tree12e7e6c8c7f5a0205c28460c8a0d05cc22e1ade1
parentbd0c9437ccc3655e3f469960994441e6d1ce2d4c (diff)
fix: NEZ-2012 增加非空校验promapi-bak
-rw-r--r--nz-admin/src/main/java/com/nis/modules/endpoint/service/impl/MonitorEndpointServiceImpl.java17
1 files changed, 12 insertions, 5 deletions
diff --git a/nz-admin/src/main/java/com/nis/modules/endpoint/service/impl/MonitorEndpointServiceImpl.java b/nz-admin/src/main/java/com/nis/modules/endpoint/service/impl/MonitorEndpointServiceImpl.java
index c1d828e1..696a897c 100644
--- a/nz-admin/src/main/java/com/nis/modules/endpoint/service/impl/MonitorEndpointServiceImpl.java
+++ b/nz-admin/src/main/java/com/nis/modules/endpoint/service/impl/MonitorEndpointServiceImpl.java
@@ -195,10 +195,13 @@ public class MonitorEndpointServiceImpl extends ServiceImpl<MonitorEndpointDao,
.eq(SysUserStarredEntity::getUid, ShiroUtils.getUserId().intValue())
);
endpoint.setStarred(count == 0 ? 0 : 1);
-
- String agentId = String.valueOf(redisTemplate.opsForHash().entries(Constant.REDIS_KEY_ENDPOINT_PROM).get("" + id));
- Promserver promserver = promserverService.getById(Integer.valueOf(agentId));
- endpoint.setPromserver(promserver);
+ // 获取agent信息
+ Map endpointProm = redisTemplate.opsForHash().entries(Constant.REDIS_KEY_ENDPOINT_PROM);
+ if(ToolUtil.isNotEmpty(endpointProm)) {
+ String agentId = ToolUtil.toStr(endpointProm.get("" + id));
+ if(StrUtil.isNotBlank(agentId))
+ endpoint.setPromserver(promserverService.getById(Integer.valueOf(agentId)));
+ }
return endpoint;
}
@@ -652,7 +655,11 @@ public class MonitorEndpointServiceImpl extends ServiceImpl<MonitorEndpointDao,
endpointConfig.setLastUpdate(endpointStateByConfigId.getTime());
}
endpoint.setConfigs(configsByEndpointId);
- endpoint.setPromserver(agentMap.get(Integer.valueOf(String.valueOf(endpointProm.get("" + endpoint.getId())))));
+ if(ToolUtil.isNotEmpty(endpointProm)) {
+ String agentId = ToolUtil.toStr(endpointProm.get("" + endpoint.getId()));
+ if(StrUtil.isNotBlank(agentId))
+ endpoint.setPromserver(agentMap.get(Integer.valueOf(agentId)));
+ }
}
}