subscribeListLogic.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  1. package logic
  2. import (
  3. "app.yhyue.com/moapp/jybase/common"
  4. "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/api/internal/svc"
  5. "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/api/internal/types"
  6. "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXSubscribe/rpc/type/bxsubscribe"
  7. "context"
  8. "github.com/gogf/gf/v2/util/gconv"
  9. "github.com/zeromicro/go-zero/core/logx"
  10. "net/http"
  11. "strings"
  12. )
  13. type SubscribeListLogic struct {
  14. logx.Logger
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. r *http.Request
  18. }
  19. func NewSubscribeListLogic(ctx context.Context, svcCtx *svc.ServiceContext, r *http.Request) *SubscribeListLogic {
  20. return &SubscribeListLogic{
  21. Logger: logx.WithContext(ctx),
  22. ctx: ctx,
  23. svcCtx: svcCtx,
  24. r: r,
  25. }
  26. }
  27. func (l *SubscribeListLogic) SubscribeList(req *types.SubscribeReq) (resp *types.CommonResp, err error) {
  28. //关键词处理
  29. //分类
  30. matchitemsArr := []string{}
  31. matchitems := ""
  32. //关键词
  33. matchkeysArr := []string{}
  34. matchkeys := ""
  35. for k, v := range req.Item {
  36. //类型换换
  37. keyArr := gconv.Strings(v)
  38. if len(keyArr) == 0 {
  39. matchitemsArr = append(matchitemsArr, common.InterfaceToStr(k))
  40. } else {
  41. for _, s := range keyArr {
  42. matchkeysArr = append(matchkeysArr, s)
  43. }
  44. }
  45. }
  46. if len(matchitemsArr) != 0 {
  47. matchitems = strings.Join(matchitemsArr, ",")
  48. }
  49. if len(matchkeysArr) != 0 {
  50. matchkeys = strings.Join(matchkeysArr, ",")
  51. matchkeys = strings.ReplaceAll(matchkeys, " ", ",")
  52. }
  53. if req.PushTime != "" { //微信跳转过来的 按照推送时间查询导出
  54. req.SelectTime = req.PushTime
  55. }
  56. res, err := l.svcCtx.Suscribe.GetSubList(l.ctx, &bxsubscribe.SubscribeInfosReq{
  57. PageNum: req.PageNum,
  58. PageSize: req.PageSize,
  59. SelectTime: req.SelectTime,
  60. Area: req.Area,
  61. City: req.City,
  62. Industry: req.Industry,
  63. BuyerClass: req.BuyerClass,
  64. KeyWords: matchkeys,
  65. Subtype: req.Subtype,
  66. UserType: req.UserType,
  67. Price: req.Price,
  68. FileExists: req.FileExists,
  69. IsRead: req.IsRead,
  70. Source: req.Source,
  71. Staffs: req.Staffs,
  72. UserId: req.UserId,
  73. EntId: req.EntId,
  74. EntUserId: req.EntUserId,
  75. DeptId: req.DeptId,
  76. NewUserId: req.NewUserId,
  77. IsEnt: req.IsEnt,
  78. PositionType: req.PositionType,
  79. NotReturnCount: req.NotReturnCount,
  80. Item: matchitems,
  81. AccountId: req.AccountId,
  82. PositionId: req.PositionId,
  83. MgoUserId: req.MgoUserId,
  84. District: req.District,
  85. Stag: req.Stag,
  86. })
  87. if err != nil {
  88. return &types.CommonResp{
  89. Err_code: res.ErrCode,
  90. Err_msg: res.ErrMsg,
  91. Data: nil,
  92. }, nil
  93. }
  94. return &types.CommonResp{
  95. Err_code: res.ErrCode,
  96. Err_msg: res.ErrMsg,
  97. Data: res.Data,
  98. }, nil
  99. }