diff --git a/Yi.Framework/Yi.Framework.ElasticSearchProcessor/Yi.Framework.ElasticSearchProcessor.csproj b/Yi.Framework/Yi.Framework.ElasticSearchProcessor/Yi.Framework.ElasticSearchProcessor.csproj
index f208d303..93993039 100644
--- a/Yi.Framework/Yi.Framework.ElasticSearchProcessor/Yi.Framework.ElasticSearchProcessor.csproj
+++ b/Yi.Framework/Yi.Framework.ElasticSearchProcessor/Yi.Framework.ElasticSearchProcessor.csproj
@@ -4,4 +4,33 @@
net5.0
+
+
+
+
+
+
+
+ PreserveNewest
+ true
+ PreserveNewest
+
+
+ PreserveNewest
+ true
+ PreserveNewest
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/Yi.Framework/Yi.Framework.PageDetail/Yi.Framework.PageDetail.csproj b/Yi.Framework/Yi.Framework.PageDetail/Yi.Framework.PageDetail.csproj
index 8137388a..464f7f90 100644
--- a/Yi.Framework/Yi.Framework.PageDetail/Yi.Framework.PageDetail.csproj
+++ b/Yi.Framework/Yi.Framework.PageDetail/Yi.Framework.PageDetail.csproj
@@ -10,16 +10,6 @@
1701;1702;CS1591
-
-
-
-
-
-
-
-
-
-
diff --git a/Yi.Framework/Yi.Framework.Service/SearchService.cs b/Yi.Framework/Yi.Framework.Service/SearchService.cs
index d1a3a389..bdb5a686 100644
--- a/Yi.Framework/Yi.Framework.Service/SearchService.cs
+++ b/Yi.Framework/Yi.Framework.Service/SearchService.cs
@@ -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);
}