add alipay customs interface

alipay/customs.go

@@ -0,0 +1,95 @@
+package alipay
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/go-pay/gopay"
+	"github.com/go-pay/gopay/pkg/xhttp"
+	"github.com/go-pay/gopay/pkg/xlog"
+)
+
+// alipay.trade.customs.declare(统一收单报关接口)
+//	文档地址：https://opendocs.alipay.com/apis/api_29/alipay.trade.customs.declare
+func (a *Client) TradeCustomsDeclare(bm gopay.BodyMap) (aliRsp *TradeCustomsDeclareRsp, err error) {
+	err = bm.CheckEmptyError("out_request_no", "trade_no", "merchant_customs_code", "merchant_customs_name", "amount", "customs_place")
+	if err != nil {
+		return nil, err
+	}
+	var bs []byte
+	if bs, err = a.doAliPay(bm, "alipay.trade.customs.declare"); err != nil {
+		return nil, err
+	}
+	aliRsp = new(TradeCustomsDeclareRsp)
+	if err = json.Unmarshal(bs, aliRsp); err != nil {
+		return nil, err
+	}
+	if aliRsp.Response != nil && aliRsp.Response.Code != "10000" {
+		info := aliRsp.Response
+		return nil, fmt.Errorf(`{"code":"%s","msg":"%s","sub_code":"%s","sub_msg":"%s"}`, info.Code, info.Msg, info.SubCode, info.SubMsg)
+	}
+	signData, signDataErr := a.getSignData(bs, aliRsp.AlipayCertSn)
+	aliRsp.SignData = signData
+	return aliRsp, a.autoVerifySignByCert(aliRsp.Sign, signData, signDataErr)
+}
+
+// alipay.acquire.customs(报关接口)
+//	文档地址：https://opendocs.alipay.com/pre-open/01x3kh
+func (a *Client) AcquireCustoms(bm gopay.BodyMap) (aliRspBs []byte, err error) {
+	err = bm.CheckEmptyError("partner", "out_request_no", "trade_no", "merchant_customs_code", "amount", "customs_place", "merchant_customs_name")
+	if err != nil {
+		return nil, err
+	}
+	bs, err := a.doAliPayCustoms(bm, "alipay.acquire.customs")
+	if err != nil {
+		return nil, err
+	}
+	return bs, nil
+}
+
+// alipay.overseas.acquire.customs.query(报关查询接口)
+//	文档地址：https://opendocs.alipay.com/pre-open/01x3ki
+func (a *Client) AcquireCustomsQuery(bm gopay.BodyMap) (aliRspBs []byte, err error) {
+	err = bm.CheckEmptyError("partner", "out_request_nos")
+	if err != nil {
+		return nil, err
+	}
+	bs, err := a.doAliPayCustoms(bm, "alipay.overseas.acquire.customs.query")
+	if err != nil {
+		return nil, err
+	}
+	return bs, nil
+}
+
+// 向支付宝发送请求
+func (a *Client) doAliPayCustoms(bm gopay.BodyMap, service string) (bs []byte, err error) {
+	bm.Set("service", service).
+		Set("_input_charset", "utf-8")
+	bm.Remove("sign_type")
+	bm.Remove("sign")
+
+	sign, err := GetRsaSign(bm, RSA, a.PrivateKeyType, a.PrivateKey)
+	if err != nil {
+		return nil, fmt.Errorf("GetRsaSign Error: %v", err)
+	}
+
+	bm.Set("sign_type", RSA).Set("sign", sign)
+	if a.DebugSwitch == gopay.DebugOn {
+		req, _ := json.Marshal(bm)
+		xlog.Debugf("Alipay_Request: %s", req)
+	}
+	param := FormatURLParam(bm)
+	// request
+	httpClient := xhttp.NewClient()
+	res, bs, errs := httpClient.Type(xhttp.TypeForm).Post("https://mapi.alipay.com/gateway.do").SendString(param).EndBytes()
+	if len(errs) > 0 {
+		return nil, errs[0]
+	}
+	if a.DebugSwitch == gopay.DebugOn {
+		xlog.Debugf("Alipay_Response: %s%d %s%s", xlog.Red, res.StatusCode, xlog.Reset, string(bs))
+	}
+	if res.StatusCode != 200 {
+		return nil, fmt.Errorf("HTTP Request Error, StatusCode = %d", res.StatusCode)
+	}
+	return bs, nil
+}

alipay/model.go

@@ -1041,3 +1041,23 @@ type MerchantItemFileUpload struct {
 	MaterialId  string `json:"material_id"`  // 文件在商品中心的素材标识（素材ID长期有效）
 	MaterialKey string `json:"material_key"` // 文件在商品中心的素材标示，创建/更新商品时使用
 }
+
+// ===============================================================
+type TradeCustomsDeclareRsp struct {
+	Response     *TradeCustomsDeclare `json:"alipay_trade_customs_declare_response"`
+	AlipayCertSn string               `json:"alipay_cert_sn,omitempty"`
+	SignData     string               `json:"-"`
+	Sign         string               `json:"sign"`
+}
+
+type TradeCustomsDeclare struct {
+	ErrorResponse
+	TradeNo          string `json:"trade_no,omitempty"`
+	AlipayDeclareNo  string `json:"alipay_declare_no"`
+	PayCode          string `json:"pay_code,omitempty"`
+	PayTransactionId string `json:"pay_transaction_id,omitempty"`
+	TotalAmount      string `json:"total_amount,omitempty"`
+	Currency         string `json:"currency,omitempty"`
+	VerDept          string `json:"ver_dept,omitempty"`
+	IdentityCheck    string `json:"identity_check,omitempty"`
+}