jinpengyong
2023-12-01 ac832618393aca09f81d6bd04117e0cdb32301c3
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package com.moral.api.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.moral.api.entity.SysDictData;
import com.moral.api.entity.SysDictType;
import com.moral.api.mapper.SysDictDataMapper;
import com.moral.api.mapper.SysDictTypeMapper;
import com.moral.api.service.SysDictDataService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.constant.RedisConstants;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
 
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
 
/**
 * <p>
 * 字典表 服务实现类
 * </p>
 *
 * @author moral
 * @since 2021-03-09
 */
@Service
public class SysDictDataServiceImpl extends ServiceImpl<SysDictDataMapper, SysDictData> implements SysDictDataService {
 
    @Autowired
    private SysDictDataMapper sysDictDataMapper;
 
    @Autowired
    private SysDictTypeMapper sysDictTypeMapper;
 
    @Autowired
    private RedisTemplate redisTemplate;
 
    @Override
    public Map<String, Object> getSysDictDataByDictType(String type) {
        Map<String, Object> result = new HashMap<>();
        //先从redis获取
        Map<String, Object> sysDict = (Map<String, Object>) redisTemplate.opsForValue().get(RedisConstants.DICT_DATA_KEY);
        List<SysDictData> dictData = (List<SysDictData>) sysDict.get(type);
        for (SysDictData dictDatum : dictData) {
            result.put(dictDatum.getDataKey(), dictDatum.getDataValue());
        }
 
        if (!ObjectUtils.isEmpty(result)) {
            return result;
        }
 
        //根据字典类型名字获取字典类型id
        QueryWrapper<SysDictType> sysDictTypeQueryWrapper = new QueryWrapper<>();
        sysDictTypeQueryWrapper.select("id").eq("name", type);
        SysDictType sysDictType = sysDictTypeMapper.selectOne(sysDictTypeQueryWrapper);
 
        //根据字典类型id获取字典数据详情
        QueryWrapper<SysDictData> sysDictDataQueryWrapper = new QueryWrapper<>();
        sysDictDataQueryWrapper.select("dataKey", "dataValue").eq("dict_type_id", sysDictType.getId());
        List<SysDictData> sysDictData = sysDictDataMapper.selectList(sysDictDataQueryWrapper);
 
        return sysDictData.stream().collect(Collectors.toMap(SysDictData::getDataKey, SysDictData::getDataValue, (a, b) -> b));
    }
}