xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除运管信息

Browse Source
This commit is contained in:
duwenyuan 2026-07-20 18:24:39 +08:00
parent 0239a93783
commit d04a18db0b
2 changed files with 5 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/aspect/StatusAspect.java
View File

@ -174,9 +174,9 @@ public class StatusAspect {
alarmItemService.saveOrUpdateBatch(alarmItems); alarmItemService.saveOrUpdateBatch(alarmItems);
} catch (FeignException.Unauthorized e) { } catch (FeignException.Unauthorized e) {
ManageUtil.refreshToken(); ManageUtil.refreshToken();
log.warn("向运管系统查询Hosts信息异常: Token失效,已刷新Token"); log.warn("更新数据源的状态信息异常: ",e);
} catch (Exception e) { } catch (Exception e) {
log.error("数据源更新状态/绑定HostId异常: {}", e.getMessage()); log.error("数据源更新状态 {}", e.getMessage());
} }
} }
@ -268,7 +268,7 @@ public class StatusAspect {
alarmItemService.saveOrUpdateBatch(alarmItems); alarmItemService.saveOrUpdateBatch(alarmItems);
} catch (FeignException.Unauthorized e) { } catch (FeignException.Unauthorized e) {
ManageUtil.refreshToken(); ManageUtil.refreshToken();
log.warn("向运管系统查询Hosts信息异常: Token失效,已刷新Token"); log.warn("服务器更新状态信息异常: ",e);
} catch (Exception e) { } catch (Exception e) {
log.error("服务器更新状态/绑定HostId/绑定监控项异常: {}", e.getMessage()); log.error("服务器更新状态/绑定HostId/绑定监控项异常: {}", e.getMessage());
} }

18
jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/service/impl/SysServerServiceImpl.java
View File

@ -93,20 +93,6 @@ public class SysServerServiceImpl extends ServiceImpl<SysServerMapper, SysServer
page = baseMapper.findPage(page, params); page = baseMapper.findPage(page, params);
List<ServerDto> serverDtos = page.getRecords(); List<ServerDto> serverDtos = page.getRecords();
// 获取所有在线服务器信息 // 获取所有在线服务器信息
List<Host> hosts = new ArrayList<>();
try {
String token = ManageUtil.getToken();
hosts = monitorAlarm.listApp(MonitorConstant.pageNo, MonitorConstant.pageSize, token)
.getResult().getRecords();
} catch (FeignException.Unauthorized e) {
ManageUtil.refreshToken();
log.warn("向运管系统查询Hosts信息异常: Token失效,已刷新Token");
} catch (Exception e) {
log.error("向运管系统查询Hosts信息异常: {}", e.getMessage());
}
// 将List<Host>转换为Map<hostId,Host>
Map<String, Host> hostMap =
hosts.stream().collect(Collectors.toMap(Host::getHostId, Host -> Host));
// 获取服务器状态信息 // 获取服务器状态信息
Map<Object, Object> statusMap = redisUtil.hmget(RedisConstant.SERVER_STATUS); Map<Object, Object> statusMap = redisUtil.hmget(RedisConstant.SERVER_STATUS);
statusMap = MapUtil.isEmpty(statusMap) ? MapUtil.newHashMap() : statusMap; statusMap = MapUtil.isEmpty(statusMap) ? MapUtil.newHashMap() : statusMap;
@ -577,10 +563,10 @@ public class SysServerServiceImpl extends ServiceImpl<SysServerMapper, SysServer
redisUtil.hmset(key, values); redisUtil.hmset(key, values);
} catch (FeignException.Unauthorized e) { } catch (FeignException.Unauthorized e) {
ManageUtil.refreshToken(); ManageUtil.refreshToken();
log.warn("向运管系统查询Hosts信息异常: Token失效,已刷新Token"); log.warn("服务器信息异常:",e);
} catch (Exception e) { } catch (Exception e) {
defaultStatus(sysServers); defaultStatus(sysServers);
log.error("向运管系统查询Hosts信息异常: {}", e.getMessage()); log.error("服务器信息异常: {}", e.getMessage());
} }
} }