소스 검색

update err return

Jerry 6 년 전
부모
커밋
ee8c29e0f8
2개의 변경된 파일32개의 추가작업 그리고 37개의 파일을 삭제
  1. 14 19
      alipay_service_api.go
  2. 18 18
      wechat_client.go

+ 14 - 19
alipay_service_api.go

@@ -12,7 +12,6 @@ import (
 	"errors"
 	"fmt"
 	"hash"
-	"log"
 	"net/http"
 	"reflect"
 	"strings"
@@ -57,7 +56,7 @@ func ParseAliPayNotifyResult(req *http.Request) (notifyReq *AliPayNotifyRequest,
 		bills := make([]fundBillListInfo, 0)
 		err = json.Unmarshal([]byte(billList), &bills)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 		}
 		notifyReq.FundBillList = bills
 	} else {
@@ -70,7 +69,7 @@ func ParseAliPayNotifyResult(req *http.Request) (notifyReq *AliPayNotifyRequest,
 		details := make([]voucherDetailListInfo, 0)
 		err = json.Unmarshal([]byte(detailList), &details)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 		}
 		notifyReq.VoucherDetailList = details
 	} else {
@@ -166,13 +165,13 @@ func VerifyAliPaySign(aliPayPublicKey string, bean interface{}, syncSign ...stri
 
 	bs, err = json.Marshal(bean)
 	if err != nil {
-		return false, err
+		return false, fmt.Errorf("json.Marshal:%v", err.Error())
 	}
 
 	bm = make(BodyMap)
 	err = json.Unmarshal(bs, &bm)
 	if err != nil {
-		return false, err
+		return false, fmt.Errorf("json.Unmarshal:%v", err.Error())
 	}
 
 	bodySign = bm.Get("sign")
@@ -199,10 +198,7 @@ func verifyAliPaySign(signData, sign, signType, aliPayPublicKey string) (err err
 		h     hash.Hash
 		hashs crypto.Hash
 	)
-	signBytes, err := base64.StdEncoding.DecodeString(sign)
-	if err != nil {
-		return err
-	}
+	signBytes, _ := base64.StdEncoding.DecodeString(sign)
 	//解析秘钥
 	block, _ := pem.Decode([]byte(aliPayPublicKey))
 	if block == nil {
@@ -210,8 +206,7 @@ func verifyAliPaySign(signData, sign, signType, aliPayPublicKey string) (err err
 	}
 	key, err := x509.ParsePKIXPublicKey(block.Bytes)
 	if err != nil {
-		log.Println("x509.ParsePKIXPublicKey:", err)
-		return err
+		return fmt.Errorf("x509.ParsePKIXPublicKey:%v", err.Error())
 	}
 	publicKey, ok := key.(*rsa.PublicKey)
 	if !ok {
@@ -235,16 +230,16 @@ func verifyAliPaySign(signData, sign, signType, aliPayPublicKey string) (err err
 
 func jsonToString(v interface{}) (str string) {
 	if v == nil {
-		return ""
+		return null
 	}
 	bs, err := json.Marshal(v)
 	if err != nil {
-		fmt.Println("err:", err)
-		return ""
+		//fmt.Println("err:", err)
+		return null
 	}
 	s := string(bs)
-	if s == "null" {
-		return ""
+	if s == null {
+		return null
 	}
 	return s
 }
@@ -331,7 +326,7 @@ func DecryptAliPayOpenDataToStruct(encryptedData, secretKey string, beanPtr inte
 
 	block, err := aes.NewCipher(aesKey)
 	if err != nil {
-		return err
+		return fmt.Errorf("aes.NewCipher:%v", err.Error())
 	}
 	if len(secretData)%len(aesKey) != 0 {
 		return errors.New("encryptedData is error")
@@ -348,7 +343,7 @@ func DecryptAliPayOpenDataToStruct(encryptedData, secretKey string, beanPtr inte
 	//解析
 	err = json.Unmarshal(originData, beanPtr)
 	if err != nil {
-		return err
+		return fmt.Errorf("json.Unmarshal:%v", err.Error())
 	}
 	return nil
 }
@@ -380,7 +375,7 @@ func AliPaySystemOauthToken(appId, privateKey, grantType, codeOrToken string) (r
 	rsp = new(AliPaySystemOauthTokenResponse)
 	err = json.Unmarshal(bs, rsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("json.Unmarshal:%v", err.Error())
 	}
 	if rsp.AliPaySystemOauthTokenResponse.AccessToken != "" {
 		return rsp, nil

+ 18 - 18
wechat_client.go

@@ -52,7 +52,7 @@ func (this *weChatClient) Micropay(body BodyMap) (wxRsp *WeChatMicropayResponse,
 	wxRsp = new(WeChatMicropayResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -80,7 +80,7 @@ func (this *weChatClient) UnifiedOrder(body BodyMap) (wxRsp *WeChatUnifiedOrderR
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
 		//fmt.Println("xml.Unmarshal.Err:", err)
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -105,7 +105,7 @@ func (this *weChatClient) QueryOrder(body BodyMap) (wxRsp *WeChatQueryOrderRespo
 	wxRsp = new(WeChatQueryOrderResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -130,7 +130,7 @@ func (this *weChatClient) CloseOrder(body BodyMap) (wxRsp *WeChatCloseOrderRespo
 	wxRsp = new(WeChatCloseOrderResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -144,12 +144,12 @@ func (this *weChatClient) Reverse(body BodyMap, certFilePath, keyFilePath, pkcs1
 		pkcsPool := x509.NewCertPool()
 		pkcs, err := ioutil.ReadFile(pkcs12FilePath)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("ioutil.ReadFile:%v", err.Error())
 		}
 		pkcsPool.AppendCertsFromPEM(pkcs)
 		certificate, err := tls.LoadX509KeyPair(certFilePath, keyFilePath)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("tls.LoadX509KeyPair:%v", err.Error())
 		}
 		tlsConfig := new(tls.Config)
 		tlsConfig.Certificates = []tls.Certificate{certificate}
@@ -170,7 +170,7 @@ func (this *weChatClient) Reverse(body BodyMap, certFilePath, keyFilePath, pkcs1
 	wxRsp = new(WeChatReverseResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -184,12 +184,12 @@ func (this *weChatClient) Refund(body BodyMap, certFilePath, keyFilePath, pkcs12
 		pkcsPool := x509.NewCertPool()
 		pkcs, err := ioutil.ReadFile(pkcs12FilePath)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("ioutil.ReadFile:%v", err.Error())
 		}
 		pkcsPool.AppendCertsFromPEM(pkcs)
 		certificate, err := tls.LoadX509KeyPair(certFilePath, keyFilePath)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("tls.LoadX509KeyPair:%v", err.Error())
 		}
 		tlsConfig := new(tls.Config)
 		tlsConfig.Certificates = []tls.Certificate{certificate}
@@ -210,7 +210,7 @@ func (this *weChatClient) Refund(body BodyMap, certFilePath, keyFilePath, pkcs12
 	wxRsp = new(WeChatRefundResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -235,7 +235,7 @@ func (this *weChatClient) QueryRefund(body BodyMap) (wxRsp *WeChatQueryRefundRes
 	wxRsp = new(WeChatQueryRefundResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }
@@ -267,12 +267,12 @@ func (this *weChatClient) DownloadFundFlow(body BodyMap, certFilePath, keyFilePa
 		pkcsPool := x509.NewCertPool()
 		pkcs, err := ioutil.ReadFile(pkcs12FilePath)
 		if err != nil {
-			return null, err
+			return null, fmt.Errorf("ioutil.ReadFile:%v", err.Error())
 		}
 		pkcsPool.AppendCertsFromPEM(pkcs)
 		certificate, err := tls.LoadX509KeyPair(certFilePath, keyFilePath)
 		if err != nil {
-			return null, err
+			return null, fmt.Errorf("tls.LoadX509KeyPair:%v", err.Error())
 		}
 		tlsConfig := new(tls.Config)
 		tlsConfig.Certificates = []tls.Certificate{certificate}
@@ -303,12 +303,12 @@ func (this *weChatClient) BatchQueryComment(body BodyMap, certFilePath, keyFileP
 		pkcsPool := x509.NewCertPool()
 		pkcs, err := ioutil.ReadFile(pkcs12FilePath)
 		if err != nil {
-			return null, err
+			return null, fmt.Errorf("ioutil.ReadFile:%v", err.Error())
 		}
 		pkcsPool.AppendCertsFromPEM(pkcs)
 		certificate, err := tls.LoadX509KeyPair(certFilePath, keyFilePath)
 		if err != nil {
-			return null, err
+			return null, fmt.Errorf("tls.LoadX509KeyPair:%v", err.Error())
 		}
 		tlsConfig := new(tls.Config)
 		tlsConfig.Certificates = []tls.Certificate{certificate}
@@ -343,12 +343,12 @@ func (this *weChatClient) Transfer(body BodyMap, certFilePath, keyFilePath, pkcs
 	pkcsPool := x509.NewCertPool()
 	pkcs, err := ioutil.ReadFile(pkcs12FilePath)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("ioutil.ReadFile:%v", err.Error())
 	}
 	pkcsPool.AppendCertsFromPEM(pkcs)
 	certificate, err := tls.LoadX509KeyPair(certFilePath, keyFilePath)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("tls.LoadX509KeyPair:%v", err.Error())
 	}
 	tlsConfig := new(tls.Config)
 	tlsConfig.Certificates = []tls.Certificate{certificate}
@@ -379,7 +379,7 @@ func (this *weChatClient) Transfer(body BodyMap, certFilePath, keyFilePath, pkcs
 	wxRsp = new(WeChatTransfersResponse)
 	err = xml.Unmarshal(bytes, wxRsp)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("xml.Unmarshal:%v", err.Error())
 	}
 	return wxRsp, nil
 }