src/AppBundle/Controller/Callback/AthenaLive/Members.php

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

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

<?php

namespace AppBundle\Controller\Callback\AthenaLive;

use AppBundle\Common\ArrayToolkit;
use Biz\User\TokenException;
use Symfony\Component\HttpFoundation\Request;

class Members extends AthenaLiveBase
{
    public function fetch(Request $request)
    {
        $token = $request->query->get('token');
        $courseId = $request->query->get('courseId');

        $userToken = $this->getTokenService()->verifyToken('live.callback', $token);

        if (!$userToken) {
            $this->createNewException(TokenException::TOKEN_INVALID());
        }

        if ($userToken['data']['courseId'] != $courseId) {
            $this->createNewException(TokenException::NOT_MATCH_COURSE());
        }

        $start = $request->query->get('start', 0);
        $limit = $request->query->get('limit', 200);

        if ($userToken['data']['type'] == 'open_course') {
            $sourceCourseMembers = $this->getOpenCourseService()->searchMembers(
                array('courseId' => $courseId),
                array('createdTime' => 'DESC'),
                $start,
                $limit
            );
        } else {
            $sourceCourseMembers = $this->getCourseMemberService()->searchMembers(
                array('courseId' => $courseId),
                array('createdTime' => 'DESC'),
                $start,
                $limit
            );
        }

        $userIds = ArrayToolkit::column($sourceCourseMembers, 'userId');
        $users = $this->getUserService()->findUsersByIds($userIds);

        $result = $this->buildCourseMemberData($sourceCourseMembers, $users);
        if (empty($result)) {
            $result['data'] = array();
            $result['finish'] = true;

            return $result;
        }
        $result['start'] = $start + $limit;
        $result['limit'] = $limit;
        if (count($result['data']) < $limit) {
            $result['finish'] = true;
        } else {
            $result['finish'] = false;