From fbd573b5d2d05cac61d2184064bb5dd18d0fe61f Mon Sep 17 00:00:00 2001
From: zhengyuxuan <zhengyuxuan1995>
Date: 星期四, 20 三月 2025 16:48:48 +0800
Subject: [PATCH] fix:退款订单号bug修复

---
 LifePayment/LifePayment.Application/LifePay/LifePayService.cs |  283 +++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 227 insertions(+), 56 deletions(-)

diff --git a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
index 2ea55a1..4491695 100644
--- a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
+++ b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
@@ -1,34 +1,28 @@
-锘縰sing DynamicQuery.Net.Dto.Input;
-using LifePayment.Application.Contracts;
+锘縰sing 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 Alipay.EasySDK.Payment.Common.Models;
+using static LifePayment.Domain.Shared.LifePaymentConstant;
+using ZeroD.Util.Fadd;
+using Nest;
 
 namespace LifePayment.Application;
 
@@ -45,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;
@@ -65,7 +59,8 @@
                           IOptions<WxPayOption> wxPayOptions,
                           IRepository<LifePayChannles, Guid> lifePayChannlesRep,
                           IRepository<LifePayAccount, Guid> lifePayAccount,
-                          IDataFilter dataFilter)
+                          IDataFilter dataFilter,
+                          IChannelFilter channelFilter)
     {
         _logger = logger;
         _aCOOLYManager = aCOOLYManager;
@@ -81,6 +76,7 @@
         _lifePayChannlesRep = lifePayChannlesRep;
         _lifePayAccount = lifePayAccount;
         this.dataFilter = dataFilter;
+        _channelFilter = channelFilter;
     }
 
     #region 鏌ヨ
@@ -160,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();
     }
 
@@ -169,13 +165,20 @@
     /// </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.CreationTimeBegin.HasValue, x => x.CreationTime >= input.CreationTimeBegin)
+            .WhereIf(input.CreationTimeEnd.HasValue, x => x.CreationTime <= input.CreationTimeEnd)
+                                            .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 +213,6 @@
                                     })
                                     .GetPageResult(input.PageModel);
         }
-
     }
 
     /// <summary>
@@ -220,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)
@@ -231,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
                             {
@@ -255,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.渚涘簲鍟嗘姌鎵d环);
+        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.渚涘簲鍟嗘姌鎵d环);
+        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;
     }
@@ -273,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)
@@ -338,6 +435,8 @@
         return result;
     }
 
+
+
     /// <summary>
     /// 鏍规嵁璁㈠崟鍙疯幏鍙栨敮浠樼姸鎬�
     /// </summary>
@@ -352,19 +451,12 @@
 
     public async Task<PageOutput<CreateEditPayChannelsInput>> GetLifePayChannlesPage(PageInput input)
     {
+        return await GetLifePayChannlesListFilter().GetPageResult(input.PageModel);
+    }
 
-        return await _lifePayChannlesRep.Select(x =>
-                                                new CreateEditPayChannelsInput
-                                                {
-                                                    Id = x.Id,
-                                                    ChannlesRate = x.ChannlesRate,
-                                                    ChannlesName = x.ChannlesName,
-                                                    ChannlesNum = x.ChannlesNum,
-                                                    Status = x.Status,
-                                                    SwitchType = x.SwitchType,
-                                                    ChannlesType = x.ChannlesType,
-                                                })
-                                            .GetPageResult(input.PageModel);
+    public async Task<List<CreateEditPayChannelsInput>> GetLifePayChannlesAllList()
+    {
+        return await GetLifePayChannlesListFilter().Where(x => x.Status == LifePayChannelsStatsEnum.鍚敤).ToListAsync();
     }
 
     public async Task<CreateEditPayChannelsInput> GetLifePayChannlesDto(Guid id)
