|
|
@ -427,8 +427,9 @@ function onCollection(err, collection) { |
|
|
|
pubClient.hgetall(pathfileval, function(err, object) { |
|
|
|
if(object){ |
|
|
|
indexupdate = false |
|
|
|
}else{ |
|
|
|
console.log('redis '+JSON.stringify(object)); |
|
|
|
} |
|
|
|
console.log('redis '+object); |
|
|
|
}); |
|
|
|
var resob = {} |
|
|
|
if (indexupdate ){ |
|
|
@ -436,6 +437,7 @@ function onCollection(err, collection) { |
|
|
|
console.log('file2222222222222222222222222222222222222 ' + JSON.stringify(pathfileval)) |
|
|
|
var token = "d2539e5a7ae1f9f1b0eb2b8f22ca467a86d28407"; // desto
|
|
|
|
var resdata = await getpipelines(token,pathfile) |
|
|
|
console.log('file2222222222222222222222222222222222222------------------------------ ' + JSON.stringify(resdata)) |
|
|
|
resob.pathlogfile = pathfileval |
|
|
|
var resobarray = [] |
|
|
|
for (let i in resdata.data) { |
|
|
@ -474,7 +476,7 @@ function onCollection(err, collection) { |
|
|
|
|
|
|
|
reslog.log = data |
|
|
|
reslog.date = convertDateToUTC(now) |
|
|
|
console.log('data ' + JSON.stringify(reslog)); |
|
|
|
console.log('dataelse ' + JSON.stringify(reslog)); |
|
|
|
//var usertmp = global.pipelines.find(x => x.pathlogfile==pathfileval);
|
|
|
|
//var user = usertmp.data[0].user25user;
|
|
|
|
///console.log('datauser ' + JSON.stringify(user));
|
|
|
|