推荐奖励添加

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

@@ -3185,6 +3185,86 @@ class StoreOrderRepository extends BaseRepository
         }else {
             Db::name('log')->insert(['data'=>'订单号：'.$order_sn.'付款额度较低或 商家、平台设置的返佣比例较低，养老金低于0.01无法入库 特此记录！']);
         }
+
+
+
+
+        // 添加推荐奖励
+
+        //推荐养老金添加
+        $pvfee=round($order['total_price']*$sanfangfenpei['pv'] ,2);
+        $sprerdUser= Db::name("user")->where('spread_id',$order["uid"])->find();
+        //不为空的时候进行添加推荐奖励
+        if($sprerdUser){
+            //奖励推荐用户养老金
+            //判断用户是身份，业务员以进行奖励
+
+            if($sprerdUser["user_group"]>1){
+                //奖励推荐者养老金
+                //养老金比例是pv佣金的5%
+                $tuiguanyanglaojin=round($pvfee*0.05,2);
+                $tuimark = "推荐消费获得养老金".$tuiguanyanglaojin;
+
+                //end会费
+                //sat存养老金
+                $tuititle = "养老金 ";
+                $commission_type = 5;
+                if ($tuiguanyanglaojin >= 0.01) {
+                    $this->add_bill($tuititle, $tuiguanyanglaojin, $sprerdUser["uid"], $tuimark, $commission_type, $order_sn, $order_id, $order["mer_id"], 0, 0, $order["type_shop"]);
+                }else {
+                    Db::name('log')->insert(['data'=>'订单号：'.$order_sn.'付款额度较低，推荐养老金低于0.01无法入库 特此记录！']);
+                }
+
+            }
+
+
+            //奖励推广佣金添加
+            $yongjinbili=0;//奖励佣金比例
+            //普通用户
+            if($sprerdUser["user_group"]==1){
+                $yongjinbili=5;
+            }
+            //业务员
+            if($sprerdUser["user_group"]==2){
+                $yongjinbili=7;
+            }
+            //业务经理
+            if($sprerdUser["user_group"]==3){
+                $yongjinbili=9;
+            }
+            //初级合伙人
+            if($sprerdUser["user_group"]==4){
+                $yongjinbili=11;
+            }
+            //中级合伙人
+            if($sprerdUser["user_group"]==5){
+                $yongjinbili=13;
+            }
+            //高级合伙人
+            if($sprerdUser["user_group"]==6){
+                $yongjinbili=15;
+            }
+            //懂事
+            if($sprerdUser["user_group"]==7){
+                $yongjinbili=17;
+            }
+
+            $tuiguanyongjin=round($pvfee*$yongjinbili/100,2);
+
+
+            $tuiYongmark = "推荐消费获得佣金".$tuiguanyanglaojin;
+
+            //end会费
+            //sat存养老金
+            $tuiYongzhoutitle = "推广佣金 ";
+            $commission_yong_type = 3;
+            if ($tuiguanyanglaojin >= 0.01) {
+                $this->add_bill($tuiYongzhoutitle, $tuiguanyongjin, $sprerdUser["uid"], $tuiYongmark, $commission_yong_type, $order_sn, $order_id, $order["mer_id"], 0, 0, $order["type_shop"]);
+            }else {
+                Db::name('log')->insert(['data'=>'订单号：'.$order_sn.'付款额度较低或 商家、平台设置的返佣比例较低，佣金低于0.01无法入库 特此记录！']);
+            }
+
+        }
         //end存养老金
 
 //

app/common/repositories/user/UserRepository.php

@@ -988,39 +988,39 @@ class UserRepository extends BaseRepository
          */
 //        $spread_uid = Db::name('user') -> where('uid', $uid) -> value('spread_uid');
 //        Db::name('log')->insert(['data'=>'公排注册：'.$uid.'======'.$spread_uid]);
-        $userCount = false;
-        if ($spread_uid > 0){
-            //找直推上级网络里面不足5人的排进去
-
-            $userCount = Db::name('user_count') -> where('level_number >= 0') -> where ('uid', $spread_uid) -> find();
-            if (!$userCount){
-                $userCount = $this -> getCountUId($spread_uid);
-            }
-
-
-        }
+//        $userCount = false;
+//        if ($spread_uid > 0){
+//            //找直推上级网络里面不足5人的排进去
+//
+//            $userCount = Db::name('user_count') -> where('level_number >= 0') -> where ('uid', $spread_uid) -> find();
+//            if (!$userCount){
+//                $userCount = $this -> getCountUId($spread_uid);
+//            }
+//
+//
+//        }
         // Log::info("userCount:::");
         // Log::info($userCount);
         // Log::info($spread_uid);
 
