影院场次列表脚本

app/command/CinemaSchedCommand.php

@@ -0,0 +1,106 @@
+<?php
+
+namespace app\command;
+
+use app\common\repositories\movie\CinemaRepository;
+use app\common\repositories\movie\FilmRepository;
+use app\common\repositories\movie\MovieRepository;
+use crmeb\services\ApiResponseService;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\facade\Db;
+
+class CinemaSchedCommand extends Command
+{
+    private $page = 1;
+    private $limit = 1000000;
+
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('cinema_sched')->setDescription('电影-影院场次列表');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        try {
+            /** @var CinemaRepository $cinema */
+            $cinema = app()->make(CinemaRepository::class);
+            $result = $cinema->getLocalCinema($this->page, $this->limit, '', '', [], [], 0);
+
+            /** @var FilmRepository $filmRepository */
+            $filmRepository = app()->make(FilmRepository::class);
+            $filmResult = $filmRepository->getFilm($this->page, $this->limit);
+
+            foreach ($result['cinema_list'] as $key => $value) {
+                foreach ($filmResult['film_list'] as $subKey => $subValue) {
+                    $this->doCinemaSched($subValue, $value);
+                }
+            }
+        } catch (\Exception $exception) {
+            var_dump($exception->getMessage(), $exception->getFile(), $exception->getLine());
+        }
+    }
+
+    /**
+     * 电影-获取影院场次列表
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function doCinemaSched($film, $cinema)
+    {
+        /** @var MovieRepository $cinema_filmRepository */
+        $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);
+        }
+    }
+
+    /**
+     * 设置影院场次
+     *
+     * @param $list
+     * @param $cinema
+     * @return void
+     * @throws \think\db\exception\DbException
+     */
+    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' => $value['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

@@ -62,7 +62,7 @@ class CinemaRepository extends BaseRepository
             }
         })->field([$field])->select()->toArray();
         foreach ($cinema_list as $key => $value) {
-            $cinema_list[$key]['distance'] = round($value['distance'] / 1000, 2);
+            $cinema_list[$key]['distance'] = isset($value['distance']) ? round($value['distance'] / 1000, 2) : 0.00;
         }
 
         $count = $this->dao->search(null, $where)->when($with, function ($query) use ($with) {

app/common/repositories/movie/FilmRepository.php

@@ -71,16 +71,4 @@ class FilmRepository extends BaseRepository
 
         return compact('film_list', 'count');
     }
-
-    /**
-     * 经纬度排序计算
-     * @param string $latitude
-     * @param string $longitude
-     * @return string
-     */
-    private function distance(string $latitude, string $longitude)
-    {
-        return "(round(6378137 * 2 * asin(sqrt(pow(sin(((latitude * pi()) / 180 - ({$latitude} * pi()) / 180) / 2), 2) 
-        + cos(({$latitude} * pi()) / 180) * cos((latitude * pi()) / 180) * pow(sin(((longitude * pi()) / 180 - ({$longitude} * pi()) / 180) / 2), 2))))) AS distance";
-    }
 }

config/console.php

@@ -24,6 +24,7 @@ return [
 //        'commercial-\_area_order_independent_account' => 'app\command\CommercialAreaOrderIndependentAccount',
         'movie_city_area' => 'app\command\MovieCityAreaCommand',
         'movie_cinema' => 'app\command\MovieCinemaCommand',
-        'movie_film' => 'app\command\MovieFilmCommand'
+        'movie_film' => 'app\command\MovieFilmCommand',
+        'cinema_film_sched' => 'app\command\CinemaSchedCommand'
     ],
 ];