iidi
/
bocloud.ams
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/develop' into develop

develop
Hoshi 2024-08-24 17:49:16 +08:00
parent 32c1501bd3 1d25f1355b
commit 572277c977
5 changed files with 160 additions and 37 deletions
bocloud.ams.booter/src/main/java/com/bocloud/ams/booter/controller/module
bocloud.ams.repository/src/main/java/com/bocloud/ams/repository/module
bocloud.ams.service/src/main/java/com/bocloud/ams/service

14
bocloud.ams.booter/src/main/java/com/bocloud/ams/booter/controller/module/ModuleController.java
View File

@ -189,4 +189,18 @@ public class ModuleController {
return moduleService.modifyProperty(model, id, context);
}
/**
* 首页统计模型总数-服务器、虚拟机、网络设备、安全设别
*
* @param model
* @param id
* @param context
* @return
*/
@PutMapping(value = "/statistics")
@Operation(summary = "首页统计模型总数")
public GeneralResult statistics(@Value(Common.REQ_CONTEXT) RequestContext context) {
return moduleService.statistics(context);
}
}

5
bocloud.ams.repository/src/main/java/com/bocloud/ams/repository/module/ModuleGroupRepository.java
View File

@ -36,6 +36,11 @@ public class ModuleGroupRepository extends BasicGenericDao<ModuleGroup, Long> {
String sql = "select * from ci_module_group where is_deleted =0 and parent_id =0 ORDER BY gmt_create DESC ";
return this.list(ModuleGroup.class, sql, null);
}
public List<ModuleGroup> queryRootInName(List<String> nameList) throws Exception {
String sql = "select * from ci_module_group where is_deleted =0 and parent_id =0 and name in (:name) ORDER BY gmt_create DESC ";
Map<String, Object> params = MapTools.simpleMap("name", nameList);
return this.list(ModuleGroup.class, sql, params);
}
public List<ModuleGroup> queryChildren(Long id) throws Exception {
String sql = "select * from ci_module_group where is_deleted =0 and parent_id = :id ORDER BY gmt_create DESC ";

57
bocloud.ams.service/src/main/java/com/bocloud/ams/service/internal/CmpInternalService.java Normal file
View File

@ -0,0 +1,57 @@
package com.bocloud.ams.service.internal;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.bocloud.cmp.boot.model.BocloudToken;
import com.megatron.common.model.GeneralResult;
import com.megatron.framework.core.CurrentService;
import com.megatron.framework.http.core.ServiceFactory;
import com.megatron.framework.http.model.RemoteService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import com.megatron.framework.http.core.HttpMethod;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
@Service
@Slf4j
public class CmpInternalService implements InitializingBean {
private Map<String, Object> headers = new HashMap<>(4);
private static final com.megatron.framework.core.Service SERVICE = com.megatron.framework.core.Service.create("cmp");
@Autowired
private CurrentService currentService;
@Autowired
private ServiceFactory serviceFactory;
public GeneralResult<JSONObject> list(Map<String,Object> params) {
String url = "/v1/vms";
log.info("params:{}", JSON.toJSONString(params));
RemoteService remoteService = serviceFactory.build(SERVICE, url, HttpMethod.GET, headers, params);
GeneralResult<?> result = remoteService.invoke();
log.info("result:{}",JSON.toJSONString(result));
if (result.isFailed()) {
return new GeneralResult<>(false, result.getMessage());
}
String data = JSONObject.toJSONString(result.getData());
return new GeneralResult<>(true, JSONObject.parseObject(data), "success");
}
@Override
public void afterPropertiesSet() throws Exception {
this.headers.put(BocloudToken.INTERNAL_TOKEN, currentService.getToken());
this.headers.put("source", currentService.getService().getName());
}
}

2
bocloud.ams.service/src/main/java/com/bocloud/ams/service/module/ModuleService.java
View File

@ -35,4 +35,6 @@ public interface ModuleService {
GeneralResult<GridBean<Property>> propertyList(Long moduleId, Pager pager);
GeneralResult<Void> modifyProperty(PropertyModel model, Long id, RequestContext context);
GeneralResult statistics(RequestContext context);
}

119
bocloud.ams.service/src/main/java/com/bocloud/ams/service/module/impl/ModuleServiceImpl.java
View File

@ -14,6 +14,9 @@ import java.util.concurrent.TimeUnit;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import com.alibaba.fastjson.JSONObject;
import com.bocloud.ams.service.internal.CmpInternalService;
import com.megatron.common.utils.MapTools;
import org.apache.commons.beanutils.BeanUtilsBean;
import org.apache.commons.beanutils.locale.LocaleBeanUtils;
import org.apache.commons.collections.CollectionUtils;
@ -107,6 +110,8 @@ public class ModuleServiceImpl implements ModuleService {
private CollectionComponentRepository collectionComponentRepository;
@Autowired
private ModuleGroupRepository moduleGroupRepository;
@Autowired
private CmpInternalService cmpInternalService;
@Override
public GeneralResult<GridBean<CiModule>> getModelList(Pager pager) {
@ -118,23 +123,23 @@ public class ModuleServiceImpl implements ModuleService {
List<Param> params = pager.getParams();
List<Map<String, Object>> collectMap = params.stream().map(Param::getParam).collect(Collectors.toList());
Map<String, Object> map =
collectMap.stream().filter(item -> item.containsKey("flag")).findFirst().orElse(null);
collectMap.stream().filter(item -> item.containsKey("flag")).findFirst().orElse(null);
if (null != map) {
Param newParam = null;
Iterator<Param> iterator = params.iterator();
while (iterator.hasNext()) {
Map<String, Object> parMap = iterator.next().getParam();
if (parMap.containsKey("moduleGroupId") && parMap.containsKey("flag")) {
Long groupId = Long.valueOf((Integer)parMap.get("moduleGroupId"));
Long groupId = Long.valueOf((Integer) parMap.get("moduleGroupId"));
if (parMap.get("flag").equals(true)) {
// 递归获取所有子groupId
List<ModuleGroup> groups = moduleGroupRepository.all();
Map<Long, List<ModuleGroup>> groupMap =
groups.stream().collect(Collectors.groupingBy(ModuleGroup::getParentId));
groups.stream().collect(Collectors.groupingBy(ModuleGroup::getParentId));
List<Long> groupIds = new ArrayList<>();
this.getGroups(groupIds, groupId, groupMap);
List<String> groupIdList =
groupIds.stream().map(String::valueOf).collect(Collectors.toList());
groupIds.stream().map(String::valueOf).collect(Collectors.toList());
String ids = String.join(",", groupIdList);
Map<String, Object> groupIdMap = new HashMap<>();
groupIdMap.put("moduleGroupId", ids);
@ -160,7 +165,7 @@ public class ModuleServiceImpl implements ModuleService {
if (CollectionUtils.isNotEmpty(groups)) {
for (CiModule module : modules) {
ModuleGroup group = groups.stream().filter(item -> item.getId().equals(module.getGroupId()))
.findFirst().orElse(null);
.findFirst().orElse(null);
if (null != group) {
module.setParentGroupId(group.getParentId());
}
@ -180,7 +185,7 @@ public class ModuleServiceImpl implements ModuleService {
try {
List<CiModule> modules = moduleRepository.all();
List<CiModule> list = modules.stream().filter(item -> ModuleConstant.STATUS_ENABLE.equals(item.getStatus()))
.collect(Collectors.toList());
.collect(Collectors.toList());
return new GeneralResult<>(true, list, "查询成功！");
} catch (Exception e) {
log.error("query module is error:", e);
@ -252,12 +257,12 @@ public class ModuleServiceImpl implements ModuleService {
return new GeneralResult<>(false, "新增模型属性分组失败");
}
Property id = new Property("uuid", "唯一标识", PropertyType.TEXTFIELD.name(), group.getName(), 100, true, true,
1, module.getId(), true, false, false, target, PropertyConstant.DefaultValueType.INNERFUN,
PropertyConstant.GLOBALLY_UNIQUE_IDENTIFIER, true, false);
1, module.getId(), true, false, false, target, PropertyConstant.DefaultValueType.INNERFUN,
PropertyConstant.GLOBALLY_UNIQUE_IDENTIFIER, true, false);
// name设置为标题列
Property name = new Property("name", "名称", PropertyType.TEXTFIELD.name(), group.getName(), 100, true, true,
2, module.getId(), true, false, true, target, PropertyConstant.DefaultValueType.FIXED, null, false,
true);
2, module.getId(), true, false, true, target, PropertyConstant.DefaultValueType.FIXED, null, false,
true);
properties.add(id);
properties.add(name);
propertyRepository.batchSave(properties, 10);
@ -323,11 +328,11 @@ public class ModuleServiceImpl implements ModuleService {
List<TopologyConfig> configs = topologyConfigRepository.listAll();
// 获取拓扑路径涉及到的模型数据
List<Long> modules = configs.stream().filter(item -> StringUtils.isNotEmpty(item.getTopologyPath()))
.flatMap(config -> Arrays.stream(config.getTopologyPath().split(","))).distinct()
.map(item -> Long.valueOf(item)).collect(Collectors.toList());
.flatMap(config -> Arrays.stream(config.getTopologyPath().split(","))).distinct()
.map(item -> Long.valueOf(item)).collect(Collectors.toList());
List<Long> ignores = configs.stream().filter(item -> StringUtils.isNotEmpty(item.getIgnoreModuleIds()))
.flatMap(config -> Arrays.stream(config.getIgnoreModuleIds().split(","))).distinct()
.map(item -> Long.valueOf(item)).collect(Collectors.toList());
.flatMap(config -> Arrays.stream(config.getIgnoreModuleIds().split(","))).distinct()
.map(item -> Long.valueOf(item)).collect(Collectors.toList());
modules.addAll(ignores);
modules.removeAll(Collections.singleton(null)); // 移除所有的null元素
if (modules.contains(id)) {
@ -419,8 +424,47 @@ public class ModuleServiceImpl implements ModuleService {
}
}
@Override
public GeneralResult statistics(RequestContext context) {
try {
List<String> nameList = Arrays.asList("网络设备", "物理服务器", "安全设备");
//查询根节点
List<ModuleGroup> rootGroups = moduleGroupRepository.queryRootInName(nameList);
log.info("moduleGroups:{}", JSON.toJSONString("moduleGroups"));
//查询出所有根节点下的子节点
List<Long> rootGroupIds = rootGroups.stream().map(ModuleGroup::getId).collect(Collectors.toList());
// 获取模型分组所有数据
List<ModuleGroup> moduleGroups = moduleGroupRepository.all();
// 获取根节点的子节点集合
List<ModuleGroup> children = moduleGroups.stream().filter(item -> rootGroupIds.contains(item.getParentId()))
.collect(Collectors.toList());
log.info("children:{}", JSON.toJSONString(children));
//查询云主机总数
Pager pager = new Pager();
pager.setPage(1);
pager.setRows(Integer.MAX_VALUE);
List<Param> paramList = new ArrayList<>();
Param param = new Param();
param.setParam(MapTools.simpleMap("isTemplate",false));
param.setSign(Sign.EQ);
paramList.add(param);
pager.setParams(paramList);
GeneralResult<JSONObject> list = cmpInternalService.list(pager.toMap());
log.info("list:{}", JSON.toJSONString(list));
return new GeneralResult<>(true, "查询成功");
} catch (Exception e) {
log.info("查询失败", e);
return new GeneralResult<>(false, "查询失败");
}
}
private GeneralResult baseModifyProperty(Long moduleId, List<PropertyGroup> groups, List<Property> properties,
Long userId) throws Exception {
Long userId) throws Exception {
CiModule module = moduleRepository.query(moduleId);
if (module == null) {
return GeneralResult.FAILED("修改属性对应的配置模型不存在");
@ -435,15 +479,15 @@ public class ModuleServiceImpl implements ModuleService {
List<PropertyGroup> oldGroups = propertyGroupRepository.listByModuleId(moduleId);
// 1-add：新增property数据 以及对应的propertyItem数据
List<Property> addProperties =
properties.stream().filter(item -> null == item.getId()).collect(Collectors.toList());
properties.stream().filter(item -> null == item.getId()).collect(Collectors.toList());
// 3-update:更新property数据（不允许从池表中引入的数据被更新） 以及对应的propertyItem数据
List<Property> updateProperties = properties.stream()
.filter(item -> null != item.getId()).collect(Collectors.toList());
.filter(item -> null != item.getId()).collect(Collectors.toList());
// 2-delete：删除去掉的property数据 以及对应的propertyItem数据
List<Long> inputPropertyIds =
properties.stream().filter(item -> null != item.getId()).map(Property::getId).collect(Collectors.toList());
properties.stream().filter(item -> null != item.getId()).map(Property::getId).collect(Collectors.toList());
List<Property> deleteProperties = oldProperties.stream()
.filter(item -> !inputPropertyIds.contains(item.getId())).collect(Collectors.toList());
.filter(item -> !inputPropertyIds.contains(item.getId())).collect(Collectors.toList());
// 1-delete：删除去掉的property数据 以及 对应的propertyItem数据
if (CollectionUtils.isNotEmpty(deleteProperties)) {
// 先校验是否存在被其他模型引用的属性，如果存在就不允许删除
@ -451,7 +495,7 @@ public class ModuleServiceImpl implements ModuleService {
List<Property> linkModuleIds = propertyRepository.queryByLinkModuleId(moduleId);
if (CollectionUtils.isNotEmpty(linkModuleIds)) {
long count = linkModuleIds.stream().map(Property::getPropertyIds).map(item -> item.split(","))
.flatMap(item -> Arrays.stream(item)).filter(item -> deletePropertyIds.contains(item)).count();
.flatMap(item -> Arrays.stream(item)).filter(item -> deletePropertyIds.contains(item)).count();
if (count > 0) {
return GeneralResult.FAILED("删除属性失败，存在其他模型引用此属性");
}
@ -460,7 +504,7 @@ public class ModuleServiceImpl implements ModuleService {
List<CollectionComponent> collectionComponents = collectionComponentRepository.queryByModuleId(moduleId);
if (CollectionUtils.isNotEmpty(collectionComponents)) {
long count = collectionComponents.stream().map(CollectionComponent::getPropertyId)
.filter(item -> deletePropertyIds.contains(item)).count();
.filter(item -> deletePropertyIds.contains(item)).count();
if (count > 0) {
return GeneralResult.FAILED("删除属性失败，存在属性被采集插件使用");
}
@ -480,7 +524,7 @@ public class ModuleServiceImpl implements ModuleService {
// 根据需要删除的property数据删除对应的propertyItem数据
List<Long> propertyIds = deleteProperties.stream().map(Property::getId).collect(Collectors.toList());
List<PropertyItem> deleteItems = oldItems.stream()
.filter(item -> propertyIds.contains(item.getPropertyId())).collect(Collectors.toList());
.filter(item -> propertyIds.contains(item.getPropertyId())).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(deleteItems)) {
deleteItems.stream().forEach(item -> {
item.setGmtModify(new Date());
@ -522,7 +566,7 @@ public class ModuleServiceImpl implements ModuleService {
}
// 3-update:更新数据
for (Property property : updateProperties) {
if(null != property.getPropertyPoolId()){
if (null != property.getPropertyPoolId()) {
property.setGmtModify(new Date());
property.setMenderId(userId);
propertyRepository.update(property);
@ -530,7 +574,7 @@ public class ModuleServiceImpl implements ModuleService {
}
// 获取新增item数据
List<PropertyItem> addItems = new ArrayList<>();
if (!Common.ONE.equals(property.getTableType())){
if (!Common.ONE.equals(property.getTableType())) {
addItems = property.getItemList().stream().filter(item -> null == item.getId()).collect(Collectors.toList());
addItems.stream().forEach(item -> {
item.setModuleId(property.getModuleId());
@ -546,22 +590,23 @@ public class ModuleServiceImpl implements ModuleService {
// 获取更新的item数据
List<PropertyItem> updateItems = new ArrayList<>();
List<Long> updateItemIds = new ArrayList<>();
if (!Common.ONE.equals(property.getTableType())){
if (!Common.ONE.equals(property.getTableType())) {
updateItems = property.getItemList().stream().filter(item -> null != item.getId()).collect(Collectors.toList());
updateItems.stream().forEach(item -> {
item.setMenderId(userId);
if (CollectionUtils.isNotEmpty(item.getItemList())) {
// 表格属性中结构项数据的下拉选项数据 转成 JSON 存储
item.setItemValue(JSON.toJSONString(item.getItemList()));
} updateItemIds.add(item.getId());
}
updateItemIds.add(item.getId());
});
}
// 根据当前属性id查询出之前的item
List<PropertyItem> updateOldItems = oldItems.stream()
.filter(item -> item.getPropertyId().equals(property.getId())).collect(Collectors.toList());
.filter(item -> item.getPropertyId().equals(property.getId())).collect(Collectors.toList());
// 获取需要删除的item数据（就是原始的减去现在的）
List<PropertyItem> deleteItems = updateOldItems.stream()
.filter(item -> !updateItemIds.contains(item.getId())).collect(Collectors.toList());
.filter(item -> !updateItemIds.contains(item.getId())).collect(Collectors.toList());
deleteItems.stream().forEach(item -> {
item.setGmtModify(new Date());
item.setMenderId(userId);
@ -588,13 +633,13 @@ public class ModuleServiceImpl implements ModuleService {
// 获取需要新增的group数据
if (CollectionUtils.isNotEmpty(groups)) {
List<PropertyGroup> addGroups =
groups.stream().filter(item -> null == item.getId()).collect(Collectors.toList());
groups.stream().filter(item -> null == item.getId()).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(addGroups)) {
propertyGroupRepository.batchSave(addGroups, addGroups.size());
}
// 获取需要更新的group数据
List<PropertyGroup> updateGroups =
groups.stream().filter(item -> null != item.getId()).collect(Collectors.toList());
groups.stream().filter(item -> null != item.getId()).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(updateGroups)) {
updateGroups.stream().forEach(item -> {
item.setMenderId(userId);
@ -604,7 +649,7 @@ public class ModuleServiceImpl implements ModuleService {
List<Long> groupIds = updateGroups.stream().map(PropertyGroup::getId).collect(Collectors.toList());
// 获取需要删除的数据
List<PropertyGroup> deleteGroups =
oldGroups.stream().filter(item -> !groupIds.contains(item.getId())).collect(Collectors.toList());
oldGroups.stream().filter(item -> !groupIds.contains(item.getId())).collect(Collectors.toList());
if (CollectionUtils.isNotEmpty(deleteGroups)) {
deleteGroups.stream().forEach(item -> {
item.setModuleId(userId);
@ -636,7 +681,7 @@ public class ModuleServiceImpl implements ModuleService {
}
code = code.trim();
Pattern compile = Pattern.compile(
"^(create|alter|select|update|union|and|or|delete|insert|trancate|char|substr|commit|ascii|declare|exec|count|show|into|drop|execute)$");
"^(create|alter|select|update|union|and|or|delete|insert|trancate|char|substr|commit|ascii|declare|exec|count|show|into|drop|execute)$");
if (compile.matcher(code).find()) {
throw new Exception("属性编码不能是关键字：" + code);
}
@ -658,7 +703,7 @@ public class ModuleServiceImpl implements ModuleService {
List<PropertyItem> items = property.getItemList();
if (CollectionUtils.isNotEmpty(items)) {
if (property.getType().equals(PropertyConstant.PropertyType.MULTILINETABLE)
|| property.getType().equals(PropertyConstant.PropertyType.SINGLELINETABLE)) {
|| property.getType().equals(PropertyConstant.PropertyType.SINGLELINETABLE)) {
Map<String, String> itemNameMap = new HashMap<>();
Map<String, String> itemCodeMap = new HashMap<>();
List<PropertyItem> tableItems = property.getItemList();
@ -681,9 +726,9 @@ public class ModuleServiceImpl implements ModuleService {
}
itemCodeMap.put(itemCode, itemCode);
if (tableItem.getType().equals(PropertyConstant.PropertyType.SINGLESELECT)
|| tableItem.getType().equals(PropertyConstant.PropertyType.MULTISELECT)
|| tableItem.getType().equals(PropertyConstant.PropertyType.RADIO)
|| tableItem.getType().equals(PropertyConstant.PropertyType.CHECKBOX)) {
|| tableItem.getType().equals(PropertyConstant.PropertyType.MULTISELECT)
|| tableItem.getType().equals(PropertyConstant.PropertyType.RADIO)
|| tableItem.getType().equals(PropertyConstant.PropertyType.CHECKBOX)) {
validateItemValues(tableItem);
}
}
@ -754,7 +799,7 @@ public class ModuleServiceImpl implements ModuleService {
}
private void copyProperties(Property property, PropertyPool pool)
throws IllegalAccessException, InvocationTargetException {
throws IllegalAccessException, InvocationTargetException {
Long id = property.getId();
BeanUtilsBean.getInstance().copyProperties(property, pool);
property.setId(id);