bot-28/app/Http/Controllers/admin/Rebate.php

<?php

namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Models\Config;
use App\Services\BalanceLogService;
use App\Services\RebateService;
use App\Services\WalletService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Validation\ValidationException;
use Exception;

class Rebate extends Controller
{
    function index()
    {
        try {
            $search = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1'],
                'member_id' => ['nullable', 'integer', 'min:1'],
                'date' => ['nullable', 'date_format:Y-m-d'],
                'status' => ['nullable', 'integer', 'in:0,1,2'],
                'username' => ['nullable', 'string'],
                'account' => ['nullable', 'string', 'max:64'],
                'first_name' => ['nullable', 'string'],
            ]);
            $result = RebateService::paginate($search);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(intval($e->getCode()));
        }
        return $this->success($result);
    }

    public function store()
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'id' => ['required', 'integer', 'min:1'],
            ]);
            $rebate = RebateService::findOne($params);
            if (!$rebate) throw new Exception('数据不存在', HttpStatus::CUSTOM_ERROR);
            RebateService::BibiReturn($rebate, $rebate->effective_betting_amount);
            DB::commit();
            $this->logGrantNotice((int) $rebate->id);
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }
        return $this->success();
    }

    private function logGrantNotice(int $id): void
    {
        try {
            $reward = DB::table('rebates')->where('id', $id)->first(['id', 'member_id', 'date', 'amount', 'status', 'grant_time']);
            $credits = DB::table('balance_logs')->where('change_type', '笔笔返')->where('related_id', $id)
                ->where('member_id', $reward->member_id)->get(['id', 'amount']);
            $requests = $credits->map(fn ($credit) => 'reward-payout:balance-log:' . $credit->id)->all();
            $messages = DB::table('site_messages')->where('sender_id', 0)->whereIn('request_id', $requests)->pluck('id', 'request_id');
            Log::info('manual_rebate_notice_diagnostic', [
                'reward' => (array) $reward,
                'credits' => $credits->map(fn ($credit) => ['ledger_id' => $credit->id, 'amount' => $credit->amount,
                    'message_id' => $messages['reward-payout:balance-log:' . $credit->id] ?? null])->all(),
                'message_count' => $messages->count(),
                'table_prefix' => DB::connection()->getTablePrefix(),
            ]);
        } catch (\Throwable $e) {
            // Diagnostics run after commit and must never turn a completed payout into an error response.
            try { Log::error('manual_rebate_notice_diagnostic_failed', ['reward_id' => $id, 'exception_class' => get_class($e)]); }
            catch (\Throwable $ignored) {}
        }
    }
}