获取影片场次日期列表、获取影片场次列表、影院影片场次列表

app/command/CinemaSchedCommand.php

@@ -3,6 +3,7 @@
 namespace app\command;
 
 use app\common\repositories\movie\CinemaRepository;
+use app\common\repositories\movie\CinemaSchedRepository;
 use app\common\repositories\movie\FilmRepository;
 use app\common\repositories\movie\MovieRepository;
 use crmeb\services\ApiResponseService;
@@ -19,7 +20,7 @@ class CinemaSchedCommand extends Command
     protected function configure()
     {
         // 指令配置
-        $this->setName('cinema_sched')->setDescription('电影-影院场次列表');
+        $this->setName('cinema_film_sched')->setDescription('电影-影院场次列表');
     }
 
     protected function execute(Input $input, Output $output)

app/common/model/movie/cinema/CinemaSched.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace app\common\model\movie\cinema;
+
+use app\model\BaseModel;
+
+class CinemaSched extends BaseModel
+{
+    protected $name = 'movie_cinema_sched';
+
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    /**
+     * @param $model
+     * @param array $where
+     * @return CinemaSched
+     */
+    public function search($model = null, array $where = [])
+    {
+        $model = $model ?? new self();
+
+        return $model->when(isset($where['film_sign']) && $where['film_sign'], function ($query) use ($where) {
+            $query->where('film_sign', $where['film_sign']);
+        })->when(isset($where['cinema_sign']) && $where['cinema_sign'], function ($query) use ($where) {
+            $query->where('cinema_sign', $where['cinema_sign']);
+        })->when(isset($where['show_date']) && $where['show_date'], function ($query) use ($where) {
+            $query->where('show_date', $where['show_date']);
+        })->when(isset($where['city']) && $where['city'], function ($query) use ($where) {
+            $query->where('city', 'like', "%{$where['city']}%");
+        });
+    }
+}

app/common/repositories/movie/CinemaSchedRepository.php

