guoziyun пре 9 месеци
родитељ
комит
13421cc4b4

+ 1 - 1
oms/dist/services/cron-jobs/done-rate.js

@@ -10,7 +10,7 @@ const app_1 = require("../../src/app"); // 导入 ClickhouseService 实例
 const mongoose_1 = __importDefault(require("mongoose")); // 导入 mongoose 和 Connection 用于处理远程连接
 const mongoose_1 = __importDefault(require("mongoose")); // 导入 mongoose 和 Connection 用于处理远程连接
 const artModel_1 = __importDefault(require("../../src/models/artModel")); // 👈 导入 Art 模型和 IArt 接口
 const artModel_1 = __importDefault(require("../../src/models/artModel")); // 👈 导入 Art 模型和 IArt 接口
 // ClickHouse 表名
 // ClickHouse 表名
-const CLICKHOUSE_EVENTS_TABLE = "events_raw"; // 确保与 ClickHouseService 中的表名一致
+const CLICKHOUSE_EVENTS_TABLE = "events"; // 确保与 ClickHouseService 中的表名一致
 // 远程数据库连接 URL
 // 远程数据库连接 URL
 const REMOTE_MONGO_URI = "mongodb://coloring:coloring123.@hk.jccytech.cn:7881/?authSource=admin";
 const REMOTE_MONGO_URI = "mongodb://coloring:coloring123.@hk.jccytech.cn:7881/?authSource=admin";
 /**
 /**

+ 1 - 1
oms/dist/services/cron-jobs/index.js

@@ -12,7 +12,7 @@ const database_1 = require("../../src/database");
 const settings = [
 const settings = [
     // 假设这些文件将存在于 oms/services/cron-jobs/ 目录下
     // 假设这些文件将存在于 oms/services/cron-jobs/ 目录下
     ["sync", "*/10 * * * *", require("./sync/sync-service")], // 每10分钟跑一次同步
     ["sync", "*/10 * * * *", require("./sync/sync-service")], // 每10分钟跑一次同步
-    ["done-rate", "30 0 * * *", require("./done-rate")], // 每天凌晨0点10分, 统计作品完成率
+    ["done-rate", "33 0 * * *", require("./done-rate")], // 每天凌晨0点10分, 统计作品完成率
     ["daily-activity-detector", "50 0 * * *", require("./daily-activity-detector")], // 每天凌晨0点50分, 检查是否需要生成新的推送消息
     ["daily-activity-detector", "50 0 * * *", require("./daily-activity-detector")], // 每天凌晨0点50分, 检查是否需要生成新的推送消息
     ["message-sender", "*/5 * * * *", require("./message-sender")], // 每5分钟运行一次
     ["message-sender", "*/5 * * * *", require("./message-sender")], // 每5分钟运行一次
 ];
 ];

+ 1 - 1
oms/services/cron-jobs/done-rate.ts

@@ -8,7 +8,7 @@ import mongoose, { Connection } from "mongoose"; // 导入 mongoose 和 Connecti
 import Art, { IArt } from "../../src/models/artModel"; // 👈 导入 Art 模型和 IArt 接口
 import Art, { IArt } from "../../src/models/artModel"; // 👈 导入 Art 模型和 IArt 接口
 
 
 // ClickHouse 表名
 // ClickHouse 表名
-const CLICKHOUSE_EVENTS_TABLE = "events_raw"; // 确保与 ClickHouseService 中的表名一致
+const CLICKHOUSE_EVENTS_TABLE = "events"; // 确保与 ClickHouseService 中的表名一致
 
 
 // 远程数据库连接 URL
 // 远程数据库连接 URL
 const REMOTE_MONGO_URI = "mongodb://coloring:coloring123.@hk.jccytech.cn:7881/?authSource=admin";
 const REMOTE_MONGO_URI = "mongodb://coloring:coloring123.@hk.jccytech.cn:7881/?authSource=admin";

+ 1 - 1
oms/services/cron-jobs/index.ts

@@ -14,7 +14,7 @@ interface CronJobModule {
 const settings: [string, string, CronJobModule][] = [
 const settings: [string, string, CronJobModule][] = [
   // 假设这些文件将存在于 oms/services/cron-jobs/ 目录下
   // 假设这些文件将存在于 oms/services/cron-jobs/ 目录下
   ["sync", "*/10 * * * *", require("./sync/sync-service") as CronJobModule], // 每10分钟跑一次同步
   ["sync", "*/10 * * * *", require("./sync/sync-service") as CronJobModule], // 每10分钟跑一次同步
-  ["done-rate", "30 0 * * *", require("./done-rate") as CronJobModule], // 每天凌晨0点10分, 统计作品完成率
+  ["done-rate", "33 0 * * *", require("./done-rate") as CronJobModule], // 每天凌晨0点10分, 统计作品完成率
   ["daily-activity-detector", "50 0 * * *", require("./daily-activity-detector") as CronJobModule], // 每天凌晨0点50分, 检查是否需要生成新的推送消息
   ["daily-activity-detector", "50 0 * * *", require("./daily-activity-detector") as CronJobModule], // 每天凌晨0点50分, 检查是否需要生成新的推送消息
   ["message-sender", "*/5 * * * *", require("./message-sender") as CronJobModule], // 每5分钟运行一次
   ["message-sender", "*/5 * * * *", require("./message-sender") as CronJobModule], // 每5分钟运行一次
 ];
 ];