|
@@ -36,12 +36,7 @@ type DefaultRpcClient struct {
|
|
|
}
|
|
|
|
|
|
func (d *DefaultRpcClient) WrapSign(request interface{}, doHandler func(ctx context.Context, req interface{}) error) {
|
|
|
- reqStr, err := json.Marshal(request)
|
|
|
- if err != nil {
|
|
|
- utils.FileLog.Error("序列化请求失败:%v", err)
|
|
|
- return
|
|
|
- }
|
|
|
- timestamp, nonce, sign, _ := d.signature(reqStr, 16)
|
|
|
+ timestamp, nonce, sign, _ := d.signature(request, 16)
|
|
|
fmt.Println(string(sign))
|
|
|
ctx := metadata.NewOutgoingContext(context.Background(), metadata.Pairs(
|
|
|
"nonce", nonce,
|
|
@@ -49,7 +44,7 @@ func (d *DefaultRpcClient) WrapSign(request interface{}, doHandler func(ctx cont
|
|
|
"signature", sign,
|
|
|
))
|
|
|
|
|
|
- err = doHandler(ctx, request)
|
|
|
+ err := doHandler(ctx, request)
|
|
|
if err != nil {
|
|
|
utils.FileLog.Error("调用PRC服务失败:%v", err)
|
|
|
}
|
|
@@ -133,7 +128,6 @@ func (d *DefaultRpcClient) signature(req interface{}, nonceLen int) (timestamp i
|
|
|
utils.FileLog.Error("RSA加密失败: %v", err)
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
|
|
|
encodedData = base64.StdEncoding.EncodeToString(encryptedData)
|
|
|
return
|