电影票订单列表

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

@@ -42,78 +42,24 @@ class MovieOrderDao extends BaseDao
      * @author xaboyCRMEB
      * @day 2020/6/16
      */
-    public function search(array $where, $sysDel = 0)
+    public function search(array $where)
     {
         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['status']) && $where['status'] !== '', function ($query) use ($where) {
+                $query->whereIn('status', $where['status']);
             })
             ->when(isset($where['order_sn']) && $where['order_sn'] !== '', function ($query) use ($where) {
-                $query->where('order_sn', 'like', '%' . $where['order_sn'] . '%');
+                $query->where('order_sn', '=', $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');
+            });
     }
 
     /**

app/common/repositories/movie/MovieRepository.php

@@ -10,12 +10,14 @@ namespace app\common\repositories\movie;
 use app\common\dao\movie\order\MovieOrderDao;
 use app\common\model\movie\order\MovieOrder;
 use app\common\repositories\BaseRepository;
+use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
 use app\traits\HuiPay;
 use crmeb\services\ApiResponseService;
 use think\exception\ValidateException;
 use think\facade\Db;
 use think\facade\Log;
+use function Symfony\Component\String\b;
 
 /**
  * Class MovieRepository
@@ -431,6 +433,8 @@ class MovieRepository extends BaseRepository
         if ($res) {
             $confirmOrder = DouHuoMallFilmApiRequest::confirmOrder($orderinfo['order_sn'], $orderinfo['price']);
             if (!empty($confirmOrder) && isset($confirmOrder['code']) && ($confirmOrder['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE)) {
+                // 计算佣金分红奖励
+                $this->calculationCommissionDividendAward();
                 // 提交事务
                 Db::commit();
             } else {
@@ -444,4 +448,265 @@ class MovieRepository extends BaseRepository
             Db::rollback();
         }
     }
+
+    private function calculationCommissionDividendAward()
+    {
+        //商家让利部分的拆分
+        $ylj_pri = bcmul($concession_pri, 0.3, 2); // 让利部分30%给消费者做养老金
+        $pv = bcmul($concession_pri, 0.35, 2); // 35%做业绩PV分配
+
+        //分配养老金给消费者
+        $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
+        //分配积分和贡献值给消费者
+        $con = $user_data['contribute'] + $pv;
+        $score = $user_data['score'] + $pv;
+
+        // 让利部分30%给消费者做养老金{$ylj_pri}
+        $this->bill_user_log($user_data['uid'], $ylj_pri, $store_order_data['order_id'], 5, $group_order['group_order_sn'], '购买商贸区商品获得养老金' . $ylj_pri, $store_order_data['mer_id'], 0);
+        // @todo 消费者购买商品赠送PV等值的积分和贡献值
+        // 贡献值
+//                $this->con_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送贡献值");
+        // 积分
+        $this->score_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送积分");
+
+        // @todo ------------PV业绩100%分配如下------------------
+        if ($user_data['spread_uid'] != 0) {
+            //查询下单用户上级
+            $spread_data = Db::name('user')->where('uid', $user_data['spread_uid'])->find();
+
+            $rate = static::getUserGroupRate($spread_data['user_group']);
+            if ($spread_data['user_group'] > 1) {
+                $ssf = 0;//变量
+                $yj_amount_90 = 0;//90%的佣金
+                // 业务员
+                if ($spread_data['user_group'] == 2) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+                } else if ($spread_data['user_group'] == 3) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                    // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
+                } else if ($spread_data['user_group'] == 4) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                    //Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
+                } else if ($spread_data['user_group'] == 5) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+                    // $yj_amount = $spread_data['brokerage_price'] + round($pv * $rate,2);
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                    // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
+                } else if ($spread_data['user_group'] == 6) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                    // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
+                } else if ($spread_data['user_group'] == 7) {
+                    $ssf = bcmul($pv, $rate, 2);
+                    $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                    $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+
+                    $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                    $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                    $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                    $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                    // Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount,'fugou'=>$fgj_amount]);
+                }
+
+                //贡献值
+                $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 12, "商贸区商品赠送贡献值");
+                //积分
+                $this->score_log($spread_data['uid'], $ssf, $store_order_data['order_id'], 12, "商贸区商品赠送积分");
+                //推广佣金
+                $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $group_order['group_order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0);
+                //养老金
+                $this->bill_user_log($spread_data['uid'], bcmul($pv, 0.05, 2), $store_order_data['order_id'], 5, $group_order['group_order_sn'], '推广获得养老金' . round($pv * 0.05, 2), $store_order_data['mer_id'], 0);
+            }
+
+            //普通用户推广人
+            if ($spread_data['user_group'] == 1) {
+                //给推广者分配佣金
+
+                $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                $yj_amount = $spread_data['brokerage_price'] + $yj_amount_90;
+                $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
+                $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                //Db::name('user')->where('uid',$spread_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
+
+                $con = $spread_data['contribute'] + bcmul($pv, $rate, 2);
+                $score = $spread_data['score'] + bcmul($pv, $rate, 2);
+
+                //贡献值和积分
+                // Db::name('user')->where('uid',$spread_data['uid'])->update(["contribute"=>$con,"score"=>$score]);
+
+                //推广佣金
+                $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $group_order['group_order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0);
+                // 贡献值
+                $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 12, "推广商贸区商品赠送贡献值");
+                // 积分
+                $this->score_log($spread_data['uid'], bcmul($pv, $rate, 2), $store_order_data['order_id'], 12, "推广商贸区商品赠送积分");
+            }
+        }
+
+        //锁客收益
+        if ($user_data['mer_id'] != 0) {
+            $merchant_data = Db::name('merchant')->where('mer_id', $user_data['mer_id'])->find();
+            $merchant_user_data = Db::name('user')->where('uid', $merchant_data['uid'])->find();
+            if (!empty($merchant_user_data)) {
+                //给推广者分配佣金
+                $yj_amount_90 = bcmul($pv, 0.05, 2) * 0.9;
+                $fgj_amount_10 = bcmul($pv, 0.05, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+
+                $yj_amount = $merchant_user_data['brokerage_price'] + $yj_amount_90;
+                $fgj_amount = $merchant_user_data['fugou'] + $fgj_amount_10;
+                $this->fugou_user_log($merchant_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                //推广佣金
+                $this->bill_user_log($merchant_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $group_order['group_order_sn'], '推广获得佣金' . $yj_amount_90, $store_order_data['mer_id'], 0);
+            }
+            /** @var OrderMerchantRepository $orderMerchantRepository */
+            $orderMerchantRepository = app()->make(OrderMerchantRepository::class);
+            $jdAndGonxianConfig = $orderMerchantRepository->getMerchantContribution($store_order_data['extension_two']);
+
+            //商户获得贡献值
+            if ($concession_pri >= 0.01) {
+                $gonxian = bcmul($concession_pri, $jdAndGonxianConfig['gonxian'], 2);
+                $gongxian_data = [
+                    "uid" => $merchant_data["uid"],
+                    "mer_id" => $user_data['mer_id'],
+                    "pv" => $pv,
+                    "number" => $gonxian,
+                    "addtime" => time(),
+                    "status" => -1,
+                    "order_type" => 2,
+                    "order_id" => $store_order_data['order_id'],
+                    "mark" => "锁客商家获得贡献值",
+                    "desc" => '',
+                    "surplus" => $gonxian,
+                    "type" => 1
+                ];
+                Db::name("user_sign_gongxian")->insert($gongxian_data);//添加记录
+            } else {
+                Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，贡献值低于0.01无法入库 特此记录！']);
+            }
+
+            //商户获得京豆
+            if ($concession_pri >= 0.01) {
+                $jd = bcmul($concession_pri, $jdAndGonxianConfig['jd'], 2);
+                $jd_data = [
+                    "uid" => $merchant_data["uid"],
+                    "mer_id" => $user_data['mer_id'],
+                    "number" => $jd,
+                    "addtime" => time(),
+                    "status" => -1,
+                    "order_type" => 2,
+                    "order_id" => $store_order_data['order_id'],
+                    "mark" => "锁客商家获得京豆",
+                    "desc" => '',
+                    "surplus" => $jd,
+                    "type" => 1
+                ];
+                Db::name("user_sign_jingdou")->insert($jd_data);//添加记录
+            } else {
+                Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，京豆低于0.01无法入库 特此记录！']);
+            }
+        }
+    }
+
+    /**
+     * 订单列表
+     *
+     * @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 getOrderList($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]['show_date'] = date('Y-m-d', $value['show_date']);
+            $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');
+    }
 }

app/controller/api/movie/Movie.php

@@ -214,6 +214,19 @@ class Movie extends BaseController
     }
 
     /**
+     * 订单列表
+     *
+     * @return mixed
+     */
+    public function getOrderList()
+    {
+        [$page, $limit] = $this->getPage();
+        $type = $this->request->param('type', -1);//订单状态：-1：全部，0 待支付 1 已支付 2已超时 3已取消 4已成功
+
+        return app('json')->success($this->repository->getOrderList($this->request->userInfo(), $page, $limit, $type));
+    }
+
+    /**
      * 查询订单信息
      *
      * @return mixed

route/api.php

@@ -1279,6 +1279,7 @@ Route::group('api/', function () {
         Route::get('film_sched', '/getFilmSched'); // 根据影片排片日期查询排片影院
         Route::get('cinemafilm_sched', '/getCinemaFilmSched'); // 根据影院影片场次日期查询场次列表
         Route::get('sched_seat', '/getSchedSeat'); // 获取场次座位
+        Route::get('order_list', '/getOrderList'); // 订单列表
     })->prefix('api.movie.Movie');
 
     //电影 - 下单业务