Browse Source

修改es索引字段

kobe6258 7 months ago
parent
commit
c025e48b0a
2 changed files with 4 additions and 5 deletions
  1. 3 3
      domian/media/media_service.go
  2. 1 2
      routers/router.go

+ 3 - 3
domian/media/media_service.go

@@ -77,8 +77,8 @@ func SearchMediaList(mediaType string, key string, from int, size int, max int64
 	return
 }
 func SearchMaxMediaId(mediaType string, key string) (total int64, latestId int64) {
-	sort := []string{"mediaId:desc"}
-	request := matchAllByCondition(sort, key, ConditionColumn, mediaType)
+	mediaSort := []string{"mediaId:desc"}
+	request := matchAllByCondition(mediaSort, key, ConditionColumn, mediaType)
 	//同步es
 	//re, err := elastic().Search(request)
 	re, err := elastic().Count(request)
@@ -88,7 +88,7 @@ func SearchMaxMediaId(mediaType string, key string) (total int64, latestId int64
 	count := re.Count
 	total = int64(count)
 	if total > 0 {
-		request = matchByCondition(sort, key, ConditionColumn, mediaType, 0, count)
+		request = matchByCondition(mediaSort, key, ConditionColumn, mediaType, 0, count)
 		re, err = elastic().Search(request)
 		if err != nil {
 			logger.Error("es搜索异常:%v", err)

+ 1 - 2
routers/router.go

@@ -4,7 +4,6 @@ import (
 	"eta/eta_mini_ht_api/controllers/media"
 	"eta/eta_mini_ht_api/controllers/report"
 	"eta/eta_mini_ht_api/controllers/user"
-	"eta/eta_mini_ht_api/middleware"
 	"github.com/beego/beego/v2/server/web"
 	"github.com/beego/beego/v2/server/web/filter/cors"
 	"time"
@@ -21,7 +20,7 @@ func init() {
 	}))
 	//增加授权拦截
 
-	web.InsertFilter("*", web.BeforeRouter, middleware.AuthMiddleware())
+	//web.InsertFilter("*", web.BeforeRouter, middleware.AuthMiddleware())
 
 	ns := web.NewNamespace("/htapi",
 		web.NSNamespace("/user",