golang调用蓝兔支付实现网上支付功能

package pay  
import (  
    "crypto/md5"  
    "encoding/hex"  
    "simple-mall/global"  
    "sort"  
    "strings"  
)  
func calculateMD5(data string) string {  
    hash := md5.Sum([]byte(data))  
    return hex.EncodeToString(hash[:])  
}  
// LTZFGenerateSignature 生成蓝兔支付签名  
func LTZFGenerateSignature(sinObj map[string]string) string {  
    // 按照参数名进行字典序排序  
    keys := make([]string, 0, len(sinObj))  
    for k := range sinObj {  
        keys = append(keys, k)  
    }  
    sort.Strings(keys)  
    // 拼接参数键值对  
    var builder strings.Builder  
    for _, key := range keys {  
    value := sinObj[key]  
        if value != "" {  
            builder.WriteString(key + "=" + value + "&")  
        }  
    }  
    // 拼接密钥 也就上边说的商户密钥
    builder.WriteString("key=" + global.LTZFConfig.SecretKey)  
    // 计算MD5并转换为大写  
    signature := calculateMD5(builder.String())  
    return strings.ToUpper(signature)  
}

// 获取微信支付签名对象  
func getLTZFWeChatPayApiSinObj(params map[string]string) string {  
    // 只有必填参数才参与签名！
    sinObj := map[string]string{  
        "mch_id": params["mch_id"],  
        "out_trade_no": params["out_trade_no"],  
        "total_fee": params["total_fee"],  
        "body": params["body"],  
        "timestamp": params["timestamp"],  
        "notify_url": params["notify_url"],  
    }  
    return LTZFGenerateSignature(sinObj)  
}
// 获取蓝兔支付微信 api 参数  
func getLTZFWeChatPayApiReq(payReq pay.WeChatPayReq) url.Values {  
    // 请求支付接口参数  
    opts := map[string]string{  
        "mch_id": global.LTZFConfig.MchId, // 上边说的商户id  
        "out_trade_no": payReq.OrderId,
        "total_fee": "0.01", // 为了测试设置为 0.01 防止误支付
        "body": payReq.Info,  
        "timestamp": strconv.FormatInt(time.Now().Unix(), 10),  
        "notify_url": "xxxxx",  // 这里填写支付成功的回调地址
        "attach": payReq.OrderId,  // 附加数据，在支付通知中原样返回
        "time_expire": "15m",  // 支付超时时间
        "sign": "",  
    }  
    // 设置接口签名  
    opts["sign"] = getLTZFWeChatPayApiSinObj(opts)  
    // 格式化参数  
    req := url.Values{}  
    for key, value := range opts {  
        req.Add(key, value)  
    }  
    return req  
}

func WeChatPay(ctx *gin.Context) {  
    payReq := pay.WeChatPayReq{}  
    if err := ctx.ShouldBind(&payReq); err != nil {  
        utils.HandleValidatorError(ctx, err)  
        return  
    }  
    // 调用蓝兔支付接口 获取支付二维码
    res, err := http.PostForm("https://api.ltzf.cn/api/wxpay/native", getLTZFWeChatPayApiReq(payReq))  
    if err != nil {  
        // 处理请求错误  
        utils.ResponseResultsError(ctx, err.Error())  
        return  
    }  
    defer func(Body io.ReadCloser) {  
    err := Body.Close()  
    if err != nil {  
        utils.ResponseResultsError(ctx, err.Error())  
    }  
    }(res.Body)  
    body, err := io.ReadAll(res.Body)  
    if err != nil {  
        // 处理读取响应体错误  
        utils.ResponseResultsError(ctx, err.Error())  
        return  
    }  
    // 解析接口响应数据  
    type Data struct {  
        CodeURL string `json:"code_url"`  
        QRCodeURL string `json:"QRcode_url"`  
    }  
    type Response struct {  
        Code int `json:"code"`  
        Data Data `json:"data"`  
        Msg string `json:"msg"`  
        RequestID string `json:"request_id"`  
    }  
    // 解析JSON数据  
    var resp Response  
    if err := json.Unmarshal(body, &resp); err != nil {  
        // 处理解析JSON错误  
        utils.ResponseResultsError(ctx, err.Error())  
        return  
    }  
    if resp.Code != 0 {  
        utils.ResponseResultsError(ctx, resp.Msg)  
        return  
    }  
    utils.ResponseResultsSuccess(ctx, resp.Data)  
}