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

donated user ignore H&R

Browse Source
This commit is contained in:
xiaomlove
2022-03-28 19:52:10 +08:00
parent 30a50b5ede
commit cd7fe1704f
8 changed files with 39 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/Console/Commands/HitAndRunUpdateStatus.php
View File

@@ -12,14 +12,14 @@ class HitAndRunUpdateStatus extends Command
*
* @var string
*/
protected $signature = 'hr:update_status {--uid=} {--torrent_id=}';
protected $signature = 'hr:update_status {--uid=} {--torrent_id=} {--ignore_time=}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Update H&R status, options: --uid, --torrent_id';
protected $description = 'Update H&R status, options: --uid, --torrent_id, --ignore_time';
/**
* Create a new command instance.
@@ -40,11 +40,12 @@ class HitAndRunUpdateStatus extends Command
{
$uid = $this->option('uid');
$torrentId = $this->option('torrent_id');
$ignoreTime = $this->option('ignore_time');
$rep = new HitAndRunRepository();
$result = $rep->cronjobUpdateStatus($uid, $torrentId);
$result = $rep->cronjobUpdateStatus($uid, $torrentId, $ignoreTime);
$log = sprintf(
'[%s], %s, uid: %s, torrentId: %s, result: %s',
REQUEST_ID, __METHOD__, $uid, $torrentId, var_export($result, true)
'[%s], %s, uid: %s, torrentId: %s, ignoreTime: %s, result: %s',
REQUEST_ID, __METHOD__, $uid, $torrentId, $ignoreTime, var_export($result, true)
);
$this->info($log);
do_log($log);

1
app/Console/Kernel.php
View File

@@ -28,6 +28,7 @@ class Kernel extends ConsoleKernel
$schedule->command('exam:checkout_cronjob')->everyMinute();
$schedule->command('backup:cronjob')->everyMinute();
$schedule->command('hr:update_status')->everyMinute();
$schedule->command('hr:update_status --ignore_time=1')->hourly();
$schedule->command('user:delete_expired_token')->dailyAt('04:00');
}

8
app/Models/User.php
View File

@@ -367,4 +367,12 @@ class User extends Authenticatable
return true;
}
public function isDonating()
{
if ($this->donoruntil && $this->donoruntil >= Carbon::now()->toDateTimeString()) {
return true;
}
return false;
}
}

25
app/Repositories/HitAndRunRepository.php
View File

@@ -12,8 +12,9 @@ use Illuminate\Support\Facades\DB;
class HitAndRunRepository extends BaseRepository
{
public function cronjobUpdateStatus($uid = null, $torrentId = null)
public function cronjobUpdateStatus($uid = null, $torrentId = null, $ignoreTime = false): bool|int
{
do_log("uid: $uid, torrentId: $torrentId, ignoreTime: " . var_export($ignoreTime, true));
$size = 1000;
$page = 1;
$setting = Setting::get('hr');
@@ -31,11 +32,10 @@ class HitAndRunRepository extends BaseRepository
}
$query = HitAndRun::query()
->where('status', HitAndRun::STATUS_INSPECTING)
->where('created_at', '<', Carbon::now()->subHours($setting['inspect_time']))
->with([
'torrent' => function ($query) {$query->select(['id', 'size', 'name']);},
'snatch',
'user' => function ($query) {$query->select(['id', 'username', 'lang', 'class']);},
'user' => function ($query) {$query->select(['id', 'username', 'lang', 'class', 'donoruntil']);},
'user.language',
]);
if (!is_null($uid)) {
@@ -44,6 +44,9 @@ class HitAndRunRepository extends BaseRepository
if (!is_null($torrentId)) {
$query->where('torrent_id', $torrentId);
}
if (!$ignoreTime) {
$query->where('created_at', '<', Carbon::now()->subHours($setting['inspect_time']));
}
$successCounts = 0;
while (true) {
$logPrefix = "page: $page, size: $size";
@@ -54,23 +57,23 @@ class HitAndRunRepository extends BaseRepository
break;
}
foreach ($rows as $row) {
$logPrefix = "[HANDLING] " . $row->toJson();
$currentLog = "$logPrefix, [HANDLING] " . $row->toJson();
do_log($logPrefix);
if (!$row->user) {
do_log("$logPrefix, user not exists, skip!", 'error');
do_log("$currentLog, user not exists, skip!", 'error');
continue;
}
if (!$row->snatch) {
do_log("$logPrefix, snatch not exists, skip!", 'error');
do_log("$currentLog, snatch not exists, skip!", 'error');
continue;
}
if (!$row->torrent) {
do_log("$logPrefix, torrent not exists, skip!", 'error');
do_log("$currentLog, torrent not exists, skip!", 'error');
continue;
}
//If is VIP or above, pass
if ($row->user->class >= HitAndRun::MINIMUM_IGNORE_USER_CLASS) {
//If is VIP or above OR donated, pass
if ($row->user->class >= HitAndRun::MINIMUM_IGNORE_USER_CLASS || $row->user->isDonating()) {
$result = $this->reachedBySpecialUserClass($row);
if ($result) {
$successCounts++;
@@ -81,7 +84,7 @@ class HitAndRunRepository extends BaseRepository
//check seed time
$targetSeedTime = $row->snatch->seedtime;
$requireSeedTime = bcmul($setting['seed_time_minimum'], 3600);
do_log("targetSeedTime: $targetSeedTime, requireSeedTime: $requireSeedTime");
do_log("$currentLog, targetSeedTime: $targetSeedTime, requireSeedTime: $requireSeedTime");
if ($targetSeedTime >= $requireSeedTime) {
$result = $this->reachedBySeedTime($row);
if ($result) {
@@ -93,7 +96,7 @@ class HitAndRunRepository extends BaseRepository
//check share ratio
$targetShareRatio = bcdiv($row->snatch->uploaded, $row->torrent->size, 4);
$requireShareRatio = $setting['ignore_when_ratio_reach'];
do_log("targetShareRatio: $targetShareRatio, requireShareRatio: $requireShareRatio");
do_log("$currentLog, targetShareRatio: $targetShareRatio, requireShareRatio: $requireShareRatio");
if ($targetShareRatio >= $requireShareRatio) {
$result = $this->reachedByShareRatio($row);
if ($result) {