fix

oms/dist/services/cron-jobs/notify/local-timezone-notify.js

@@ -4,15 +4,14 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.run = run;
-const mongoose_1 = __importDefault(require("mongoose"));
 const userModel_1 = require("../../../src/models/userModel");
-const messageTemplateModel_1 = require("../../../src/models/messageTemplateModel");
 const messageStrategyModel_1 = require("../../../src/models/messageStrategyModel");
 const artModel_1 = __importDefault(require("../../../src/models/artModel"));
 const timezoneService_1 = require("../../../src/services/timezoneService");
-// 确保模型已被注册
-mongoose_1.default.model("MessageTemplate", messageTemplateModel_1.MessageTemplate.schema);
-mongoose_1.default.model("MessageStrategy", messageStrategyModel_1.MessageStrategy.schema);
+const database_1 = require("../../../src/database");
+// // 确保模型已被注册
+// mongoose.model("MessageTemplate", MessageTemplate.schema);
+// mongoose.model("MessageStrategy", MessageStrategy.schema);
 // 国家代码到语言的映射表
 const countryCodeToLanguageMap = {
     CN: "zh-cn",
@@ -128,6 +127,7 @@ const recordMessage = async (uid, cc, template, messageData, strategyId, strateg
  */
 async function run() {
     console.log("脚本开始：创建活跃用户每日通知任务...");
+    await (0, database_1.connectToDatabase)();
     try {
         const sevenDaysAgo = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000);
         const activeUsers = await userModel_1.User.find({

oms/services/cron-jobs/notify/local-timezone-notify.ts

@@ -5,10 +5,11 @@ import { MessageStrategy, IMessageStrategy } from "../../../src/models/messageSt
 import { MessageRecord, IMessageRecord } from "../../../src/models/messageRecordModel";
 import Art, { IArt } from "../../../src/models/artModel";
 import { TimezoneService } from "../../../src/services/timezoneService";
+import { connectToDatabase } from "../../../src/database";
 
-// 确保模型已被注册
-mongoose.model("MessageTemplate", MessageTemplate.schema);
-mongoose.model("MessageStrategy", MessageStrategy.schema);
+// // 确保模型已被注册
+// mongoose.model("MessageTemplate", MessageTemplate.schema);
+// mongoose.model("MessageStrategy", MessageStrategy.schema);
 
 // 国家代码到语言的映射表
 const countryCodeToLanguageMap: { [key: string]: string } = {
@@ -140,6 +141,8 @@ const recordMessage = async (
 export async function run(): Promise<void> {
   console.log("脚本开始：创建活跃用户每日通知任务...");
 
+  await connectToDatabase();
+
   try {
     const sevenDaysAgo = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000);