1. 完成字典类型的迁移

2. 开始字典数据的迁移

src/main/java/cn/iocoder/dashboard/modules/system/service/dict/SysDictDataService.java

@@ -1,5 +1,9 @@
 package cn.iocoder.dashboard.modules.system.service.dict;
 
+import cn.iocoder.dashboard.common.pojo.PageResult;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataCreateReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataPageReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataUpdateReqVO;
 import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictDataDO;
 
 import java.util.List;
@@ -13,4 +17,50 @@ public interface SysDictDataService {
 
     List<SysDictDataDO> listDictDatas();
 
+    /**
+     * 获得字典数据分页列表
+     *
+     * @param reqVO 分页请求
+     * @return 字典数据分页列表
+     */
+    PageResult<SysDictDataDO> pageDictDatas(SysDictDataPageReqVO reqVO);
+
+    /**
+     * 获得字典数据详情
+     *
+     * @param id 字典数据编号
+     * @return 字典数据
+     */
+    SysDictDataDO getDictData(Long id);
+
+    /**
+     * 创建字典数据
+     *
+     * @param reqVO 字典数据信息
+     * @return 字典数据编号
+     */
+    Long createDictData(SysDictDataCreateReqVO reqVO);
+
+    /**
+     * 更新字典数据
+     *
+     * @param reqVO 字典数据信息
+     */
+    void updateDictData(SysDictDataUpdateReqVO reqVO);
+
+    /**
+     * 删除字典数据
+     *
+     * @param id 字典数据编号
+     */
+    void deleteDictData(Long id);
+
+    /**
+     * 获得指定字典类型的数据数量
+     *
+     * @param dictType 字典类型
+     * @return 数据数量
+     */
+    int countByDictType(String dictType);
+
 }

src/main/java/cn/iocoder/dashboard/modules/system/service/dict/SysDictTypeService.java

@@ -3,7 +3,7 @@ package cn.iocoder.dashboard.modules.system.service.dict;
 import cn.iocoder.dashboard.common.pojo.PageResult;
 import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypeCreateReqVO;
 import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypePageReqVO;
-import cn.iocoder.dashboard.modules.system.controller.user.vo.user.SysUserUpdateReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypeUpdateReqVO;
 import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictTypeDO;
 
 /**
@@ -13,14 +13,50 @@ import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictType
  */
 public interface SysDictTypeService {
 
+    /**
+     * 获得字典类型分页列表
+     *
+     * @param reqVO 分页请求
+     * @return 字典类型分页列表
+     */
     PageResult<SysDictTypeDO> pageDictTypes(SysDictTypePageReqVO reqVO);
 
+    /**
+     * 获得字典类型详情
+     *
+     * @param id 字典类型编号
+     * @return 字典类型
+     */
     SysDictTypeDO getDictType(Long id);
 
+    /**
+     * 获得字典类型详情
+     *
+     * @param type 字典类型
+     * @return 字典类型详情
+     */
+    SysDictTypeDO getDictType(String type);
+
+    /**
+     * 创建字典类型
+     *
+     * @param reqVO 字典类型信息
+     * @return 字典类型编号
+     */
     Long createDictType(SysDictTypeCreateReqVO reqVO);
 
-    void updateDictType(SysUserUpdateReqVO reqVO);
+    /**
+     * 更新字典类型
+     *
+     * @param reqVO 字典类型信息
+     */
+    void updateDictType(SysDictTypeUpdateReqVO reqVO);
 
+    /**
+     * 删除字典类型
+     *
+     * @param id 字典类型编号
+     */
     void deleteDictType(Long id);
 
 }

src/main/java/cn/iocoder/dashboard/modules/system/service/dict/impl/SysDictDataServiceImpl.java

@@ -1,14 +1,25 @@
 package cn.iocoder.dashboard.modules.system.service.dict.impl;
 
+import cn.iocoder.dashboard.common.enums.CommonStatusEnum;
+import cn.iocoder.dashboard.common.exception.util.ServiceExceptionUtil;
+import cn.iocoder.dashboard.common.pojo.PageResult;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataCreateReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataPageReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.data.SysDictDataUpdateReqVO;
+import cn.iocoder.dashboard.modules.system.convert.dict.SysDictDataConvert;
 import cn.iocoder.dashboard.modules.system.dal.mysql.dao.dict.SysDictDataMapper;
 import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictDataDO;
+import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictTypeDO;
 import cn.iocoder.dashboard.modules.system.service.dict.SysDictDataService;
+import cn.iocoder.dashboard.modules.system.service.dict.SysDictTypeService;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.util.Comparator;
 import java.util.List;
 
