目前微信支付是PKCS12，但是目前sdk不支持

[ArenaSu]

• Go 版本：1.23.7
• wechatpay-go 版本：github.com/wechatpay-apiv3/wechatpay-go v0.2.20

微信支付给的证书附件中的三份文件（证书pkcs12格式、证书pem格式、证书密钥pem格式），说明是PKCS12格式的，但是github.com/wechatpay-apiv3/wechatpay-go@v0.2.20/utils/pem.go里LoadPrivateKey里只有x509.ParsePKCS8PrivateKey，然后直接报错：decode private key err

[ArenaSu]

@xy-peng 麻烦看下这个问题呢，急需解决这个问题

[ixqbar]

是打算加载p12文件吗？

[ixqbar]

可以参考 #249

[ArenaSu]

可以参考 #249

好的，3q，我来试试

[ArenaSu]

@ixqbar 你好，还是有问题，代码如下：

package wechatpay

import (
	"context"
	"fmt"
	"github.com/wechatpay-apiv3/wechatpay-go/core"
	"github.com/wechatpay-apiv3/wechatpay-go/core/option"
	"github.com/wechatpay-apiv3/wechatpay-go/services/transferbatch"
	"github.com/wechatpay-apiv3/wechatpay-go/utils"
	"log"
	"time"
)

// 初始化微信支付客户端
func NewWechatPayClient(mchID, mchCertificateSerialNo, mchAPIv3Key, privateKeyPath string) (*core.Client, error) {
	privateKey, err := utils.LoadPrivateKeyWithPath(privateKeyPath)
	if err != nil {
		return nil, fmt.Errorf("load private key err:%s", err)
	}

	// 初始化客户端
	ctx := context.Background()
	opts := []core.ClientOption{
		option.WithWechatPayAutoAuthCipher(mchID, mchCertificateSerialNo, privateKey, mchAPIv3Key),
	}

	return core.NewClient(ctx, opts...)
}

// 企业付款到零钱
func TransferToBalance(client *core.Client, appID, openID, partnerTradeNo, description string, amount int64) (*transferbatch.InitiateBatchTransferResponse, error) {
	svc := transferbatch.TransferBatchApiService{Client: client}

	// 构建请求参数
	req := transferbatch.InitiateBatchTransferRequest{
		Appid:       core.String(appID),
		OutBatchNo:  core.String(partnerTradeNo),
		BatchName:   core.String(description),
		BatchRemark: core.String(description),
		TotalAmount: core.Int64(amount),
		TotalNum:    core.Int64(1),
		TransferDetailList: []transferbatch.TransferDetailInput{
			{
				OutDetailNo:    core.String(fmt.Sprintf("%s", partnerTradeNo)),
				TransferAmount: core.Int64(amount),
				TransferRemark: core.String(description),
				Openid:         core.String(openID),
				UserName:       nil, // 不校验真实姓名
			},
		},
	}

	resp, _, err := svc.InitiateBatchTransfer(context.Background(), req)
	if err != nil {
		return nil, fmt.Errorf("transfer to balance failed: %v", err)
	}

	return resp, nil
}

// 查询转账批次
func queryTransferBatch(client *core.Client, batchID string) (*transferbatch.TransferBatchEntity, error) {
	svc := transferbatch.TransferBatchApiService{Client: client}
	resp, _, err := svc.GetTransferBatchByNo(context.Background(),
		transferbatch.GetTransferBatchByNoRequest{
			BatchId:         core.String(batchID),
			NeedQueryDetail: core.Bool(true),
		})
	return resp, err
}

调用代码如下：

func wechatTransferToBalanceTest() {
	const privateKeyPath = "/etc/itui/apiclient_key.pem"
	conf, err := config.LoadConfig("./itui.yaml")
	if err != nil {
		fmt.Println("failed to load config, error: " + err.Error())
		return
	}

	fmt.Println("MerchantId: " + conf.MerchantId)
	fmt.Println("MerchantCertificateSerialNumber: " + conf.MerchantCertificateSerialNumber)

	// 初始化客户端
	client, err := wechatpay.NewWechatPayClient(conf.MerchantId, conf.MerchantCertificateSerialNumber, conf.PaymentKey, privateKeyPath)
	if err != nil {
		fmt.Println("init wechat pay client failed, error: " + err.Error())
		return
	}

	// 准备转账参数
	appid := "wxc822d26b8435f72d"
	openID := "o6Mb_6yQYxjs9RAG77OyMaHJqDQ4" // 用户openid
	amount := int64(100)                     // 转账金额(分)
	description := "测试转账"
	partnerTradeNo := fmt.Sprintf(
		"T%s%d", time.Now().Format("20060102150405"), time.Now().UnixNano()%1000)

	fmt.Println("partnerTradeNo:" + partnerTradeNo)
	// 发起转账
	resp, err := wechatpay.TransferToBalance(client, appid, openID, partnerTradeNo, description, amount)
	if err != nil {

		fmt.Println("transfer to balance failed, error: " + err.Error())
		return
	}

	log.Printf("Transfer success: BatchId=%s, BatchStatus=%s\n", *resp.BatchId, *resp.BatchStatus)
}

