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


@@ -1,36 +1,26 @@


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;




namespace LifePayment.Application;




@@ -47,7 +37,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 +57,8 @@


                          IOptions<WxPayOption> wxPayOptions,


                          IRepository<LifePayChannles, Guid> lifePayChannlesRep,


                          IRepository<LifePayAccount, Guid> lifePayAccount,


                          IDataFilter dataFilter)


                          IDataFilter dataFilter,


                          IChannelFilter channelFilter)


    {


        _logger = logger;


        _aCOOLYManager = aCOOLYManager;


@@ -83,6 +74,7 @@


        _lifePayChannlesRep = lifePayChannlesRep;


        _lifePayAccount = lifePayAccount;


        this.dataFilter = dataFilter;


        _channelFilter = channelFilter;


    }




    #region 查询


@@ -162,7 +154,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,7 +165,7 @@


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


                                            .Select(x =>


@@ -218,7 +210,6 @@


                                    })


                                    .GetPageResult(input.PageModel);


        }




    }




    /// <summary>


@@ -228,7 +219,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 +230,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,7 +254,10 @@


                                RefundCheckRemark = a.RefundCheckRemark,


                                RefundApplyRemark = a.RefundApplyRemark,


                                RefundTime = a.RefundTime,


                                ChannelName = b.ChannlesName


                                ChannelName = b.ChannlesName,


                                ActualRechargeAmount = a.ActualRechargeAmount,


                                PlatformDeductionAmount = a.PlatformDeductionAmount,


                                ACOOLYStatus = a.ACOOLYStatus


                            }).GetPageResult(input.PageModel);




        return result;


@@ -281,7 +275,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)


@@ -403,7 +397,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,


@@ -974,7 +968,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 +979,8 @@


        }




        order.LifePayOrderStatus = status;


        order.ACOOLYStatus = acoolyStatus;


        order.PlatformDeductionAmount = payAmount;


        if (acoolyOrderNo.IsNotNullOrEmpty())


        {


            order.ACOOLYOrderNo = acoolyOrderNo;


@@ -1024,11 +1020,39 @@


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


        }




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


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


        switch (order.LifePayType)


        {


            case LifePayTypeEnum.WxPay:


                var wxRefundResult = await WxPayDomesticRefunds(order.OrderNo, 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;


@@ -1072,7 +1096,7 @@




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


        order.RefundApplyRemark = input.RefundApplyRemark;


        order.RefundTime = DateTime.Now;


        order.RefundApplyTime = DateTime.Now;




        await _lifePayOrderRepository.UpdateAsync(order);


    }


@@ -1106,7 +1130,10 @@


        return res;


    }






    private async Task<AlipayTradeRefundResponse> AliTradeRefund(AlipayTradeRefundRequest input)


    {


        return await _aliPayApi.TradeRefund(input);


    }




    public async Task<int> AddUpdateUserAccount(AddUpdateUserAccountInput input)


    {


@@ -1501,7 +1528,6 @@


        CheckExtensions.IfTrueThrowUserFriendlyException(amount <= 0,


                                                         CustomeErrorMessage.SometingMustSometing,


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




        var res = await _wxPayApi.PayTransactionsH5(new PayTransactionsNativeH5


        {


            Appid = _wxPayOptions.AppID,


@@ -1554,6 +1580,7 @@




        return res.QrCode;


    }




    /// <summary>


    /// 构造待签名字符串


    /// </summary>


@@ -1582,7 +1609,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 +1654,5 @@


                    });


    }




        #endregion


    }


    #endregion


}