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

wallet 流水新增account

Browse Source
This commit is contained in:
tianfeng 2025-09-29 13:09:07 +08:00
parent c84396629c
commit a19efc4511
2 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
rc-service/rc-inner-api/wallet-inner/wallet-inner-model/src/main/java/com/red/circle/wallet/inner/model/dto/FreightBalanceRunningWaterDTO.java
View File

@ -32,6 +32,11 @@ public class FreightBalanceRunningWaterDTO extends DTO {
@JsonSerialize(using = ToStringSerializer.class)
private Long id;
/**
* 账号
*/
private String account;
/**
* 来源系统.
*/

24
rc-service/rc-service-wallet/wallet-inner-endpoint/src/main/java/com/red/circle/wallet/inner/service/freight/impl/FreightBalanceRunningWaterClientServiceImpl.java
View File

@ -1,10 +1,17 @@
package com.red.circle.wallet.inner.service.freight.impl;
import com.red.circle.other.inner.endpoint.user.user.UserProfileClient;
import com.red.circle.other.inner.model.dto.user.UserProfileDTO;
import com.red.circle.wallet.infra.database.rds.entity.freight.FreightBalanceRunningWater;
import com.red.circle.wallet.infra.database.rds.service.freight.FreightBalanceRunningWaterService;
import com.red.circle.wallet.inner.convertor.FreightBalanceRunningWaterInnerConvertor;
import com.red.circle.wallet.inner.model.dto.FreightBalanceRunningWaterDTO;
import com.red.circle.wallet.inner.service.freight.FreightBalanceRunningWaterClientService;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
@ -20,12 +27,23 @@ public class FreightBalanceRunningWaterClientServiceImpl implements
private final FreightBalanceRunningWaterService freightBalanceRunningWaterService;
private final FreightBalanceRunningWaterInnerConvertor freightBalanceRunningWaterInnerConvertor;
private final UserProfileClient userProfileClient;
@Override
public List<FreightBalanceRunningWaterDTO> flowByUserId(Long userId, Long lastId) {
return freightBalanceRunningWaterInnerConvertor.toListFreightBalanceRunningWaterDTO(
freightBalanceRunningWaterService.flowByUserId(userId, lastId)
);
List<FreightBalanceRunningWater> runningWaters = freightBalanceRunningWaterService.flowByUserId(userId, lastId);
List<FreightBalanceRunningWaterDTO> runningWaterDTO = freightBalanceRunningWaterInnerConvertor.toListFreightBalanceRunningWaterDTO(runningWaters);
Set<Long> acceptUserIdList = runningWaterDTO.stream().map(FreightBalanceRunningWaterDTO::getAcceptUserId).collect(Collectors.toSet());
Map<Long, UserProfileDTO> userProfileDTOMap = userProfileClient.mapByUserIds(acceptUserIdList).getBody();
runningWaterDTO.forEach(dto -> {
UserProfileDTO profileDTO = userProfileDTOMap.get(dto.getAcceptUserId());
if (profileDTO != null) {
dto.setAccount(profileDTO.getAccount());
}
});
return runningWaterDTO;
}
@Override