From 84f97d1b0b2cbf157dea598363e4cfcf8c15348a Mon Sep 17 00:00:00 2001
From: zhengyuxuan <zhengyuxuan1995>
Date: 星期四, 03 四月 2025 15:52:22 +0800
Subject: [PATCH] fix：佣金统计
---
LifePayment/LifePayment.Application/LifePay/StatisticsService.cs | 82 +++++++++++++++++++++++-----------------
1 files changed, 47 insertions(+), 35 deletions(-)
diff --git a/LifePayment/LifePayment.Application/LifePay/StatisticsService.cs b/LifePayment/LifePayment.Application/LifePay/StatisticsService.cs
index 01e43a9..a4e22f2 100644
--- a/LifePayment/LifePayment.Application/LifePay/StatisticsService.cs
+++ b/LifePayment/LifePayment.Application/LifePay/StatisticsService.cs
@@ -20,6 +20,7 @@
using ZeroD.Util;
using NPOI.SS.Formula.Functions;
using System.Security.Principal;
+using StackExchange.Redis;
namespace LifePayment.Application.LifePay
{
@@ -59,11 +60,11 @@
var statistics = await _dallyStatisticsRepository.Where(x => x.CreationTime.Date == today)
.WhereIf(channleList.Count() > 0, x => channleList.Contains(x.ChannelId))
.ToListAsync();
- var totalRechargeReceipts = await _lifePayRechargeReceiptsRepository.Where(x => x.IsDeleted == false && x.CreationTime < today).SumAsync(x => x.RechargeAmount);
+ var totalRechargeReceipts = await _lifePayRechargeReceiptsRepository.Where(x => x.CreationTime < today).SumAsync(x => x.RechargeAmount);
if (statistics == null || statistics.Count() == 0)
{
TopStatisticsOutput topStatisticsOutput = new TopStatisticsOutput() { };
- var allChannle = await _lifePayChannlesRep.Where(x => x.IsDeleted == false).ToListAsync();
+ var allChannle = await _lifePayChannlesRep.ToListAsync();
foreach (var item in allChannle)
{
var entity = await TopStatistics(item.ChannlesNum, today);
@@ -85,11 +86,8 @@
if (channleList.Count() == 0)
{
/// 璐︽埛浣欓
- var accountBalance = totalRechargeReceipts - await _lifePayOrderRepository.Where(x => x.PayStatus == LifePayStatusEnum.宸叉敮浠�
- && (x.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�兼垚鍔� || x.ACOOLYStatus == ACOOLYStatusEnum.宸插畬鎴� || x.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�))
- .SumAsync(x => x.PlatformDeductionAmount);
- topStatisticsOutput.Amount = accountBalance ?? 0;
-
+ topStatisticsOutput.Amount = totalRechargeReceipts - await _lifePayOrderRepository.Where(x => x.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�兼垚鍔� || x.ACOOLYStatus == ACOOLYStatusEnum.宸插畬鎴� || x.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�)
+ .SumAsync(x => x.PlatformDeductionAmount) ?? 0;
}
return topStatisticsOutput;
@@ -112,10 +110,8 @@
if (channleList.Count() == 0)
{
/// 璐︽埛浣欓
- var accountBalance = totalRechargeReceipts - await _lifePayOrderRepository.Where(x => x.PayStatus == LifePayStatusEnum.宸叉敮浠�
- && (x.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�兼垚鍔� || x.ACOOLYStatus == ACOOLYStatusEnum.宸插畬鎴� || x.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�))
- .SumAsync(x => x.PlatformDeductionAmount);
- topStatisticsOutput.Amount = accountBalance ?? 0;
+ topStatisticsOutput.Amount = totalRechargeReceipts - await _lifePayOrderRepository.Where(x => x.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�兼垚鍔� || x.ACOOLYStatus == ACOOLYStatusEnum.宸插畬鎴� || x.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�)
+ .SumAsync(x => x.PlatformDeductionAmount) ?? 0;
}
return topStatisticsOutput;
@@ -134,7 +130,7 @@
.WhereIf(channleList.Count() > 0, x => channleList.Contains(x.ChannelId))
.OrderBy(o => o.CreationTime)
.ToListAsync();
-
+ CheckExtensions.IfTrueThrowUserFriendlyException(statistics == null, "鏀舵缁熻澶辫触");
var groupedStatistics = statistics
.GroupBy(x => x.CreationTime)
.Select(g => new
@@ -148,14 +144,16 @@
foreach (var item in groupedStatistics)
{
+ /// 瀹為檯鏀舵鏃ユ湡
+ var creationTime = item.CreationTime.AddDays(-1).ToString("yyyy-MM-dd");
ReceiptsDetail receive = new ReceiptsDetail()
{
- CreationTime = item.CreationTime.AddDays(-1).ToString("yyyy-MM-dd"),
+ CreationTime = creationTime,
Amount = item.TotalReceiptsYesterday
};
ReceiptsDetail income = new ReceiptsDetail()
{
- CreationTime = item.CreationTime.AddDays(-1).ToString("yyyy-MM-dd"),
+ CreationTime = creationTime,
Amount = item.TotalIncomeYesterday
};
receiptsListOutPut.ReceiveList.Add(receive);
@@ -165,13 +163,18 @@
return receiptsListOutPut;
}
+ /// <summary>
+ /// 鑾峰彇30澶╀剑閲�
+ /// </summary>
+ /// <param name="channleList"></param>
+ /// <returns></returns>
public async Task<ChannlesRakeListOutPut> GetChannlesRakeList(List<string> channleList)
{
var today = DateTime.Now.Date;
- var statistics = await _lifePayChannlesRakeRepository.Where(x => x.IsDeleted == false &&
- x.FinishTime.Date <= today && x.FinishTime.Date >= today.AddDays(-30))
+ var statistics = await _lifePayChannlesRakeRepository.Where(x => x.FinishTime.Date <= today && x.FinishTime.Date >= today.AddDays(-30))
.WhereIf(channleList.Count() > 0, x => channleList.Contains(x.ChannelId))
.ToListAsync();
+ CheckExtensions.IfTrueThrowUserFriendlyException(statistics == null, "浣ｉ噾缁熻澶辫触");
var groupedStatistics = statistics
.GroupBy(x => x.FinishTime.ToString("yyyy-MM-dd"))
.Select(g => new
@@ -183,27 +186,30 @@
ChannlesRakeListOutPut channlesRakeListOutPut = new ChannlesRakeListOutPut();
- foreach (var item in groupedStatistics)
+ var dateList = Enumerable.Range(1, 31)
+ .Select(i => today.AddDays(-i))
+ .ToList();
+ foreach (var date in dateList)
{
+ var stat = groupedStatistics.FirstOrDefault(g => g.FinishTime == date.ToString("yyyy-MM-dd"));
ReceiptsDetail receive = new ReceiptsDetail()
{
- CreationTime = item.FinishTime,
- Amount = item.ChannlesRakePrice
+ CreationTime = date.ToString("yyyy-MM-dd"),
+ Amount = stat?.ChannlesRakePrice ?? 0
};
-
channlesRakeListOutPut.ChannlesRakeList.Add(receive);
}
return channlesRakeListOutPut;
-
}
public async Task<ChannelDataListOutPut> GetChannelDataList(List<string> channleList)
{
-
- var statistics = await _lifePayChannlesRakeRepository.Where(x => x.IsDeleted == false)
- .WhereIf(channleList.Count() > 0, x => channleList.Contains(x.ChannelId))
- .ToListAsync();
+ int maxStatisticsNumber = 5;
+ var statistics = await _lifePayChannlesRakeRepository
+ .WhereIf(channleList != null && channleList.Count() > 0, x => channleList.Contains(x.ChannelId))
+ .ToListAsync();
+ CheckExtensions.IfTrueThrowUserFriendlyException(statistics == null, "娓犻亾鏀舵缁熻澶辫触");
var groupedStatistics = statistics
.GroupBy(x => x.ChannelId)
.Select(g => new
@@ -221,19 +227,20 @@
{
ChannelDataReceive receive = new ChannelDataReceive()
{
- ChannelName = _lifePayChannlesRep.Where(x => x.ChannlesNum == item.ChannelId).FirstOrDefault().ChannlesName,
+ ChannelName = _lifePayChannlesRep.Where(x => x.ChannlesNum == item.ChannelId).FirstOrDefault()?.ChannlesName,
ReceivePrice = item.ReceivePrice,
ChannlesRakePrice = item.ChannlesRakePrice,
};
- if (channelDataList.ReceiveList.Count() < 5)
+ if (channelDataList.ReceiveList.Count() < maxStatisticsNumber)
{
channelDataList.ReceiveList.Add(receive);
}
}
/// 绱鐢ㄦ埛
- var users = await _lifePayUserRepository.Where(x => x.IsDeleted == false).WhereIf(channleList.Count() > 0, x => channleList.Contains(x.CreationChannleNum))
+ var users = await _lifePayUserRepository.WhereIf(channleList.Count() > 0, x => channleList.Contains(x.CreationChannleNum))
.ToListAsync();
+ CheckExtensions.IfTrueThrowUserFriendlyException(statistics == null, "绱鐢ㄦ埛缁熻澶辫触");
var groupedUsers = users
.GroupBy(x => x.CreationChannleNum)
.Select(g => new
@@ -247,10 +254,10 @@
{
ChannelDataUserNumber usernumber = new ChannelDataUserNumber()
{
- ChannelName = _lifePayChannlesRep.Where(x => x.ChannlesNum == item.ChannelId).FirstOrDefault().ChannlesName,
+ ChannelName = _lifePayChannlesRep.Where(x => x.ChannlesNum == item.ChannelId).FirstOrDefault()?.ChannlesName,
Number = item.Number,
};
- if (channelDataList.UserNumberList.Count() < 5)
+ if (channelDataList.UserNumberList.Count() < maxStatisticsNumber)
{
channelDataList.UserNumberList.Add(usernumber);
}
@@ -272,7 +279,7 @@
if (statistics == null || statistics.Count() == 0)
{
TopStatisticsOutput topStatisticsOutput = new TopStatisticsOutput() { };
- var allChannle = await _lifePayChannlesRep.Where(x => x.IsDeleted == false).ToListAsync();
+ var allChannle = await _lifePayChannlesRep.ToListAsync();
foreach (var item in allChannle)
{
var entity = await TopStatistics(item.ChannlesNum, today);
@@ -313,11 +320,16 @@
var yesterdayFail = await _lifePayOrderRepository.Where(x => x.CreationTime >= today.AddDays(-1) && x.CreationTime < today && x.LifePayOrderStatus == LifePayOrderStatusEnum.宸查��娆�)
.WhereIf(!string.IsNullOrWhiteSpace(channleId), x => x.ChannelId == channleId).CountAsync();
/// 绱鐢ㄦ埛
- var accumulatedUsers = await _lifePayUserRepository.Where(x => x.IsDeleted == false).WhereIf(!string.IsNullOrWhiteSpace(channleId), x => x.CreationChannleNum == channleId).CountAsync();
+ var accumulatedUsers = await _lifePayUserRepository.Where(x => x.CreationTime < today)
+ .WhereIf(!string.IsNullOrWhiteSpace(channleId), x => x.CreationChannleNum == channleId).CountAsync();
/// 鏄ㄦ棩娲昏穬鐢ㄦ埛
- var yesterdayActiveUsers = await _lifePayUserRepository.Where(x => x.IsDeleted == false).WhereIf(!string.IsNullOrWhiteSpace(channleId), x => x.CreationChannleNum == channleId).Where(x => x.LastLoginTime >= today.AddDays(-1) && x.LastLoginTime < today).CountAsync();
-
- var accumulatedChannlesRakePrice = await _lifePayChannlesRakeRepository.Where(x => x.IsDeleted == false && x.FinishTime < today)
+ var yesterdayActiveUsers = await (from a in _lifePayUserRepository
+ join b in _lifePayOrderRepository on a.Id equals b.UserId
+ where b.CreationTime >= today.AddDays(-1) && b.CreationTime < today
+ && (b.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�间腑 || b.ACOOLYStatus == ACOOLYStatusEnum.鍏呭�兼垚鍔� || b.ACOOLYStatus == ACOOLYStatusEnum.宸插畬鎴� || b.ACOOLYStatus == ACOOLYStatusEnum.閮ㄥ垎鍏呭�兼垚鍔�)
+ select b).Distinct().CountAsync();
+ /// 绱浣ｉ噾
+ var accumulatedChannlesRakePrice = await _lifePayChannlesRakeRepository.Where(x => x.FinishTime < today)
.WhereIf(!string.IsNullOrWhiteSpace(channleId), x => x.ChannelId == channleId).SumAsync(x => x.ChannlesRakePrice);
var entity = new DallyStatistics()
--
Gitblit v1.9.1