|
|
@ -477,14 +477,14 @@ function onCollection(err, collection) { |
|
|
|
var user = resob1.res25creator |
|
|
|
console.log('datauser ' + JSON.stringify(user)); |
|
|
|
console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>> '+JSON.stringify(reslog)); |
|
|
|
//pubClient.get(issend, function(err, object) {
|
|
|
|
//if(err == null){
|
|
|
|
//pubClient.set(issend, itemsProcessed, function(err, res) {
|
|
|
|
pubClient.get(issend, function(err, object) { |
|
|
|
if(err == null){ |
|
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
|
//});
|
|
|
|
//}
|
|
|
|
}); |
|
|
|
} |
|
|
|
itemsProcessed++; |
|
|
|
//});
|
|
|
|
}); |
|
|
|
})() |
|
|
|
}else{ |
|
|
|
pubClient.get(pathfileval, function(err, object) { |
|
|
@ -505,15 +505,15 @@ function onCollection(err, collection) { |
|
|
|
var user = objecttmp.user25user |
|
|
|
//io.join(user);
|
|
|
|
//io.to(user).emit(reslog);
|
|
|
|
//pubClient.get(issend, function(err, object) {
|
|
|
|
//if(err == null){
|
|
|
|
//pubClient.set(issend, itemsProcessed, function(err, res) {
|
|
|
|
pubClient.get(issend, function(err, object) { |
|
|
|
if(err == null){ |
|
|
|
pubClient.set(issend, itemsProcessed, function(err, res) { |
|
|
|
io.in(user).emit("logdata", reslog); |
|
|
|
//});
|
|
|
|
//}
|
|
|
|
}); |
|
|
|
} |
|
|
|
itemsProcessed++; |
|
|
|
}); |
|
|
|
//});
|
|
|
|
}); |
|
|
|
} |
|
|
|
}); |
|
|
|
|
|
|
|