调整场次获取按照热映影片方式获取

app/command/CinemaSchedCommand.php

@@ -2,6 +2,7 @@
 
 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;
@@ -34,11 +35,9 @@ class CinemaSchedCommand extends Command
             $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);
-//                    if ($subValue['film_sign'] == 'F6556061D4' && $value['cinema_sign'] == 'CCB622D8D8') {
-//                    }
+            foreach ($filmResult['film_list'] as $key => $film) {
+                foreach ($result['cinema_list'] as $subKey => $cinema) {
+                    $this->doCinemaSched($film, $cinema);
                 }
             }
         } catch (\Exception $exception) {
@@ -89,8 +88,8 @@ class CinemaSchedCommand extends Command
                     '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'], // 销售价
+                    'price' => $value['price'], // 销售价
+                    'cost_price' => $value['cost_price'], // 原价
                     'channel_price' => json_encode($value['channel_price'], JSON_FORCE_OBJECT)
                 ];
                 $where = [

app/common/repositories/movie/MovieRepository.php

@@ -101,7 +101,7 @@ class MovieRepository extends BaseRepository
             foreach ($fileSchedValue as $key => $value) {
                 $pcYanglaojinGongxian = static::getPvYanglaojinScore($value['cost_price']);
 
-                $fileSchedValue[$key]['price'] = $pcYanglaojinGongxian['cost_price'];
+                $fileSchedValue[$key]['price'] = $pcYanglaojinGongxian['cost_price']; // 销售价
                 $fileSchedValue[$key]['yanglaojin'] = $pcYanglaojinGongxian['yanglaojin'];
                 $fileSchedValue[$key]['pv'] = $pcYanglaojinGongxian['pv'];
                 $fileSchedValue[$key]['score'] = $pcYanglaojinGongxian['score'];
@@ -169,7 +169,7 @@ class MovieRepository extends BaseRepository
         if (empty($sched)) throw new ValidateException('观影场次不存在');
 
         $seat_sign = json_decode($params['seat_sign'], true);
-        $order_price = round($sched['price'] * count($seat_sign), 2);
+        $order_price = bcmul((string)$sched['cost_price'], (string)count($seat_sign), 2);
         $submitOrder = DouHuoMallFilmApiRequest::submitOrder($userinfo->phone, $params['channel_type'], $params['sched_sign'], $seat_sign, $order_sn, $order_price);
         if (!empty($submitOrder) && isset($submitOrder['code']) && ($submitOrder['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE) && isset($submitOrder['data']['plat_order'])) {
             /** @var CinemaRepository $cinemaRepository */