对所有监测物进行三级警报的设置

沈斌

2017-01-20 23d5c220f2602e2ee14d96d1376e385d2e429536

对所有监测物进行三级警报的设置

 method.js

@@ -186,7 +186,11 @@
                open_id: "o-RTuwvMHWotyirPHLmdSB_dKoQU"
            },
            options: {
                1: [500, 700, 900]
                1: [1000, 2000, 3000],
                2: [1000, 2000, 3000],
                3: [1000, 2000, 3000],
                4: [1000, 2000, 3000],
                5: [1000, 2000, 3000]
            }
        };
        configs[mac] = _config;
@@ -261,25 +265,35 @@
    }, function(err, doc) {
        if (err) return;

        var opt1 = _config['options'][1];
        if(x1 > opt1[0]) {
            var level = 1;
            if(x1 > opt1[2]) {
                level = 3;
            } else if(x1 > opt1[1]) {
                level = 2;
            }
            sensor_data._id = doc.insertedId;
            sensor_data.level = level;
            sensor_data.notice = _config.notice;
            sensor_data.address = _config.address;
            queue.pushToMQ('ex_data_alarm', sensor_data);
        }
        var level1 = this.getLevel(x1,  _config['options'][1]);
        var level2 = this.getLevel(x9,  _config['options'][2]);
        var level3 = this.getLevel(x11, _config['options'][3]);
        var level4 = this.getLevel(x10, _config['options'][4]);
        var level5 = this.getLevel(x14, _config['options'][5]);
        sensor_data._id = doc.insertedId;
        sensor_data.level = Math.max(level1, level2, level3, level4, level5);
        sensor_data.notice = _config.notice;
        sensor_data.address = _config.address;
        sensor_data.data = { 1: [x1, level1], 2: [x9, level2], 3: [x11, level3], 4: [x10, level4], 5: [x14, level5] };
        queue.pushToMQ('ex_data_alarm', sensor_data);

        callback(doc, rank);
    });
};

module.exports.getLevel = function(val, option) {
    var level = 0;
    if(val > option[0]) {
        var level = 1;
        if(val > option[2]) {
            level = 3;
        } else if(val > option[1]) {
            level = 2;
        }
    }
    return level;
};

module.exports.updateDeviceSleep = function(db, data, callback) {
    var mac = this.getMac(data);
    var collection = db.collection("devices");