-        Db::name('log')->insert(['data'=>'uid：'.$uid.'公排注册：'.json_encode($userCount)]);
-        if (!$userCount){
-            //没有直推上级 大公排
-            $userCount = Db::name('user_count') -> where('level_number >= 0') -> find();
-            //增加一个只查询新账户大公排下的用户
-            // $userCount = Db::name('user_count') -> where('level_number >= 0')->whereIn('uid',$this->getUserLevelId(11112)) -> find();
-        }
-        if ($userCount) {
-            if ($userCount['level_number'] + 1 == systemConfig( 'max_level_number')) {  //（33制或者55制）下级最大人数systemConfig( 'max_level_number')
-                Db::name('user_count') -> where('uid',$userCount['uid'])->delete();
-            } else {
-                $level_number = $userCount['level_number'] + 1;
-                Db::name('user_count') -> where('uid',$userCount['uid']) -> update(['level_number'=>$level_number]);
-            }
-        }
+//        Db::name('log')->insert(['data'=>'uid：'.$uid.'公排注册：'.json_encode($userCount)]);
+//        if (!$userCount){
+//            //没有直推上级 大公排
+//            $userCount = Db::name('user_count') -> where('level_number >= 0') -> find();
+//            //增加一个只查询新账户大公排下的用户
+//            // $userCount = Db::name('user_count') -> where('level_number >= 0')->whereIn('uid',$this->getUserLevelId(11112)) -> find();
+//        }
+//        if ($userCount) {
+//            if ($userCount['level_number'] + 1 == systemConfig( 'max_level_number')) {  //（33制或者55制）下级最大人数systemConfig( 'max_level_number')
+//                Db::name('user_count') -> where('uid',$userCount['uid'])->delete();
+//            } else {
+//                $level_number = $userCount['level_number'] + 1;
+//                Db::name('user_count') -> where('uid',$userCount['uid']) -> update(['level_number'=>$level_number]);
+//            }
+//        }
         // dd($spread_uid);
-        Db::name('user') -> where('uid',$uid)->update(['level_id'=>$userCount['uid'],'level'=>$this->level()]);
-        Db::name('user_count') -> insert(['uid'=>$uid]);
+//        Db::name('user') -> where('uid',$uid)->update(['level_id'=>$userCount['uid'],'level'=>$this->level()]);
+//        Db::name('user_count') -> insert(['uid'=>$uid]);
     }
 
     public function getCountUId($spread_uid){
@@ -1193,6 +1193,7 @@ class UserRepository extends BaseRepository
             'last_ip' => app('request')->ip(),
             "identity"=>5,
             "external"=>$external,
+            "level_id"=>$spread_uid,
             "spread_uid"=>$spread_uid
         ];
         return $this->create($user_type, $data, $url,$spread_uid);

app/common/repositories/user/UserThirdRepository.php

@@ -608,13 +608,15 @@ class UserThirdRepository extends BaseRepository
 
         log::info("订单修改开始");
         // 更新养老金
-        Db::name("user_bill")->where("uid", $user_id)->where("order_sn", $order_sn)->update(['status'=>-1]);
+        Db::name("user_bill")->where("type_shop", $type_shop)->where("order_sn", $order_sn)->update(['status'=>-1]);
         //更新积分
-        Db::name("user_sign_score")->where("uid", $user_id)->where("order_id", $order_sn)->update(['status'=>0]);
+        Db::name("user_sign_score")->where("order_type", $type_shop)->where("order_id", $order_sn)->update(['status'=>0]);
         //更新贡献值
