guoziyun 8 hónapja
szülő
commit
b1dea511e1

+ 1 - 1
oms/dist/src/scripts/backfill-done-rate-tip-count.js

@@ -58,7 +58,7 @@ async function runBackfill() {
                 // 如果当天没有 tip 事件,但可能存在 DoneRate 记录,我们仍然需要更新它们 (如果它们是 null 或 undefined)
                 // 但由于 DoneRateModel 默认 tipCount: 0,所以我们只需要处理有 tip 事件的记录。
                 console.log(`[TipCount Backfill] No 'color_tip' events found for ${currentYYYYMMDD}. Skipping MongoDB update.`);
-                // continue;
+                continue;
             }
             // 2. 批量更新 MongoDB 中的 DoneRate 记录
             const bulkOps = tipResults

+ 4 - 5
oms/dist/src/scripts/run-tip-count.js

@@ -1,11 +1,10 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const backfill_done_rate_tip_count_1 = require("./backfill-done-rate-tip-count");
-const recalculate_total_done_rate_1 = require("./recalculate-total-done-rate");
+const initialize_tip_count_1 = require("./initialize-tip-count");
 async function run() {
-    // await runInitialization();
-    await (0, backfill_done_rate_tip_count_1.runBackfill)();
-    await (0, recalculate_total_done_rate_1.runRecalculation)();
+    await (0, initialize_tip_count_1.runInitialization)();
+    // await runBackfill();
+    // await runRecalculation();
 }
 if (require.main === module) {
     run().catch((err) => {

+ 1 - 1
oms/src/scripts/backfill-done-rate-tip-count.ts

@@ -73,7 +73,7 @@ export async function runBackfill(): Promise<string> {
         // 如果当天没有 tip 事件,但可能存在 DoneRate 记录,我们仍然需要更新它们 (如果它们是 null 或 undefined)
         // 但由于 DoneRateModel 默认 tipCount: 0,所以我们只需要处理有 tip 事件的记录。
         console.log(`[TipCount Backfill] No 'color_tip' events found for ${currentYYYYMMDD}. Skipping MongoDB update.`);
-        // continue;
+        continue;
       }
 
       // 2. 批量更新 MongoDB 中的 DoneRate 记录

+ 3 - 3
oms/src/scripts/run-tip-count.ts

@@ -3,9 +3,9 @@ import { runInitialization } from "./initialize-tip-count";
 import { runRecalculation } from "./recalculate-total-done-rate";
 
 async function run() {
-  // await runInitialization();
-  await runBackfill();
-  await runRecalculation();
+  await runInitialization();
+  // await runBackfill();
+  // await runRecalculation();
 }
 
 if (require.main === module) {