zhusenlin/Yi.Admin
1
0
Fork 0
mirror of https://gitee.com/ccnetcore/Yi synced 2026-04-02 15:16:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

es提交

Browse Source
This commit is contained in:
橙子
2021-11-09 19:13:21 +08:00
parent 4a37c7454d
commit 0a6759b361
3 changed files with 34 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
Yi.Framework/Yi.Framework.Service/SearchService.cs
View File

@@ -3,6 +3,7 @@ using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Yi.Framework.Core;
using Yi.Framework.Interface;
using Yi.Framework.Model.Models;
using Yi.Framework.Model.Search;
@@ -12,9 +13,11 @@ namespace Yi.Framework.Service
public class SearchService : ISearchService
{
private IGoodsService _goodsService;
public SearchService(IGoodsService goodsService)
private ElasticSearchInvoker _elasticSearchInvoker ;
public SearchService(IGoodsService goodsService, ElasticSearchInvoker elasticSearchInvoker)
{
_goodsService = goodsService;
_elasticSearchInvoker = elasticSearchInvoker;
}
public void ImpDataBySpu()
{
@@ -48,7 +51,7 @@ namespace Yi.Framework.Service
}
}
// 存入es,先留着，不写
//_elasticSearchService.Send(goodsList);
_elasticSearchInvoker.Send(goodsList);
page++;
} while (size == 100);
}