From 7abf9f290c39dd20f865be53dbecee7fab6de140 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期一, 26 十月 2026 19:12:41 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev_business_新高电力' into dev_business_新高电力
---
yudao-module-srm/src/main/java/cn/iocoder/yudao/module/srm/service/certificate/SrmSupplierCertificateServiceImpl.java | 71 +++++++++++++++++++++++++++++++++++
1 files changed, 71 insertions(+), 0 deletions(-)
diff --git a/yudao-module-srm/src/main/java/cn/iocoder/yudao/module/srm/service/certificate/SrmSupplierCertificateServiceImpl.java b/yudao-module-srm/src/main/java/cn/iocoder/yudao/module/srm/service/certificate/SrmSupplierCertificateServiceImpl.java
index 78132f6..795baab 100644
--- a/yudao-module-srm/src/main/java/cn/iocoder/yudao/module/srm/service/certificate/SrmSupplierCertificateServiceImpl.java
+++ b/yudao-module-srm/src/main/java/cn/iocoder/yudao/module/srm/service/certificate/SrmSupplierCertificateServiceImpl.java
@@ -1,12 +1,20 @@
package cn.iocoder.yudao.module.srm.service.certificate;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+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.srm.controller.admin.certificate.vo.SrmSupplierCertificateImportExcelVO;
+import cn.iocoder.yudao.module.srm.controller.admin.certificate.vo.SrmSupplierCertificateImportReqVO;
+import cn.iocoder.yudao.module.srm.controller.admin.certificate.vo.SrmSupplierCertificateImportRespVO;
import cn.iocoder.yudao.module.srm.controller.admin.certificate.vo.SrmSupplierCertificatePageReqVO;
import cn.iocoder.yudao.module.srm.controller.admin.certificate.vo.SrmSupplierCertificateSaveReqVO;
import cn.iocoder.yudao.module.srm.dal.dataobject.SrmSupplierCertificateDO;
+import cn.iocoder.yudao.module.srm.dal.dataobject.SrmSupplierDO;
import cn.iocoder.yudao.module.srm.dal.mysql.SrmSupplierCertificateMapper;
+import cn.iocoder.yudao.module.srm.dal.mysql.SrmSupplierMapper;
import cn.iocoder.yudao.module.srm.enums.ErrorCodeConstants;
import cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil;
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
@@ -16,6 +24,8 @@
import org.springframework.validation.annotation.Validated;
import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
import java.util.List;
@Service
@@ -29,6 +39,9 @@
@Resource
private SrmSupplierCertificateMapper certificateMapper;
+
+ @Resource
+ private SrmSupplierMapper supplierMapper;
@Resource
private StorageAttachmentApi storageAttachmentApi;
@@ -87,6 +100,64 @@
return certificateMapper.selectExpiringList(now, now.plusDays(30));
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public SrmSupplierCertificateImportRespVO importCertificateList(List<SrmSupplierCertificateImportExcelVO> importCertificates,
+ SrmSupplierCertificateImportReqVO importReqVO) {
+ // 1. 鏍￠獙闈炵┖
+ importCertificates = CollectionUtils.filterList(importCertificates,
+ item -> StrUtil.isNotBlank(item.getCertificateName()));
+ if (CollUtil.isEmpty(importCertificates)) {
+ throw ServiceExceptionUtil.exception(ErrorCodeConstants.CERTIFICATE_IMPORT_LIST_IS_EMPTY);
+ }
+
+ // 2. 閫愭潯澶勭悊
+ SrmSupplierCertificateImportRespVO respVO = SrmSupplierCertificateImportRespVO.builder()
+ .createCertificateNames(new ArrayList<>())
+ .updateCertificateNames(new ArrayList<>())
+ .failureCertificateNames(new LinkedHashMap<>())
+ .build();
+ importCertificates.forEach(importCertificate -> {
+ try {
+ // 2.1 瑙ｆ瀽渚涘簲鍟�
+ if (StrUtil.isBlank(importCertificate.getSupplierName())) {
+ throw ServiceExceptionUtil.exception(ErrorCodeConstants.CERTIFICATE_IMPORT_SUPPLIER_NAME_REQUIRED);
+ }
+ SrmSupplierDO supplier = supplierMapper.selectByName(importCertificate.getSupplierName());
+ if (supplier == null) {
+ throw ServiceExceptionUtil.exception(ErrorCodeConstants.CERTIFICATE_IMPORT_SUPPLIER_NOT_EXISTS,
+ importCertificate.getSupplierName());
+ }
+ // 2.2 鍒ゆ柇鏄惁瀛樺湪
+ SrmSupplierCertificateDO existCertificate = certificateMapper.selectBySupplierIdAndCertificateName(
+ supplier.getId(), importCertificate.getCertificateName());
+ if (existCertificate == null) {
+ // 2.2.1 鏂板
+ SrmSupplierCertificateDO certificate = BeanUtils.toBean(importCertificate, SrmSupplierCertificateDO.class)
+ .setSupplierId(supplier.getId());
+ updateStatus(certificate);
+ certificateMapper.insert(certificate);
+ respVO.getCreateCertificateNames().add(importCertificate.getCertificateName());
+ return;
+ }
+ // 2.2.2 宸插瓨鍦紝鍒ゆ柇鏄惁鍏佽鏇存柊
+ if (!importReqVO.getUpdateSupport()) {
+ respVO.getFailureCertificateNames().put(importCertificate.getCertificateName(),
+ StrUtil.format(ErrorCodeConstants.CERTIFICATE_IMPORT_NAME_EXISTS.getMsg(), importCertificate.getCertificateName()));
+ return;
+ }
+ SrmSupplierCertificateDO updateCertificate = BeanUtils.toBean(importCertificate, SrmSupplierCertificateDO.class)
+ .setId(existCertificate.getId()).setSupplierId(supplier.getId());
+ updateStatus(updateCertificate);
+ certificateMapper.updateById(updateCertificate);
+ respVO.getUpdateCertificateNames().add(importCertificate.getCertificateName());
+ } catch (ServiceException ex) {
+ respVO.getFailureCertificateNames().put(importCertificate.getCertificateName(), ex.getMessage());
+ }
+ });
+ return respVO;
+ }
+
private void validateCertificateExists(Long id) {
if (certificateMapper.selectById(id) == null) {
throw ServiceExceptionUtil.exception(ErrorCodeConstants.CERTIFICATE_NOT_EXISTS);
--
Gitblit v1.9.3