guoziyun 9 месяцев назад
Родитель
Сommit
3ad7cd13b2

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

@@ -17,7 +17,7 @@ const settings = [
     // ["active-user-daily-notify", "30 18 * * *", require("./active-user-daily-notify") as CronJobModule], // 每天下午6点,开始活跃用户新作品消息推送
     // ["active-user-daily-notify", "30 18 * * *", require("./active-user-daily-notify") as CronJobModule], // 每天下午6点,开始活跃用户新作品消息推送
     // ["fcm-notify", "30 18 * * *", require("./fcm-notify") as CronJobModule], // 每天下午6点,基于原来的active-user-daily-notify,增加schedule推送,AB测试
     // ["fcm-notify", "30 18 * * *", require("./fcm-notify") as CronJobModule], // 每天下午6点,基于原来的active-user-daily-notify,增加schedule推送,AB测试
     ["daily-notify-at-morning", "0 19 * * *", require("./notify/daily-notify-at-morning")], // 每天下午7点,对应巴西时间早上8点推送一轮
     ["daily-notify-at-morning", "0 19 * * *", require("./notify/daily-notify-at-morning")], // 每天下午7点,对应巴西时间早上8点推送一轮
-    ["daily-notify-at-midday", "0 23 * * *", require("./notify/daily-notify-at-midday")], // 每天下午7点,对应巴西时间中午12点推送一轮
+    ["daily-notify-at-midday", "0 23 * * *", require("./notify/daily-notify-at-midday")], // 每天晚上11点,对应巴西时间中午12点推送一轮
     ["daily-notify-at-evening", "0 3 * * *", require("./notify/daily-notify-at-evening")], // 每天凌晨3点,对应巴西时间下午4点
     ["daily-notify-at-evening", "0 3 * * *", require("./notify/daily-notify-at-evening")], // 每天凌晨3点,对应巴西时间下午4点
     ["daily-notify-at-afternoon", "0 7 * * *", require("./notify/daily-notify-at-afternoon")], // 每天上午7点,对应巴西时间晚上8点
     ["daily-notify-at-afternoon", "0 7 * * *", require("./notify/daily-notify-at-afternoon")], // 每天上午7点,对应巴西时间晚上8点
 ];
 ];

+ 2 - 0
oms/dist/services/ingestor-service.js

@@ -388,6 +388,8 @@ async function processMessage(msg) {
                 }
                 }
             }
             }
         }
         }
+        // 更正,message_receive 消息不应更新 lastActiveAt 时间
+        delete userSetData.lastActiveAt;
         // Initialize update object with $set and $setOnInsert
         // Initialize update object with $set and $setOnInsert
         const updateOperation = {
         const updateOperation = {
             $set: userSetData,
             $set: userSetData,

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

@@ -19,7 +19,7 @@ const settings: [string, string, CronJobModule][] = [
   // ["active-user-daily-notify", "30 18 * * *", require("./active-user-daily-notify") as CronJobModule], // 每天下午6点,开始活跃用户新作品消息推送
   // ["active-user-daily-notify", "30 18 * * *", require("./active-user-daily-notify") as CronJobModule], // 每天下午6点,开始活跃用户新作品消息推送
   // ["fcm-notify", "30 18 * * *", require("./fcm-notify") as CronJobModule], // 每天下午6点,基于原来的active-user-daily-notify,增加schedule推送,AB测试
   // ["fcm-notify", "30 18 * * *", require("./fcm-notify") as CronJobModule], // 每天下午6点,基于原来的active-user-daily-notify,增加schedule推送,AB测试
   ["daily-notify-at-morning", "0 19 * * *", require("./notify/daily-notify-at-morning") as CronJobModule], // 每天下午7点,对应巴西时间早上8点推送一轮
   ["daily-notify-at-morning", "0 19 * * *", require("./notify/daily-notify-at-morning") as CronJobModule], // 每天下午7点,对应巴西时间早上8点推送一轮
-  ["daily-notify-at-midday", "0 23 * * *", require("./notify/daily-notify-at-midday") as CronJobModule], // 每天下午7点,对应巴西时间中午12点推送一轮
+  ["daily-notify-at-midday", "0 23 * * *", require("./notify/daily-notify-at-midday") as CronJobModule], // 每天晚上11点,对应巴西时间中午12点推送一轮
   ["daily-notify-at-evening", "0 3 * * *", require("./notify/daily-notify-at-evening") as CronJobModule], // 每天凌晨3点,对应巴西时间下午4点
   ["daily-notify-at-evening", "0 3 * * *", require("./notify/daily-notify-at-evening") as CronJobModule], // 每天凌晨3点,对应巴西时间下午4点
   ["daily-notify-at-afternoon", "0 7 * * *", require("./notify/daily-notify-at-afternoon") as CronJobModule], // 每天上午7点,对应巴西时间晚上8点
   ["daily-notify-at-afternoon", "0 7 * * *", require("./notify/daily-notify-at-afternoon") as CronJobModule], // 每天上午7点,对应巴西时间晚上8点
 ];
 ];

+ 3 - 0
oms/services/ingestor-service.ts

@@ -364,6 +364,9 @@ async function processMessage(msg: Message) {
       }
       }
     }
     }
 
 
+    // 更正,message_receive 消息不应更新 lastActiveAt 时间
+    delete userSetData.lastActiveAt;
+
     // Initialize update object with $set and $setOnInsert
     // Initialize update object with $set and $setOnInsert
     const updateOperation: mongo.UpdateFilter<IUser> = {
     const updateOperation: mongo.UpdateFilter<IUser> = {
       $set: userSetData,
       $set: userSetData,