付呗支付

lib/fb_pay/api.go

@@ -0,0 +1,92 @@
+package fb_pay
+
+const (
+	ReqHeader = "application/json; charset=utf-8"
+	TestUrl   = "https://shq-api.51fubei.com/gateway/agent"
+	PrdUrl    = "https://shq-api.51fubei.com/gateway/agent"
+	//Methods 接口名称
+
+	Unification       = "fbpay.order.create"                         //统一支付
+	OrderQrcode       = "fbpay.order.qrcode"                         //支付宝跳转支付
+	AggregateCode     = "fbpay.fixed.qrcode.create"                  //聚合码支付
+	PaymentCode       = "fbpay.order.pay"                            //付款码支付
+	OrderQuery        = "fbpay.order.query"                          //订单查询
+	Refund            = "fbpay.order.refund"                         //退款
+	RefundQuery       = "fbpay.order.refund.query"                   //退款查询
+	WechatPaymentAuth = "openapi.agent.merchant.wechat.payment.auth" //微信网页授权
+	UnionPaymentAuth  = "openapi.agent.merchant.union.payment.auth"  //银联云闪付授权
+
+)
+
+type BaseParameters struct {
+	VendorSn   string `json:"vendor_sn" label:"服务商开放平台id（服务商后台生成），服务商级接入该字段必填，与app_id二选一，根据接口级别进行判定"`
+	AppId      string `json:"app_id" label:"商户开放平台id（商户后台生成），商户级接入该字段必填，与vendor_sn二选一，根据接口级别进行判定"`
+	Method     string `json:"method" label:"接口名称"`
+	Format     string `json:"format" label:"接口格式，默认json"`
+	SignMethod string `json:"sign_method" label:"签名算法，默认md5"`
+	Nonce      string `json:"nonce" label:"请求端随机生成数"`
+	Version    string `json:"version" label:"接口版本，默认1.0"`
+	BizContent string `json:"biz_content" label:"请求参数的集合，除公共参数外所有请求参数都必须放在这个参数中"`
+}
+
+type RequestParameters struct {
+	BaseParameters
+	Sign string `json:"sign" label:"签名"`
+}
+
+type OrderCreateParameters struct {
+	OrderCreateMustParameters
+	PayWay             string `json:"pay_way" label:"02：公众号,03：小程序"`
+	StoreId            int64  `json:"store_id" label:"商户门店号（如果只有一家有效门店，可不传）"`
+	CashierId          int64  `json:"cashier_id" label:"收银员ID"`
+	SubAppid           string `json:"sub_appid" label:"公众号appid/小程序appid。当微信支付时，该字段必填（user_id需要保持一致，即为该公众号appid获取的）间联商户需提前配置对应公众号appid，对应配置接口"`
+	Royalty            int    `json:"royalty" label:"1	分账自定义打标参数,1：参与分账（需开白名单）,不传则默认不参与分账"`
+	GoodsTag           string `json:"goods_tag" label:"订单优惠标记，代金券或立减优惠功能的参数（使用单品券时必传）"`
+	Detail             string `json:"detail" label:"订单包含的商品信息，Json格式。当当微信支付或者支付宝支付时时可选填此字段。对于使用单品优惠的商户，该字段必须按照规范上传，详见“单品优惠参数说明”"`
+	DeviceNo           string `json:"device_no" label:"终端号"`
+	Body               string `json:"body" label:"商品描述"`
+	Attach             string `json:"attach" label:"附加数据，原样返回，该字段主要用于商户携带订单的自定义数据"`
+	TimeoutExpress     string `json:"timeout_express" label:"订单失效时间，逾期将关闭交易。格式为yyyyMMddHHmmss，失效时间需大于1分钟。银联暂不支持"`
+	NotifyUrl          string `json:"notify_url" label:"支付回调地址"`
+	AlipayExtendParams string `json:"alipay_extend_params" label:"支付宝业务拓展参数--花呗分期"`
+	PlatformStoreId    string `json:"platform_store_id" label:"平台方门店号（即微信/支付宝的storeid）"`
+	DisablePayChannels string `json:"disable_pay_channels" label:"禁止使用优惠券标识,promotion-支付宝优惠（包含实时优惠+商户优惠）"`
+	Remark             string `json:"remark" label:"备注"`
+}
+
+type OrderCreateMustParameters struct {
+	MerchantOrderSn string  `json:"merchant_order_sn" binding:"required" label:"外部系统订单号（确保唯一，前后不允许带空格）"`
+	PayType         string  `json:"pay_type" binding:"required" label:"支付方式，,wxpay 微信，,alipay 支付宝,unionpay 银联云闪付"`
+	TotalAmount     float64 `json:"total_amount" binding:"订单总金额，单位为元，精确到0.01 ~ 10000000"`
+	UserId          string  `json:"user_id" binding:"required" label:"用户标识,微信openid.支付宝userid,银联云闪付upUserId"`
+	MerchantId      int64   `json:"merchant_id" label:"付呗商户号，以服务商级接入时必传，以商户级接入时不传"`
+}
+
+type OrderCreateDetailParameters struct {
+	CostPrice   int64  `json:"cost_price" label:"1.商户侧一张小票订单可能被分多次支付，订单原价用于记录整张小票的交易金额。2.当订单原价与支付金额不相等，则不享受优惠。3.该字段主要用于防止同一张小票分多次支付，以享受多次优惠的情况，正常支付订单不必上传此参数。"`
+	ReceiptId   string `json:"receipt_id" label:"商家小票ID"`
+	GoodsDetail string `json:"total_amount" binding:"单品信息，使用Json数组格式提交，见下文说明"`
+}
+type OrderCreateDetailGoodsDetailParameters struct {
+	GoodsId   string `json:"goods_id"  binding:"required" label:"商品编码"`
+	GoodsName string `json:"goods_name"  binding:"required" label:"商品名称"`
+	Quantity  int    `json:"quantity"  binding:"required" label:"商品数量"`
+	Price     int64  `json:"price" binding:"required" label:"商品单价，单位为分"`
+}
+
+type OrderQrcodeParameters struct {
+	OrderQrcodeMustParameters
+	//CashierId          int64  `json:"cashier_id" label:"收银员ID"`
+	DeviceNo           string `json:"device_no" label:"终端号"`
+	Body               string `json:"body" label:"商品描述"`
+	Attach             string `json:"attach" label:"附加数据，原样返回，该字段主要用于商户携带订单的自定义数据"`
+	NotifyUrl          string `json:"notify_url" label:"支付回调地址"`
+	AlipayExtendParams string `json:"alipay_extend_params" label:"支付宝业务拓展参数--花呗分期"`
+}
+
+type OrderQrcodeMustParameters struct {
+	MerchantOrderSn string  `json:"merchant_order_sn" binding:"required" label:"外部系统订单号（确保唯一，前后不允许带空格）"`
+	PayType         string  `json:"pay_type" binding:"required" label:"支付方式，alipay 支付宝 (目前只支持支付宝扫码)"`
+	TotalAmount     float64 `json:"total_amount" binding:"订单总金额，单位为元，精确到0.01 ~ 10000000"`
+	StoreId         int64   `json:"store_id" binding:"required" label:"商户门店号"`
+}

