|
...
|
...
|
@@ -65,7 +65,7 @@ class VideoTask extends Command |
|
|
|
}
|
|
|
|
echo '开始:'.PHP_EOL;
|
|
|
|
Log::info('开始视频推广任务');
|
|
|
|
$this->createSubTask();
|
|
|
|
$this->createSubTask($number);
|
|
|
|
$this->sendSubTask();
|
|
|
|
Log::info('结束视频推广任务');
|
|
|
|
return true;
|
|
...
|
...
|
@@ -80,12 +80,20 @@ class VideoTask extends Command |
|
|
|
*/
|
|
|
|
public function getVideoNumber()
|
|
|
|
{
|
|
|
|
$taskLogModel = new KeywordVideoTaskLog();
|
|
|
|
// 获取当月的开始时间
|
|
|
|
$startOfMonth = Carbon::now()->startOfMonth()->format('Y-m-d H:i:s');
|
|
|
|
// 获取当月的结束时间
|
|
|
|
$endOfMonth = Carbon::now()->endOfMonth()->format('Y-m-d H:i:s');
|
|
|
|
$number = $taskLogModel->formatQuery(['created_at' => ['between', [$startOfMonth, $endOfMonth]]])->count();
|
|
|
|
$current_time = date('Y-m-d 00:00:00');
|
|
|
|
$number = Cache::get('video_keyword_number');
|
|
|
|
if(empty($number) || ($current_time == date('Y-m-13 00:00:00'))){
|
|
|
|
if($current_time <= date('Y-m-13 00:00:00')){
|
|
|
|
$startOfMonth = Carbon::now()->subMonth()->day(13)->format('Y-m-d 00:00:00');
|
|
|
|
$endOfMonth = Carbon::now()->day(13)->format('Y-m-d 00:00:00');
|
|
|
|
}else{
|
|
|
|
$startOfMonth = Carbon::now()->day(13)->format('Y-m-d 00:00:00');
|
|
|
|
$endOfMonth = Carbon::now()->addMonth()->day(13)->format('Y-m-d 00:00:00');
|
|
|
|
}
|
|
|
|
$taskLogModel = new KeywordVideoTaskLog();
|
|
|
|
$number = $taskLogModel->formatQuery(['created_at' => ['between', [$startOfMonth, $endOfMonth]]])->count();
|
|
|
|
Cache::put('video_keyword_number',$number);
|
|
|
|
}
|
|
|
|
return $number;
|
|
|
|
}
|
|
|
|
/**
|
|
...
|
...
|
@@ -93,7 +101,7 @@ class VideoTask extends Command |
|
|
|
* TODO 获取需要生成子任务的项目,获取项目中未生成视频的关键词,通过关键词生成初始化子任务
|
|
|
|
* @return bool
|
|
|
|
*/
|
|
|
|
public function createSubTask()
|
|
|
|
public function createSubTask($number)
|
|
|
|
{
|
|
|
|
$sub_task_num = $this->max_sub_task;
|
|
|
|
while (true) {
|
|
...
|
...
|
@@ -146,6 +154,7 @@ class VideoTask extends Command |
|
|
|
if($rs && ($sub_task_num > 0)){
|
|
|
|
$sub_task_num--;
|
|
|
|
}
|
|
|
|
Cache::put('video_keyword_number',$number++);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
$task_project->status = KeywordVideoTask::STATUS_CLOSE;
|
...
|
...
|
|