|
@@ -454,6 +454,14 @@ const updateGamesRelation = () => {
|
|
|
delete GAMES.Relations[id];
|
|
delete GAMES.Relations[id];
|
|
|
updateCount.delete ++;
|
|
updateCount.delete ++;
|
|
|
}
|
|
}
|
|
|
|
|
+ else {
|
|
|
|
|
+ const { rel } = GAMES.Relations[id];
|
|
|
|
|
+ const relTime = rel.ps?.timestamp;
|
|
|
|
|
+ if (relTime && relTime < Date.now()) {
|
|
|
|
|
+ delete GAMES.Relations[id];
|
|
|
|
|
+ updateCount.delete ++;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
Logs.out('updateGamesRelation', updateCount);
|
|
Logs.out('updateGamesRelation', updateCount);
|
|
@@ -468,6 +476,25 @@ const updateGamesRelation = () => {
|
|
|
}
|
|
}
|
|
|
updateGamesRelation();
|
|
updateGamesRelation();
|
|
|
|
|
|
|
|
|
|
+const gamesRelationCleanup = () => {
|
|
|
|
|
+ const relations = Object.values(GAMES.Relations);
|
|
|
|
|
+ const expireTime = Date.now() - 1000*60;
|
|
|
|
|
+ relations.forEach(item => {
|
|
|
|
|
+ const { rel } = item;
|
|
|
|
|
+ Object.keys(rel).forEach(platform => {
|
|
|
|
|
+ const { evtime, sptime } = rel[platform];
|
|
|
|
|
+ if (evtime && evtime < expireTime) {
|
|
|
|
|
+ delete rel[platform].events;
|
|
|
|
|
+ delete rel[platform].evtime;
|
|
|
|
|
+ }
|
|
|
|
|
+ if (sptime && sptime < expireTime) {
|
|
|
|
|
+ delete rel[platform].special;
|
|
|
|
|
+ delete rel[platform].sptime;
|
|
|
|
|
+ }
|
|
|
|
|
+ });
|
|
|
|
|
+ });
|
|
|
|
|
+}
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 同步比赛结果
|
|
* 同步比赛结果
|
|
|
*/
|
|
*/
|
|
@@ -607,9 +634,11 @@ const solutionsCleanup = () => {
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 定时清理中单方案
|
|
* 定时清理中单方案
|
|
|
|
|
+ * 定时清理盘口信息
|
|
|
*/
|
|
*/
|
|
|
setInterval(() => {
|
|
setInterval(() => {
|
|
|
solutionsCleanup();
|
|
solutionsCleanup();
|
|
|
|
|
+ gamesRelationCleanup();
|
|
|
}, 1000*30);
|
|
}, 1000*30);
|
|
|
|
|
|
|
|
/**
|
|
/**
|