/
user_provider2.go
96 lines (76 loc) · 1.76 KB
/
user_provider2.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
package main
import (
"context"
"fmt"
"strconv"
)
import (
"github.com/apache/dubbo-go/config"
"github.com/dubbogo/gost/log"
perrors "github.com/pkg/errors"
)
func init() {
config.SetProviderService(new(UserProvider2))
}
type UserProvider2 struct {
}
func (u *UserProvider2) getUser(userID string) (*User, error) {
if user, ok := userMap[userID]; ok {
return &user, nil
}
return nil, fmt.Errorf("invalid user id:%s", userID)
}
func (u *UserProvider2) GetUser(ctx context.Context, req []interface{}, rsp *User) error {
var (
err error
user *User
)
gxlog.CInfo("req:%#v", req)
user, err = u.getUser(req[0].(string))
if err == nil {
*rsp = *user
gxlog.CInfo("rsp:%#v", rsp)
}
return err
}
func (u *UserProvider2) GetUser0(id string, name string) (User, error) {
var err error
gxlog.CInfo("id:%s, name:%s", id, name)
user, err := u.getUser(id)
if err != nil {
return User{}, err
}
if user.Name != name {
return User{}, perrors.New("name is not " + user.Name)
}
return *user, err
}
func (u *UserProvider2) GetUser2(ctx context.Context, req []interface{}, rsp *User) error {
var err error
gxlog.CInfo("req:%#v", req)
rsp.ID = strconv.FormatFloat(req[0].(float64), 'f', 0, 64)
rsp.Sex = Gender(MAN).String()
return err
}
func (u *UserProvider2) GetUser3() error {
return nil
}
func (u *UserProvider2) GetUsers(req []interface{}) ([]User, error) {
var err error
gxlog.CInfo("req:%s", req)
t := req[0].([]interface{})
user, err := u.getUser(t[0].(string))
if err != nil {
return nil, err
}
gxlog.CInfo("user:%v", user)
return []User{*user}, err
}
func (s *UserProvider2) MethodMapper() map[string]string {
return map[string]string{
"GetUser2": "getUser",
}
}
func (u *UserProvider2) Reference() string {
return "UserProvider2"
}