From ee552e8f4dd8a2d7bd59f7bd87845de0188d7a36 Mon Sep 17 00:00:00 2001
From: lijin <17408817@qq.com>
Date: 星期四, 20 十一月 2025 10:49:24 +0800
Subject: [PATCH] Merge branch 'dev-818-3.4.2.12' of http://120.26.58.240:8888/r/ApiTools into dev-818-3.4.2.12

---
 ApiTools.Core/Jobs/RefreshChannelWalletTransactionStatusJob.cs |   10 +++++-----
 1 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/ApiTools.Core/Jobs/RefreshChannelWalletTransactionStatusJob.cs b/ApiTools.Core/Jobs/RefreshChannelWalletTransactionStatusJob.cs
index c92df86..c0f092b 100644
--- a/ApiTools.Core/Jobs/RefreshChannelWalletTransactionStatusJob.cs
+++ b/ApiTools.Core/Jobs/RefreshChannelWalletTransactionStatusJob.cs
@@ -29,15 +29,15 @@
 
         public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
         {
-            var env = App.GetConfig<string>("Environment");
-            if (env != "Local")
-            {
+            //var env = App.GetConfig<string>("Environment");
+            //if (env != "Local")
+            //{
                 var transactions = await channelWalletTransactionRepository.GetQueryable(false)
                 .Where(it =>
                     it.TransactionStatus == EnumWalletTransactionStatus.WaitPay
                     || it.TransactionStatus == EnumWalletTransactionStatus.Dealing)
                 .ToListAsync();
-                var walletIds = transactions.DistinctSelect(it => it.WalletId);
+                var walletIds = transactions.Select(it => it.WalletId).Distinct().ToList();
                 var wallets = await channelWalletRepository.GetQueryable(false)
                     .Where(it => walletIds.Contains(it.Id))
                     .ToListAsync();
@@ -52,7 +52,7 @@
                         await channelWalletService.DownloadEreceiptUrl(wallet, transaction);
                     }
                 }
-            }
+            //}
         }
     }
 }

--
Gitblit v1.9.1