Browse Source

滑落条件修改,在原基础上,加上返佣金额

lizhen_gitee 1 year ago
parent
commit
db4ef54940
2 changed files with 15 additions and 2 deletions
  1. 10 1
      application/admin/controller/user/User.php
  2. 5 1
      application/common/library/Auth.php

+ 10 - 1
application/admin/controller/user/User.php

@@ -204,11 +204,20 @@ class User extends Backend
         $user_score = Db::name('user_wallet')->where('score','gt',0)->column('user_id,score');
         //dump($user_score);
 
+        //各个用户的推荐返佣总额
+        $user_fanyong = [];
+        $user_score_log = Db::name('user_score_log')->field('user_id,sum(change_value) as sum_change_value')->where('log_type',3)->group('user_id')->select();
+        foreach($user_score_log as $log){
+            $user_fanyong[$log['user_id']] = $log['sum_change_value'];
+        }
+
         //找出那个超出2倍的
         $special_user = [];
         foreach($user_score as $user_id => $score){
             $user_pay_money = isset($user_pay[$user_id]) ? $user_pay[$user_id] : 0;
-            if($score > $user_pay_money * 2){
+            $user_fanyong_money = isset($user_fanyong[$user_id]) ? $user_fanyong[$user_id] : 0;
+
+            if($score > ($user_pay_money + $user_fanyong_money) * 2){
                 $special_user[] = $user_id;
             }
         }

+ 5 - 1
application/common/library/Auth.php

@@ -586,7 +586,11 @@ class Auth
 
         $score = model('wallet')->getWallet($this->id,'score');//积分
 
-        if($score >= $order_price_sum*2){
+        //推荐返佣总额
+        $fanyong_sum = Db::name('user_score_log')->where('user_id',$this->id)->where('log_type',3)->sum('change_value');
+        $fanyong_sum = $fanyong_sum ?: 0;
+
+        if($score >= ($order_price_sum + $fanyong_sum)*2){
             return true;
         }