package com.qianwen.smartman.modules.system.service.impl; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.qianwen.core.cache.utils.CacheUtil; import com.qianwen.core.log.exception.ServiceException; import com.qianwen.core.mp.support.Condition; import com.qianwen.core.mp.support.Query; 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.cache.DictCache; import com.qianwen.smartman.common.constant.ExtCacheConstant; import com.qianwen.smartman.modules.system.entity.Dict; import com.qianwen.smartman.modules.system.mapper.DictMapper; import com.qianwen.smartman.modules.system.service.IDictService; import com.qianwen.smartman.modules.system.vo.DictVO; import com.qianwen.smartman.modules.system.wrapper.DictWrapper; @Service public class DictServiceImpl extends ServiceImpl implements IDictService { @Override // org.springblade.modules.system.service.IDictService public IPage selectDictPage(IPage page, DictVO dict) { return page.setRecords(this.baseMapper.selectDictPage(page, dict)); } @Override // org.springblade.modules.system.service.IDictService public List tree() { return ForestNodeMerger.merge(this.baseMapper.tree()); } @Override // org.springblade.modules.system.service.IDictService public List parentTree() { return ForestNodeMerger.merge(this.baseMapper.parentTree()); } @Override // org.springblade.modules.system.service.IDictService public String getValue(String code, String dictKey) { return Func.toStr(this.baseMapper.getValue(code, dictKey), ""); } @Override // org.springblade.modules.system.service.IDictService public List getList(String code) { return this.baseMapper.getList(code); } @Override // org.springblade.modules.system.service.IDictService public boolean submit(Dict dict) { LambdaQueryWrapper lqw = Wrappers.query().lambda().eq(Dict::getCode, dict.getCode()).eq(Dict::getDictKey, dict.getDictKey()); Long cnt = this.baseMapper.selectCount(Func.isEmpty(dict.getId()) ? lqw : lqw.notIn(Dict::getId, new Object[] { dict.getId() })); /* Wrapper wrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> { return v0.getCode(); }, dict.getCode())).eq((v0) -> { return v0.getDictKey(); }, dict.getDictKey()); Long cnt = ((DictMapper) this.baseMapper).selectCount(Func.isEmpty(dict.getId()) ? wrapper : (Wrapper) wrapper.notIn((v0) -> { return v0.getId(); }, new Object[]{dict.getId()}));*/ if (cnt.longValue() > 0) { throw new ServiceException("当前字典键值已存在!"); } if (Func.isNotEmpty(dict.getId()) && dict.getParentId().longValue() == BladeConstant.TOP_PARENT_ID.longValue()) { Dict parent = DictCache.getById(dict.getId()); update(Wrappers.update().lambda().set(Dict::getCode, dict.getCode()).eq(Dict::getCode, parent.getCode()).ne(Dict::getParentId, BladeConstant.TOP_PARENT_ID)); /* update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.update().lambda().set((v0) -> { return v0.getCode(); }, dict.getCode())).eq((v0) -> { return v0.getCode(); }, parent.getCode())).ne((v0) -> { return v0.getParentId(); }, BladeConstant.TOP_PARENT_ID));*/ } if (Func.isEmpty(dict.getParentId())) { dict.setParentId(BladeConstant.TOP_PARENT_ID); } dict.setIsDeleted(0); CacheUtil.clear("blade:dict", ExtCacheConstant.TENANT_MODE); return saveOrUpdate(dict); } @Override // org.springblade.modules.system.service.IDictService public boolean removeDict(String ids) { Long cnt = this.baseMapper.selectCount(Wrappers.query().lambda().in(Dict::getParentId, Func.toLongList(ids))); /* Long cnt = ((DictMapper) this.baseMapper).selectCount((Wrapper) Wrappers.query().lambda().in((v0) -> { return v0.getParentId(); }, Func.toLongList(ids)));*/ if (cnt.longValue() > 0) { throw new ServiceException("请先删除子节点!"); } return removeByIds(Func.toLongList(ids)); } @Override // org.springblade.modules.system.service.IDictService public IPage parentList(Map dict, Query query) { IPage page = page(Condition.getPage(query), Condition.getQueryWrapper(dict, Dict.class).lambda().eq(Dict::getParentId, BladeConstant.TOP_PARENT_ID).orderByAsc(Dict::getSort)); /* IPage page = page(Condition.getPage(query), (Wrapper) ((LambdaQueryWrapper) Condition.getQueryWrapper(dict, Dict.class).lambda().eq((v0) -> { return v0.getParentId(); }, BladeConstant.TOP_PARENT_ID)).orderByAsc((v0) -> { return v0.getSort(); }));*/ return DictWrapper.build().pageVO(page); } @Override // org.springblade.modules.system.service.IDictService public List childList(Map dict, Long parentId) { if (parentId.longValue() < 0) { return new ArrayList<>(); } dict.remove("parentId"); Dict parentDict = DictCache.getById(parentId); List list = list(Condition.getQueryWrapper(dict, Dict.class).lambda().ne(Dict::getId, parentId).eq(Dict::getCode, parentDict.getCode()).orderByAsc(Dict::getSort)); /* List list = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Condition.getQueryWrapper(dict, Dict.class).lambda().ne((v0) -> { return v0.getId(); }, parentId)).eq((v0) -> { return v0.getCode(); }, parentDict.getCode())).orderByAsc((v0) -> { return v0.getSort(); }));*/ return DictWrapper.build().listNodeVO(list); } }