pay.js 5.45 KB
/**
 * 订单支付
 * @author: jiangfeng<jeff.jiang@yoho.cn>
 * @date: 2016/07/18
 */

'use strict';

const PayData = require('../models/pay');
const OrderData = require('../models/order');
const PayHelpers = require('../helpers/payment');
const cleanHtml = require(`${global.utils}/cleanHtml`);
const camelCase = global.yoho.camelCase;
const helpers = global.yoho.helpers;
const _ = require('lodash');
const integerTest = /^[0-9]*$/;

/**
 * 支付页
 * @param req
 * @param res
 * @param next
 */
const online = (req, res, next) => {
    let orderCode = req.query.code;
    let uid = req.user.uid;

    if (!integerTest.test(orderCode)) {
        // 不合法订单号
        return next();
    }

    PayData.getPayInfo(uid, orderCode).then(result => {
        let order = result.order;
        let promotion = order.promotionFormulas;
        let coin = 0;
        let amount = _.toNumber(order.paymentAmount);

        if (!order.orderCode) {
            // 不合法订单号
            return next();
        }

        _.forEach(promotion, p => {
            if (p.promotion === 'YOHO币') {
                coin = parseInt(parseFloat(p.promotionAmount.substring(2, p.promotionAmount.length)) * 100, 10);
            }
        });

        if (order.address) {
            order.address = cleanHtml.htmlDecode(order.address);
        }

        if (amount > 0) {
            res.display('pay', Object.assign({
                defaultHeader: false,
                module: 'shopping',
                page: 'pay',
                title: '支付页面',
                username: req.user.username
            }, result));
        } else {
            res.display('pay-success', {
                defaultHeader: false,
                content: {
                    cost: order.paymentAmount,
                    orderNum: order.orderCode,
                    coin: coin,
                    orderHref: helpers.urlFormat('/me/order/detail', {
                        orderCode: order.orderCode
                    }),
                    walkHref: helpers.urlFormat('/')
                }
            });
        }

    }).catch(next);

};

/**
 * 获取第三方支付跳转url
 * @param req
 * @param res
 * @param next
 */
const toPay = (req, res, next) => {
    let orderCode = req.body.code;
    let payType = req.body.payType;
    let uid = req.user.uid;
    let user = req.user;

    if (!integerTest.test(orderCode)) {
        // 不合法订单号
        return next();
    }

    OrderData.orderDetail(uid, orderCode).then(result => {
        if (result && result.data) {
            let order = camelCase(result.data);

            return PayHelpers.pay(user, order, payType);
        } else {
            return {
                code: 400,
                message: '获取订单失败'
            };
        }
    }).then(result => {
        res.json(result);
    }).catch(next);
};

/**
 * 微信扫码支付页面
 * @param req
 * @param res
 * @param next
 */
const weixinQr = (req, res, next) => {
    let code = req.query.code;
    let url = req.query.url;
    let uid = req.user.uid;

    if (!integerTest.test(code)) {
        // 不合法订单号
        return next();
    }

    OrderData.orderDetail(uid, code).then(result => {
        if (result && result.data) {
            return camelCase(result.data);
        } else {
            return {};
        }
    }).then(order => {
        res.display('weixin-pay', {
            defaultHeader: false,
            module: 'shopping',
            page: 'wxpay',
            title: '微信扫码支付页面',
            code: code,
            url: url,
            order: order
        });
    }).catch(next);
};

const weixinPayState = (req, res) => {
    let code = req.query.code;
    let uid = req.user.uid;

    OrderData.orderDetail(uid, code).then(result => {
        if (result && result.data && result.data.payment_status === 'Y') {
            res.json({
                code: 200,
                data: {
                    href: helpers.urlFormat('/me/order/detail', {orderCode: code})
                }
            });
        } else {
            return res.json({});
        }
    }).catch(() => {
        return res.json({});
    });
};

/**
 * 支付成功回调
 * @param req
 * @param res
 */
const callback = (req, res, next) => {
    let type = req.params.type;
    let payId = PayData.payments[type];
    let query = req.query;

    if (!payId) {
        return next();
    }

    PayHelpers.afterPay(query, payId, req.user).then(result => {
        if (result.code === 200 && result.data && result.data.order) {
            let order = result.data.order;
            let promotion = order.promotionFormulas;
            let coin = 0;


            _.forEach(promotion, p => {
                if (p.promotion === 'YOHO币') {
                    coin = parseInt(parseFloat(p.promotionAmount.substring(2, p.promotionAmount.length)) * 100, 10);
                }
            });

            res.display('pay-success', {
                defaultHeader: false,
                content: {
                    cost: order.paymentAmount,
                    orderNum: order.orderCode,
                    coin: coin,
                    orderHref: helpers.urlFormat('/me/order/detail', {
                        orderCode: order.orderCode
                    }),
                    walkHref: helpers.urlFormat('/')
                }
            });
        }
    }).catch(next);

};


module.exports = {
    online,
    callback,
    toPay,
    weixinQr,
    weixinPayState
};