| | |
| | | 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); |
| | | var level = Math.max(level1, level2, level3, level4, level5); |
| | | if(level > 0) { |
| | | sensor_data._id = doc.insertedId; |
| | | sensor_data.level = level; |
| | | 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); |
| | | }); |