From 8ef91ebd038d333092396ec7abc74a9bc639361a Mon Sep 17 00:00:00 2001 From: chenchun Date: Tue, 11 Mar 2025 13:43:26 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=AE=8C=E6=88=90=E8=82=A1=E7=A5=A8?= =?UTF-8?q?=E4=BB=B7=E6=A0=BC=E7=94=9F=E6=88=90job?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Jobs/ai-stock/GenerateStockPricesJob.cs | 26 +++++++++++++++++++ 1 file changed, 26 insertions(+) create mode 100644 Yi.Abp.Net8/src/Yi.Abp.Web/Jobs/ai-stock/GenerateStockPricesJob.cs diff --git a/Yi.Abp.Net8/src/Yi.Abp.Web/Jobs/ai-stock/GenerateStockPricesJob.cs b/Yi.Abp.Net8/src/Yi.Abp.Web/Jobs/ai-stock/GenerateStockPricesJob.cs new file mode 100644 index 00000000..9e820796 --- /dev/null +++ b/Yi.Abp.Net8/src/Yi.Abp.Web/Jobs/ai-stock/GenerateStockPricesJob.cs @@ -0,0 +1,26 @@ +using System.Threading; +using System.Threading.Tasks; +using Volo.Abp.BackgroundWorkers.Hangfire; +using Yi.Framework.Stock.Domain.Managers; + +namespace Yi.Abp.Web.Jobs.ai_stock +{ + public class GenerateStockPricesJob : HangfireBackgroundWorkerBase + { + private readonly StockMarketManager _stockMarketManager; + + public GenerateStockPricesJob(StockMarketManager stockMarketManager) + { + _stockMarketManager = stockMarketManager; + + RecurringJobId = "AI股票价格生成"; + //每天凌晨1点执行一次 + CronExpression = "0 0 1 * * ?"; + } + + public override async Task DoWorkAsync(CancellationToken cancellationToken = new CancellationToken()) + { + await _stockMarketManager.GenerateStocksAsync(); + } + } +} \ No newline at end of file