<?php
|
|
namespace app\api\controller\plus\business\chat;
|
|
use app\api\controller\Controller;
|
use app\api\model\plus\business\chat\Chat as ChatModel;
|
use app\api\model\plus\business\chat\Conversation as ConversationModel;
|
use app\api\model\plus\business\chat\Participant;
|
use app\api\model\user\User as UserModel;
|
use app\common\model\plus\business\Business as BusinessModel;
|
|
/**
|
* 名片聊天控制器
|
*/
|
class Chat extends Controller
|
{
|
/**
|
* 发送消息
|
*/
|
public function sendMessage()
|
{
|
$user = $this->getUser();
|
$userId = $user['user_id'];
|
$conversationId = $this->request->post('conversation_id/d', 0);
|
$businessCardId = $this->request->post('business_card_id/d', 0);
|
$content = $this->request->post('content/s', '');
|
|
if (empty($content)) {
|
return $this->renderError('消息内容不能为空');
|
}
|
|
// 如果没有会话ID，根据名片ID创建会话
|
if (empty($conversationId) && !empty($businessCardId)) {
|
$conversationModel = new ConversationModel();
|
|
// 获取名片信息
|
$businessModel = new BusinessModel();
|
$businessCard = $businessModel->where('business_card_id', $businessCardId)->find();
|
|
if (!$businessCard) {
|
return $this->renderError('名片不存在');
|
}
|
|
// 创建会话，参与者包括当前用户和名片所有者
|
$participants = [$userId, $businessCard->user_id];
|
$conversationId = $conversationModel->createConversation($businessCardId, $participants);
|
|
if (!$conversationId) {
|
return $this->renderError('创建会话失败');
|
}
|
}
|
|
if (empty($conversationId)) {
|
return $this->renderError('会话ID不能为空');
|
}
|
|
$chatModel = new ChatModel();
|
$result = $chatModel->sendMessage($conversationId, $userId, $content);
|
|
if ($result) {
|
// 更新会话时间
|
$conversationModel = new ConversationModel();
|
$conversationModel->updateConversationTime($conversationId);
|
// 准备WebSocket消息数据
|
$wsMessage = [
|
'type' => 'message',
|
'user_id' => $userId,
|
'to_user_id' => 0, // 需要确定接收者ID
|
'content' => $content,
|
'conversation_id' => $conversationId,
|
'business_card_id' => $businessCardId,
|
'chat_id' => $chatModel->chat_id,
|
'time' => date('Y-m-d H:i:s')
|
];
|
|
// 确定接收者ID
|
$participantModel = new Participant();
|
$participants = $participantModel->where('conversation_id', $conversationId)
|
->where('user_id', '<>', $userId)
|
->select();
|
|
if (!empty($participants)) {
|
$wsMessage['to_user_id'] = $participants[0]['user_id'];
|
}
|
|
return $this->renderSuccess('发送成功', [
|
'message' => $chatModel->toArray(),
|
'ws_message' => $wsMessage
|
]);
|
} else {
|
return $this->renderError('发送失败');
|
}
|
}
|
|
/**
|
* 获取会话消息列表
|
*/
|
public function getMessages()
|
{
|
$param=request()->param();
|
$user = $this->getUser();
|
$userId = $user['user_id'];
|
if (empty($param['conversation_id']) && !empty($param['business_card_id'])) {
|
$conversationModel = new ConversationModel();
|
$conversation = $conversationModel->getConversationByBusinessCard($param['business_card_id']);
|
if ($conversation) {
|
$param['conversation_id'] = $conversation['conversation_id'];
|
}
|
}
|
|
if (empty($param['conversation_id'])) {
|
return $this->renderError('会话不存在');
|
}
|
|
$chatModel = new ChatModel();
|
$messages = $chatModel->getMessages($param);
|
$hasParticipant = Participant::where('conversation_id', $param['conversation_id'])
|
->where('user_id','<>', $userId)
|
->find();
|
$heUser=(new UserModel())->detail($hasParticipant['user_id']);
|
$card=(new BusinessModel())->where('user_id',$hasParticipant['user_id'])->where('is_default',1)->find();
|
|
return $this->renderSuccess('获取成功', compact('messages','heUser','card'));
|
}
|
|
/**
|
* 获取会话列表
|
*/
|
public function getConversations()
|
{
|
$param=request()->param();
|
$user = $this->getUser();
|
$param['user_id'] = $user['user_id'];
|
|
|
$conversationModel = new ConversationModel();
|
$conversations = $conversationModel->getUserConversations($param);
|
|
// 为每个会话添加未读消息数量
|
$chatModel = new ChatModel();
|
foreach ($conversations as &$conversation) {
|
$conversation['unread_count'] = $chatModel->getUnreadCount($conversation['conversation_id'], $param['user_id']);
|
|
// 获取最后一条消息
|
if (!empty($conversation['messages'])) {
|
$conversation['last_message'] = end($conversation['messages']);
|
}
|
}
|
|
return $this->renderSuccess('获取成功', compact('conversations'));
|
}
|
|
/**
|
* 标记消息为已读
|
*/
|
public function markAsRead()
|
{
|
$user = $this->getUser();
|
$userId = $user['user_id'];
|
|
$param=request()->param();
|
|
if (empty($param['chat_id']) && empty($param['conversation_id'])) {
|
return $this->renderError('参数错误');
|
}
|
|
$chatModel = new ChatModel();
|
|
if (!empty($param['chat_id'])) {
|
// 标记单条消息为已读
|
$result = $chatModel->markAsRead($param['chat_id'], $userId);
|
$error=$chatModel->getError();
|
} else {
|
$chatDate=$chatModel->where('conversation_id',$param['conversation_id'])->where('sender_id','<>',$userId)->find();
|
if (empty($chatDate)){
|
return $this->renderSuccess('标记成功');
|
}
|
// 标记整个会话为已读
|
$participantModel = new Participant();
|
$result = $participantModel->markConversationAsRead($param['conversation_id'], $chatDate['sender_id']);
|
// 更新会话中所有消息的已读状态
|
if ($result) {
|
$chatModel->where('conversation_id', $param['conversation_id'])
|
->where('sender_id', '<>', $userId)
|
->where('is_read', 0)
|
->update([
|
'is_read' => 1,
|
'read_time' => time(),
|
'update_time' => time()
|
]);
|
}
|
$error=$participantModel->getError();
|
}
|
|
if ($result) {
|
return $this->renderSuccess('标记成功');
|
} else {
|
return $this->renderError('标记失败'.$error);
|
}
|
}
|
|
/**
|
* 根据名片ID获取或创建会话
|
*/
|
public function getOrCreateConversation()
|
{
|
$user = $this->getUser();
|
$userId = $user['user_id'];
|
|
$businessCardId = $this->request->post('business_card_id/d', 0);
|
|
if (empty($businessCardId)) {
|
return $this->renderError('名片ID不能为空');
|
}
|
|
// 获取名片信息
|
$businessModel = new BusinessModel();
|
$businessCard = $businessModel->where('business_card_id', $businessCardId)->find();
|
|
if (!$businessCard) {
|
return $this->renderError('名片不存在');
|
}
|
|
$conversationModel = new ConversationModel();
|
|
// 检查是否已存在会话
|
$conversation = $conversationModel->getConversationByBusinessCard($businessCardId);
|
|
if ($businessCard['user_id'] == $userId&&!$conversation) {
|
return $this->renderError('不能与自己建立会话');
|
}
|
if (!$conversation) {
|
|
// 创建新会话
|
$participants = [$userId, $businessCard['user_id']];
|
$conversationId = $conversationModel->createConversation($businessCardId, $participants);
|
if ($conversationId) {
|
$conversation = $conversationModel->getConversationByBusinessCard($businessCardId);
|
}
|
}
|
|
if ($conversation) {
|
// 添加未读消息数量
|
$chatModel = new ChatModel();
|
$conversation['unread_count'] = $chatModel->getUnreadCount($conversation['conversation_id'], $userId);
|
|
return $this->renderSuccess('获取成功', compact('conversation'));
|
} else {
|
return $this->renderError('创建会话失败');
|
}
|
}
|
}
|
