生活缴费api
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
lingling
2025-03-19 74f5570dceeb1a5a88c0a685705a9e4cc88881ce 
 LifePayment/LifePayment.Application/LifePay/LifePayService.cs


@@ -1,34 +1,25 @@


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 ZeroD.Util;


using static LifePayment.Domain.Shared.LifePaymentConstant;




namespace LifePayment.Application;




@@ -45,7 +36,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;


@@ -65,7 +56,8 @@


                          IOptions<WxPayOption> wxPayOptions,


                          IRepository<LifePayChannles, Guid> lifePayChannlesRep,


                          IRepository<LifePayAccount, Guid> lifePayAccount,


                          IDataFilter dataFilter)


                          IDataFilter dataFilter,


                          IChannelFilter channelFilter)


    {


        _logger = logger;


        _aCOOLYManager = aCOOLYManager;


@@ -81,6 +73,7 @@


        _lifePayChannlesRep = lifePayChannlesRep;


        _lifePayAccount = lifePayAccount;


        this.dataFilter = dataFilter;


        _channelFilter = channelFilter;


    }




    #region 查询


@@ -160,7 +153,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();


    }




@@ -169,13 +162,19 @@


    /// </summary>


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


    /// <returns></returns>


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


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


    {


        return await _lifePayUserRepository.Select(x =>


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


                                                   new UserListOutput()


                                                   {


                                                       Id = x.Id,


                                                       CreationChannle = string.IsNullOrEmpty(x.CreationChannleNum) ? "" : _lifePayChannlesRep.Where(c => c.ChannlesNum == x.CreationChannleNum).FirstOrDefault().ChannlesName,


                                                       LastLoginChannle = string.IsNullOrEmpty(x.LastLoginChannleNum) ? "" : _lifePayChannlesRep.Where(c => c.ChannlesNum == x.LastLoginChannleNum).FirstOrDefault().ChannlesName,


                                                       PhoneNumber = x.PhoneNumber,


                                                       Name = string.IsNullOrEmpty(x.Name) ? "" : x.Name,


                                                       CreationTime = x.CreationTime,


                                                       LastLoginTime = x.LastLoginTime


                                                   })


@@ -210,7 +209,6 @@


                                    })


                                    .GetPageResult(input.PageModel);


        }




    }




    /// <summary>


@@ -220,7 +218,8 @@


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


@@ -231,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


                            {


@@ -273,7 +272,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)


@@ -367,6 +366,7 @@


                                                    {


                                                        Id = x.Id,


                                                        ChannlesRate = x.ChannlesRate,


                                                        ChannlesRakeRate = x.ChannlesRakeRate,


                                                        ChannlesName = x.ChannlesName,


                                                        ChannlesNum = x.ChannlesNum,


                                                        Status = x.Status,


@@ -394,7 +394,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,


@@ -560,7 +560,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -604,7 +604,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -648,7 +648,7 @@


            PayAmount = amount.PayAmont,


            DiscountAmount = amount.DiscountAmount,


            RechargeAmount = amount.RechargeAmount,


            ChannelId = channle.Id


            ChannelId = channle.ChannlesNum


        };




        await CreateLifePayOrder(orderInput);


@@ -1068,6 +1068,15 @@


        await _lifePayOrderRepository.UpdateAsync(order);


    }




    /// <summary>


    /// 微信退款


    /// </summary>


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


    /// <param name="reason"></param>


    /// <param name="refund"></param>


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


    {


        WxPayDomesticRefundsRequest req = new WxPayDomesticRefundsRequest


@@ -1088,8 +1097,13 @@


        return res;


    }








    public async Task<int> AddUpdateUserAccount(AddUpdateUserAccountInput input)


    {


        var user = await _lifePayUserRepository.Where(r => r.Id == input.UserId && !r.IsDeleted).FirstOrDefaultAsync();


        CheckExtensions.IfTrueThrowUserFriendlyException(user == null, "用户不存在");




        if (input.Id.HasValue)


        {


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


@@ -1126,6 +1140,16 @@


            };


            await _lifePayAccount.InsertAsync(userAccount);


        }




        if (input.LifePayType == LifePayOrderTypeEnum.话费订单)


        {


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


            if (!string.IsNullOrEmpty(extraProperties.Name))


            {


                user.Name = extraProperties.Name;


            }


        }






        return Constant.SUCCESS;


    }


@@ -1549,7 +1573,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


                      {


@@ -1585,6 +1609,7 @@


                    {


                        Id = x.Id,


                        ChannlesRate = x.ChannlesRate,


                        ChannlesRakeRate = x.ChannlesRakeRate,


                        ChannlesName = x.ChannlesName,


                        ChannlesNum = x.ChannlesNum,


                        Status = x.Status,


@@ -1593,5 +1618,5 @@


                    });


    }




        #endregion


    }


    #endregion


}