src/Biz/Course/Job/CourseDataCleanJob.php

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

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

<?php

namespace Biz\Course\Job;

use Biz\Course\Dao\LearningDataAnalysisDao;
use Biz\Course\Service\MemberService;
use Codeages\Biz\Framework\Scheduler\AbstractJob;

class CourseDataCleanJob extends AbstractJob
{
    private $step = 1000;

    public function execute()
    {
        $this->cleanStudentLearningData();
    }

    private function cleanStudentLearningData()
    {
        $courseIds = $this->biz['db']->fetchAll('SELECT id FROM course_v8', array());
        $courseIds = array_column($courseIds, 'id');
        foreach ($courseIds as $courseId) {
            $this->refreshLearningProgress($courseId);
        }
    }

    private function refreshLearningProgress($courseId)
    {
        $memberUserIds = $this->getCourseMemberService()->findMemberUserIdsByCourseId($courseId);
        for ($i = 0; $i < count($memberUserIds) / $this->step; ++$i) {
            $userIds = array_slice($memberUserIds, $this->step * $i, $this->step);
            $this->getLearningDataAnalysisDao()->batchRefreshUserLearningData($courseId, $userIds);
        }
    }

    /**
     * @return MemberService
     */
    private function getCourseMemberService()
    {
        return $this->biz->service('Course:MemberService');
    }

    /**
     * @return LearningDataAnalysisDao
     */
    private function getLearningDataAnalysisDao()
    {
        return $this->biz->dao('Course:LearningDataAnalysisDao');
    }
}