From fabb9415151f1d942a0b5c438876981bc3ddbe60 Mon Sep 17 00:00:00 2001 From: guzeng Date: Wed, 2 Jun 2021 17:52:39 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=8E=A5=E5=8F=A3=E8=B0=83?= =?UTF-8?q?=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cancel.go | 70 ++++++++++++++++++++++++++++++++++++++++++++++++++ cancel_test.go | 13 ++++++++++ common.go | 62 ++++++++++++++++++++++++++++++++++++++++++++ go.mod | 7 +++++ go.sum | 23 +++++++++++++++++ 5 files changed, 175 insertions(+) create mode 100644 cancel.go create mode 100644 cancel_test.go create mode 100644 common.go create mode 100644 go.sum diff --git a/cancel.go b/cancel.go new file mode 100644 index 0000000..9b36d68 --- /dev/null +++ b/cancel.go @@ -0,0 +1,70 @@ +package orderrpc + +import ( + "encoding/json" + "strconv" + "time" + + "git.tetele.net/tgo/crypter" + + "github.com/golang/protobuf/proto" +) + +type OrderCancelRes struct { + Success bool +} + +func Cancel(dbname, site_id string, order_id string, url ...string) (*OrderCancelRes, error) { + + conn, err := rpc_server_conn(url...) + if err != nil { + return nil, err + } + defer conn.Close() + + data := map[string]string{ + "dbname": dbname, + "site_id": site_id, + "order_id": order_id, + } + + data_json, err := json.Marshal(data) + if err != nil { + return nil, err + } + + encryData := crypter.DesEn(string(data_json), DES_KEY) + + now_int64 := time.Now().Unix() + + now := strconv.FormatInt(now_int64, 10) + + sign := Sign(encryData, now) + + req := &CreateRequest{ + proto.String(encryData), + proto.String(now), + proto.String(sign), + nil} + + res := &CreateResponse{} + + err = conn.Cancel(req, res) + + if err != nil { + return nil, err + } + + res_data, err := HandleResponse(res) + + var res_arr OrderCancelRes + + err = json.Unmarshal([]byte(res_data), &res_arr) + + if err != nil { + return nil, err + } + + return &res_arr, nil + +} diff --git a/cancel_test.go b/cancel_test.go new file mode 100644 index 0000000..ff750b8 --- /dev/null +++ b/cancel_test.go @@ -0,0 +1,13 @@ +package orderrpc + +import ( + "testing" +) + +func Test_Cancel(t *testing.T) { + + ret, err := Cancel("jianfan", "100064", "2") + + t.Log(ret) + t.Log(err) +} diff --git a/common.go b/common.go new file mode 100644 index 0000000..59e2e73 --- /dev/null +++ b/common.go @@ -0,0 +1,62 @@ +package orderrpc + +import ( + "errors" + "strconv" + "time" + + "git.tetele.net/tgo/crypter" +) + +const DES_KEY = "ordernew" + +func rpc_server_conn(url ...string) (*OrderServiceClient, error) { + + var order_rpc_url string = "127.0.0.1:7973" + if len(url) > 0 && url[0] != "" { + order_rpc_url = url[0] + } + + conn, _, err := DialOrderService("tcp", order_rpc_url) + if err != nil { + return nil, err + } + + return conn, nil +} + +/** + * 处理返回结果 + */ +func HandleResponse(res *CreateResponse) (string, error) { + + res_data := res.GetData() + + if res_data == "" { + + return "", errors.New("未收到收据") + } + + time_int64, err := strconv.ParseInt(res.GetTime(), 10, 64) + if err != nil { + return "", err + } + + now_int64 := time.Now().Unix() + + if now_int64-time_int64 > 10 || time_int64-now_int64 > 10 { + //时间误差前后10秒，返回 + return "", errors.New("返回时间错误") + } + + check_sign := CheckSign(res.GetSign(), res_data, res.GetTime()) + if !check_sign { + return "", errors.New("返回数据签名错误") + } + + //解密 + res_data_de := crypter.DesDe(res_data, "ordernew") + + return res_data_de, nil + +} diff --git a/go.mod b/go.mod index 8418bf5..722a7d9 100644 --- a/go.mod +++ b/go.mod @@ -1,3 +1,10 @@ module git.tetele.net/tgo/orderrpc go 1.14 + +require ( + git.tetele.net/tgo/crypter v0.2.2 + github.com/chai2010/protorpc v1.0.0 + github.com/golang/protobuf v1.5.2 + golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a // indirect +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..448520e --- /dev/null +++ b/go.sum @@ -0,0 +1,23 @@ +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= +github.com/chai2010/protorpc v1.0.0/go.mod h1:woR3WwjaQDqFjlzdVsFEKiK5Ur12QL8mYxVPjfr5z54= +github.com/golang/protobuf v1.0.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= +github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= +github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw= +github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= +github.com/golang/snappy v0.0.0-20170215233205-553a64147049 h1:K9KHZbXKpGydfDN0aZrsoHpLJlZsBrGMFWbgLDGnPZk= +github.com/golang/snappy v0.0.0-20170215233205-553a64147049/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= +github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU= +github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a h1:kr2P4QFmQr29mSLA43kwrOcgcReGTfbE9N577tCTuBc= +golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a/go.mod h1:P+XmwS30IXTQdn5tA2iutPOUgjI07+tq3H3K9MVA1s8= +golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= +google.golang.org/protobuf v1.26.0 h1:bxAC2xTBsZGibn2RTntX0oH50xLsqy1OxA9tTL3p/lk= +google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=