lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-04-14 20:40:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

add prefix to cleanup batch job ids key

Browse Source
This commit is contained in:
lgb
2024-02-22 12:25:02 +08:00
parent 7ccee2384b
commit 288b141c43
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/Repositories/CleanupRepository.php
View File

@@ -13,6 +13,8 @@ class CleanupRepository extends BaseRepository
const USER_SEEDING_LEECHING_TIME_BATCH_KEY = "batch_key:user_seeding_leeching_time";
const TORRENT_SEEDERS_ETC_BATCH_KEY = "batch_key:torrent_seeders_etc";
const IDS_KEY_PREFIX = "cleanup_batch_job_ids:";
private static array $batchKeyActionsMap = [
self::USER_SEED_BONUS_BATCH_KEY => [
'action' => 'seed_bonus',
@@ -96,7 +98,7 @@ class CleanupRepository extends BaseRepository
while($arr_keys = $redis->hScan($batch, $it, "*", self::$scanSize)) {
$delay = self::getDelay($batchKeyInfo['task_index'], $length, $page);
$idStr = implode(",", array_keys($arr_keys));
$idRedisKey = Str::random();
$idRedisKey = self::IDS_KEY_PREFIX + Str::random();
NexusDB::cache_put($idRedisKey, $idStr);
$command = sprintf(
'cleanup --action=%s --begin_id=%s --end_id=%s --id_redis_key=%s --request_id=%s --delay=%s',