Эх сурвалжийг харах

feat:A24176初始化es调整

fuwencai 8 сар өмнө
parent
commit
3fe786c51e

+ 4 - 4
rpc/knowledge/init/init.go

@@ -1,8 +1,8 @@
 package init
 
 import (
-	elastic "app.yhyue.com/moapp/jybase/es"
-
+	es7 "app.yhyue.com/moapp/jybase/es"
+	elastic "app.yhyue.com/moapp/jybase/esv1"
 	"app.yhyue.com/moapp/jybase/mysql"
 	"bp.jydev.jianyu360.cn/SocialPlatform/knowledgeBase/entity"
 	"bp.jydev.jianyu360.cn/SocialPlatform/knowledgeBase/rpc/knowledge/internal/config"
@@ -42,9 +42,9 @@ func init() {
 	if es.Addr != "" {
 		log.Println("--初始化 elasticsearch--")
 		log.Println(es.Addr, es.Size)
-		elastic.NewEs("v1", es.Addr, es.Size, "", "")
+		elastic.InitElasticSize(es.Addr, es.Size)
 	}
-	entity.ESV7 = &elastic.EsV7{
+	entity.ESV7 = &es7.EsV7{
 		Address:  C.Esv7.Address,
 		UserName: C.Esv7.Username,
 		Password: C.Esv7.Password,