| | |
| | | package cn.iocoder.yudao.module.erp.service.purchase; |
| | | |
| | | 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.object.BeanUtils; |
| | | import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.supplier.ErpSupplierImportExcelVO; |
| | | import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.supplier.ErpSupplierImportReqVO; |
| | | import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.supplier.ErpSupplierImportRespVO; |
| | | import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.supplier.ErpSupplierPageReqVO; |
| | | import cn.iocoder.yudao.module.erp.controller.admin.purchase.vo.supplier.ErpSupplierSaveReqVO; |
| | | import cn.iocoder.yudao.module.erp.dal.dataobject.purchase.ErpSupplierDO; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.validation.annotation.Validated; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.LinkedHashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | |
| | | 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.erp.enums.ErrorCodeConstants.*; |
| | | |
| | | /** |
| | |
| | | return supplierMapper.selectListByStatus(status); |
| | | } |
| | | |
| | | @Override |
| | | public ErpSupplierImportRespVO importSupplierList(List<ErpSupplierImportExcelVO> importSuppliers, |
| | | ErpSupplierImportReqVO importReqVO) { |
| | | // 1. 校验非空 |
| | | importSuppliers = filterList(importSuppliers, item -> StrUtil.isNotBlank(item.getName())); |
| | | if (CollUtil.isEmpty(importSuppliers)) { |
| | | throw exception(SUPPLIER_IMPORT_LIST_IS_EMPTY); |
| | | } |
| | | // 2. 逐条处理 |
| | | ErpSupplierImportRespVO respVO = ErpSupplierImportRespVO.builder() |
| | | .createSupplierNames(new ArrayList<>()) |
| | | .updateSupplierNames(new ArrayList<>()) |
| | | .failureSupplierNames(new LinkedHashMap<>()) |
| | | .build(); |
| | | importSuppliers.forEach(importSupplier -> { |
| | | try { |
| | | ErpSupplierDO existSupplier = supplierMapper.selectByName(importSupplier.getName()); |
| | | if (existSupplier == null) { |
| | | // 新增 |
| | | ErpSupplierDO supplier = BeanUtils.toBean(importSupplier, ErpSupplierDO.class); |
| | | supplierMapper.insert(supplier); |
| | | respVO.getCreateSupplierNames().add(importSupplier.getName()); |
| | | return; |
| | | } |
| | | // 已存在,判断是否允许更新 |
| | | if (!importReqVO.getUpdateSupport()) { |
| | | respVO.getFailureSupplierNames().put(importSupplier.getName(), |
| | | StrUtil.format(SUPPLIER_NAME_EXISTS.getMsg(), importSupplier.getName())); |
| | | return; |
| | | } |
| | | ErpSupplierDO updateSupplier = BeanUtils.toBean(importSupplier, ErpSupplierDO.class) |
| | | .setId(existSupplier.getId()); |
| | | supplierMapper.updateById(updateSupplier); |
| | | respVO.getUpdateSupplierNames().add(importSupplier.getName()); |
| | | } catch (ServiceException ex) { |
| | | respVO.getFailureSupplierNames().put(importSupplier.getName(), ex.getMessage()); |
| | | } |
| | | }); |
| | | return respVO; |
| | | } |
| | | |
| | | } |