lijianbin
3 years ago
5 changed files with 134 additions and 121 deletions
Unified View
Diff Options
-
+73 -71account.client.go
-
+45 -45common.go
-
+1 -1go.mod
-
+4 -4go.sum
-
+11 -0user.proto
+ 73
- 71
account.client.go
View File
| @ -1,106 +1,108 @@ | |||||
| package userrpc | package userrpc | ||||
| import ( | import ( | ||||
| "encoding/json" | "encoding/json" | ||||
| "errors" | "errors" | ||||
| ) | ) | ||||
| /** | /** | ||||
| * 获取用户积分 | * 获取用户积分 | ||||
| */ | */ | ||||
| func GetUserScore(dbname,userId string, url ...string) (string, error) { | func GetUserScore(dbname, userId string, url ...string) (string, error) { | ||||
| if dbname == "" || userId == "" { | if dbname == "" || userId == "" { | ||||
| return "", errors.New("参数错误") | return "", errors.New("参数错误") | ||||
| } | } | ||||
| conn, err := rpc_server_conn(url...) | conn, err := rpc_server_conn(url...) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| defer conn.Close() | defer conn.Close() | ||||
| data := GetUserReq{} | data := GetUserReq{} | ||||
| data.Dbname = dbname | data.Dbname = dbname | ||||
| data.UserId = userId | data.UserId = userId | ||||
| req, err := SetReqData(data) | req, err := SetReqData(data) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| res := &Response{} | res := &Response{} | ||||
| err = conn.GetUserScore(req, res) | err = conn.GetUserScore(req, res) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| res_data_de, err := GetResData(res) | res_data_de, err := GetResData(res) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| if res_data_de == "" { | if res_data_de == "" { | ||||
| return "", nil | return "", nil | ||||
| } | } | ||||
| var score string | var score string | ||||
| err = json.Unmarshal([]byte(res_data_de),&score) | err = json.Unmarshal([]byte(res_data_de), &score) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| return score, nil | return score, nil | ||||
| } | } | ||||
| /** | /** | ||||
| * 获取用户红包 | * 获取用户红包 | ||||
| */ | */ | ||||
| func GetUserRedEnvelope(dbname,userId string, url ...string) (string, error) { | func GetUserRedEnvelope(dbname, userId string, url ...string) (string, error) { | ||||
| if dbname == "" || userId == "" { | if dbname == "" || userId == "" { | ||||
| return "", errors.New("参数错误") | return "", errors.New("参数错误") | ||||
| } | } | ||||
| conn, err := rpc_server_conn(url...) | conn, err := rpc_server_conn(url...) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| defer conn.Close() | defer conn.Close() | ||||
| data := GetUserReq{} | data := GetUserReq{} | ||||
| data.Dbname = dbname | data.Dbname = dbname | ||||
| data.UserId = userId | data.UserId = userId | ||||
| req, err := SetReqData(data) | req, err := SetReqData(data) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| res := &Response{} | res := &Response{} | ||||
| err = conn.GetUserRedEnvelope(req, res) | err = conn.GetUserRedEnvelope(req, res) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| res_data_de, err := GetResData(res) | res_data_de, err := GetResData(res) | ||||
| if err != nil { | if err != nil { | ||||
| return "", err | return "", err | ||||
| } | } | ||||
| if res_data_de == "" { | if res_data_de == "" { | ||||
| return "", nil | return "", nil | ||||
| } | } | ||||
| var redEnvelope string | var redEnvelope string | ||||
| err = json.Unmarshal([]byte(res_data_de),&redEnvelope) | err = json.Unmarshal([]byte(res_data_de), &redEnvelope) | ||||
| if err != nil { | |||||
| return "", err | |||||
| } | |||||
| return redEnvelope, nil | |||||
| } | |||||
| if err != nil { | |||||
| return "", err | |||||
| } | |||||
| return redEnvelope, nil | |||||
| } | |||||
+ 45
- 45
common.go
View File
| @ -1,83 +1,83 @@ | |||||
| package userrpc | package userrpc | ||||
| import ( | import ( | ||||
| "git.tetele.net/tgo/conf" | "git.tetele.net/tgo/conf" | ||||
| ) | ) | ||||
| const DES_KEY = "usersrpc" | const DES_KEY = "usersrpc" | ||||
| type Req struct { | type Req struct { | ||||
| SiteId string | SiteId string | ||||
| Dbname string | Dbname string | ||||
| } | } | ||||
| type Third struct { | type Third struct { | ||||
| Userid string | Userid string | ||||
| Platform string | Platform string | ||||
| Openid string | Openid string | ||||
| Openname string | Openname string | ||||
| Unionid string | Unionid string | ||||
| Avatar string | Avatar string | ||||
| Mobile string | Mobile string | ||||
| } | } | ||||
| type BindThirdReq struct { | type BindThirdReq struct { | ||||
| Req | Req | ||||
| Third | Third | ||||
| } | } | ||||
| type GetThirdReq struct { | type GetThirdReq struct { | ||||
| Req | Req | ||||
| Userid string | Userid string | ||||
| Platform string | Platform string | ||||
| } | } | ||||
| type GetBusinessReq struct { | type GetBusinessReq struct { | ||||
| Req | Req | ||||
| BusinessId string | BusinessId string | ||||
| } | } | ||||
| type GetUserReq struct { | type GetUserReq struct { | ||||
| Req | Req | ||||
| UserId string | UserId string | ||||
| } | } | ||||
| type GetAddressReq struct { | type GetAddressReq struct { | ||||
| Req | Req | ||||
| AddressId string | AddressId string | ||||
| } | } | ||||
| type Res struct { | type Res struct { | ||||
| Errcode int | Errcode int | ||||
| Errmsg string | Errmsg string | ||||
| } | } | ||||
| type Business struct { | type Business struct { | ||||
| Type string | Type string | ||||
| BusinessId string | BusinessId string | ||||
| CustomerId string | CustomerId string | ||||
| Name string | Name string | ||||
| CompanyId string | CompanyId string | ||||
| Contact string | Contact string | ||||
| Mobile string | Mobile string | ||||
| HandingFee string | HandingFee string | ||||
| IsOpen string | IsOpen string | ||||
| } | } | ||||
| func rpc_server_conn(url ...string) (*UserServiceClient, error) { | func rpc_server_conn(url ...string) (*UserServiceClient, error) { | ||||
| var rpc_url string | var rpc_url string | ||||
| if len(url) > 0 && url[0] != "" { | if len(url) > 0 && url[0] != "" { | ||||
| rpc_url = url[0] | rpc_url = url[0] | ||||
| } else if conf.USER_RPC_URL != "" { | } else if conf.USER_RPC_URL != "" { | ||||
| rpc_url = conf.USER_RPC_URL | rpc_url = conf.USER_RPC_URL | ||||
| } else { | } else { | ||||
| rpc_url = "127.0.0.1:" + conf.USER_RPC_PORT | rpc_url = "127.0.0.1:" + conf.USER_RPC_PORT | ||||
| } | } | ||||
| conn, _, err := DialUserService("tcp", rpc_url) | conn, _, err := DialUserService("tcp", rpc_url) | ||||
| if err != nil { | if err != nil { | ||||
| return nil, err | return nil, err | ||||
| } | } | ||||
| return conn, nil | return conn, nil | ||||
| } | } | ||||