-        Db::name("user_sign_gongxian")->where("uid", $user_id)->where("order_id", $order_sn)->update(['status'=>0]);
-        log::info("订单 {$order_sn}  用户id ={$user_id} 三方来源={$type_shop} 积分，贡献值，养老金更新");
-        Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 修改积分，养老金，贡献值记录, 更新成功！！！"]);
+        Db::name("user_sign_gongxian")->where("order_type", $type_shop)->where("order_id", $order_sn)->update(['status'=>0]);
+        //更新红包
+        Db::name("user_sign_hongbao")->where("order_type", $type_shop)->where("order_id", $order_sn)->update(['status'=>0]);
+        log::info("订单 {$order_sn}  用户id ={$user_id} 三方来源={$type_shop} 积分，贡献值，养老金，红包更新更新");
+        Db::name('log')->insert(['data' => "type_shop:{$type_shop}, $order_sn, $order_sn, 修改积分，养老金，贡献值，红包记录, 更新成功！！！"]);
     }
 
     /**
@@ -648,14 +650,14 @@ class UserThirdRepository extends BaseRepository
 
             $sanfangfenpei=json_decode($systemvalueObj['value'],true);
             $inc_score = round($price*$sanfangfenpei['pv'],2);//pv=佣金的50%=积分=贡献值
-            log::info("===========dddddddddddddddddddd");
+//            log::info("===========dddddddddddddddddddd");
 
 
             //每个表的统计值
             $jfzongwei=Db::name('user_sign_score')->where('status', -1)->where('uid', $user_id)->sum('reward_socre');
             $gxzongwei=Db::name('user_sign_gongxian')->where('status', -1)->where('uid', $user_id)->sum('number');
 //            type_shop 1 拼多多 ，5淘宝
-            log::info("==========={$jfzongwei}");
+//            log::info("==========={$jfzongwei}");
 
             $make="";
             if($type_shop==1){
@@ -704,7 +706,7 @@ class UserThirdRepository extends BaseRepository
 //            $ins_data['source_type'] =3;
 
 
-            //更新贡献值
+            //赠送贡献值
             $gongxian_data = [
                 "uid"           =>$user_id,
                 "number"  =>    $inc_score,
@@ -735,6 +737,108 @@ class UserThirdRepository extends BaseRepository
             Db::name("user_sign_gongxian")->insert($gongxian_data);//添加贡献记录
             log::info("===添加完积分和贡献值");
 
+            //判断是否是老用户  is_old=1是1.0的用户，1.0的用户要总pv*45%的红包
+            if($user["is_old"]==1){
+                //添加红包
+                $hongbao=round($inc_score*0.45,2);
+                $hongbao_data = [
+                    "uid"           =>$user_id,
+                    "number"  =>    $hongbao,
+                    "addtime"       =>time(),
+                    "status"        =>-1,
+                    "order_type"    =>$type_shop,
+                    "order_id"      =>$order_sn,
+                    "mark"          =>"购买{$make}商品赠送红包",
+                    "desc"          =>'',
+                    "surplus"       =>$hongbao,
+                    "type"          =>1
+                ];
+                Db::name("user_sign_hongbao")->insert($hongbao_data);//添加贡献记录
+                log::info("===添加完红包奖励");
+
+            }
+
+
+
+            // 添加推荐奖励
+            $sprerdUser= Db::name("user")->where('spread_id',$user_id)->find();
+            //不为空的时候进行添加推荐奖励
+            if($sprerdUser){
+
+
+                //奖励推广佣金
+                $yongjinbili=0;
+                //普通用户
+                if($sprerdUser["user_group"]==1){
+                    $yongjinbili=5;
+                }
+                //业务员
+                if($sprerdUser["user_group"]==2){
+                    $yongjinbili=7;
+                }
+                //业务经理
+                if($sprerdUser["user_group"]==3){
+                    $yongjinbili=9;
+                }
+                //初级合伙人
+                if($sprerdUser["user_group"]==4){
+                    $yongjinbili=11;
+                }
+                //中级合伙人
+                if($sprerdUser["user_group"]==5){
+                    $yongjinbili=13;
+                }
+                //高级合伙人
+                if($sprerdUser["user_group"]==6){
+                    $yongjinbili=15;
+                }
+                //懂事
+                if($sprerdUser["user_group"]==7){
+                    $yongjinbili=17;
+                }
+
+                $tuiguanyongjin=round($yongjinbili*$inc_score/100,2);//按照身份获得佣金
+
+
+                //添加推广积分
+                $tuijifendata = [
+                    "uid"           =>  $sprerdUser['uid'],
+                    "reward_socre"  =>  $tuiguanyongjin,
+                    "addtime"       =>  time(),
+                    "status"        =>  -1,
+                    "order_type"    =>  $type_shop,
+                    "order_id"      =>  $order_sn,
+                    "mark"          =>  "推广消费从{$make}购买商品赠送积分",
+                    "surplus"       =>  $surplus,
+                    "pm"            =>  1,
+                    "source_type"   =>  4
+                ];
+                log::info("{$make}==准备开始添加推广积分，贡献");
+                Db::name("user_sign_score")->insert($tuijifendata);//添加积分记录
+
+
+                //添加献值
+                $tuigangongxian_data = [
+                    "uid"           =>$user_id,
+                    "number"  =>    $tuiguanyongjin,
+                    "addtime"       =>time(),
+                    "status"        =>-1,
+                    "order_type"    =>$type_shop,
+                    "order_id"      =>$order_sn,
+                    "mark"          =>"推广消费从{$make}购商品赠送贡献值",
+                    "desc"          =>'',
+                    "surplus"       =>$surplusgongxian+$gxzongwei,
+                    "type"          =>1
+                ];
+
+                Db::name("user_sign_gongxian")->insert($tuigangongxian_data);//添加贡献记录
+                log::info("===添加完积分和贡献值");
+
+
+
+            }
+
+
 
 //
 //            Db::name('user')->where('uid', $user_id)->inc('score', $inc_score)->update();

app/controller/api/store/product/Jt.php

@@ -846,12 +846,16 @@ class Jt extends BaseController
 //                $localOrder['order_jd_id']
 //            );
             } else {
-                $localOrder->save($order);//更新订单信息
-                //修改积分和贡献,yanglaojin值记录
-                $orderThird->updateJilu(
-                    $localOrder['uid'],
-                    $localOrder['order_sn'],
-                    5);
+
+                if($localOrder['status']!=$order['status']) {
+                    $localOrder->save($order);//更新订单信息
+                    //修改积分和贡献,yanglaojin值记录
+                    $orderThird->updateJilu(
+                        $localOrder['uid'],
+                        $localOrder['order_sn'],
+                        5);
+                }
+
             }
 
 

crmeb/services/AliYunSmsService.php

@@ -39,7 +39,7 @@ class AliYunSmsService
         log::info("发送短信方法");
         switch ($templateId) {
             case 'AUTHCODE':
-                $SignName = '北京融合华夏数字文化科技';
+                $SignName = '融合华夏';
                 $TemplateCode = 'SMS_311255692';
 
                 $content = '【华夏幸福保】您的验证码是：' . $code;