获取影片场次日期返回时间戳

app/command/MovieOrderCommand.php

@@ -0,0 +1,110 @@
+<?php
+
+namespace app\command;
+
+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 MovieOrderCommand extends Command
+{
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('movie-order')->setDescription('电影-订单');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        $this->doMovieOrder();
+    }
+
+    /**
+     * 电影-订单
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function doMovieOrder()
+    {
+        $page = 1;
+        $limit = 100;
+
+        /** @var MovieRepository $movieOrderRepository */
+        $movieOrderRepository = app()->make(MovieRepository::class);
+        $filmLists = $movieOrderRepository->getOrderListAll($page, $limit);
+
+        if (isset($filmLists['code']) && ($filmLists['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE)) {
+            $this->createMovieFilm($filmLists['data']['list']);
+
+            $data = $filmLists['data'];
+            $totalPages = $data['paging']['pages'] ?? 0;
+            for ($index = ($page + 1); $index <= $totalPages; $index++) {
+                $filmLists = $movieRepository->getFilm($index, $limit);
+                if (isset($filmLists['code']) && ($filmLists['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE)) {
+                    $this->createMovieFilm($filmLists['data']['list']);
+                }
+            }
+        }
+    }
+
+    /**
+     * 电影-获取影片列表
+     *
+     * @param $list
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function createMovieFilm($list)
+    {
+        $film_signList = array_column($list, 'film_sign');
+
+        $localFilm_nameLists = Db::name('movie_film')->whereIn('film_sign', $film_signList)->field('id,film_sign,film_name,publish_date')->select();
+        $localFilm_nameLists = !empty($localFilm_nameLists) ? array_reduce($localFilm_nameLists->toArray(), function ($carry, $item) {
+            $carry[$item['film_sign']] = [
+                'id' => $item['id'], 'film_sign' => $item['film_sign'], 'film_name' => $item['film_name'], 'publish_date' => $item['publish_date']
+            ];
+            return $carry;
+        }, []) : [];
+        $time = strtotime(date('Y-m-d'));
+
+        foreach ($list as $key => $value) {
+            $publish_date = strtotime($value['publish_date']);
+            $params = [
+                'film_sign' => $value['film_sign'],
+                'film_name' => $value['film_name'],
+                'publish_date' => $publish_date,
+                'language' => trim($value['language']),
+                'type' => $value['type'],
+                'duration' => $value['duration'],
+                'version' => $value['version'],
+                'grade' => $value['grade'],
+                'hots' => $value['hots'],
+                'cover_img' => $value['cover_img'],
+                'video' => $value['video'],
+                'detail_img' => json_encode($value['detail_img'], JSON_FORCE_OBJECT),
+                'director' => json_encode($value['director'], JSON_FORCE_OBJECT),
+                'actors' => json_encode($value['actors'], JSON_FORCE_OBJECT),
+                'intro' => $value['intro'],
+                'is_show' => intval(($publish_date <= $time))
+            ];
+            if (!isset($localFilm_nameLists[$value['film_sign']])) {
+                $params['create_time'] = time();
+                Db::name('movie_film')->insert($params);
+            } else {
+                $localFilm_name = $localFilm_nameLists[$value['film_sign']];
+                if (md5($value['film_sign'] . $value['film_name'] . $value['publish_date'])
+                    != md5($localFilm_name['film_sign'] . $localFilm_name['film_name'] . $localFilm_name['publish_date'])) {
+                    $params['update_time'] = time();
+                    Db::name('movie_film')->where('id', $localFilm_name['id'])->update($params);
+                }
+            }
+        }
+    }
+}

app/common/repositories/movie/CinemaSchedRepository.php

@@ -128,7 +128,14 @@ class CinemaSchedRepository extends BaseRepository
         $cinema_sched = $movieRepository->getCinemaSched($film_sign, $cinema_sign);
 
         // 排片日期
-        $show_date = array_keys($cinema_sched);
+        $show_date = [];
+        $show_date_tmp = array_keys($cinema_sched);
+        foreach ($show_date_tmp as $sdKey => $sdValue) {
+            $show_date[$sdKey] = [
+                'date_timestamp' => strtotime(date('Y') . '-' . $sdValue),
+                'date' => $sdValue,
+            ];
+        }
         // 场次列表
         foreach ($cinema_sched as $date => &$cinema_schedValue) {
             foreach ($cinema_schedValue as $key => $value) {

app/common/repositories/movie/MovieRepository.php

@@ -688,4 +688,50 @@ class MovieRepository extends BaseRepository
 
         return compact('movie_order', 'count');
     }
+
+    /**
+     * 订单列表
+     *
+     * @param $userinfo
+     * @param $page
+     * @param $limit
+     * @param $type
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getOrderListAll($userinfo, $page, $limit, $type = -1)
+    {
+        $where['uid'] = $userinfo['uid'];
+        switch ($type) {
+            case 0:
+                $where['status'] = [0];
+                break;
+            case 1:
+            case 4:
+                $where['status'] = [1, 4];
+                break;
+            case 2:
+            case 3:
+                $where['status'] = [2, 3];
+                break;
+            default:
+                break;
+        }
+
+        $field = 'order_sn,order_price,city_name,area_name,cinema_name,address,hall_name,film_sign,film_name,show_date,show_time,sched_seat,number,status,create_time';
+        $movie_order = $this->dao->search($where)
+            ->when($page && $limit, function ($query) use ($page, $limit) {
+                $query->page($page, $limit);
+            })->order('order_id desc')->field([$field])->select()->toArray();
+        foreach ($movie_order as $key => $value) {
+            $movie_order[$key]['sched_seat'] = json_decode($value['sched_seat'], true);
+            $movie_order[$key]['cover_img'] = Db::name('movie_film')->where('film_sign', $value['film_sign'])->value('cover_img');
+        }
+
+        $count = $this->dao->search($where)->count();
+
+        return compact('movie_order', 'count');
+    }
 }