lib/fb_pay/fb_pay.go

@@ -0,0 +1,105 @@
+package fb_pay
+
+import (
+	zhios_pay_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git/utils"
+	"errors"
+	"fmt"
+	"strings"
+)
+
+func GetUnificationByVendorSn(vendorSn string) *RequestParameters {
+	var rp RequestParameters
+	rp.VendorSn = vendorSn
+	rp.Method = Unification
+	return &rp
+}
+
+func GetOrderQrcodeByVendorSn(vendorSn string) *RequestParameters {
+	var rp RequestParameters
+	rp.VendorSn = vendorSn
+	rp.Method = OrderQrcode
+	return &rp
+}
+
+func GetAggregateCodeByVendorSn(vendorSn string) *RequestParameters {
+	var rp RequestParameters
+	rp.VendorSn = vendorSn
+	rp.Method = AggregateCode
+	return &rp
+}
+
+func GetRequestParametersByVendorSn(vendorSn string) *RequestParameters {
+	var rp RequestParameters
+	rp.VendorSn = vendorSn
+	return &rp
+}
+
+func GetUnificationByAppId(appId string) *RequestParameters {
+	var rp RequestParameters
+	rp.AppId = appId
+	rp.Method = Unification
+	return &rp
+}
+
+func GetOrderQrcodeByAppId(appId string) *RequestParameters {
+	var rp RequestParameters
+	rp.AppId = appId
+	rp.Method = OrderQrcode
+	return &rp
+}
+
+func GetAggregateCodeByAppId(appId string) *RequestParameters {
+	var rp RequestParameters
+	rp.AppId = appId
+	rp.Method = AggregateCode
+	return &rp
+}
+
+func GetRequestParametersByAppId(appId string) *RequestParameters {
+	var rp RequestParameters
+	rp.AppId = appId
+	return &rp
+}
+
+func (bp *BaseParameters) SetBizContent(param interface{}) {
+	fmt.Println("参数：", zhios_pay_utils.SerializeStr(param))
+	bp.BizContent = zhios_pay_utils.SerializeStr(param)
+}
+
+func (bp *BaseParameters) GetSign(appSecret string) string {
+	struct2Map := make(map[string]string)
+	zhios_pay_utils.Unserialize(zhios_pay_utils.Serialize(bp), &struct2Map)
+	needSignStr := zhios_pay_utils.JoinStringsInASCII(struct2Map, "&", "=", false, false)
+	needSignStr = needSignStr + appSecret
+	return strings.ToUpper(zhios_pay_utils.Md5(needSignStr))
+}
+
+func (rp *RequestParameters) SetSign(appSecret string) {
+	rp.Sign = rp.BaseParameters.GetSign(appSecret)
+}
+
+func (rp *RequestParameters) Send(prd bool) (string, error) {
+	if rp.Sign == "" {
+		return "", errors.New("请进行签名")
+	}
+	param := zhios_pay_utils.Struct2Map(rp)
+	for key, value := range param {
+		if value == "" {
+			delete(param, key)
+		}
+	}
+	url := TestUrl
+	if prd {
+		url = PrdUrl
+	}
+	headers := map[string]string{
+		"Content-Type": ReqHeader,
+	}
+	zhios_pay_utils.CurlDebug = true
+	res, err := zhios_pay_utils.CurlPost(url, zhios_pay_utils.SerializeStr(param), headers)
+	if err != nil {
+		return "", err
+	}
+	fmt.Println(string(res))
+	return string(res), nil
+}

