451 lines
21 KiB
PHP
Executable File
451 lines
21 KiB
PHP
Executable File
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace app\command;
|
||
|
||
use Exception;
|
||
use think\console\Command;
|
||
use think\console\Input;
|
||
use think\console\input\Argument;
|
||
use think\console\input\Option;
|
||
use think\console\Output;
|
||
|
||
use think\facade\Cache;
|
||
|
||
use Curl\Curl;
|
||
use think\helper\Str;
|
||
use app\kernel\Lebolebo\Account;
|
||
use app\kernel\Lebolebo\Curriculum;
|
||
|
||
use Aria2;
|
||
|
||
class Lebo extends Command
|
||
{
|
||
private $aria2 = null;
|
||
private $completed = false;
|
||
|
||
protected function configure()
|
||
{
|
||
// 指令配置
|
||
$this->setName('course')
|
||
->setDescription('the course command');
|
||
}
|
||
protected function execute(Input $input, Output $output)
|
||
{
|
||
$this->aria2 = new Aria2('http://192.168.100.106:16800/jsonrpc', '11223344');
|
||
$this->completed = false;
|
||
while ($this->completed === false) {
|
||
try {
|
||
$this->start();
|
||
} catch (\Exception $e) {
|
||
dump($e);
|
||
sleep(3);
|
||
}
|
||
}
|
||
dump('下载完成！');
|
||
// 指令输出
|
||
// $output->writeln('course');
|
||
}
|
||
private function start()
|
||
{
|
||
$savepath = store_path() . '/lebolebo/';
|
||
// $savepath = 'D:/lebolebo/';
|
||
$account_cache_key = 'lebo_account';
|
||
$account_info = Cache::get($account_cache_key);
|
||
if ($account_info) {
|
||
} else {
|
||
$account = new Account();
|
||
$account_info = $account->login('13880615958', 'robo520');
|
||
if ($account_info['code'] == 500) {
|
||
dump($account_info['msg']);
|
||
exit;
|
||
}
|
||
Cache::set($account_cache_key, $account_info, 3600);
|
||
dump('账号信息缓存成功');
|
||
}
|
||
// $curl = new Curl();
|
||
$curr = new Curriculum();
|
||
$curr->setHeader('token', $account_info['data']['token']);
|
||
$course = $curr->list(1);
|
||
|
||
foreach ($course['data']['list'] as $index => $list) {
|
||
$c = $savepath . $list['courseName'];
|
||
// dump($index,$list['courseName']);
|
||
if ($list['courseName'] != '线上-CSP-J 集训课程') {
|
||
continue;
|
||
}
|
||
is_dir($c) || mkdir($c, 0755, true);
|
||
$detail = $curr->detail($list['id']);
|
||
$courseCover = $c . '/courseCover.png';
|
||
if ($detail['data']['courseCover']) {
|
||
$downloadurl = $detail['data']['courseCover'];
|
||
$check = $this->checkfile($downloadurl, $courseCover);
|
||
if (!$check && !is_file($courseCover)) {
|
||
// $result = $curl->_fastDownload($downloadurl,$courseCover);
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $c,
|
||
'out' => 'courseCover.png'
|
||
]
|
||
);
|
||
// dump('封面下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$courseCover);
|
||
// }
|
||
}
|
||
$txt = $courseCover . '-下载地址.txt';
|
||
$this->savetxt($txt, $downloadurl);
|
||
}
|
||
$d = $curr->courseUnitList($list['courseCode']);
|
||
$courseUnits = $d['data']['courseUnit'];
|
||
if ($courseUnits === null) {
|
||
continue;
|
||
}
|
||
foreach ($courseUnits as $courseUnit) {
|
||
$courseUnitName = $c . '/' . str_ireplace('/', '-', $courseUnit['courseUnitName']);
|
||
if (!is_dir($courseUnitName)) {
|
||
dump('创建课程文件夹：' . $courseUnitName);
|
||
mkdir($courseUnitName, 0755, true);
|
||
}
|
||
$selectByCourseUnits = $curr->selectByCourseUnits($courseUnit['courseCode'], $courseUnit['courseUnitCode']);
|
||
foreach ($selectByCourseUnits['data'] as $selectByCourseUnit) {
|
||
$this->waiting();
|
||
$sessionName = $courseUnitName . '/' . $selectByCourseUnit['sessionName'];
|
||
if (!is_dir($sessionName)) {
|
||
dump('创建课件文件夹：' . $sessionName);
|
||
mkdir($sessionName, 0755, true);
|
||
}
|
||
$t = $curr->selectByCourseSessionCode($selectByCourseUnit['courseSessionCode']);
|
||
// 0: {type: 1, des: "PPT-HTML"}
|
||
// 1: {type: 2, des: "讲义"}
|
||
// 2: {type: 3, des: "课前预习"}
|
||
// 3: {type: 4, des: "测一测"}
|
||
// 4: {type: 5, des: "玩一玩"}
|
||
// 5: {type: 6, des: "试一试"}
|
||
// 6: {type: 9, des: "知识点"}
|
||
// 7: {type: 10, des: "名人名言"}
|
||
// 8: {type: 11, des: "录播课"}
|
||
// 9: {type: 13, des: "教辅"}
|
||
// 10: {type: 14, des: "备课"}
|
||
// 11: {type: 15, des: "课程内容"}
|
||
// 12: {type: 16, des: "课后拓展"}
|
||
// 13: {type: 18, des: "素养目标"}
|
||
$ts = $t['data'];
|
||
foreach ($ts as $kk) {
|
||
switch ($kk['resourceType']) {
|
||
case '1': // PPT-HTML
|
||
if (!isset($kk['content'])) {
|
||
break;
|
||
}
|
||
$filename = $kk['content']['fileName'];
|
||
$downloadurl = $kk['content']['fileUrl'];
|
||
$file = $sessionName . '/' . $filename;
|
||
// 保存下载地址
|
||
$txt = "{$file}-下载地址.txt";
|
||
$this->savetxt($txt, $downloadurl);
|
||
$check = $this->checkfile($downloadurl, $file);
|
||
if (!$check && !is_file($file)) {
|
||
dump('下载PPT：' . $file);
|
||
// $result = $curl->_fastDownload($downloadurl,$file);
|
||
// dump('PPT下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$file);
|
||
// }
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $sessionName,
|
||
'out' => $filename
|
||
]
|
||
);
|
||
} else if ($check && !is_file($file)) {
|
||
if (is_file($check)) {
|
||
try {
|
||
copy($check, $file);
|
||
} catch (Exception $e) {
|
||
dump('文件拷贝失败：', $e);
|
||
exit;
|
||
}
|
||
} else {
|
||
dump('下载PPT：' . $file);
|
||
// $result = $curl->_fastDownload($downloadurl,$file);
|
||
// dump('PPT下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$file);
|
||
// }
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $sessionName,
|
||
'out' => $filename
|
||
]
|
||
);
|
||
}
|
||
|
||
dump('跳过PPT：' . $file);
|
||
} else {
|
||
dump('PPT文件已存在：' . $file);
|
||
$this->complete($downloadurl, $file);
|
||
}
|
||
break;
|
||
case '2':
|
||
break;
|
||
case '3':
|
||
break;
|
||
case '4':
|
||
break;
|
||
case '5':
|
||
break;
|
||
case '6':
|
||
// 试一试
|
||
$shiyishi = $sessionName . '/试一试/';
|
||
if (!is_dir($shiyishi)) {
|
||
mkdir($shiyishi, 0755, true);
|
||
}
|
||
$questions = $kk['content']['questions'];
|
||
if (!is_array($questions)) break;
|
||
foreach ($questions as $key => $question) {
|
||
$filename = $question['fileName'];
|
||
$downloadurl = $question['fileUrl'];
|
||
$file = $shiyishi . $filename;
|
||
// 保存文件下载地址
|
||
$txt = "{$file}-下载地址.txt";
|
||
$this->savetxt($txt, $downloadurl);
|
||
$check = $this->checkfile($downloadurl, $file);
|
||
if (!$check && !is_file($file)) {
|
||
// $result = $curl->_fastDownload($downloadurl,$file);
|
||
// dump('试一试下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$file);
|
||
// }
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $shiyishi,
|
||
'out' => $filename
|
||
]
|
||
);
|
||
} else if ($check && !is_file($file)) {
|
||
copy($check, $file);
|
||
dump('跳过试一试：' . $file);
|
||
} else {
|
||
dump('试一试文件已存在：' . $file);
|
||
$this->complete($downloadurl, $file);
|
||
}
|
||
}
|
||
break;
|
||
case '9':
|
||
break;
|
||
case '10':
|
||
break;
|
||
case '11':
|
||
break;
|
||
case '13':
|
||
// 教辅
|
||
if (!isset($kk['content']['resourceList'])) {
|
||
break;
|
||
}
|
||
$jiaofupath = $sessionName . '/教辅/';
|
||
if (!is_dir($jiaofupath)) {
|
||
mkdir($jiaofupath, 0755, true);
|
||
}
|
||
$resourceLists = $kk['content']['resourceList'];
|
||
foreach ($resourceLists as $resourceList) {
|
||
if (empty($resourceList['fileName'])) {
|
||
continue;
|
||
}
|
||
$file = $jiaofupath . $resourceList['fileName'];
|
||
if (Str::endsWith($file, ['.mp4', '.mov'])) {
|
||
$dd = $curr->getVideoUrl($resourceList['fileUrl']);
|
||
$downloadurl = $dd['data'];
|
||
} else {
|
||
$downloadurl = $resourceList['fileUrl'];
|
||
}
|
||
// 保存下载地址
|
||
$txt = "{$file}-下载地址.txt";
|
||
$this->savetxt($txt, $downloadurl);
|
||
$check = $this->checkfile($downloadurl, $file);
|
||
if (!$check && !is_file($file)) {
|
||
dump('下载教辅：' . $file);
|
||
// $result = $curl->_fastDownload($downloadurl,$file);
|
||
// dump('教辅下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$file);
|
||
// }
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $jiaofupath,
|
||
'out' => $resourceList['fileName']
|
||
]
|
||
);
|
||
} else if ($check && !is_file($file)) {
|
||
copy($check, $file);
|
||
dump('跳过教辅：' . $file);
|
||
} else {
|
||
dump('教辅文件已存在：' . $file);
|
||
$this->complete($downloadurl, $file);
|
||
}
|
||
}
|
||
break;
|
||
case '14':
|
||
// 备课
|
||
if (!isset($kk['content']['resourceList'])) {
|
||
break;
|
||
}
|
||
$beikepath = $sessionName . '/备课/';
|
||
if (!is_dir($beikepath)) {
|
||
mkdir($beikepath, 0755, true);
|
||
}
|
||
$resourceLists = $kk['content']['resourceList'];
|
||
foreach ($resourceLists as $resourceList) {
|
||
$file = $beikepath . $resourceList['fileName'];
|
||
if (Str::endsWith($file, ['.mp4', '.mov', '.MP4', '.mkv', '.wmv'])) {
|
||
$dd = $curr->getVideoUrl($resourceList['fileUrl']);
|
||
$downloadurl = $dd['data'];
|
||
} else {
|
||
$downloadurl = $resourceList['fileUrl'];
|
||
}
|
||
// 保存下载地址
|
||
$txt = "{$file}-下载地址.txt";
|
||
$this->savetxt($txt, $downloadurl);
|
||
$check = $this->checkfile($downloadurl, $file);
|
||
if (!$check && !is_file($file)) {
|
||
dump('下载备课：' . $file);
|
||
// $result = $curl->_fastDownload($downloadurl,$file);
|
||
// dump('备课下载结果：',$result);
|
||
// if($result){
|
||
// $this->complete($downloadurl,$file);
|
||
// }
|
||
$this->aria2->addUri(
|
||
[$downloadurl],
|
||
[
|
||
'dir' => $beikepath,
|
||
'out' => $resourceList['fileName']
|
||
]
|
||
);
|
||
} else if ($check && !is_file($file)) {
|
||
copy($check, $file);
|
||
dump('跳过备课：' . $file);
|
||
} else {
|
||
dump('备课文件已存在：' . $file);
|
||
$this->complete($downloadurl, $file);
|
||
}
|
||
}
|
||
break;
|
||
case '15':
|
||
// 课程内容
|
||
if (is_null($kk['content']['courseContent'])) break;
|
||
$file = "{$sessionName}/课程内容.txt";
|
||
$this->savetxt($file, strip_tags($kk['content']['courseContent']));
|
||
break;
|
||
case '16':
|
||
break;
|
||
case '18':
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
// break;
|
||
}
|
||
}
|
||
}
|
||
// break;
|
||
}
|
||
$this->completed = true;
|
||
}
|
||
private function checkfile($url, $file)
|
||
{
|
||
$key = 'lebolebo_check_header_' . md5($url);
|
||
try {
|
||
if (($head = Cache::get($key, null)) === NULL) {
|
||
$head = @get_headers($url, true);
|
||
if ($head === false) {
|
||
dump('获取文件信息失败，直接重新下载' . $file);
|
||
return false;
|
||
}
|
||
Cache::set($key, $head, 86400);
|
||
}
|
||
$kk = 'lebolebo_file_' . pathinfo($file, PATHINFO_BASENAME);
|
||
if (isset($head['Content-Length']) && ($size = intval($head['Content-Length']))) {
|
||
$kk .= $size;
|
||
if (is_file($file) && ($size !== filesize($file))) {
|
||
dump('文件大小不符，重新下载' . $file);
|
||
unlink($file);
|
||
return false;
|
||
}
|
||
}
|
||
if (isset($head['ETag'])) {
|
||
$t = $kk . md5($head['ETag']);
|
||
if (Cache::has($t)) {
|
||
return Cache::get($t);
|
||
}
|
||
}
|
||
if (isset($head['Content-MD5'])) {
|
||
$t = $kk . md5($head['Content-MD5']);
|
||
if (Cache::has($t)) {
|
||
return Cache::get($t);
|
||
}
|
||
}
|
||
} catch (Exception $e) {
|
||
dump('检查文件失败：', $url, $file, $e);
|
||
exit;
|
||
}
|
||
return false;
|
||
}
|
||
private function complete($url, $file)
|
||
{
|
||
$key = 'lebolebo_check_header_' . md5($url);
|
||
try {
|
||
if (($head = Cache::get($key, null)) === NULL) {
|
||
$head = @get_headers($url, 1);
|
||
if ($head === false) {
|
||
return false;
|
||
}
|
||
Cache::set($key, $head, 86400);
|
||
}
|
||
$kk = 'lebolebo_file_' . pathinfo($file, PATHINFO_BASENAME);
|
||
if (isset($head['Content-Length'])) {
|
||
$kk .= intval($head['Content-Length']);
|
||
}
|
||
if (isset($head['ETag'])) {
|
||
$t = $kk . md5($head['ETag']);
|
||
Cache::set($t, $file, 86400);
|
||
}
|
||
if (isset($head['Content-MD5'])) {
|
||
$t = $kk . md5($head['Content-MD5']);
|
||
Cache::set($t, $file, 86400);
|
||
}
|
||
} catch (Exception $e) {
|
||
dump($e);
|
||
exit;
|
||
}
|
||
}
|
||
private function savetxt(string $file, string $content)
|
||
{
|
||
if (is_file($file)) {
|
||
unlink($file);
|
||
}
|
||
$myfile = fopen($file, "w");
|
||
fwrite($myfile, $content);
|
||
fclose($myfile);
|
||
// dump('已保存文本内容：'.$file);
|
||
}
|
||
private function waiting()
|
||
{
|
||
$num = 1;
|
||
while ($num > 0) {
|
||
$activeDownloads = $this->aria2->getGlobalStat();
|
||
$num = intval($activeDownloads['result']['numWaiting']);
|
||
if ($num > 10) {
|
||
dump('当前任务过多，等待任务数：', $num);
|
||
sleep(1);
|
||
} else {
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|