user.go 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package user
  2. import (
  3. "context"
  4. "sghgogs.com/micro/shopping-service/domain/service"
  5. pb "sghgogs.com/micro/shopping-service/proto"
  6. )
  7. type User struct {
  8. Service service.IService
  9. }
  10. func (svc *User) GetUserList(ctx context.Context, query *pb.GetUserListRequest, rsp *pb.GetUserListResponse) error {
  11. list, i, err := svc.Service.GetUserList(query)
  12. if err != nil {
  13. return nil
  14. } else {
  15. rsp.TotalCount = i
  16. rsp.Items = list
  17. }
  18. return nil
  19. }
  20. func (svc *User) GetUser(ctx context.Context, query *pb.GetUserRequest, rsp *pb.GetUserResponse) error {
  21. if user, err := svc.Service.GetUser(query); err != nil {
  22. return err
  23. } else {
  24. rsp.Data = user
  25. }
  26. return nil
  27. }
  28. func (svc *User) CreateUser(ctx context.Context, data *pb.CreateUserRequest, rsp *pb.CreateUserResponse) error {
  29. if err := svc.Service.CreateUser(ctx, data); err != nil {
  30. return err
  31. }
  32. return nil
  33. }
  34. func (svc *User) UpdateUser(ctx context.Context, data *pb.UpdateUserRequest, rsp *pb.UpdateUserResponse) error {
  35. if err := svc.Service.UpdateUser(ctx, data); err != nil {
  36. return err
  37. }
  38. return nil
  39. }
  40. func (svc *User) DeleteUser(ctx context.Context, data *pb.DeleteUserRequest, rsp *pb.DeleteUserResponse) error {
  41. if err := svc.Service.DeleteUser(data); err != nil {
  42. return err
  43. }
  44. return nil
  45. }
  46. func (svc *User) ToggleUser(ctx context.Context, data *pb.ToggleUserRequest, rsp *pb.ToggleUserResponse) error {
  47. if err := svc.Service.ToggleUser(ctx, data); err != nil {
  48. return err
  49. }
  50. return nil
  51. }