feat:检索库配置

jyBXBase/rpc/etc/db.yaml

@@ -18,7 +18,7 @@ redis:
         - other=192.168.3.206:1712
 es:
     addr: http://192.168.3.206:9800
-    size: 5
+    size: 30
 mongo:
     main:
         dbName: qfw

jyBXBuyer/rpc/etc/db.yaml

@@ -11,7 +11,7 @@ redis:
         - other=192.168.3.206:1712
 es:
     addr: http://192.168.3.206:9800
-    size: 5
+    size: 30
 mongo:
     main:
         dbName: qfw

jyBXCore/api/etc/bxcore-api.yaml

@@ -1,7 +1,7 @@
 Name: bxcore-api
 Host: 0.0.0.0
 Port: 8004
-Timeout: 10000
+Timeout: 15000
 Webrpcport: 8014
 Gateway:
   ServerCode: jybxcore

jyBXCore/api/internal/logic/searchListLogic.go

@@ -7,7 +7,9 @@ import (
 	"jyBXCore/api/internal/types"
 	"jyBXCore/api/internal/util"
 	"jyBXCore/rpc/type/bxcore"
+	"log"
 	"net/http"
+	"time"
 )
 
 type SearchListLogic struct {
@@ -27,6 +29,7 @@ func NewSearchListLogic(ctx context.Context, svcCtx *svc.ServiceContext, r *http
 }
 
 func (l *SearchListLogic) SearchList(req *types.SearchReq) (resp *types.CommonResp, err error) {
+	t := time.Now()
 	res, err := l.svcCtx.BxCore.GetSearchList(l.ctx, &bxcore.SearchReq{
 		PageNum:        req.PageNum,
 		PageSize:       req.PageSize,
@@ -50,6 +53,7 @@ func (l *SearchListLogic) SearchList(req *types.SearchReq) (resp *types.CommonRe
 		EntId:          l.r.Header.Get("entId"),
 		Platform:       util.CheckPlatform(l.r),
 	})
+	log.Println("请求接口耗时：", time.Since(t).Seconds())
 	if err != nil {
 		return &types.CommonResp{
 			Err_code: res.ErrCode,

jyBXCore/go.mod

@@ -3,7 +3,7 @@ module jyBXCore
 go 1.16
 
 require (
-	app.yhyue.com/moapp/jybase v0.0.0-20220527072445-3116753a8f28
+	app.yhyue.com/moapp/jybase v0.0.0-20220617085837-48c1bf245c2f
 	bp.jydev.jianyu360.cn/BaseService/gateway v0.0.0-20220505015640-56e56f06bc5c
 	github.com/go-sql-driver/mysql v1.6.0
 	github.com/golang/protobuf v1.5.2

jyBXCore/go.sum

@@ -4,8 +4,8 @@ app.yhyue.com/moapp/jybase v0.0.0-20220415064050-37ce64b3e2d4/go.mod h1:qNRA0sHu
 app.yhyue.com/moapp/jybase v0.0.0-20220418104200-46c3fff161c7/go.mod h1:qNRA0sHuYqcLoYoP8irpaWnW9YsXixe6obBIkwaXpD0=
 app.yhyue.com/moapp/jybase v0.0.0-20220420032112-668025915ee4/go.mod h1:qNRA0sHuYqcLoYoP8irpaWnW9YsXixe6obBIkwaXpD0=
 app.yhyue.com/moapp/jybase v0.0.0-20220421060131-a1001013ba46/go.mod h1:qNRA0sHuYqcLoYoP8irpaWnW9YsXixe6obBIkwaXpD0=
-app.yhyue.com/moapp/jybase v0.0.0-20220527072445-3116753a8f28 h1:4f2Ut0aMEmanwpRdRD2npShh8HMz4/OVfIv+HwhKifk=
-app.yhyue.com/moapp/jybase v0.0.0-20220527072445-3116753a8f28/go.mod h1:qNRA0sHuYqcLoYoP8irpaWnW9YsXixe6obBIkwaXpD0=
+app.yhyue.com/moapp/jybase v0.0.0-20220617085837-48c1bf245c2f h1:U8sVqWn/JH2gcsJqQcHFaCx/MtY1pGUwbUAc5dVkwto=
+app.yhyue.com/moapp/jybase v0.0.0-20220617085837-48c1bf245c2f/go.mod h1:qNRA0sHuYqcLoYoP8irpaWnW9YsXixe6obBIkwaXpD0=
 bp.jydev.jianyu360.cn/BP/jynsq v0.0.0-20220222052708-ebc43af90698/go.mod h1:ojo/AUH9Yr1wzarEjOaNMkj1Cet/9r8IgLyba64Z52E=
 bp.jydev.jianyu360.cn/BaseService/gateway v0.0.0-20220419090715-88ddb32961be/go.mod h1:Yj4oabIGItuMoF0BXYLz2XAnF581kxgXBrvlUtIJrkI=
 bp.jydev.jianyu360.cn/BaseService/gateway v0.0.0-20220505015640-56e56f06bc5c h1:p2WctRqfE6wdLPHnACIO983CfYV2LLaaLC2ADpSaNn0=

jyBXCore/rpc/etc/db.yaml

@@ -11,7 +11,7 @@ redis:
         - other=192.168.3.206:1712
 es:
     addr: http://192.168.3.206:9800
-    size: 5
+    size: 30
 mongo:
     main:
         dbName: qfw

jyBXCore/rpc/internal/logic/getsearchlistlogic.go

@@ -9,6 +9,7 @@ import (
 	IC "jyBXCore/rpc/init"
 	"jyBXCore/rpc/util"
 	"strings"
+	"time"
 
 	"jyBXCore/rpc/internal/svc"
 	"jyBXCore/rpc/type/bxcore"
@@ -33,6 +34,7 @@ func NewGetSearchListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Get
 // 标讯搜索结果列表数据
 func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.SearchResp, error) {
 	defer MC.Catch()
+	t := time.Now()
 	res := &bxcore.SearchData{
 		Count: 0,
 		List:  []*bxcore.SearchList{},
@@ -119,6 +121,7 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
 			res.Count = count
 			res.List = list
 		}
+		logx.Info("关键词 -0- 查询耗时：", time.Since(t).Seconds())
 	} else if in.Platform == "PC" {
 		var count int64 = 0
 		var list = []*bxcore.SearchList{}
@@ -172,6 +175,7 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
 			}, nil
 		}
 	}
+	logx.Info("关键词 -全部- 查询耗时：", time.Since(t).Seconds())
 	return &bxcore.SearchResp{
 		Data:    res,
 		ErrMsg:  "",

jyBXCore/rpc/util/search.go

@@ -18,6 +18,7 @@ import (
 	"regexp"
 	"strconv"
 	"strings"
+	"time"
 	"unicode"
 )
 
@@ -163,6 +164,7 @@ const (
 
 //GetBidSearchData 标信息搜索
 func GetBidSearchData(in *bxcore.SearchReq) (count int64, list []*bxcore.SearchList) {
+	t := time.Now()
 	var hightlightContent bool = false //是否高亮正文
 	var selectTypeArr = strings.Split(in.SelectType, ",")
 	for _, v := range selectTypeArr {
@@ -233,9 +235,11 @@ func GetBidSearchData(in *bxcore.SearchReq) (count int64, list []*bxcore.SearchL
 				list = append(list, searchList)
 			}
 		}
+		logx.Info("关键词 -1- 查询耗时：", time.Since(t).Seconds())
 		MakeCollection(in.UserId, list)
 		logx.Info("=====:", len(list))
 	}
+	logx.Info("关键词 查询耗时：", time.Since(t).Seconds())
 	return
 }
 

jyBXSubscribe/rpc/etc/db.yaml

@@ -36,7 +36,7 @@ redis:
         - pushcache_2_b=192.168.3.206:5002
 es:
     addr: http://192.168.3.206:9800
-    size: 5
+    size: 30
 mongo:
     main:
         dbName: qfw