src/AppBundle/Extensions/DataTag/LatestStatusesDataTag.php

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

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

<?php

namespace AppBundle\Extensions\DataTag;

use Biz\Course\Service\CourseService;
use AppBundle\Common\ArrayToolkit;
use AppBundle\Common\ExtensionManager;

class LatestStatusesDataTag extends BaseDataTag implements DataTag
{
    /**
     * 获取所有用户的最新动态
     *
     * 可传入的参数：
     *   mode     必需 动态的模式(simple, full)
     *   count    必需 获取动态数量
     *   objectType 可选 动态所属对象类型
     *   objectId   可选 动态所属对象编号
     *
     * @param array $arguments 参数
     *
     * @return array 用户列表
     */
    public function getData(array $arguments)
    {
        $conditions = array();
        if (isset($arguments['private']) && $arguments['private'] == 0) {
            $conditions['private'] = 0;
        }

        if (isset($arguments['objectType']) && isset($arguments['objectId'])) {
            if ($arguments['objectType'] == 'course') {
                $conditions['courseIds'] = array($arguments['objectId']);
            } elseif ($arguments['objectType'] == 'courseSet') {
                $courses = $this->getCourseService()->findCoursesByCourseSetId($arguments['objectId']);
                $conditions['courseIds'] = ArrayToolkit::column($courses, 'id');
            } else {
                $courses = $this->getClassroomService()->findActiveCoursesByClassroomId($arguments['objectId']);
                if ($courses) {
                    $courseIds = ArrayToolkit::column($courses, 'id');
                    $conditions['classroomCourseIds'] = $courseIds;
                    $conditions['classroomId'] = $arguments['objectId'];
                } else {
                    $conditions['onlyClassroomId'] = $arguments['objectId'];
                }
            }
        }

        $statuses = $this->getStatusService()->searchStatuses($conditions, array('createdTime' => 'DESC'), 0, $arguments['count']);

        if (empty($statuses)) {
            return array();
        }

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

        $manager = ExtensionManager::instance();

        foreach ($statuses as &$status) {