node 小程序支付接口

Posted 2020-10-04 white_0710

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了node 小程序支付接口相关的知识，希望对你有一定的参考价值。

//需要引入的包
var xml2js = require(‘xml2js‘);
var qs = require(‘querystring‘);
var https = require(‘https‘);
var http = require(‘http‘);
var request = require(‘request‘);
var crypto = require(‘crypto‘);
var mysql = require(‘mysql‘);

var key = ‘********************‘; //商户后台支付的key

function createOrder(res,reqData,req) {
    var total_fee,attach,openid,body,bookingNo;
    var apiUrl = "https://api.mch.weixin.qq.com/pay/unifiedorder";
　　for( var k in reqData){     //这里是前端需要传过来的参数
        var postData = JSON.parse(k);
        total_fee = postData["total_fee"];
        openid = postData["openid"];
        body = postData[‘body‘];
        attach = postData[‘attach‘];
        bookingNo = postData[‘bookingNo‘];
        break;
    }
    var wxConfig = {
        appid:‘****‘,
        mch_id : ‘*****‘
    };
    var timeStamp = createTimeStamp(); //时间节点
    var nonce_str = createNonceStr() + createTimeStamp(); //随机字符串
    var create_ip = get_client_ip(req); //请求ip
    var notify_url =‘https://tqmsq.7dar.com/notifypay‘;

    var formData = "<xml>";
    formData += "<appid>"+wxConfig[‘appid‘]+"</appid>"; //appid
    formData += "<mch_id>"+wxConfig[‘mch_id‘]+"</mch_id>"; //商户号
    formData += "<nonce_str>"+nonce_str+"</nonce_str>"; //随机字符串
    formData += "<body>" + body + "</body>"; //商品描述
    formData += "<notify_url>"+notify_url+"</notify_url>";
    formData += "<openid>" + openid + "</openid>";
    formData += "<out_trade_no>" + bookingNo + "</out_trade_no>";
    formData += "<spbill_create_ip>"+create_ip+"</spbill_create_ip>";
    formData += "<total_fee>" + total_fee + "</total_fee>";
    formData += "<trade_type>JSAPI</trade_type>";
    formData += "<sign>" + paysignjsapi(wxConfig[‘appid‘],body,wxConfig[‘mch_id‘],nonce_str,notify_url,openid,bookingNo,create_ip,total_fee,‘JSAPI‘) + "</sign>";
    formData += "</xml>";
    console.log(formData);
    //记录日志
    var sql = "INSERT INTO qiming.order (order_num,openid,product_name,price,is_success) VALUES(?,?,?,?,?)";
    client.query(sql,[bookingNo,openid,body,total_fee,1],function (err,result) {
         if(err){
             throw err
         }
    });

    request({
        url: apiUrl,
        method: ‘POST‘,
        body: formData
    },function (err, response, body) {
        if (!err && response.statusCode === 200){
            console.log(body);
            var result_code = getXMLNodeValue(‘result_code‘, body.toString("utf-8"));
            var resultCode = result_code.split(‘[‘)[2].split(‘]‘)[0];
            if(resultCode === ‘SUCCESS‘){ //成功
                var prepay_id = getXMLNodeValue(‘prepay_id‘, body.toString("utf-8")).split(‘[‘)[2].split(‘]‘)[0]; //获取到prepay_id
                //签名
                var _paySignjs = paysignjs(wxConfig[‘appid‘], nonce_str, ‘prepay_id=‘+ prepay_id,‘MD5‘,timeStamp);
                var args = {
                    appId: wxConfig[‘appid‘],
                    timeStamp: timeStamp,
                    nonceStr: nonce_str,
                    signType: "MD5",
                    package: prepay_id,
                    paySign: _paySignjs,
                    status:200
                };

                res.write(JSON.stringify(args));
                res.end();
            }else{                         //失败
                var err_code_des = getXMLNodeValue(‘err_code_des‘,body.toString("utf-8"));
                var errDes = err_code_des.split(‘[‘)[2].split(‘]‘)[0];
               var errArg = {
                   status:400,
                   errMsg: errDes
               };
               res.write(JSON.stringify(errArg));
               res.end();
            }
            console.log(‘prepay_id是‘+resultCode)
        }
    })
}

用到的一些工具函数

function paysignjs(appid, nonceStr, package, signType, timeStamp) {
    var ret = {
        appId: appid,
        nonceStr: nonceStr,
        package: package,
        signType: signType,
        timeStamp: timeStamp
    };
    var string = raw1(ret);
    string = string + ‘&key=‘+key;
    console.log(string);
    var crypto = require(‘crypto‘);
    return crypto.createHash(‘md5‘).update(string, ‘utf8‘).digest(‘hex‘);
}

function raw1(args) {
    var keys = Object.keys(args);
    keys = keys.sort()
    var newArgs = {};
    keys.forEach(function(key) {
        newArgs[key] = args[key];
    });

    var string = ‘‘;
    for(var k in newArgs) {
        string += ‘&‘ + k + ‘=‘ + newArgs[k];
    }
    string = string.substr(1);
    return string;
}

//生成签名
function paysignjsapi(appid,body,mch_id,nonce_str,notify_url,openid,out_trade_no,spbill_create_ip,total_fee,trade_type) {
    var ret = {
        appid: appid,
        body: body,
        mch_id: mch_id,
        nonce_str: nonce_str,
        notify_url: notify_url,
        openid: openid,
        out_trade_no: out_trade_no,
        spbill_create_ip: spbill_create_ip,
        total_fee: total_fee,
        trade_type: trade_type
    };
    var string = raw(ret);
    string = string + ‘&key=‘+ key;
    var sign = crypto.createHash(‘md5‘).update(string, ‘utf8‘).digest(‘hex‘);
    return sign.toUpperCase()
}

function raw(args) {
    var keys = Object.keys(args);
    keys = keys.sort();
    var newArgs = {};
    keys.forEach(function(key) {
        newArgs[key.toLowerCase()] = args[key];
    });
    var string = ‘‘;
    for(var k in newArgs) {
        string += ‘&‘ + k + ‘=‘ + newArgs[k];
    }
    string = string.substr(1);
    return string;
}
//解析xml
function getXMLNodeValue(node_name, xml) {
    var tmp = xml.split("<" + node_name + ">");
    var _tmp = tmp[1].split("</" + node_name + ">");
    return _tmp[0];
}
//获取url请求客户端ip
var get_client_ip = function(req) {
    var ip = req.headers[‘x-forwarded-for‘] ||
        req.ip ||
        req.connection.remoteAddress ||
        req.socket.remoteAddress ||
        req.connection.socket.remoteAddress || ‘‘;
    if(ip.split(‘,‘).length>0){
        ip = ip.split(‘,‘)[0]
    }
    return ip;
};

// 随机字符串产生函数
function createNonceStr() {
    return Math.random().toString(36).substr(2, 15)
}
// 时间戳产生函数
function createTimeStamp() {
    return parseInt(new Date().getTime() / 1000) + ‘‘
}

以上是关于node 小程序支付接口的主要内容，如果未能解决你的问题，请参考以下文章

微信小程序篇（微信小程序的支付）转载 “微信小程序联盟”