|  |  | 
 |  |  | using static LifePayment.Domain.Shared.LifePaymentConstant; | 
 |  |  | using ZeroD.Util.Fadd; | 
 |  |  | using Nest; | 
 |  |  | using Volo.Abp.Domain.Entities; | 
 |  |  | using Volo.Abp.ObjectMapping; | 
 |  |  | using NPOI.SS.Formula.Functions; | 
 |  |  | using StackExchange.Redis; | 
 |  |  |  | 
 |  |  | namespace LifePayment.Application; | 
 |  |  |  | 
 |  |  | 
 |  |  |     private readonly IRepository<LifePayOrder, Guid> _lifePayOrderRepository; | 
 |  |  |     private readonly IRepository<LifePayUser, Guid> _lifePayUserRepository; | 
 |  |  |     private readonly IRepository<LifePayIntroInfo, Guid> _lifePayIntroInfoRepository; | 
 |  |  |     private readonly IRepository<DallyStatistics, Guid> _dallyStatisticsRepository; | 
 |  |  |     private readonly IRepository<LifePayChannles, Guid> _lifePayChannlesRep; | 
 |  |  |     private readonly IRepository<LifePayAccount, Guid> _lifePayAccount; | 
 |  |  |     private readonly IRepository<OperateHistory, Guid> _operateHistory; | 
 |  |  |     private readonly IDataFilter dataFilter; | 
 |  |  |     private readonly IChannelFilter _channelFilter; | 
 |  |  |     private readonly IAliPayApi _aliPayApi; | 
 |  |  |     private readonly IAlipayInterfaceManager _alipayInterfaceManager; | 
 |  |  |     private readonly IWxPayApi _wxPayApi; | 
 |  |  |     private readonly WxPayOption _wxPayOptions; | 
 |  |  |  | 
 |  |  | 
 |  |  |                           IRepository<LifePayUser, Guid> lifePayUserRepository, | 
 |  |  |                           IRepository<LifePayPremium, Guid> lifePayPremiumRepository, | 
 |  |  |                           IRepository<LifePayIntroInfo, Guid> lifePayIntroInfoRepository, | 
 |  |  |                           IRepository<OperateHistory, Guid> operateHistory, | 
 |  |  |                           IAliPayApi aliPayApi, | 
 |  |  |                           IAlipayInterfaceManager aliPayInterfaceManager, | 
 |  |  |                           IWxPayApi wxPayApi, | 
 |  |  |                           IOptions<WxPayOption> wxPayOptions, | 
 |  |  |                           IRepository<LifePayChannles, Guid> lifePayChannlesRep, | 
 |  |  | 
 |  |  |         _lifePayPremiumRepository = lifePayPremiumRepository; | 
 |  |  |         _lifePayIntroInfoRepository = lifePayIntroInfoRepository; | 
 |  |  |         _aliPayApi = aliPayApi; | 
 |  |  |         _alipayInterfaceManager = aliPayInterfaceManager; | 
 |  |  |         _wxPayApi = wxPayApi; | 
 |  |  |         _wxPayOptions = wxPayOptions.Value; | 
 |  |  |         _distributedEventBus = distributedEventBus; | 
 |  |  | 
 |  |  |         _lifePayAccount = lifePayAccount; | 
 |  |  |         this.dataFilter = dataFilter; | 
 |  |  |         _channelFilter = channelFilter; | 
 |  |  |         _operateHistory = operateHistory; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     #region 查询 | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /// <summary> | 
 |  |  |     /// 获取电费面值 | 
 |  |  | 
 |  |  |     /// <returns></returns> | 
 |  |  |     public async Task<PageOutput<LifePayOrderListOutput>> GetLifePayOrderPage(QueryLifePayOrderListInput input) | 
 |  |  |     { | 
 |  |  |         var channles = await _lifePayChannlesRep.Where(x => x.ChannlesName.Contains(input.KeyWords)).Select(x => x.ChannlesNum).ToListAsync(); | 
 |  |  |         var result = await (from a in _channelFilter.GetChannelLifePayOrderFilter(_lifePayOrderRepository) | 
 |  |  |                       .WhereIf(input.BeginFinishTime.HasValue, x => x.FinishTime >= input.BeginFinishTime) | 
 |  |  |                                             .WhereIf(input.EndFinishTime.HasValue, x => x.FinishTime <= input.EndFinishTime) | 
 |  |  | 
 |  |  |                                             .WhereIf(input.EndPayTime.HasValue, x => x.PayTime <= input.EndPayTime) | 
 |  |  |                                             .WhereIf(input.LifePayOrderStatus.HasValue, x => x.LifePayOrderStatus == input.LifePayOrderStatus.Value) | 
 |  |  |                                             .WhereIf(input.PayStatus.HasValue, x => x.PayStatus == input.PayStatus.Value) | 
 |  |  |                                             .WhereIf(input.ACOOLYStatus.HasValue, x => x.ACOOLYStatus == input.ACOOLYStatus.Value) | 
 |  |  |                                             .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayOrderType == input.LifePayOrderType.Value) | 
 |  |  |                                             .WhereIf(input.UserId.HasValue, x => x.UserId == input.UserId.Value) | 
 |  |  |                                             .WhereIf(input.KeyWords.IsNotNullOrEmpty(), x => x.OrderNo.Contains(input.KeyWords) || x.OutOrderNo.Contains(input.KeyWords) || x.ACOOLYOrderNo.Contains(input.KeyWords) || channles.Contains(x.ChannelId)) | 
 |  |  |                             join b in _lifePayChannlesRep on a.ChannelId equals b.ChannlesNum into temp | 
 |  |  |                             from b in temp.DefaultIfEmpty() | 
 |  |  |                             select new LifePayOrderListOutput | 
 |  |  |                             { | 
 |  |  |                                 DiscountAmount = a.DiscountAmount, | 
 |  |  |                                 FinishTime = a.FinishTime, | 
 |  |  |                                 Id = a.Id, | 
 |  |  |                                 LifePayOrderStatus = a.LifePayOrderStatus, | 
 |  |  |                                 LifePayOrderType = a.LifePayOrderType, | 
 |  |  |                                 LifePayType = a.LifePayType, | 
 |  |  |                                 OrderNo = a.OrderNo, | 
 |  |  |                                 PayAmount = a.PayAmount, | 
 |  |  |                                 PhoneNumber = a.PhoneNumber, | 
 |  |  |                                 RechargeAmount = a.RechargeAmount, | 
 |  |  |                                 UserId = a.UserId, | 
 |  |  |                                 OutOrderNo = a.OutOrderNo, | 
 |  |  |                                 PayStatus = a.PayStatus, | 
 |  |  |                                 PayTime = a.PayTime, | 
 |  |  |                                 ACOOLYOrderNo = a.ACOOLYOrderNo, | 
 |  |  |                                 RefundCredentialsImgUrl = a.RefundCredentialsImgUrl.GetOssPath(), | 
 |  |  |                                 RefundPrice = a.RefundPrice, | 
 |  |  |                                 CreationTime = a.CreationTime, | 
 |  |  |                                 RefundCheckRemark = a.RefundCheckRemark, | 
 |  |  |                                 RefundApplyRemark = a.RefundApplyRemark, | 
 |  |  |                                 RefundTime = a.RefundTime, | 
 |  |  |                                 ChannelName = b.ChannlesName, | 
 |  |  |                                 ActualRechargeAmount = a.ActualRechargeAmount, | 
 |  |  |                                 PlatformDeductionAmount = a.PlatformDeductionAmount, | 
 |  |  |                                 ACOOLYStatus = a.ACOOLYStatus, | 
 |  |  |                                 LifePayRefundStatus = a.LifePayRefundStatus, | 
 |  |  |                             }).GetPageResult(input.PageModel); | 
 |  |  |  | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /// <summary> | 
 |  |  |     /// 退款订单分页 | 
 |  |  |     /// </summary> | 
 |  |  |     /// <param name="input"></param> | 
 |  |  |     /// <returns></returns> | 
 |  |  |     public async Task<PageOutput<LifePayOrderListOutput>> GetLifePayRefundOrderPage(QueryLifePayRefundOrderListInput input) | 
 |  |  |     { | 
 |  |  |  | 
 |  |  |         var result = await (from a in _channelFilter.GetChannelLifePayOrderFilter(_lifePayOrderRepository) | 
 |  |  |         .Where(x => x.LifePayOrderStatus == LifePayOrderStatusEnum.待退款 || x.LifePayOrderStatus == LifePayOrderStatusEnum.已退款 || x.LifePayOrderStatus == LifePayOrderStatusEnum.退款中 | 
 |  |  |         || x.LifePayRefundStatus > LifePayRefundStatusEnum.无需退款) | 
 |  |  |                                             .WhereIf(input.BeginFinishTime.HasValue, x => x.FinishTime >= input.BeginFinishTime) | 
 |  |  |                                             .WhereIf(input.EndFinishTime.HasValue, x => x.FinishTime <= input.EndFinishTime) | 
 |  |  |                                             .WhereIf(input.BeginRefundApplyTime.HasValue, x => x.RefundApplyTime >= input.BeginRefundApplyTime) | 
 |  |  |                                             .WhereIf(input.LifePayType.HasValue, x => x.LifePayType == input.LifePayType) | 
 |  |  |                                             .WhereIf(input.EndRefundApplyTime.HasValue, x => x.RefundApplyTime <= input.EndRefundApplyTime) | 
 |  |  |                                             .WhereIf(input.LifePayOrderStatus.HasValue, x => x.LifePayOrderStatus == input.LifePayOrderStatus.Value) | 
 |  |  |                                             .WhereIf(input.ACOOLYStatus.HasValue, x => x.ACOOLYStatus == input.ACOOLYStatus.Value) | 
 |  |  |                                             .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayOrderType == input.LifePayOrderType.Value) | 
 |  |  |                                             .WhereIf(input.UserId.HasValue, x => x.UserId == input.UserId.Value) | 
 |  |  |                                             .WhereIf(input.KeyWords.IsNotNullOrEmpty(), x => x.PhoneNumber.Contains(input.KeyWords) || x.OrderNo.Contains(input.KeyWords) || x.OutOrderNo.Contains(input.KeyWords) || x.ACOOLYOrderNo.Contains(input.KeyWords)) | 
 |  |  | 
 |  |  |                                 CreationTime = a.CreationTime, | 
 |  |  |                                 RefundCheckRemark = a.RefundCheckRemark, | 
 |  |  |                                 RefundApplyRemark = a.RefundApplyRemark, | 
 |  |  |                                 RefundApplyTime = a.RefundApplyTime, | 
 |  |  |                                 RefundTime = a.RefundTime, | 
 |  |  |                                 RefundPrice = a.RefundPrice, | 
 |  |  |                                 ChannelName = b.ChannlesName, | 
 |  |  |                                 ActualRechargeAmount = a.ActualRechargeAmount, | 
 |  |  |                                 PlatformDeductionAmount = a.PlatformDeductionAmount, | 
 |  |  | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /// <summary> | 
 |  |  |     /// 退款订单分页 | 
 |  |  |     /// </summary> | 
 |  |  |     /// <param name="input"></param> | 
 |  |  |     /// <returns></returns> | 
 |  |  |     public async Task<List<LifePayOrderListTemplate>> GetLifePayRefudOrderPageExport(QueryLifePayRefundOrderListInput input) | 
 |  |  |     { | 
 |  |  |  | 
 |  |  |       | 
 |  |  |         var result = await (await GetLifePayRefundOrderListFilter(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, | 
 |  |  |             PhoneNumber = x.PhoneNumber, | 
 |  |  |             RechargeAmount = x.RechargeAmount, | 
 |  |  |             OutOrderNo = x.OutOrderNo, | 
 |  |  |             PayStatus = x.PayStatus, | 
 |  |  |             PayTime = x.PayTime, | 
 |  |  |             ACOOLYOrderNo = x.ACOOLYOrderNo, | 
 |  |  |             CreationTime = x.CreationTime, | 
 |  |  |             RefundApplyRemark = x.RefundApplyRemark, | 
 |  |  |             ChannelName = x.ChannelName | 
 |  |  |         }).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.yyyyMMddHHmm); | 
 |  |  |             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.yyyyMMddHHmm); | 
 |  |  |             s.LifePayTypeStr = s.LifePayType.GetDescription(); | 
 |  |  |             s.PayStatusStr = s.PayStatus.GetDescription(); | 
 |  |  |             s.LifePayOrderStatusStr = s.LifePayOrderStatus.GetDescription(); | 
 |  |  |             s.FinishTimeStr = !s.FinishTime.HasValue ? string.Empty : s.FinishTime.Value.ToString(LifePaymentConstant.DateTimeFormatStr.yyyyMMddHHmm); | 
 |  |  |         }); | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     public async Task<LifePayOrderOutput> GetLifePayOrderDetail(string orderNo) | 
 |  |  |     { | 
 |  |  |         var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync(); | 
 |  |  |         var platformRate = await _lifePayRateRepository.FirstOrDefaultAsync(r => r.RateType == LifePayRateTypeEnum.供应商折扣价); | 
 |  |  |         var channle = await _lifePayChannlesRep.FirstOrDefaultAsync(r => r.ChannlesNum == order.ChannelId); | 
 |  |  |         var premium = await _lifePayPremiumRepository.Where(x => x.IsDeleted == false && x.PremiumType == order.LifePayType).FirstOrDefaultAsync(); | 
 |  |  |         CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在"); | 
 |  |  |          CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在"); | 
 |  |  |         var user = await _lifePayUserRepository.FirstOrDefaultAsync(x => x.Id == order.UserId); | 
 |  |  |          | 
 |  |  |         var channlesRakePrice = (order.PayAmount - (order.PlatformDeductionAmount == null ? 0 : order.PlatformDeductionAmount)) * channle.ChannlesRakeRate / 100; | 
 |  |  | 
 |  |  |             Id = order.Id, | 
 |  |  |             OutOrderNo = order.OutOrderNo, | 
 |  |  |             LifePayChannle = channle.ChannlesName, | 
 |  |  |             LifePayOrderStatus = order.LifePayOrderStatus, | 
 |  |  |             Status = order.LifePayOrderStatus, | 
 |  |  |             LifePayOrderType = order.LifePayOrderType, | 
 |  |  |             LifePayType = order.LifePayType, | 
 |  |  |             OrderNo = order.OrderNo, | 
 |  |  | 
 |  |  |             LifePayRefundStatus = order.LifePayRefundStatus, | 
 |  |  |             ActualRechargeAmount = order.ActualRechargeAmount, | 
 |  |  |             RefundPrice = order.RefundPrice, | 
 |  |  |             PlatformRate = platformRate.Rate, | 
 |  |  |             PlatformRate = order.PlatformRate, | 
 |  |  |             PlatformPrice = order.PlatformDeductionAmount, | 
 |  |  |             ElecBillUrl = order.ElecBillUrl.GetOssPath(), | 
 |  |  |             RefundElecBillUrl = order.RefundElecBillUrl.GetOssPath(), | 
 |  |  |             ChannleRate = channle.ChannlesRate, | 
 |  |  |             ChannlesRakeRate = channle.ChannlesRakeRate, | 
 |  |  |             ChannlesRakePrice = channlesRakePrice.HasValue ? 0 : Math.Round(channlesRakePrice.Value, 2), | 
 |  |  |             PremiumRate = premium == null ? 0 : premium.Rate, | 
 |  |  |             PremiumPrice = premium == null ? 0 : Math.Round(order.PayAmount * premium.Rate, 2), | 
 |  |  |             Profit = (order.PayAmount - order.PlatformDeductionAmount) * (1.00m - channle.ChannlesRakeRate / 100) - (premium == null ? 0 : Math.Round(order.PayAmount * premium.Rate, 2)) | 
 |  |  |             PremiumRate = order.PremiumRate, | 
 |  |  |             PremiumPrice = Math.Round(order.PayAmount * (order.PremiumRate.HasValue ? order.PremiumRate.Value:0), 2), | 
 |  |  |             Profit = (order.PayAmount - order.PlatformDeductionAmount) * (1.00m - channle.ChannlesRakeRate / 100) - Math.Round(order.PayAmount * (order.PremiumRate.HasValue ? order.PremiumRate.Value : 0), 2) | 
 |  |  |         }; | 
 |  |  |  | 
 |  |  |         return result; | 
 |  |  | 
 |  |  |             Id = order.Id, | 
 |  |  |             OutOrderNo = order.OutOrderNo, | 
 |  |  |             LifePayChannle = channle.ChannlesName, | 
 |  |  |             LifePayOrderStatus = order.LifePayOrderStatus, | 
 |  |  |             Status = order.LifePayOrderStatus, | 
 |  |  |             LifePayOrderType = order.LifePayOrderType, | 
 |  |  |             LifePayType = order.LifePayType, | 
 |  |  |             OrderNo = order.OrderNo, | 
 |  |  | 
 |  |  |             CreationTime = order.CreationTime, | 
 |  |  |             RefundCheckRemark = order.RefundCheckRemark, | 
 |  |  |             RefundApplyRemark = order.RefundApplyRemark, | 
 |  |  |             RefundApplyTime = order.RefundApplyTime, | 
 |  |  |             RefundTime = order.RefundTime, | 
 |  |  |             RefundOrderNo = order.RefundOrderNo, | 
 |  |  |             ACOOLYOrderNo = order.ACOOLYOrderNo, | 
 |  |  |             LifePayRefundStatus = order.LifePayRefundStatus, | 
 |  |  |             ActualRechargeAmount = order.ActualRechargeAmount, | 
 |  |  |             ActualReceivedAmount = order.ActualReceivedAmount, | 
 |  |  |             RefundPrice = order.RefundPrice, | 
 |  |  |             ElecBillUrl = order.ElecBillUrl.GetOssPath(), | 
 |  |  |             RefundElecBillUrl = order.RefundElecBillUrl.GetOssPath(), | 
 |  |  |         }; | 
 |  |  |  | 
 |  |  |         return result; | 
 |  |  | 
 |  |  |                                                         RefundApplyRemark = x.RefundApplyRemark, | 
 |  |  |                                                         RefundTime = x.RefundTime, | 
 |  |  |                                                         ACOOLYOrderNo = x.ACOOLYOrderNo, | 
 |  |  |                                                         LifePayRefundStatus = x.LifePayRefundStatus, | 
 |  |  |                                                         ACOOLYStatus = x.ACOOLYStatus, | 
 |  |  |                                                     }) | 
 |  |  |                                             .GetPageResult(input.PageModel); | 
 |  |  |     } | 
 |  |  | 
 |  |  |         }); | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |     public async Task<string> GetBillErceiptExport(string orderNo) | 
 |  |  |     { | 
 |  |  |         try | 
 |  |  |         { | 
 |  |  |             var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync(); | 
 |  |  |  | 
 |  |  |             CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "未找到订单信息"); | 
 |  |  |             if (order.LifePayType == LifePayTypeEnum.AliPay) | 
 |  |  |             { | 
 |  |  |                 var elecInfoInput = new DataBillErceiptApplyInput | 
 |  |  |                 { | 
 |  |  |                     Type = "FUND_DETAIL", | 
 |  |  |                     Key = order.OutOrderNo | 
 |  |  |                 }; | 
 |  |  |  | 
 |  |  |                 var elecInfoOutput = await _alipayInterfaceManager.DataBillErceiptApply(elecInfoInput); | 
 |  |  |                 if (elecInfoOutput != null) | 
 |  |  |                 { | 
 |  |  |                     var elecFileInput = new DataBillEreceiptQueryInput | 
 |  |  |                     { | 
 |  |  |                         FileId = elecInfoOutput.FileId, | 
 |  |  |                     }; | 
 |  |  |                     var elecFileOutput = await _alipayInterfaceManager.DataBillEreceiptQuery(elecFileInput); | 
 |  |  |                     if (!string.IsNullOrEmpty(elecFileOutput.DownloadUrl)) | 
 |  |  |                     { | 
 |  |  |                         return elecFileOutput.DownloadUrl; | 
 |  |  |                     } | 
 |  |  |                     return ""; | 
 |  |  |                 } | 
 |  |  |                 return ""; | 
 |  |  |             } | 
 |  |  |             else | 
 |  |  |             { | 
 |  |  |                 WxPayTradeBillApplyRequest req = new WxPayTradeBillApplyRequest | 
 |  |  |                 { | 
 |  |  |                     OutBillNo = order.OutOrderNo, | 
 |  |  |                 }; | 
 |  |  |  | 
 |  |  |                 var res = await _wxPayApi.WxPayTradeBillApply(req); | 
 |  |  |                 return ""; | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         catch (Exception ex) | 
 |  |  |         { | 
 |  |  |             _logger.LogError("获取订单号为{0}电子回单出现错误:{1}", orderNo, ex.Message); | 
 |  |  |             return ""; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |     #endregion | 
 |  |  |  | 
 |  |  |     #region 操作 | 
 |  |  | 
 |  |  |  | 
 |  |  |         var amount = CalculateAmount(input.ProductData.ParValue, rate.FirstOrDefault(x => x.RateType == LifePayRateTypeEnum.默认话费折扣).Rate); | 
 |  |  |  | 
 |  |  |         var platformRate = await _lifePayRateRepository.FirstOrDefaultAsync(r => r.RateType == LifePayRateTypeEnum.供应商折扣价); | 
 |  |  |          | 
 |  |  |  | 
 |  |  |         var orderInput = new CreateLifePayOrderInput | 
 |  |  |         { | 
 |  |  |             OrderNo = channle.ChannlesNum + CreateOrderNo(), | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.待确认, | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.充值中, | 
 |  |  |             LifePayOrderType = LifePayOrderTypeEnum.话费订单, | 
 |  |  |             //LifePayType = input.LifePayType, | 
 |  |  |             OrderParamDetailJsonStr = JsonConvert.SerializeObject(input.ProductData), | 
 |  |  | 
 |  |  |             PayAmount = amount.PayAmont, | 
 |  |  |             DiscountAmount = amount.DiscountAmount, | 
 |  |  |             RechargeAmount = amount.RechargeAmount, | 
 |  |  |             ChannelId = channle.ChannlesNum | 
 |  |  |             ChannelId = channle.ChannlesNum, | 
 |  |  |             PlatformRate = platformRate.Rate, | 
 |  |  |             ChannleRate = channle.ChannlesRate, | 
 |  |  |             ChannlesRakeRate = channle.ChannlesRakeRate, | 
 |  |  |         }; | 
 |  |  |  | 
 |  |  |         await CreateLifePayOrder(orderInput); | 
 |  |  | 
 |  |  |  | 
 |  |  |         var amount = CalculateAmount(input.ProductData.ParValue, rate.FirstOrDefault(x => x.RateType == LifePayRateTypeEnum.默认电费折扣).Rate); | 
 |  |  |  | 
 |  |  |         var platformRate = await _lifePayRateRepository.FirstOrDefaultAsync(r => r.RateType == LifePayRateTypeEnum.供应商折扣价); | 
 |  |  |  | 
 |  |  |         var orderInput = new CreateLifePayOrderInput | 
 |  |  |         { | 
 |  |  |             OrderNo = channle.ChannlesNum + CreateOrderNo(), | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.待确认, | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.充值中, | 
 |  |  |             LifePayOrderType = LifePayOrderTypeEnum.电费订单, | 
 |  |  |             // LifePayType = input.LifePayType, | 
 |  |  |             OrderParamDetailJsonStr = JsonConvert.SerializeObject(input.ProductData), | 
 |  |  | 
 |  |  |             PayAmount = amount.PayAmont, | 
 |  |  |             DiscountAmount = amount.DiscountAmount, | 
 |  |  |             RechargeAmount = amount.RechargeAmount, | 
 |  |  |             ChannelId = channle.ChannlesNum | 
 |  |  |             ChannelId = channle.ChannlesNum, | 
 |  |  |             PlatformRate = platformRate.Rate, | 
 |  |  |             ChannleRate = channle.ChannlesRate, | 
 |  |  |             ChannlesRakeRate = channle.ChannlesRakeRate, | 
 |  |  |         }; | 
 |  |  |  | 
 |  |  |         await CreateLifePayOrder(orderInput); | 
 |  |  | 
 |  |  |  | 
 |  |  |         var amount = CalculateAmount(input.ProductData.ParValue, rate.FirstOrDefault(x => x.RateType == LifePayRateTypeEnum.默认燃气折扣).Rate); | 
 |  |  |  | 
 |  |  |         var platformRate = await _lifePayRateRepository.FirstOrDefaultAsync(r => r.RateType == LifePayRateTypeEnum.供应商折扣价); | 
 |  |  |  | 
 |  |  |         var orderInput = new CreateLifePayOrderInput | 
 |  |  |         { | 
 |  |  |             OrderNo = channle.ChannlesNum + CreateOrderNo(), | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.待确认, | 
 |  |  |             LifePayOrderStatus = LifePayOrderStatusEnum.充值中, | 
 |  |  |             LifePayOrderType = LifePayOrderTypeEnum.燃气订单, | 
 |  |  |             // LifePayType = input.LifePayType, | 
 |  |  |             OrderParamDetailJsonStr = JsonConvert.SerializeObject(input.ProductData), | 
 |  |  | 
 |  |  |         CheckExtensions.IfTrueThrowUserFriendlyException(order.LifePayType.HasValue, "当前订单已选择支付类型"); | 
 |  |  |  | 
 |  |  |         order.LifePayType = input.LifePayType; | 
 |  |  |  | 
 |  |  |         var premium = await _lifePayPremiumRepository.Where(x => x.IsDeleted == false && x.PremiumType == order.LifePayType).FirstOrDefaultAsync(); | 
 |  |  |         order.PremiumRate = premium == null ? 0 : premium.Rate; | 
 |  |  |         await _lifePayOrderRepository.UpdateAsync(order); | 
 |  |  |  | 
 |  |  |         var desc = "生活缴费-"; | 
 |  |  | 
 |  |  |                 break; | 
 |  |  |             case LifePayOrderTypeEnum.电费订单: | 
 |  |  |                 desc += "电费"; | 
 |  |  |                 break; | 
 |  |  |             case LifePayOrderTypeEnum.燃气订单: | 
 |  |  |                 desc += "燃气"; | 
 |  |  |                 break; | 
 |  |  |             default: | 
 |  |  |                 break; | 
 |  |  | 
 |  |  |                     break; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             order.LifePayOrderStatus = LifePayOrderStatusEnum.待确认; | 
 |  |  |             order.LifePayRefundStatus = LifePayRefundStatusEnum.无需退款; | 
 |  |  |             order.LifePayOrderStatus = LifePayOrderStatusEnum.充值中; | 
 |  |  |             //SetOrderStatus(order, result.Code); | 
 |  |  |             order.OutRequestNo = result.RequestNo.IsNullOrEmpty() ? null : result.RequestNo; | 
 |  |  |             order.ACOOLYOrderNo = result.ACOOLYOrderNo.IsNullOrEmpty() ? null : result.ACOOLYOrderNo; | 
 |  |  | 
 |  |  |         catch (Exception ex) | 
 |  |  |         { | 
 |  |  |             _logger.LogError(ex, "处理生活缴费支付成功回调时异常"); | 
 |  |  |             order.LifePayOrderStatus = LifePayOrderStatusEnum.已失败; | 
 |  |  |             order.PayStatus = LifePayStatusEnum.待退款; | 
 |  |  |             order.LifePayOrderStatus = LifePayOrderStatusEnum.待退款; | 
 |  |  |             order.LifePayRefundStatus = LifePayRefundStatusEnum.待退款; | 
 |  |  |         } | 
 |  |  |         _logger.LogError("生活缴费订单状态:" + order.LifePayOrderStatus.ToString()); | 
 |  |  |         await _lifePayOrderRepository.UpdateAsync(order); | 
 |  |  | 
 |  |  |         var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync(); | 
 |  |  |         CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在"); | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成) | 
 |  |  |         { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         //if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成) | 
 |  |  |         //{ | 
 |  |  |         //    return; | 
 |  |  |         //} | 
 |  |  |  | 
 |  |  |         order.LifePayOrderStatus = status; | 
 |  |  |         order.ACOOLYStatus = acoolyStatus; | 
 |  |  |         order.PlatformDeductionAmount = payAmount; | 
 |  |  |         if (acoolyOrderNo.IsNotNullOrEmpty()) | 
 |  |  |         { | 
 |  |  |             order.ACOOLYOrderNo = acoolyOrderNo; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成) | 
 |  |  |         { | 
 |  |  |             order.FinishTime = DateTime.Now; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已失败 && order.PayStatus != LifePayStatusEnum.已退款) | 
 |  |  |         { | 
 |  |  |             order.PayStatus = LifePayStatusEnum.待退款; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         order.LifePayOrderStatus = status; | 
 |  |  |         order.ACOOLYStatus = acoolyStatus; | 
 |  |  |  | 
 |  |  |         await _lifePayOrderRepository.UpdateAsync(order); | 
 |  |  |     } | 
 |  |  | 
 |  |  |         var order = await _lifePayOrderRepository.FirstOrDefaultAsync(x => x.Id == input.Id); | 
 |  |  |         CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在"); | 
 |  |  |  | 
 |  |  |         if (order.PayStatus == LifePayStatusEnum.已退款) | 
 |  |  |         if (order.LifePayRefundStatus == LifePayRefundStatusEnum.已退款) | 
 |  |  |         { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus != LifePayOrderStatusEnum.已失败 && order.PayStatus != LifePayStatusEnum.待退款 && order.LifePayOrderStatus != LifePayOrderStatusEnum.退款待审核) | 
 |  |  |         if (input.RefundPrice > order.PayAmount) | 
 |  |  |         { | 
 |  |  |             throw new UserFriendlyException("退款的金额不能大于实付金额"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (input.LifePayRefundType == LifePayRefundTypeEnum.全额退款) | 
 |  |  |         { | 
 |  |  |             input.RefundPrice = order.PayAmount; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus != LifePayOrderStatusEnum.待退款 || order.PayStatus != LifePayStatusEnum.已支付 || order.LifePayRefundStatus != LifePayRefundStatusEnum.待退款) | 
 |  |  |         { | 
 |  |  |             throw new UserFriendlyException("当前订单状态无法退款"); | 
 |  |  |         } | 
 |  |  | 
 |  |  |         switch (order.LifePayType) | 
 |  |  |         { | 
 |  |  |             case LifePayTypeEnum.WxPay: | 
 |  |  |                 var wxRefundResult = await WxPayDomesticRefunds(order.OrderNo, outRefundNo,order.RefundApplyRemark, Convert.ToInt32(order.PayAmount * 100), Convert.ToInt32(order.PayAmount * 100)); | 
 |  |  |                 var wxRefundResult = await WxPayDomesticRefunds(order.OrderNo, outRefundNo,order.RefundApplyRemark, Convert.ToInt32(input.RefundPrice * 100), Convert.ToInt32(order.PayAmount * 100)); | 
 |  |  |                 if (wxRefundResult.Status == "SUCCESS") | 
 |  |  |                 { | 
 |  |  |                     order.PayStatus = LifePayStatusEnum.已退款; | 
 |  |  |                     order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款; | 
 |  |  |                     order.LifePayRefundStatus = LifePayRefundStatusEnum.已退款; | 
 |  |  |                 } | 
 |  |  |                 else if (wxRefundResult.Status == "PROCESSING") | 
 |  |  |                 { | 
 |  |  |                     order.PayStatus = LifePayStatusEnum.退款中; | 
 |  |  |                     order.LifePayOrderStatus = LifePayOrderStatusEnum.退款中; | 
 |  |  |                     order.LifePayRefundStatus = LifePayRefundStatusEnum.退款中; | 
 |  |  |                 } | 
 |  |  |                 else | 
 |  |  |                 { | 
 |  |  |                     throw new UserFriendlyException("退款失败"); | 
 |  |  |                     order.LifePayOrderStatus = LifePayOrderStatusEnum.待退款; | 
 |  |  |                     order.LifePayRefundStatus = LifePayRefundStatusEnum.待退款; | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 break; | 
 |  |  |             case LifePayTypeEnum.AliPay: | 
 |  |  |                 var aliRefundResult = await AliTradeRefund(new AlipayTradeRefundRequest() { OutTradeNo = order.OrderNo, RefundAmount = order.PayAmount.ToString() }); | 
 |  |  |                 var aliRefundResult = await AliTradeRefund(new AlipayTradeRefundRequest() { OutTradeNo = order.OrderNo, RefundAmount = Convert.ToInt32(input.RefundPrice * 100).ToString() }); | 
 |  |  |                 if (aliRefundResult.Code != AlipayResultCode.Success) | 
 |  |  |                 { | 
 |  |  |                     throw new UserFriendlyException("退款失败"); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 order.PayStatus = LifePayStatusEnum.已退款; | 
 |  |  |                 order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款; | 
 |  |  |                 break; | 
 |  |  |             default: throw new UserFriendlyException("退款失败"); | 
 |  |  | 
 |  |  |         order.RefundCheckRemark = input.RefundCheckRemark; | 
 |  |  |         order.RefundTime = DateTime.Now; | 
 |  |  |         order.RefundCheckUserId = CurrentUser.Id; | 
 |  |  |         order.RefundPrice = order.PayAmount; | 
 |  |  |         order.RefundPrice = input.RefundPrice; | 
 |  |  |  | 
 |  |  |         await _lifePayOrderRepository.UpdateAsync(order); | 
 |  |  |  | 
 |  |  |         #region 记录日志 | 
 |  |  |  | 
 |  |  |         await PublishLifePayOrderHistoryEvent("退款", "退款", order.Id); | 
 |  |  |         await LifePayOrderHistory("退款", "退款", order.Id, (int)OperateHistoryTypeEnum.LifePayRefund); | 
 |  |  |  | 
 |  |  |         #endregion | 
 |  |  |  | 
 |  |  | 
 |  |  |             throw new UserFriendlyException("非用户本人退款"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.PayStatus == LifePayStatusEnum.已退款) | 
 |  |  |         if (order.LifePayRefundStatus == LifePayRefundStatusEnum.已退款) | 
 |  |  |         { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (order.LifePayOrderStatus != LifePayOrderStatusEnum.待确认 && order.LifePayOrderStatus != LifePayOrderStatusEnum.已失败 | 
 |  |  |             && order.PayStatus != LifePayStatusEnum.已支付) | 
 |  |  |         if (order.PayStatus != LifePayStatusEnum.已支付 || order.LifePayOrderStatus != LifePayOrderStatusEnum.已完成) | 
 |  |  |         { | 
 |  |  |             throw new UserFriendlyException("当前订单状态无法申请退款"); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         order.LifePayOrderStatus = LifePayOrderStatusEnum.退款待审核; | 
 |  |  |         order.LifePayOrderStatus = LifePayOrderStatusEnum.待退款; | 
 |  |  |         order.RefundApplyRemark = input.RefundApplyRemark; | 
 |  |  |         order.RefundApplyTime = DateTime.Now; | 
 |  |  |  | 
 |  |  | 
 |  |  |         var order = await _lifePayOrderRepository.FirstOrDefaultAsync(x => x.Id == input.Id); | 
 |  |  |         CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "订单不存在"); | 
 |  |  |  | 
 |  |  |         if (order.PayStatus == LifePayStatusEnum.已退款) | 
 |  |  |         if(order.LifePayRefundStatus == LifePayRefundStatusEnum.已退款) | 
 |  |  |         { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if ((order.LifePayOrderStatus == LifePayOrderStatusEnum.已失败 && order.PayStatus == LifePayStatusEnum.待退款) || | 
 |  |  |             order.LifePayOrderStatus == LifePayOrderStatusEnum.退款待审核 || order.LifePayOrderStatus == LifePayOrderStatusEnum.待确认) | 
 |  |  |         if (order.LifePayOrderStatus == LifePayOrderStatusEnum.待退款) | 
 |  |  |         { | 
 |  |  |             order.LifePayOrderStatus = LifePayOrderStatusEnum.退款失败; | 
 |  |  |             if (order.ACOOLYStatus == ACOOLYStatusEnum.已完成 || order.ACOOLYStatus == ACOOLYStatusEnum.部分充值成功) | 
 |  |  |             { | 
 |  |  |                 order.LifePayOrderStatus = LifePayOrderStatusEnum.已完成; | 
 |  |  |             } | 
 |  |  |             else if (order.ACOOLYStatus == ACOOLYStatusEnum.充值失败) | 
 |  |  |             { | 
 |  |  |                 order.LifePayOrderStatus = LifePayOrderStatusEnum.退款失败; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             order.RefundCheckRemark = input.RefundCheckRemark; | 
 |  |  |             order.RefundCheckUserId = CurrentUser.Id; | 
 |  |  |  | 
 |  |  | 
 |  |  |                 order.FinishTime = DateTime.Now; | 
 |  |  |                 break; | 
 |  |  |             case ACOOLYConstant.Code.PROCESSING: | 
 |  |  |                 order.LifePayOrderStatus = LifePayOrderStatusEnum.待确认; | 
 |  |  |                 order.LifePayOrderStatus = LifePayOrderStatusEnum.充值中; | 
 |  |  |                 break; | 
 |  |  |             default: | 
 |  |  |                 break; | 
 |  |  | 
 |  |  |         }; | 
 |  |  |  | 
 |  |  |         await _distributedEventBus.PublishAsync(recordEto, false); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private async Task LifePayOrderHistory(string operateContent, string operateName, Guid relationId, int? tableType = (int)OperateHistoryTypeEnum.LifePayRefund) | 
 |  |  |     { | 
 |  |  |         var operateHistory = new OperateHistory | 
 |  |  |         { | 
 |  |  |             CreatorName = CurrentUser.Name, | 
 |  |  |             OperateContent = operateName, | 
 |  |  |             OperateName = operateName, | 
 |  |  |             RelationId = relationId, | 
 |  |  |             TableType = tableType | 
 |  |  |  | 
 |  |  |         }; | 
 |  |  |         await _operateHistory.InsertAsync(operateHistory); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /// <summary> | 
 |  |  | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private async Task<IQueryable<LifePayOrderListOutput>> GetLifePayRefundOrderListFilter(QueryLifePayRefundOrderListInput input) | 
 |  |  |     { | 
 |  |  |         var result = (from a in _channelFilter.GetChannelLifePayOrderFilter(_lifePayOrderRepository) | 
 |  |  |      .Where(x => x.LifePayOrderStatus == LifePayOrderStatusEnum.待退款 || x.LifePayOrderStatus == LifePayOrderStatusEnum.已退款 || x.LifePayOrderStatus == LifePayOrderStatusEnum.退款中 | 
 |  |  |      || x.LifePayRefundStatus > LifePayRefundStatusEnum.无需退款) | 
 |  |  |                                          .WhereIf(input.BeginFinishTime.HasValue, x => x.FinishTime >= input.BeginFinishTime) | 
 |  |  |                                          .WhereIf(input.EndFinishTime.HasValue, x => x.FinishTime <= input.EndFinishTime) | 
 |  |  |                                          .WhereIf(input.BeginRefundApplyTime.HasValue, x => x.RefundApplyTime >= input.BeginRefundApplyTime) | 
 |  |  |                                          .WhereIf(input.LifePayType.HasValue, x => x.LifePayType == input.LifePayType) | 
 |  |  |                                          .WhereIf(input.EndRefundApplyTime.HasValue, x => x.RefundApplyTime <= input.EndRefundApplyTime) | 
 |  |  |                                          .WhereIf(input.LifePayOrderStatus.HasValue, x => x.LifePayOrderStatus == input.LifePayOrderStatus.Value) | 
 |  |  |                                          .WhereIf(input.ACOOLYStatus.HasValue, x => x.ACOOLYStatus == input.ACOOLYStatus.Value) | 
 |  |  |                                          .WhereIf(input.LifePayOrderType.HasValue, x => x.LifePayOrderType == input.LifePayOrderType.Value) | 
 |  |  |                                          .WhereIf(input.UserId.HasValue, x => x.UserId == input.UserId.Value) | 
 |  |  |                                          .WhereIf(input.KeyWords.IsNotNullOrEmpty(), x => x.PhoneNumber.Contains(input.KeyWords) || x.OrderNo.Contains(input.KeyWords) || x.OutOrderNo.Contains(input.KeyWords) || x.ACOOLYOrderNo.Contains(input.KeyWords)) | 
 |  |  |                             join b in _lifePayChannlesRep on a.ChannelId equals b.ChannlesNum into temp | 
 |  |  |                             from b in temp.DefaultIfEmpty() | 
 |  |  |                             select new LifePayOrderListOutput | 
 |  |  |                             { | 
 |  |  |                                 DiscountAmount = a.DiscountAmount, | 
 |  |  |                                 FinishTime = a.FinishTime, | 
 |  |  |                                 Id = a.Id, | 
 |  |  |                                 LifePayOrderStatus = a.LifePayOrderStatus, | 
 |  |  |                                 LifePayOrderType = a.LifePayOrderType, | 
 |  |  |                                 LifePayType = a.LifePayType, | 
 |  |  |                                 OrderNo = a.OrderNo, | 
 |  |  |                                 PayAmount = a.PayAmount, | 
 |  |  |                                 PhoneNumber = a.PhoneNumber, | 
 |  |  |                                 RechargeAmount = a.RechargeAmount, | 
 |  |  |                                 UserId = a.UserId, | 
 |  |  |                                 OutOrderNo = a.OutOrderNo, | 
 |  |  |                                 PayStatus = a.PayStatus, | 
 |  |  |                                 PayTime = a.PayTime, | 
 |  |  |                                 ACOOLYOrderNo = a.ACOOLYOrderNo, | 
 |  |  |                                 RefundCredentialsImgUrl = a.RefundCredentialsImgUrl.GetOssPath(), | 
 |  |  |                                 CreationTime = a.CreationTime, | 
 |  |  |                                 RefundCheckRemark = a.RefundCheckRemark, | 
 |  |  |                                 RefundApplyRemark = a.RefundApplyRemark, | 
 |  |  |                                 RefundApplyTime = a.RefundApplyTime, | 
 |  |  |                                 RefundTime = a.RefundTime, | 
 |  |  |                                 RefundPrice = a.RefundPrice, | 
 |  |  |                                 ChannelName = b.ChannlesName, | 
 |  |  |                                 ActualRechargeAmount = a.ActualRechargeAmount, | 
 |  |  |                                 PlatformDeductionAmount = a.PlatformDeductionAmount, | 
 |  |  |                                 ACOOLYStatus = a.ACOOLYStatus, | 
 |  |  |                                 LifePayRefundStatus = a.LifePayRefundStatus, | 
 |  |  |                             }); | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |     private IQueryable<CreateEditPayChannelsInput> GetLifePayChannlesListFilter() | 
 |  |  |     { | 
 |  |  |         return _lifePayChannlesRep.Select(x => |