〇、序

前期已经实现了对扫码盒子请求的监听，本章将研究如何将交易明细记录保存至mysql数据库。

一、开发实战

（一）导入mysql模块

使用如下命令为项目添加mysql依赖包

npm i mysql --save

（二）新建mysql数据库

新建交易明细表transactions

2019-04-17_001614.png

（三）编写mysql的操作类

初步的想法是在rules文件内，监听逻辑里面，当识别收款成功就新开一次mysql连接进行数据保存，为了更好节省数据库网络连接开销，将使用mysql数据连接池新开连接，新建lib文件夹并新建连接池类mysql.js：

var mysql=require("mysql");
var pool = mysql.createPool({
    host: 'localhost',
    user: 'user',
    password: 'code',
    database: 'eabcpay',
    port: 3306
});

var query=function(sql,callback){
    pool.getConnection(function(err,conn){
        if(err){
            callback(err,null,null);
        }else{
            conn.query(sql,function(qerr,vals,fields){
                //释放连接
                conn.release();
                //事件驱动回调
                callback(qerr,vals,fields);
            });
        }
    });
};

module.exports=query;

（二）优化rules

myRuleModule示例

const dateUtil = require("./lib/dateFormat.js");
var query = require("./lib/mysql.js");

module.exports = {
    replaceServerResDataAsync: function (req, res, serverResData, callback) {
        // console.log(req.url);
        // console.log(req.headers.host);
        // console.log(req.url.indexOf("/site/CashCollect/DirectCashCollect"));
        var flag = false;
        var orderNo = "1";
        var amount = 0.00;
        var cashier = "default";
        var createtime = dateUtil.formatTime(new Date());
        var unusedamount = 0.00;
        var queryStr;

        if (req.headers.host == "e.abchina.com" && req.url.indexOf("/site/CashCollect/DirectCashCollect") > -1) {
            var resData = serverResData.toString();
            resData = JSON.parse(resData);

            // 会有支付时候并不是马上支付完毕的情况，当IsWaiting为true时还在支付当中，稍后才会调用/site/BranchMarketOrder/PayQuery查询方支付结果
            if (resData.Code == 0 && !resData.Value.IsWaiting) {
                flag = true;
                orderNo = resData.Value.OrderNo;
                amount = 0.01;
                cashier = "wang";
                createtime = dateUtil.formatTime(new Date());
                unusedamount = 100000.00;
            }
        } else if (req.headers.host == "e.abchina.com" && req.url.indexOf("/site/BranchMarketOrder/PayQuery") > -1) {
            var billId;
            var resData = serverResData.toString();
            resData = JSON.parse(resData);

            if (req.url.indexOf("?") > -1) {
                var arrUrl = req.url.split("?");
                var billIdStr = arrUrl[1];
                var billIdSplit = billIdStr.split("=");
                billId = billIdSplit[1];
            }

            var para = arrUrl[1];
            console.log(resData.Code);
            console.log(resData);
            if (resData.Code == 0 && resData.Message == "成功") {
                flag = true;
                orderNo = billId;
                amount = 0.01;
                cashier = "wang";
                createtime = dateUtil.formatTime(new Date());
                unusedamount = 100000.00;
            }
        }
        if (flag) {
            queryStr = "INSERT INTO transactions(orderno,amount,cashier,createtime,unusedamount) VALUES ('" + orderNo + "', " + amount + ", '" + cashier + "', '" + createtime + "', " + unusedamount + ");";
            console.log(queryStr);
            query(queryStr, function (err, vals, fields) {
                console.log(vals);
            });
        }
        callback(serverResData);
    }
}

四、下一步研究计划

1.对语音播报模块进行研究；

2.对利用订单号查找金额进行实验；

3.优化mysql数据库模块，研发交易记录功能和收银员交班功能。