hbcl
/
bocloud.ims
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

处理大屏展示资源使用情况问题

develop
bayuzhen 2024-05-30 15:08:38 +08:00
parent 185d1cd9ad
commit 273988a5f8
1 changed files with 80 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
bocloud.ims.service/src/main/java/com/bocloud/ims/service/resource/server/ServerServiceImpl.java
View File

@ -150,31 +150,88 @@ public class ServerServiceImpl implements ServerService {
vendorId = Long.valueOf(paramMap.get("vendorId").toString()); vendorId = Long.valueOf(paramMap.get("vendorId").toString());
} }
} }
if (null == vendorId) { CloudVendor vendor = cloudVendorRepository.listById(vendorId);
Integer totals = 0; if (simple) {
List<CloudVendor> vendorList = cloudVendorRepository.queryProxy().col(GenericEntity::getDeleted).eq(0).list(); int total = this.serverRepository.count(params, labelContent, vendorType);
List<Server> servers = new ArrayList<>(); List<SimpleBean> beans = this.serverRepository.list(params, sorter, labelContent);
for (CloudVendor cloudVendor : vendorList) { gridBean = new GridBean(1, 1, total, beans);
vendorType = cloudVendor.getType();
int total = this.serverRepository.counts(params, labelContent, vendorType, clusterName, vdcName);
List<Server> list = this.serverRepository.list(page, rows, params, sorter, labelContent, vendorType, clusterName, vdcName);
getServerList(rows, params, cloudVendor, list);
servers.addAll(list);
totals += total;
}
gridBean = GridHelper.getBean(page, rows, totals, servers);
} else { } else {
CloudVendor vendor = cloudVendorRepository.listById(vendorId); int total = this.serverRepository.counts(params, labelContent, vendorType, clusterName, vdcName);
if (simple) { List<Server> list = this.serverRepository.list(page, rows, params, sorter, labelContent, vendorType, clusterName, vdcName);
int total = this.serverRepository.count(params, labelContent, vendorType);
List<SimpleBean> beans = this.serverRepository.list(params, sorter, labelContent); String azUuid, azName, ratioDesc;
gridBean = new GridBean(1, 1, total, beans); Long cpuUsed, cpuHz;
} else { Double memoryCapacity, memUsed;
int total = this.serverRepository.counts(params, labelContent, vendorType, clusterName, vdcName); ServerConfig config;
List<Server> list = this.serverRepository.list(page, rows, params, sorter, labelContent, vendorType, clusterName, vdcName); Map<String, String> allAzUuidNameMap = sangforAzService.getAllAzUuidNameMap();
getServerList(rows, params, vendor, list); Map<Long, String> netMap = new HashMap<>();
gridBean = GridHelper.getBean(page, rows, total, list); if (null != vendor && "CLOUDTOWER".equals(vendor.getType())) {
List<Long> collect = list.stream().map(Server::getId).collect(Collectors.toList());
List<NetworkCard> networkCardList = networkCardRepository.queryProxy().col(NetworkCard::getHostId).in(collect)
.col(NetworkCard::getCategory).eq("PM")
.col(GenericEntity::getDeleted).eq(false).list();
netMap = networkCardList.stream().collect(Collectors.toMap(NetworkCard::getHostId, NetworkCard::getInstanceId, (existingValue, newValue) -> newValue));
} }
for (Server server : list) {
if (null != vendor && "CLOUDTOWER".equals(vendor.getType())) {
server.setNicUuid(netMap.get(server.getId()));
}
azUuid = server.getAzUuid();
if (StringUtils.isNotEmpty(azUuid)) {
azName = allAzUuidNameMap.get(azUuid);
if (StringUtils.isNotEmpty(azName)) {
server.setAzName(azName);
}
}
List<NetworkCard> networkCards = networkCardRepository.listByHostIdAndSwitcherAvailable(server.getId(), true);
server.setNetcards(networkCards);
params.clear();
params.add(new Param(MapTools.simpleMap("hostId", server.getId()), Sign.EQ));
int vmNum = cloudServerRepository.count(params, 0L);
params.add(new Param(MapTools.simpleMap("isTemplate", 1), Sign.EQ));
int templateNum = cloudServerRepository.count(params, 0L);
server.setVmNum(vmNum - templateNum);
server.setTemplateNum(templateNum);
if (!StringUtils.isEmpty(server.getResourceGroup())) {
Dictionary dictionary = dictionaryRepository.query(server.getResourceGroup(), "RESOURCE_GROUP");
if (null != dictionary) {
server.setResourceGroupName(dictionary.getName());
}
}
// 设置这个物理机的资源池
if (ServerAssetCategory.X86_SERVER.name().equals(server.getAssetCategory())) {
// 这是一个x86物理机
server.setGroupName(poolGroupRepository.getGroupNameByResourceTarget(server.getId(),
ResourceCategory.Computer.name(), ResourceCatalog.PHYSICAL.name()));
}
Optional.ofNullable(this.serverConfigRepository.getBySid(server.getId()))
.ifPresent(server::setConfig);
config = server.getConfig();
Optional.ofNullable(server.getRole()).ifPresent(role -> {
server.setRoles(new ArrayList<>(Arrays.asList(role.split(","))));
server.getRoles().remove("nfs_gateway");
});
// 深信服6.8宿主机下拉框增加CPU和内存利用率(非实时数据，以上次同步时候的数据计算)
if ("6.8".equalsIgnoreCase(vendor.getVersion()) && CloudProvider.SANGFOR.name().equals(vendor.getType()) && rows == 9999) {
ratioDesc = "(CPU" + new BigDecimal(server.getCpuRatio()).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP).toString() + "%" + "-内存" + new BigDecimal(server.getMemRatio()).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP).toString() + "%)";
server.setName(server.getName() + ratioDesc);
}
// vmware宿主机下拉框增加CPU和内存利用率(非实时数据，以上次同步时候的数据计算)
if (CloudProvider.VMWARE.name().equals(vendor.getType()) && rows >= 9999 && config != null) {
cpuUsed = (config.getCpuUsed() != null ? config.getCpuUsed() : 0L);
cpuHz = (config.getCpuHz() != null ? config.getCpuHz() : 0L);
memUsed = (config.getMemUsed() != null ? config.getMemUsed() : 0D);
memoryCapacity = (config.getMemoryCapacity() != null ? config.getMemoryCapacity() : 0D);
if (cpuHz > 0L && memoryCapacity > 0D) {
ratioDesc = "(CPU" + new BigDecimal(cpuUsed * 1.0D / cpuHz).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP).toString() + "%" + "-内存" + new BigDecimal(memUsed / memoryCapacity).multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP).toString() + "%)";
server.setName(server.getName() + ratioDesc);
}
}
}
gridBean = GridHelper.getBean(page, rows, total, list);
} }
return new BocloudResult(true, gridBean, "查询成功"); return new BocloudResult(true, gridBean, "查询成功");
} catch (Exception e) { } catch (Exception e) {