电影票下单逻辑

app/common/dao/movie/order/MovieOrderDao.php

@@ -0,0 +1,302 @@
+<?php
+/**
+ * @package merchant
+ *
+ * @author xaboy
+ * @day 2020/6/1
+ *
+ *
+ */
+
+namespace app\common\dao\movie\order;
+
+
+use app\common\dao\BaseDao;
+use app\common\model\movie\order\MovieOrder;
+use app\common\model\user\User;
+use think\facade\Db;
+
+/**
+ * Class MovieOrderDao
+ * @package app\common\dao\movie\order
+ * @author xaboy
+ * @day 2020/6/8
+ */
+class MovieOrderDao extends BaseDao
+{
+
+    /**
+     * @return string
+     * @author xaboy
+     * @day 2020/6/8
+     */
+    protected function getModel(): string
+    {
+        return MovieOrder::class;
+    }
+
+    /**
+     * @param array $where
+     * @param int $sysDel
+     * @return \think\db\BaseQuery
+     * @author xaboyCRMEB
+     * @day 2020/6/16
+     */
+    public function search(array $where, $sysDel = 0)
+    {
+
+        return MovieOrder::getDB()
+            ->when(($sysDel !== null), function ($query) use ($sysDel) {
+                $query->where('is_system_del', $sysDel);
+            })
+            ->when(isset($where['pay_type']) && $where['pay_type'] != -1 && $where['pay_type'] >= 0, function ($query) use ($where) {
+                $query->where('pay_type', $where['pay_type']);
+            })
+            ->when(isset($where['order_type']) && $where['order_type'] && $where['order_type'] >= 0, function ($query) use ($where) {
+                $query->where('order_type', $where['order_type']);
+            })
+            ->when(isset($where['distribution_mode']) && $where['distribution_mode'] && $where['distribution_mode'] >= 0, function ($query) use ($where) {
+                $query->where('distribution_mode', $where['distribution_mode']);
+            })
+            ->when(isset($where['status']) && $where['status'] !== '', function ($query) use ($where) {
+                if ($where['status'] == -2)
+                    $query->where('paid', 1);
+                else
+                    $query->where('status', $where['status']);
+            })
+            ->when(isset($where['uid']) && $where['uid'] !== '', function ($query) use ($where) {
+                $query->where('uid', $where['uid']);
+            })
+            ->when(isset($where['take_order']), function ($query) use ($where) {
+                $query->where('order_type', 1)->where('status', '>=', 2);
+            })
+            ->when(isset($where['mer_id']) && $where['mer_id'] !== '', function ($query) use ($where) {
+                $query->where('mer_id', $where['mer_id']);
+            })
+            ->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
+                getModelTime($query, $where['date']);
+            })
+            ->when(isset($where['verify_date']) && $where['verify_date'] !== '', function ($query) use ($where) {
+                getModelTime($query, $where['verify_date']);
+            })
+            ->when(isset($where['order_sn']) && $where['order_sn'] !== '', function ($query) use ($where) {
+                $query->where('order_sn', 'like', '%' . $where['order_sn'] . '%');
+            })
+            ->when(isset($where['paid']) && $where['paid'] !== '', function ($query) use ($where) {
+                $query->where('paid', $where['paid']);
+            })
+            ->when(isset($where['is_del']) && $where['is_del'] !== '', function ($query) use ($where) {
+                $query->where('is_del', $where['is_del']);
+            })
+            ->when(isset($where['service_id']) && $where['service_id'] !== '', function ($query) use ($where) {
+                $query->where('service_id', $where['service_id']);
+            })
+            ->when(isset($where['username']) && $where['username'] !== '', function ($query) use ($where) {
+                $uid = User::where('nickname', 'like', "%{$where['username']}%")
+                    ->whereOr('phone', 'like', "%{$where['username']}%")
+                    ->column('uid');
+                $query->where('uid', 'in', $uid);
+            })
+            ->when(isset($where['gzc']) && $where['gzc'] !== '', function ($query) use ($where) {
+                $query->where('gzc', $where['gzc']);
+            })
+            ->when(isset($where['keywords']) && $where['keywords'] !== '', function ($query) use ($where) {
+                $query->where(function ($query) use ($where) {
+                    $query->where('real_name', 'like', "%" . $where['keywords'] . "%")
+                        ->whereOr('user_phone', 'like', "%{$where['keywords']}%")
+                        ->whereOr('order_sn', 'like', '%' . $where['keywords'] . '%')
+                        ->whereOr('verify_code', 'like', '%' . $where['keywords'] . '%');
+                });
+            })
+            ->when(isset($where['reconciliation_type']) && $where['reconciliation_type'] !== '', function ($query) use ($where) {
+                $query->when($where['reconciliation_type'], function ($query) use ($where) {
+                    $query->where('reconciliation_id', '<>', 0);
+                }, function ($query) use ($where) {
+                    $query->where('reconciliation_id', 0);
+                });
+            })->order('create_time DESC');
+    }
+
+    /**
+     * @param array $where
+     * @param int $sysDel
+     * @return \think\db\BaseQuery
+     * @author xaboyCRMEB
+     * @day 2020/6/16
+     */
+    public function merSearch(array $where, $sysDel = 0)
+    {
+
+        return MovieOrder::getDB()
+            ->alias('so')
+            ->leftJoin('user_bill ub', 'ub.order_sn=so.order_sn')
+            ->when(($sysDel !== null), function ($query) use ($sysDel) {
+                $query->where('so.is_system_del', $sysDel);
+            })
+            ->when(isset($where['pay_type']) && $where['pay_type'] != -1 && $where['pay_type'] >= 0, function ($query) use ($where) {
+                $query->where('so.pay_type', $where['pay_type']);
+            })
+            ->when(isset($where['order_type']) && $where['order_type'] && $where['order_type'] >= 0, function ($query) use ($where) {
+                $query->where('so.order_type', $where['order_type']);
+            })
+            ->when(isset($where['distribution_mode']) && $where['distribution_mode'] && $where['distribution_mode'] >= 0, function ($query) use ($where) {
+                $query->where('so.distribution_mode', $where['distribution_mode']);
+            })
+            ->when(isset($where['status']) && $where['status'] !== '', function ($query) use ($where) {
+                if ($where['status'] == -2)
+                    $query->where('so.paid', 1);
+                else
+                    $query->where('so.status', $where['status']);
+            })
+            ->when(isset($where['uid']) && $where['uid'] !== '', function ($query) use ($where) {
+                $query->where('so.uid', $where['uid']);
+            })
+            ->when(isset($where['take_order']), function ($query) use ($where) {
+                $query->where('so.order_type', 1)->where('status', '>=', 2);
+            })
+            ->when(isset($where['mer_id']) && $where['mer_id'] !== '', function ($query) use ($where) {
+                $query->where('so.mer_id', $where['mer_id']);
+            })
+            ->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
+                getModelTime($query, $where['date']);
+            })
+            ->when(isset($where['verify_date']) && $where['verify_date'] !== '', function ($query) use ($where) {
+                getModelTime($query, $where['verify_date']);
+            })
+            ->when(isset($where['order_sn']) && $where['order_sn'] !== '', function ($query) use ($where) {
+                $query->where('so.order_sn', 'like', '%' . $where['order_sn'] . '%');
+            })
+            ->when(isset($where['paid']) && $where['paid'] !== '', function ($query) use ($where) {
+                $query->where('so.paid', $where['paid']);
+            })
+            ->when(isset($where['is_del']) && $where['is_del'] !== '', function ($query) use ($where) {
+                $query->where('so.is_del', $where['is_del']);
+            })
+            ->when(isset($where['service_id']) && $where['service_id'] !== '', function ($query) use ($where) {
+                $query->where('so.service_id', $where['service_id']);
+            })
+            ->when(isset($where['username']) && $where['username'] !== '', function ($query) use ($where) {
+                $uid = User::where('so.nickname', 'like', "%{$where['username']}%")
+                    ->whereOr('so.phone', 'like', "%{$where['username']}%")
+                    ->column('so.uid');
+                $query->where('so.uid', 'in', $uid);
+            })
+            ->when(isset($where['gzc']) && $where['gzc'] !== '', function ($query) use ($where) {
+                $query->where('so.gzc', $where['gzc']);
+            })
+            ->when(isset($where['keywords']) && $where['keywords'] !== '', function ($query) use ($where) {
+                $query->where(function ($query) use ($where) {
+                    $query->where('so.real_name', 'like', "%" . $where['keywords'] . "%")
+                        ->whereOr('so.user_phone', 'like', "%{$where['keywords']}%")
+                        ->whereOr('so.order_sn', 'like', '%' . $where['keywords'] . '%')
+                        ->whereOr('so.verify_code', 'like', '%' . $where['keywords'] . '%');
+                });
+            })
+            ->when(isset($where['reconciliation_type']) && $where['reconciliation_type'] !== '', function ($query) use ($where) {
+                $query->when($where['reconciliation_type'], function ($query) use ($where) {
+                    $query->where('so.reconciliation_id', '<>', 0);
+                }, function ($query) use ($where) {
+                    $query->where('so.reconciliation_id', 0);
+                });
+            })->order('so.create_time DESC');
+    }
+
+    /**
+     * @param $id
+     * @param $uid
+     * @return array|\think\Model|null
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author xaboy
+     * @day 2020/6/11
+     */
+    public function userOrder($id, $uid)
+    {
+        return MovieOrder::getDB()->where('order_id', $id)->where('uid', $uid)->where('is_del', 0)->where('paid', 1)->where('is_system_del', 0)->find();
+    }
+
+    /**
+     * @param array $where
+     * @param $ids
+     * @return \think\db\BaseQuery
+     * @author xaboy
+     * @day 2020/6/26
+     */
+    public function usersOrderQuery(array $where, $ids)
+    {
+        return MovieOrder::getDB()->whereIn('uid', $ids)->when(isset($where['date']) && $where['date'] !== '', function ($query) use ($where) {
+            getModelTime($query, $where['date'], 'pay_time');
+        })->when(isset($where['keyword']) && $where['keyword'] !== '', function ($query) use ($where) {
+            $query->where('order_id|order_sn', $where['keyword']);
+        })->where('paid', 1)->order('pay_time DESC');
+    }
+
+    /**
+     * @param $field
+     * @param $value
+     * @param int|null $except
+     * @return bool
+     * @author xaboy
+     * @day 2020/6/11
+     */
+    public function fieldExists($field, $value, ?int $except = null): bool
+    {
+        return ($this->getModel()::getDB())->when($except, function ($query) use ($field, $except) {
+                $query->where($field, '<>', $except);
+            })->where($field, $value)->count() > 0;
+    }
+
+    public function orderUserNum($date, $paid = null, $merId = null)
+    {
+        return MovieOrder::getDB()->when($paid, function ($query, $paid) {
+            $query->where('paid', $paid);
+        })->when($merId, function ($query, $merId) {
+            $query->where('mer_id', $merId);
+        })->when($date, function ($query, $date) {
+            getModelTime($query, $date, 'pay_time');
+        })->group('uid')->count();
+    }
+
+    public function orderUserGroup($date, $paid = null, $merId = null)
+    {
+        return MovieOrder::getDB()->when($paid, function ($query, $paid) {
+            $query->where('paid', $paid);
+        })->when($merId, function ($query, $merId) {
+            $query->where('mer_id', $merId);
+        })->when($date, function ($query, $date) {
+            getModelTime($query, $date, 'pay_time');
+        })->group('uid')->field(Db::raw('uid,sum(pay_price) as pay_price'))->select();
+    }
+
+    public function orderPrice($date, $paid = null, $merId = null)
+    {
+        return MovieOrder::getDB()->when($paid, function ($query, $paid) {
+            $query->where('paid', $paid);
+        })->when($merId, function ($query, $merId) {
+            $query->where('mer_id', $merId);
+        })->when($date, function ($query, $date) {
+            getModelTime($query, $date, 'pay_time');
+        })->sum('pay_price');
+    }
+
+    public function orderGroupNum($date, $merId = null)
+    {
+        return MovieOrder::getDB()->field(Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,from_unixtime(unix_timestamp(pay_time),\'%m-%d\') as `day`'))
+            ->where('paid', 1)->when($date, function ($query, $date) {
+                getModelTime($query, $date, 'pay_time');
+            })->when($merId, function ($query, $merId) {
+                $query->where('mer_id', $merId);
+            })->order('day ASC')->group('day')->select();
+    }
+
+    public function orderGroupNumPage($where, $page, $limit, $merId = null)
+    {
+        return MovieOrder::getDB()->when(isset($where['dateRange']), function ($query) use ($where) {
+            getModelTime($query, date('Y/m/d H:i:s', $where['dateRange']['start']) . '-' . date('Y/m/d H:i:s', $where['dateRange']['stop']), 'pay_time');
+        })->field(Db::raw('sum(pay_price) as pay_price,count(*) as total,count(distinct uid) as user,from_unixtime(unix_timestamp(pay_time),\'%m-%d\') as `day`'))
+            ->where('paid', 1)->when($merId, function ($query, $merId) {
+                $query->where('mer_id', $merId);
+            })->order('day DESC')->page($page, $limit)->group('day')->select();
+    }
+}

