fix

oms/dist/src/scripts/migrate-done-rates.js

@@ -81,7 +81,9 @@ async function migrateDoneRates() {
         let successfulInserts = 0;
         let batch = [];
         // 使用游标查询，不会一次性加载所有数据到内存
-        const cursor = OldDoneRate.find({}).lean().cursor();
+        const cursor = OldDoneRate.find({ collectionName: { $in: ["20250906", "20250907"] } })
+            .lean()
+            .cursor();
         // 逐条处理游标中的数据
         for await (const doc of cursor) {
             // 格式化数据以匹配本地模型

oms/dist/src/scripts/migrate-total-done-rates.js

@@ -75,9 +75,7 @@ async function migrateTotalDoneRates() {
         let successfulInserts = 0;
         let batch = [];
         // 使用游标查询，不会一次性加载所有数据到内存
-        const cursor = OldTotalDoneRate.find({ collectionName: { $in: ["20250906", "20250907"] } })
-            .lean()
-            .cursor();
+        const cursor = OldTotalDoneRate.find({}).lean().cursor();
         // 逐条处理游标中的数据
         for await (const doc of cursor) {
             // 数据结构同构，可以直接推入批次

oms/src/scripts/migrate-done-rates.ts

@@ -68,7 +68,9 @@ async function migrateDoneRates() {
     let batch: any[] = [];
 
     // 使用游标查询，不会一次性加载所有数据到内存
-    const cursor = OldDoneRate.find({}).lean().cursor();
+    const cursor = OldDoneRate.find({ collectionName: { $in: ["20250906", "20250907"] } })
+      .lean()
+      .cursor();
 
     // 逐条处理游标中的数据
     for await (const doc of cursor) {

oms/src/scripts/migrate-total-done-rates.ts

@@ -60,9 +60,7 @@ async function migrateTotalDoneRates() {
     let batch: any[] = [];
 
     // 使用游标查询，不会一次性加载所有数据到内存
-    const cursor = OldTotalDoneRate.find({ collectionName: { $in: ["20250906", "20250907"] } })
-      .lean()
-      .cursor();
+    const cursor = OldTotalDoneRate.find({}).lean().cursor();
 
     // 逐条处理游标中的数据
     for await (const doc of cursor) {