+import static cn.iocoder.dashboard.modules.system.enums.SysErrorCodeConstants.*;
+
 /**
  * 字典数据 Service 实现类
  *
@@ -21,14 +32,102 @@ public class SysDictDataServiceImpl implements SysDictDataService {
             .comparing(SysDictDataDO::getDictType)
             .thenComparingInt(SysDictDataDO::getSort);
 
+    @Resource
+    private SysDictTypeService dictTypeService;
+
     @Resource
     private SysDictDataMapper dictDataMapper;
 
     @Override
     public List<SysDictDataDO> listDictDatas() {
-        List<SysDictDataDO> list = dictDataMapper.selectList(null);
+        List<SysDictDataDO> list = dictDataMapper.selectList();
         list.sort(COMPARATOR_TYPE_AND_SORT);
         return list;
     }
 
+    @Override
+    public PageResult<SysDictDataDO> pageDictDatas(SysDictDataPageReqVO reqVO) {
+        return SysDictDataConvert.INSTANCE.convertPage02(dictDataMapper.selectList(reqVO));
+    }
+
+    @Override
+    public SysDictDataDO getDictData(Long id) {
+        return dictDataMapper.selectById(id);
+    }
+
+    @Override
+    public Long createDictData(SysDictDataCreateReqVO reqVO) {
+        // 校验正确性
+        this.checkCreateOrUpdate(null, reqVO.getLabel(), reqVO.getDictType());
+        // 插入字典类型
+        SysDictDataDO dictData = SysDictDataConvert.INSTANCE.convert(reqVO);
+        dictDataMapper.insert(dictData);
+        return dictData.getId();
+    }
+
+    @Override
+    public void updateDictData(SysDictDataUpdateReqVO reqVO) {
+        // 校验正确性
+        this.checkCreateOrUpdate(reqVO.getId(), reqVO.getLabel(), reqVO.getDictType());
+        // 更新字典类型
+        SysDictDataDO updateObj = SysDictDataConvert.INSTANCE.convert(reqVO);
+        dictDataMapper.updateById(updateObj);
+    }
+
+    @Override
+    public void deleteDictData(Long id) {
+        // 校验是否存在
+        this.checkDictDataExists(id);
+        // 删除字典数据
+        dictDataMapper.deleteById(id);
+    }
+
+    @Override
+    public int countByDictType(String dictType) {
+        return dictDataMapper.selectCountByDictType(dictType);
+    }
+
+    private void checkCreateOrUpdate(Long id, String label, String dictType) {
+        // 校验自己存在
+        checkDictDataExists(id);
+        // 校验字典数据的值的唯一性
+        checkDictDataValueUnique(id, label);
+        // 校验字典类型有效
+        checkDictTypeValid(dictType);
+    }
+
+    private void checkDictDataValueUnique(Long id, String label) {
+        SysDictDataDO dictData = dictDataMapper.selectByLabel(label);
+        if (dictData == null) {
+            return;
+        }
+        // 如果 id 为空，说明不用比较是否为相同 id 的字典数据
+        if (id == null) {
+            throw ServiceExceptionUtil.exception(DICT_DATA_VALUE_DUPLICATE);
+        }
+        if (!dictData.getId().equals(id)) {
+            throw ServiceExceptionUtil.exception(DICT_DATA_VALUE_DUPLICATE);
+        }
+    }
+
+    private void checkDictDataExists(Long id) {
+        if (id == null) {
+            return;
+        }
+        SysDictDataDO dictData = dictDataMapper.selectById(id);
+        if (dictData == null) {
+            throw ServiceExceptionUtil.exception(DICT_DATA_NOT_FOUND);
+        }
+    }
+
+    private void checkDictTypeValid(String type) {
+        SysDictTypeDO dictType = dictTypeService.getDictType(type);
+        if (dictType == null) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_NOT_FOUND);
+        }
+        if (!CommonStatusEnum.ENABLE.getStatus().equals(dictType.getStatus())) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_NOT_ENABLE);
+        }
+    }
+
 }

src/main/java/cn/iocoder/dashboard/modules/system/service/dict/impl/SysDictTypeServiceImpl.java

@@ -0,0 +1,137 @@
+package cn.iocoder.dashboard.modules.system.service.dict.impl;
+
+import cn.iocoder.dashboard.common.exception.util.ServiceExceptionUtil;
+import cn.iocoder.dashboard.common.pojo.PageResult;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypeCreateReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypePageReqVO;
+import cn.iocoder.dashboard.modules.system.controller.dict.vo.type.SysDictTypeUpdateReqVO;
+import cn.iocoder.dashboard.modules.system.convert.dict.SysDictTypeConvert;
+import cn.iocoder.dashboard.modules.system.dal.mysql.dao.dict.SysDictTypeMapper;
+import cn.iocoder.dashboard.modules.system.dal.mysql.dataobject.dict.SysDictTypeDO;
+import cn.iocoder.dashboard.modules.system.service.dict.SysDictDataService;
+import cn.iocoder.dashboard.modules.system.service.dict.SysDictTypeService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+import static cn.iocoder.dashboard.modules.system.enums.SysErrorCodeConstants.*;
+
+/**
+ * 字典类型 Service 实现类
+ *
+ * @author 芋道源码
+ */
+@Service
+public class SysDictTypeServiceImpl implements SysDictTypeService {
+
+    @Resource
+    private SysDictTypeServiceImpl self;
+    @Resource
+    private SysDictDataService dictDataService;
+
+    @Resource
+    private SysDictTypeMapper dictTypeMapper;
+
+    @Override
+    public PageResult<SysDictTypeDO> pageDictTypes(SysDictTypePageReqVO reqVO) {
+        return SysDictTypeConvert.INSTANCE.convertPage02(dictTypeMapper.selectList(reqVO));
+    }
+
+    @Override
+    public SysDictTypeDO getDictType(Long id) {
+        return dictTypeMapper.selectById(id);
+    }
+
+    @Override
+    public SysDictTypeDO getDictType(String type) {
+        return dictTypeMapper.selectByType(type);
+    }
+
+    @Override
+    public Long createDictType(SysDictTypeCreateReqVO reqVO) {
+        // 校验正确性
+        this.checkCreateOrUpdate(null, reqVO.getName(), reqVO.getType());
+        // 插入字典类型
+        SysDictTypeDO dictType = SysDictTypeConvert.INSTANCE.convert(reqVO);
+        dictTypeMapper.insert(dictType);
+        return dictType.getId();
+    }
+
+    @Override
+    public void updateDictType(SysDictTypeUpdateReqVO reqVO) {
+        // 校验正确性
+        this.checkCreateOrUpdate(reqVO.getId(), reqVO.getName(), null);
+        // 更新字典类型
+        SysDictTypeDO updateObj = SysDictTypeConvert.INSTANCE.convert(reqVO);
+        dictTypeMapper.updateById(updateObj);
+    }
+
+    @Override
+    public void deleteDictType(Long id) {
+        // 执行删除
+        self.deleteDictType0(id);
+        // TODO 发送 MQ 消息
+    }
+
+    @Transactional
+    public void deleteDictType0(Long id) {
+        // 校验是否存在
+        SysDictTypeDO dictType = this.checkDictTypeExists(id);
+        // 校验是否有字典数据
+        if (dictDataService.countByDictType(dictType.getType()) > 0) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_HAS_CHILDREN);
+        }
+        // 删除字典类型
+        dictTypeMapper.deleteById(id);
+    }
+
+    private void checkCreateOrUpdate(Long id, String name, String type) {
+        // 校验自己存在
+        checkDictTypeExists(id);
+        // 校验字典类型的名字的唯一性
+        checkDictTypeNameUnique(id, name);
+        // 校验字典类型的类型的唯一性
+        checkDictTypeUnique(id, type);
+    }
+
+    private void checkDictTypeNameUnique(Long id, String type) {
+        SysDictTypeDO dictType = dictTypeMapper.selectByName(type);
+        if (dictType == null) {
+            return;
+        }
+        // 如果 id 为空，说明不用比较是否为相同 id 的字典类型
+        if (id == null) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_NAME_DUPLICATE);
+        }
+        if (!dictType.getId().equals(id)) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_NAME_DUPLICATE);
+        }
+    }
+
+    private void checkDictTypeUnique(Long id, String type) {
+        SysDictTypeDO dictType = dictTypeMapper.selectByType(type);
+        if (dictType == null) {
+            return;
+        }
+        // 如果 id 为空，说明不用比较是否为相同 id 的字典类型
+        if (id == null) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_TYPE_DUPLICATE);
+        }
+        if (!dictType.getId().equals(id)) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_TYPE_DUPLICATE);
+        }
+    }
+
+    private SysDictTypeDO checkDictTypeExists(Long id) {
+        if (id == null) {
+            return null;
+        }
+        SysDictTypeDO dictType = dictTypeMapper.selectById(id);
+        if (dictType == null) {
+            throw ServiceExceptionUtil.exception(DICT_TYPE_NOT_FOUND);
+        }
+        return dictType;
+    }
+
+}