调整场次脚本，将未排片影院批量插入到：未排片影院表

app/command/CinemaSchedCommand.php

@@ -32,18 +32,42 @@ class CinemaSchedCommand extends Command
             $cinema = app()->make(CinemaRepository::class);
             // 获取影院列表
             $result = $cinema->getLocalCinema($this->page, $this->limit, '', '', [], [], 0);
+            $cinema_sign_list = $cinemainfo = [];
+            foreach ($result['cinema_list'] as $subKey => $cinema) {
+                $cinema_sign_list[] = $cinema['cinema_sign'];
+                $cinemainfo[$cinema['cinema_sign']] = $cinema;
+            }
 
             /** @var FilmRepository $filmRepository */
             $filmRepository = app()->make(FilmRepository::class);
             // 获取{2个月内}已上映影片列表
             $filmResult = $filmRepository->getFilmByStartEndDate($this->page, $this->limit, strtotime('-2 month', $date), $date);
+            if ($filmResult && $cinema_sign_list) {
+                foreach ($filmResult as $key => $film) {
+                    // 获取排片影院
+//                    $scheduledCinema = Db::name('movie_cinema_sched')
+//                        ->where('film_sign', $film['film_sign'])->where('show_date', '>=', $date)
+//                        ->whereIn('cinema_sign', $cinema_sign_list)
+//                        ->field('film_sign,cinema_sign')->group('cinema_sign')->select();
+//                    $diffUnscheduledCinema = !empty($scheduledCinema) ?
+//                        array_diff($cinema_sign_list, array_column($scheduledCinema->toArray(), 'cinema_sign', 'cinema_sign')) : $cinema_sign_list;
+//                    $this->batchInsertUnscheduledCinema($film, $cinemainfo, $diffUnscheduledCinema);
 
-            foreach ($filmResult as $key => $film) {
-                foreach ($result['cinema_list'] as $subKey => $cinema) {
-                    // 是否未排片 @todo 影院未排片，不请求第三方接口获取排片场次
-                    if (!($this->isUnscheduledFilm($film['film_sign'], $cinema['cinema_sign']))) {
-                        $this->doCinemaSched($film, $cinema);
+                    $diffUnscheduledCinema = [];
+                    // 获取是否存在未排片影院记录 @todo 影院未排片，不请求第三方接口获取排片场次
+                    $unscheduledCinema = Db::name('movie_cinema_unsched')->where('film_sign', $film['film_sign'])->whereIn('cinema_sign', $cinema_sign_list)
+                        ->field('film_sign,cinema_sign')->select();
+                    // 从总的影院、未排片影院中取出差异数据，得到排片影院
+                    $diffScheduledCinema = !empty($unscheduledCinema) ? array_diff($cinema_sign_list, array_column($unscheduledCinema->toArray(), 'cinema_sign')) : $cinema_sign_list;
+                    // 将{影片和排片影院}调用第三方获取排片场次
+                    foreach ($diffScheduledCinema as $cinemaKey => $cinemaSignValue) {
+                        $res = $this->doCinemaSched($film, $cinemainfo[$cinemaSignValue]);
+                        if (!$res) {
+                            $diffUnscheduledCinema[] = $cinemaSignValue;
+                        }
                     }
+                    // 未排片影院批量插入
+                    if ($diffUnscheduledCinema) $this->batchInsertUnscheduledCinema($film, $cinemainfo, $diffUnscheduledCinema);
                 }
             }
         } catch (\Exception $exception) {
@@ -52,24 +76,36 @@ class CinemaSchedCommand extends Command
     }
 
     /**
-     * 是否未排片
+     * 批量插入未排片影院
      *
-     * @param $film_sign
-     * @param $cinema_sign
-     * @return bool
+     * @param $film
+     * @param $cinemainfo
+     * @param $diffUnscheduledCinema
+     * @return void
      */
-    private function isUnscheduledFilm($film_sign = '', $cinema_sign = '')
+    private function batchInsertUnscheduledCinema($film, $cinemainfo, $diffUnscheduledCinema)
     {
-        $count = Db::name('movie_cinema_unsched')->where(['film_sign' => $film_sign, 'cinema_sign' => $cinema_sign])->count();
-        return $count > 0;
+        $data = [];
+
+        foreach ($diffUnscheduledCinema as $key => $value) {
+            $data[] = [
+                'film_sign' => $film['film_sign'],
+                'film_name' => $film['film_name'],
+                'cinema_sign' => $cinemainfo[$value]['cinema_sign'],
+                'cinema_name' => $cinemainfo[$value]['cinema_name'],
+                'create_time' => time()
+            ];
+        }
+        if ($data) Db::name('movie_cinema_unsched')->insertAll($data);
     }
 
     /**
-     * 电影-获取影院场次列表
-     * @return void
-     * @throws \think\db\exception\DataNotFoundException
+     *  电影-获取影院场次列表
+     *
+     * @param $film
+     * @param $cinema
+     * @return array|mixed|string
      * @throws \think\db\exception\DbException
-     * @throws \think\db\exception\ModelNotFoundException
      */
     private function doCinemaSched($film, $cinema)
     {
@@ -80,10 +116,9 @@ class CinemaSchedCommand extends Command
         if (!empty($cinema_sched)) {
             // 写入排片场次数据
             $this->createCinemaSched($cinema_sched, $cinema);
-        } else {
-            // 写入未排片影院
-            $this->createUnschedCinema($film, $cinema);
         }
+
+        return $cinema_sched;
     }
 
     /**
@@ -131,23 +166,4 @@ 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);
-    }
 }

app/common/repositories/movie/MovieRepository.php

@@ -190,7 +190,7 @@ class MovieRepository extends BaseRepository
         if (json_last_error()) throw new ValidateException('锁座下单失败');
 
         $order_price = bcmul((string)$channel_sn['price'], (string)count($sched_seat), 2);
-        $submitOrder = DouHuoMallFilmApiRequest::submitOrder($userinfo->phone, $channel_sn['channel_type'], $params['sched_sign'], array_column($sched_seat, 'seat_sign'), $order_sn, $order_price);
+        $submitOrder = DouHuoMallFilmApiRequest::submitOrder($params['phone'] ?? $userinfo->phone, $channel_sn['channel_type'], $params['sched_sign'], array_column($sched_seat, 'seat_sign'), $order_sn, $order_price);
         if (!empty($submitOrder) && isset($submitOrder['code']) && ($submitOrder['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE) && isset($submitOrder['data']['plat_order'])) {
             /** @var CinemaRepository $cinemaRepository */
             $cinemaRepository = app()->make(CinemaRepository::class);