调整场次数据逻辑，未排片写入记录且不请求接口

app/command/CinemaSchedCommand.php

@@ -26,6 +26,7 @@ class CinemaSchedCommand extends Command
 
     protected function execute(Input $input, Output $output)
     {
+        $date = strtotime(date('Y-m-d'));
         try {
             /** @var CinemaRepository $cinema */
             $cinema = app()->make(CinemaRepository::class);
@@ -34,12 +35,15 @@ class CinemaSchedCommand extends Command
 
             /** @var FilmRepository $filmRepository */
             $filmRepository = app()->make(FilmRepository::class);
-            // 获取已上映影片列表
-            $filmResult = $filmRepository->getFilm($this->page, $this->limit);
+            // 获取{2个月内}已上映影片列表
+            $filmResult = $filmRepository->getFilmByStartEndDate($this->page, $this->limit, strtotime('-2 month', $date), $date);
 
-            foreach ($filmResult['film_list'] as $key => $film) {
+            foreach ($filmResult as $key => $film) {
                 foreach ($result['cinema_list'] as $subKey => $cinema) {
-                    $this->doCinemaSched($film, $cinema);
+                    // 是否未排片 @todo 影院未排片，不请求第三方接口获取排片场次
+                    if (!($this->isUnscheduledFilm($film['film_sign'], $cinema['cinema_sign']))) {
+                        $this->doCinemaSched($film, $cinema);
+                    }
                 }
             }
         } catch (\Exception $exception) {
@@ -48,6 +52,19 @@ class CinemaSchedCommand extends Command
     }
 
     /**
+     * 是否未排片
+     *
+     * @param $film_sign
+     * @param $cinema_sign
+     * @return bool
+     */
+    private function isUnscheduledFilm($film_sign = '', $cinema_sign = '')
+    {
+        $count = Db::name('movie_cinema_unsched')->where(['film_sign' => $film_sign, 'cinema_sign' => $cinema_sign])->count();
+        return $count > 0;
+    }
+
+    /**
      * 电影-获取影院场次列表
      * @return void
      * @throws \think\db\exception\DataNotFoundException
@@ -60,9 +77,13 @@ class CinemaSchedCommand extends Command
         $cinema_filmRepository = app()->make(MovieRepository::class);
         // 获取排片场次
         $cinema_sched = $cinema_filmRepository->getCinemaSched($film['film_sign'], $cinema['cinema_sign']);
-
-        // 写入排片场次数据
-        $this->createCinemaSched($cinema_sched, $cinema);
+        if (!empty($cinema_sched)) {
+            // 写入排片场次数据
+            $this->createCinemaSched($cinema_sched, $cinema);
+        } else {
+            // 写入未排片影院
+            $this->createUnschedCinema($film, $cinema);
+        }
     }
 
     /**
@@ -110,4 +131,23 @@ class CinemaSchedCommand extends Command
             }
         }
     }
+
+    /**
+     * 记录未排片影院
+     *
+     * @param $film
+     * @param $cinema
+     * @return void
+     */
+    private function createUnschedCinema($film, $cinema)
+    {
+        $params = [
+            'film_sign' => $film['film_sign'],
+            'film_name' => $film['film_name'],
+            'cinema_sign' => $cinema['cinema_sign'],
+            'cinema_name' => $cinema['cinema_name'],
+            'create_time' => time()
+        ];
+        Db::name('movie_cinema_unsched')->insert($params);
+    }
 }