281 lines
9.1 KiB
PHP
281 lines
9.1 KiB
PHP
<?php
|
|
/**
|
|
* This is my open source code, please do not use it for commercial applications.
|
|
* For the full copyright and license information,
|
|
* please view the LICENSE file that was distributed with this source code
|
|
*
|
|
* @author Yuandong<837215079@qq.com>
|
|
* @link https://github.com/gzydong/hyperf-chat
|
|
*/
|
|
|
|
namespace App\Service;
|
|
|
|
use App\Model\User;
|
|
use App\Model\UsersFriend;
|
|
use App\Model\UsersFriendsApply;
|
|
use App\Traits\PagingTrait;
|
|
use Hyperf\DbConnection\Db;
|
|
use Exception;
|
|
|
|
/**
|
|
* ContactsService
|
|
* 注：联系人服务层
|
|
*
|
|
* @package App\Service
|
|
*/
|
|
class ContactsService extends BaseService
|
|
{
|
|
use PagingTrait;
|
|
|
|
/**
|
|
* 获取联系人列表
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @return array
|
|
*/
|
|
public function getContacts(int $user_id): array
|
|
{
|
|
$prefix = config('databases.default.prefix');
|
|
$sql = <<<SQL
|
|
SELECT users.id,users.nickname,users.avatar,users.motto,users.gender,tmp_table.friend_remark from {$prefix}users users
|
|
INNER join
|
|
(
|
|
SELECT id as rid,user2 as uid,user1_remark as friend_remark from {$prefix}users_friends where user1 = {$user_id} and `status` = 1
|
|
UNION all
|
|
SELECT id as rid,user1 as uid,user2_remark as friend_remark from {$prefix}users_friends where user2 = {$user_id} and `status` = 1
|
|
) tmp_table on tmp_table.uid = users.id
|
|
SQL;
|
|
|
|
$rows = Db::select($sql);
|
|
|
|
array_walk($rows, function (&$item) {
|
|
$item = (array)$item;
|
|
});
|
|
|
|
return $rows;
|
|
}
|
|
|
|
/**
|
|
* 添加联系人/申请
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $friend_id 好友ID
|
|
* @param string $remarks 申请备注
|
|
* @return bool
|
|
*/
|
|
public function addContact(int $user_id, int $friend_id, string $remarks): bool
|
|
{
|
|
// 判断是否是好友关系
|
|
if (UsersFriend::isFriend($user_id, $friend_id)) return true;
|
|
|
|
// 查询最后一次联系人申请
|
|
$result = UsersFriendsApply::where('user_id', $user_id)
|
|
->where('friend_id', $friend_id)
|
|
->orderBy('id', 'desc')->first();
|
|
|
|
if ($result && $result->status == 0) {
|
|
$result->remarks = $remarks;
|
|
$result->updated_at = date('Y-m-d H:i:s');
|
|
$result->save();
|
|
return true;
|
|
} else {
|
|
$result = UsersFriendsApply::create([
|
|
'user_id' => $user_id,
|
|
'friend_id' => $friend_id,
|
|
'status' => 0,
|
|
'remarks' => $remarks,
|
|
'created_at' => date('Y-m-d H:i:s'),
|
|
'updated_at' => date('Y-m-d H:i:s')
|
|
]);
|
|
|
|
return (bool)$result;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 删除联系人
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $friend_id 好友ID
|
|
* @return bool
|
|
*/
|
|
public function deleteContact(int $user_id, int $friend_id): bool
|
|
{
|
|
if (!UsersFriend::isFriend($user_id, $friend_id)) {
|
|
return false;
|
|
}
|
|
|
|
$data = ['status' => 0];
|
|
|
|
// 用户ID比大小交换位置
|
|
if ($user_id > $friend_id) {
|
|
[$user_id, $friend_id] = [$friend_id, $user_id];
|
|
}
|
|
|
|
return (bool)UsersFriend::where('user1', $user_id)->where('user2', $friend_id)->update($data);
|
|
}
|
|
|
|
/**
|
|
* 同意添加联系人 / 联系人申请
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $apply_id 联系人申请ID
|
|
* @param string $remarks 联系人备注名称
|
|
* @return bool
|
|
*/
|
|
public function acceptInvitation(int $user_id, int $apply_id, string $remarks = ''): bool
|
|
{
|
|
$info = UsersFriendsApply::where('id', $apply_id)
|
|
->where('friend_id', $user_id)
|
|
->where('status', 0)
|
|
->orderBy('id', 'desc')
|
|
->first(['user_id', 'friend_id']);
|
|
|
|
if (!$info) return false;
|
|
|
|
Db::beginTransaction();
|
|
try {
|
|
$res = UsersFriendsApply::where('id', $apply_id)->update(['status' => 1, 'updated_at' => date('Y-m-d H:i:s')]);
|
|
if (!$res) {
|
|
throw new Exception('更新好友申请表信息失败');
|
|
}
|
|
|
|
// 判断大小 交换 user1,user2 的位置
|
|
[$user1, $user2] = $info->user_id < $info->friend_id ? [$info->user_id, $info->friend_id] : [$info->friend_id, $info->user_id];
|
|
|
|
// 查询是否存在好友记录
|
|
$friendResult = UsersFriend::where([
|
|
['user1', '=', $user1],
|
|
['user2', '=', $user2]
|
|
])->first(['id', 'user1', 'user2', 'active', 'status']);
|
|
|
|
if ($friendResult) {
|
|
$active = ($friendResult->user1 == $info->user_id && $friendResult->user2 == $info->friend_id) ? 1 : 2;
|
|
UsersFriend::where('id', $friendResult->id)->update(['active' => $active, 'status' => 1]);
|
|
} else {
|
|
$friend_nickname = User::where('id', $info->friend_id)->value('nickname');
|
|
|
|
UsersFriend::create([
|
|
'user1' => $user1,
|
|
'user2' => $user2,
|
|
'user1_remark' => $user1 == $user_id ? $remarks : $friend_nickname,
|
|
'user2_remark' => $user2 == $user_id ? $remarks : $friend_nickname,
|
|
'active' => $user1 == $user_id ? 2 : 1,
|
|
'status' => 1,
|
|
'agree_time' => date('Y-m-d H:i:s'),
|
|
'created_at' => date('Y-m-d H:i:s')
|
|
]);
|
|
}
|
|
|
|
Db::commit();
|
|
} catch (Exception $e) {
|
|
Db::rollBack();
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 拒绝添加联系人 / 联系人申请
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $apply_id 联系人申请ID
|
|
* @param string $remarks 拒绝申请备注信息
|
|
* @return bool
|
|
*/
|
|
public function declineInvitation(int $user_id, int $apply_id, string $remarks = ''): bool
|
|
{
|
|
return (bool)UsersFriendsApply::where([
|
|
['id', '=', $apply_id],
|
|
['user_id', '=', $user_id],
|
|
['status', '=', 2],
|
|
])->update([
|
|
'status' => 2,
|
|
'remarks' => $remarks,
|
|
'updated_at' => date('Y-m-d H:i:s')
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 编辑联系人备注
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $friend_id 朋友ID
|
|
* @param string $remarks 好友备注名称
|
|
* @return bool
|
|
*/
|
|
public function editContactRemark(int $user_id, int $friend_id, string $remarks): bool
|
|
{
|
|
$data = [];
|
|
if ($user_id > $friend_id) {
|
|
[$user_id, $friend_id] = [$friend_id, $user_id];
|
|
$data['user2_remark'] = $remarks;
|
|
} else {
|
|
$data['user1_remark'] = $remarks;
|
|
}
|
|
|
|
return (bool)UsersFriend::where('user1', $user_id)->where('user2', $friend_id)->update($data);
|
|
}
|
|
|
|
/**
|
|
* 搜索联系人
|
|
*
|
|
* @param string $mobile 用户手机号/登录账号
|
|
* @return array
|
|
*/
|
|
public function findContact(string $mobile): array
|
|
{
|
|
$user = User::where('mobile', $mobile)->first(['id', 'nickname', 'mobile', 'avatar', 'gender']);
|
|
|
|
return $user ? $user->toArray() : [];
|
|
}
|
|
|
|
/**
|
|
* 获取联系人申请记录
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $page 当前分页
|
|
* @param int $page_size 分页大小
|
|
* @return array
|
|
*/
|
|
public function getContactApplyRecords(int $user_id, $page = 1, $page_size = 30): array
|
|
{
|
|
$rowsSqlObj = UsersFriendsApply::select([
|
|
'users_friends_apply.id',
|
|
'users_friends_apply.status',
|
|
'users_friends_apply.remarks',
|
|
'users.nickname',
|
|
'users.avatar',
|
|
'users.mobile',
|
|
'users_friends_apply.user_id',
|
|
'users_friends_apply.friend_id',
|
|
'users_friends_apply.created_at'
|
|
]);
|
|
|
|
$rowsSqlObj->leftJoin('users', 'users.id', '=', 'users_friends_apply.user_id');
|
|
$rowsSqlObj->where('users_friends_apply.friend_id', $user_id);
|
|
|
|
$count = $rowsSqlObj->count();
|
|
$rows = [];
|
|
if ($count > 0) {
|
|
$rows = $rowsSqlObj->orderBy('users_friends_apply.id', 'desc')->forPage($page, $page_size)->get()->toArray();
|
|
}
|
|
|
|
return $this->getPagingRows($rows, $count, $page, $page_size);
|
|
}
|
|
|
|
/**
|
|
* 删除联系人申请记录
|
|
*
|
|
* @param int $user_id 用户ID
|
|
* @param int $apply_id 联系人好友申请ID
|
|
* @return bool
|
|
* @throws Exception
|
|
*/
|
|
public function delContactApplyRecord(int $user_id, int $apply_id): bool
|
|
{
|
|
return (bool)UsersFriendsApply::where('id', $apply_id)->where('friend_id', $user_id)->delete();
|
|
}
|
|
}
|