LifePaymentApi.git

			@@ -14,6 +14,9 @@
			using LifePayment.Domain;
			using static LifePayment.Domain.Shared.LifePaymentConstant;
			using Newtonsoft.Json;
			using LifePayment.Domain.Common;
			using Spire.Pdf.Exporting.XPS.Schema;
			using Nest;

			namespace LifePayment.Application.LifePay
			{
			@@ -21,6 +24,8 @@
			{
			private readonly IRepository<LifePayRechargeReceipts, Guid> _lifePayRechargeReceiptsRepository;
			private readonly IRepository<LifePayExpensesReceipts, Guid> _lifePayExpensesReceiptsRepository;
			private readonly IRepository<LifePayConsumption, Guid> _lifePayConsumption;
			private readonly IRepository<LifePayChannles, Guid> _lifePayChannlesRep;
			private readonly IRepository<LifePayChannlesRake, Guid> _lifePayChannlesRakeRepository;
			private readonly IRepository<LifePayOrder, Guid> _lifePayOrderRepository;
			private readonly IAliPayApi _aliPayApi;
			@@ -29,20 +34,62 @@
			public LifePayOrderService(
			IRepository<LifePayRechargeReceipts, Guid> lifePayRechargeReceiptsRepository,
			IRepository<LifePayExpensesReceipts, Guid> lifePayExpensesReceiptsRepository,
			IRepository<LifePayConsumption, Guid> lifePayConsumptionRepository,
			IRepository<LifePayChannlesRake, Guid> lifePayChannlesRakeRepository,
			IRepository<LifePayChannles, Guid> lifePayChannlesRep,
			IRepository<LifePayOrder, Guid> lifePayOrderRepository,
			IAliPayApi aliPayApi,
			IWxPayApi wxPayApi)
			{
			_lifePayRechargeReceiptsRepository = lifePayRechargeReceiptsRepository;
			_lifePayExpensesReceiptsRepository = lifePayExpensesReceiptsRepository;
			_lifePayConsumption = lifePayConsumptionRepository;
			_lifePayChannlesRakeRepository = lifePayChannlesRakeRepository;
			_lifePayChannlesRep = lifePayChannlesRep;
			_lifePayOrderRepository = lifePayOrderRepository;
			_aliPayApi = aliPayApi;
			_wxPayApi = wxPayApi;
			}

			#region 查询

			/// <summary>
			/// 获取消费流水
			/// </summary>
			/// <param name="input"></param>
			/// <returns></returns>
			public async Task<PageOutput<LifePayConsumptionListOutput>> GetLifePayConsumptionPage(LifePayConsumptionPageInput input)
			{
			var channles = await _lifePayChannlesRep.Where(x => x.ChannlesName.Contains(input.KeyWord)).Select(x => x.ChannlesNum).ToListAsync();
			var list = await _lifePayConsumption.Where(x => x.IsDeleted == false)
			.WhereIf(input.KeyWord.IsNotNullOrEmpty(), x => x.OrderNo.Contains(input.KeyWord) \|\| x.AcoolyOrderNo.Contains(input.KeyWord) \|\| channles.Contains(x.ChannelId))
			.WhereIf(input.Flow.HasValue, x => x.Flow == input.Flow)
			.WhereIf(input.TimeBegin.HasValue, x => x.FinishTime >= input.TimeBegin)
			.WhereIf(input.TimeEnd.HasValue, x => x.FinishTime <= input.TimeEnd)
			.Select(x => new LifePayConsumptionListOutput()
			{
			Id = x.Id,
			OrderNo = x.OrderNo,
			AcoolyOrderNo = x.AcoolyOrderNo,
			Amount = x.Amount,
			ACOOLYStatus = x.ACOOLYStatus,
			FinishTime = x.FinishTime,
			FrozenStatus = x.FrozenStatus,
			Flow = x.Flow,
			DeductionAmount = x.DeductionAmount,
			FrozenAmount = x.FrozenAmount.Value
			})
			.GetPageResult(input.PageModel);

			var totalDeductionAmount = await _lifePayConsumption.Where(x => x.IsDeleted == false).SumAsync(x => x.DeductionAmount);
			var totalFrozenAmount = await _lifePayConsumption.Where(x => x.IsDeleted == false).SumAsync(x => x.FrozenAmount);
			LifePayConsumptionStatistics objectData = new LifePayConsumptionStatistics();
			objectData.TotalDeductionAmount = totalDeductionAmount;
			objectData.TotalFrozenAmount = totalFrozenAmount.Value;
			list.ObjectData = objectData;
			return list;
			}

			/// <summary>
			/// 获取充值流水
			/// </summary>
			@@ -146,54 +193,31 @@

			public async Task<List<LifePayChannlesRakeListTemplate>> GetLifePayChannlesRakePageExport(LifePayChannlesRakePageInput input)
			{
			//var result = await (await GetLifePayOrderListFilter(input)).Select(x => new LifePayOrderListTemplate
			//{
			// DiscountAmount = x.DiscountAmount,
			// FinishTime = x.FinishTime,
			// LifePayOrderStatus = x.LifePayOrderStatus,
			// LifePayOrderType = x.LifePayOrderType,
			// LifePayType = x.LifePayType,
			// OrderNo = x.OrderNo,
			// PayAmount = x.PayAmount,
			// ActualRechargeAmount = x.RechargeAmount,
			// PhoneNumber = x.PhoneNumber,
			// RechargeAmount = x.RechargeAmount,
			// OutOrderNo = x.OutOrderNo,
			// PayStatus = x.PayStatus,
			// PayTime = x.PayTime,
			// ACOOLYOrderNo = x.ACOOLYOrderNo,
			// CreationTime = x.CreationTime,
			// LifePayRefundStatus = x.LifePayRefundStatus,
			// ACOOLYStatus = x.ACOOLYStatus,
			// //RefundApplyRemark = x.RefundApplyRemark,
			// ChannelName = x.ChannelName,
			// PlatformPrice = x.PlatformDeductionAmount.HasValue ? x.PlatformDeductionAmount.Value : 0.00m
			//}).OrderByDescending(r => r.CreationTime).ToListAsync();
			//var i = 0;
			//result.ForEach(s =>
			//{
			// s.SerialNumber = ++i;
			// s.LifePayOrderTypeStr = s.LifePayOrderType.GetDescription();
			// s.CreationTimeStr = s.CreationTime.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmmss);
			// s.RechargeAmountStr = s.RechargeAmount.ToString("F2");
			// s.PayAmountStr = s.PayAmount.ToString("F2");
			// s.PayTimeStr = !s.PayTime.HasValue ? string.Empty : s.PayTime.Value.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmmss);
			// s.LifePayTypeStr = s.LifePayType.GetDescription();
			// s.PayStatusStr = s.PayStatus.GetDescription();
			// s.ActualRechargeAmountStr = s.ActualRechargeAmount.ToString("F2");
			// s.LifePayRefundStatusStr = s.LifePayRefundStatus == LifePayRefundStatusEnum.无需退款 ? "" : s.LifePayRefundStatus.GetDescription();
			// s.ACOOLYStatusStr = s.ACOOLYStatus.GetDescription();
			// s.LifePayOrderStatusStr = s.LifePayOrderStatus.GetDescription();
			// s.FinishTimeStr = !s.FinishTime.HasValue ? string.Empty : s.FinishTime.Value.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmmss);
			//});
			return null;
			var result = await (await GetLifePayChannlesRakeListFilter(input)).Select(x => new LifePayChannlesRakeListTemplate
			{
			CreationTime = x.CreationTime,
			FinishTime = x.FinishTime,
			OrderNo = x.OrderNo,
			PayAmount = x.PayAmount,
			ChannlesRakeRate = x.ChannlesRakeRate,
			ChannlesRakePrice = x.ChannlesRakePrice
			}).OrderByDescending(r => r.CreationTime).ToListAsync();
			var i = 0;
			result.ForEach(s =>
			{
			s.SerialNumber = ++i;
			s.CreationTimeStr = s.CreationTime.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmmss);
			s.PayAmountStr = s.PayAmount.ToString("F2");
			s.ChannlesRakeRateStr = s.ChannlesRakeRate.ToString("F0") + "%";
			s.ChannlesRakePriceStr = s.ChannlesRakePrice.ToString("F2");
			s.FinishTimeStr = s.FinishTime.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmmss);
			});
			return result;
			}

			#endregion




			#region 操作

			/// <summary>
			/// 编辑充值流水
			@@ -229,7 +253,6 @@
			}
			}


			/// <summary>
			/// 插入收支流水
			/// </summary>
			@@ -244,11 +267,9 @@
			var data = new LifePayExpensesReceipts()
			{
			Id = Guid.NewGuid(),
			OrderNo = input.OrderNo,
			OutOrderNo = input.OutOrderNo,
			LifePayType = input.LifePayType,
			ExpensesReceiptsType = input.ExpensesReceiptsType,
			Amount = input.Amount,
			};

			switch (input.LifePayType)
			@@ -260,18 +281,22 @@
			if (query.Code == AlipayResultCode.Success && (query.TradeStatus == AlipayStatus.TRADESUCCESS
			\|\| query.TradeStatus == AlipayStatus.TRADECLOSED))
			{
			data.OrderNo = input.OrderNo;
			data.ExtraProperties = JsonConvert.SerializeObject(query);
			data.FinishTime = Convert.ToDateTime(query.SendPayDate);
			data.Amount = Convert.ToDecimal(query.TotalAmount);
			await _lifePayExpensesReceiptsRepository.InsertAsync(data);
			}
			}
			else
			{
			var query = await _aliPayApi.QueryAlipayTradeRefund(new OrderInQuiryInput() { OutTradeNo = input.OrderNo });
			var query = await _aliPayApi.QueryAlipayTradeRefund(new OrderInQuiryInput() { OutTradeNo = input.OrderNo, OutRefundNo = input.OutRefundNo });
			if (query.Code == AlipayResultCode.Success && query.RefundStatus == AlipayRefundStatus.Success)
			{
			data.OrderNo = input.OutRefundNo;
			data.ExtraProperties = JsonConvert.SerializeObject(query);
			data.FinishTime = Convert.ToDateTime(query.GmtRefundPay);
			data.Amount = Convert.ToDecimal(query.RefundAmount);
			await _lifePayExpensesReceiptsRepository.InsertAsync(data);
			}
			}
			@@ -282,23 +307,69 @@
			var query = await _wxPayApi.WxPayTradeQuery(input.OrderNo);
			if (query.TradeState == WxPayStatus.支付成功 \|\| query.TradeState == WxPayStatus.转入退款)
			{
			data.OrderNo = input.OrderNo;
			data.ExtraProperties = JsonConvert.SerializeObject(query);
			data.FinishTime = Convert.ToDateTime(query.SuccessTime);
			data.Amount = Convert.ToDecimal(query.Amount.Total) / 100;
			await _lifePayExpensesReceiptsRepository.InsertAsync(data);
			}
			}
			else
			{
			var query = await _wxPayApi.WxPayDomesticRefundsQuery(input.OrderNo);
			var query = await _wxPayApi.WxPayDomesticRefundsQuery(input.OutRefundNo);
			if (query.Status == WxPayRefundStatus.退款成功)
			{
			data.OrderNo = input.OutRefundNo;
			data.ExtraProperties = JsonConvert.SerializeObject(query);
			data.FinishTime = Convert.ToDateTime(query.SuccessTime);
			data.Amount = Convert.ToDecimal(query.Amount.Total) / 100;
			await _lifePayExpensesReceiptsRepository.InsertAsync(data);
			}
			}
			break;
			default: break;
			}
			}
			}

			/// <summary>
			/// 统计所有消费流水
			/// </summary>
			/// <returns></returns>
			public async Task GetAllLifePayConsumption()
			{
			var orderList = await _lifePayOrderRepository.Where(x => x.PayStatus == LifePayStatusEnum.已支付).ToListAsync();
			foreach (var item in orderList)
			{

			if (item.ACOOLYStatus != null)
			{
			switch (item.ACOOLYStatus)
			{
			case ACOOLYStatusEnum.充值中:
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值中, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			break;
			case ACOOLYStatusEnum.充值成功:
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值中, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值成功, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			break;
			case ACOOLYStatusEnum.已完成:
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值中, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			await CreatLifePayConsumption(ACOOLYStatusEnum.已完成, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			break;
			case ACOOLYStatusEnum.充值失败:
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值中, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			await CreatLifePayConsumption(ACOOLYStatusEnum.充值失败, item.OrderNo, item.ACOOLYOrderNo,
			item.PlatformDeductionAmount ?? 0, item.ChannelId, item.CreationTime, item.FinishTime);
			break;
			default: break;
			}
			}
			}
			}
			@@ -336,15 +407,14 @@
			/// 出账
			if (item.RefundOrderNo.IsNotNullOrEmpty())
			{
			if (input.LifePayType == LifePayTypeEnum.WxPay)
			{
			input.OrderNo = item.RefundOrderNo;
			}
			input.OutRefundNo = item.OrderNo;
			input.ExpensesReceiptsType = ExpensesReceiptsTypeEnum.Receipts;
			await AddLifePayExpensesReceipts(input);

			input.OutRefundNo = item.RefundOrderNo;
			input.ExpensesReceiptsType = ExpensesReceiptsTypeEnum.Receipts;
			await AddLifePayExpensesReceipts(input);
			}

			}
			}
			}
			@@ -377,5 +447,133 @@
			}
			}
			}
			#endregion

			#region 方法
			public async Task CreatLifePayConsumption(ACOOLYStatusEnum status, string orderNo, string aCOOLYOrderNo,
			decimal platformDeductionAmount, string channelId, DateTime orderCreationTime, DateTime? orderFinishTime)
			{
			LifePayConsumption lifePayConsumption = new LifePayConsumption()
			{
			OrderNo = orderNo,
			AcoolyOrderNo = aCOOLYOrderNo,
			Amount = platformDeductionAmount,
			ChannelId = channelId,
			};
			LifePayConsumption repeat = new LifePayConsumption();
			switch (status)
			{
			case ACOOLYStatusEnum.充值中:
			lifePayConsumption.FinishTime = orderCreationTime;
			lifePayConsumption.ACOOLYStatus = ACOOLYStatusEnum.充值中;
			lifePayConsumption.FrozenStatus = ConsumptionFrozenStatusEnum.Frozen;
			lifePayConsumption.Flow = ConsumptionFlowEnum.Unchanged;
			lifePayConsumption.DeductionAmount = 0;
			lifePayConsumption.FrozenAmount = lifePayConsumption.Amount;

			repeat = await _lifePayConsumption.Where(x => x.OrderNo == lifePayConsumption.OrderNo
			&& x.ACOOLYStatus == lifePayConsumption.ACOOLYStatus && x.Flow == lifePayConsumption.Flow).FirstOrDefaultAsync();
			if (repeat == null)
			{
			await _lifePayConsumption.InsertAsync(lifePayConsumption);
			}

			break;
			case ACOOLYStatusEnum.已完成:
			lifePayConsumption.FinishTime = orderFinishTime.Value;
			lifePayConsumption.ACOOLYStatus = ACOOLYStatusEnum.已完成;
			lifePayConsumption.FrozenStatus = ConsumptionFrozenStatusEnum.Thaw;
			lifePayConsumption.Flow = ConsumptionFlowEnum.Out;
			lifePayConsumption.DeductionAmount = lifePayConsumption.Amount;
			lifePayConsumption.FrozenAmount = 0;

			repeat = await _lifePayConsumption.Where(x => x.OrderNo == lifePayConsumption.OrderNo
			&& x.ACOOLYStatus == lifePayConsumption.ACOOLYStatus && x.Flow == lifePayConsumption.Flow).FirstOrDefaultAsync();
			if (repeat == null)
			{
			await _lifePayConsumption.InsertAsync(lifePayConsumption);
			}

			break;
			case ACOOLYStatusEnum.充值失败:
			lifePayConsumption.FinishTime = orderCreationTime;
			lifePayConsumption.ACOOLYStatus = ACOOLYStatusEnum.充值失败;
			lifePayConsumption.FrozenStatus = ConsumptionFrozenStatusEnum.Frozen;
			lifePayConsumption.Flow = ConsumptionFlowEnum.Unchanged;
			lifePayConsumption.DeductionAmount = 0;
			lifePayConsumption.FrozenAmount = lifePayConsumption.Amount;

			repeat = await _lifePayConsumption.Where(x => x.OrderNo == lifePayConsumption.OrderNo
			&& x.ACOOLYStatus == lifePayConsumption.ACOOLYStatus && x.Flow == lifePayConsumption.Flow).FirstOrDefaultAsync();
			if (repeat == null)
			{
			await _lifePayConsumption.InsertAsync(lifePayConsumption);
			}

			break;
			case ACOOLYStatusEnum.已退款:
			lifePayConsumption.FinishTime = orderFinishTime.Value;
			lifePayConsumption.ACOOLYStatus = ACOOLYStatusEnum.已退款;
			lifePayConsumption.FrozenStatus = ConsumptionFrozenStatusEnum.Thaw;
			lifePayConsumption.Flow = ConsumptionFlowEnum.Unchanged;
			lifePayConsumption.DeductionAmount = 0;
			lifePayConsumption.FrozenAmount = 0;

			repeat = await _lifePayConsumption.Where(x => x.OrderNo == lifePayConsumption.OrderNo
			&& x.ACOOLYStatus == lifePayConsumption.ACOOLYStatus && x.Flow == lifePayConsumption.Flow).FirstOrDefaultAsync();
			if (repeat == null)
			{
			await _lifePayConsumption.InsertAsync(lifePayConsumption);
			}

			break;

			//case ACOOLYStatusEnum.部分充值成功:
			// lifePayConsumption.FinishTime = orderCreationTime;
			// lifePayConsumption.ACOOLYStatus = ACOOLYStatusEnum.部分充值成功;
			// lifePayConsumption.FrozenStatus = ConsumptionFrozenStatusEnum.Thaw;
			// lifePayConsumption.Flow = ConsumptionFlowEnum.Unchanged;
			// lifePayConsumption.DeductionAmount = 0;
			// lifePayConsumption.FrozenAmount = lifePayConsumption.Amount;

			// repeat = await _lifePayConsumption.Where(x => x.OrderNo == lifePayConsumption.OrderNo
			// && x.ACOOLYStatus == lifePayConsumption.ACOOLYStatus && x.Flow == lifePayConsumption.Flow).FirstOrDefaultAsync();
			// if (repeat == null)
			// {
			// await _lifePayConsumption.InsertAsync(lifePayConsumption);
			// }

			// break;
			default: break;
			}
			}

			private async Task<IQueryable<LifePayChannlesRakeListOutput>> GetLifePayChannlesRakeListFilter(LifePayChannlesRakePageInput input)
			{
			var list = _lifePayChannlesRakeRepository.Where(x => x.IsDeleted == false)
			.WhereIf(input.ChannelId.IsNotNullOrEmpty(), x => x.ChannelId == input.ChannelId)
			.WhereIf(input.CreationTimeBegin.HasValue, x => x.CreationTime >= input.CreationTimeBegin)
			.WhereIf(input.CreationTimeEnd.HasValue, x => x.CreationTime <= input.CreationTimeEnd)
			.WhereIf(input.FinishTimeBegin.HasValue, x => x.FinishTime >= input.FinishTimeBegin)
			.WhereIf(input.FinishTimeEnd.HasValue, x => x.FinishTime <= input.FinishTimeEnd)

			.Select(x => new LifePayChannlesRakeListOutput()
			{
			Id = x.Id,
			OrderNo = x.OrderNo,
			PayAmount = x.PayAmount,
			ChannlesRakeRate = x.ChannlesRakeRate,
			ChannlesRakePrice = x.ChannlesRakePrice,
			ChannelId = x.ChannelId,
			FinishTime = x.FinishTime,
			CreationTime = x.CreationTime,
			});


			return list;
			}

			#endregion

			}
			}