@@ -0,0 +1,144 @@
+<?php
+/**
+ * @package merchant
+ * @Author: Qinii
+ * @Date: 2020/5/8
+ */
+
+namespace app\common\repositories\movie;
+
+use app\common\model\movie\cinema\CinemaSched;
+use app\common\repositories\BaseRepository;
+use think\facade\Db;
+
+/**
+ * Class CinemaSchedRepository
+ * @package app\common\repositories\movie
+ * @author xaboy
+ * @mixin CinemaSched
+ */
+class CinemaSchedRepository extends BaseRepository
+{
+    protected $dao;
+
+    /**
+     * ProductRepository constructor.
+     * @param CinemaSched $dao
+     */
+    public function __construct(CinemaSched $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    /**
+     * @param $film_sign
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getFilmSchedDate($film_sign)
+    {
+        $field = 'show_date';
+        $where = ['film_sign' => $film_sign];
+
+        $show_date = $this->dao->search(null, $where)->field([$field])->order('show_date asc')->group('show_date')->select()->toArray();
+        foreach ($show_date as $key => $value) {
+            $show_date[$key]['date'] = date('m-d', $value['show_date']);
+        }
+
+        return compact('show_date');
+    }
+
+    /**
+     * @param $page
+     * @param $limit
+     * @param $longitude
+     * @param $latitude
+     * @param $show_date
+     * @param $with
+     * @param $order
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getFilmSched($page, $limit, $film_sign, $longitude, $latitude, $show_date, $with = [], $order = 1)
+    {
+        $field = 'cinema_sign,cinema_name,address,cost_price,longitude,latitude';
+        $where = ['film_sign' => $film_sign, 'show_date' => $show_date];
+
+        $cinema_sched = $this->dao->search(null, $where)->when($with, function ($query) use ($with) {
+            $query->with($with);
+        })->when($latitude && $longitude, function ($query) use ($field, $longitude, $latitude) {
+            $query->field([$field, $this->distance($latitude, $longitude)]);
+        })->when($page && $limit, function ($query) use ($page, $limit) {
+            $query->page($page, $limit);
+        })->when(!is_null($order), function ($query) use ($order) {
+            if ($order == 1) {//距离最近
+                $query->order('distance asc');
+            } else {//播放日期
+                $query->order('show_date desc');
+            }
+        })->field([$field])->select()->toArray();
+        foreach ($cinema_sched as $key => $value) {
+            $cinema_sched[$key]['distance'] = isset($value['distance']) ? round($value['distance'] / 1000, 2) : 0.00;
+        }
+
+        $count = $this->dao->search(null, $where)->when($with, function ($query) use ($with) {
+            $query->with($with);
+        })->when($latitude && $longitude, function ($query) use ($field, $longitude, $latitude) {
+            $query->field([$field, $this->distance($latitude, $longitude)]);
+        })->count();
+
+        return compact('cinema_sched', 'count');
+    }
+
+    /**
+     * @param $page
+     * @param $limit
+     * @param $cinema_sign
+     * @param $film_sign
+     * @param $show_date
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getCinemaFilmSched($page, $limit, $cinema_sign, $film_sign, $show_date)
+    {
+        $field = 'relation_id,sched_sign,film_sign,film_name,show_date,show_time,cinema_sign,cinema_name,hall_sign,hall_name,cost_price';
+        $where = ['cinema_sign' => $cinema_sign, 'film_sign' => $film_sign, 'show_date' => $show_date];
+
+        $cinema_sched = $this->dao->search(null, $where)
+            ->when($page && $limit, function ($query) use ($page, $limit) {
+                $query->page($page, $limit);
+            })->order('show_time asc')->field([$field])->select()->toArray();
+        foreach ($cinema_sched as $key => $value) {
+            $pcYanglaojinGongxian = MovieRepository::getPvYanglaojinScore($value['cost_price']);
+
+            $cinema_sched[$key]['cost_price'] = $pcYanglaojinGongxian['cost_price'];
+            $cinema_sched[$key]['yanglaojin'] = $pcYanglaojinGongxian['yanglaojin'];
+            $cinema_sched[$key]['pv'] = $pcYanglaojinGongxian['pv'];
+            $cinema_sched[$key]['score'] = $pcYanglaojinGongxian['score'];
+            $cinema_sched[$key]['gongxian'] = $pcYanglaojinGongxian['gongxian'];
+            $cinema_sched[$key]['distance'] = isset($value['distance']) ? round($value['distance'] / 1000, 2) : 0.00;
+        }
+
+        $count = $this->dao->search(null, $where)->count();
+
+        return compact('cinema_sched', '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";
+    }
+}

app/common/repositories/movie/MovieRepository.php

@@ -28,10 +28,10 @@ class MovieRepository extends BaseRepository
 
     protected $dao;
 
-    private $premium_ratio = 0.2;//溢价比例
-    private $yanglaojin_ratio = 0.3;
+    const premium_ratio = 0.2;//溢价比例
+    const yanglaojin_ratio = 0.3;
 
-    private $pv_ratio = 0.7;
+    const pv_ratio = 0.7;
 
     /**
      * ProductRepository constructor.
@@ -99,13 +99,13 @@ class MovieRepository extends BaseRepository
             ? $result['data']['list'] : [];
         foreach ($cinemaSchedList as $dateDay => &$fileSchedValue) {
             foreach ($fileSchedValue as $key => $value) {
-                $premium = round($value['cost_price'] * $this->premium_ratio, 2);
+                $pcYanglaojinGongxian = static::getPvYanglaojinScore($value['cost_price']);
 
-                $fileSchedValue[$key]['cost_price'] = bcadd((string)$value['cost_price'], (string)$premium, 2);
-
-                $pv = bcmul((string)$premium, $this->pv_ratio, 2);
-                $fileSchedValue[$key]['yanglaojin'] = bcmul((string)$premium, $this->yanglaojin_ratio, 2);
-                $fileSchedValue[$key]['pv'] = $fileSchedValue[$key]['score'] = $fileSchedValue[$key]['gongxian'] = $pv;
+                $fileSchedValue[$key]['cost_price'] = $pcYanglaojinGongxian['cost_price'];
+                $fileSchedValue[$key]['yanglaojin'] = $pcYanglaojinGongxian['yanglaojin'];
+                $fileSchedValue[$key]['pv'] = $pcYanglaojinGongxian['pv'];
+                $fileSchedValue[$key]['score'] = $pcYanglaojinGongxian['score'];
+                $fileSchedValue[$key]['gongxian'] = $pcYanglaojinGongxian['gongxian'];
 
                 unset($fileSchedValue[$key]['channel_price']);
             }
@@ -315,4 +315,20 @@ class MovieRepository extends BaseRepository
 
         return compact('city_name', 'initial');
     }
+
+    /**
+     * 获取pv、养老金、售价、积分
+     *
+     * @param $cost_price
+     * @return array
+     */
+    public static function getPvYanglaojinScore($cost_price)
+    {
+        $premium = round($cost_price * self::premium_ratio, 2);
+        $cost_price = bcadd((string)$cost_price, (string)$premium, 2);
+        $pv = $gongxian = $score = bcmul((string)$premium, self::pv_ratio, 2);
+        $yanglaojin = bcmul((string)$premium, self::yanglaojin_ratio, 2);
+
+        return compact('premium', 'cost_price', 'pv', 'yanglaojin', 'gongxian', 'score');
+    }
 }

app/controller/api/movie/Movie.php

@@ -8,6 +8,7 @@
 namespace app\controller\api\movie;
 
 use app\common\repositories\movie\CinemaRepository;
+use app\common\repositories\movie\CinemaSchedRepository;
 use app\common\repositories\movie\FilmRepository;
 use app\common\repositories\movie\MovieRepository;
 use app\common\repositories\system\groupData\GroupDataRepository;
@@ -95,19 +96,64 @@ class Movie extends BaseController
     }
 
     /**
-     * 获取影院场次列表
+     * 获取影片场次日期列表
      *
      * @return mixed
      */
