hyperf-chat/app/Service/UserService.php

<?php

namespace App\Service;

use App\Helpers\HashHelper;
use App\Model\User;
use App\Model\Article\ArticleClass;
use App\Model\Contact\Contact;
use App\Model\Contact\ContactApply;
use Hyperf\DbConnection\Db;

class UserService extends BaseService
{
    /**
     * 获取用户信息
     *
     * @param int   $user_id 用户ID
     * @param array $field   查询字段
     * @return User|object|null
     */
    public function findById(int $user_id, $field = ['*']): ?User
    {
        return User::where('id', $user_id)->first($field);
    }

    /**
     * 登录逻辑
     *
     * @param string $mobile   手机号
     * @param string $password 登录密码
     * @return User|bool
     */
    public function login(string $mobile, string $password)
    {
        if (!$user = User::where('mobile', $mobile)->first()) {
            return false;
        }

        if (!password_verify($password, $user->password)) {
            return false;
        }

        return $user;
    }

    /**
     * 账号注册逻辑
     *
     * @param array $data 用户数据
     * @return bool
     */
    public function register(array $data)
    {
        Db::beginTransaction();
        try {
            $data['password']   = HashHelper::make($data['password']);
            $data['created_at'] = date('Y-m-d H:i:s');
            $data['updated_at'] = date('Y-m-d H:i:s');

            $result = User::create($data);

            // 创建用户的默认笔记分类
            ArticleClass::create([
                'user_id'    => $result->id,
                'class_name' => '我的笔记',
                'is_default' => 1,
                'sort'       => 1,
                'created_at' => time()
            ]);

            Db::commit();
        } catch (\Exception $e) {
            Db::rollBack();
            return false;
        }

        return true;
    }

    /**
     * 账号重置密码
     *
     * @param string $mobile   用户手机好
     * @param string $password 新密码
     * @return bool
     */
    public function resetPassword(string $mobile, string $password)
    {
        return (bool)User::where('mobile', $mobile)->update(['password' => HashHelper::make($password)]);
    }

    /**
     * 修改绑定的手机号
     *
     * @param int    $user_id 用户ID
     * @param string $mobile  换绑手机号
     * @return array
     */
    public function changeMobile(int $user_id, string $mobile)
    {
        if (User::where('mobile', $mobile)->value('id')) {
            return [false, '手机号已被他人绑定'];
        }

        $isTrue = (bool)User::where('id', $user_id)->update(['mobile' => $mobile]);
        return [$isTrue, null];
    }

    /**
     * 通过手机号查找用户
     *
     * @param int $friend_id  用户ID
     * @param int $me_user_id 当前登录用户的ID
     * @return array
     */
    public function getUserCard(int $friend_id, int $me_user_id)
    {
        $info = User::select(['id', 'mobile', 'nickname', 'avatar', 'gender', 'motto'])->where('id', $friend_id)->first();
        if (!$info) return [];

        $info                    = $info->toArray();
        $info['friend_status']   = 0;//朋友关系[0:本人;1:陌生人;2:朋友;]
        $info['nickname_remark'] = '';
        $info['friend_apply']    = 0;

        // 判断查询信息是否是自己
        if ($friend_id != $me_user_id) {
            $is_friend = di()->get(UserFriendService::class)->isFriend($me_user_id, $friend_id, true);

            $info['friend_status'] = $is_friend ? 2 : 1;
            if ($is_friend) {
                $info['nickname_remark'] = di()->get(UserFriendService::class)->getFriendRemark($me_user_id, $friend_id);
            } else {
                $res = ContactApply::where('user_id', $me_user_id)
                    ->where('friend_id', $friend_id)
                    ->orderBy('id', 'desc')
                    ->exists();

                $info['friend_apply'] = $res ? 1 : 0;
            }
        }

        return $info;
    }

    /**
     * 获取用户好友列表
     *
     * @param int $user_id 用户ID
     * @return array
     */
    public function getUserFriends(int $user_id): array
    {
        return Contact::Join('users', 'users.id', '=', 'contact.friend_id')
            ->where('user_id', $user_id)->where('contact.status', 1)
            ->get([
                'users.id',
                'users.nickname',
                'users.avatar',
                'users.motto',
                'users.gender',
                'contact.remark as friend_remark',
            ])->toArray();
    }

    /**
     * 获取指定用户的所有朋友的用户ID
     *
     * @param int $user_id 指定用户ID
     * @return array
     */
    public function getFriendIds(int $user_id): array
    {
        return Contact::where('user_id', $user_id)->where('status', 1)->pluck('friend_id')->toArray();
    }
}