| | |
|---|
| | | package com.ruoyi.system.service.impl; |
|---|
| | | |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.util.ObjectUtil; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|---|
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|---|
| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | |
|---|
| | | import java.util.Arrays; |
|---|
| | | import java.util.Collection; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 字典 业务层处理 |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public List<SysDictData> selectDictDataByType(String dictType) { |
|---|
| | | List<SysDictData> dictDatas = RedisUtils.getCacheObject(getCacheKey(dictType)); |
|---|
| | | if (StringUtils.isNotEmpty(dictDatas)) { |
|---|
| | | if (CollUtil.isNotEmpty(dictDatas)) { |
|---|
| | | return dictDatas; |
|---|
| | | } |
|---|
| | | dictDatas = dictDataMapper.selectDictDataByType(dictType); |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void loadingDictCache() { |
|---|
| | | List<SysDictType> dictTypeList = baseMapper.selectList(); |
|---|
| | | for (SysDictType dictType : dictTypeList) { |
|---|
| | | List<SysDictData> dictDatas = dictDataMapper.selectDictDataByType(dictType.getDictType()); |
|---|
| | | RedisUtils.setCacheObject(getCacheKey(dictType.getDictType()), dictDatas); |
|---|
| | | } |
|---|
| | | List<SysDictData> dictDataList = dictDataMapper.selectList( |
|---|
| | | new LambdaQueryWrapper<SysDictData>().eq(SysDictData::getStatus, "0")); |
|---|
| | | Map<String, List<SysDictData>> dictDataMap = dictDataList.stream().collect(Collectors.groupingBy(SysDictData::getDictType)); |
|---|
| | | dictDataMap.forEach((k,v) -> { |
|---|
| | | String dictKey = getCacheKey(k); |
|---|
| | | List<SysDictData> dictList = v.stream() |
|---|
| | | .sorted(Comparator.comparing(SysDictData::getDictSort)) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | RedisUtils.setCacheObject(dictKey, dictList); |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public String checkDictTypeUnique(SysDictType dict) { |
|---|
| | | Long dictId = StringUtils.isNull(dict.getDictId()) ? -1L : dict.getDictId(); |
|---|
| | | Long dictId = ObjectUtil.isNull(dict.getDictId()) ? -1L : dict.getDictId(); |
|---|
| | | long count = baseMapper.selectCount(new LambdaQueryWrapper<SysDictType>() |
|---|
| | | .eq(SysDictType::getDictType, dict.getDictType()) |
|---|
| | | .ne(SysDictType::getDictId, dictId)); |
|---|
