请写出 .net6 连接oracle数据库并使用hangfire任务调度的详细代码

在.NET 6中，你可以使用Entity Framework Core（EF Core）连接Oracle数据库，并结合Hangfire作为异步任务调度系统。首先，确保安装了相关的NuGet包：

1. Oracle.EntityFrameworkCore - 对Oracle数据库的支持
2. Microsoft.Extensions.Hangfire - Hangfire库

以下是连接Oracle数据库并设置Hangfire的基本步骤：

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Hangfire;

// 1. 添加依赖项到Startup.cs
public void ConfigureServices(IServiceCollection services)
{
    // 配置数据库连接
    services.AddDbContext<YourDbContext>(options =>
        options.UseOracle(Configuration.GetConnectionString("OracleConnection")));

    // 注册Hangfire
    services.AddHangfire(config => {
        config.UseSqlServerStorage(Configuration.GetConnectionString("HangfireConnection"));
        config.UseBackgroundJobOptions(new BackgroundJobOptions
        {
            MaxConcurrentJobs = 5,
            JobActivator = new ActivatorJobActivator()
        });
    });

    // ...其他服务添加...
}

// 2. 创建DbContext
public class YourDbContext : DbContext
{
    public YourDbContext(DbContextOptions<YourDbContext> options) : base(options)
    {
        Database.EnsureCreated();
    }

    // 定义你的实体和上下文
    public DbSet<YourEntity> YourEntities { get; set; }
}

// 3. 使用Hangfire异步任务
public class JobWorker : IHostedService
{
    private readonly ILogger<JobWorker> _logger;
    private IAsyncJobManager _jobManager;

    public JobWorker(ILogger<JobWorker> logger, IAsyncJobManager jobManager)
    {
        _logger = logger;
        _jobManager = jobManager;
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        // 注册异步任务示例
        await _jobManager.EnqueueAsync(() => ExecuteSomeTask(), "yourQueue");

        // 其他任务调度代码...

    }

    private async Task ExecuteSomeTask()
    {
        using (var context = new YourDbContext(_services.GetService DbContextOptions))
        {
            var entity = await context.YourEntities.FindAsync(id);
            // 执行数据库操作...
            Console.WriteLine($"Executing task for id: {entity.Id}");
        }
    }

    public Task StopAsync(CancellationToken cancellationToken) => Task.CompletedTask;
}

// 然后在Configure方法中启动Hangfire
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    // ...
    app.UseHangfireServer();

    if (env.IsDevelopment())
    {
        app.UseHangfireDashboard("/hangfire", new DashboardOptions
        {
            Authorization = new[] {"admin"}.ToList(),
        });
    }
    
    app.UseRouting();
    app.UseEndpoints(endpoints =>
    {
        endpoints.MapControllers();
    });
}