-    public function getCinemaSched()
+    public function getFilmSchedDate()
     {
-        $cinema_sign = $this->request->param('cinema_sign', '');
-        if (empty($cinema_sign)) return app('json')->fail('请选择影院');
+        $film_sign = $this->request->param('film_sign', '');
+        if (empty($film_sign)) return app('json')->fail('请选择要观看的影片');
+
+        /** @var CinemaSchedRepository $cinemaSchedRepository */
+        $cinemaSchedRepository = app()->make(CinemaSchedRepository::class);
+        return app('json')->success($cinemaSchedRepository->getFilmSchedDate($film_sign));
+    }
 
+    /**
+     * 获取影片场次列表
+     *
+     * @return mixed
+     */
+    public function getFilmSched()
+    {
+        [$page, $limit] = $this->getPage();
         $film_sign = $this->request->param('film_sign', '');
-        if (empty($film_sign)) return app('json')->fail('请选择影片');
+        $longitude = $this->request->param('longitude', '');// 经度
+        $latitude = $this->request->param('latitude', '');// 纬度
+        $show_date = $this->request->param('show_date', '');
 
-        return app('json')->success($this->repository->getCinemaSched($film_sign, $cinema_sign));
+        if (empty($film_sign)) return app('json')->fail('请选择要观看的影片');
+        if (empty($longitude) || empty($latitude)) return app('json')->fail('请授权应用开启定位');
+        if (empty($show_date)) return app('json')->fail('请选择观影日期');
+
+        /** @var CinemaSchedRepository $cinemaSchedRepository */
+        $cinemaSchedRepository = app()->make(CinemaSchedRepository::class);
+        return app('json')->success($cinemaSchedRepository->getFilmSched($page, $limit, $film_sign, $longitude, $latitude, $show_date));
+    }
+
+    /**
+     * 影院影片场次列表
+     *
+     * @return mixed
+     */
+    public function getCinemaFilmSched()
+    {
+        [$page, $limit] = $this->getPage();
+        $cinema_sign = $this->request->param('cinema_sign', '');
+        $film_sign = $this->request->param('film_sign', '');
+//        $longitude = $this->request->param('longitude', '');// 经度
+//        $latitude = $this->request->param('latitude', '');// 纬度
+        $show_date = $this->request->param('show_date', '');
+
+        if (empty($cinema_sign)) return app('json')->fail('请选择观影影院');
+        if (empty($film_sign)) return app('json')->fail('请选择观影影片');
+//        if (empty($longitude) || empty($latitude)) return app('json')->fail('请授权应用开启定位');
+        if (empty($show_date)) return app('json')->fail('请选择观影日期');
+
+        /** @var CinemaSchedRepository $cinemaSchedRepository */
+        $cinemaSchedRepository = app()->make(CinemaSchedRepository::class);
+        return app('json')->success($cinemaSchedRepository->getCinemaFilmSched($page, $limit, $cinema_sign, $film_sign, $show_date));
     }
 
     /**

route/api.php

@@ -1271,11 +1271,13 @@ Route::group('api/', function () {
 
     //电影
     Route::group('movie', function () {
-        Route::get('city', '/getMovieCity');
-        Route::get('area', '/getArea');
-        Route::get('cinema', '/getCinema');
-        Route::get('film', '/getFilm');
-        Route::get('cinema_sched', '/getCinemaSched');
+        Route::get('city', '/getMovieCity'); // 城市列表
+        Route::get('area', '/getArea'); // 城区列表
+        Route::get('cinema', '/getCinema'); // 影院列表
+        Route::get('film', '/getFilm'); // 影片列表
+        Route::get('filmsched_date', '/getFilmSchedDate'); // 影片场次日期
+        Route::get('film_sched', '/getFilmSched'); // 影片场次排片影院列表
+        Route::get('cinemafilm_sched', '/getCinemaFilmSched'); // 影院影片场次列表
         Route::get('sched_seat', '/getSchedSeat');
     })->prefix('api.movie.Movie');