From dbde30883895c6047995d84a846c36f79fc0a895 Mon Sep 17 00:00:00 2001
From: sunpengfei <i@angelzzz.com>
Date: 星期五, 22 八月 2025 15:12:08 +0800
Subject: [PATCH] feat:开发
---
FlexJobApi.Core/Utils/ScheduleUtils/DbJobPersistence.cs | 16 ++--------------
1 files changed, 2 insertions(+), 14 deletions(-)
diff --git a/FlexJobApi.Core/Utils/ScheduleUtils/DbJobPersistence.cs b/FlexJobApi.Core/Utils/ScheduleUtils/DbJobPersistence.cs
index c13c0ea..592a3dd 100644
--- a/FlexJobApi.Core/Utils/ScheduleUtils/DbJobPersistence.cs
+++ b/FlexJobApi.Core/Utils/ScheduleUtils/DbJobPersistence.cs
@@ -37,21 +37,9 @@
/// 浣滀笟璋冨害鏈嶅姟鍚姩鏃�
/// </summary>
/// <returns></returns>
- public async Task<IEnumerable<SchedulerBuilder>> PreloadAsync(CancellationToken stoppingToken) // Furion 4.9.1.59 涔嬪墠涓� public IEnumerable<SchedulerBuilder> Preload()
+ public Task<IEnumerable<SchedulerBuilder>> PreloadAsync(CancellationToken stoppingToken)
{
- var schedulers = new List<SchedulerBuilder>();
- var jobDetails = await repScheduleJobDetail.AsQueryable().AsNoTracking().ToListAsync();
- var jobTriggers = await repScheduleJobTrigger.AsQueryable().AsNoTracking().ToListAsync();
- foreach (var jobDetail in jobDetails)
- {
- var triggers = jobTriggers.Where(it => it.JobId == jobDetail.JobId)
- .Select(it => TriggerBuilder.From(it.ToJson()))
- .ToArray();
- var jobBuilder = JobBuilder.From(jobDetail.ToJson());
- var scheduler = SchedulerBuilder.Create(jobBuilder, triggers);
- schedulers.Add(scheduler);
- }
- return schedulers;
+ return Task.FromResult(App.EffectiveTypes.ScanToBuilders().AsEnumerable());
}
public Task<SchedulerBuilder> OnLoadingAsync(SchedulerBuilder builder, CancellationToken stoppingToken)
--
Gitblit v1.9.1