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

金币代理流水问题修复

Browse Source
This commit is contained in:
tianfeng 2025-11-08 17:03:12 +08:00
parent 6f35cb319f
commit 5e8dc1126d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rc-service/rc-service-wallet/wallet-infrastructure/src/main/java/com/red/circle/wallet/infra/database/rds/service/freight/impl/FreightBalanceRunningWaterServiceImpl.java
View File

@ -39,7 +39,11 @@ public class FreightBalanceRunningWaterServiceImpl extends
@Override @Override
public List<FreightBalanceRunningWater> flowByUserId(Long userId, Long lastId) { public List<FreightBalanceRunningWater> flowByUserId(Long userId, Long lastId) {
return query() return query()
.eq(FreightBalanceRunningWater::getUserId, userId) .and(wrapper -> wrapper
.eq(FreightBalanceRunningWater::getUserId, userId)
.or()
.eq(FreightBalanceRunningWater::getAcceptUserId, userId)
)
.lt(Objects.nonNull(lastId), FreightBalanceRunningWater::getId, lastId) .lt(Objects.nonNull(lastId), FreightBalanceRunningWater::getId, lastId)
.orderByDesc(FreightBalanceRunningWater::getId) .orderByDesc(FreightBalanceRunningWater::getId)
.last(PageConstant.DEFAULT_LIMIT) .last(PageConstant.DEFAULT_LIMIT)