From a47038826eb7d1c152a50e95b3c9be177a130e8d Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期四, 20 十一月 2025 09:26:18 +0800
Subject: [PATCH] feat:开发平安转账
---
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