Weishen/Hydro
2
0 Fork 0
mirror of https://gitcode.com/gh_mirrors/hy/Hydro.git synced 2026-10-20 01:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

import without pid check, fix bulk, upgrade dep

Browse Source
This commit is contained in:
undefined committed 2020-08-13 12:34:43 +08:00
1 parent ac9dc00c6a
commit 76f105c4c8
14 files changed
+117 -193
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

packages/migrate-vijos/script.ts
+4 -4
View File
@@ -420,19 +420,19 @@ async function removeInvalidPid(src: Db, report: Function) {
async function userfileUsage(src: Db, report: Function) {
const count = await src.collection('domain.user').find().count();
const bulk = dst.collection('user').initializeUnorderedBulkOp();
await report({ progress: 1, message: `userfileUsage: ${count}` });
const total = Math.floor(count / 50);
for (let i = 0; i <= total; i++) {
const docs = await src.collection('userfileUsage')
const docs = await src.collection('domain.user')
.find().skip(i * 50).limit(50)
.toArray();
const t = [];
for (const doc of docs) {
if (doc.userfile_usage) {
bulk.find({ _id: doc.uid }).updateOne({ $set: { usage: doc.userfile_usage } });
t.push(dst.collection('user').updateOne({ _id: doc.uid }, { $set: { usage: doc.userfile_usage } }));
}
}
await bulk.execute();
await Promise.all(t);
}
}