src/Biz/IM/Service/Impl/ConversationServiceImpl.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Biz\IM\Service\Impl;

use Biz\BaseService;
use AppBundle\Common\ArrayToolkit;
use Biz\CloudPlatform\IMAPIFactory;
use Biz\IM\ConversationException;
use Biz\IM\Service\ConversationService;

class ConversationServiceImpl extends BaseService implements ConversationService
{
    private $imApi;

    public function getConversation($id)
    {
        return $this->getConversationDao()->get($id);
    }

    public function getConversationByConvNo($convNo)
    {
        return $this->getConversationDao()->getByConvNo($convNo);
    }

    public function getConversationByMemberIds(array $memberIds)
    {
        sort($memberIds);
        $memberHash = $this->buildMemberHash($memberIds);

        return $this->getConversationDao()->getByMemberHash($memberHash);
    }

    public function getConversationByTarget($targetId, $targetType)
    {
        return $this->getConversationDao()->getByTargetIdAndTargetType($targetId, $targetType);
    }

    public function createConversation($title, $targetType, $targetId, $members)
    {
        $conversation = array();
        $conversation['title'] = $title;
        $conversation['targetType'] = $targetType;
        $conversation['targetId'] = empty($targetId) ? 0 : intval($targetId);

        $memberIds = ArrayToolkit::column($members, 'id');
        if ($targetType == 'private') {
            $conversation['title'] = join(ArrayToolkit::column($members, 'nickname'), '-').'的私聊';
            $conversation['memberIds'] = $memberIds;
        } else {
            $conversation['memberIds'] = array();
        }

        $lockName = "im_{$conversation['targetType']}{$conversation['targetId']}";
        if ($targetType == 'global') {
            $lockName = "im_{$conversation['targetType']}0";
        }

        $lockResult = $this->getLock()->get($lockName, 50);
        if (!$lockResult) {
            $this->createNewException(ConversationException::CREATE_FAILED());