From d7bcd67ae72349db381fe6e62e6d1525d997d205 Mon Sep 17 00:00:00 2001 From: lijiarao Date: Tue, 2 Jul 2024 11:36:47 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E5=8A=9F=E8=83=BD=E5=AE=89=E5=85=A8?= =?UTF-8?q?=E4=B8=AD=E5=BF=83=20=E5=88=A4=E9=87=8D=EF=BC=8C=E8=81=94?= =?UTF-8?q?=E7=B3=BB=E4=BA=BA=E6=98=AF=E5=90=A6=E9=87=8D=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/SafetyCenterSubitemService.java | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-) diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/functionalsafetycenter/service/SafetyCenterSubitemService.java b/jero-boot-incoming-payment/src/main/java/com/jero/functionalsafetycenter/service/SafetyCenterSubitemService.java index c88d9db8..7f949639 100644 --- a/jero-boot-incoming-payment/src/main/java/com/jero/functionalsafetycenter/service/SafetyCenterSubitemService.java +++ b/jero-boot-incoming-payment/src/main/java/com/jero/functionalsafetycenter/service/SafetyCenterSubitemService.java @@ -46,10 +46,17 @@ public class SafetyCenterSubitemService extends ServiceImpl 0){ throw new JeroBootException("成员单位已经存在"); } + //判重，联系人是否重复 + List contactsList = safetyCenterSubitem.getContactsList(); + if (!contactsList.isEmpty()){ + List collect = contactsList.stream().map(SafetyCenterSubitemContacts::getContactsId).distinct().collect(Collectors.toList()); + if (collect.size() != contactsList.size()){ + throw new JeroBootException("企业联系人重复"); + } + } this.save(safetyCenterSubitem); //保存成员单位联系人 String subitemId = safetyCenterSubitem.getId(); - List contactsList = safetyCenterSubitem.getContactsList(); for (SafetyCenterSubitemContacts contacts : contactsList) { contacts.setProjectId(projectId); contacts.setCompanyId(companyId); @@ -75,13 +82,20 @@ public class SafetyCenterSubitemService extends ServiceImpl 0){ throw new JeroBootException("成员单位已经存在"); } + //判重，联系人是否重复 + List contactsList = safetyCenterSubitem.getContactsList(); + if (!contactsList.isEmpty()){ + List collect = contactsList.stream().map(SafetyCenterSubitemContacts::getContactsId).distinct().collect(Collectors.toList()); + if (collect.size() != contactsList.size()){ + throw new JeroBootException("企业联系人重复"); + } + } this.updateById(safetyCenterSubitem); //先删除之前保存的 LambdaQueryWrapper wrapper1 = new LambdaQueryWrapper<>(); wrapper1.eq(SafetyCenterSubitemContacts::getSubitemId,subitemId); contactsService.remove(wrapper1); //保存成员单位联系人 - List contactsList = safetyCenterSubitem.getContactsList(); for (SafetyCenterSubitemContacts contacts : contactsList) { contacts.setProjectId(projectId); contacts.setCompanyId(companyId);