| | |
| | | * @param int $appId 应用ID |
| | | * @return bool |
| | | */ |
| | | public function sendMessage($conversationId, $senderId, $content, $messageType = 0) |
| | | public function sendMessage($conversationId, $senderId, $content, $messageType = 0, $appId = null) |
| | | { |
| | | $data = [ |
| | | 'conversation_id' => $conversationId, |
| | | 'sender_id' => $senderId, |
| | | 'content' => $content, |
| | | 'message_type' => $messageType, |
| | | 'app_id' => self::$app_id, |
| | | 'is_read' => 0, |
| | | 'read_time' => 0, |
| | | 'app_id' => $appId?$appId:self::$app_id, |
| | | 'send_time' => time(), |
| | | ]; |
| | | |
| | | return $this->save($data); |
| | |
| | | */ |
| | | public function markAsRead($chatId, $readerId) |
| | | { |
| | | $message = $this->find($chatId); |
| | | $message = $this->where('chat_id',$chatId)->find(); |
| | | if ($message && $message->sender_id != $readerId) { |
| | | $message->is_read = 1; |
| | | $message->read_time = time(); |
| | | $message->update_time = time(); |
| | | return $message->save(); |
| | | $data=[ |
| | | 'is_read'=>1, |
| | | 'read_time'=>time() |
| | | ]; |
| | | return $message->save($data); |
| | | } |
| | | return false; |
| | | } |