You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
532 lines
20 KiB
532 lines
20 KiB
<?php
|
|
|
|
/**
|
|
* raingad IM [ThinkPHP6]
|
|
* @author xiekunyu <raingad@foxmail.com>
|
|
*/
|
|
|
|
namespace app\enterprise\model;
|
|
|
|
use GatewayClient\Gateway;
|
|
use app\BaseModel;
|
|
use think\facade\Db;
|
|
use think\facade\Request;
|
|
use think\model\concern\SoftDelete;
|
|
use app\manage\model\Config;
|
|
use thans\jwt\facade\JWTAuth;
|
|
|
|
class User extends BaseModel
|
|
{
|
|
use SoftDelete;
|
|
|
|
protected $pk = "user_id";
|
|
|
|
public static $defaultField = 'user_id,realname,realname as displayName,account,avatar,name_py,email,last_login_ip';
|
|
|
|
protected $json = ['setting'];
|
|
protected $jsonAssoc = true;
|
|
|
|
// 系统人员或者其他静态人员
|
|
public static function staticUser(){
|
|
return [
|
|
'adminNotice'=>[
|
|
'id'=>'admin_notice',
|
|
'displayName'=>lang('system.notice'),
|
|
'avatar'=>getMainHost().'/static/common/img/notice.png',
|
|
'name_py'=>'xitongtongzhi',
|
|
],
|
|
'fileTransfer'=>[
|
|
'id'=>-1,
|
|
'displayName'=>lang('system.favor'),
|
|
'avatar'=>getMainHost().'/static/common/img/file_transfer.png',
|
|
'name_py'=>'wodeshoucang',
|
|
]
|
|
];
|
|
}
|
|
|
|
public function getUid()
|
|
{
|
|
return self::$uid;
|
|
}
|
|
|
|
//查询用户信息
|
|
public static function getUserInfo($map=[], $field = '*')
|
|
{
|
|
if(!$map){
|
|
return self::$userInfo;
|
|
}
|
|
$data = self::where($map)->field($field)->find();
|
|
if ($data) {
|
|
$data = $data->toArray();
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 刷新用户token 之前token将被拉黑
|
|
* 修改用户数据后 调用该方法 并返回前台更新token
|
|
* @param array $info 用户信息
|
|
* @param string $terminal 客户端标识
|
|
* @return string
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public static function refreshToken($info,$terminal)
|
|
{
|
|
$info = str_encipher(json_encode($info),true, config('app.aes_token_key'));
|
|
$authToken = 'bearer '.JWTAuth::builder(['info' => $info, 'terminal' => $terminal]);
|
|
return $authToken;
|
|
}
|
|
|
|
// 获取所有用户列表
|
|
public static function getAllUser($map, $user_ids = [],$user_id,$group_id = 0)
|
|
{
|
|
$field = self::$defaultField;
|
|
$list=[];
|
|
if($group_id){
|
|
$groupUser=GroupUser::where([['group_id','=',$group_id],['role','<>',1],['status','=',1]])->column('user_id');
|
|
if($groupUser){
|
|
$list=User::where([['user_id','in',$groupUser]])->field($field)->select()->toArray();
|
|
}
|
|
}else{
|
|
$config=Config::getSystemInfo();
|
|
// 如果是社区模式，就只查询自己的好友，如果是企业模式，就查询所有用户
|
|
if($config['sysInfo']['runMode']==1){
|
|
$list = self::where($map)->field($field)->select()->toArray();
|
|
}else{
|
|
$friendList = Friend::getFriend(['create_user' => $user_id,'status'=>1]);
|
|
$userList = array_keys($friendList);
|
|
$list = self::where($map)->where('user_id', 'in', $userList)->field($field)->select()->toArray();
|
|
}
|
|
}
|
|
foreach ($list as $k => $v) {
|
|
$list[$k]['disabled'] = false;
|
|
$list[$k]['avatar'] = avatarUrl($v['avatar'], $v['realname'], $v['user_id']);
|
|
if ($user_ids) {
|
|
if (in_array($v['user_id'], $user_ids)) {
|
|
$list[$k]['disabled'] = true;
|
|
}
|
|
}
|
|
}
|
|
return $list;
|
|
}
|
|
|
|
//查询用户列表
|
|
public static function getUserList($map, $user_id, $field = "")
|
|
{
|
|
if (!$field) {
|
|
$field = self::$defaultField;
|
|
}
|
|
|
|
$config=Config::getSystemInfo();
|
|
// 如果是社区模式，就只查询自己的好友，如果是企业模式，就查询所有用户
|
|
if($config['sysInfo']['runMode']==1){
|
|
$friendList = Friend::getFriend(['create_user' => $user_id]);
|
|
$list = self::where($map)->field($field)->select();
|
|
}else{
|
|
$friendList = Friend::getFriend(['create_user' => $user_id,'status'=>1]);
|
|
$userList = array_keys($friendList);
|
|
// 将专属客服设置为好友
|
|
$csUid=request()->userInfo['cs_uid'] ?? 0;
|
|
if($csUid){
|
|
$userList[]=$csUid;
|
|
}
|
|
// 如果我有客服权限，就查询客服的好友
|
|
$cus=self::where(['cs_uid'=>$user_id])->column('user_id');
|
|
if($cus){
|
|
$userList=array_merge($userList,$cus);
|
|
}
|
|
$userList = array_unique($userList);
|
|
$list = self::where($map)->where('user_id', 'in', $userList)->field($field)->select();
|
|
}
|
|
$list_chart = chartSort($list, 'realname', false, 'index');
|
|
// 查询未读消息
|
|
$unread = (new Message())
|
|
->field('from_user,count(msg_id) as unread')
|
|
->where([['to_user', '=', $user_id], ['is_read', '=', 0], ['is_group', '=', 0]])
|
|
->group('from_user')
|
|
->select();
|
|
// 查询最近的联系人
|
|
$map1 = [['to_user', '=', $user_id], ['is_last', '=', 1], ['is_group', '=', 0]];
|
|
$map2 = [['from_user', '=', $user_id], ['is_last', '=', 1], ['is_group', '=', 0]];
|
|
$msgField = 'from_user,to_user,content as lastContent,create_time as lastSendTime,chat_identify,type,del_user';
|
|
$lasMsgList = (new Message())
|
|
->field($msgField)
|
|
->whereOr([$map1, $map2])
|
|
->order('create_time desc')
|
|
->select();
|
|
// 查询群聊
|
|
$group = Group::getMyGroup(['gu.user_id' => $user_id, 'gu.status' => 1]);
|
|
if ($group) {
|
|
$group = $group->toArray();
|
|
$group_ids = arrayToString($group, 'group_id');
|
|
$getGroupLastMsg = (new Message())->field($msgField)->where([['to_user', 'in', $group_ids], ['is_group', '=', 1], ['is_last', '=', 1]])->select();
|
|
$getAtMsg=(new Message())->field($msgField)->where([['to_user', 'in', $group_ids], ['is_group', '=', 1]])->whereFindInSet('at',$user_id)->select();
|
|
|
|
// halt($getAtMsg);
|
|
foreach ($group as $k => $v) {
|
|
$setting = $v['setting'] ? json_decode($v['setting'], true) : ['manage' => 0, 'invite' => 1, 'nospeak' => 0];
|
|
$group_id = 'group-' . $v['group_id'];
|
|
$group[$k]['id'] = $group_id;
|
|
$group[$k]['account'] = $group_id;
|
|
$group[$k]['avatar'] = avatarUrl($v['avatar'], $v['displayName'], $v['group_id'], 120);
|
|
$group[$k]['name_py'] = $v['name_py'];
|
|
$group[$k]['owner_id'] = $v['owner_id'];
|
|
$group[$k]['role'] = $v['role'];
|
|
$group[$k]['is_group'] = 1;
|
|
$group[$k]['setting'] = $setting;
|
|
$group[$k]['index'] = "[2]群聊";
|
|
$group[$k]['realname'] = $v['displayName'] . " [群聊]";
|
|
$group[$k]['is_notice'] = $v['is_notice'];
|
|
$group[$k]['is_top'] = $v['is_top'];
|
|
$group[$k]['is_online'] = 1;
|
|
$group[$k]['is_at'] = 0;
|
|
if ($getGroupLastMsg) {
|
|
foreach ($getGroupLastMsg as $key=>$val) {
|
|
if ($val['to_user'] == $v['group_id']) {
|
|
$group[$k]['type'] =$val['type'];
|
|
$group[$k]['lastContent'] = str_encipher($val['lastContent'],false);
|
|
$group[$k]['lastSendTime'] = $val['lastSendTime'] * 1000;
|
|
// 已经赋值了删除掉提升下次循环的性能
|
|
unset($getGroupLastMsg[$key]);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if($getAtMsg){
|
|
foreach ($getAtMsg as $key=> $val) {
|
|
if ($val['to_user'] == $v['group_id']) {
|
|
++$group[$k]['is_at'];
|
|
// 已经赋值了删除掉提升下次循环的性能
|
|
unset($getAtMsg[$key]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
try{
|
|
Gateway::$registerAddress = config('gateway.registerAddress');
|
|
$onlineList=Gateway::getAllUidList();
|
|
}catch(\Exception $e){
|
|
$onlineList=[];
|
|
}
|
|
foreach ($list_chart as $k => $v) {
|
|
// 是否有消息通知或者置顶聊天
|
|
$friend = isset($friendList[$v['user_id']]) ? $friendList[$v['user_id']] : [];
|
|
$list_chart[$k]['id'] = $v['user_id'];
|
|
$list_chart[$k]['displayName'] = ($friend['nickname'] ?? '') ? : $v['realname'];
|
|
$list_chart[$k]['name_py'] = $v['name_py'];
|
|
$list_chart[$k]['avatar'] = avatarUrl($v['avatar'], $v['realname'], $v['user_id'], 120);
|
|
$list_chart[$k]['lastContent'] = '';
|
|
$list_chart[$k]['unread'] = 0;
|
|
$list_chart[$k]['lastSendTime'] = time() * 1000;
|
|
$list_chart[$k]['is_group'] = 0;
|
|
$list_chart[$k]['setting'] = [];
|
|
$list_chart[$k]['is_at'] = 0;
|
|
$list_chart[$k]['last_login_ip'] = $v['last_login_ip'];
|
|
$list_chart[$k]['location'] =$v['last_login_ip'] ? implode(" ", \Ip::find($v['last_login_ip'])) : "未知";
|
|
$is_online=0;
|
|
if(isset($onlineList[$v['user_id']])){
|
|
$is_online=1;
|
|
}
|
|
$list_chart[$k]['is_online'] = $is_online;
|
|
|
|
$is_top = 0;
|
|
$is_notice = 1;
|
|
$is_blacklist = 1;
|
|
if ($friend) {
|
|
$is_top = $friend['is_top'];
|
|
$is_notice = $friend['is_notice'];
|
|
$is_blacklist = $friend['is_blacklist'];
|
|
}
|
|
$list_chart[$k]['is_top'] = $is_top;
|
|
$list_chart[$k]['is_notice'] = $is_notice;
|
|
$list_chart[$k]['is_blacklist'] = $is_blacklist;
|
|
if ($unread) {
|
|
foreach ($unread as $val) {
|
|
if ($val['from_user'] == $v['user_id']) {
|
|
$list_chart[$k]['unread'] = $val['unread'];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if ($lasMsgList) {
|
|
foreach ($lasMsgList as $val) {
|
|
if ($val['from_user'] == $v['user_id'] || $val['to_user'] == $v['user_id']) {
|
|
$content = str_encipher($val['lastContent'],false);
|
|
// 屏蔽已删除的消息
|
|
if ($val['del_user']) {
|
|
$delUser = explode(',', $val['del_user']);
|
|
if (in_array($user_id, $delUser)) {
|
|
//$content = "";
|
|
continue;
|
|
}
|
|
}
|
|
$list_chart[$k]['type'] = $val['type'];
|
|
$list_chart[$k]['lastContent'] = $content;
|
|
$list_chart[$k]['lastSendTime'] = $val['lastSendTime'] * 1000;
|
|
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
// 合并群聊和联系人
|
|
$data = array_merge($list_chart, $group);
|
|
// 合并助手消息和聊天消息
|
|
$helper=self::otherChat($user_id);
|
|
$data=array_merge($data,$helper);
|
|
return $data;
|
|
}
|
|
|
|
// 获取机器人聊天消息
|
|
public static function otherChat($uid){
|
|
$staticList=self::staticUser();
|
|
$adminNotice=$staticList['adminNotice'];
|
|
$fileTransfer=$staticList['fileTransfer'];
|
|
$count=Message::where(['chat_identify'=>$adminNotice['id']])->count();
|
|
$createTime=Message::where(['chat_identify'=>$adminNotice['id']])->order('id desc')->value('create_time');
|
|
$sendTime=0;
|
|
if($createTime){
|
|
$sendTime=is_string($createTime) ? strtotime($createTime) : $createTime;
|
|
}
|
|
$chat_identify=chat_identify($uid,$fileTransfer['id']);
|
|
$fileLast=Message::where(['is_last'=>1,'chat_identify'=>$chat_identify])->find();
|
|
$fileSendTime=$fileLast['create_time'] ?? '';
|
|
$content =$fileLast['content'] ?? '';
|
|
$friend=Friend::where(['create_user'=>$uid,'friend_user_id'=>$fileTransfer['id']])->find();
|
|
$notice=[
|
|
[
|
|
'id'=>$adminNotice['id'],
|
|
'user_id'=>$adminNotice['id'],
|
|
'displayName'=>$adminNotice['displayName'],
|
|
'realname'=>$adminNotice['displayName'],
|
|
'name_py'=>$adminNotice['name_py'],
|
|
'avatar'=>$adminNotice['avatar'],
|
|
'lastContent'=>$sendTime ? $count.'条公告' :'',
|
|
'unread'=>0,
|
|
'lastSendTime'=>$sendTime * 1000,
|
|
'is_group'=>2,
|
|
'setting'=>[],
|
|
'type'=>'text',
|
|
'is_top'=>0,
|
|
'is_notice'=>1,
|
|
'is_online'=>0,
|
|
'index'=>"[1]系统消息",
|
|
],
|
|
[
|
|
'id'=>$fileTransfer['id'],
|
|
'user_id'=>$fileTransfer['id'],
|
|
'displayName'=>$fileTransfer['displayName'],
|
|
'realname'=>$fileTransfer['displayName'],
|
|
'name_py'=>$fileTransfer['name_py'],
|
|
'avatar'=>$fileTransfer['avatar'],
|
|
'lastContent'=> str_encipher($content,false) ?: '传输你的文件',
|
|
'unread'=>0,
|
|
'lastSendTime'=>((is_string($fileSendTime) ? strtotime($fileSendTime) : $fileSendTime) * 1000) ?: time() * 1000,
|
|
'is_group'=>3,
|
|
'setting'=>[],
|
|
'type'=>$fileLast['type'] ?? 'text',
|
|
'is_top'=>$friend['is_top'] ?? 0,
|
|
'is_notice'=>$friend['is_notice'] ?? 1,
|
|
'is_online'=>0,
|
|
'index'=>"[1]系统消息",
|
|
],
|
|
];
|
|
|
|
return $notice;
|
|
|
|
}
|
|
|
|
public static function getList($map)
|
|
{
|
|
return self::field(self::$defaultField)->where($map)->select();
|
|
}
|
|
|
|
// 匹配用户列表信息(返回用户信息)
|
|
|
|
public static function matchUser($data, $many = false, $field = 'user_id', $cs = 80)
|
|
{
|
|
if ($many) {
|
|
$idr = arrayToString($data, $field, false);
|
|
} else {
|
|
$idr = [];
|
|
if (is_array($field)) {
|
|
foreach ($field as $v) {
|
|
$idr[] = $data[$v];
|
|
}
|
|
} else {
|
|
$idr = [$data[$field]];
|
|
}
|
|
}
|
|
$key = array_search(0, $idr);
|
|
if ($key) {
|
|
array_splice($idr, $key, 1);
|
|
}
|
|
$userList = self::where([['user_id', 'in', $idr]])->field(self::$defaultField)->select()->toArray();
|
|
$friend = Friend::where([['friend_user_id', 'in', $idr],['create_user','=',self::$uid]])->field('friend_user_id,nickname')->select()->toArray();
|
|
$list = [];
|
|
foreach ($userList as $v) {
|
|
$v['avatar'] = avatarUrl($v['avatar'], $v['realname'], $v['user_id'], $cs);
|
|
$v['id'] = $v['user_id'];
|
|
if($friend){
|
|
foreach($friend as $key=>$val){
|
|
if($val['friend_user_id']==$v['user_id']){
|
|
$v['displayName']=$val['nickname'] ? : $v['displayName'];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
$list[$v['user_id']] = $v;
|
|
}
|
|
return $list;
|
|
}
|
|
|
|
// 匹配用户列表信息（返回data）
|
|
public static function matchAllUser($data, $many = false, $field = 'user_id', $key = "userInfo", $cs = 80, $uid = 0)
|
|
{
|
|
if ($many) {
|
|
$idr = arrayToString($data, $field);
|
|
$userList = self::getList([['user_id', 'in', $idr]]);
|
|
foreach ($data as $k => $v) {
|
|
foreach ($userList as $vv) {
|
|
if ($v[$field] == $vv['user_id']) {
|
|
$displayName = $vv['realname'];
|
|
if ($uid) {
|
|
$friendNameData = Friend::getFriendName($uid, $vv['user_id']);
|
|
if ($friendNameData['nickname']) {
|
|
$displayName = $friendNameData['nickname'];
|
|
}
|
|
}
|
|
$data[$k][$key] = [
|
|
'id' => $vv['user_id'],
|
|
'displayName' => $displayName,
|
|
'account' => $vv['account'],
|
|
'name_py' => $vv['name_py'],
|
|
'avatar' => avatarUrl($vv['avatar'], $vv['realname'], $vv['user_id'], $cs),
|
|
];
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
$user = self::getUserInfo(['user_id' => $data[$field]]);
|
|
$data[$key] = [
|
|
'id' => $user['user_id'],
|
|
'displayName' => $user['realname'],
|
|
'account' => $user['account'],
|
|
'name_py' => $user['name_py'],
|
|
'avatar' => avatarUrl($user['avatar'], $user['realname'], $user['user_id']),
|
|
];
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
|
|
// 将id转换成联系人信息
|
|
public function setContact($id,$is_group=0,$type='text',$content='',$contactInfo=null){
|
|
$data=[
|
|
'id'=>$id,
|
|
'lastContent'=>$content,
|
|
'unread'=>0,
|
|
'lastSendTime'=> time() * 1000,
|
|
'is_group'=>$is_group,
|
|
'is_top'=>0,
|
|
'is_notice'=>1,
|
|
'is_top'=>0,
|
|
'is_at'=>0,
|
|
'setting'=>[],
|
|
'type'=>$type,
|
|
'location'=>'',
|
|
];
|
|
if($is_group==0){
|
|
$user=$contactInfo ?: User::where('user_id',$id)->find();
|
|
if(!$user){
|
|
$this->error=lang('user.exist');
|
|
return false;
|
|
}
|
|
$user->avatar=avatarUrl($user->avatar,$user->realname,$user->user_id,120);
|
|
// 查询好友关系
|
|
$friend= self::$userInfo ? Friend::where(['friend_user_id'=>$id,'create_user'=>self::$userInfo['user_id']])->find() : [];
|
|
$data['displayName'] = ($friend['nickname'] ?? '') ? : $user['realname'];
|
|
$data['avatar'] = avatarUrl($user['avatar'], $user['realname'], $user['user_id'], 120);
|
|
$data['location'] =$user['last_login_ip'] ? implode(" ", \Ip::find($user['last_login_ip'])) : "未知";
|
|
$data['name_py'] = $user['name_py'];
|
|
}else{
|
|
$group_id=is_numeric($id) ? $id : (explode('-',$id)[1] ?? 0);
|
|
$group=$contactInfo ?: Group::where(['group_id'=>$group_id])->find();
|
|
if(!$group){
|
|
$this->error=lang('group.exist');
|
|
return false;
|
|
}
|
|
$data['id'] = 'group-'.$group_id;
|
|
$data['displayName'] = $group['name'];
|
|
$data['avatar'] = avatarUrl($group['avatar'], $group['name'], $group['group_id'], 120);
|
|
$data['name_py'] = $group['name_py'];
|
|
$data['setting'] = $group['setting'];
|
|
$data['role'] = 3;
|
|
}
|
|
$data['index'] =getFirstChart($data['displayName']);
|
|
return $data;
|
|
}
|
|
|
|
// 验证账号的合法性
|
|
public function checkAccount(&$data){
|
|
$user_id=$data['user_id'] ?? 0;
|
|
if($user_id){
|
|
$user=self::find($data['user_id']);
|
|
if(!$user){
|
|
$this->error='账户不存在';
|
|
return false;
|
|
}
|
|
if($user->user_id==1 && self::$uid!=1){
|
|
$this->error='超管账户只有自己才能修改';
|
|
return false;
|
|
}
|
|
$other=self::where([['account','=',$data['account']],['user_id','<>',$data['user_id']]])->find();
|
|
if($other){
|
|
$this->error='账户已存在';
|
|
return false;
|
|
}
|
|
}else{
|
|
$user=self::where('account',$data['account'])->find();
|
|
if($user){
|
|
$this->error='账户已存在';
|
|
return false;
|
|
}
|
|
}
|
|
$config=Config::getSystemInfo();
|
|
$regauth=$config['sysInfo']['regauth'] ?? 0;
|
|
$acType=\utils\Regular::check_account($data['account']);
|
|
switch($regauth){
|
|
case 1:
|
|
if($acType!=1){
|
|
$this->error='当前系统只允许账号为手机号！';
|
|
return false;
|
|
}
|
|
break;
|
|
case 2:
|
|
if($acType!=2){
|
|
$this->error='当前系统只允许账号为邮箱！';
|
|
return false;
|
|
}
|
|
break;
|
|
case 3:
|
|
// 验证账号是否为手机号或者邮箱
|
|
if(!$acType){
|
|
$this->error='账户必须为手机号或者邮箱';
|
|
return false;
|
|
}
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
$data['is_auth'] =$regauth ? 1 : 0;
|
|
$email=$data['email'] ?? '';
|
|
if($data['is_auth'] && $acType==2 && !$email){
|
|
$data['email'] =$data['account'];
|
|
}
|
|
return true;
|
|
}
|
|
}
|
|
|