package logic import ( MC "app.yhyue.com/moapp/jybase/common" "context" "fmt" "jyBXCore/rpc/entity" IC "jyBXCore/rpc/init" "jyBXCore/rpc/util" "log" "strings" "time" "jyBXCore/rpc/internal/svc" "jyBXCore/rpc/type/bxcore" "github.com/zeromicro/go-zero/core/logx" ) type GetSearchListNoLoginLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger } func NewGetSearchListNoLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSearchListNoLoginLogic { return &GetSearchListNoLoginLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } // 未登录用户搜索结果列表 func (l *GetSearchListNoLoginLogic) GetSearchListNoLogin(in *bxcore.SearchReq) (*bxcore.SearchResp, error) { defer MC.Catch() res := &bxcore.SearchData{ Count: 0, List: []*bxcore.SearchList{}, InterceptLimit: int64(MC.IntAllDef(IC.C.KeywordsLimit, 35)), } //初始化搜索对象 ks := entity.NewKeyWordsSearch() var selectType []string selectTypeSplit := strings.Split(in.SelectType, ",") // 未登录用户只能搜标题和正文 for i := 0; i < len(selectTypeSplit); i++ { if selectTypeSplit[i] == "title" || selectTypeSplit[i] == "content" { selectType = append(selectType, selectTypeSplit[i]) } } if len(selectType) == 0 { selectType = []string{"title", "content"} } // in.SelectType = strings.Join(selectType, ",") //处理搜索条件 heightWords := ks.SearchParamsHandle(in) if in.PageNum < 0 && in.PageSize < 0 { return &bxcore.SearchResp{ Data: res, ErrMsg: "", ErrCode: 0, }, nil } //判断是否是空搜索,如果是空搜索,查缓存数据 if ks.IsEmptySearch(in) { res.List, res.Count, res.Total = ks.GetBidSearchListByCacheNoLogin(in, l.svcCtx.Config.NoLoginSearch.Switch) return &bxcore.SearchResp{ Data: res, ErrMsg: "", ErrCode: 0, }, nil } in.Subtype = "招标预告,招标公告,招标结果,招标信用信息" //"招标预告,招标公告,招标结果,招标信用信息" in.PublishTime = fmt.Sprintf("%d-%d", time.Now().AddDate(-1, 0, 0).Unix(), time.Now().Unix()) t := time.Now() //招标信息有效查询 res.IsLimit = 1 //查询数据 searchLimit := util.IsSearchLimit(strings.Split(in.SelectType, ",")) //全文检索限制 if searchLimit { res.IsLimit = util.IsLimited(in.LimitFlag, in.UserId, in.UserType != "fType", in.IsNew) if res.IsLimit == 1 { //没有被限制 defer util.Limit() } } //无限制 if res.IsLimit == 1 { t2 := time.Now() res.Count, res.Total, res.List = ks.GetBidSearchListNoLogin(in, l.svcCtx.Config.NoLoginSearch.Switch) //util.GetBidSearchData(in) log.Println("未登录查询耗时:", time.Since(t2)) res.KeyWords = strings.Join(heightWords, " ") res.InterceptOtherWords = in.InterceptOtherWords res.InterceptKeyWords = in.InterceptKeyWords } log.Println("关键词 -全部- 查询耗时:", time.Since(t).Seconds()) return &bxcore.SearchResp{ Data: res, ErrMsg: "", ErrCode: 0, }, nil }