<?php

namespace app\common\model\plus\business\chat;

use app\common\model\BaseModel;

/**
 * 名片聊天会话模型
 */
class Conversation extends BaseModel
{
    protected $pk = 'conversation_id';
    protected $name = 'business_conversation';

    /**
     * 关联名片
     */
    public function businessCard()
    {
        return $this->belongsTo("app\\common\\model\\plus\\business\\Business", 'business_card_id', 'business_card_id');
    }

    /**
     * 关联参与者
     */
    public function participants()
    {
        return $this->hasMany("app\\common\\model\\plus\\business\\chat\\Participant", 'conversation_id', 'conversation_id');
    }

    /**
     * 关联消息
     */
    public function messages()
    {
        return $this->hasMany("app\\common\\model\\plus\\business\\chat\\Chat", 'conversation_id', 'conversation_id');
    }

    /**
     * 创建会话
     * @param int $businessCardId 名片ID
     * @param array $participants 参与者数组
     * @param int $appId 应用ID
     * @return int|false
     */
    public function createConversation($businessCardId, $participants = [])
    {
        $appId = self::$app_id;
        // 检查是否已存在相同名片的会话
        $existing = $this->where('business_card_id', $businessCardId)->find();
        if ($existing) {
            return $existing->conversation_id;
        }

        $data = [
            'business_card_id' => $businessCardId,
            'app_id' => $appId
        ];
        try {
            $this->save($data);
            $conversationId = $this->conversation_id;
            // 添加参与者
            foreach ($participants as $userId) {
                (new Participant())->addParticipant($conversationId, $userId, $appId);
            }
            return $conversationId;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            return false;
        }
    }

    /**
     * 获取用户相关的会话列表
     * @return array|\think\Paginator
     */
    public function getUserConversations($param = [])
    {
        return $this->with(['businessCard', 'participants.user', 'messages'])
            ->order('update_time', 'desc')
            ->paginate($param);
    }

    /**
     * 根据名片ID获取会话
     * @param int $businessCardId 名片ID
     * @return array|null
     */
    public function getConversationByBusinessCard($businessCardId)
    {
        return $this->with(['businessCard', 'participants.user'])
            ->where('business_card_id', $businessCardId)
            ->find();
    }

    /**
     * 更新会话时间
     * @param int $conversationId 会话ID
     * @return bool
     */
    public function updateConversationTime($conversationId)
    {
        $conversation = $this->find($conversationId);
        if ($conversation) {
            $conversation->update_time = time();
            return $conversation->save();
        }
        return false;
    }
}