调整取值和调用方式

app/command/CinemaSchedCommand.php

@@ -57,9 +57,7 @@ class CinemaSchedCommand extends Command
         $cinema_filmRepository = app()->make(MovieRepository::class);
         $cinema_sched = $cinema_filmRepository->getCinemaSched($film['film_sign'], $cinema['cinema_sign']);
 
-        if (isset($cinema_sched['code']) && ($cinema_sched['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE)) {
-            $this->createCinemaSched($cinema_sched['data']['list'], $cinema);
-        }
+        $this->createCinemaSched($cinema_sched, $cinema);
     }
 
     /**
@@ -72,35 +70,37 @@ class CinemaSchedCommand extends Command
      */
     private function createCinemaSched($list, $cinema)
     {
-        foreach ($list as $key => $value) {
-            $params = [
-                'relation_id' => $value['relation_id'],
-                'sched_sign' => $value['sched_sign'],
-                'film_sign' => $value['film_sign'],
-                'film_name' => $value['film_name'],
-                'show_date' => strtotime(date('Y') . '-' . $value['show_date']),
-                'show_time' => trim($value['show_time']),
-                'cinema_sign' => $cinema['cinema_sign'],
-                'cinema_name' => $cinema['cinema_name'],
-                'address' => $cinema['address'],
-                'longitude' => $cinema['longitude'],
-                'latitude' => $cinema['latitude'],
-                'hall_sign' => $value['hall_sign'],
-                'hall_name' => $value['hall_name'],
-                'stop_sell_time' => $value['stop_sell_time'],
-                'cost_price' => $value['cost_price'],
-                'channel_price' => json_encode($value['channel_price'], JSON_FORCE_OBJECT)
-            ];
-            $where = [
-                'relation_id' => $value['relation_id'], 'sched_sign' => $value['sched_sign'], 'film_sign' => $value['film_sign'], 'cinema_sign' => $params['cinema_sign']
-            ];
-            $model = Db::name('movie_cinema_sched')->where($where)->find();
-            if (empty($model)) {
-                $params['create_time'] = time();
-                Db::name('movie_cinema_sched')->insert($params);
-            } else {
-                $params['update_time'] = time();
-                Db::name('movie_cinema_sched')->where('id', $model['id'])->update($params);
+        foreach ($list as $key => $sched) {
+            foreach ($sched as $subKey => $value) {
+                $params = [
+                    'relation_id' => $value['relation_id'],
+                    'sched_sign' => $value['sched_sign'],
+                    'film_sign' => $value['film_sign'],
+                    'film_name' => $value['film_name'],
+                    'show_date' => strtotime(date('Y') . '-' . $value['show_date']),
+                    'show_time' => trim($value['show_time']),
+                    'cinema_sign' => $cinema['cinema_sign'],
+                    'cinema_name' => $cinema['cinema_name'],
+                    'address' => $cinema['address'],
+                    'longitude' => $cinema['longitude'],
+                    'latitude' => $cinema['latitude'],
+                    'hall_sign' => $value['hall_sign'],
+                    'hall_name' => $value['hall_name'],
+                    'stop_sell_time' => strtotime($value['stop_sell_time']),
+                    'cost_price' => $value['cost_price'],
+                    'channel_price' => json_encode($value['channel_price'], JSON_FORCE_OBJECT)
+                ];
+                $where = [
+                    'relation_id' => $value['relation_id'], 'sched_sign' => $value['sched_sign'], 'film_sign' => $value['film_sign'], 'cinema_sign' => $params['cinema_sign']
+                ];
+                $model = Db::name('movie_cinema_sched')->where($where)->find();
+                if (empty($model)) {
+                    $params['create_time'] = time();
+                    Db::name('movie_cinema_sched')->insert($params);
+                } else {
+                    $params['update_time'] = time();
+                    Db::name('movie_cinema_sched')->where('id', $model['id'])->update($params);
+                }
             }
         }
     }

app/common/repositories/movie/CinemaRepository.php

@@ -16,7 +16,7 @@ use think\facade\Db;
  * Class CinemaRepository
  * @package app\common\repositories\movie
  * @author xaboy
- * @mixin MovieOrderDao
+ * @mixin Cinema
  */
 class CinemaRepository extends BaseRepository
 {

app/common/repositories/movie/MovieRepository.php

@@ -107,7 +107,7 @@ class MovieRepository extends BaseRepository
                 $fileSchedValue[$key]['score'] = $pcYanglaojinGongxian['score'];
                 $fileSchedValue[$key]['gongxian'] = $pcYanglaojinGongxian['gongxian'];
 
-                unset($fileSchedValue[$key]['channel_price']);
+//                unset($fileSchedValue[$key]['channel_price']);
             }
         }