mirror of
https://github.com/lkddi/nexusphp.git
synced 2026-04-03 14:10:57 +08:00
new feature: claim
This commit is contained in:
xiaomlove
267
app/Repositories/ClaimRepository.php
Normal file
267
app/Repositories/ClaimRepository.php
Normal file
@@ -0,0 +1,267 @@
|
||||
<?php
|
||||
namespace App\Repositories;
|
||||
|
||||
use App\Models\BonusLogs;
|
||||
use App\Models\Claim;
|
||||
use App\Models\Message;
|
||||
use App\Models\Setting;
|
||||
use App\Models\Snatch;
|
||||
use App\Models\Torrent;
|
||||
use App\Models\User;
|
||||
use Carbon\Carbon;
|
||||
use Illuminate\Support\Facades\DB;
|
||||
use JetBrains\PhpStorm\ArrayShape;
|
||||
use Nexus\Database\NexusDB;
|
||||
|
||||
class ClaimRepository extends BaseRepository
|
||||
{
|
||||
public function getList(array $params)
|
||||
{
|
||||
$query = Claim::query()->with(['family']);
|
||||
if (!empty($params['family_id'])) {
|
||||
$query->where('family_id', $params['family_id']);
|
||||
}
|
||||
$query->orderBy('family_id', 'desc');
|
||||
return $query->paginate();
|
||||
}
|
||||
|
||||
public function store($uid, $torrentId)
|
||||
{
|
||||
$exists = Claim::query()->where('uid', $uid)->where('torrent_id', $torrentId)->exists();
|
||||
if ($exists) {
|
||||
throw new \RuntimeException(nexus_trans("torrent.claim_already"));
|
||||
}
|
||||
$max = Claim::getConfigTorrentUpLimit();
|
||||
$count = Claim::query()->where('uid', $uid)->count();
|
||||
if ($count >= $max) {
|
||||
throw new \RuntimeException(nexus_trans("torrent.claim_number_reach_maximum"));
|
||||
}
|
||||
$snatch = Snatch::query()->where('userid', $uid)->where('torrentid', $torrentId)->first();
|
||||
if (!$snatch) {
|
||||
throw new \RuntimeException(nexus_trans("torrent.no_snatch"));
|
||||
}
|
||||
$claimTorrentTTL = Claim::getConfigTorrentTTL();
|
||||
$torrent = Torrent::query()->findOrFail($torrentId, Torrent::$commentFields);
|
||||
if ($torrent->added->addDays($claimTorrentTTL)->gte(Carbon::now())) {
|
||||
throw new \RuntimeException(nexus_trans("torrent.can_no_be_claimed_yet"));
|
||||
}
|
||||
$insert = [
|
||||
'uid' => $uid,
|
||||
'torrent_id' => $torrentId,
|
||||
'snatched_id' => $snatch->id,
|
||||
'seed_time_begin' => $snatch->seedtime,
|
||||
'uploaded_begin' => $snatch->uploaded,
|
||||
];
|
||||
return Claim::query()->create($insert);
|
||||
}
|
||||
|
||||
public function update(array $params, $id)
|
||||
{
|
||||
$model = Claim::query()->findOrFail($id);
|
||||
$model->update($params);
|
||||
return $model;
|
||||
}
|
||||
|
||||
public function getDetail($id)
|
||||
{
|
||||
$model = Claim::query()->findOrFail($id);
|
||||
return $model;
|
||||
}
|
||||
|
||||
public function delete($id, $uid)
|
||||
{
|
||||
$model = Claim::query()->findOrFail($id);
|
||||
if ($model->uid != $uid) {
|
||||
throw new \RuntimeException("No permission");
|
||||
}
|
||||
$deductBonus = Claim::getConfigGiveUpDeductBonus();
|
||||
return NexusDB::transaction(function () use ($model, $deductBonus) {
|
||||
User::query()->where('id', $model->uid)->decrement('seedbonus', $deductBonus);
|
||||
do_log(sprintf("[GIVE_UP_CLAIM_TORRENT], user: %s, deduct bonus: %s", $model->uid, $deductBonus), 'alert');
|
||||
return $model->delete();
|
||||
});
|
||||
}
|
||||
|
||||
public function getStats($uid)
|
||||
{
|
||||
$key = "claim_stats_$uid";
|
||||
return NexusDB::remember($key, 60, function () use ($uid) {
|
||||
$max = Claim::getConfigTorrentUpLimit();
|
||||
return sprintf('%s/%s', Claim::query()->where('uid', $uid)->count(), $max);
|
||||
});
|
||||
}
|
||||
|
||||
public function settleCronjob(): array
|
||||
{
|
||||
$query = Claim::query()->select(['uid'])->groupBy('uid');
|
||||
$size = 10000;
|
||||
$page = 1;
|
||||
$successCount = $failCount = 0;
|
||||
while (true) {
|
||||
$logPrefix = "page: $page, size: $size";
|
||||
$result = (clone $query)->forPage($page, $size)->get();
|
||||
if ($result->isEmpty()) {
|
||||
do_log("$logPrefix, no more data...");
|
||||
break;
|
||||
}
|
||||
foreach ($result as $row) {
|
||||
$uid = $row->uid;
|
||||
do_log("$logPrefix, begin to settle user: $uid...");
|
||||
$result = $this->settleUser($row->uid);
|
||||
do_log("$logPrefix, settle user: $uid done!, result: " . var_export($result, true));
|
||||
if ($result) {
|
||||
$successCount++;
|
||||
} else {
|
||||
$failCount++;
|
||||
}
|
||||
}
|
||||
$page++;
|
||||
}
|
||||
return ['success_count' => $successCount, 'fail_count' => $failCount];
|
||||
}
|
||||
|
||||
public function settleUser($uid, $force = false, $test = false): bool
|
||||
{
|
||||
$user = User::query()->with('language')->findOrFail($uid);
|
||||
$list = Claim::query()->where('uid', $uid)->with(['snatch'])->get();
|
||||
$now = Carbon::now();
|
||||
$startOfThisMonth = $now->clone()->startOfMonth();
|
||||
$seedTimeRequiredHours = Claim::getConfigStandardSeedTimeHours();
|
||||
$uploadedRequiredTimes = Claim::getConfigStandardUploadedTimes();
|
||||
$bonusMultiplier = Claim::getConfigBonusMultiplier();
|
||||
$bonusDeduct = Claim::getConfigRemoveDeductBonus();
|
||||
$reachedTorrentIdArr = $unReachedTorrentIdArr = $remainTorrentIdArr = $unReachedIdArr = $toUpdateIdArr = [];
|
||||
$totalSeedTime = 0;
|
||||
$seedTimeCaseWhen = $uploadedCaseWhen = [];
|
||||
do_log(
|
||||
"uid: $uid, claim torrent count: " . $list->count()
|
||||
. ", seedTimeRequiredHours: $seedTimeRequiredHours"
|
||||
. ", uploadedRequiredTimes: $uploadedRequiredTimes"
|
||||
. ", bonusMultiplier: $bonusMultiplier"
|
||||
. ", bonusDeduct: $bonusDeduct"
|
||||
);
|
||||
foreach ($list as $row) {
|
||||
if ($row->last_settle_at && $row->last_settle_at->gte($startOfThisMonth)) {
|
||||
do_log("ID: {$row->id} already settle", 'alert');
|
||||
if (!$force) {
|
||||
do_log("No force, return", 'alert');
|
||||
return false;
|
||||
}
|
||||
}
|
||||
if (
|
||||
bcsub($row->snatch->seedtime, $row->seed_time_begin) >= $seedTimeRequiredHours * 3600
|
||||
|| bcsub($row->snatch->uploaded, $row->uploaded_begin) >= $uploadedRequiredTimes * $row->torrent->size
|
||||
) {
|
||||
do_log("[REACHED], uid: $uid, torrent: " . $row->torrent_id);
|
||||
$reachedTorrentIdArr[] = $row->torrent_id;
|
||||
$toUpdateIdArr[] = $row->id;
|
||||
$totalSeedTime += bcsub($row->snatch->seedtime, $row->seed_time_begin);
|
||||
$seedTimeCaseWhen[] = sprintf('when %s then %s', $row->id, $row->snatch->seedtime);
|
||||
$uploadedCaseWhen[] = sprintf('when %s then %s', $row->id, $row->snatch->uploaded);
|
||||
} else {
|
||||
$targetStartOfMonth = $row->created_at->startOfMonth();
|
||||
if ($startOfThisMonth->diffInMonths($targetStartOfMonth) > 1) {
|
||||
do_log("[UNREACHED_REMOVE], uid: $uid, torrent: " . $row->torrent_id);
|
||||
$unReachedIdArr[] = $row->id;
|
||||
$unReachedTorrentIdArr = $row->torrent_id;
|
||||
} else {
|
||||
do_log("[UNREACHED_FIRST_MONTH], uid: $uid, torrent: " . $row->torrent_id);
|
||||
$seedTimeCaseWhen[] = sprintf('when %s then %s', $row->id, $row->snatch->seedtime);
|
||||
$uploadedCaseWhen[] = sprintf('when %s then %s', $row->id, $row->snatch->uploaded);
|
||||
$toUpdateIdArr[] = $row->id;
|
||||
$remainTorrentIdArr[] = $row->torrent_id;
|
||||
}
|
||||
}
|
||||
}
|
||||
$bonusResult = calculate_seed_bonus($uid, $reachedTorrentIdArr);
|
||||
$seedTimeHoursAvg = $totalSeedTime / (count($reachedTorrentIdArr) ?: 1) / 3600;
|
||||
do_log(sprintf(
|
||||
"reachedTorrentIdArr: %s, unReachedIdArr: %s, bonusResult: %s, seedTimeHours: %s",
|
||||
json_encode($reachedTorrentIdArr), json_encode($unReachedIdArr), json_encode($bonusResult), $seedTimeHoursAvg
|
||||
), 'alert');
|
||||
$bonusFinal = $bonusResult['seed_bonus'] * $seedTimeHoursAvg * $bonusMultiplier;
|
||||
do_log("bonus final: $bonusFinal", 'alert');
|
||||
|
||||
$totalDeduct = $bonusDeduct * count($unReachedIdArr);
|
||||
do_log("totalDeduct: $totalDeduct", 'alert');
|
||||
|
||||
/**
|
||||
* Just do a test, debug from log
|
||||
*/
|
||||
if ($test) {
|
||||
do_log("[TEST], return");
|
||||
return true;
|
||||
}
|
||||
|
||||
//Increase user bonus
|
||||
User::query()->where('id', $uid)->increment('seedbonus', $bonusFinal);
|
||||
do_log("Increase user bonus: $bonusFinal", 'alert');
|
||||
|
||||
//Handle unreached
|
||||
if (!empty($unReachedIdArr)) {
|
||||
Claim::query()->whereIn('id', $unReachedIdArr)->delete();
|
||||
User::query()->where('id', $uid)->decrement('seedbonus', $totalDeduct);
|
||||
do_log("Deduct user bonus: $totalDeduct", 'alert');
|
||||
}
|
||||
|
||||
//Update claim `last_settle_at` and init `seed_time_begin` & `uploaded_begin`
|
||||
$sql = sprintf(
|
||||
"update claims set uploaded_begin = case id %s end, seed_time_begin = case id %s end, last_settle_at = '%s', updated_at = '%s' where id in (%s)",
|
||||
implode(' ', $uploadedCaseWhen), implode(' ', $seedTimeCaseWhen), $now->toDateTimeString(), $now->toDateTimeString(), implode(',', $toUpdateIdArr)
|
||||
);
|
||||
$affectedRows = DB::update($sql);
|
||||
do_log("query: $sql, affectedRows: $affectedRows");
|
||||
|
||||
//Send message
|
||||
$torrentInfo = Torrent::query()
|
||||
->whereIn('id', array_merge($reachedTorrentIdArr, $unReachedTorrentIdArr, $remainTorrentIdArr))
|
||||
->get(Torrent::$commentFields)
|
||||
->keyBy('id')
|
||||
;
|
||||
$msg = [];
|
||||
$locale = $user->locale;
|
||||
$msg[] = nexus_trans('claim.msg_title', ['month' => $now->clone()->subMonths(1)->format('Y-m')], $locale);
|
||||
$msg[] = nexus_trans('claim.claim_total', [ 'total' => $list->count()], $locale);
|
||||
|
||||
$reachList = collect($reachedTorrentIdArr)->map(
|
||||
fn($item) => sprintf("[url=details.php?id=%s]%s[/url]", $item, $torrentInfo->get($item)->name)
|
||||
)->implode("\n");
|
||||
$msg[] = nexus_trans("claim.claim_reached_counts", ['counts' => count($reachedTorrentIdArr)], $locale) . "\n$reachList";
|
||||
$msg[] = nexus_trans(
|
||||
"claim.claim_reached_summary", [
|
||||
'bonus_per_hour' => number_format($bonusResult['seed_bonus'], 2),
|
||||
'hours'=> number_format($seedTimeHoursAvg, 2),
|
||||
'bonus_total'=> number_format($bonusFinal, 2)
|
||||
], $locale
|
||||
);
|
||||
|
||||
$remainList = collect($remainTorrentIdArr)->map(
|
||||
fn($item) => sprintf("[url=details.php?id=%s]%s[/url]", $item, $torrentInfo->get($item)->name)
|
||||
)->implode("\n");
|
||||
$msg[] = nexus_trans("claim.claim_unreached_remain_counts", ['counts' => count($remainTorrentIdArr)], $locale) . "\n$remainList";
|
||||
|
||||
$unReachList = collect($unReachedTorrentIdArr)->map(
|
||||
fn($item) => sprintf("[url=details.php?id=%s]%s[/url]", $item, $torrentInfo->get($item)->name)
|
||||
)->implode("\n");
|
||||
$msg[] = nexus_trans("claim.claim_unreached_remove_counts", ['counts' => count($unReachedTorrentIdArr)], $locale) . "\n$unReachList";
|
||||
if ($totalDeduct) {
|
||||
$msg[] = nexus_trans(
|
||||
"claim.claim_unreached_summary", [
|
||||
'deduct_per_torrent '=> number_format($bonusDeduct, 2),
|
||||
'deduct_total' => number_format($totalDeduct, 2)
|
||||
], $locale
|
||||
);
|
||||
}
|
||||
|
||||
$message = [
|
||||
'receiver' => $uid,
|
||||
'added' => $now,
|
||||
'subject' => nexus_trans('claim.msg_subject', ['month' => $now->clone()->subMonths(1)->format('Y-m')], $locale),
|
||||
'msg' => implode("\n\n", $msg),
|
||||
];
|
||||
Message::query()->insert($message);
|
||||
|
||||
do_log("[DONE], cost time: " . (time() - $now->timestamp) . " seconds");
|
||||
return true;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user