address.go 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package address
  2. import (
  3. "context"
  4. "sghgogs.com/micro/shopping-service/domain/service"
  5. pb "sghgogs.com/micro/shopping-service/proto"
  6. )
  7. type Address struct {
  8. Service service.IService
  9. }
  10. func (svc *Address) CreateAddress(ctx context.Context, add *pb.CreateAddressRequest, rsp *pb.CreateAddressResponse) error {
  11. if err := svc.Service.CreateAddress(add); err != nil {
  12. return err
  13. }
  14. return nil
  15. }
  16. func (svc *Address) GetAddressList(ctx context.Context, query *pb.GetAddressListRequest, rsp *pb.GetAddressListResponse) error {
  17. list, i, err := svc.Service.GetAddressList(query)
  18. if err != nil {
  19. return err
  20. }
  21. rsp.TotalCount = i
  22. rsp.Items = list
  23. return nil
  24. }
  25. func (svc *Address) GetAddress(ctx context.Context, query *pb.GetAddressRequest, rsp *pb.GetAddressResponse) error {
  26. if address, err := svc.Service.GetAddress(query); err != nil {
  27. return err
  28. } else {
  29. rsp.Data = address
  30. }
  31. return nil
  32. }
  33. func (svc *Address) UpdateAddress(ctx context.Context, query *pb.UpdateAddressRequest, rsp *pb.UpdateAddressResponse) error {
  34. if err := svc.Service.UpdateAddress(query); err != nil {
  35. return err
  36. }
  37. return nil
  38. }
  39. func (svc *Address) DeleteAddress(ctx context.Context, query *pb.DeleteAddressRequest, rsp *pb.DeleteAddressResponse) error {
  40. if err := svc.Service.DeleteAddress(query); err != nil {
  41. return err
  42. }
  43. return nil
  44. }