| | |
| | | package cn.iocoder.yudao.module.system.service.dict; |
| | | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum; |
| | | import cn.iocoder.yudao.framework.common.exception.ServiceException; |
| | | import cn.iocoder.yudao.framework.common.pojo.PageResult; |
| | | import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils; |
| | | import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
| | | import cn.iocoder.yudao.module.system.controller.admin.dict.vo.data.DictDataImportExcelVO; |
| | | import cn.iocoder.yudao.module.system.controller.admin.dict.vo.data.DictDataImportReqVO; |
| | | import cn.iocoder.yudao.module.system.controller.admin.dict.vo.data.DictDataImportRespVO; |
| | | import cn.iocoder.yudao.module.system.controller.admin.dict.vo.data.DictDataPageReqVO; |
| | | import cn.iocoder.yudao.module.system.controller.admin.dict.vo.data.DictDataSaveReqVO; |
| | | import cn.iocoder.yudao.module.system.dal.dataobject.dict.DictDataDO; |
| | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.Comparator; |
| | | import java.util.LinkedHashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; |
| | | import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList; |
| | | import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.*; |
| | | |
| | | /** |
| | |
| | | return list; |
| | | } |
| | | |
| | | @Override |
| | | public DictDataImportRespVO importDictDataList(List<DictDataImportExcelVO> importDictDatas, DictDataImportReqVO importReqVO) { |
| | | importDictDatas = filterList(importDictDatas, item -> StrUtil.isNotBlank(item.getLabel())); |
| | | if (CollUtil.isEmpty(importDictDatas)) { |
| | | throw exception(DICT_DATA_IMPORT_LIST_IS_EMPTY); |
| | | } |
| | | DictDataImportRespVO respVO = DictDataImportRespVO.builder() |
| | | .createDictDataNames(new ArrayList<>()) |
| | | .updateDictDataNames(new ArrayList<>()) |
| | | .failureDictDataNames(new LinkedHashMap<>()) |
| | | .build(); |
| | | importDictDatas.forEach(importDictData -> { |
| | | try { |
| | | // 1. 校验字典类型有效 |
| | | validateDictTypeExists(importDictData.getDictType()); |
| | | // 2. 判断是否存在(字典类型 + 字典值 唯一) |
| | | DictDataDO existDictData = dictDataMapper.selectByDictTypeAndValue( |
| | | importDictData.getDictType(), importDictData.getValue()); |
| | | if (existDictData == null) { |
| | | // 2.1 新增 |
| | | validateDictDataValueUnique(null, importDictData.getDictType(), importDictData.getValue()); |
| | | DictDataDO dictData = BeanUtils.toBean(importDictData, DictDataDO.class); |
| | | dictDataMapper.insert(dictData); |
| | | respVO.getCreateDictDataNames().add(importDictData.getLabel()); |
| | | return; |
| | | } |
| | | // 2.2 已存在,判断是否允许更新 |
| | | if (!importReqVO.getUpdateSupport()) { |
| | | respVO.getFailureDictDataNames().put(importDictData.getLabel(), |
| | | StrUtil.format(DICT_DATA_VALUE_DUPLICATE.getMsg())); |
| | | return; |
| | | } |
| | | DictDataDO updateDictData = BeanUtils.toBean(importDictData, DictDataDO.class) |
| | | .setId(existDictData.getId()); |
| | | dictDataMapper.updateById(updateDictData); |
| | | respVO.getUpdateDictDataNames().add(importDictData.getLabel()); |
| | | } catch (ServiceException ex) { |
| | | respVO.getFailureDictDataNames().put(importDictData.getLabel(), ex.getMessage()); |
| | | } |
| | | }); |
| | | return respVO; |
| | | } |
| | | |
| | | } |