polymerizesearchlogic.go 1019 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package logic
  2. import (
  3. "context"
  4. "github.com/zeromicro/go-zero/core/logx"
  5. "jyBXCore/rpc/entity"
  6. IC "jyBXCore/rpc/init"
  7. "jyBXCore/rpc/internal/svc"
  8. "jyBXCore/rpc/type/bxcore"
  9. )
  10. type PolymerizeSearchLogic struct {
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. logx.Logger
  14. }
  15. func NewPolymerizeSearchLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PolymerizeSearchLogic {
  16. return &PolymerizeSearchLogic{
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. Logger: logx.WithContext(ctx),
  20. }
  21. }
  22. // 聚合搜索
  23. func (l *PolymerizeSearchLogic) PolymerizeSearch(in *bxcore.PolymerizeSearchReq) (*bxcore.PolymerizeSearchResp, error) {
  24. // todo: add your logic here and delete this line
  25. if in.SearchCode == "" {
  26. return &bxcore.PolymerizeSearchResp{}, nil
  27. }
  28. data := &bxcore.SearchReturn{}
  29. ks := entity.NewKeyWordsSearch()
  30. IC.Search_Thread <- true
  31. data = ks.PolymerizeSearch(v)
  32. defer func() {
  33. <-IC.Search_Thread
  34. }()
  35. return &bxcore.PolymerizeSearchResp{
  36. ErrCode: 0,
  37. ErrMsg: "",
  38. Data: data,
  39. }, nil
  40. }