|
@@ -503,9 +503,11 @@ public abstract class SnapshotApplicationBase
|
|
|
/// <returns></returns>
|
|
|
public async Task<string> GetRedPackReceivedTotalAsync(CancellationToken cancellationToken)
|
|
|
{
|
|
|
- var member = await _citizenRepository.GetAsync(m => m.Id == _sessionContext.UserId, cancellationToken)
|
|
|
- ?? throw UserFriendlyException.SameMessage("用户不存在");
|
|
|
- return (member.TotalAmount ?? 0).ToYuanFinance();
|
|
|
+ var totalAmount = await _redPackRecordRepository.Queryable()
|
|
|
+ .Where(m => m.WXOpenId == _sessionContext.OpenId && m.PickupStatus == ERedPackPickupStatus.Received)
|
|
|
+ .Select(m => SqlFunc.AggregateSum(m.Amount))
|
|
|
+ .FirstAsync(cancellationToken);
|
|
|
+ return totalAmount.ToYuanFinance();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|