test/ada_pay_test.go

@@ -211,3 +211,22 @@ func TestCreateAliPayQr(t *testing.T) {
 	}
 	t.Log(zhios_pay_utils.SerializeStr(data))
 }
+
+func TestPaymentQuery(t *testing.T) {
+	Adapay, err := adapay.GetAdapayByDBSysConfig("jiuhuicang", "app_a794b158-359b-4e5a-8464-5bd8f171bb6e", "api_live_419ec107-9854-45e8-af12-070efcef6ae9", "api_test_d6485653-c09e-405f-b386-8ef2936dfb97", "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCwN6xgd6Ad8v2hIIsQVnbt8a3JituR8o4Tc3B5WlcFR55bz4OMqrG/356Ur3cPbc2Fe8ArNd/0gZbC9q56Eb16JTkVNA/fye4SXznWxdyBPR7+guuJZHc/VW2fKH2lfZ2P3Tt0QkKZZoawYOGSMdIvO+WqK44updyax0ikK6JlNQIDAQAB",
+		"MIICeAIBADANBgkqhkiG9w0BAQEFAASCAmIwggJeAgEAAoGBAMxVAwWM79+2Lx1TYA4muHy40AbwcBwXmvgNJGp2gq7bcDaNd5cmvXndwS6exV2hIGo8er0Qu3myGrwD/4BIoqCDSuqYfJkrlKzKM30+WAfwRulrFW+SOr6qCvGFF2bMdL884NMgd5PCpayASONq/blefQ3/Ic+c0gtZQxJzYzxLAgMBAAECgYEAyS+rGfv68zpeiXFeUpCtdaBCs5Jp0D8txq6p/GlTovdNNWl1Js5uIV/GpjCOA/JyCCgkcaPX86r5x8Xn/FeIRt/U1kkGs2zvKcxQntkOhmzMdDe7/FuwbRUUeM6LWGIc5AeQcBWYZeS8HAFMnlWho+knMqqgHC/fgUyon6YgMAECQQDyjJYSp+hdhTnvo88GPisQEPOoZRbrUnVFbwjD/OrQT7s6uSlbTAJRXGEYfdeaWsh2CoFl986pOqc/84E/Lr3LAkEA16nd1J3stk9XtC4i+iiXY0codiK24kU+pMcEm8NNyMV1nQT5iTcDA1ZeJCgamJZFeqcfyusimBNbCXdBKk2rgQJBAIymodAntkOlIjepEkBYhLhIXENme6fypTaicL7WR4SM99HR1f2vUhjELTn6n7BOvLhW1zq+PQU9kgcvud9dx4kCQFSMXtBFHZEXp/2WfNXv5fHg6sbtsx8gIH//GhpqxerpJsPpOF8H9yFu0beBFXQurYx5SqiF6GkQZYdffme0TYECQQDgOdQxysI1FEM/l8BDnQgmnO7sJqUtP9HsVcKElGdkJMZGqb8B5rt12y4dxpyVfyaTMZZZjqIx8zgQBhn+l0NJ")
+	if err != nil {
+		t.Error(err)
+	}
+	createPaymentParams := map[string]interface{}{
+		"payment_id": "002112022102209243910429704781642039296",
+	}
+
+	data, apiError, err := Adapay.Payment().Query(createPaymentParams)
+	if err != nil || apiError != nil { // 网络或本应用异常
+		t.Error(err)
+		t.Error(apiError)
+		return
+	}
+	t.Log(zhios_pay_utils.SerializeStr(data))
+}

