From ecc217f694e03e660ef54bbada24fcb4ee59a728 Mon Sep 17 00:00:00 2001
From: zhengyuxuan <zhengyuxuan1995>
Date: 星期五, 21 三月 2025 09:33:12 +0800
Subject: [PATCH] 回单下载

---
 LifePayment/LifePayment.Application/LifePay/LifePayService.cs |   70 ++++++++++++++++++++++++++++++++++
 1 files changed, 69 insertions(+), 1 deletions(-)

diff --git a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
index b10cf07..a06be30 100644
--- a/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
+++ b/LifePayment/LifePayment.Application/LifePay/LifePayService.cs
@@ -25,6 +25,7 @@
 using Nest;
 using Volo.Abp.Domain.Entities;
 using Volo.Abp.ObjectMapping;
+using NPOI.SS.Formula.Functions;
 
 namespace LifePayment.Application;
 
@@ -41,9 +42,11 @@
     private readonly IRepository<DallyStatistics, Guid> _dallyStatisticsRepository;
     private readonly IRepository<LifePayChannles, Guid> _lifePayChannlesRep;
     private readonly IRepository<LifePayAccount, Guid> _lifePayAccount;
+    private readonly IRepository<OperateHistory, Guid> _operateHistory;
     private readonly IDataFilter dataFilter;
     private readonly IChannelFilter _channelFilter;
     private readonly IAliPayApi _aliPayApi;
+    private readonly IAlipayInterfaceManager _alipayInterfaceManager;
     private readonly IWxPayApi _wxPayApi;
     private readonly WxPayOption _wxPayOptions;
 
@@ -58,7 +61,9 @@
                           IRepository<LifePayPremium, Guid> lifePayPremiumRepository,
                           IRepository<LifePayIntroInfo, Guid> lifePayIntroInfoRepository,
                           IRepository<DallyStatistics, Guid> dallyStatisticsRepository,
+                          IRepository<OperateHistory, Guid> operateHistory,
                           IAliPayApi aliPayApi,
+                          IAlipayInterfaceManager aliPayInterfaceManager,
                           IWxPayApi wxPayApi,
                           IOptions<WxPayOption> wxPayOptions,
                           IRepository<LifePayChannles, Guid> lifePayChannlesRep,
@@ -75,6 +80,7 @@
         _lifePayIntroInfoRepository = lifePayIntroInfoRepository;
         _dallyStatisticsRepository = dallyStatisticsRepository;
         _aliPayApi = aliPayApi;
+        _alipayInterfaceManager = aliPayInterfaceManager;
         _wxPayApi = wxPayApi;
         _wxPayOptions = wxPayOptions.Value;
         _distributedEventBus = distributedEventBus;
@@ -82,6 +88,7 @@
         _lifePayAccount = lifePayAccount;
         this.dataFilter = dataFilter;
         _channelFilter = channelFilter;
+        _operateHistory = operateHistory;
     }
 
     #region 鏌ヨ
@@ -660,7 +667,54 @@
         });
         return result;
     }
+    public async Task<string> GetBillErceiptExport(string orderNo)
+    {
+        try
+        {
+            var order = await _lifePayOrderRepository.Where(x => x.OrderNo == orderNo).FirstOrDefaultAsync();
 
+            CheckExtensions.IfTrueThrowUserFriendlyException(order == null, "鏈壘鍒拌鍗曚俊鎭�");
+            if (order.LifePayType == LifePayTypeEnum.AliPay)
+            {
+                var elecInfoInput = new DataBillErceiptApplyInput
+                {
+                    Type = "FUND_DETAIL",
+                    Key = orderNo
+                };
+
+                var elecInfoOutput = await _alipayInterfaceManager.DataBillErceiptApply(elecInfoInput);
+                if (elecInfoOutput != null)
+                {
+                    var elecFileInput = new DataBillEreceiptQueryInput
+                    {
+                        FileId = elecInfoOutput.FileId,
+                    };
+                    var elecFileOutput = await _alipayInterfaceManager.DataBillEreceiptQuery(elecFileInput);
+                    if (!string.IsNullOrEmpty(elecFileOutput.DownloadUrl))
+                    {
+                        return elecFileOutput.DownloadUrl;
+                    }
+                    return "";
+                }
+                return "";
+            }
+            else
+            {
+                WxPayTradeBillApplyRequest req = new WxPayTradeBillApplyRequest
+                {
+                    OutBillNo = order.OutOrderNo,
+                };
+
+                var res = await _wxPayApi.WxPayTradeBillApply(req);
+                return "";
+            }
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError("鑾峰彇璁㈠崟鍙蜂负{0}鐢靛瓙鍥炲崟鍑虹幇閿欒锛歿1}", orderNo, ex.Message);
+            return "";
+        }
+    }
     #endregion
 
     #region 鎿嶄綔
@@ -1208,7 +1262,7 @@
 
         #region 璁板綍鏃ュ織
 
-        await PublishLifePayOrderHistoryEvent("閫�娆�", "閫�娆�", order.Id);
+        await LifePayOrderHistory("閫�娆�", "閫�娆�", order.Id, (int)OperateHistoryTypeEnum.LifePayRefund);
 
         #endregion
 
@@ -1596,6 +1650,20 @@
         await _distributedEventBus.PublishAsync(recordEto, false);
     }
 
+    private async Task LifePayOrderHistory(string operateContent, string operateName, Guid relationId, int? tableType = (int)OperateHistoryTypeEnum.LifePayRefund)
+    {
+        var operateHistory = new OperateHistory
+        {
+            CreatorName = CurrentUser.Name,
+            OperateContent = operateName,
+            OperateName = operateName,
+            RelationId = relationId,
+            TableType = tableType
+
+        };
+        await _operateHistory.InsertAsync(operateHistory);
+    }
+
     /// <summary>
     /// 鑾峰彇鏀粯浜岀淮鐮�
     /// </summary>

--
Gitblit v1.9.1