锁座订单

app/command/CinemaSchedCommand.php

@@ -87,7 +87,8 @@ class CinemaSchedCommand extends Command
                     'hall_sign' => $value['hall_sign'],
                     'hall_name' => $value['hall_name'],
                     'stop_sell_time' => strtotime($value['stop_sell_time']),
-                    '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/model/movie/cinema/Cinema.php

@@ -24,8 +24,8 @@ class Cinema extends BaseModel
 
         return $model->when(isset($where['cinema_name']) && $where['cinema_name'], function ($query) use ($where) {
             $query->where('cinema_name', 'like', "%{$where['cinema_name']}%");
-        })->when(isset($where['cate_one_id']) && $where['cate_one_id'], function ($query) use ($where) {
-            $query->where('cate_one_id', $where['cate_one_id']);
+        })->when(isset($where['cinema_sign']) && $where['cinema_sign'], function ($query) use ($where) {
+            $query->where('cinema_sign', $where['cinema_sign']);
         })->when(isset($where['cate_two_id']) && $where['cate_two_id'], function ($query) use ($where) {
             $query->where('cate_two_id', $where['cate_two_id']);
         })->when(isset($where['city']) && $where['city'], function ($query) use ($where) {

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

@@ -28,8 +28,10 @@ class CinemaSched extends BaseModel
             $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']}%");
+        })->when(isset($where['relation_id']) && $where['relation_id'], function ($query) use ($where) {
+            $query->where('relation_id', $where['relation_id']);
+        })->when(isset($where['sched_sign']) && $where['sched_sign'], function ($query) use ($where) {
+            $query->where('sched_sign', $where['sched_sign']);
         });
     }
 }

app/common/repositories/movie/CinemaRepository.php

@@ -85,4 +85,18 @@ class CinemaRepository extends BaseRepository
         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";
     }
+
+    /**
+     * 获取影院信息
+     *
+     * @param $cinema_sign
+     * @return Cinema|array|\think\Model|null
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getCinemaInfo($cinema_sign)
+    {
+        return $this->dao->search(null, ['cinema_sign' => $cinema_sign])->find();
+    }
 }

app/common/repositories/movie/CinemaSchedRepository.php

@@ -65,7 +65,7 @@ class CinemaSchedRepository extends BaseRepository
      */
     public function getFilmSched($page, $limit, $film_sign, $longitude, $latitude, $show_date, $with = [], $order = 1)
     {
-        $field = 'sched_sign,cinema_sign,cinema_name,address,show_date,cost_price,longitude,latitude';
+        $field = 'sched_sign,cinema_sign,cinema_name,address,show_date,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) {
@@ -85,8 +85,8 @@ class CinemaSchedRepository extends BaseRepository
             $cinema_sched[$key]['distance'] = isset($value['distance']) ? round($value['distance'] / 1000, 2) : 0.00;
             $cinema_sched[$key]['show_date'] = date('m-d', $value['show_date']);
 
-            $pcYanglaojinGongxian = MovieRepository::getPvYanglaojinScore($value['cost_price']);
-            $cinema_sched[$key]['cost_price'] = $pcYanglaojinGongxian['cost_price'];
+            $pcYanglaojinGongxian = MovieRepository::getPvYanglaojinScore($value['price']);
+            $cinema_sched[$key]['price'] = $pcYanglaojinGongxian['cost_price'];
         }
 
         $count = $this->dao->search(null, $where)->when($with, function ($query) use ($with) {
@@ -111,7 +111,7 @@ class CinemaSchedRepository extends BaseRepository
      */
     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';
+        $field = 'relation_id,sched_sign,film_sign,film_name,show_date,show_time,cinema_sign,cinema_name,hall_sign,hall_name,price';
         $where = ['cinema_sign' => $cinema_sign, 'film_sign' => $film_sign, 'show_date' => strtotime($show_date)];
 
         $cinema_sched = $this->dao->search(null, $where)
@@ -119,9 +119,9 @@ class CinemaSchedRepository extends BaseRepository
                 $query->page($page, $limit);
             })->order('show_time asc')->field([$field])->select()->toArray();
         foreach ($cinema_sched as $key => $value) {
-            $pcYanglaojinGongxian = MovieRepository::getPvYanglaojinScore($value['cost_price']);
+            $pcYanglaojinGongxian = MovieRepository::getPvYanglaojinScore($value['price']);
 
-            $cinema_sched[$key]['cost_price'] = $pcYanglaojinGongxian['cost_price'];
+            $cinema_sched[$key]['price'] = $pcYanglaojinGongxian['cost_price'];
             $cinema_sched[$key]['yanglaojin'] = $pcYanglaojinGongxian['yanglaojin'];
             $cinema_sched[$key]['pv'] = $pcYanglaojinGongxian['pv'];
             $cinema_sched[$key]['score'] = $pcYanglaojinGongxian['score'];
@@ -144,4 +144,19 @@ class CinemaSchedRepository extends BaseRepository
         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";
     }