test/fb_pay_test.go

@@ -0,0 +1,79 @@
+package test
+
+import (
+	fb "code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git/lib/fb_pay"
+	zhios_pay_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git/utils"
+	"testing"
+	"time"
+)
+
+func TestFBPayUnification(t *testing.T) {
+	unification := fb.GetUnificationByVendorSn("2022120518415543840a")
+	var ordCreat fb.OrderCreateParameters
+	ordCreat.OrderCreateMustParameters.MerchantOrderSn = "202212061833-01"
+	ordCreat.OrderCreateMustParameters.TotalAmount = 0.1
+	ordCreat.OrderCreateMustParameters.PayType = "alipay"
+	ordCreat.OrderCreateMustParameters.UserId = "userid"
+	ordCreat.OrderCreateMustParameters.MerchantId = 1979251
+	unification.Nonce = ordCreat.OrderCreateMustParameters.MerchantOrderSn + time.Now().Format("20060102150405")
+	param := zhios_pay_utils.Struct2Map(ordCreat)
+	for key, value := range param {
+		if value == "" {
+			delete(param, key)
+		}
+	}
+	unification.SetBizContent(param)
+	unification.SetSign("c5d47b9e515594313d80fb9903ece2d8")
+	send, err := unification.Send(false)
+	if err != nil {
+		t.Error(err)
+	}
+	t.Logf("回调数据：%s\n", send)
+}
+
+func TestFBPayOrderQrcode(t *testing.T) {
+	unification := fb.GetOrderQrcodeByVendorSn("2022120518415543840a")
+	var orderQrcode fb.OrderQrcodeParameters
+	orderQrcode.OrderQrcodeMustParameters.MerchantOrderSn = "20221208-02"
+	orderQrcode.OrderQrcodeMustParameters.TotalAmount = 0.1
+	orderQrcode.OrderQrcodeMustParameters.PayType = "alipay"
+	orderQrcode.OrderQrcodeMustParameters.StoreId = 1331462
+	unification.Nonce = orderQrcode.OrderQrcodeMustParameters.MerchantOrderSn + time.Now().Format("20060102150405")
+	param := zhios_pay_utils.Struct2Map(orderQrcode)
+	for key, value := range param {
+		if value == "" {
+			delete(param, key)
+		}
+	}
+	unification.SetBizContent(param)
+	unification.SetSign("c5d47b9e515594313d80fb9903ece2d8")
+	send, err := unification.Send(false)
+	if err != nil {
+		t.Error(err)
+	}
+	t.Logf("回调数据：%s\n", send)
+}
+
+func TestFBPayOrderWxconfig(t *testing.T) {
+	requestParameters := fb.GetRequestParametersByVendorSn("2022120518415543840a")
+	requestParameters.Method = "fbpay.order.wxconfig"
+	requestParameters.SignMethod = "md5"
+	requestParameters.Nonce = time.Now().Format("20060102150405")
+	param := make(map[string]interface{})
+	param["merchant_id"] = 1979251
+	param["store_id"] = 1331462
+	param["sub_appid"] = "wx43207c79f84a14ca"
+	param["account_type"] = "01"
+	for key, value := range param {
+		if value == "" {
+			delete(param, key)
+		}
+	}
+	requestParameters.SetBizContent(param)
+	requestParameters.SetSign("c5d47b9e515594313d80fb9903ece2d8")
+	send, err := requestParameters.Send(false)
+	if err != nil {
+		t.Error(err)
+	}
+	t.Logf("回调数据：%s\n", send)
+}