@@ -374,6 +466,7 @@
                                                     {
                                                         Id = x.Id,
                                                         ChannlesRate = x.ChannlesRate,
+                                                        ChannlesRakeRate = x.ChannlesRakeRate,
                                                         ChannlesName = x.ChannlesName,
                                                         ChannlesNum = x.ChannlesNum,
                                                         Status = x.Status,
@@ -389,6 +482,7 @@
                                                     {
                                                         Id = x.Id,
                                                         ChannlesRate = x.ChannlesRate,
+                                                        ChannlesRakeRate = x.ChannlesRakeRate,
                                                         ChannlesName = x.ChannlesName,
                                                         ChannlesNum = x.ChannlesNum,
                                                         Status = x.Status,
@@ -400,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,
@@ -555,7 +649,7 @@
 
         var orderInput = new CreateLifePayOrderInput
         {
-            OrderNo = CreateOrderNo(),
+            OrderNo = channle.ChannlesNum + CreateOrderNo(),
             LifePayOrderStatus = LifePayOrderStatusEnum.寰呯‘璁�,
             LifePayOrderType = LifePayOrderTypeEnum.璇濊垂璁㈠崟,
             //LifePayType = input.LifePayType,
@@ -566,7 +660,7 @@
             PayAmount = amount.PayAmont,
             DiscountAmount = amount.DiscountAmount,
             RechargeAmount = amount.RechargeAmount,
-            ChannelId = channle.Id
+            ChannelId = channle.ChannlesNum
         };
 
         await CreateLifePayOrder(orderInput);
@@ -599,7 +693,7 @@
 
         var orderInput = new CreateLifePayOrderInput
         {
-            OrderNo = CreateOrderNo(),
+            OrderNo = channle.ChannlesNum + CreateOrderNo(),
             LifePayOrderStatus = LifePayOrderStatusEnum.寰呯‘璁�,
             LifePayOrderType = LifePayOrderTypeEnum.鐢佃垂璁㈠崟,
             // LifePayType = input.LifePayType,
@@ -610,7 +704,7 @@
             PayAmount = amount.PayAmont,
             DiscountAmount = amount.DiscountAmount,
             RechargeAmount = amount.RechargeAmount,
-            ChannelId = channle.Id
+            ChannelId = channle.ChannlesNum
         };
 
         await CreateLifePayOrder(orderInput);
@@ -643,7 +737,7 @@
 
         var orderInput = new CreateLifePayOrderInput
         {
-            OrderNo = CreateOrderNo(),
+            OrderNo = channle.ChannlesNum + CreateOrderNo(),
             LifePayOrderStatus = LifePayOrderStatusEnum.寰呯‘璁�,
             LifePayOrderType = LifePayOrderTypeEnum.鐕冩皵璁㈠崟,
             // LifePayType = input.LifePayType,
@@ -654,7 +748,7 @@
             PayAmount = amount.PayAmont,
             DiscountAmount = amount.DiscountAmount,
             RechargeAmount = amount.RechargeAmount,
-            ChannelId = channle.Id
+            ChannelId = channle.ChannlesNum
         };
 
         await CreateLifePayOrder(orderInput);
@@ -971,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, "璁㈠崟涓嶅瓨鍦�");
@@ -982,6 +1076,8 @@
         }
 
         order.LifePayOrderStatus = status;
+        order.ACOOLYStatus = acoolyStatus;
+        order.PlatformDeductionAmount = payAmount;
         if (acoolyOrderNo.IsNotNullOrEmpty())
         {
             order.ACOOLYOrderNo = acoolyOrderNo;
@@ -996,6 +1092,7 @@
         {
             order.PayStatus = LifePayStatusEnum.寰呴��娆�;
         }
+
 
         await _lifePayOrderRepository.UpdateAsync(order);
     }
@@ -1021,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);
 
@@ -1069,17 +1197,26 @@
 
         order.LifePayOrderStatus = LifePayOrderStatusEnum.閫�娆惧緟瀹℃牳;
         order.RefundApplyRemark = input.RefundApplyRemark;
-        order.RefundTime = DateTime.Now;
+        order.RefundApplyTime = DateTime.Now;
 
         await _lifePayOrderRepository.UpdateAsync(order);
     }
 
-    public async Task<WxPayDomesticRefundsReponse> WxPayDomesticRefunds(string outTradeNo, string reason, int refund, int total, string currency = "CNY")
+    /// <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 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
             {
@@ -1094,8 +1231,16 @@
         return res;
     }
 
+    private async Task<AlipayTradeRefundResponse> AliTradeRefund(AlipayTradeRefundRequest input)
+    {
+        return await _aliPayApi.TradeRefund(input);
+    }
+
     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)
@@ -1132,6 +1277,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;
     }
@@ -1200,6 +1355,7 @@
             dto.ChannlesName = input.ChannlesName;
             dto.ChannlesNum = input.ChannlesNum;
             dto.ChannlesRate = input.ChannlesRate;
+            dto.ChannlesRakeRate = input.ChannlesRakeRate;
             dto.SwitchType = input.SwitchType;
             dto.ChannlesType = input.ChannlesType;
             dto.Status = input.Status;
@@ -1350,10 +1506,10 @@
     private (decimal PayAmont, decimal DiscountAmount, decimal RechargeAmount) CalculateAmount(decimal amount, decimal rate)
     {
         /// 姝e父鏀粯
-        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, "鏀粯閲戦閿欒");
 
@@ -1473,7 +1629,6 @@
         CheckExtensions.IfTrueThrowUserFriendlyException(amount <= 0,
                                                          CustomeErrorMessage.SometingMustSometing,
                                                          "鑾峰彇鏀粯浜岀淮鐮佹椂閲戦", "澶т簬0");
-
         var res = await _wxPayApi.PayTransactionsH5(new PayTransactionsNativeH5
         {
             Appid = _wxPayOptions.AppID,
@@ -1526,6 +1681,7 @@
 
         return res.QrCode;
     }
+
     /// <summary>
     /// 鏋勯�犲緟绛惧悕瀛楃涓�
     /// </summary>
@@ -1554,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
                       {
@@ -1583,6 +1739,21 @@
         return result;
     }
 
+    private IQueryable<CreateEditPayChannelsInput> GetLifePayChannlesListFilter()
+    {
+        return _lifePayChannlesRep.Select(x =>
+                    new CreateEditPayChannelsInput
+                    {
+                        Id = x.Id,
+                        ChannlesRate = x.ChannlesRate,
+                        ChannlesRakeRate = x.ChannlesRakeRate,
+                        ChannlesName = x.ChannlesName,
+                        ChannlesNum = x.ChannlesNum,
+                        Status = x.Status,
+                        SwitchType = x.SwitchType,
+                        ChannlesType = x.ChannlesType,
+                    });
+    }
 
     #endregion
 }

--
Gitblit v1.9.1