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


@@ -28,6 +28,8 @@


using NPOI.SS.Formula.Functions;


using StackExchange.Redis;


using static Volo.Abp.Identity.Settings.IdentitySettingNames;


using static Microsoft.EntityFrameworkCore.DbLoggerCategory;


using LifePayment.Application.LifePay;




namespace LifePayment.Application;




@@ -45,6 +47,8 @@


    private readonly IRepository<LifePayChannles, Guid> _lifePayChannlesRep;


    private readonly IRepository<LifePayAccount, Guid> _lifePayAccount;


    private readonly IRepository<OperateHistory, Guid> _operateHistory;


    private readonly IRepository<LifePayChannlesRake, Guid> _lifePayChannlesRakeRepository;


    private readonly ILifePayOrderService _lifePayOrderService;


    private readonly IDataFilter dataFilter;


    private readonly IChannelFilter _channelFilter;


    private readonly IAliPayApi _aliPayApi;


@@ -63,7 +67,9 @@


                          IRepository<LifePayUser, Guid> lifePayUserRepository,


                          IRepository<LifePayPremium, Guid> lifePayPremiumRepository,


                          IRepository<LifePayIntroInfo, Guid> lifePayIntroInfoRepository,


                          IRepository<LifePayChannlesRake, Guid> lifePayChannlesRakeRepository,


                          IRepository<OperateHistory, Guid> operateHistory,


                          ILifePayOrderService lifePayOrderService,


                          IAliPayApi aliPayApi,


                          IAlipayInterfaceManager aliPayInterfaceManager,


                          IWxPayApi wxPayApi,


@@ -79,9 +85,11 @@


        _lifePayRateRepository = lifePayRateRepository;


        _lifePayOrderRepository = lifePayOrderRepository;


        _lifePayUserRepository = lifePayUserRepository;


        _lifePayChannlesRakeRepository = lifePayChannlesRakeRepository;


        _lifePayPremiumRepository = lifePayPremiumRepository;


        _lifePayIntroInfoRepository = lifePayIntroInfoRepository;


        _aliPayApi = aliPayApi;


        _lifePayOrderService = lifePayOrderService;


        _alipayInterfaceManager = aliPayInterfaceManager;


        _wxPayApi = wxPayApi;


        _wxPayOptions = wxPayOptions.Value;


@@ -197,6 +205,8 @@


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


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


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


            .WhereIf(input.LoginTimeBegin.HasValue, x => x.LastLoginTime >= input.LoginTimeBegin)


            .WhereIf(input.LoginTimeEnd.HasValue, x => x.LastLoginTime <= input.LoginTimeEnd)


                                            .Select(x =>


                                                   new UserListOutput()


                                                   {


@@ -818,6 +828,66 @@


            return "";


        }


    }




    /// <summary>


    /// 查询支付宝支付订单信息


    /// </summary>


    /// <param name="input"></param>


    /// <returns></returns>


    public async Task<AlipayTradeQueryResponse> QueryAlipayTrade(OrderInQuiryInput input)


    {


        var result = await _aliPayApi.OrderInQuiry(input);




        return result;


    }




    /// <summary>


    /// 查询支付宝退款订单信息


    /// </summary>


    /// <param name="input"></param>


    /// <returns></returns>


    public async Task<AlipayTradeFastpayRefundQueryResponse> QueryAlipayTradeRefund(OrderInQuiryInput input)


    {


        var result = await _aliPayApi.QueryAlipayTradeRefund(input);


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


        if (result.Code == AlipayResultCode.Success && result.RefundStatus == AlipayRefundStatus.Success)


        {


            order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款;


            order.LifePayRefundStatus = LifePayRefundStatusEnum.已退款;


            await _lifePayOrderService.AddLifePayExpensesReceipts(new AddLifePayExpensesReceiptsInput()


            {


                OrderNo = result.OutTradeNo,


                OutOrderNo = result.TradeNo,


                LifePayType = LifePayTypeEnum.AliPay,


                ExpensesReceiptsType = ExpensesReceiptsTypeEnum.Receipts


            });


        }




        return result;


    }




    /// <summary>


    /// 查询微信退款订单信息


    /// </summary>


    /// <param name="outTradeNo"></param>


    /// <returns></returns>


    public async Task<WxPayDomesticRefundsQueryReponse> WxPayDomesticRefundsQuery(string outTradeNo)


    {


        return await _wxPayApi.WxPayDomesticRefundsQuery(outTradeNo);


    }




    /// <summary>


    /// 查询微信订单信息


    /// </summary>


    /// <param name="outTradeNo"></param>


    /// <returns></returns>


    public async Task<WxPayTradeQueryReponse> WxPayTradeQuery(string outTradeNo)


    {


        return await _wxPayApi.WxPayTradeQuery(outTradeNo);


    }




  




    #endregion




    #region 操作