+
+    /**
+     * 获取影片场次详情
+     *
+     * @param $relation_id
+     * @param $sched_sign
+     * @return CinemaSched|array|\think\Model|null
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getCinemaSchedInfo($relation_id, $sched_sign)
+    {
+        return $this->dao->search(null, ['relation_id' => $relation_id, 'sched_sign' => $sched_sign])->find();
+    }
 }

app/common/repositories/movie/DouHuoMallFilmApiRequest.php

@@ -203,11 +203,15 @@ class DouHuoMallFilmApiRequest
     /**
      * 锁座订单
      *
-     * @param $relation_id
+     * @param $phone
+     * @param $channel_type
      * @param $sched_sign
+     * @param $seat_sign
+     * @param $third_order
+     * @param $order_price
      * @return mixed|string
      */
-    public static function submitOrder($phone, $channel_type, $sched_sign, $third_order, $order_price)
+    public static function submitOrder($phone, $channel_type, $sched_sign, $seat_sign, $third_order, $order_price)
     {
         $url = '/openapi/Movie/submitOrder';
         $body = [
@@ -216,7 +220,8 @@ class DouHuoMallFilmApiRequest
             'sched_sign' => $sched_sign,
             'third_order' => $third_order,
             'order_price' => $order_price,
-            'phone' => $phone
+            'phone' => $phone,
+            'seat_sign' => $seat_sign
         ];
 
         $res = self::curl_post(self::$path . $url, $body);

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]['cost_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'];
@@ -126,7 +126,7 @@ class MovieRepository extends BaseRepository
         $schedSeatList = (isset($result['code']) && ($result['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE))
             ? $result['data']['list'] : [];
         foreach ($schedSeatList as $key => $value) {
-            $tmpprice = json_decode($value['price'],true);
+            $tmpprice = json_decode($value['price'], true);
             if (isset($tmpprice['P2'])) {
                 $price = $tmpprice['P2'];
             } elseif (isset($tmpprice['P1'])) {
@@ -144,6 +144,8 @@ class MovieRepository extends BaseRepository
             $schedSeatList[$key]['pv'] = $pcYanglaojinGongxian['pv'];
             $schedSeatList[$key]['score'] = $pcYanglaojinGongxian['score'];
             $schedSeatList[$key]['gongxian'] = $pcYanglaojinGongxian['gongxian'];
+            $schedSeatList[$key]['relation_id'] = $relation_id; // 场次ID
+            $schedSeatList[$key]['sched_sign'] = $sched_sign; // 场次编码
         }
 
         return $schedSeatList;
@@ -151,13 +153,13 @@ class MovieRepository extends BaseRepository
 
     /**
      * 锁座订单
-     * @param $sched_sign
-     * @param $seat_sign
-     * @param $channel_type
-     * @param $third_order
-     * @param $order_price
-     * @param $phone
-     * @return mixed|string
+     *
+     * @param $userinfo
+     * @param $params
+     * @return mixed
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
      */
     public function submitOrder($userinfo, $params)
     {
@@ -165,49 +167,57 @@ class MovieRepository extends BaseRepository
         $storeOrder = app()->make(StoreOrderRepository::class);
         $order_sn = $storeOrder->getNewOrderId() . '0';
 
-        $order_price = round($params['number'] * $params['price'], 2);
-        $submitOrder = DouHuoMallFilmApiRequest::submitOrder($userinfo->phone, $params['channel_type'], $params['sched_sign'], $order_sn, $order_price);
-        if (!empty($submitOrder) && isset($submitOrder['code']) && ($submitOrder['code'] == 200) && isset($submitOrder['data']['plat_order'])) {
+        /** @var CinemaSchedRepository $cinemaSchedRepository */
+        $cinemaSchedRepository = app()->make(CinemaSchedRepository::class);
+        $sched = $cinemaSchedRepository->getCinemaSchedInfo($params['relation_id'], $params['sched_sign']);
+        if (empty($sched)) throw new ValidateException('观影场次不存在');
+
+        $seat_sign = json_decode($params['seat_sign'], true);
+        $order_price = round($sched['price'] * 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 */
+            $cinemaRepository = app()->make(CinemaRepository::class);
+            $cinema = $cinemaRepository->getCinemaInfo($sched['cinema_sign']);
+
             $_order = [
                 'uid' => $userinfo->uid,
                 'mobile' => $userinfo->phone,
                 'order_sn' => $order_sn,
                 'plat_order' => $submitOrder['data']['plat_order'],
-                'price' => $params['price'],
-                'number' => $params['number'],
+                'price' => $sched['price'],
+                'number' => count($seat_sign),
                 'order_price' => $order_price,
                 'channel_type' => $params['channel_type'],
-                'pay_type' => $params['pay_type'],
-                'city_sign' => $params['city_sign'],
-                'city_name' => $params['city_name'],
-                'area_code' => $params['area_code'],
-                'area_name' => $params['area_name'],
-                'cinema_sign' => $params['cinema_sign'],
-                'cinema_name' => $params['cinema_name'],
-                'address' => $params['address'],
-                'longitude' => $params['longitude'],
-                'latitude' => $params['latitude'],
-                'hall_sign' => $params['hall_sign'],
-                'hall_name' => $params['hall_name'],
-                'relation_id' => $params['relation_id'],
-                'sched_sign' => $params['sched_sign'],
-                'film_sign' => $params['film_sign'],
-                'film_name' => $params['film_name'],
-                'show_date' => $params['show_date'],
-                'show_time' => $params['show_time'],
-                'sched_seat' => $params['sched_seat'],
+                'city_sign' => $cinema['city_sign'],
+                'city_name' => $cinema['city_name'],
+                'area_code' => $cinema['area_sign'],
+                'area_name' => $cinema['area_name'],
+                'cinema_sign' => $cinema['cinema_sign'],
+                'cinema_name' => $cinema['cinema_name'],
+                'address' => $cinema['address'],
+                'longitude' => $cinema['longitude'],
+                'latitude' => $cinema['latitude'],
+                'hall_sign' => $sched['hall_sign'],
+                'hall_name' => $sched['hall_name'],
+                'relation_id' => $sched['relation_id'],
+                'sched_sign' => $sched['sched_sign'],
+                'film_sign' => $sched['film_sign'],
+                'film_name' => $sched['film_name'],
+                'show_date' => $sched['show_date'],
+                'show_time' => $sched['show_time'],
+                'sched_seat' => $sched['sched_seat'],
                 'create_time' => time()
             ];
 
-            $group = Db::transaction(function () use ($userinfo, $_order) {
+            $order_sn = Db::transaction(function () use ($userinfo, $_order) {
                 $_order = $this->dao->create($_order);
-                if ($_order) return ['code' => ApiResponseService::DEFAULT_SUCCESS_CODE, 'msg' => '下单成功', 'data' => ['order_sn' => $_order['order_sn']]];
-
-                throw new ValidateException('下单失败');
+                if ($_order) return $_order['order_sn'];
+                throw new ValidateException('锁座下单失败');
             });
-            return $group;
+            return $order_sn;
         } else {
-            return $submitOrder;
+            throw new ValidateException('锁座下单失败');
         }
     }
 

app/controller/api/movie/Movie.php

@@ -14,6 +14,7 @@ use app\common\repositories\movie\MovieRepository;
 use app\common\repositories\system\groupData\GroupDataRepository;
 use app\controller\merchant\user\User;
 use crmeb\basic\BaseController;
+use crmeb\services\ApiResponseService;
 use think\App;
 
 class Movie extends BaseController
@@ -180,39 +181,21 @@ class Movie extends BaseController
     public function submitOrder()
     {
         $params = $this->request->params(
-            ['price', 0.00],
-            ['number', 0],
-            ['channel_type', ''],
-            ['pay_type', ''],
-            ['city_sign', ''],
-            ['city_name', ''],
-            ['area_code', ''],
-            ['area_name', ''],
-            ['cinema_sign', ''],
-            ['cinema_name', ''],
-            ['address', ''],
-            ['longitude', ''],
-            ['latitude', ''],
-            ['hall_sign', ''],
-            ['hall_name', ''],
-            ['relation_id', ''],
-            ['sched_sign', ''],
-            ['film_sign', ''],
-            ['film_name', ''],
-            ['show_date', ''],
-            ['show_time', ''],
-            ['sched_seat', '']
+            ['channel_type', 'P2'],
+            ['relation_id', ''], // 场次ID
+            ['sched_sign', ''], // 场次编码
+            ['seat_no', ''], // 座位
+            ['seat_sign', ''] // 座位编码
         );
 
-        if (empty($params['sched_sign'])) return app('json')->fail('请选择场次');
-        if (empty($params['seat_sign'])) return app('json')->fail('请选择座位');
-        if (empty($params['channel_type'])) return app('json')->fail('请选择购票类型');
+        if (empty($params['relation_id']) || empty($params['sched_sign'])) return app('json')->fail('请选择观影场次');
+        if (empty($params['seat_no']) || empty($params['seat_sign'])) return app('json')->fail('请选择座位');
 
         $result = $this->repository->submitOrder($this->request->userInfo(), $params);
-        if ($result['code'] == 200) {
-            return app('json')->success($result);
+        if (!empty($result)) {
+            return app('json')->success(['order_sn' => $result]);
         } else {
-            return app('json')->fail($result);
+            return app('json')->fail('锁座下单失败');
         }
     }