php/app/command/CinemaSchedCommand.php

<?php

namespace app\command;

use app\common\model\user\User;
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;
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_film_sched')->setDescription('电影-影院场次列表');
    }

    protected function execute(Input $input, Output $output)
    {
        $date = strtotime(date('Y-m-d'));
        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);
            // 获取{2个月内}已上映影片列表
            $filmResult = $filmRepository->getFilmByStartEndDate($this->page, $this->limit, strtotime('-2 month', $date), $date);

            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);
                    }
                }
            }
        } catch (\Exception $exception) {
            var_dump($exception->getMessage(), $exception->getFile(), $exception->getLine());
        }
    }

    /**
     * 是否未排片
     *
     * @param $film_sign
     * @param $cinema_sign
     * @return bool
     */
    private function isUnscheduledFilm($film_sign = '', $cinema_sign = '')
    {
        $count = Db::name('movie_cinema_unsched')->where(['film_sign' => $film_sign, 'cinema_sign' => $cinema_sign])->count();
        return $count > 0;
    }

    /**
     * 电影-获取影院场次列表
     * @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 (!empty($cinema_sched)) {
            // 写入排片场次数据
            $this->createCinemaSched($cinema_sched, $cinema);
        } else {
            // 写入未排片影院
            $this->createUnschedCinema($film, $cinema);
        }
    }

    /**
     * 写入排片场次数据
     *
     * @param $list
     * @param $cinema
     * @return void
     * @throws \think\db\exception\DbException
     */
    private function createCinemaSched($list, $cinema)
    {
        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']),
                    'price' => $value['price'], // 销售价
                    '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);
                }
            }
        }
    }

    /**
     * 记录未排片影院
     *
     * @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);
    }
}