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.
209 lines
8.5 KiB
209 lines
8.5 KiB
<?php
|
|
/**
|
|
* User raingad
|
|
* Date 2024/11/17 17:24
|
|
*/
|
|
|
|
|
|
namespace app\manage\controller;
|
|
|
|
|
|
use app\BaseController;
|
|
use app\enterprise\model\{Message as MessageModel,User,Friend,Group};
|
|
use think\facade\Db;
|
|
class Message extends BaseController
|
|
{
|
|
protected $fileType = ['file', 'image','video','voice'];
|
|
// 获取聊天记录
|
|
public function index()
|
|
{
|
|
$param = $this->request->param();
|
|
$user_id=$param['user_id'] ?? 0;
|
|
$toContactId=$param['toContactId'] ?? 0;
|
|
$is_group=($param['is_group'] ?? 0) ? $param['is_group']-1 : -1;
|
|
$map = [ 'status' => 1];
|
|
if($user_id){
|
|
if(!$toContactId){
|
|
return warning(lang('system.parameterError'));
|
|
}
|
|
$chat_identify=chat_identify($param['user_id'],$param['toContactId']);
|
|
$map['chat_identify'] = $chat_identify;
|
|
}
|
|
if($is_group>=0){
|
|
$map['is_group']=$is_group;
|
|
}
|
|
$type = isset($param['type']) ? $param['type'] : '';
|
|
$where = [];
|
|
if ($type && $type != "all") {
|
|
$map['type'] = $type;
|
|
} else {
|
|
$where[] = ['type', 'not in', ['event','admin_notice','webrtc']];
|
|
}
|
|
$keywords = isset($param['keywords']) ? $param['keywords'] : '';
|
|
if ($keywords && in_array($type, ['text', 'all'])) {
|
|
$where[] = ['content', 'like', '%' . $keywords . '%'];
|
|
$where[] = ['type', '=', 'text'];
|
|
}
|
|
$listRows = $param['limit'] ?: 20;
|
|
$pageSize = $param['page'] ?: 1;
|
|
$last_id = $param['last_id'] ?? 0;
|
|
if($last_id){
|
|
$where[]=['msg_id','<',$last_id];
|
|
}
|
|
$list = MessageModel::getList($map, $where, 'msg_id desc', $listRows, $pageSize);
|
|
$data = $this->recombileMsg($list);
|
|
return success('', $data, $list->total(),$list->currentPage());
|
|
}
|
|
|
|
protected function recombileMsg($list,$isPagination=true)
|
|
{
|
|
$data = [];
|
|
if ($list) {
|
|
$listData = $isPagination ? $list->toArray()['data'] : $list;
|
|
$userList = User::matchUser($listData, true, 'from_user', 120);
|
|
foreach ($listData as $k => $v) {
|
|
$content = str_encipher($v['content'],false);
|
|
$preview = '';
|
|
$ext='';
|
|
if (in_array($v['type'], $this->fileType)) {
|
|
$content = getFileUrl($content);
|
|
$preview = previewUrl($content);
|
|
$ext=getExtUrl($content);
|
|
}
|
|
$fromUser = $userList[$v['from_user']];
|
|
$toContactId=$v['is_group'] ==1 ? 'group-'.$v['to_user'] : $v['to_user'];
|
|
$atList=($v['at'] ?? null) ? explode(',',$v['at']): [];
|
|
if($v['is_group']==0){
|
|
$toUser=User::where(['user_id'=>$v['to_user']])->field(User::$defaultField)->find() ?? [];
|
|
if($toUser){
|
|
$toUser=[
|
|
'name'=>$toUser['realname']
|
|
];
|
|
}
|
|
|
|
}else{
|
|
$toUser=Group::where(['group_id'=>$v['to_user']])->find();
|
|
if($toUser){
|
|
$toUser=[
|
|
'name'=>$toUser['name']
|
|
];
|
|
}
|
|
}
|
|
$data[] = [
|
|
'msg_id' => $v['msg_id'],
|
|
'id' => $v['id'],
|
|
'status' => "succeed",
|
|
'type' => $v['type'],
|
|
'sendTime' => is_numeric($v['create_time']) ? $v['create_time'] * 1000 : strtotime($v['create_time']) * 1000,
|
|
'create_time' => is_string($v['create_time']) ? $v['create_time'] : date('Y-m-d H:i:s',$v['create_time']),
|
|
'content' => $content,
|
|
'preview' => $preview,
|
|
'download' => $v['file_id'] ? getMainHost().'/filedown/'.encryptIds($v['file_id']) : '',
|
|
'is_read' => $v['is_read'],
|
|
'is_group' => $v['is_group'],
|
|
'at' => $atList,
|
|
'toContactId' => $toContactId,
|
|
'from_user' => $v['from_user'],
|
|
'file_id' => $v['file_id'],
|
|
'file_cate' => $v['file_cate'],
|
|
'fileName' => $v['file_name'],
|
|
'fileSize' => $v['file_size'],
|
|
'fromUser' => $fromUser,
|
|
'toUser' => $toUser,
|
|
'extUrl'=>$ext,
|
|
'extends'=>is_string($v['extends'])?json_decode($v['extends'],true) : $v['extends']
|
|
];
|
|
}
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
// 获取某个联系人的好友列表
|
|
public function getContacts(){
|
|
$param = $this->request->param();
|
|
$user_id=$param['user_id'] ?? 0;
|
|
if(!$user_id){
|
|
return warning(lang('system.parameterError'));
|
|
}
|
|
$config=$this->globalConfig;
|
|
$listRows = $param['limit'] ?: 20;
|
|
$pageSize = $param['page'] ?: 1;
|
|
$keywords = $param['keywords'] ?: '';
|
|
$where=[['status','=',1]];
|
|
if($keywords){
|
|
$where[] = ['realname', 'like', '%' . $keywords . '%'];
|
|
}
|
|
$hasConvo=$param['hasConvo'] ?? 0;
|
|
if($hasConvo){
|
|
// 查询最近的联系人
|
|
$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 MessageModel())
|
|
->field($msgField)
|
|
->whereOr([$map1, $map2])
|
|
->order('create_time desc')
|
|
->select();
|
|
$ids1=\utils\Arr::arrayToString($lasMsgList,'from_user',false);
|
|
$ids2=\utils\Arr::arrayToString($lasMsgList,'to_user',false);
|
|
$ids=array_merge($ids1,$ids2);
|
|
$userList = array_diff($ids, [$user_id]);
|
|
$where[]=['user_id','in',$userList];
|
|
}else{
|
|
// 如果是社区模式，就只查询的好友，如果是企业模式，就查询所有用户
|
|
if($config['sysInfo']['runMode']==1){
|
|
$where[]=['user_id','<>',$user_id];
|
|
}else{
|
|
$friendList = Friend::getFriend(['create_user' => $user_id,'status'=>1]);
|
|
$userList = array_keys($friendList);
|
|
$where[]=['user_id','in',$userList];
|
|
}
|
|
}
|
|
|
|
$list = User::where($where)->field(User::$defaultField)->paginate(['list_rows'=>$listRows,'page'=>$pageSize]);
|
|
$data=[];
|
|
if($list){
|
|
$data=$list->toArray()['data'];
|
|
foreach ($data as $k => $v) {
|
|
$data[$k]['avatar'] = avatarUrl($v['avatar'], $v['realname'], $v['user_id'], 120);
|
|
$data[$k]['id'] = $v['user_id'];
|
|
}
|
|
}
|
|
return success('',$data,$list->total(),$list->currentPage());
|
|
}
|
|
|
|
// 消息处理
|
|
public function dealMsg(){
|
|
$param = $this->request->param();
|
|
$id = $param['id'];
|
|
$message = MessageModel::where(['id' => $id])->find();
|
|
if ($message) {
|
|
$dealType=$param['dealType'] ?? 0;
|
|
$content=$message['content'] ?? '';
|
|
if($dealType==1){
|
|
MessageModel::where(['id' => $id])->find()->delete();
|
|
// 如果是最后一条消息，需要将上一条设置为最后一条
|
|
if($message['is_last']){
|
|
MessageModel::where(['chat_identify'=>$message['chat_identify']])->order('msg_id desc')->limit(1)->update(['is_last'=>1]);
|
|
}
|
|
$action='delMessage';
|
|
}else{
|
|
$content=str_encipher(lang('im.forbidMsg'),true);
|
|
MessageModel::where(['id' => $id])->update(['content'=>$content,'type'=>'text']);
|
|
$action='updateMessage';
|
|
}
|
|
$toContactId = $message['to_user'];
|
|
if ($message['is_group'] == 1) {
|
|
$toContactId = explode('-', $message['chat_identify'])[1];
|
|
}
|
|
$data=[
|
|
'id'=>$message['id'],
|
|
'content'=>str_encipher($content,false),
|
|
];
|
|
wsSendMsg($toContactId, $action, $data, $message['is_group']);
|
|
return success('');
|
|
} else {
|
|
return warning(lang('im.exist'));
|
|
}
|
|
}
|
|
}
|