hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

金币代理根据国家区分

Browse Source 
(cherry picked from commit 9d96215b2c62f0103384643fbb4c7b5cc398d31c)
This commit is contained in:
tianfeng 2026-04-02 18:55:49 +08:00
parent 89d68a1861
commit 11fcf9502a
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/user/impl/UserFreightBalanceRestServiceImpl.java
View File

@ -71,10 +71,15 @@ public class UserFreightBalanceRestServiceImpl implements UserFreightBalanceRest
} }
// 根据国家编码过滤数据 // 根据国家编码过滤数据
List<UserFreightBalanceDTO> filteredRecords = freightPageResult.getRecords().stream() List<UserFreightBalanceDTO> records = freightPageResult.getRecords().stream()
.filter(dto -> isCountrySupported(userProfile.getId(), dto.getUserId())) .filter(dto -> isCountrySupported(userProfile.getId(), dto.getUserId()))
.collect(Collectors.toList()); .toList();
List<UserProfile> userProfiles = userProfileGateway.listByUserIds(records.stream().map(UserFreightBalanceDTO::getUserId).collect(Collectors.toSet()));
Set<String> countryCodeSet = userProfiles.stream().map(UserProfile::getCountryCode).collect(Collectors.toSet());
List<UserFreightBalanceDTO> filteredRecords = records.stream()
.filter(e -> countryCodeSet.contains(userProfile.getCountryCode()))
.collect(Collectors.toList());
if (filteredRecords.isEmpty()) { if (filteredRecords.isEmpty()) {
return PageResult.newPageResult(20); return PageResult.newPageResult(20);
} }