Skip to content

N
node-bigstream
Commit 7c594cf6 authored by project's avatar project
Browse files
Options

--no commit message 

--no commit message
parent 60ee4721
Show whitespace changes
Inline Side-by-side
Showing with 6 additions and 3 deletions
plugins/di/di-agritronics/execute.js
View file @ 7c594cf6
......@@ -10,6 +10,8 @@ function execute_function(context,response){
var data = 'hello world';
var ct = new Date().getTime();
let result = {
"object_type": 'agritronic',
"station_id": param.station_id,
......@@ -22,9 +24,10 @@ function execute_function(context,response){
async.whilst(function() { return idx < param.data_types.length;}, function(callback) {
let dtype = param.data_types[idx].type;
let node_id = param.data_types[idx].node_id;
let ts = memstore.getItem(`${param.station_id}-${dtype}`);
if(typeof(ts) === 'undefined') ts = `${param.init_observed_date},${param.init_observed_time}`;
let url = param.url + `?appkey=${param.appkey}&p=${param.station_id},${node_id},${dtype},${ts}`;
let lts = memstore.getItem(`${param.station_id}-${dtype}`);
console.log(`memstore: ${param.station_id}-${dtype} = ${lts}`);
if(typeof(lts) === 'undefined') lts = `${param.init_observed_date},${param.init_observed_time}`;
let url = param.url + `?appkey=${param.appkey}&p=${param.station_id},${node_id},${dtype},${lts}`;
idx++;
getData(url).then((data) => {
if(data.search("denied") === -1){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment