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


@@ -1,36 +1,28 @@


using DynamicQuery.Net.Dto.Input;


using LifePayment.Application.Contracts;


using LifePayment.Application.Contracts;


using LifePayment.Domain;


using LifePayment.Domain.LifePay;


using LifePayment.Domain.Models;


using LifePayment.Domain.Shared;


using MailKit.Search;


using Microsoft.EntityFrameworkCore;


using Microsoft.Extensions.Logging;


using Microsoft.Extensions.Options;


using Nest;


using Newtonsoft.Json;


using NPOI.OpenXmlFormats.Dml.Chart;


using NPOI.SS.Formula.Functions;


using StackExchange.Redis;


using System;


using System.Collections.Generic;


using System.Linq;


using System.Security.Cryptography;


using System.Linq.Dynamic.Core;


using System.Threading.Tasks;


using Volo.Abp;


using Volo.Abp.Application.Services;


using Volo.Abp.Domain.Entities;


using Volo.Abp.Data;


using Volo.Abp.Domain.Repositories;


using Volo.Abp.EventBus.Distributed;


using ZeroD.Util;


using ZeroD.Util.Fadd;


using static LifePayment.Domain.Shared.LifePaymentConstant;


using Volo.Abp.Data;


using Z.EntityFramework.Plus;


using LifePayment.Domain.LifePay;


using pingan.openbank.api.sdk.enums;


using System.Linq.Dynamic.Core;


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


using ZeroD.Util;


using Alipay.EasySDK.Payment.Common.Models;


using static LifePayment.Domain.Shared.LifePaymentConstant;


using ZeroD.Util.Fadd;


using Nest;




namespace LifePayment.Application;




@@ -47,7 +39,7 @@


    private readonly IRepository<LifePayChannles, Guid> _lifePayChannlesRep;


    private readonly IRepository<LifePayAccount, Guid> _lifePayAccount;


    private readonly IDataFilter dataFilter;




    private readonly IChannelFilter _channelFilter;


    private readonly IAliPayApi _aliPayApi;


    private readonly IWxPayApi _wxPayApi;


    private readonly WxPayOption _wxPayOptions;


@@ -67,7 +59,8 @@


                          IOptions<WxPayOption> wxPayOptions,


                          IRepository<LifePayChannles, Guid> lifePayChannlesRep,


                          IRepository<LifePayAccount, Guid> lifePayAccount,


                          IDataFilter dataFilter)


                          IDataFilter dataFilter,


                          IChannelFilter channelFilter)


    {


        _logger = logger;


        _aCOOLYManager = aCOOLYManager;


@@ -83,6 +76,7 @@


        _lifePayChannlesRep = lifePayChannlesRep;


        _lifePayAccount = lifePayAccount;


        this.dataFilter = dataFilter;


        _channelFilter = channelFilter;


    }




    #region 查询


@@ -162,7 +156,7 @@


    public async Task<List<LifePayIntroInfoOutput>> GetIntroInfo(LifePayOrderTypeEnum lifePayType)


    {


        return await _lifePayIntroInfoRepository.Where(x => x.IsDeleted == false && x.LifePayType == lifePayType).OrderBy(x => x.Sequence)


            .Select(x => new LifePayIntroInfoOutput() { Type = x.Type, ContentSummary = x.ContentSummary, Content = x.Content, LifePayType = x.LifePayType,Path = x.Path,Sequence = x.Sequence })


            .Select(x => new LifePayIntroInfoOutput() { Type = x.Type, ContentSummary = x.ContentSummary, Content = x.Content, LifePayType = x.LifePayType, Path = x.Path, Sequence = x.Sequence })


                                           .ToListAsync();


    }




@@ -173,9 +167,10 @@


    /// <returns></returns>


    public async Task<PageOutput<UserListOutput>> GetUserPage(QueryUserPageInput input)


    {


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


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


                                                   {


@@ -218,7 +213,6 @@


                                    })


                                    .GetPageResult(input.PageModel);


        }




    }




    /// <summary>


