xinyuxi/ZYZ
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🐞 fix(隐藏数据): 定时任务覆盖问题

Browse Source
This commit is contained in:
luying
2023-08-01 14:03:11 +08:00
parent 4c0f0bb56b
commit d8ac54f0a6
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
game-server/app/services/timeTaskService.ts
+4 -3
View File
@@ -863,10 +863,10 @@ export async function initHiddenData(data?: HiddenDataModelType, nextData?: Hidd
setHiddenData(data?.heroes, data?.goods, nextData?.refTime); setHiddenData(data?.heroes, data?.goods, nextData?.refTime);
} }
export async function initHiddenDataSchedule(isInit: boolean, data?: HiddenDataModelType) { export async function initHiddenDataSchedule(isInit: boolean) {
if(hiddenDataJob) hiddenDataJob.cancel(); if(hiddenDataJob) hiddenDataJob.cancel();
let now = nowSeconds(); let now = nowSeconds();
if(!data) data = await HiddenDataModel.findCurData(now); let data = await HiddenDataModel.findCurData(now);
let nextData = await HiddenDataModel.findNextData(data?.refTime??now); let nextData = await HiddenDataModel.findNextData(data?.refTime??now);
if(isInit) { if(isInit) {
@@ -876,10 +876,11 @@ export async function initHiddenDataSchedule(isInit: boolean, data?: HiddenDataM
} }
console.log('######## initHiddenDataSchedule', nextData); console.log('######## initHiddenDataSchedule', nextData);
if(nextData) { if(nextData) {
if(scheduledJobs['hiddenData']) scheduledJobs['hiddenData'].cancel();
scheduleJob(`hiddenData`, nextData.refTime * 1000, async () => { scheduleJob(`hiddenData`, nextData.refTime * 1000, async () => {
console.log('######## hiddenDataSchedule', nextData); console.log('######## hiddenDataSchedule', nextData);
await initHiddenDataSchedule(false, nextData); await initHiddenDataSchedule(false);
}); });
} }
} }