Browse Source

连接服务时增加对配置的判断

master v0.3.0
guzeng 2 years ago
parent
commit
c048d7631d
4 changed files with 33 additions and 14 deletions
  1. +11
    -3
      common.go
  2. +1
    -0
      go.mod
  3. +2
    -0
      go.sum
  4. +19
    -11
      third.client_test.go

+ 11
- 3
common.go View File

@ -1,5 +1,9 @@
package userrpc
import (
"git.tetele.net/tgo/conf"
)
const DES_KEY = "usersrpc"
type Req struct {
@ -52,12 +56,16 @@ type Business struct {
func rpc_server_conn(url ...string) (*UserServiceClient, error) {
var user_rpc_url string = "127.0.0.1:7976"
var rpc_url string
if len(url) > 0 && url[0] != "" {
user_rpc_url = url[0]
rpc_url = url[0]
} else if conf.USER_RPC_URL != "" {
rpc_url = conf.USER_RPC_URL
} else {
rpc_url = "127.0.0.1:" + conf.USER_RPC_PORT
}
conn, _, err := DialUserService("tcp", user_rpc_url)
conn, _, err := DialUserService("tcp", rpc_url)
if err != nil {
return nil, err
}


+ 1
- 0
go.mod View File

@ -3,6 +3,7 @@ module git.tetele.net/tgo/userrpc
go 1.14
require (
git.tetele.net/tgo/conf v0.33.1 // indirect
git.tetele.net/tgo/crypter v0.2.2 // indirect
github.com/chai2010/protorpc v1.0.0
github.com/golang/protobuf v1.0.0


+ 2
- 0
go.sum View File

@ -1,3 +1,5 @@
git.tetele.net/tgo/conf v0.33.1 h1:ZEIv3Vq35RCv5f3T3Uz97s2mkZLl7W5OlmXvzI3/sS8=
git.tetele.net/tgo/conf v0.33.1/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
git.tetele.net/tgo/crypter v0.2.2 h1:YMQJh2Gj5Po4ZfelJUmXBKi01UbmtiSy3bmqRfnYQMo=
git.tetele.net/tgo/crypter v0.2.2/go.mod h1:vfvRLZA8+lHNgNXneOcgvVhDyuv25ZRb+C6xHOmXNx0=
github.com/chai2010/protorpc v1.0.0 h1:aJ45G9sl1utSKo35EqnBSTs5jqTpdJDJAuZMMYPAtFo=


+ 19
- 11
third.client_test.go View File

@ -2,19 +2,27 @@ package userrpc
import (
"testing"
"git.tetele.net/tgo/crypter"
)
func Test_BindThird(t *testing.T) {
dbname := "test1_tetele_com"
site_id := "1001"
platform := "deliver_mini"
user_id := "1"
openid := "CasfoieFsdfsdfiDiodf_df"
openname := "测试中"
avatar := "https://ssss.ttt.ddd/sfsd"
mobile := "1234456456"
res, err := BindThird(site_id, dbname, platform, user_id, openid, openname, "", avatar, mobile)
t.Log(res)
t.Log(err)
// dbname := "test1_tetele_com"
// site_id := "1001"
// platform := "deliver_mini"
// user_id := "1"
// openid := "CasfoieFsdfsdfiDiodf_df"
// openname := "测试中"
// avatar := "https://ssss.ttt.ddd/sfsd"
// mobile := "1234456456"
// res, err := BindThird(site_id, dbname, platform, user_id, openid, openname, "", avatar, mobile)
// t.Log(res)
// t.Log(err)
// data := "E5B2642BDEA1FBC85BA958C398E58DEC2E1425E26E25D6A178DBD078AD0DFC6859DF5634B0A01CE01F84E056380981A1F1433044FB197D8965FD8F3322DF2373619AD4ACB158605B45AC3947B200C8B62C2B30256B2D2D7283492F268F609944"
data := "E5B2642BDEA1FBC85BA958C398E58DEC2E1425E26E25D6A178DBD078AD0DFC6859DF5634B0A01CE01F84E056380981A1F1433044FB197D89AF51E05A9E9F5C76BE8F563F2E4D42AB3C3C649B4187A7C48E98988C734CEACD"
org := crypter.DesDe(data, DES_KEY)
t.Log(org)
}

Loading…
Cancel
Save