生活缴费api
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhengyiming
2025-03-21 a22995ea9ded904780c27319510a82275a972cab 
 LifePayment/LifePayment.Application/LifePay/LifePayService.cs


@@ -21,6 +21,12 @@


using ZeroD.Util;


using Alipay.EasySDK.Payment.Common.Models;


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;




@@ -34,11 +40,14 @@


    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;




@@ -52,7 +61,9 @@


                          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,


@@ -68,6 +79,7 @@


        _lifePayPremiumRepository = lifePayPremiumRepository;


        _lifePayIntroInfoRepository = lifePayIntroInfoRepository;


        _aliPayApi = aliPayApi;


        _alipayInterfaceManager = aliPayInterfaceManager;


        _wxPayApi = wxPayApi;


        _wxPayOptions = wxPayOptions.Value;


        _distributedEventBus = distributedEventBus;


@@ -75,9 +87,11 @@


        _lifePayAccount = lifePayAccount;


        this.dataFilter = dataFilter;


        _channelFilter = channelFilter;


        _operateHistory = operateHistory;


    }




    #region 查询






    /// <summary>


    /// 获取电费面值


@@ -167,7 +181,8 @@


    {


        return await _channelFilter.GetChannelLifePayUserFilter(_lifePayUserRepository).Where(x => x.IsDeleted == false)


            .WhereIf(!string.IsNullOrEmpty(input.QueryCondition), x => x.PhoneNumber.Contains(input.QueryCondition) || x.Name.Contains(input.QueryCondition))


            .WhereIf(input.CreationTime.HasValue, x => x.CreationTime.ToString("yyyy-MM-dd") == input.CreationTime.Value.ToString("yyyy-MM-dd"))


            .WhereIf(input.CreationTimeBegin.HasValue, x => x.CreationTime >= input.CreationTimeBegin)


            .WhereIf(input.CreationTimeEnd.HasValue, x => x.CreationTime <= input.CreationTimeEnd)


                                            .Select(x =>


                                                   new UserListOutput()


                                                   {


@@ -227,6 +242,63 @@


                                            .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.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(),


                                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))


@@ -253,7 +325,9 @@


                                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,


@@ -266,31 +340,96 @@




    public async Task<LifePayOrderOutput> GetLifePayOrderDetail(string orderNo)


    {


        var result = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo)


                                            .Select(x =>


                                                    new LifePayOrderOutput


                                                    {


                                                        DiscountAmount = x.DiscountAmount,


                                                        FinishTime = x.FinishTime,


                                                        Id = x.Id,


                                                        LifePayOrderStatus = x.LifePayOrderStatus,


                                                        LifePayOrderType = x.LifePayOrderType,


                                                        LifePayType = x.LifePayType,


                                                        OrderNo = x.OrderNo,


                                                        PayAmount = x.PayAmount,


                                                        RechargeAmount = x.RechargeAmount,


                                                        PayStatus = x.PayStatus,


                                                        PayTime = x.PayTime,


                                                        OrderParamDetailJsonStr = x.OrderParamDetailJsonStr,


                                                        RefundCredentialsImgUrl = x.RefundCredentialsImgUrl.GetOssPath(),


                                                        CreationTime = x.CreationTime,


                                                        RefundCheckRemark = x.RefundCheckRemark,


                                                        RefundApplyRemark = x.RefundApplyRemark,


                                                        RefundTime = x.RefundTime,


                                                        ACOOLYOrderNo = x.ACOOLYOrderNo,


                                                    })


                                            .FirstOrDefaultAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(result == null, "订单不存在");


        var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();


        var channle = await _lifePayChannlesRep.FirstOrDefaultAsync(r => r.ChannlesNum == order.ChannelId);


         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;


        var result = new LifePayOrderOutput()


                {


            UserName = user.Name,


            UserPhoneNumber = user.PhoneNumber,


            DiscountAmount = order.DiscountAmount,


            FinishTime = order.FinishTime,


            Id = order.Id,


            OutOrderNo = order.OutOrderNo,


            LifePayChannle = channle.ChannlesName,


            Status = order.LifePayOrderStatus,


            LifePayOrderType = order.LifePayOrderType,


            LifePayType = order.LifePayType,


            OrderNo = order.OrderNo,


            PayAmount = order.PayAmount,


            RechargeAmount = order.RechargeAmount,


            PayStatus = order.PayStatus,


            PayTime = order.PayTime,


            OrderParamDetailJsonStr = order.OrderParamDetailJsonStr,


            RefundCredentialsImgUrl = order.RefundCredentialsImgUrl.GetOssPath(),


            CreationTime = order.CreationTime,


            RefundCheckRemark = order.RefundCheckRemark,


            RefundApplyRemark = order.RefundApplyRemark,


            RefundTime = order.RefundTime,


            ACOOLYOrderNo = order.ACOOLYOrderNo,


            LifePayRefundStatus = order.LifePayRefundStatus,


            ActualRechargeAmount = order.ActualRechargeAmount,


            RefundPrice = order.RefundPrice,


            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 = 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;


    }




    public async Task<LifePayRefundOrderOutput> GetLifePayRefundOrderDetail(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, "订单不存在");


        var user = await _lifePayUserRepository.FirstOrDefaultAsync(x => x.Id == order.UserId);




        var channlesRakePrice = (order.PayAmount - (order.PlatformDeductionAmount == null ? 0 : order.PlatformDeductionAmount)) * channle.ChannlesRakeRate / 100;


        var result = new LifePayRefundOrderOutput()


        {


            UserName = user.Name,


            UserPhoneNumber = user.PhoneNumber,


            DiscountAmount = order.DiscountAmount,


            FinishTime = order.FinishTime,


            Id = order.Id,


            OutOrderNo = order.OutOrderNo,


            LifePayChannle = channle.ChannlesName,


            Status = order.LifePayOrderStatus,


            LifePayOrderType = order.LifePayOrderType,


            LifePayType = order.LifePayType,


            OrderNo = order.OrderNo,


            PayAmount = order.PayAmount,


            RechargeAmount = order.RechargeAmount,


            PayStatus = order.PayStatus,


            PayTime = order.PayTime,


            RefundCredentialsImgUrl = order.RefundCredentialsImgUrl.GetOssPath(),


            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;


    }


@@ -337,6 +476,8 @@


                                                        RefundApplyRemark = x.RefundApplyRemark,


                                                        RefundTime = x.RefundTime,


                                                        ACOOLYOrderNo = x.ACOOLYOrderNo,


                                                        LifePayRefundStatus = x.LifePayRefundStatus,


                                                        ACOOLYStatus = x.ACOOLYStatus,


                                                    })


                                            .GetPageResult(input.PageModel);


    }


