基于SpringBoot、MyBatisPlus、ElementUI、G2Plot、Echarts等技术栈的大屏设计器

package com.gccloud.dataroom.core.module.map.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gccloud.common.exception.GlobalException; import com.gccloud.common.utils.BeanConvertUtils; import com.gccloud.common.utils.JSON; import com.gccloud.common.utils.QueryWrapperUtils; import com.gccloud.dataroom.core.module.map.dto.DataRoomMapRepeatDTO; import com.gccloud.dataroom.core.module.map.vo.DataRoomMapVO; import com.gccloud.dataroom.core.module.map.vo.MapChildVO; import com.gccloud.dataroom.core.module.map.dao.DataRoomMapDao; import com.gccloud.dataroom.core.module.map.dto.DataRoomMapDTO; import com.gccloud.dataroom.core.module.map.dto.MapSearchDTO; import com.gccloud.dataroom.core.module.map.entity.DataRoomMapEntity; import com.gccloud.dataroom.core.module.map.service.IDataRoomMapService; import com.google.common.collect.Lists; import org.apache.commons.lang3.StringUtils; import org.json.JSONArray; import org.json.JSONObject; import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; /** * @author hongyang * @version 1.0 * @date 2023/8/31 14:08 */ @Service public class DataRoomMapServiceImpl extends ServiceImpl<DataRoomMapDao, DataRoomMapEntity> implements IDataRoomMapService { public static final int YES = 1; public static final int NO = 0; @Override public List<DataRoomMapVO> getList(MapSearchDTO searchDTO) { if (StringUtils.isNotBlank(searchDTO.getSearchKey())) { searchDTO.setParentId(null); } LambdaQueryWrapper<DataRoomMapEntity> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.select(DataRoomMapEntity::getParentId); List<DataRoomMapEntity> list = this.list(queryWrapper); Set<String> parentIds = list.stream().map(DataRoomMapEntity::getParentId).collect(Collectors.toSet()); LambdaQueryWrapper<DataRoomMapEntity> wrapper = QueryWrapperUtils.wrapperLike(new LambdaQueryWrapper<>(), searchDTO.getSearchKey(), DataRoomMapEntity::getName, DataRoomMapEntity::getMapCode); wrapper.eq(searchDTO.getLevel() != null, DataRoomMapEntity::getLevel, searchDTO.getLevel()); wrapper.eq(StringUtils.isNotBlank(searchDTO.getParentId()), DataRoomMapEntity::getParentId, searchDTO.getParentId()); wrapper.eq(searchDTO.getUploadedGeoJson() != null, DataRoomMapEntity::getUploadedGeoJson, searchDTO.getUploadedGeoJson()); List<DataRoomMapEntity> entityList = this.list(wrapper); List<String> idList = entityList.stream().map(DataRoomMapEntity::getId).collect(Collectors.toList()); List<DataRoomMapVO> voList = Lists.newArrayList(); for (DataRoomMapEntity entity : entityList) { // 如果地图的直接父级也在列表中，那么不返回该地图 if (idList.contains(entity.getParentId())) { continue; } DataRoomMapVO mapVO = BeanConvertUtils.convert(entity, DataRoomMapVO.class); mapVO.setHasChildren(parentIds.contains(entity.getId())); voList.add(mapVO); } return voList; // return this.baseMapper.getList(searchDTO); } @Override public List<DataRoomMapVO> getAvailableTree(Integer level) { // 根据层级，如果某个地图的某个子级（或子级的子级...）也符合该层级，那么把该地图也返回 LambdaQueryWrapper<DataRoomMapEntity> queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.select(DataRoomMapEntity::getId, DataRoomMapEntity::getLevel, DataRoomMapEntity::getParentId, DataRoomMapEntity::getMapCode, DataRoomMapEntity::getName, DataRoomMapEntity::getUploadedGeoJson); queryWrapper.le(DataRoomMapEntity::getLevel, level); List<DataRoomMapEntity> list = list(queryWrapper); // 转成树形结构 return this.convertToTree(list, level); } /** * 转树形结构 * @param list * @return */ private List<DataRoomMapVO> convertToTree(List<DataRoomMapEntity> list, Integer targetLevel) { List<DataRoomMapVO> voList = BeanConvertUtils.convert(list, DataRoomMapVO.class); // 根节点 List<DataRoomMapVO> rootList = Lists.newArrayList(); // 组装id为key，地图为value的map Map<String, DataRoomMapVO> map = new HashMap<>(); voList.forEach(vo -> map.put(vo.getId(), vo)); // 目标层级的地图 List<DataRoomMapVO> targetLevelList = voList.stream().filter(vo -> vo.getLevel().equals(targetLevel)).collect(Collectors.toList()); // 目标层级的地图，以及其父级地图... List<DataRoomMapVO> match = Lists.newArrayList(targetLevelList); for (DataRoomMapVO mapVO : targetLevelList) { mapVO.setDisabled(!mapVO.getUploadedGeoJson().equals(YES)); if (mapVO.getLevel().equals(0)) { // 已经是最顶级了，没有父级了 continue; } DataRoomMapVO parent = map.get(mapVO.getParentId()); if(parent == null) { continue; } // 将目标层级的地图，以及其父级地图...加入到match中 this.getParentMap(parent, map, match); } for (DataRoomMapVO vo : match) { if (vo.getParentId().equals(SUPER_PARENT_ID)) { rootList.add(vo); continue; } DataRoomMapVO parent = map.get(vo.getParentId()); if (parent == null) { continue; } if (parent.getChildren() == null) { parent.setChildren(Lists.newArrayList()); } parent.getChildren().add(vo); } return rootList; } /** * 获取地图的父级地图，以及父级地图的父级地图... * @param parentMap * @param mapIdMap * @param match */ private void getParentMap(DataRoomMapVO parentMap, Map<String, DataRoomMapVO> mapIdMap, List<DataRoomMapVO> match) { if (parentMap == null) { return; } if (match.contains(parentMap)) { // 已经包含了，不需要再加入了 return; } match.add(parentMap); if (parentMap.getLevel().equals(0)) { // 已经是最顶级了，没有父级了 return; } DataRoomMapVO parent = mapIdMap.get(parentMap.getParentId()); this.getParentMap(parent, mapIdMap, match); } @Override public String add(DataRoomMapDTO mapDTO) { if (StringUtils.isBlank(mapDTO.getParentId())) { mapDTO.setParentId(SUPER_PARENT_ID); } if (StringUtils.isBlank(mapDTO.getMapCode())) { throw new GlobalException("地图编码不能为空"); } DataRoomMapEntity mapEntity = BeanConvertUtils.convert(mapDTO, DataRoomMapEntity.class); if (StringUtils.isNotBlank(mapEntity.getGeoJson())) { mapEntity.setUploadedGeoJson(YES); } else { mapEntity.setUploadedGeoJson(NO); } this.save(mapEntity); if (mapDTO.getAutoParseNextLevel().equals(YES) && mapEntity.getUploadedGeoJson().equals(YES)) { // 自动从geoJson中解析下一级的基础数据，保存到数据库，将geoJson上传状态置为false this.parseNextLevelAndSave(mapEntity, mapEntity.getGeoJson()); } return mapEntity.getId(); } @Override public void update(DataRoomMapDTO mapDTO) { if (StringUtils.isBlank(mapDTO.getId())) { throw new GlobalException("地图id不能为空"); } DataRoomMapEntity old = this.getB