<?php

namespace App\Common\Trait;

use App\Cache\Redis\Lua\RateLimit;
use App\Cache\Redis\RedisCache;
use App\Cache\Redis\RedisKey;
use App\Common\Repository\AdminUserRepository;
use App\Model\AdminUser;
use Hyperf\Context\Context;
use Hyperf\Database\Model\Model;
use Hyperf\Di\Annotation\Inject;

trait AdminUserTrait
{
    /**
     * @var RedisCache
     */
    #[Inject]
    protected RedisCache $redis;

    /**
     * @var AdminUserRepository
     */
    #[Inject]
    protected AdminUserRepository $adminUserRepository;

    /**
     * 单例加缓存模型(仅仅用户信息) tips: 只可读取显示的数据(不影响大致问题)，不可操作类敏感数据 比如 inc 账户余额 之类的 会导致脏读
     * @param int $adminId
     * @return AdminUser|Model|mixed|string|null
     */
    public function getAdminUserInfo(int $adminId): mixed
    {
        $key = RedisKey::getAdminUserInfoKey($adminId);
        if (Context::has($key)) {
            return Context::get($key,false);
        }

        if ($this->redis->with()->exists($key)) {
            $userInfo = unserialize($this->redis->with()->get($key));
            Context::set($key,$userInfo);
            return $userInfo;
        }

        $userInfo = $this->adminUserRepository->findById($adminId) ?? null;
        if (!$userInfo) return null;

        Context::set($key, $userInfo);
        $this->redis->with()->set($key, serialize($userInfo), 3600);

        return $userInfo;
    }

    /**
     * @param int $adminId
     * @return void
     */
    public function updateAdminUserInfo(int $adminId): void
    {
        $key = RedisKey::getAdminUserInfoKey($adminId);
        if ($this->redis->with()->exists($key)) $this->redis->with()->del($key);
        if (Context::has($key)) Context::destroy($key);
        $this->getAdminUserInfo($adminId);
    }
}