bot-28/app/Models/User.php

<?php

namespace App\Models;

// // 关键：导入正确的 Builder 类（Eloquent 构建器）
// use Illuminate\Database\Eloquent\Builder;

use Carbon\Carbon;
use App\Models\Agent\Agent as SystemAgent;

/**
 * @property int $id
 * @property string $member_id
 * @property string $username
 * @property string $first_name
 * @property string $language
 * @property string $register_ip
 * @property integer $status
 * @property string $visitor_id
 * @property string $phone 用户手机号
 * @property string $admin_note
 * @property $last_active_time 最后活跃时间
 */
class User extends BaseModel
{
    protected $table = 'users';
    protected $fillable = ['usdt', 'is_banned', 'last_active_time', 'visitor_id', 'register_ip', 'register_domain', 'status', 'admin_note', 'member_id', 'first_name', 
    'game_id', 'username', 'secret_key', 'secret_pass', 'language','user_code', 'agent_user_code', 'agent_id', 'level','recharge_channel_group_id'];
    protected $attributes = [
        'language' => 'zh',
        'recharge_channel_group_id' => 1,
    ];
    protected $hidden = ['updated_at', 'real_name'];

    protected static function booted()
    {
        static::creating(static function (self $user) {
            if (empty($user->recharge_channel_group_id)) {
                $user->recharge_channel_group_id = 1;
            }
        });
        // 未调用 parent::booted()，后台实时推送的新增用户事件在此单独注册
        static::created(static function (self $user) {
            try { \App\Services\AdminRealtime\AdminRealtime::captureModel($user, 'created'); }
            catch (\Throwable $e) { \Illuminate\Support\Facades\Log::error('admin_realtime_capture_failed', ['source' => 'users', 'id' => $user->getKey(), 'error' => get_class($e)]); }
        });
    }

    
    // public function newQuery($excludeDeleted = true): Builder
    // {
    //     // 1. 获取原生 Eloquent 查询构建器
    //     $query = parent::newQuery($excludeDeleted);
        
    //     // 2. 强制清空当前连接的表前缀（从根源阻止拼接）
    //     $this->getConnection()->setTablePrefix('');
        
    //     // 3. 强制指定查询的表名为 la_operation（覆盖所有拼接逻辑）
    //     $query->from('bot_users');
        
    //     return $query;
    // }
    
    function getLastActiveTimeAttribute($value): string
    {
        $timestamp = is_numeric($value) ? (int) $value : (is_string($value) ? strtotime($value) : false);
        return $timestamp > 0 ? Carbon::createFromTimestamp($timestamp, 'Asia/Shanghai')->format('Y-m-d H:i') : '';
    }

    function getCreatedAtAttribute($value): string
    {
        return Carbon::parse($value)->setTimezone('Asia/Shanghai')->format('Y-m-d');
    }

    public function wallet()
    {
        return $this->belongsTo(Wallet::class, 'member_id', 'member_id');
    }

    public function level()
    {
        return $this->belongsTo(Level::class, 'level', 'level')->select('id', 'level', 'level_name','img','recharge');
    }

    public function agent()
    {
        return $this->belongsTo(User::class, 'agent_user_code', 'user_code')->select('id', 'user_code', 'account','first_name','member_id');
    }

    public function systemAgent()
    {
        return $this->belongsTo(SystemAgent::class, 'agent_id');
    }

    public function setLanguage($language): void
    {
        $this->language = $language;
    }

    public function getMemberId()
    {
        return $this->member_id;
    }

    public function getUsername()
    {
        return $this->username;
    }

    public function getFirstName()
    {
        return $this->first_name;
    }

    /**
     * 生成8位数字+大写字母混合邀请码
     * @return string 生成的邀请码
     */
    public static function generateUserCode($num_len = 6, $letter_len = 2) {
        // 生成num_len位安全随机数字
        $numbers = '';
        for ($i = 0; $i < $num_len; $i++) {
            $numbers .= random_int(0, 9);
        }
        
        // 生成letter_len位安全随机字母
        $letters = '';
        $chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
        $charLength = strlen($chars);
        for ($i = 0; $i < $letter_len; $i++) {
            $letters .= $chars[random_int(0, $charLength - 1)];
        }
        
        // 打乱顺序
        $user_code = str_shuffle($numbers . $letters);
        if (User::where('user_code', $user_code)->value('id')) {
            return self::generateUserCode();
        }
        return $user_code;
    }

    /**
     * Telegram 进来的用户没有 account，生成 tg + 随机数字，保证不与 users.account 重复
     */
    public static function generateTgAccount(int $num_len = 8): string
    {
        do {
            $account = 'tg';
            for ($i = 0; $i < $num_len; $i++) {
                $account .= random_int(0, 9);
            }
        } while (User::where('account', $account)->exists());
        return $account;
    }
}