@@ -228,7 +222,7 @@


    /// <returns></returns>


    public async Task<PageOutput<LifePayOrderListOutput>> GetLifePayOrderPage(QueryLifePayOrderListInput input)


    {


        var result = await (from a in _lifePayOrderRepository.Where(x => x.PayStatus != LifePayStatusEnum.未支付)


        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.BeginPayTime.HasValue, x => x.PayTime >= input.BeginPayTime)


@@ -239,7 +233,7 @@


                                            .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.Id into temp


                            join b in _lifePayChannlesRep on a.ChannelId equals b.ChannlesNum into temp


                            from b in temp.DefaultIfEmpty()


                            select new LifePayOrderListOutput


                            {


@@ -263,8 +257,103 @@


                                RefundCheckRemark = a.RefundCheckRemark,


                                RefundApplyRemark = a.RefundApplyRemark,


                                RefundTime = a.RefundTime,


                                ChannelName = b.ChannlesName


                                ChannelName = b.ChannlesName,


                                ActualRechargeAmount = a.ActualRechargeAmount,


                                PlatformDeductionAmount = a.PlatformDeductionAmount,


                                ACOOLYStatus = a.ACOOLYStatus,


                                LifePayRefundStatus = a.LifePayRefundStatus,


                            }).GetPageResult(input.PageModel);




        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, "订单不存在");


        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,


            LifePayOrderStatus = 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 = platformRate.Rate,


            PlatformPrice = order.PlatformDeductionAmount,


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


        };




        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,


            LifePayOrderStatus = 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,


            RefundTime = order.RefundTime,


            ACOOLYOrderNo = order.ACOOLYOrderNo,


            LifePayRefundStatus = order.LifePayRefundStatus,


            ActualRechargeAmount = order.ActualRechargeAmount,


            RefundPrice = order.RefundPrice,


        };




        return result;


    }


@@ -281,7 +370,7 @@


            return new PageOutput<UserLifePayOrderOutput>();


        }




        return await _lifePayOrderRepository.Where(x => x.PayStatus != LifePayStatusEnum.未支付)


        return await _channelFilter.GetChannelLifePayOrderFilter(_lifePayOrderRepository).Where(x => x.PayStatus != LifePayStatusEnum.未支付)


                                            .WhereIf(input.BeginFinishTime.HasValue, x => x.FinishTime >= input.BeginFinishTime)


                                            .WhereIf(input.EndFinishTime.HasValue, x => x.FinishTime <= input.EndFinishTime)


                                            .WhereIf(input.BeginPayTime.HasValue, x => x.PayTime >= input.BeginPayTime)


@@ -346,6 +435,8 @@


        return result;


    }








    /// <summary>


    /// 根据订单号获取支付状态


    /// </summary>


