package com.qianwen.smartman.modules.dnc.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
import java.util.stream.Stream;
|
|
import org.apache.commons.compress.utils.Lists;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.google.common.collect.Sets;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.mp.base.BaseServiceImpl;
|
import com.qianwen.core.tool.constant.BladeConstant;
|
import com.qianwen.core.tool.node.ForestNodeMerger;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.common.constant.DncConstant;
|
import com.qianwen.smartman.common.utils.ListUtils;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.smartman.modules.cps.vo.ProcessCatalogueTreeVO;
|
import com.qianwen.smartman.modules.dnc.convert.DncProcessCatalogueConvert;
|
import com.qianwen.smartman.modules.dnc.entity.DncArtBag;
|
import com.qianwen.smartman.modules.dnc.entity.DncArtFile;
|
import com.qianwen.smartman.modules.dnc.entity.DncProcessCatalogue;
|
import com.qianwen.smartman.modules.dnc.enums.DncEnums;
|
import com.qianwen.smartman.modules.dnc.mapper.DncProcessCatalogueMapper;
|
import com.qianwen.smartman.modules.dnc.service.IDncArtBagService;
|
import com.qianwen.smartman.modules.dnc.service.IDncArtFileService;
|
import com.qianwen.smartman.modules.dnc.service.IDncProcessCatalogueService;
|
import com.qianwen.smartman.modules.dnc.vo.DncCatalogueAndArtBagTreeVO;
|
import com.qianwen.smartman.modules.dnc.vo.DncCatalogueAndArtBagVO;
|
import com.qianwen.smartman.modules.dnc.vo.DncProcessCatalogueVO;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/DncProcessCatalogueServiceImpl.class */
|
public class DncProcessCatalogueServiceImpl extends BaseServiceImpl<DncProcessCatalogueMapper, DncProcessCatalogue> implements IDncProcessCatalogueService {
|
@Autowired
|
@Lazy
|
private IDncArtBagService artBagService;
|
@Autowired
|
@Lazy
|
private IDncArtFileService dncArtFileService;
|
private static final Long RANDOM_ID = 234123L;
|
|
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public DncProcessCatalogueVO updateName(Long id, String name) {
|
DncProcessCatalogue dncProcessCatalogue = (DncProcessCatalogue) getById(id);
|
checkName(dncProcessCatalogue.getParentId(), id, name);
|
dncProcessCatalogue.setName(name);
|
updateById(dncProcessCatalogue);
|
return DncProcessCatalogueConvert.INSTANCE.convert(dncProcessCatalogue);
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public DncProcessCatalogueVO save(Long parentId, String name) {
|
checkName(parentId, null, name);
|
DncProcessCatalogue dncProcessCatalogue = new DncProcessCatalogue();
|
dncProcessCatalogue.setName(name).setParentId(parentId);
|
save(dncProcessCatalogue);
|
DncProcessCatalogue parent = (DncProcessCatalogue) getById(parentId);
|
String parentAllPath = parent.getAllPath();
|
String allPath = parentAllPath + "/" + dncProcessCatalogue.getId();
|
DncProcessCatalogue byId = (DncProcessCatalogue) getById(dncProcessCatalogue.getId());
|
byId.setAllPath(allPath);
|
updateById(byId);
|
return DncProcessCatalogueConvert.INSTANCE.convert(byId);
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
@Transactional(rollbackFor = {Exception.class})
|
public boolean remove(List<String> ids) {
|
String id = ListUtils.getFirst(ids);
|
Set<String> catalogueIdSets = Sets.newHashSet(listObjs(Wrappers.<DncProcessCatalogue>lambdaQuery().select(DncProcessCatalogue::getId).like(DncProcessCatalogue::getAllPath, id), String::valueOf));
|
/*
|
Set<String> catalogueIdSets = Sets.newHashSet(listObjs((Wrapper) Wrappers.lambdaQuery().select(new SFunction[]{(v0) -> {
|
return v0.getId();
|
}}).like((v0) -> {
|
return v0.getAllPath();
|
}, id), String::valueOf));*/
|
catalogueIdSets.add(id);
|
List<Long> catalogueIds = catalogueIdSets.stream().map((v0) -> {
|
return Func.toLong(v0);
|
}).collect(Collectors.toList());
|
removeByIds(catalogueIds);
|
List<Long> bagIds = this.artBagService.listObjs(Wrappers.<DncArtBag>lambdaQuery().select(DncArtBag::getId).in(DncArtBag::getCatalogueId, catalogueIds), bagId -> Long.valueOf(bagId.toString()));
|
/*
|
List<Long> bagIds = this.artBagService.listObjs((Wrapper) Wrappers.lambdaQuery().select(new SFunction[]{(v0) -> {
|
return v0.getId();
|
}}).in((v0) -> {
|
return v0.getCatalogueId();
|
}, catalogueIds), bagId -> {
|
return Long.valueOf(bagId.toString());
|
});*/
|
if (Func.isNotEmpty(bagIds)) {
|
this.artBagService.removeByIds(bagIds);
|
this.dncArtFileService.remove(Wrappers.<DncArtFile>lambdaQuery().in(DncArtFile::getArtBagId, bagIds));
|
/*
|
this.dncArtFileService.remove((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getArtBagId();
|
}, bagIds));*/
|
return true;
|
}
|
return true;
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public List<DncProcessCatalogueVO> lazyList(String parentId) {
|
if (Func.isEmpty(parentId)) {
|
parentId = DncConstant.DNC_DEFAULT_PARENT_ID;
|
}
|
|
List<DncProcessCatalogue> list = list(Wrappers.<DncProcessCatalogue>lambdaQuery().eq(DncProcessCatalogue::getParentId, parentId));
|
/*
|
List<DncProcessCatalogue> list = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, parentId));*/
|
return DncProcessCatalogueConvert.INSTANCE.convert(list);
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public List<DncCatalogueAndArtBagVO> lazyArtBagList(String parentId) {
|
Long groupId = null;
|
if (Func.isEmpty(parentId)) {
|
parentId = DncConstant.DNC_DEFAULT_PARENT_ID;
|
} else {
|
groupId = Long.valueOf(Func.toLong(parentId));
|
}
|
List<DncCatalogueAndArtBagVO> voList = new ArrayList<>();
|
List<DncProcessCatalogue> list = list(Wrappers.<DncProcessCatalogue>lambdaQuery().eq(DncProcessCatalogue::getParentId, parentId));
|
/*
|
List<DncProcessCatalogue> list = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, parentId));*/
|
if (Func.isNotEmpty(list)) {
|
List<DncCatalogueAndArtBagVO> collect = list.stream().map(catalogue -> {
|
return DncCatalogueAndArtBagVO.builder().parentId(catalogue.getParentId()).name(catalogue.getName()).id(catalogue.getId()).isGroup(Boolean.TRUE).isArtBag(Boolean.FALSE).build();
|
}).collect(Collectors.toList());
|
voList.addAll(collect);
|
}
|
List<DncProcessCatalogue> groupList = list();
|
if (Func.isNotEmpty(groupList)) {
|
Map<Long, DncProcessCatalogue> dncProcessCatalogueMap = list().stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, Function.identity()));
|
if (groupId != null) {
|
List<DncArtBag> artBagList = this.artBagService.list(Wrappers.<DncArtBag>lambdaQuery().eq(DncArtBag::getCatalogueId, groupId));
|
/*
|
List<DncArtBag> artBagList = this.artBagService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getCatalogueId();
|
}, groupId));*/
|
if (Func.isNotEmpty(artBagList)) {
|
List<DncCatalogueAndArtBagVO> dncCatalogueAndArtBags = artBagList.stream().map(catalogue2 -> {
|
DncProcessCatalogue dncProcessCatalogue = (DncProcessCatalogue) dncProcessCatalogueMap.get(catalogue2.getCatalogueId());
|
return DncCatalogueAndArtBagVO.builder().id(catalogue2.getCatalogueId()).parentId(dncProcessCatalogue.getParentId()).artId(Func.toStr(catalogue2.getId())).code(catalogue2.getCode()).artName(catalogue2.getName()).isGroup(Boolean.FALSE).isArtBag(Boolean.TRUE).build();
|
}).collect(Collectors.toList());
|
voList.addAll(dncCatalogueAndArtBags);
|
}
|
}
|
}
|
return voList;
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public List<DncCatalogueAndArtBagTreeVO> artBagTree() {
|
List<DncProcessCatalogue> list = list();
|
List<DncArtBag> artBagList = this.artBagService.list();
|
return ForestNodeMerger.merge( Stream.concat(list.stream().map(catalogue -> {
|
return DncCatalogueAndArtBagTreeVO.builder().parentId(catalogue.getParentId()).name(catalogue.getName()).id(catalogue.getId()).isGroup(Boolean.TRUE).isArtBag(Boolean.FALSE).build();
|
}), artBagList.stream().map(catalogue2 -> {
|
return DncCatalogueAndArtBagTreeVO.builder().id(catalogue2.getId()).parentId(catalogue2.getCatalogueId()).artId(Func.toStr(catalogue2.getId())).code(catalogue2.getCode()).artName(catalogue2.getName()).isGroup(Boolean.FALSE).isArtBag(Boolean.TRUE).build();
|
})).collect(Collectors.toList()));
|
}
|
|
@Override // org.springblade.modules.dnc.service.IDncProcessCatalogueService
|
public List<ProcessCatalogueTreeVO> cateArtBagTree() {
|
List<DncProcessCatalogue> catalogueList = list();
|
List<ProcessCatalogueTreeVO> tree = Lists.newArrayList();
|
if (Func.isNotEmpty(catalogueList)) {
|
List<ProcessCatalogueTreeVO> res = catalogueList.stream().map(c -> {
|
ProcessCatalogueTreeVO vo = new ProcessCatalogueTreeVO();
|
Long id = Long.valueOf(c.getId().equals(BladeConstant.TOP_PARENT_ID) ? c.getId().longValue() + RANDOM_ID.longValue() : c.getId().longValue());
|
vo.setId(id);
|
vo.setParentId(c.getParentId());
|
vo.setName(c.getName());
|
vo.setCode(c.getName());
|
vo.setIsProcess(false);
|
return vo;
|
}).collect(Collectors.toList());
|
tree.addAll(res);
|
List<Long> catalogueIds = catalogueList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<DncArtBag> dncArtBags = this.artBagService.list(Wrappers.lambdaQuery(DncArtBag.class).in((v0) -> {
|
return v0.getCatalogueId();
|
}, catalogueIds));
|
if (Func.isNotEmpty(dncArtBags)) {
|
List<ProcessCatalogueTreeVO> bagRes = dncArtBags.stream().map(c2 -> {
|
ProcessCatalogueTreeVO vo = new ProcessCatalogueTreeVO();
|
vo.setId(c2.getId());
|
Long parentId = Long.valueOf(c2.getCatalogueId().equals(BladeConstant.TOP_PARENT_ID) ? c2.getCatalogueId().longValue() + RANDOM_ID.longValue() : c2.getCatalogueId().longValue());
|
vo.setParentId(parentId);
|
vo.setName(c2.getName());
|
vo.setCode(c2.getName());
|
vo.setIsProcess(false);
|
return vo;
|
}).collect(Collectors.toList());
|
tree.addAll(bagRes);
|
List<Long> bagIds = dncArtBags.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
|
List<DncArtFile> files = this.dncArtFileService.list(Wrappers.lambdaQuery(DncArtFile.class)
|
.in(DncArtFile::getArtBagId, bagIds)
|
.eq(DncArtFile::getFileType, 1)
|
.eq(DncArtFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
|
/*
|
List<DncArtFile> files = this.dncArtFileService.list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery(DncArtFile.class).in((v0) -> {
|
return v0.getArtBagId();
|
}, bagIds)).eq((v0) -> {
|
return v0.getFileType();
|
}, 1)).eq((v0) -> {
|
return v0.getIsCurrent();
|
}, DncEnums.CurrentVersion.YES.getCode()));
|
*/
|
if (Func.isNotEmpty(files)) {
|
List<ProcessCatalogueTreeVO> fileRes = files.stream().map(c3 -> {
|
ProcessCatalogueTreeVO vo = new ProcessCatalogueTreeVO();
|
vo.setId(c3.getId());
|
vo.setParentId(c3.getArtBagId());
|
vo.setName(c3.getFilename());
|
vo.setCode(c3.getOriginalFilename());
|
vo.setIsProcess(true);
|
return vo;
|
}).collect(Collectors.toList());
|
tree.addAll(fileRes);
|
}
|
}
|
}
|
return ForestNodeMerger.merge(tree);
|
}
|
|
private void checkName(Long parentId, Long id, String name) {
|
long count = count(Wrappers.<DncProcessCatalogue>lambdaQuery()
|
.eq(DncProcessCatalogue::getParentId, parentId)
|
.eq(DncProcessCatalogue::getName, name)
|
.ne(Func.isNotEmpty(id), DncProcessCatalogue::getId, id));
|
/*
|
long count = count(((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, parentId)).eq((v0) -> {
|
return v0.getName();
|
}, name)).ne(Func.isNotEmpty(id), (v0) -> {
|
return v0.getId();
|
}, id));*/
|
if (count > 0) {
|
throw new ServiceException(MessageUtils.message("dnc.process.catalogue.name.already.exists", new Object[0]));
|
}
|
}
|
}
|