app/common/model/movie/order/MovieOrder.php

@@ -0,0 +1,28 @@
+<?php
+/**
+ * @package merchant
+ *
+ * @author xaboy
+ * @day 2020/6/1
+ *
+ *
+ */
+
+namespace app\common\model\movie\order;
+
+
+use app\common\model\BaseModel;
+
+class MovieOrder extends BaseModel
+{
+
+    public static function tablePk(): ?string
+    {
+        return 'order_id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'order_movie';
+    }
+}

app/common/repositories/movie/DouHuoMallFilmApiRequest.php

@@ -207,7 +207,7 @@ class DouHuoMallFilmApiRequest
      * @param $sched_sign
      * @return mixed|string
      */
-    public static function submitOrde($phone, $channel_type, $sched_sign, $third_order, $order_price)
+    public static function submitOrder($phone, $channel_type, $sched_sign, $third_order, $order_price)
     {
         $url = '/openapi/Movie/submitOrder';
         $body = [

app/controller/api/movie/Movie.php

@@ -42,8 +42,8 @@ class Movie extends BaseController
     public function getMovieCity()
     {
         [$page, $limit] = $this->getPage();
-        $initial = $this->request->params(['initial']);
-        $city_name = $this->request->params(['city_name']);
+        $initial = $this->request->param('initial', '');
+        $city_name = $this->request->param('city_name', '');
 
         return app('json')->success($this->repository->getMovieCity($page, $limit, $initial, $city_name));
     }
@@ -55,7 +55,7 @@ class Movie extends BaseController
      */
     public function getArea()
     {
-        $city_sign = $this->request->params(['city_sign']);
+        $city_sign = $this->request->param('city_sign', '');
         if (empty($city_sign)) return app('json')->fail('请选择城市');
 
         return app('json')->success($this->repository->getMovieArea($city_sign));
@@ -69,8 +69,8 @@ class Movie extends BaseController
     public function getCinema()
     {
         [$page, $limit] = $this->getPage();
-        $city_sign = $this->request->params(['city_sign']);
-        $area_sign = $this->request->params(['area_sign']);
+        $city_sign = $this->request->param('city_sign', '');
+        $area_sign = $this->request->param('area_sign', '');
 
         return app('json')->success($this->repository->getCinema($page, $limit, $city_sign, $area_sign));
     }
@@ -83,8 +83,8 @@ class Movie extends BaseController
     public function getFilm()
     {
         [$page, $limit] = $this->getPage();
-        $cinema_sign = $this->request->params(['cinema_sign']);
-        $film_sign = $this->request->params(['film_sign']);
+        $cinema_sign = $this->request->param('cinema_sign', '');
+        $film_sign = $this->request->param('film_sign', '');
 
         return app('json')->success($this->repository->getFilm($page, $limit, $cinema_sign, $film_sign));
     }
@@ -96,10 +96,10 @@ class Movie extends BaseController
      */
     public function getCinemaSched()
     {
-        $cinema_sign = $this->request->params(['cinema_sign']);
+        $cinema_sign = $this->request->param('cinema_sign', '');
         if (empty($cinema_sign)) return app('json')->fail('请选择影院');
 
-        $film_sign = $this->request->params(['film_sign']);
+        $film_sign = $this->request->param('film_sign', '');
         if (empty($film_sign)) return app('json')->fail('请选择影片');
 
         return app('json')->success($this->repository->getCinemaSched($film_sign, $cinema_sign));
@@ -112,12 +112,88 @@ class Movie extends BaseController
      */
     public function getSchedSeat()
     {
-        $relation_id = $this->request->params(['relation_id']);
+        $relation_id = $this->request->param('relation_id', '');
         if (empty($cinema_sign)) return app('json')->fail('请选择场次');
 
-        $sched_sign = $this->request->params(['sched_sign']);
+        $sched_sign = $this->request->param('sched_sign', '');
         if (empty($film_sign)) return app('json')->fail('请选择场次');
 
         return app('json')->success($this->repository->getSchedSeat($relation_id, $sched_sign));
     }
+
+    /**
+     * 锁座订单
+     *
+     * @return mixed
+     */
+    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', '']
+        );
+
+        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('请选择购票类型');
+
+        $result = $this->repository->submitOrder($this->request->userInfo(), $params);
+        if ($result['code'] == 200) {
+            return app('json')->success($result);
+        } else {
+            return app('json')->fail($result);
+        }
+    }
+
+    /**
+     * 确认订单
+     *
+     * @return mixed
+     */
+    public function confirmOrder()
+    {
+        $relation_id = $this->request->param(['relation_id']);
+        if (empty($cinema_sign)) return app('json')->fail('请选择场次');
+
+        $sched_sign = $this->request->param(['sched_sign']);
+        if (empty($film_sign)) return app('json')->fail('请选择场次');
+
+        return app('json')->success($this->repository->confirmOrder($relation_id, $sched_sign));
+    }
+
+    /**
+     * 查询订单信息
+     *
+     * @return mixed
+     */
+    public function getOrderInfo()
+    {
+        $relation_id = $this->request->param(['relation_id']);
+        if (empty($cinema_sign)) return app('json')->fail('请选择场次');
+
+        $sched_sign = $this->request->param(['sched_sign']);
+        if (empty($film_sign)) return app('json')->fail('请选择场次');
+
+        return app('json')->success($this->repository->getOrderInfo($relation_id, $sched_sign));
+    }
 }

route/api.php

@@ -1281,6 +1281,9 @@ Route::group('api/', function () {
 
     //电影 - 下单业务
     Route::group('movie', function () {
+        Route::post('submit_order', '/submitOrder');
+        Route::post('confirm_order', '/confirmOrder');
+        Route::get('order_info', '/getOrderInfo');
     })->prefix('api.movie.Movie')->middleware(\app\common\middleware\UserTokenMiddleware::class, false);
 })
     ->middleware(\app\common\middleware\AllowOriginMiddleware::class)