postRepositories = $postRepositories; } /** * Execute the console command. * * @return mixed */ public function handle() { $this->line(date('Y-m-d H:i:s').'开始创建帖子'); $key = "community_post_create"; $posts = Redis::smembers($key); Log::debug('帖子数据:' . json_encode($posts)); foreach ($posts as $post) { $row = $this->postRepositories->createPost(json_decode($post,true)); Log::debug(date("Y-m-d H:i:s") . "创建帖子:" . json_encode($row)); Redis::srem($key,$post); } $this->line(date('Y-m-d H:i:s').' 创建帖子结束'); } }