商贸区支付成功后处理奖励机制

app/common/repositories/store/order/StoreOrderRepository.php

@@ -2403,7 +2403,7 @@ class StoreOrderRepository extends BaseRepository
 //                        ['type' => 'b1', 'price' => $jcvr, 'other' => $jcjf, 'note' => "VR+积分"],
                             ['type' => 'b2', 'price' => $jcprice, 'other' => $jcjf1, "note" => "现金+积分"],
                             // ['type'=>'b3','price'=>$jcvr1,'other'=>$jcjd,"note"=>"VR+京豆"],
-                            ['type' => 'b4', 'price' => $jcvr1, 'other' => $jcjd, "note" => "现金+京豆"],
+//                            ['type' => 'b4', 'price' => $jcvr1, 'other' => $jcjd, "note" => "现金+京豆"],
 //                        ['type' => 'b5', 'price' => $orderpri, 'other' => 0, "note" => "VR"],
                             ['type' => 'b6', 'price' => $orderpri, 'other' => 0, "note" => "现金"],
 

app/controller/api/Notify.php

@@ -2,8 +2,10 @@
 namespace app\controller\api;
 
 use AdaPaySdk\AdapayTools;
+use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\movie\MovieRepository;
 use app\common\repositories\store\order\StoreRefundOrderRepository;
+use app\common\repositories\system\merchant\MerchantRepository;
 use app\common\repositories\user\UserRepository;
 use app\controller\api\merchant\sxy\Access;
 use app\controller\api\store\service\Huafei;
@@ -181,7 +183,7 @@ class Notify
                                     //Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,"contribute"=>$con,"score"=>$score]);
 
                                     $this->bill_user_log($user_data['uid'],$ylj_pri,$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.$ylj_pri,$store_order_data['mer_id'],0);
-                                    $this->con_log_pv($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送贡献值");
+                                    $this->con_log_pv($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送pv");
                                     $this->con_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送贡献值");
                                     $this->score_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送积分");
 
@@ -417,7 +419,7 @@ class Notify
  
                                 $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
  
-                                $this->con_log_pv($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1);
+                                $this->con_log_pv($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送pv",1);
                                 // $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1);
                                 $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1, $gx_jf);
                                 $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送积分",1);
@@ -715,6 +717,125 @@ class Notify
                                 }
 
 
+                            } else {
+                                // 商贸区
+                                /** @var \app\common\repositories\merchant\MerchantRepository $merchant */
+                                $merchant = app()->make(MerchantRepository::class);
+                                $merchantInfo = $merchant->get($store_order_data['mer_id']);
+                                // 1企业2个体3个人
+                                if ($merchantInfo && !empty($store_order_data) && in_array($merchantInfo['type'], [2, 3])) {
+                                    //商家让利部分的拆分
+                                    $ylj_pri = bcmul($concession_pri, 0.3, 2); // 让利部分30%给消费者做养老金
+                                    $pv = bcmul($concession_pri, 0.35, 2); // 35%做业绩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);
+                                    // 购买商贸区赠送贡献值
+                                    $this->con_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送贡献值");
+                                    // 购买商贸区赠送PV值
+                                    $this->con_log_pv($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区赠送PV值");
+                                    // 积分
+                                    $this->score_log($user_data['uid'], $pv, $store_order_data['order_id'], 12, "购买商贸区商品赠送积分");
+
+                                    if ($user_data['spread_uid'] != 0) {
+                                        //查询下单用户上级
+                                        $spread_data = Db::name('user')->where('uid', $user_data['spread_uid'])->find();
+                                        /** @var \app\common\repositories\store\order\StoreOrderRepository $StoreOrderRepository */
+                                        $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']);
+                                        if ($spread_data['user_group'] > 1) {
+                                            $ssf = bcmul($pv, $rate, 2);
+                                            $yj_amount_90 = bcmul($pv, $rate, 2) * 0.9;
+                                            $fgj_amount_10 = bcmul($pv, $rate, 2) * 0.1;//推广者的佣金抽10%到个人复购金
+                                            $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                                            //贡献值
+                                            $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%到个人复购金
+
+                                            $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
+
+                                            //推广佣金
+                                            $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%到个人复购金
+                                            $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']);
+
+                                        //商户获得贡献值  ---- 3月29日  商户不再获得贡献值 改为获得分润值
+                    //                    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无法入库 特此记录！']);
+                                        }
+                                    }
+                                }
                             }
 
                          
@@ -1404,18 +1525,23 @@ class Notify
         return $newList;
     }
 
-    public function con_log_pv($uid, $num, $order_id, $order_type, $mark, $status = -1)
+    public function con_log_pv($uid, $pv, $order_id, $order_type, $mark, $status = -1)
     {
         // 添加pv记录
         $pv_data = [
             "uid" => $uid,
-            "pv" => $num,
+            "pv" => $pv,
             "addtime" => time(),
             "status" => $status,
             "order_type" => $order_type,
             "order_id" => $order_id,
-            "mark" => str_replace('贡献值', 'PV', $mark),
+            "mark" => $mark,
         ];
+        // 当状态为1时是实时结算
+        if($status == 1) {
+            Db::name('user')->where('uid', $uid)->inc('pv', (float)$pv)->update();
+            $pv_data['settlement_time'] = date('Y-m-d H:i:s');
+        }
         Db::name("user_pv_log")->insert($pv_data);//添加pv记录
     }
 
@@ -1443,10 +1569,6 @@ class Notify
                     Db::name('user')->where("uid",$uid)->update(['per_contribute'=>$con_data['per_contribute'] + $num]);
                 }
 
-                if($pv > 0){
-                    Db::name('user')->where("uid", $uid)->update(['pv' => $con_data['pv'] + $pv]);
-                }
-
                 //if(count($spread_data) > 0){
                     // $all_ids = [];
                     // foreach($spread_data as $k=>$v){