create_daily_data.js

 create_data.js

@@ -21,7 +21,7 @@
            fetchDeviceMinutelyData(start, end, days, (i+1)*(j+1)*(k+1));
        }
    }
}


function fetchDeviceMinutelyData(start, end, d, t) {
    pool.getConnection(function (err, conn) {

 create_minutely_data.js

@@ -50,12 +50,7 @@
                    time: moment(moment(start, 'YYYY-MM-DD HH:mm:00').valueOf() + 8*60*60*1000).toDate()
                };
            }
            devices[mac][key] = val;

            if(devices[mac]["ext"] == null) {
                devices[mac]["ext"] = {};
            }
            devices[mac]["ext"][key] = [data.min_val, data.max_val]
            devices[mac][key] = [val, data.min_val, data.max_val];
        });

        var device_data = [];

 create_monthly_data.js

 create_yearly_data.js

 sync.js

New file
@@ -0,0 +1,20 @@
var moment = require('moment');
var config = require('./config');
var mongoClient = require('mongodb').MongoClient;

mongoClient.connect(config.mongo, {
    poolSize: 10,
    keepAlive: 300000,
    auto_reconnect: true,
    reconnectTries: 1000,
    reconnectInterval: 5000,
    connectTimeoutMS: 30000
}, function(err, client) {
    if (err) {
        console.log(err.message);
        return;
    }

    //TODO

});