调用代码报错如下：

transfer to balance failed, error: transfer to balance failed: error http response:[StatusCode: 403 Code: "NO_AUTH"
Message: 当前商户号接入升级版本功能，暂不支持使用升级前功能，请在产品中心-商家转账-前往功能查看接口文档

[ixqbar]

https://pay.weixin.qq.com/doc/v3/merchant/4013778940
#244
https://pay.weixin.qq.com/doc/v3/merchant/4012716434

参考修改接口及参数

func (a *TransferBatchApiService) InitiateTransferBatch(ctx context.Context, req InitiateTransferBatchRequest) (resp *InitiateTransferBatchResponse, result *core.APIResult, err error) {
	var (
		localVarHTTPMethod   = nethttp.MethodPost
		localVarPostBody     interface{}
		localVarQueryParams  neturl.Values
		localVarHeaderParams = nethttp.Header{}
	)

	// 对请求中敏感字段进行加密
	encReq := req.Clone()
	encryptCertificate, err := a.Client.EncryptRequest(ctx, encReq)
	if err != nil {
		return nil, nil, fmt.Errorf("encrypt request failed: %v", err)
	}

	if encryptCertificate != "" {
		localVarHeaderParams.Set(consts.WechatPaySerial, encryptCertificate)
	}
	req = *encReq

	localVarPath := consts.WechatPayAPIServer + "/v3/partner-transfer/batches"
	// Make sure All Required Params are properly set

	// Setup Body Params
	localVarPostBody = req

	// Determine the Content-Type Header
	localVarHTTPContentTypes := []string{"application/json"}
	// Setup Content-Type
	localVarHTTPContentType := core.SelectHeaderContentType(localVarHTTPContentTypes)

	// Perform Http Request
	result, err = a.Client.Request(ctx, localVarHTTPMethod, localVarPath, localVarHeaderParams, localVarQueryParams, localVarPostBody, localVarHTTPContentType)
	if err != nil {
		return nil, result, err
	}

	// Extract InitiateTransferBatchResponse from Http Response
	resp = new(InitiateTransferBatchResponse)
	err = core.UnMarshalResponse(result.Response, resp)
	if err != nil {
		return nil, result, err
	}
	return resp, result, nil
}

[ArenaSu]

@ixqbar 你好，请教下，您发的文档地址，我看url是https://api.mch.weixin.qq.com/v3/fund-app/mch-transfer/transfer-bills，而您的接口里是/v3/partner-transfer/batches，我看了半天这个request参数怎么对照映射呢？

[ixqbar]

给你发的演示代码是sdk里原有接口封装，意思就是你只需要按照新微信接口文档替换修改为新的接口及参数即可

[ArenaSu]

给你发的演示代码是sdk里原有接口封装，意思就是你只需要按照新微信接口文档替换修改为新的接口及参数即可

@ixqbar 您好，改完之后调用报错的，错误信息如下： error http response:[StatusCode: 400 Code: "PARAM_ERROR"
Message: 输入源“/body/sub_mchid”映射到字段“特约商户号”必填性规则校验失败，此字段为必填项。

我的接口实现参数麻烦可以参考上面我发的comment里面有代码，感谢帮忙看下。

[ixqbar]

请仔细看文档 https://pay.weixin.qq.com/doc/v3/merchant/4012716434 后构造自己的请求

[ArenaSu]

请仔细看文档 https://pay.weixin.qq.com/doc/v3/merchant/4012716434 后构造自己的请求

@ixqbar 是参考 /v3/fund-app/mch-transfer/transfer-bills 这个构造请求吗？我发现您代码里InitiateBatchTransferRequest和文档里body里的对应不上啊（比如transfer_scene_report_infos，比如openid的位置？），搞了1天了还是不对，一直报错：[StatusCode: 400 Code: "PARAM_ERROR"
Message: 输入源“/body/sub_mchid”映射到字段“特约商户号”必填性规则校验失败，此字段为必填项。

麻烦专家看下呢，卡在这里解决不了被催的不行

我在负责人问下客服是不是特约商户号吧，是的话，我再试下partnertransferbatch.TransferBatchApiService方式

[ArenaSu]

@ixqbar 试不了，根本没有sub_mchid信息，不是特约商户号，麻烦看下怎么搞。。。

[ixqbar]

先確認一點，你是服務商模式還是商戶模式，兩者文檔對接不一樣

貼出代碼 或者 +v ixqbar

[ArenaSu]

先確認一點，你是服務商模式還是商戶模式，兩者文檔對接不一樣

貼出代碼 或者 +v ixqbar

@ixqbar 加您微信了