From 0a6759b3611651febd36c5919b87457850f664e5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A9=99=E5=AD=90?= <454313500@qq.com>
Date: Tue, 9 Nov 2021 19:13:21 +0800
Subject: [PATCH] =?UTF-8?q?es=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
...Yi.Framework.ElasticSearchProcessor.csproj | 29 +++++++++++++++++++
.../Yi.Framework.PageDetail.csproj | 10 -------
.../Yi.Framework.Service/SearchService.cs | 7 +++--
3 files changed, 34 insertions(+), 12 deletions(-)
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);
}