@@ -839,8 +909,9 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(channle == null, "渠道不存在");




        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.PhoneOrder && x.PayStatus == LifePayStatusEnum.已支付


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中 && x.OrderParamDetailJsonStr.Contains(input.ProductData.Phone)).ToListAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有相同手机号订单正在充值中，请勿重复充值");


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.Phone)).ToListAsync();


         CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");




        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


@@ -896,10 +967,12 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(channle == null, "渠道不存在");


        CheckExtensions.IfTrueThrowUserFriendlyException(channle.Status == LifePayChannelsStatsEnum.禁用, "渠道已被禁用");




        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.ElectricOrder && x.PayStatus == LifePayStatusEnum.已支付


         && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中


         && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中 && x.OrderParamDetailJsonStr.Contains(input.ProductData.ElectricType)


         && x.OrderParamDetailJsonStr.Contains(input.ProductData.ElectricAccount)).ToListAsync();


                CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");






        var rate = await GetLifePayRate(channle, LifePayRateTypeEnum.默认电费折扣);


@@ -951,7 +1024,7 @@


        //var rate = await GetRate();


        //CheckExtensions.IfTrueThrowUserFriendlyException(rate.IsNullOrEmpty(), "未配置折扣");


        var repeatOrder = await _lifePayOrderRepository.Where(x => x.LifePayOrderType == LifePayOrderTypeEnum.GasOrder && x.PayStatus == LifePayStatusEnum.已支付


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中


        && x.LifePayOrderStatus == LifePayOrderStatusEnum.充值中 && x.OrderParamDetailJsonStr.Contains(input.ProductData.GasOrgType)


        && x.OrderParamDetailJsonStr.Contains(input.ProductData.GasAccount)).ToListAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(repeatOrder.Count() > 0, "您有同户号订单正在充值中，请勿重复充值");




@@ -1004,8 +1077,8 @@


        //var payUrl = await GetPayQRCode(order.LifePayType.Value, order.OrderNo, desc, 0.01m, ip, input.H5Type);


        var payUrl = await GetPayQRCode(res.LifePayType, res.OrderNo, res.Desc, res.PayAmount, ip, input.H5Type);


#else


      //var payUrl = await GetPayQRCode(order.LifePayType.Value, order.OrderNo, desc, 0.01m, ip, input.H5Type);


        var payUrl = await GetPayQRCode(order.LifePayType.Value, order.OrderNo, desc, order.PayAmount??0, ip, input.H5Type);


      //var payUrl = await GetPayQRCode(res.LifePayType, res.OrderNo, res.Desc, 0.01m, ip, input.H5Type);


        var payUrl = await GetPayQRCode(res.LifePayType, res.OrderNo, res.Desc, res.PayAmount, ip, input.H5Type);


#endif




        return payUrl;


@@ -1259,7 +1332,7 @@


        await _lifePayOrderRepository.UpdateAsync(order);


    }




    public async Task WxPayDomesticRefundsHandler(string orderNo, LifePayRefundStatusEnum refundStatus)


    public async Task LifePayRefundsHandler(string orderNo, LifePayRefundStatusEnum refundStatus)


    {


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


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


@@ -1277,6 +1350,7 @@


        }


    }






    /// <summary>


    /// ACOOLYO订单通知处理


    /// </summary>


@@ -1288,10 +1362,10 @@


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


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




        //if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成)


        //{


        //    return;


        //}


        if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成 || order.LifePayOrderStatus == LifePayOrderStatusEnum.已退款)


        {


            return;


        }




        order.PlatformDeductionAmount = payAmount;


        if (acoolyOrderNo.IsNotNullOrEmpty())