@@ -403,7 +494,7 @@




    public async Task<UserLifePayOrderRefundOutput> GetUserLifePayOrderRefund(Guid id)


    {


        var order = await _lifePayOrderRepository.Where(x => x.Id == id).Select(x =>


        var order = await _channelFilter.GetChannelLifePayOrderFilter(_lifePayOrderRepository).Where(x => x.Id == id).Select(x =>


                                                    new UserLifePayOrderRefundOutput


                                                    {


                                                        Id = x.Id,


@@ -558,7 +649,7 @@




        var orderInput = new CreateLifePayOrderInput


        {


            OrderNo = CreateOrderNo(),


            OrderNo = channle.ChannlesNum + CreateOrderNo(),


            LifePayOrderStatus = LifePayOrderStatusEnum.待确认,


            LifePayOrderType = LifePayOrderTypeEnum.话费订单,


            //LifePayType = input.LifePayType,


@@ -569,7 +660,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -602,7 +693,7 @@




        var orderInput = new CreateLifePayOrderInput


        {


            OrderNo = CreateOrderNo(),


            OrderNo = channle.ChannlesNum + CreateOrderNo(),


            LifePayOrderStatus = LifePayOrderStatusEnum.待确认,


            LifePayOrderType = LifePayOrderTypeEnum.电费订单,


            // LifePayType = input.LifePayType,


@@ -613,7 +704,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -646,7 +737,7 @@




        var orderInput = new CreateLifePayOrderInput


        {


            OrderNo = CreateOrderNo(),


            OrderNo = channle.ChannlesNum + CreateOrderNo(),


            LifePayOrderStatus = LifePayOrderStatusEnum.待确认,


            LifePayOrderType = LifePayOrderTypeEnum.燃气订单,


            // LifePayType = input.LifePayType,


@@ -657,7 +748,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -974,7 +1065,7 @@


    /// <param name="orderNo"></param>


    /// <param name="outOrderNo"></param>


    /// <returns></returns>


    public async Task ACOOLYOrderNotifyHandler(string orderNo, string acoolyOrderNo, LifePayOrderStatusEnum status)


    public async Task ACOOLYOrderNotifyHandler(string orderNo, string acoolyOrderNo, LifePayOrderStatusEnum status, ACOOLYStatusEnum acoolyStatus, decimal payAmount)


    {


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


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


@@ -985,6 +1076,8 @@


        }




        order.LifePayOrderStatus = status;


        order.ACOOLYStatus = acoolyStatus;


        order.PlatformDeductionAmount = payAmount;


        if (acoolyOrderNo.IsNotNullOrEmpty())


        {


            order.ACOOLYOrderNo = acoolyOrderNo;


@@ -999,6 +1092,7 @@


        {


            order.PayStatus = LifePayStatusEnum.待退款;


        }






        await _lifePayOrderRepository.UpdateAsync(order);


    }


@@ -1024,15 +1118,46 @@


            throw new UserFriendlyException("当前订单状态无法退款");


        }




        /// TODO 退款请求完成后如何操作


        /// var refundResult = await WxPayDomesticRefunds(order.OrderNo, order.RefundApplyRemark, Convert.ToInt32(order.PayAmount * 100), Convert.ToInt32(order.PayAmount * 100));


        var outRefundNo = order.ChannelId + CreateRefundOrderNo();


        order.RefundOrderNo = outRefundNo;


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


                if (wxRefundResult.Status == "SUCCESS")


                {


                    order.PayStatus = LifePayStatusEnum.已退款;


                    order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款;


                }


                else if (wxRefundResult.Status == "PROCESSING")


                {


                    order.PayStatus = LifePayStatusEnum.退款中;


                    order.LifePayOrderStatus = LifePayOrderStatusEnum.退款中;


                }


                else


                {


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


                }




        order.PayStatus = LifePayStatusEnum.已退款;


        order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款;


                break;


            case LifePayTypeEnum.AliPay:


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


                if (aliRefundResult.Code != AlipayResultCode.Success)


                {


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


                }




                order.PayStatus = LifePayStatusEnum.已退款;


                order.LifePayOrderStatus = LifePayOrderStatusEnum.已退款;


                break;


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


        }




        order.RefundCredentialsImgUrl = input.RefundCredentialsImgUrl;


        order.RefundCheckRemark = input.RefundCheckRemark;


        order.RefundTime = DateTime.Now;


        order.RefundCheckUserId = CurrentUser.Id;


        order.RefundPrice = order.PayAmount;




        await _lifePayOrderRepository.UpdateAsync(order);




@@ -1072,7 +1197,7 @@




        order.LifePayOrderStatus = LifePayOrderStatusEnum.退款待审核;


        order.RefundApplyRemark = input.RefundApplyRemark;


        order.RefundTime = DateTime.Now;


        order.RefundApplyTime = DateTime.Now;




        await _lifePayOrderRepository.UpdateAsync(order);


    }


@@ -1086,12 +1211,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


            {


@@ -1106,7 +1231,10 @@


        return res;


    }






    private async Task<AlipayTradeRefundResponse> AliTradeRefund(AlipayTradeRefundRequest input)


    {


        return await _aliPayApi.TradeRefund(input);


    }




    public async Task<int> AddUpdateUserAccount(AddUpdateUserAccountInput input)


    {


@@ -1378,10 +1506,10 @@


    private (decimal PayAmont, decimal DiscountAmount, decimal RechargeAmount) CalculateAmount(decimal amount, decimal rate)


    {


        /// 正常支付


        var payAmount = decimal.Round(amount * rate / 100, 2, MidpointRounding.AwayFromZero);


        //var payAmount = decimal.Round(amount * rate / 100, 2, MidpointRounding.AwayFromZero);




        /// 1分钱支付


        //decimal payAmount = 0.01m;


        decimal payAmount = 0.01m;




        CheckExtensions.IfTrueThrowUserFriendlyException(payAmount < 0.01m, "支付金额错误");




@@ -1501,7 +1629,6 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(amount <= 0,


                                                         CustomeErrorMessage.SometingMustSometing,


                                                         "获取支付二维码时金额", "大于0");




        var res = await _wxPayApi.PayTransactionsH5(new PayTransactionsNativeH5


        {


            Appid = _wxPayOptions.AppID,


@@ -1554,6 +1681,7 @@




        return res.QrCode;


    }




    /// <summary>


    /// 构造待签名字符串


    /// </summary>


@@ -1582,7 +1710,7 @@


                                            .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.Id into temp


                      join b in _lifePayChannlesRep on a.ChannelId equals b.ChannlesNum into temp


                      from b in temp.DefaultIfEmpty()


                      select new LifePayOrderListOutput


                      {


@@ -1627,5 +1755,5 @@


                    });


    }




        #endregion


    }


    #endregion


}