userlistlogic.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package logic
  2. import (
  3. "context"
  4. "fmt"
  5. "messagecenter/service"
  6. quitl "app.yhyue.com/moapp/jybase/common"
  7. "messagecenter/rpc/messagecenter/internal/svc"
  8. "messagecenter/rpc/messagecenter/messagecenter"
  9. "github.com/zeromicro/go-zero/core/logx"
  10. )
  11. type UserListLogic struct {
  12. ctx context.Context
  13. svcCtx *svc.ServiceContext
  14. logx.Logger
  15. }
  16. func NewUserListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UserListLogic {
  17. return &UserListLogic{
  18. ctx: ctx,
  19. svcCtx: svcCtx,
  20. Logger: logx.WithContext(ctx),
  21. }
  22. }
  23. // 用户列表查询
  24. func (l *UserListLogic) UserList(in *messagecenter.UserReq) (*messagecenter.UserResp, error) {
  25. // todo: add your logic here and delete this line
  26. m := service.MessageMailBox{}
  27. data, err := m.UserList(in.CustomerServiceId, int(in.UserType), in.Phone, in.StartTime, in.EndTime)
  28. if err != nil {
  29. return nil, err
  30. }
  31. result := []*messagecenter.UserEntity{}
  32. for _, v := range *data {
  33. userResp := messagecenter.UserEntity{
  34. UserId: fmt.Sprintln(v["id"]),
  35. NickName: quitl.ObjToString(quitl.If(quitl.ObjToString("nickname") == "", quitl.ObjToString(v["phone"]), quitl.ObjToString(v["nickname"]))),
  36. }
  37. result = append(result, &userResp)
  38. }
  39. return &messagecenter.UserResp{Data: result}, nil
  40. }