zhusenlin/Yi.Admin
1
0
Fork 0
mirror of https://gitee.com/ccnetcore/Yi synced 2026-03-13 21:16:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

回滚main

Browse Source
This commit is contained in:
橙子
2021-11-09 19:51:35 +08:00
parent 08ba7207bb
commit 2d2dd55cc0
20 changed files with 6 additions and 672 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Yi.Framework/Yi.Framework.ElasticSearchProcessor/WarmupESIndexWorker.cs
View File

@@ -27,15 +27,14 @@ namespace Yi.Framework.ElasticSearchProcessor
private readonly ElasticSearchInvoker _elasticSearchInvoker;
private readonly IOptionsMonitor<ElasticSearchOptions> _ElasticSearchOptions = null;
private readonly ISearchService _searchService;
public WarmupESIndexWorker(ILogger<WarmupESIndexWorker> logger, RabbitMQInvoker rabbitMQInvoker, IConfiguration configuration, ElasticSearchInvoker elasticSearchInvoker, IOptionsMonitor<ElasticSearchOptions> optionsMonitor, ISearchService searchService)
public WarmupESIndexWorker(ILogger<WarmupESIndexWorker> logger, RabbitMQInvoker rabbitMQInvoker, IConfiguration configuration, ElasticSearchInvoker elasticSearchInvoker, IOptionsMonitor<ElasticSearchOptions> optionsMonitor)
{
this._logger = logger;
this._RabbitMQInvoker = rabbitMQInvoker;
this._configuration = configuration;
this._elasticSearchInvoker = elasticSearchInvoker;
this._ElasticSearchOptions = optionsMonitor;
this._searchService=searchService;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
@@ -48,14 +47,14 @@ namespace Yi.Framework.ElasticSearchProcessor
HttpClient _HttpClient = new HttpClient();
this._RabbitMQInvoker.RegistReciveAction(rabbitMQConsumerModel, message =>
{
SKUWarmupQueueModel skuWarmupQueueModel = JsonConvert.DeserializeObject<SKUWarmupQueueModel>(message);
//SKUWarmupQueueModel skuWarmupQueueModel = JsonConvert.DeserializeObject<SKUWarmupQueueModel>(message);
//【得到消息队列模型】
#region 先删除Index---新建Index---再建立全部数据索引
{
try
{
this._elasticSearchInvoker.DropIndex(this._ElasticSearchOptions.CurrentValue.IndexName);
this._searchService.ImpDataBySpu();
//this._searchService.ImpDataBySpu();
//【触发es数据导入服务】
this._logger.LogInformation($"{nameof(WarmupESIndexWorker)}.InitAll succeed");
return true;