代码优化，重构消息推送函数

沈斌

2016-12-23 ee567fd428466945ec8bb290308f3e26287dda63

 server.js

@@ -10,16 +10,17 @@
var queue = require('./queue');

var map = {
    "5a0000010001": 32,
    "5a0000010002": 102,
    "5a0000010003": 162,
    "5a0000010004": 32,
    "5a0000010006": 122,
    "5a0000010007": 32,
    "5a000001000c": 20
    "5a0000010001": 32,  //心跳命令行
    "5a0000010002": 102, //云地址写入WIFI模块
    "5a0000010003": 162, //传感器数据上传
    "5a0000010004": 32,  //云端时间
    "5a0000010006": 122, //配网数据
    "5a0000010007": 32,  //主机休眠前发送即将休眠的命令
    "5a000001000c": 20   //联云通知
};

function handleData(db, socket, value) {

    //1.心跳命令行
    if(value.startsWith('5a0000010001')) {
        var output = [ 0x6A, 0x00, 0x00, 0x01, 0x00, 0x01, 0xA1, 0x1A, 0xC7, 0x6B ];
@@ -38,7 +39,7 @@
    if(value.startsWith('5a0000010003')) {
        var output = [ 0x6A, 0x00, 0x00, 0x01, 0x00, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x6B ];
        method.insertData(db, value, function(data, rank) {
            method.insertDocument2(db, value, rank, function(data) {});
            //method.insertDocument2(db, value, rank, function(data) {});
            var fields = method.padLeft(rank.toString(16), 8).match(/.{2}/g);
            output[6] = method.toDec(fields[0]);
            output[7] = method.toDec(fields[1]);
@@ -153,10 +154,6 @@

        socket.on('close', function(data) {
            console.log('Closed socket: ' + socket.remoteAddress +' '+ socket.remotePort);
        });

        socket.on('close', function(data) {
            console.log('Closed socket: ' + socket.remoteAddress + ' ' + socket.remotePort);
        });
    }).listen(config.PORT, config.HOST);