var log4js = require('log4js'); var logger = log4js.getLogger(); var db = require('./lib/server/db-connector').dbConnection; var dbSave = require('./lib/server/db-save')(db); var Sugar = require('sugar-date'); var mdot = require('./lib/mdot/mdot.js'); ( function() { var doBulkInsert = (qArray) => { 'use strict'; logger.info('Doing bulk insert...'); dbSave.doBulkInsert(qArray) .then(function(d) { logger.info('Finished bulk insert'); }) .catch(function(e) { logger.error(e); }); }; var doInsertEntry = (obj) => { // Logger.info('sendSocket: ' + JSON.stringify(obj)); // insertEntry(obj); /* dbSave.addNewEvent(obj) .then(function(d) { 'use strict'; logger.info('Finished - Raw',d); }) .catch(function(e) { 'use strict'; logger.error(e); }); */ dbSave.addProcessedEvent(obj) .then(function(d) { 'use strict'; logger.info('Finished - Processed',d); }) .catch(function(e) { 'use strict'; logger.error(e); }); }; var queries = []; var device = 8; var ids = ['CENSIS-LoRa-1','CENSIS-LoRa-2','CENSIS-LoRa-3','CENSIS-LoRa-4','HIE-mobile-1','HIE-demo','HIE-mobile-2','HIE-smart-campus-1','HIE-smart-campus-2','HIE-smart-campus-3','HIE-smart-campus-4','HIE-smart-campus-5','HIE-smart-campus-6','HIE-smart-campus-7','HIE-mDot-1']; var data = {id: ids[device]}; //var startTs = Sugar.Date.create('2015-07-19 14:46:48'); var startTs = Sugar.Date.create('2015-8-29 08:46:48'); var endTs = Sugar.Date.create('2016-08-29 09:35:36'); // first record recorded "2016-08-29 09:44:59+00" // logger.debug(startTs, endTs); // logger.debug(startTs.getTime(), endTs.getTime()); data.start = startTs.getTime(); data.end = endTs.getTime(); mdot.doGet(data) .then(function(d) { 'use strict'; //Logger.debug(d); logger.info('Number of items:', d.events.length); for (var item in d.events) { var newItem = d.events[item]; queries.push(dbSave.genRawQuery(newItem)); } doBulkInsert(queries); logger.info('Number of queries:', queries.length); }) .catch(function(err) { 'use strict'; logger.error(err); }); } )();