Merge pull request #613 from ivothgle/mini-program-b2b-payment

add mini program b2b pay

Author: Matrix-X

src/kernel/Encryptor.go

@@ -12,12 +12,13 @@ import (
 	"encoding/json"
 	"encoding/xml"
 	"fmt"
-	"github.com/ArtisanCloud/PowerLibs/v3/object"
-	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel/support"
 	"math/rand"
 	"sort"
 	"strings"
 	"time"
+
+	"github.com/ArtisanCloud/PowerLibs/v3/object"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel/support"
 )
 
 // Wechat Docs: https://open.work.weixin.qq.com/api/doc/90000/90138/90307
@@ -249,7 +250,6 @@ func (encryptor *Encryptor) Signature(token, timestamp, nonce, data string) stri
 
 func CalcPaySig(uri, postBody, appkey string) string {
 	needSignMsg := uri + "&" + postBody
-	fmt.Println("need sign str => ", needSignMsg)
 	h := hmac.New(sha256.New, []byte(appkey))
 	h.Write([]byte(needSignMsg))
 	paySig := hex.EncodeToString(h.Sum(nil))

src/miniProgram/application.go

@@ -8,6 +8,7 @@ import (
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel/providers"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/auth"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/b2b"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/base"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/customerServiceMessage"
 	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/dataCube"
@@ -42,6 +43,7 @@ type MiniProgram struct {
 	*kernel.ServiceContainer
 
 	Base           *base.Client
+	B2B            *b2b.Client
 	VirtualPayment *virtualPayment.Client
 	AccessToken    *auth.AccessToken
 	Auth           *auth.Client
@@ -109,9 +111,10 @@ type UserConfig struct {
 	Token             string
 	AESKey            string
 
-	// 小程序虚拟支付新增配置
-	AppKey  string // 现网AppKey
-	OfferID string // OfferID(支付应用ID) 等同于商户号
+	// 小程序虚拟支付 或 b2b 支付
+	AppKey     string // 现网AppKey
+	SandBoxKey string // 沙盒AppKey
+	OfferID    string // OfferID(支付应用ID) 等同于商户号
 
 	ResponseType string
 	Log          Log
@@ -378,6 +381,12 @@ func NewMiniProgram(config *UserConfig, extraInfos ...*kernel.ExtraInfo) (*MiniP
 		return nil, err
 	}
 
+	//-------------- B2B Pay --------------
+	app.B2B, err = b2b.RegisterProvider(app)
+	if err != nil {
+		return nil, err
+	}
+
 	return app, err
 }
 

src/miniProgram/b2b/client.go

@@ -0,0 +1,121 @@
+package b2b
+
+import (
+	"context"
+	"encoding/json"
+
+	"github.com/ArtisanCloud/PowerLibs/v3/object"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/b2b/request"
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/miniProgram/b2b/response"
+)
+
+type Client struct {
+	BaseClient *kernel.BaseClient
+
+	appKey        string
+	sandboxAppKey string
+}
+
+// CreatePayment 创建 B2b 支付 https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/B2b_store_assistant.html#_3-3-%E6%94%AF%E4%BB%98%E4%B8%8E%E9%80%80%E6%AC%BE
+func (c *Client) CreatePayment(sessionKey string, data any, overAppKey ...string) (*object.StringMap, error) {
+	appKey := c.appKey
+	if len(overAppKey) > 0 && overAppKey[0] != "" {
+		appKey = overAppKey[0]
+	}
+	jsonData, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+	strData := string(jsonData)
+	return &object.StringMap{
+		"sign_data": strData,
+		"mode":      "retail_pay_goods",
+		"signature": kernel.CalcSignature(strData, sessionKey),
+		"pay_sig":   kernel.CalcSignature("requestCommonPayment"+"&"+strData, appKey),
+	}, nil
+}
+
+func postJson[I, O any](ctx context.Context, c *Client, path string, in *I) (out *O, err error) {
+	postBody, err := json.Marshal(in)
+	if err != nil {
+		return nil, err
+	}
+	signPost := string(postBody)
+
+	paySign := kernel.CalcSignature(path+"&"+signPost, c.appKey)
+	query := &object.StringMap{
+		"pay_sig": paySign,
+	}
+	out = new(O)
+	_, err = c.BaseClient.HttpPostJson(ctx, path, signPost, query, nil, out)
+	return out, err
+}
+
+// GetOrder 查询订单 https://developers.weixin.qq.com/miniprogram/dev/platform-capabilities/industry/B2b_store_assistant.html#_3-3-%E6%94%AF%E4%BB%98%E4%B8%8E%E9%80%80%E6%AC%BE
+func (c *Client) GetOrder(ctx context.Context, in *request.GetOrderReq) (*response.GetOrderRes, error) {
+	return postJson[request.GetOrderReq, response.GetOrderRes](ctx, c, "/retail/B2b/getorder", in)
+}
+
+// Refund 退款
+func (c *Client) Refund(ctx context.Context, in *request.RefundReq) (*response.RefundRes, error) {
+	if in.AppKey != "" {
+		c.appKey = in.AppKey
+	}
+	return postJson[request.RefundReq, response.RefundRes](ctx, c, "/retail/B2b/refund", in)
+}
+
+// GetRefund 查询退款
+func (c *Client) GetRefund(ctx context.Context, in *request.GetRefundReq) (*response.GetRefundRes, error) {
+	return postJson[request.GetRefundReq, response.GetRefundRes](ctx, c, "/retail/B2b/getrefund", in)
+}
+
+// AddProfitSharingAccount 添加分账方
+func (c *Client) AddProfitSharingAccount(ctx context.Context, in *request.AddProfitSharingAccountReq) (*response.AddProfitSharingAccountRes, error) {
+	return postJson[request.AddProfitSharingAccountReq, response.AddProfitSharingAccountRes](ctx, c, "/retail/B2b/addprofitsharingaccount", in)
+}
+
+// DelProfitSharingAccount 删除分账方
+func (c *Client) DelProfitSharingAccount(ctx context.Context, in *request.DelProfitSharingAccountReq) (*response.DelProfitSharingAccountRes, error) {
+	return postJson[request.DelProfitSharingAccountReq, response.DelProfitSharingAccountRes](ctx, c, "/retail/B2b/delprofitsharingaccount", in)
+}
+
+// QueryProfitSharingAccount 查询分账方
+func (c *Client) QueryProfitSharingAccount(ctx context.Context, in *request.QueryProfitSharingAccountReq) (*response.QueryProfitSharingAccountRes, error) {
+	return postJson[request.QueryProfitSharingAccountReq, response.QueryProfitSharingAccountRes](ctx, c, "/retail/B2b/queryprofitsharingaccount", in)
+}
+
+// CreateProfitSharingOrder 请求分账
+func (c *Client) CreateProfitSharingOrder(ctx context.Context, in *request.CreateProfitSharingOrderReq) (*response.CreateProfitSharingOrderRes, error) {
+	return postJson[request.CreateProfitSharingOrderReq, response.CreateProfitSharingOrderRes](ctx, c, "/retail/B2b/createprofitsharingorder", in)
+}
+
+// QueryProfitSharingOrder 查询分账结果
+func (c *Client) QueryProfitSharingOrder(ctx context.Context, in *request.QueryProfitSharingOrderReq) (*response.QueryProfitSharingOrderRes, error) {
+	return postJson[request.QueryProfitSharingOrderReq, response.QueryProfitSharingOrderRes](ctx, c, "/retail/B2b/queryprofitsharingorder?", in)
+}
+
+// QueryProfitSharingRemainAmt 查询分账剩余金额
+func (c *Client) QueryProfitSharingRemainAmt(ctx context.Context, in *request.QueryProfitSharingRemainAmtReq) (*response.QueryProfitSharingRemainAmtRes, error) {
+	return postJson[request.QueryProfitSharingRemainAmtReq, response.QueryProfitSharingRemainAmtRes](ctx, c, "/retail/B2b/queryprofitsharingremainamt", in)
+}
+
+// FinishProfitSharingOrder 完成分账
+func (c *Client) FinishProfitSharingOrder(ctx context.Context, in *request.FinishProfitSharingOrderReq) (*response.FinishProfitSharingOrderRes, error) {
+	return postJson[request.FinishProfitSharingOrderReq, response.FinishProfitSharingOrderRes](ctx, c, "/retail/B2b/finishprofitsharingorder", in)
+}
+
+// RefundProfitSharing 请求分账回退
+func (c *Client) RefundProfitSharing(ctx context.Context, in *request.RefundProfitSharingReq) (*response.RefundProfitSharingRes, error) {
+	return postJson[request.RefundProfitSharingReq, response.RefundProfitSharingRes](ctx, c, "/retail/B2b/refundprofitsharing", in)
+}
+
+// QueryRefundProfitSharingOrder 查询分账回退结果
+func (c *Client) QueryRefundProfitSharingOrder(ctx context.Context, in *request.QueryRefundProfitSharingOrderReq) (*response.QueryRefundProfitSharingOrderRes, error) {
+	return postJson[request.QueryRefundProfitSharingOrderReq, response.QueryRefundProfitSharingOrderRes](ctx, c, "/retail/B2b/queryrefundprofitsharingorder", in)
+}
+
+// DownloadBill 查看账单
+func (c *Client) DownloadBill(ctx context.Context, in *request.DownloadBillReq) (*response.DownloadBillRes, error) {
+	return postJson[request.DownloadBillReq, response.DownloadBillRes](ctx, c, "/retail/B2b/downloadbill", in)
+}

src/miniProgram/b2b/provider.go

@@ -0,0 +1,22 @@
+package b2b
+
+import (
+	"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel"
+)
+
+func RegisterProvider(app kernel.ApplicationInterface) (*Client, error) {
+	baseClient, err := kernel.NewBaseClient(&app, nil)
+	config := app.GetConfig()
+	appKey := config.GetString("app_key", "")
+	sandboxAppKey := config.GetString("sandbox_app_key", "")
+
+	if err != nil {
+		return nil, err
+	}
+	return &Client{
+		baseClient,
+		appKey,
+		sandboxAppKey,
+	}, nil
+
+}

src/miniProgram/b2b/request/order.go

@@ -0,0 +1,91 @@
+package request
+
+type GetOrderReq struct {
+	MchID      string `json:"mchid"` // 微信 b2b 支付配的商户号，和商户订单号配合使用
+	OutTradeNo string `json:"out_trade_no,omitempty"`
+	OrderId    string `json:"order_id,omitempty"`
+}
+
+type RefundReq struct {
+	MchID        string `json:"mchid"`                   // 微信商户号
+	OutTradeNo   string `json:"out_trade_no,omitempty"`  // 商户订单号
+	OrderID      string `json:"order_id,omitempty"`      // B2b支付订单号
+	OutRefundNo  string `json:"out_refund_no"`           // 商户退款单号
+	RefundAmount int64  `json:"refund_amount"`           // 退款金额，单位为分，只能为整数，不能超过原订单支付金额。
+	RefundFrom   int    `json:"refund_from"`             // 退款来源，枚举值 1：人工客服退款 2：用户自己退款 3：其他
+	RefundReason int    `json:"refund_reason,omitempty"` // 退款原因，枚举值 0：暂无描述 1：产品问题 2：售后问题 3：意愿问题 4：价格问题 5：其他原因
+	AppKey       string `json:"-" xml:"-"`               // 唯独这个接口一定要现网 appKey，覆盖计算
+}
+
+type GetRefundReq struct {
+	MchID       string `json:"mchid"`                   // 微信商户号
+	OutRefundNo string `json:"out_refund_no,omitempty"` // 商户退款单号
+	RefundID    string `json:"refund_id,omitempty"`     // B2b支付退款单号
+}
+
+type AddProfitSharingAccountReq struct {
+	ProfitSharingRelationType string `json:"profit_sharing_relation_type"` // 分账接收方关系类型
+	PayeeType                 string `json:"payee_type"`                   // 分账接收方类型
+	PayeeID                   string `json:"payee_id"`                     // 分账接收方标识
+	PayeeName                 string `json:"payee_name,omitempty"`         // 分账接收方名称
+	Env                       int    `json:"env"`                          // 环境类型
+}
+
+type DelProfitSharingAccountReq struct {
+	PayeeType string `json:"payee_type"` // 分账接收方类型
+	PayeeID   string `json:"payee_id"`   // 分账接收方标识
+	Env       int    `json:"env"`        // 环境类型
+}
+
+type QueryProfitSharingAccountReq struct {
+	Offset int `json:"offset"` // 偏移量
+	Limit  int `json:"limit"`  // 查询数量
+}
+
+type CreateProfitSharingOrderReq struct {
+	MchID           string `json:"mchid"`            // 子商户id
+	OutTradeNo      string `json:"out_trade_no"`     // 支付单id
+	ProfitFee       int64  `json:"profit_fee"`       // 分账费用, 单位:分，不超过支付单本身的金额
+	ReceiverType    string `json:"receiver_type"`    // 分账接收方类型
+	ReceiverAccount string `json:"receiver_account"` // 分账接收方账号
+}
+
+type QueryProfitSharingOrderReq struct {
+	MchID           string `json:"mchid"`            // 商户号，必填
+	OutTradeNo      string `json:"out_trade_no"`     // 支付单 id，必填
+	ReceiverType    string `json:"receiver_type"`    // 分账接收方类型，必填
+	ReceiverAccount string `json:"receiver_account"` // 分账接收方账号，必填
+}
+
+type QueryProfitSharingRemainAmtReq struct {
+	MchID      string `json:"mchid"`        // 子商户id，必填
+	OutTradeNo string `json:"out_trade_no"` // 订单 id，必填
+	Env        int    `json:"env"`          // 环境参数，0标识正式（默认值），1 标识沙盒，否
+}
+
+type FinishProfitSharingOrderReq struct {
+	MchID      string `json:"mchid"`        // 子商户id，必填
+	OutTradeNo string `json:"out_trade_no"` // 订单 id，必填
+}
+
+type RefundProfitSharingReq struct {
+	MchID       string `json:"mchid"`         // 商户号 id，必填
+	OutTradeNo  string `json:"out_trade_no"`  // 订单 id，必填
+	OutRefundNo string `json:"out_refund_no"` // 退款单 id，必填
+	PayeeType   string `json:"payee_type"`    // 退款分账方类型，必填
+	PayeeID     string `json:"payee_id"`      // 退款分账方 id，必填
+	RefundAmt   int64  `json:"refund_amt"`    // 退款金额，必填
+}
+
+type QueryRefundProfitSharingOrderReq struct {
+	MchID       string `json:"mchid"`         // 商户号 id，必填
+	OutTradeNo  string `json:"out_trade_no"`  // 订单 id，必填
+	OutRefundNo string `json:"out_refund_no"` // 退款单 id，必填
+	PayeeType   string `json:"payee_type"`    // 退款分账方类型，必填
+	PayeeID     string `json:"payee_id"`      // 退款分账方 id，必填
+}
+
+type DownloadBillReq struct {
+	MchID    string `json:"mchid"`     // 商户号，必填
+	BillDate string `json:"bill_date"` // 账单日期，格式:yyyymmdd，必填
+}