update 功能安全中心 判重,联系人是否重复
This commit is contained in:
+16
-2
@@ -46,10 +46,17 @@ public class SafetyCenterSubitemService extends ServiceImpl<SafetyCenterSubitemM
|
|||||||
if (this.count(wrapper) > 0){
|
if (this.count(wrapper) > 0){
|
||||||
throw new JeroBootException("成员单位已经存在");
|
throw new JeroBootException("成员单位已经存在");
|
||||||
}
|
}
|
||||||
|
//判重,联系人是否重复
|
||||||
|
List<SafetyCenterSubitemContacts> contactsList = safetyCenterSubitem.getContactsList();
|
||||||
|
if (!contactsList.isEmpty()){
|
||||||
|
List<String> collect = contactsList.stream().map(SafetyCenterSubitemContacts::getContactsId).distinct().collect(Collectors.toList());
|
||||||
|
if (collect.size() != contactsList.size()){
|
||||||
|
throw new JeroBootException("企业联系人重复");
|
||||||
|
}
|
||||||
|
}
|
||||||
this.save(safetyCenterSubitem);
|
this.save(safetyCenterSubitem);
|
||||||
//保存成员单位联系人
|
//保存成员单位联系人
|
||||||
String subitemId = safetyCenterSubitem.getId();
|
String subitemId = safetyCenterSubitem.getId();
|
||||||
List<SafetyCenterSubitemContacts> contactsList = safetyCenterSubitem.getContactsList();
|
|
||||||
for (SafetyCenterSubitemContacts contacts : contactsList) {
|
for (SafetyCenterSubitemContacts contacts : contactsList) {
|
||||||
contacts.setProjectId(projectId);
|
contacts.setProjectId(projectId);
|
||||||
contacts.setCompanyId(companyId);
|
contacts.setCompanyId(companyId);
|
||||||
@@ -75,13 +82,20 @@ public class SafetyCenterSubitemService extends ServiceImpl<SafetyCenterSubitemM
|
|||||||
if (this.count(wrapper) > 0){
|
if (this.count(wrapper) > 0){
|
||||||
throw new JeroBootException("成员单位已经存在");
|
throw new JeroBootException("成员单位已经存在");
|
||||||
}
|
}
|
||||||
|
//判重,联系人是否重复
|
||||||
|
List<SafetyCenterSubitemContacts> contactsList = safetyCenterSubitem.getContactsList();
|
||||||
|
if (!contactsList.isEmpty()){
|
||||||
|
List<String> collect = contactsList.stream().map(SafetyCenterSubitemContacts::getContactsId).distinct().collect(Collectors.toList());
|
||||||
|
if (collect.size() != contactsList.size()){
|
||||||
|
throw new JeroBootException("企业联系人重复");
|
||||||
|
}
|
||||||
|
}
|
||||||
this.updateById(safetyCenterSubitem);
|
this.updateById(safetyCenterSubitem);
|
||||||
//先删除之前保存的
|
//先删除之前保存的
|
||||||
LambdaQueryWrapper<SafetyCenterSubitemContacts> wrapper1 = new LambdaQueryWrapper<>();
|
LambdaQueryWrapper<SafetyCenterSubitemContacts> wrapper1 = new LambdaQueryWrapper<>();
|
||||||
wrapper1.eq(SafetyCenterSubitemContacts::getSubitemId,subitemId);
|
wrapper1.eq(SafetyCenterSubitemContacts::getSubitemId,subitemId);
|
||||||
contactsService.remove(wrapper1);
|
contactsService.remove(wrapper1);
|
||||||
//保存成员单位联系人
|
//保存成员单位联系人
|
||||||
List<SafetyCenterSubitemContacts> contactsList = safetyCenterSubitem.getContactsList();
|
|
||||||
for (SafetyCenterSubitemContacts contacts : contactsList) {
|
for (SafetyCenterSubitemContacts contacts : contactsList) {
|
||||||
contacts.setProjectId(projectId);
|
contacts.setProjectId(projectId);
|
||||||
contacts.setCompanyId(companyId);
|
contacts.setCompanyId(companyId);
|
||||||
|
|||||||
Reference in New Issue
Block a user