| | |
| | | using Microsoft.EntityFrameworkCore; |
| | | using ZeroD.Util; |
| | | using LifePayment.Domain; |
| | | using static LifePayment.Domain.Shared.LifePaymentConstant; |
| | | |
| | | namespace LifePayment.Application.LifePay |
| | | { |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | //public async Task<LifePayExpensesReceiptsPageOutput<LifePayExpensesReceiptsListOutput>> GetLifePayExpensesReceiptsPage(LifePayExpensesReceiptsPageInput input) |
| | | //{ |
| | | // var list = await _lifePayExpensesReceiptsRepository.Where(x => x.IsDeleted == false) |
| | | // .WhereIf(input.KeyWord.IsNotNullOrEmpty(), x => x.OrderNo.Contains(input.KeyWord)) |
| | | // .WhereIf(input.CreationTimeBegin.HasValue, x => x.CreationTime >= input.CreationTimeBegin) |
| | | // .WhereIf(input.CreationTimeEnd.HasValue, x => x.CreationTime <= input.CreationTimeEnd) |
| | | // .Select(x => new LifePayRechargeReceiptsListOutput() |
| | | // { |
| | | // Id = x.Id, |
| | | // OrderNo = x.OrderNo, |
| | | // RechargeAmount = x.RechargeAmount, |
| | | // Remark = x.Remark, |
| | | // Voucher = x.Voucher.GetOssPath(), |
| | | // CreationTime = x.CreationTime, |
| | | // }) |
| | | // .GetPageResult(input.PageModel); |
| | | |
| | | // var total = await _lifePayRechargeReceiptsRepository.Where(x => x.IsDeleted == false).SumAsync(x => x.RechargeAmount); |
| | | // LifePayRechargeReceiptsPageOutput<LifePayRechargeReceiptsListOutput> result = new LifePayRechargeReceiptsPageOutput<LifePayRechargeReceiptsListOutput>(); |
| | | // result.Data = list.Data; |
| | | // result.TotalRechargeAmount = total; |
| | | // return result; |
| | | //} |
| | | |
| | | /// <summary> |
| | | /// 插入收支流水 |
| | | /// </summary> |
| | |
| | | } |
| | | } |
| | | break; |
| | | case LifePayTypeEnum.WxPay: break; |
| | | case LifePayTypeEnum.WxPay: |
| | | if (input.ExpensesReceiptsType == ExpensesReceiptsTypeEnum.Expenses) |
| | | { |
| | | var query = await _wxPayApi.WxPayTradeQuery(input.OrderNo); |
| | | if (query.Code == AlipayResultCode.Success && query.Status == WxPayStatus.支付成功) |
| | | { |
| | | await _lifePayExpensesReceiptsRepository.InsertAsync(data); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | var query = await _wxPayApi.WxPayDomesticRefundsQuery(input.OrderNo); |
| | | if (query.Code == AlipayResultCode.Success && query.RefundStatus == WxPayRefundStatus.退款成功) |
| | | { |
| | | await _lifePayExpensesReceiptsRepository.InsertAsync(data); |
| | | } |
| | | } |
| | | break; |
| | | default: break; |
| | | } |
| | | |