@@ -1313,6 +1387,27 @@


        order.ACOOLYStatus = acoolyStatus;


        order.FinishTime = DateTime.Now;


        await _lifePayOrderRepository.UpdateAsync(order);




        if (order.LifePayOrderStatus == LifePayOrderStatusEnum.已完成)


        {


            /// 毛利


            var grossProfit = order.RechargeAmount * (order.ChannleRate - order.PlatformRate) / 100;


            /// 渠道佣金  （(充值面额 * 渠道折扣比例)-(充值面额 * 平台折扣比例)）* 佣金比例


            var channlesRakePrice = grossProfit * (order.ChannlesRakeRate) / 100;


            if (channlesRakePrice.HasValue)


            {


                LifePayChannlesRake lifePayChannlesRake = new LifePayChannlesRake()


                {


                    OrderNo = order.OrderNo,


                    PayAmount = order.PayAmount.Value,


                    ChannlesRakeRate = order.ChannlesRakeRate.Value,


                    ChannlesRakePrice = channlesRakePrice.Value,


                    FinishTime = order.FinishTime.Value,


                    ChannelId = order.ChannelId,


                };


                await _lifePayChannlesRakeRepository.InsertAsync(lifePayChannlesRake);


            }


        }


    }




    /// <summary>


@@ -1347,7 +1442,6 @@


        }




        var outRefundNo = order.ChannelId + CreateRefundOrderNo();


        order.RefundOrderNo = outRefundNo;


        switch (order.LifePayType)


        {


            case LifePayTypeEnum.WxPay:


@@ -1370,18 +1464,19 @@




                break;


            case LifePayTypeEnum.AliPay:


                var aliRefundResult = await AliTradeRefund(new AlipayTradeRefundRequest() { OutTradeNo = order.OrderNo, RefundAmount = input.RefundPrice.ToString() });


                var aliRefundResult = await AliTradeRefund(new AlipayTradeRefundRequest() { OutTradeNo = order.OrderNo, OutRefundNo = outRefundNo, RefundAmount = input.RefundPrice.ToString() });


                if (aliRefundResult.Code != AlipayResultCode.Success)


                {


                    throw new UserFriendlyException("退款失败:" + aliRefundResult.SubMsg);


                }




                order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款;


                order.LifePayRefundStatus = LifePayRefundStatusEnum.已退款;


                order.LifePayOrderStatus = LifePayOrderStatusEnum.退款中;


                order.LifePayRefundStatus = LifePayRefundStatusEnum.退款中;


                break;


            default: throw new UserFriendlyException("退款失败");


        }




        order.RefundOrderNo = outRefundNo;


        order.RefundCredentialsImgUrl = input.RefundCredentialsImgUrl;


        order.RefundCheckRemark = input.RefundCheckRemark;


        order.RefundTime = DateTime.Now;


@@ -1483,7 +1578,7 @@


            var userAccount = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.Id == input.Id)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(userAccount == null, "户号不存在");


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.Id != input.Id)


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.Id != input.Id && x.IsDeleted == false)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent != null, "户号已存在");




@@ -1497,7 +1592,7 @@


        }


        else


        {


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content)


            var repeatAccountContent = await _lifePayAccount.Where(x => x.UserId == input.UserId && x.LifePayType == input.LifePayType && x.Content == input.Content && x.IsDeleted == false)


                                            .FirstOrDefaultAsync();


            CheckExtensions.IfTrueThrowUserFriendlyException(repeatAccountContent != null, "户号已存在");


            var userAccount = new LifePayAccount


@@ -1515,7 +1610,7 @@


            await _lifePayAccount.InsertAsync(userAccount);


        }




        if (input.LifePayType == LifePayOrderTypeEnum.PhoneOrder)


        if (input.LifePayType == LifePayOrderTypeEnum.PhoneOrder || input.LifePayType == LifePayOrderTypeEnum.ElectricOrder)


        {


            var extraProperties = JsonConvert.DeserializeObject<Model_UserAccountExtraProperties>(input.ExtraProperties);


            if (!string.IsNullOrEmpty(extraProperties.Name) && extraProperties.Phone == user.PhoneNumber)


@@ -1957,7 +2052,6 @@


        return message;


    }






    private async Task<IQueryable<LifePayOrderListOutput>> GetLifePayOrderListFilter(QueryLifePayOrderListInput input)


    {


        var channles = await _lifePayChannlesRep.Where(x => x.ChannlesName.Contains(input.KeyWords)).Select(x => x.ChannlesNum).ToListAsync();


@@ -2118,6 +2212,7 @@


            return channel.ChannlesRate;


        }


    }




    public async Task<SetPayTypeReturn> SetPayType(string orderNo, LifePayTypeEnum lifePayType, string ip)


    {


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