计算佣金、分红奖励

app/common/repositories/movie/MovieRepository.php

@@ -448,8 +448,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();
+                // 计算佣金、分红奖励
+                $this->calculationCommissionDividendAward($orderinfo);
                 // 提交事务
                 Db::commit();
             } else {
@@ -464,218 +464,158 @@ class MovieRepository extends BaseRepository
         }
     }
 
-    private function calculationCommissionDividendAward()
+    /**
+     * 计算佣金、分红奖励
+     * @param $orderinfo
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function calculationCommissionDividendAward($orderinfo)
     {
-        //商家让利部分的拆分
-        $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, "购买商贸区商品赠送贡献值");
+        /** @var StoreOrderRepository $storeOrderRepository */
+        $storeOrderRepository = app()->make(StoreOrderRepository::class);
+
+        // 电影分佣比例配置
+        $movie_commission_rate_config = Db::name('system_config_value')->where('config_key', 'movie_commission_rate_config')->find();
+        // 让利金额
+        $concession_pri = bcmul((string)$orderinfo['price'], $movie_commission_rate_config['premium_rate'], 2);
+        // 养老金
+        $ylj_pri = bcmul($concession_pri, $movie_commission_rate_config['consumer_yanglaojin_rate'], 2);
+        // 业绩PV
+        $pv = bcmul($concession_pri, $movie_commission_rate_config['pv_rate'], 2);
+
+        //-------------------消费者收益---------------------
+        // PV值
+        $storeOrderRepository->con_log_pv($orderinfo['uid'], $pv, $orderinfo['order_id'], 13, "购买电影票赠送PV值");
+        // 养老金
+        $this->distributionAnnuityEarnings($orderinfo['uid'], $ylj_pri, $orderinfo['order_id'], 5, $orderinfo['order_sn'], '购买电影票获得养老金' . $ylj_pri, 0, 0);
+        // 消费者 - 红包 - 老用户发红包奖励
+        $user = Db::name("user")->where('uid', $orderinfo["uid"])->find();
+        if ($user['is_old'] == 1) {
+            $storeOrderRepository->giveHongBao($orderinfo["uid"], $pv, $orderinfo['order_id'], '购买电影票赠送红包');
+        }
         // 积分
-        $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']);
+        $storeOrderRepository->score_log($orderinfo['uid'], $pv, $orderinfo['order_id'], 13, "购买电影票赠送积分");
+        // 贡献值
+        $storeOrderRepository->con_log($orderinfo['uid'], $pv, $orderinfo['order_id'], 13, "购买电影票赠送贡献值");
+        //-------------------消费者收益---------------------
+
+        // 推广者
+        if ($user['spread_uid'] != 0) {
+            //查询{下单用户}的上级
+            $spread_data = Db::name('user')->where('uid', $user['spread_uid'])->find();
+            $rate = $storeOrderRepository->getUserGroupRate($spread_data['user_group']);
+
+            //养老金
+            $spread_yanglaojin = bcmul($pv, $movie_commission_rate_config['spread_yanglaojin_rate'], 2);
+            $this->distributionAnnuityEarnings(
+                $spread_data['uid'], $spread_yanglaojin, $orderinfo['order_id'], 5, $orderinfo['order_sn'], '电影票-推广者获得养老金' . $spread_yanglaojin, 0, 0
+            );
+
+            // 直推佣金
+            $yj_amount_90 = round(bcmul($pv, $rate, 2) * $movie_commission_rate_config['commission_directthrust_rate'], 2);
+            $this->distributionAnnuityEarnings(
+                $spread_data['uid'], $yj_amount_90, $orderinfo['order_id'], 3, $orderinfo['order_sn'], '电影票-推广者获得直推佣金' . $yj_amount_90,
+                0, 0
+            );
+
+            // 复购金-推广者的佣金抽10%到个人复购金
+            $fgj_amount_10 = round(bcmul($pv, $rate, 2) * $movie_commission_rate_config['repurchase_directthrust_rate'], 2);
+            $storeOrderRepository->fugou_user_log($spread_data['uid'], $fgj_amount_10, $orderinfo['order_id'], 1);
+
+            // 积分
+            $score = bcmul($pv, $rate, 2);
+            $storeOrderRepository->score_log($spread_data['uid'], $score, $orderinfo['order_id'], 13, "电影票-推广者获得赠送积分");
+
+            // 业务员及以上身份
             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);
