using Furion;
using Furion.DatabaseAccessor;
using Furion.EventBus;
using Furion.Schedule;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ApiTools.Core
{
    /// <summary>
    /// 刷新渠道钱包交易状态
    /// </summary>
    [JobDetail("RefreshChannelWalletTransactionStatusJob", Description = "刷新渠道钱包交易状态", Concurrent = false)]
    [PeriodMinutes(5)]
    public class RefreshChannelWalletTransactionStatusJob(
            ChannelWalletRepository channelWalletRepository,
            ChannelWalletTransactionRepository channelWalletTransactionRepository,
            ChannelWalletService channelWalletService
        ) : IJob
    {
        private readonly ChannelWalletRepository channelWalletRepository = channelWalletRepository;
        private readonly ChannelWalletTransactionRepository channelWalletTransactionRepository = channelWalletTransactionRepository;
        private readonly ChannelWalletService channelWalletService = channelWalletService;

        public async Task ExecuteAsync(JobExecutingContext context, CancellationToken stoppingToken)
        {
            var env = App.GetConfig<string>("Environment");
            if (env != "Local")
            {
                var transactions = await channelWalletTransactionRepository.GetQueryable(false)
                .Include(it => it.PingAnPay)
                .Where(it =>
                    it.TransactionStatus == EnumWalletTransactionStatus.WaitPay
                    || it.TransactionStatus == EnumWalletTransactionStatus.Dealing
                    || it.TransactionStatus == EnumWalletTransactionStatus.Success
                    && it.EreceiptStatus != EnumWalletTransactionEreceiptStatus.SUCCESS
                    && it.EreceiptStatus != EnumWalletTransactionEreceiptStatus.FAIL)
                .ToListAsync();
                var walletIds = transactions.Select(it => it.WalletId).Distinct().ToList();
                var wallets = await channelWalletRepository.GetQueryable(false)
                    .Where(it => walletIds.Contains(it.Id))
                    .ToListAsync();
                foreach (var transaction in transactions)
                {
                    var wallet = wallets.FirstOrDefault(it => it.Id == transaction.WalletId);
                    if (wallet != null)
                    {
                        if (transaction.TransactionStatus == EnumWalletTransactionStatus.WaitPay
                            || transaction.TransactionStatus == EnumWalletTransactionStatus.Dealing)
                        {
                            // 查询交易详情
                            await channelWalletService.GetTransactionDetail(wallet, transaction);
                        }
                        // 下载回单
                        await channelWalletService.DownloadEreceiptUrl(wallet, transaction);
                    }
                }
            }
        }
    }
}