@@ -558,7 +699,54 @@


        });


        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 操作


@@ -584,10 +772,13 @@




        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),


@@ -597,7 +788,10 @@


            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);


@@ -628,10 +822,12 @@




        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),


@@ -641,7 +837,10 @@


            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);


@@ -672,10 +871,12 @@




        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),


@@ -710,7 +911,8 @@


        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 = "生活缴费-";


@@ -721,6 +923,9 @@


                break;


            case LifePayOrderTypeEnum.电费订单:


                desc += "电费";


                break;


            case LifePayOrderTypeEnum.燃气订单:


                desc += "燃气";


                break;


            default:


                break;


@@ -908,10 +1113,12 @@


                OpenId = openid


            }


        };


        Logger.LogError("调用请求：" + req.ToJson());


        var timestamp = DateTimeOffset.Now.ToUnixTimeSeconds();


        string nonce = Guid.NewGuid().ToString();




        var res = await _wxPayApi.PayTransactionsJsAPI(req);


        Logger.LogError("调用结果：" + res.ToJson());


        string package = "prepay_id=" + res.PrepayId;


        ModelPaymentMiniPay info = new ModelPaymentMiniPay();


        if (res != null)


@@ -981,7 +1188,8 @@


                    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;


@@ -989,8 +1197,8 @@


        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);


@@ -1007,28 +1215,20 @@


        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);


    }


@@ -1044,44 +1244,55 @@


        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("当前订单状态无法退款");


        }




        var outRefundNo = order.ChannelId + CreateRefundOrderNo();


        order.RefundOrderNo = outRefundNo;


        switch (order.LifePayType)


        {


            case LifePayTypeEnum.WxPay:


                var wxRefundResult = await WxPayDomesticRefunds(order.OrderNo, 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("退款失败");


@@ -1091,13 +1302,13 @@


        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




@@ -1118,18 +1329,17 @@


            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;




@@ -1145,12 +1355,12 @@


    /// <param name="total"></param>


    /// <param name="currency"></param>


    /// <returns></returns>


    public async Task<WxPayDomesticRefundsReponse> WxPayDomesticRefunds(string outTradeNo, string reason, int refund, int total, string currency = "CNY")


    public async Task<WxPayDomesticRefundsReponse> WxPayDomesticRefunds(string outTradeNo,string outRefundNo, string reason, int refund, int total, string currency = "CNY")


    {


        WxPayDomesticRefundsRequest req = new WxPayDomesticRefundsRequest


        {


            OutTradeNo = outTradeNo,


            OutRefundNo = CreateRefundOrderNo(),


            OutRefundNo = outRefundNo,


            Reason = reason,


            Amount = new Model_WxPayDomesticRefunds_Amount


            {


@@ -1252,15 +1462,22 @@


        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;




@@ -1459,7 +1676,7 @@


                order.FinishTime = DateTime.Now;


                break;


            case ACOOLYConstant.Code.PROCESSING:


                order.LifePayOrderStatus = LifePayOrderStatusEnum.待确认;


                order.LifePayOrderStatus = LifePayOrderStatusEnum.充值中;


                break;


            default:


                break;


@@ -1485,6 +1702,20 @@


        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>


    /// 获取支付二维码


    /// </summary>