+                // 贡献值
+                $storeOrderRepository->con_log($spread_data['uid'], $pv, $orderinfo['order_id'], 13, "电影票-推广者获得赠送贡献值");
             }
 
-            //普通用户推广人
+            // 普通用户推广人
             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, "推广商贸区商品赠送积分");
+                $gongxianValue = bcmul($pv, $movie_commission_rate_config['contributionvalue_spread_user_rate'], 2);
+                $storeOrderRepository->con_log($spread_data['uid'], $gongxianValue, $orderinfo['order_id'], 13, "电影票-推广者用户身份获得赠送贡献值");
             }
         }
 
-        //锁客收益
-        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 ($user['mer_id'] != 0) {
+            $merchant_uid = Db::name('merchant')->where('mer_id', $user['mer_id'])->value('uid');
+            $merchant_user = Db::name('user')->where('uid', $merchant_uid)->find();
+            if (!empty($merchant_user)) {
+                // 锁客佣金
+                $yj_amount_90 = round(bcmul($pv, $movie_commission_rate_config['commission_lockpassenger_merid_rate'], 2) * $movie_commission_rate_config['commission_lockpassenger_rate'], 2);
+                $this->distributionAnnuityEarnings(
+                    $merchant_uid, $yj_amount_90, $orderinfo['order_id'], 3, $orderinfo['order_sn'], '电影票-商户锁定用户获得佣金' . $yj_amount_90,
+                    $user['mer_id'], 0
+                );
+
+                // 锁客复购金
+                $fgj_amount_10 = round(bcmul($pv, $movie_commission_rate_config['repurchase_lockpassenger_merid_rate'], 2) * $movie_commission_rate_config['repurchase_lockpassenger_rate'], 2);
+                $storeOrderRepository->fugou_user_log($merchant_uid, $fgj_amount_10, $orderinfo['order_id'], 1);
             }
+        }
+    }
 
-            //商户获得京豆
-            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 $uid
+     * @param $num
+     * @param $order_id
+     * @param $comm_order_type
+     * @param $order_sn
+     * @param $mark
+     * @param $merid
+     * @param $ds
+     * @return void
+     */
+    private function distributionAnnuityEarnings($uid, $num, $order_id, $comm_order_type, $order_sn, $mark, $merid, $ds = 0)
+    {
+        $name = '';
+
+        if ($comm_order_type == 3) {
+            $name = '直推奖';
+
+        } else if ($comm_order_type == 5) {
+            $name = '养老金';
         }
+
+        $bill = [
+            'uid' => $uid,
+            'link_id' => $order_id,//关联订单id
+            'pm' => 1,//0：支出，1：获得
+            'title' => $name,//账单标题
+            'category' => 'now_money',//明细种类
+            'type' => 'commission',//明细类型
+            'number' => $num,//明细数字
+            'balance' => 0,//剩余
+            'mark' => $mark,//备注
+            'create_time' => date('Y-m-d H:i:s'),//添加时间
+            'status' => $ds,//0待确定，1有效，-1无效
+            'commission_type' => $comm_order_type,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
+            //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
+            //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
+            'order_sn' => $order_sn,//订单号
+            'tripartite' => 0,//
+            'type_shop' => 0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
+            'mer_id' => $merid,//商户id
+            'source' => 0,//1线下 0线上
+            'order_type' => 1,//1自营  2 第三方  订单类型
+            'is_red_brokerage' => 0,//1红积分对冲佣金 0正常佣金
+            'gzc' => 0,//养老金是否已进入公证处log表0：未进入。1：已进入
+            'take_time' => '',//结算时间
+            'district_id' => '',//
+            'street_id' => '',//
+            'month' => '',//月份
+        ];
+
+        Db::name('user_bill')->insert($bill);
     }
 
     /**