czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

批量插入

Browse Source
This commit is contained in:
wangw
2025-11-28 17:43:27 +08:00
parent af8d528a2f
commit 002a34042b
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cash-service/account-service/src/main/java/com/czg/service/account/service/impl/BkContactListServiceImpl.java
View File

@@ -20,12 +20,12 @@ import java.util.stream.Collectors;
* @since 2025-11-27 * @since 2025-11-27
*/ */
@Service @Service
public class BkContactListServiceImpl extends ServiceImpl<BkContactListMapper, BkContactList> implements BkContactListService{ public class BkContactListServiceImpl extends ServiceImpl<BkContactListMapper, BkContactList> implements BkContactListService {
@Override @Override
public List<BkContactList> getUserList(Long shopId, Set<String> phones) { public List<BkContactList> getUserList(Long shopId, Set<String> phones) {
remove(QueryWrapper.create().eq(BkContactList::getShopId, shopId)); remove(QueryWrapper.create().eq(BkContactList::getShopId, shopId));
saveBatch(phones.stream() List<BkContactList> collect = phones.stream()
.filter(StrUtil::isNotEmpty) .filter(StrUtil::isNotEmpty)
.map(phone -> { .map(phone -> {
BkContactList bkContact = new BkContactList(); BkContactList bkContact = new BkContactList();
@@ -33,7 +33,8 @@ public class BkContactListServiceImpl extends ServiceImpl<BkContactListMapper, B
bkContact.setPhone(phone.trim()); bkContact.setPhone(phone.trim());
return bkContact; return bkContact;
}) })
.collect(Collectors.toList())); .collect(Collectors.toList());
mapper.insertBatch(collect);
return mapper.getUserList(shopId); return mapper.getUserList(shopId);
} }
} }