function iniProcessDetail(isjob) {
var cursor = logColl.find({}).sort({ip: 1});
var insertbolk = [];
var eveipobj = {};
var hasinsertdetail = 0;
var goNext = true; function InsertDbs(teminsert) {
console.log("will insert" + teminsert.length);
(function (insertbolk) {
logprocessDetailColl.insert(insertbolk, function (err) {
hasinsertdetail += insertbolk.length;
console.log("insert insertprocessDetails count" + hasinsertdetail);
});
})(teminsert)
insertbolk = [];
} async.whilst(
function () {
return goNext;
},
function (callback) {
cursor.nextObject(function (err, item) {
// less 1
// if (insertbolk.length == 1000) {
// InsertDbs(insertbolk);
// }
if (item) {
setTimeout(function () {
function inieveipobj(eveipobj, item) {
eveipobj._id = eveipobj._id || item.ip;
eveipobj.value = eveipobj.value || {};
eveipobj.value.arr = eveipobj.value.arr || [];
return eveipobj;
} eveipobj = inieveipobj(eveipobj, item);
if (eveipobj._id != item.ip) {
(function (eveipobj) {
var prodetail = ipMeta.getProcessDetail(eveipobj)
insertbolk.push(prodetail);
})(eveipobj)
eveipobj = {};
eveipobj = inieveipobj(eveipobj, item);
}
var obj = {}
obj.gps = item.gps;
obj.created = item.created;
eveipobj.value.arr.push(obj);
if (insertbolk.length == 1000) {
InsertDbs(insertbolk);
}
callback();
}, 5); } else {
goNext = false;
callback();
}
})
},
function (err) {
if (insertbolk.length > 0) {
InsertDbs(insertbolk);
}
console.log('No Map/Reduce IniProdetails Finished', err);
if (isjob) {
fromDetailTolocation(isjob);
}
}
);
}

最新文章

  1. 阿里云提示Discuz uc.key泄露导致代码注入漏洞uc.php的解决方法
  2. SQL存储过程解密
  3. 数的统计count(bzoj1036)
  4. LightOJ1051 Good or Bad(DP)
  5. html5添加音乐包括暂停
  6. proguard使用
  7. POJ 1286 Necklace of Beads(Polya原理)
  8. #你好Unity3D#Hierarchy视图监听gameObject点击事件
  9. Android学习及开发随记1:Android Studio安装配置
  10. 关于Vim的问题s
  11. [RxJS] Drag and Drop example
  12. Eclipse 编译StanfordNLP
  13. Android学习总结——SQLite
  14. 在IE浏览器中iframe跨域访问cookie/session丢失的解决办法
  15. HTTP认证方式与https简介
  16. Problem : 1002 ( A + B Problem II )
  17. hdu 2254(矩阵)
  18. 如何使用python在保留原excel格式的前提下插入/修改数据
  19. Python装饰器举例分析
  20. asp.net query string 及 form data 遇到的编码问题

热门文章

  1. MyBatis项目报错:The server time zone value '�й�׼' is unrecognized or represents more than one time zone
  2. springboot跨域请求接口示例
  3. [LC] 51. N-Queens
  4. 66)vector基础总结
  5. Constant expression required
  6. PAT甲级——1073 Scientific Notation (20分)
  7. Charles 安装配置
  8. CSP模拟赛游记
  9. Window命令行切换命令
  10. 通过Dockerfile 文件为linux images 添加新用户