package com.qianwen.smartman.modules.cps.service.impl;
|
|
import com.alibaba.excel.write.merge.AbstractMergeStrategy;
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import java.lang.invoke.SerializedLambda;
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.UUID;
|
import java.util.stream.Collectors;
|
import org.apache.commons.compress.utils.Lists;
|
import com.qianwen.smartman.common.cache.RegionCache;
|
import com.qianwen.smartman.common.constant.CommonConstant;
|
import com.qianwen.smartman.common.constant.CommonGroupConstant;
|
import com.qianwen.smartman.common.constant.ExcelConstant;
|
import com.qianwen.smartman.common.enums.CommonGroupTypeEnum;
|
import com.qianwen.smartman.common.utils.ExtraLambdaQueryWrapper;
|
import com.qianwen.smartman.common.utils.Lambda;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.smartman.common.utils.ValidatorUtils;
|
import com.qianwen.core.excel.util.ExcelUtil;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.mp.support.Condition;
|
import com.qianwen.core.oss.model.BladeFile;
|
import com.qianwen.core.secure.utils.AuthUtil;
|
import com.qianwen.core.tool.constant.BladeConstant;
|
import com.qianwen.core.tool.node.ForestNodeMerger;
|
import com.qianwen.core.tool.utils.CollectionUtil;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.cps.convert.CommonGroupConvert;
|
import com.qianwen.smartman.modules.cps.entity.CommonGroup;
|
import com.qianwen.smartman.modules.cps.entity.CommonGroupOfItem;
|
import com.qianwen.smartman.modules.cps.entity.CraftVersionLine;
|
import com.qianwen.smartman.modules.cps.entity.Workstation;
|
import com.qianwen.smartman.modules.cps.excel.CommonGroupImport;
|
import com.qianwen.smartman.modules.cps.mapper.CommonGroupMapper;
|
import com.qianwen.smartman.modules.cps.mapper.WorkstationMapper;
|
import com.qianwen.smartman.modules.cps.service.ICommonGroupOfItemService;
|
import com.qianwen.smartman.modules.cps.service.ICommonGroupService;
|
import com.qianwen.smartman.modules.cps.service.ICraftVersionLineService;
|
import com.qianwen.smartman.modules.cps.service.IWorkstationService;
|
import com.qianwen.smartman.modules.cps.utils.ThrowFun;
|
import com.qianwen.smartman.modules.cps.vo.CommonGroupFtpVO;
|
import com.qianwen.smartman.modules.cps.vo.CommonGroupTypeVO;
|
import com.qianwen.smartman.modules.cps.vo.CommonGroupVO;
|
import com.qianwen.smartman.modules.cps.vo.JimuTreeVO;
|
import com.qianwen.smartman.modules.cps.vo.MdcWorkStationGroupVO;
|
import com.qianwen.smartman.modules.cps.vo.WorkstationGroupVO;
|
import com.qianwen.smartman.modules.cps.vo.WorkstationInGroupVO;
|
import com.qianwen.smartman.modules.dnc.entity.DncWsRelationTd;
|
import com.qianwen.smartman.modules.dnc.enums.DncEnums;
|
import com.qianwen.smartman.modules.dnc.service.IDncWsRelationTdService;
|
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
|
import com.qianwen.smartman.modules.system.entity.Dict;
|
import com.qianwen.smartman.modules.system.entity.ParamBiz;
|
import com.qianwen.smartman.modules.system.service.IDictService;
|
import com.qianwen.smartman.modules.system.service.IParamBizService;
|
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 org.springframework.web.multipart.MultipartFile;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/CommonGroupServiceImpl.class */
|
public class CommonGroupServiceImpl extends ServiceImpl<CommonGroupMapper, CommonGroup> implements ICommonGroupService {
|
private static final String PARENT_ID = "parentId";
|
private static final String ROOT_NODE_CONFIGURE_ERROR = "The root node is not configured or configured incorrectly";
|
@Autowired
|
@Lazy
|
private IWorkstationService workstationService;
|
@Autowired
|
@Lazy
|
private ICommonGroupOfItemService commonGroupOfItemService;
|
@Autowired
|
private OssBuilder ossBuilder;
|
@Autowired
|
private IParamBizService paramService;
|
@Autowired
|
private IDncWsRelationTdService wsRelationTdService;
|
@Autowired
|
private IDictService dictService;
|
@Autowired
|
private ICraftVersionLineService lineService;
|
@Autowired
|
private WorkstationMapper workstationMapper;
|
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public Boolean changeStatus(List<Long> ids, Integer status) {
|
return update(Wrappers.<CommonGroup>lambdaUpdate()
|
.set(CommonGroup::getStatus, status)
|
.in(CommonGroup::getId, ids));
|
/*
|
return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
|
return v0.getStatus();
|
}, status)).in((v0) -> {
|
return v0.getId();
|
}, ids)));*/
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroup> getAllSubGroup(Long id, String groupType, Integer groupCategory) {
|
return this.baseMapper.getAllSubGroup(id, groupType, groupCategory);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroupVO> lazyList(Long parentId, String groupType, Integer groupCategory, Map<String, Object> param) {
|
if (Func.isEmpty(param.get(PARENT_ID)) && param.size() == 1) {
|
parentId = BladeConstant.TOP_PARENT_ID;
|
}
|
if (Func.isEmpty(param.get(PARENT_ID)) && param.size() > 1 && Func.toLong(parentId) == BladeConstant.TOP_PARENT_ID.longValue()) {
|
parentId = null;
|
}
|
return this.baseMapper.lazyList(AuthUtil.getTenantId(), parentId, groupType, groupCategory, param);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroupVO> tree(String tenantId, String groupType, Integer groupCategory) {
|
return ForestNodeMerger.merge(this.baseMapper.tree(tenantId, groupType, groupCategory));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroupVO> lazyTree(String tenantId, Long parentId) {
|
if (AuthUtil.isAdministrator()) {
|
tenantId = "";
|
}
|
return ForestNodeMerger.merge(this.baseMapper.lazyTree(tenantId, parentId));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public String getGroupIds(String tenantId, String groupNames, String groupType, Integer groupCategory) {
|
List<CommonGroup> commonList = this.baseMapper.selectList(
|
Wrappers.<CommonGroup>query().lambda()
|
.eq(CommonGroup::getTenantId, tenantId)
|
.in(CommonGroup::getName, Func.toStrList(groupNames)));
|
|
if (commonList != null && commonList.size() > 0) {
|
return (String) commonList.stream().map(group -> {
|
return Func.toStr(group.getId());
|
}).distinct().collect(Collectors.joining(","));
|
}
|
return null;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public String getGroupIdsByFuzzy(String tenantId, String groupNames, String groupType, Integer groupCategory) {
|
Wrapper wrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getTenantId();
|
}, tenantId)).eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory);
|
wrapper.and(wrapper2 -> {
|
List<String> names = Func.toStrList(groupNames);
|
names.forEach(name -> {
|
LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) wrapper2.like((v0) -> {
|
return v0.getName();
|
}, name)).or();
|
});
|
});
|
List<CommonGroup> groupList = this.baseMapper.selectList(wrapper);
|
if (groupList != null && groupList.size() > 0) {
|
return (String) groupList.stream().map(group -> {
|
return Func.toStr(group.getId());
|
}).distinct().collect(Collectors.joining(","));
|
}
|
return null;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<String> getGroupNames(String groupIds) {
|
return this.baseMapper.getGroupNames(Func.toLongArray(groupIds));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public boolean removeGroup(String ids) {
|
Long cnt = this.baseMapper.selectCount((Wrapper) Wrappers.query().lambda().in((v0) -> {
|
return v0.getParentId();
|
}, Func.toLongList(ids)));
|
if (cnt.longValue() > 0) {
|
throw new ServiceException(MessageUtils.message("cps.group.delete.child.node", new Object[0]));
|
}
|
return removeByIds(Func.toLongList(ids));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public CommonGroup insert(CommonGroup group) {
|
if (Func.isEmpty(group.getParentId())) {
|
group.setTenantId(AuthUtil.getTenantId());
|
group.setParentId(getRootNodeId(group.getGroupType(), group.getGroupCategory()));
|
}
|
String code = getNextChildCode(group.getParentId(), group.getGroupType(), group.getGroupCategory());
|
group.setCode(code);
|
if (Func.isEmpty(group.getSort())) {
|
group.setSort(Integer.valueOf(Integer.parseInt(code.substring(code.length() - 5))));
|
}
|
group.setIsDeleted(0);
|
if (CommonGroupTypeEnum.MACHINE.getName().equals(group.getGroupType())) {
|
group.setExtendId(UUID.randomUUID().toString());
|
}
|
validateGroup(group);
|
validateUnableGroup(group);
|
saveOrUpdate(group);
|
return group;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public CommonGroup update(CommonGroup group) {
|
validateGroup(group);
|
saveOrUpdate(group);
|
return group;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public void move(Long id, Long parentId, String groupType, Integer groupCategory) {
|
CommonGroup group = (CommonGroup) getById(id);
|
if (group.getParentId().equals(id)) {
|
return;
|
}
|
String oldCode = group.getCode();
|
List<CommonGroup> children = getGroupChildren(id, true, groupType, groupCategory);
|
group.setCode(getNextChildCode(parentId, groupType, groupCategory));
|
group.setParentId(parentId);
|
validateGroup(group);
|
children.forEach(g -> {
|
g.setCode(CommonGroup.appendCode(group.getCode(), CommonGroup.getRelativeCode(g.getCode(), oldCode)));
|
update(g);
|
});
|
update(group);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroup> getGroupChildren(Long parentId, boolean recursive, String groupType, Integer groupCategory) {
|
if (!recursive) {
|
return this.baseMapper.selectList((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getParentId();
|
}, parentId)).eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory));
|
}
|
if (null == parentId) {
|
return this.baseMapper.selectList((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory));
|
}
|
String codeOrDefault = getCodeOrDefault(parentId);
|
return this.baseMapper.selectList((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().likeRight((v0) -> {
|
return v0.getCode();
|
}, codeOrDefault)).ne((v0) -> {
|
return v0.getId();
|
}, parentId));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<CommonGroupVO> search(String groupName, Long parentId, String groupType, Integer groupCategory) {
|
Wrapper wrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory);
|
if (Func.isNotEmpty(groupName)) {
|
wrapper.like((v0) -> {
|
return v0.getName();
|
}, groupName);
|
}
|
if (Func.isNotEmpty(parentId) && parentId.longValue() > BladeConstant.TOP_PARENT_ID.longValue()) {
|
wrapper.eq((v0) -> {
|
return v0.getParentId();
|
}, parentId);
|
}
|
List<CommonGroup> groupList = this.baseMapper.selectList(wrapper);
|
return CommonGroupConvert.INSTANCE.convert(groupList);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<Long> getCommonGroupChildIds(String code, String groupType, Integer groupCategory) {
|
List<CommonGroup> childList = getCommonGroupChildList(code, groupType, groupCategory, null);
|
if (Func.isNotEmpty(childList)) {
|
List<Long> groupIdList = (List) childList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
return groupIdList;
|
}
|
return null;
|
}
|
|
private List<CommonGroup> getCommonGroupChildList(String code, String groupType, Integer groupCategory, Integer status) {
|
return this.baseMapper.selectList((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory)).eq(Func.isNotEmpty(status), (v0) -> {
|
return v0.getStatus();
|
}, status).likeRight(Func.isNotEmpty(code), (v0) -> {
|
return v0.getCode();
|
}, code));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public HashMap<String, Long> getCommonGroupNameMap(String groupType, Integer groupCategory) {
|
return getCommonGroupMap(null, groupType, groupCategory, null);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public HashMap<String, Long> getCommonGroupNameMap(String code, String groupType, Integer groupCategory) {
|
return getCommonGroupMap(code, groupType, groupCategory, null);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public HashMap<String, Long> getCommonGroupNameMap(String groupType, Integer groupCategory, Integer status) {
|
return getCommonGroupMap(null, groupType, groupCategory, status);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public HashMap<String, Long> getCommonGroupNameMap(String code, String groupType, Integer groupCategory, Integer status) {
|
return getCommonGroupMap(code, groupType, groupCategory, status);
|
}
|
|
private HashMap<String, Long> getCommonGroupMap(String code, String groupType, Integer groupCategory, Integer status) {
|
HashMap<String, Long> resultMap = new HashMap<>(16);
|
List<CommonGroup> childList = getCommonGroupChildList(code, groupType, groupCategory, status);
|
if (Func.isEmpty(childList)) {
|
return resultMap;
|
}
|
Map<Long, List<CommonGroup>> dataMap = (Map) childList.stream().collect(Collectors.groupingBy((v0) -> {
|
return v0.getParentId();
|
}));
|
List<CommonGroup> commonGroups = dataMap.get(BladeConstant.TOP_PARENT_ID);
|
if (Func.isEmpty(commonGroups)) {
|
return resultMap;
|
}
|
if (commonGroups.size() > 1) {
|
throw new IllegalArgumentException(ROOT_NODE_CONFIGURE_ERROR);
|
}
|
CommonGroup commonGroup = commonGroups.get(0);
|
Long id = commonGroup.getId();
|
String parentName = commonGroup.getName();
|
if (Func.isNotEmpty(code)) {
|
List<String> codeList = new ArrayList<>();
|
String[] codes = code.split("-");
|
for (int i = 0; i < codes.length; i++) {
|
codeList.add(code.substring(0, 5 * (i + 1)));
|
}
|
List<CommonGroup> parentList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory)).eq(Func.isNotEmpty(status), (v0) -> {
|
return v0.getStatus();
|
}, status).in((v0) -> {
|
return v0.getCode();
|
}, codeList));
|
if (Func.isNotEmpty(parentList)) {
|
id = (Long) parentList.stream().filter(x -> {
|
return x.getCode().equals(code);
|
}).map((v0) -> {
|
return v0.getId();
|
}).findFirst().orElse(id);
|
parentName = getParentName(codeList, parentList);
|
}
|
}
|
buildCommonGroupNameMap(id, parentName, dataMap, resultMap);
|
return resultMap;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public CommonGroup getRootNode(String groupType, Integer groupCategory) {
|
List<CommonGroup> commonGroupList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory)).eq((v0) -> {
|
return v0.getParentId();
|
}, BladeConstant.TOP_PARENT_ID));
|
if (Func.isEmpty(commonGroupList) || commonGroupList.size() > 1) {
|
throw new IllegalArgumentException(ROOT_NODE_CONFIGURE_ERROR);
|
}
|
return commonGroupList.get(0);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public Long getRootNodeId(String groupType, Integer groupCategory) {
|
return getRootNode(groupType, groupCategory).getId();
|
}
|
|
private String getParentName(List<String> codeList, List<CommonGroup> parentList) {
|
StringBuilder sb = new StringBuilder();
|
Map<String, String> map = (Map) parentList.stream().filter(x -> {
|
return !BladeConstant.TOP_PARENT_ID.equals(x.getParentId());
|
}).collect(Collectors.toMap((v0) -> {
|
return v0.getCode();
|
}, (v0) -> {
|
return v0.getName();
|
}));
|
for (String code : codeList) {
|
if (Func.isNotEmpty(map.get(code))) {
|
sb.append(map.get(code));
|
}
|
}
|
return sb.toString();
|
}
|
|
private void buildCommonGroupNameMap(Long parentId, String parentName, Map<Long, List<CommonGroup>> dataMap, HashMap<String, Long> resultMap) {
|
if (Func.isNotEmpty(parentName)) {
|
resultMap.put(parentName, parentId);
|
}
|
List<CommonGroup> commonGroupList = dataMap.get(parentId);
|
if (Func.isNotEmpty(commonGroupList)) {
|
for (int i = 0; i < commonGroupList.size(); i++) {
|
String prefix = Func.isEmpty(parentName) ? parentName : parentName + "-";
|
String name = prefix + commonGroupList.get(i).getName();
|
buildCommonGroupNameMap(commonGroupList.get(i).getId(), name, dataMap, resultMap);
|
}
|
}
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
@Transactional(rollbackFor = {Exception.class})
|
public BladeFile importCommonGroup(List<CommonGroupImport> data, CommonGroupTypeVO commonGroupTypeVO) {
|
if (Func.isEmpty(data)) {
|
throw new ServiceException(MessageUtils.message("excel.import.data.can.not.be.null", new Object[0]));
|
}
|
if (data.size() > 200) {
|
throw new ServiceException(MessageUtils.message("excel.import.size.failed", new Object[0]));
|
}
|
String rootName = getRootNode(commonGroupTypeVO.getGroupType(), commonGroupTypeVO.getGroupCategory()).getName();
|
Boolean flag = Boolean.TRUE;
|
for (CommonGroupImport commonGroupImport : data) {
|
importProcess(null, commonGroupImport.getName(), rootName, commonGroupTypeVO, commonGroupImport);
|
if (Func.isNotEmpty(commonGroupImport.getFailReason())) {
|
flag = Boolean.FALSE;
|
}
|
}
|
if (!flag.booleanValue()) {
|
MultipartFile multipartFile = ExcelUtil.exportFillTemplateToMultipartFile(ExcelConstant.DIRECTORY + "organizationFailTemplate" + ExcelConstant.SUFFIX, MessageUtils.message("excel.import.failed.report.name", new Object[0]) + ExcelConstant.SUFFIX, "部门信息表", (List) data.stream().filter(x -> {
|
return Func.isNotEmpty(x.getFailReason());
|
}).collect(Collectors.toList()), (Object) null, (AbstractMergeStrategy) null);
|
BladeFile bladeFile = this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
|
return bladeFile;
|
}
|
return null;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationGroupVO> listWorkstationGroup(String groupType, String groupCategory, String groupTag) {
|
List<CommonGroup> commonGroupList = list(Wrappers.lambdaQuery().eq(Func.isNotBlank(groupType), (v0) -> {
|
return v0.getGroupType();
|
}, groupType).eq(Func.isNotBlank(groupCategory), (v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory).eq(Func.isNotBlank(groupTag), (v0) -> {
|
return v0.getGroupTag();
|
}, groupTag));
|
List<WorkstationGroupVO> result = CommonGroupConvert.INSTANCE.convert1(commonGroupList);
|
if (CollectionUtil.isNotEmpty(result)) {
|
List<String> codeList = (List) result.stream().map((v0) -> {
|
return v0.getCode();
|
}).distinct().collect(Collectors.toList());
|
if (CollectionUtil.isNotEmpty(codeList)) {
|
List<CommonGroup> groupList = list((Wrapper) Wrappers.lambdaQuery().eq(Func.isNotBlank(groupType), (v0) -> {
|
return v0.getGroupType();
|
}, groupType).eq(Func.isNotBlank(groupCategory), (v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory).eq(Func.isNotBlank(groupTag), (v0) -> {
|
return v0.getGroupTag();
|
}, groupTag).in((v0) -> {
|
return v0.getCode();
|
}, codeList));
|
Map<String, String> map = (Map) groupList.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getCode();
|
}, (v0) -> {
|
return v0.getName();
|
}, v1, v2 -> {
|
return v1;
|
}));
|
result.forEach(i -> {
|
i.setPath(CommonGroup.appendName(i.getCode(), map));
|
});
|
}
|
}
|
return result;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationInGroupVO> groupWorkstationListType(CommonGroupTypeVO commonGroupTypeVO) {
|
List<CommonGroup> groupList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupTypeVO.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroupTypeVO.getGroupCategory())).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<Long> groupIds = (List) groupList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> itemList = this.commonGroupOfItemService.list(Wrappers.lambdaQuery().in(Func.isNotEmpty(groupIds), (v0) -> {
|
return v0.getGroupId();
|
}, groupIds));
|
List<Workstation> workstations = this.workstationService.listMachine(commonGroupTypeVO.getStatus(), commonGroupTypeVO.getKeyword());
|
List<WorkstationInGroupVO> list = (List) groupList.stream().filter(o -> {
|
return Func.isNotEmpty(o.getParentId());
|
}).map(o2 -> {
|
return WorkstationInGroupVO.builder().id(o2.getId()).parentId(o2.getParentId()).title(o2.getName()).code("").isWorkstation(Boolean.FALSE).isGroup(Boolean.TRUE).groupTag(o2.getGroupTag()).build();
|
}).collect(Collectors.toList());
|
list.addAll((Collection) workstations.stream().flatMap(o1 -> {
|
Long id = o1.getId();
|
return itemList.stream().filter(o22 -> {
|
Integer distinguish = commonGroupTypeVO.getDistinguish();
|
boolean result = id.equals(o22.getItemId());
|
if (Func.isNotEmpty(distinguish)) {
|
boolean equals = DncEnums.SupportCncRw.Support.getCode().equals(o1.getSupportCncRw());
|
return result && equals;
|
}
|
return result;
|
}).map(o23 -> {
|
return WorkstationInGroupVO.builder().id(id).parentId(o23.getGroupId()).title(o1.getName()).code(o1.getCode()).isWorkstation(Boolean.TRUE).supportCncRw(o1.getSupportCncRw()).isGroup(Boolean.FALSE).avatar(o1.getAvatar()).ftpCatalogue(o1.getFtpCatalogue()).build();
|
}).distinct();
|
}).collect(Collectors.toList()));
|
return list;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationInGroupVO> groupWorkstationListLazy(Long groupId) {
|
List<CommonGroup> commonGroupList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, groupId)).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<WorkstationInGroupVO> collect = (List) commonGroupList.stream().map(commonGroup -> {
|
return WorkstationInGroupVO.builder().parentId(groupId).isWorkstation(false).isGroup(true).code(commonGroup.getCode()).title(commonGroup.getName()).groupTag(commonGroup.getGroupTag()).id(commonGroup.getId()).build();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> commonGroupOfItemList = this.commonGroupOfItemService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupId();
|
}, groupId)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.WORKSTATION.getName()));
|
Map<Long, Long> workstationIdToGroupId = (Map) commonGroupOfItemList.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getItemId();
|
}, (v0) -> {
|
return v0.getGroupId();
|
}));
|
if (Func.isNotEmpty(commonGroupOfItemList)) {
|
List<Long> workstationIds = (List) commonGroupOfItemList.stream().map((v0) -> {
|
return v0.getItemId();
|
}).collect(Collectors.toList());
|
List<Workstation> workstations = (List) this.workstationService.listByIds(workstationIds).stream().filter(s -> {
|
return CommonConstant.ENABLE.equals(s.getStatus());
|
}).filter((v0) -> {
|
return Func.isNotEmpty(v0);
|
}).collect(Collectors.toList());
|
List<WorkstationInGroupVO> collect1 = (List) workstations.stream().map(workstation -> {
|
return WorkstationInGroupVO.builder().isWorkstation(true).isGroup(false).id(workstation.getId()).title(workstation.getName()).code(workstation.getName()).parentId((Long) workstationIdToGroupId.get(workstation.getId())).supportCncRw(workstation.getSupportCncRw()).build();
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(collect1)) {
|
collect.addAll(collect1);
|
}
|
}
|
return collect;
|
}
|
|
private List<WorkstationInGroupVO> groupWorkstationList(Long groupId) {
|
List<CommonGroup> commonGroupList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, groupId)).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<WorkstationInGroupVO> collect = Lists.newArrayList();
|
if (Func.isNotEmpty(commonGroupList)) {
|
List<Long> ids = (List) commonGroupList.stream().map((v0) -> {
|
return v0.getId();
|
}).distinct().collect(Collectors.toList());
|
List<CommonGroupOfItem> commonGroupOfItemList = this.commonGroupOfItemService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getGroupId();
|
}, ids)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.WORKSTATION.getName()));
|
Map<Long, Long> workstationIdToGroupId = (Map) commonGroupOfItemList.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getItemId();
|
}, (v0) -> {
|
return v0.getGroupId();
|
}));
|
if (Func.isNotEmpty(commonGroupOfItemList)) {
|
List<Long> workstationIds = (List) commonGroupOfItemList.stream().map((v0) -> {
|
return v0.getItemId();
|
}).collect(Collectors.toList());
|
List<Workstation> workstations = (List) this.workstationService.listByIds(workstationIds).stream().filter(s -> {
|
return CommonConstant.ENABLE.equals(s.getStatus());
|
}).filter((v0) -> {
|
return Func.isNotEmpty(v0);
|
}).collect(Collectors.toList());
|
List<WorkstationInGroupVO> collect1 = (List) workstations.stream().map(workstation -> {
|
return WorkstationInGroupVO.builder().isWorkstation(true).isGroup(false).id(workstation.getId()).title(workstation.getName()).code(workstation.getName()).parentId((Long) workstationIdToGroupId.get(workstation.getId())).supportCncRw(workstation.getSupportCncRw()).build();
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(collect1)) {
|
collect.addAll(collect1);
|
}
|
}
|
}
|
return collect;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationInGroupVO> groupFtpDirectoryListLazy(Long groupId) {
|
List<CommonGroup> commonGroupList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, groupId)).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<WorkstationInGroupVO> collect = (List) commonGroupList.stream().map(commonGroup -> {
|
return WorkstationInGroupVO.builder().parentId(groupId).isWorkstation(false).isGroup(true).code(commonGroup.getCode()).title(commonGroup.getName()).groupTag(commonGroup.getGroupTag()).id(commonGroup.getId()).build();
|
}).collect(Collectors.toList());
|
List<Long> bindingFtps = (List) this.wsRelationTdService.list().stream().map((v0) -> {
|
return v0.getWorkstationId();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> commonGroupOfItemList = this.commonGroupOfItemService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupId();
|
}, groupId)).eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.WORKSTATION.getName()));
|
Map<Long, Long> workstationIdToGroupId = (Map) commonGroupOfItemList.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getItemId();
|
}, (v0) -> {
|
return v0.getGroupId();
|
}));
|
if (Func.isNotEmpty(commonGroupOfItemList)) {
|
List<Long> workstationIds = (List) ((List) commonGroupOfItemList.stream().map((v0) -> {
|
return v0.getItemId();
|
}).collect(Collectors.toList())).stream().filter(item -> {
|
return !bindingFtps.contains(item);
|
}).collect(Collectors.toList());
|
List<Workstation> workstations = (List) this.workstationService.listByIds(workstationIds).stream().filter((v0) -> {
|
return Func.isNotEmpty(v0);
|
}).collect(Collectors.toList());
|
List<WorkstationInGroupVO> workstationInGroupVOList = (List) workstations.stream().map(workstation -> {
|
return WorkstationInGroupVO.builder().isWorkstation(true).isGroup(false).id(workstation.getId()).title(workstation.getName()).code(workstation.getName()).parentId((Long) workstationIdToGroupId.get(workstation.getId())).supportCncRw(workstation.getSupportCncRw()).build();
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(workstationInGroupVOList)) {
|
collect.addAll(workstationInGroupVOList);
|
}
|
}
|
return collect;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationInGroupVO> groupFtpDirectoryWorkstationList(CommonGroupFtpVO commonGroupFtpVO) {
|
List<CommonGroup> groupList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupFtpVO.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroupFtpVO.getGroupCategory())).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<Long> groupIds = (List) groupList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> itemList = this.commonGroupOfItemService.list((Wrapper) Wrappers.lambdaQuery().in(Func.isNotEmpty(groupIds), (v0) -> {
|
return v0.getGroupId();
|
}, groupIds).eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupFtpVO.getGroupType()));
|
List<Long> bindingFtps = (List) this.wsRelationTdService.list().stream().map((v0) -> {
|
return v0.getWorkstationId();
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(commonGroupFtpVO.getTransferDirectorId())) {
|
List<DncWsRelationTd> list = this.wsRelationTdService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getTransferDirectorId();
|
}, commonGroupFtpVO.getTransferDirectorId()));
|
if (Func.isNotEmpty(list)) {
|
List<Long> ftpRelationIds = (List) list.stream().map((v0) -> {
|
return v0.getWorkstationId();
|
}).collect(Collectors.toList());
|
if (Func.isNotEmpty(ftpRelationIds)) {
|
bindingFtps = (List) bindingFtps.stream().filter(s -> {
|
return !ftpRelationIds.contains(s);
|
}).collect(Collectors.toList());
|
}
|
}
|
}
|
List<Long> finalBindingFtps = bindingFtps;
|
List<Workstation> workstations = (List) this.workstationService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getStatus();
|
}, commonGroupFtpVO.getStatus() == null ? CommonConstant.ENABLE : commonGroupFtpVO.getStatus())).stream().filter(item -> {
|
return !finalBindingFtps.contains(item.getId());
|
}).collect(Collectors.toList());
|
List<WorkstationInGroupVO> list2 = (List) groupList.stream().filter(o -> {
|
return Func.isNotEmpty(o.getParentId());
|
}).map(o2 -> {
|
return WorkstationInGroupVO.builder().id(o2.getId()).parentId(o2.getParentId()).title(o2.getName()).code("").isWorkstation(Boolean.FALSE).isGroup(Boolean.TRUE).groupTag(o2.getGroupTag()).build();
|
}).collect(Collectors.toList());
|
list2.addAll((Collection) workstations.stream().flatMap(o1 -> {
|
Long id = o1.getId();
|
return itemList.stream().filter(o22 -> {
|
return id.equals(o22.getItemId());
|
}).map(o23 -> {
|
return WorkstationInGroupVO.builder().id(id).parentId(o23.getGroupId()).title(o1.getName()).code(o1.getCode()).isWorkstation(Boolean.TRUE).isGroup(Boolean.FALSE).calendarCode(o1.getCalendarCode()).build();
|
}).distinct();
|
}).collect(Collectors.toList()));
|
return list2;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<MdcWorkStationGroupVO> getMdcGroup() {
|
ParamBiz param = new ParamBiz();
|
param.setUserId(AuthUtil.getUserId());
|
param.setParamKey("mdc_chosen_groups");
|
ParamBiz detail = (ParamBiz) this.paramService.getOne(Condition.getQueryWrapper(param));
|
List<CommonGroup> groupList = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.WORKSTATION.getName()));
|
if (detail == null) {
|
return new ArrayList();
|
}
|
List<MdcWorkStationGroupVO> result = JSONArray.parseArray(detail.getParamValue(), MdcWorkStationGroupVO.class);
|
if (CollectionUtil.isEmpty(result)) {
|
return new ArrayList();
|
}
|
Set<Long> groupIdSet = (Set) groupList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toSet());
|
Iterator<MdcWorkStationGroupVO> ite = result.iterator();
|
while (ite.hasNext()) {
|
if (!groupIdSet.contains(ite.next().getGroupId())) {
|
ite.remove();
|
}
|
}
|
return result;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
@Transactional(rollbackFor = {Exception.class})
|
public Boolean deleteGroup(Long groupId) {
|
CommonGroup commonGroup = (CommonGroup) getOne((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getId();
|
}, groupId));
|
List<String> dictItems = getDictItems();
|
deleteCheckGroup(commonGroup);
|
verificationProductionLineCommonGroup(commonGroup);
|
validCraftVersionBing(groupId);
|
String groupTag = commonGroup.getGroupTag();
|
List<Long> groupIdList = (List) this.baseMapper.getAllSubGroup(groupId, commonGroup.getGroupType(), commonGroup.getGroupCategory()).stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> commonGroupOfItemList = this.commonGroupOfItemService.list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
|
return v0.getGroupId();
|
}, groupIdList));
|
if (Func.isBlank(groupTag)) {
|
CommonGroup rootNode = getDefaultGroup(commonGroup.getGroupType(), commonGroup.getGroupCategory());
|
String groupType = commonGroup.getGroupType();
|
if (Func.equals(groupType, CommonGroupConstant.NG_TYPE)) {
|
List<CommonGroup> list = list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getParentId();
|
}, groupId));
|
List<CommonGroupOfItem> commonGroupOfItemList2 = this.commonGroupOfItemService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupId();
|
}, groupId));
|
commonGroupOfItemList2.forEach(c -> {
|
c.setGroupId(rootNode.getParentId());
|
});
|
this.commonGroupOfItemService.updateBatchById(commonGroupOfItemList2);
|
list.forEach(item -> {
|
item.setParentId(rootNode.getParentId());
|
});
|
updateBatchById(list);
|
removeById(groupId);
|
return true;
|
}
|
commonGroupOfItemList.forEach(c2 -> {
|
c2.setGroupId(rootNode.getId());
|
});
|
this.commonGroupOfItemService.updateBatchById(commonGroupOfItemList);
|
removeById(groupId);
|
} else {
|
if (!dictItems.contains(groupTag)) {
|
CommonGroup rootNode2 = getDefaultGroup(commonGroup.getGroupType(), commonGroup.getGroupCategory());
|
commonGroupOfItemList.forEach(c3 -> {
|
c3.setGroupId(rootNode2.getId());
|
});
|
this.commonGroupOfItemService.updateBatchById(commonGroupOfItemList);
|
}
|
removeBatchByIds(groupIdList);
|
}
|
return true;
|
}
|
|
private void validCraftVersionBing(Long groupId) {
|
long count = this.lineService.count((Wrapper) Wrappers.lambdaQuery(CraftVersionLine.class).eq((v0) -> {
|
return v0.getGroupId();
|
}, groupId));
|
ThrowFun.isTrue(count > 0).throwMessage(MessageUtils.message("cps.common.group.line.bind.version", new Object[0]));
|
}
|
|
private void verificationProductionLineCommonGroup(CommonGroup commonGroup) {
|
boolean active = false;
|
List<String> dictItems = getDictItems();
|
String groupTag = commonGroup.getGroupTag();
|
if (dictItems.contains(groupTag)) {
|
List<WorkstationInGroupVO> workstationInGroups = groupWorkstationList(commonGroup.getId());
|
if (Func.isNotEmpty(workstationInGroups)) {
|
long count = workstationInGroups.stream().filter(s -> {
|
return Boolean.TRUE.equals(s.getIsWorkstation());
|
}).count();
|
if (count > 0) {
|
active = true;
|
}
|
}
|
if (active) {
|
throw new ServiceException(MessageUtils.message("cps.common.group.production.line.delete.fail", new Object[0]));
|
}
|
}
|
}
|
|
public void deleteCheckGroup(CommonGroup commonGroup) {
|
CommonGroup rootNode = getRootNode(commonGroup.getGroupType(), commonGroup.getGroupCategory());
|
CommonGroup defaultGroup = getDefaultGroup(commonGroup.getGroupType(), commonGroup.getGroupCategory());
|
if (rootNode.getId().equals(commonGroup.getId()) || defaultGroup.getId().equals(commonGroup.getId())) {
|
throw new ServiceException(MessageUtils.message("cps.common.group.can.not.delete.root.or.default.group", new Object[0]));
|
}
|
}
|
|
private List<String> getDictItems() {
|
List<String> list = Lists.newArrayList();
|
List<Dict> dictList = this.dictService.getList(CommonGroupConstant.PRODUCTION_LINE_DICT_KEY);
|
if (Func.isNotEmpty(dictList)) {
|
dictList.forEach(item -> {
|
list.add(item.getDictKey());
|
});
|
}
|
return list;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public CommonGroup getDefaultGroup(String groupType, Integer groupCategory) {
|
return (CommonGroup) getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory)).eq((v0) -> {
|
return v0.getCode();
|
}, CommonGroupConstant.DEFAULT_CODE)).eq((v0) -> {
|
return v0.getName();
|
}, CommonGroupConstant.WORKSTATION_TYPE.equals(groupType) ? CommonGroupConstant.DEFAULT_NAME : CommonGroupConstant.DEFAULT_GROUP_NAME));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<WorkstationInGroupVO> groupWorkstationList(CommonGroupTypeVO commonGroupTypeVO) {
|
List<CommonGroup> groupList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupTypeVO.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroupTypeVO.getGroupCategory())).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<Long> groupIds = (List) groupList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<CommonGroupOfItem> itemList = this.commonGroupOfItemService.list((Wrapper) Wrappers.lambdaQuery().in(Func.isNotEmpty(groupIds), (v0) -> {
|
return v0.getGroupId();
|
}, groupIds).eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupTypeVO.getGroupType()));
|
List<Workstation> workstations = this.workstationService.list(((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getStatus();
|
}, commonGroupTypeVO.getStatus() == null ? CommonConstant.ENABLE : commonGroupTypeVO.getStatus())).eq(Func.isNotEmpty(commonGroupTypeVO.getWorkType()), (v0) -> {
|
return v0.getDeviceType();
|
}, commonGroupTypeVO.getWorkType()).in(Func.isNotEmpty(commonGroupTypeVO.getWorkstationIdList()), (v0) -> {
|
return v0.getId();
|
}, commonGroupTypeVO.getWorkstationIdList()));
|
Map<Long, String> groupMap = (Map) groupList.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getName();
|
}));
|
List<WorkstationInGroupVO> list = (List) groupList.stream().filter(o -> {
|
return Func.isNotEmpty(o.getParentId());
|
}).map(o2 -> {
|
return WorkstationInGroupVO.builder().id(o2.getId()).parentId(o2.getParentId()).parentName((String) groupMap.get(o2.getParentId())).title(o2.getName()).code("").isWorkstation(Boolean.FALSE).isGroup(Boolean.TRUE).groupTag(o2.getGroupTag()).build();
|
}).collect(Collectors.toList());
|
list.addAll((Collection) workstations.stream().flatMap(o1 -> {
|
Long id = o1.getId();
|
return itemList.stream().filter(o22 -> {
|
return id.equals(o22.getItemId());
|
}).map(o23 -> {
|
return WorkstationInGroupVO.builder().id(id).parentId(o23.getGroupId()).parentName((String) groupMap.get(o23.getGroupId())).title(o1.getName()).code(o1.getCode()).isWorkstation(Boolean.TRUE).isGroup(Boolean.FALSE).calendarCode(o1.getCalendarCode()).build();
|
}).distinct();
|
}).collect(Collectors.toList()));
|
return list;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public Map<Long, Set<Long>> groupWorkstationMap(List<String> groupIds) {
|
List<CommonGroupOfItem> groupOfItems = this.commonGroupOfItemService.list(Wrappers.lambdaQuery().in(Func.isNotEmpty(groupIds), (v0) -> {
|
return v0.getGroupId();
|
}, groupIds));
|
return (Map) groupOfItems.stream().collect(Collectors.groupingBy((v0) -> {
|
return v0.getGroupId();
|
}, Collectors.mapping((v0) -> {
|
return v0.getItemId();
|
}, Collectors.toSet())));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICommonGroupService
|
public List<JimuTreeVO> groupWorkstationListJimu(String pid) {
|
List<JimuTreeVO> result = new ArrayList<>();
|
if (Func.isEmpty(pid)) {
|
pid = String.valueOf(CommonGroupConstant.ROOT);
|
}
|
List<CommonGroup> groupList = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, CommonGroupTypeEnum.WORKSTATION.getName())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, CommonGroupConstant.DEFAULT_CATEGORY)).eq((v0) -> {
|
return v0.getParentId();
|
}, pid)).orderByAsc((v0) -> {
|
return v0.getSort();
|
}));
|
List<Workstation> workstationList = this.workstationMapper.listWorkstationDataByGroup(pid);
|
String finalPid = pid;
|
if (Func.isNotEmpty(groupList)) {
|
groupList.forEach(o -> {
|
result.add(JimuTreeVO.builder().id(String.valueOf(o.getId())).pid(finalPid).title(o.getName()).value(String.valueOf(o.getId())).disabled(Boolean.TRUE.booleanValue()).build());
|
});
|
}
|
if (Func.isNotEmpty(workstationList)) {
|
workstationList.forEach(o2 -> {
|
result.add(JimuTreeVO.builder().id(String.valueOf(o2.getId())).pid(finalPid).title(o2.getName()).value(String.valueOf(o2.getId())).disabled(Boolean.FALSE.booleanValue()).build());
|
});
|
}
|
return result;
|
}
|
|
private void importProcess(Long parentId, String names, String rootName, CommonGroupTypeVO commonGroupTypeVO, CommonGroupImport excel) {
|
String parent = names.split("-")[0].trim();
|
String child = names.substring(parent.length());
|
names.split("-");
|
if (Func.isEmpty(excel.getName())) {
|
excel.setFailReason(MessageUtils.message("cps.organization.name.can.not.be.null", new Object[0]));
|
} else if (Func.isEmpty(parentId) && !rootName.equals(parent)) {
|
excel.setFailReason(MessageUtils.message("cps.organization.name.import.failed", new Object[0]));
|
} else if (ValidatorUtils.checkContextLength(parent)) {
|
excel.setFailReason(MessageUtils.message("cps.organization.name.can.not.exceed", new Object[0]));
|
} else if (getOrCreateIdUnable(parentId, parent, commonGroupTypeVO)) {
|
excel.setFailReason(MessageUtils.message("cps.organization.already.exist.stop.status", new Object[0]));
|
} else {
|
if (checkName(names).booleanValue()) {
|
excel.setFailReason(MessageUtils.message("cps.organization.already.exist", new Object[0]));
|
}
|
Long id = getOrCreateId(parentId, parent, commonGroupTypeVO);
|
if (Func.isNotBlank(child)) {
|
importProcess(id, child.substring(1).trim(), rootName, commonGroupTypeVO, excel);
|
}
|
}
|
}
|
|
public Boolean checkName(String names) {
|
HashMap<String, Long> commonGroupNameMap = getCommonGroupNameMap(CommonGroupTypeEnum.ORGANIZATION.getName(), 1);
|
return Boolean.valueOf(commonGroupNameMap.containsKey(names));
|
}
|
|
private boolean getOrCreateIdUnable(Long parentId, String name, CommonGroupTypeVO commonGroupTypeVO) {
|
CommonGroup commonGroup = (CommonGroup) getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupTypeVO.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroupTypeVO.getGroupCategory())).eq((v0) -> {
|
return v0.getParentId();
|
}, Func.isEmpty(parentId) ? BladeConstant.TOP_PARENT_ID : parentId)).eq((v0) -> {
|
return v0.getStatus();
|
}, CommonConstant.DEACTIVATE)).eq((v0) -> {
|
return v0.getName();
|
}, name));
|
if (commonGroup != null) {
|
return Boolean.TRUE.booleanValue();
|
}
|
return Boolean.FALSE.booleanValue();
|
}
|
|
private Long getOrCreateId(Long parentId, String name, CommonGroupTypeVO commonGroupTypeVO) {
|
CommonGroup commonGroup = (CommonGroup) getOne((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroupTypeVO.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroupTypeVO.getGroupCategory())).eq((v0) -> {
|
return v0.getParentId();
|
}, Func.isEmpty(parentId) ? BladeConstant.TOP_PARENT_ID : parentId)).eq((v0) -> {
|
return v0.getStatus();
|
}, CommonConstant.ENABLE)).eq((v0) -> {
|
return v0.getName();
|
}, name));
|
if (Func.isNotEmpty(commonGroup)) {
|
return commonGroup.getId();
|
}
|
String code = getNextChildCode(parentId, commonGroupTypeVO.getGroupType(), commonGroupTypeVO.getGroupCategory());
|
CommonGroup commonGroup2 = CommonGroup.builder().groupType(commonGroupTypeVO.getGroupType()).groupCategory(commonGroupTypeVO.getGroupCategory()).parentId(parentId).code(code).name(name).fullName(name).sort(Integer.valueOf(Integer.parseInt(code.substring(code.length() - 5)))).remark("批量导入").isDeleted(0).build();
|
save(commonGroup2);
|
return commonGroup2.getId();
|
}
|
|
protected void validateGroup(CommonGroup commonGroup) {
|
Long pId = Long.valueOf(Func.isEmpty(commonGroup.getParentId()) ? 0L : commonGroup.getParentId().longValue());
|
Long id = Long.valueOf(Func.isEmpty(commonGroup.getId()) ? 0L : commonGroup.getId().longValue());
|
List<CommonGroup> siblings = this.baseMapper.selectList((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroup.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroup.getGroupCategory())).eq((v0) -> {
|
return v0.getParentId();
|
}, pId)).eq((v0) -> {
|
return v0.getStatus();
|
}, CommonConstant.ENABLE)).ne((v0) -> {
|
return v0.getId();
|
}, id));
|
if (siblings.stream().anyMatch(g -> {
|
return g.getName().equals(commonGroup.getName());
|
})) {
|
throw new ServiceException(MessageUtils.message("cps.group.exist.same.name.group", new Object[0]));
|
}
|
if (commonGroup.getParentId().longValue() > 0 && Func.toLong(commonGroup.getParentId()) == Func.toLong(commonGroup.getId())) {
|
throw new ServiceException(MessageUtils.message("cps.group.parent.can.not.choose.self", new Object[0]));
|
}
|
}
|
|
protected void validateUnableGroup(CommonGroup commonGroup) {
|
Long pId = Long.valueOf(Func.isEmpty(commonGroup.getParentId()) ? 0L : commonGroup.getParentId().longValue());
|
Long id = Long.valueOf(Func.isEmpty(commonGroup.getId()) ? 0L : commonGroup.getId().longValue());
|
List<CommonGroup> siblings = this.baseMapper.selectList((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getGroupType();
|
}, commonGroup.getGroupType())).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, commonGroup.getGroupCategory())).eq((v0) -> {
|
return v0.getParentId();
|
}, pId)).eq((v0) -> {
|
return v0.getStatus();
|
}, CommonConstant.DEACTIVATE)).ne((v0) -> {
|
return v0.getId();
|
}, id));
|
if (siblings.stream().anyMatch(g -> {
|
return g.getName().equals(commonGroup.getName());
|
})) {
|
throw new ServiceException(MessageUtils.message("cps.organization.already.exist.stop.status", new Object[0]));
|
}
|
}
|
|
public String getNextChildCode(Long parentId, String groupType, Integer groupCategory) {
|
CommonGroup lastChildOrNull = getLastChildOrNull(parentId, groupType, groupCategory);
|
if (null != lastChildOrNull) {
|
return CommonGroup.calculateNextCode(lastChildOrNull.getCode());
|
}
|
String parentCode = parentId != null ? getCodeOrDefault(parentId) : null;
|
return CommonGroup.appendCode(parentCode, CommonGroup.createCode(1));
|
}
|
|
public String getCodeOrDefault(Long id) {
|
CommonGroup commonGroup = (CommonGroup) this.baseMapper.selectById(id);
|
if (commonGroup == null) {
|
return null;
|
}
|
return commonGroup.getCode();
|
}
|
|
public CommonGroup getLastChildOrNull(Long parentId, String groupType, Integer groupCategory) {
|
return (CommonGroup) this.baseMapper.selectOne(((ExtraLambdaQueryWrapper) ((ExtraLambdaQueryWrapper) ((ExtraLambdaQueryWrapper) ((ExtraLambdaQueryWrapper) ((ExtraLambdaQueryWrapper) Lambda.create().eq((v0) -> {
|
return v0.getParentId();
|
}, parentId)).eq((v0) -> {
|
return v0.getGroupType();
|
}, groupType)).eq((v0) -> {
|
return v0.getGroupCategory();
|
}, groupCategory)).eq((v0) -> {
|
return v0.getStatus();
|
}, CommonConstant.ENABLE)).orderByDesc((v0) -> {
|
return v0.getCode();
|
})).limit(1));
|
}
|
}
|
