Elgato_dark/sol-cloud
1
0
Fork 0
mirror of https://github.com/BgaSol/sol-cloud synced 2026-05-23 09:08:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(common-base-web): Optimize the null value processing of the findIds method

Browse source
This commit is contained in:
Sol 2025-06-13 11:34:59 +08:00
parent 88489f907c
commit 24baf77516
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
cloud/common/common-base-web/src/main/java/com/bgasol/common/core/base/service/BaseService.java
View file

@ -263,6 +263,9 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
public List<ENTITY> findIds(String... ids) {
// 优先从缓存查询结果
if (ObjectUtils.isEmpty(commonBaseRedissonClient())) {
if (ObjectUtils.isEmpty(ids)) {
return new ArrayList<>();
}
return commonBaseMapper().selectByIds(Arrays.asList(ids));
}
@ -272,8 +275,12 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
// 缓存中没有的查询数据库
List<String> noneCacheIds = Arrays.stream(ids).filter(id -> !cacheList.containsKey(id)).toList();
List<ENTITY> entities = commonBaseMapper().selectByIds(noneCacheIds);
List<ENTITY> entities;
if (ObjectUtils.isEmpty(noneCacheIds)) {
entities = new ArrayList<>();
} else {
entities = commonBaseMapper().selectByIds(noneCacheIds);
}
// 准备缓存的新数据 数据库中也没有查到的数据制作为NULL_PLACEHOLDER实体
Map<String, ENTITY> toCacheDate = noneCacheIds.stream().collect(Collectors.toMap(id -> id,
id -> entities.stream().filter(entity -> entity.getId().equals(id)).findFirst().orElse(
@ -282,7 +289,6 @@ public abstract class BaseService<ENTITY extends BaseEntity, PAGE_DTO extends Ba
// 将数据库查询的结果，缓存到redis中
mapCache.putAll(toCacheDate, randomizeTtl(), DEFAULT_TIME_UNIT);
// 合并缓存和数据库的结果 （将防止缓存穿透的空对象扔掉）
List<ENTITY> result = new ArrayList<>(cacheList.values().stream().filter(entity -> !entity.getId().equals(NULL_PLACEHOLDER)).toList());
result.addAll(entities);