php/app/controller/api/store/merchant/Taskorder.php

<?php
/**
 * @package merchant
 * @Author: Qinii
 * @Date: 2020/5/28
 */
namespace app\controller\api\store\merchant;

use think\App;
use crmeb\basic\BaseController;
use app\common\repositories\system\merchant\MerchantRepository as repository;
use think\facade\Db;
use think\facade\Log;
use function Symfony\Component\VarDumper\Dumper\esc;

class Taskorder extends BaseController
{

//添加贡献值日志
    public function con_log($uid,$num,$order_id,$order_type,$mark){

        $con_data = Db::name('user')->where("uid",$uid)->find();

        $con = [
            'uid'=>$uid,
            'number'=>$num,//赠送数量
            'status'=>1,//红包状态
            'mark'=>$mark,//备注
            'desc'=>'',//描述
            'order_id'=>$order_id,//订单id
            'surplus'=> $con_data['contribute'],//剩余
            'order_type'=>$order_type,//订单类型
            'type'=>1,//1增加，2消耗
            'settlement_time'=>date('Y-m-d H:i:s'),
            'addtime'=>time()
        ];

        Db::name('user_sign_gongxian')->insert($con);
    }

//添加积分日志
    public function score_log($uid,$num,$order_id,$order_type,$mark){

        $score_data = Db::name('user')->where("uid",$uid)->find();

        $score = [
            'uid'=>$uid,
            'continuity_day'=>0,//连续签到天数
            'reward_socre'=>$num,//积分数量
            'signin_time'=>0,//签到时间
            'source_uid'=>0,//赠送积分用户来源id
            'status'=>1,//积分状态1:有效，0:失效,1:待确认
            'mark'=> $mark,//备注
            'order_id'=>$order_id,//订单id
            'pm'=>1,//1收入，2支出
            'surplus'=> $score_data['score'],//剩余
            'order_type'=>$order_type,//订单类型 ,10精彩生活区，11会员区，12复购区
            'source_type'=>3,//积分类型，1签到，2分享好友注册赠送，3自己下单赠送

            'settlement_time'=>date('Y-m-d H:i:s'),
            'addtime'=>time()
        ];

        Db::name('user_sign_score')->insert($score);
    }

    //添加推广佣金/养老金日志(养老金金额)
    public function bill_user_log($uid,$num,$order_id,$comm_order_type,$order_sn,$mark,$merid,$ds=1){

        $con_data = Db::name('user')->where("uid",$uid)->find();
        $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'=>3,//养老金是否已进入公证处log表0：未进入。1：已进入
            'take_time'=>'',//结算时间
            'district_id'=>'',//
            'street_id'=>'',//
            'month'=>'',//月份


        ];

        Db::name('user_bill')->insert($bill);
    }

    //添加复购金
    public function fugou_user_log($uid,$num,$order_id,$type_inc_des){

        $bill = [
            'uid'=>$uid,
            'number'=>$num,//数量
            'status'=>1,//复购金状态1-有效 0-失效 -1待确认
            'mark'=>"复购金",//备注
            'desc'=>"抽取佣金的10%作为复购金",//描述
            'order_id'=>$order_id,//订单id
            'surplus'=>0,//剩余
            'order_type'=>11,//关联订单ID
            'type'=>$type_inc_des,//复购金类型 :1赠送，2消耗
            'settlement_time'=>date('Y-m-d H:i:s'),//添加时间,
            'addtime'=>time(),
        ];

        Db::name('user_sign_fugou')->insert($bill);
    }


    public function lst(){




        $ss = $this->dis_of(6511,'wx1737991777789524830');

        var_dump($ss);

        return;

        // $group_order_id = "wx1737599771117429170";
        $group_order_id = "wx1737801399090353840";


        $group_order = Db::name('store_group_order')->where('group_order_sn',$group_order_id)->find();

        //分配逻辑
        $store_order_data = Db::name('store_order')->where('group_order_id',$group_order['group_order_id'])->find();

        //找到对应的商品id(product_id)
        $store_order_product_data = Db::name('store_order_product')->where('order_id',$store_order_data['order_id'])->find();
        //找到对应的商品让利金额或比例
        $store_product_data = Db::name('store_product')->where('product_id',$store_order_product_data['product_id'])->find();
        //下单用户
        $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find();


        //$concession_pri = $store_product_data['concession_pri'];//商家让利金额
        $concession_pri = 100;//商家让利金额

        $pv = 0; //待分配的PV
        $spread_uid = 0;//下单用户上级uid





        if($store_order_data['mer_id'] == 439){
            //var_dump(123);return;

            //分配参数
            $job_par = [];
            if(!empty($store_order_data)){
                $job_par = json_decode($store_order_data['fzone_paytype'], true);
                //if($job_par['note'] == "现金"){
                //普通消费者
                $ylj_pri = round($concession_pri * 0.3,2);
                $pv = round($concession_pri * 0.35,2);

                //分配养老金给消费者
                $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
                //分配积分和贡献值给消费者
                $con = $user_data['contribute'] + $pv;
                $score = $user_data['score'] + $pv;



                Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,"contribute"=>$con,"score"=>$score]);

                $this->bill_user_log($user_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.03,2),$store_order_data['mer_id']);
                $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,"购买精彩生活商品赠送积分");

                //给推广者分配养老金
                //给推广者分配佣金
                if($user_data['spread_uid'] != 0){
                    //查询下单用户上级身份
                    $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();

                    //业务员或以上的推荐人等级
                    //user_group=1是消费者 3%，2:业务员 5%，3:业务经理7%，4:初级合伙人9%，5:中级合伙人11%,6:高级合伙人13%，7：董事15%
                    if($spread_data['user_group'] > 1){

                        // $ylj_amount = $spread_data['annuity'] + round($pv * 0.05,2);
                        // //var_dump($ylj_amount);return;
                        // $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->update(['annuity'=>$ylj_amount]);

                        // //根据不同级别分配不同的佣金
                        // //user_group=1是消费者 3%，2:业务员 5%，3:业务经理7%，4:初级合伙人9%，5:中级合伙人11%,6:高级合伙人13%，7：董事15%
                        // //给推广者分配佣金
                        // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.03,2);
                        // $ylj_amount = $spread_data['annuity'] + round($pv * 0.03,2);

                        // Db::name('user')->where('uid',$user_data['spread_uid'])->update(['brokerage_price'=>$yj_amount]);
                        // Db::name('user')->where('uid',$user_data['spread_uid'])->update(['annuity'=>$ylj_amount]);


                        // //给推广者分配佣金
                        $yj_amount = 0;
                        $ylj_amount = $spread_data['annuity'] + round($pv * 0.05,2);
                        $ssf = 0;//变量

                        if($spread_data['user_group'] == 2){
                            $ssf =round($pv * 0.07,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.07,2);
                            $score     = $spread_data['score'] + round($pv * 0.07,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.07,2);
                            // var_dump($pv);
                            // var_dump(round($pv * 0.07,2));
                            //  var_dump(round($pv * 0.07,2));
                            //  var_dump(round($pv * 0.07,2));return;


                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }else if($spread_data['user_group'] == 3){
                            $ssf =round($pv * 0.09,2);
                            var_dump($ssf);return;

                            $con       = $spread_data['contribute'] + round($pv * 0.09,2);
                            $score     = $spread_data['score'] + round($pv * 0.09,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.09,2);
                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }else if($spread_data['user_group'] == 4){
                            $ssf =round($pv * 0.11,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.11,2);
                            $score     = $spread_data['score'] + round($pv * 0.11,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.11,2);
                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }else if($spread_data['user_group'] == 5){
                            $ssf =round($pv * 0.13,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.13,2);
                            $score     = $spread_data['score'] + round($pv * 0.13,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.13,2);
                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }else if($spread_data['user_group'] == 6){
                            $ssf =round($pv * 0.15,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.15,2);
                            $score     = $spread_data['score'] + round($pv * 0.15,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.15,2);
                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }else if($spread_data['user_group'] == 7){
                            $ssf =round($pv * 0.17,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.17,2);
                            $score     = $spread_data['score'] + round($pv * 0.17,2);
                            $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.17,2);
                            Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yj_amount,'annuity'=>$ylj_amount]);
                        }
                        var_dump($ssf);
//贡献值
                        $this->con_log($spread_data['uid'],$ssf,$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
//积分
                        $this->score_log($spread_data['uid'],$ssf,$store_order_data['order_id'],11,"推广会员专区商品赠送积分");
// //推广佣金
                        $this->bill_user_log($spread_data['uid'],$ssf,$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.$ssf,$store_order_data['mer_id']);

                        $this->bill_user_log($spread_data['uid'],round($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']);
                    }

                    //普通用户推广人
                    if($spread_data['user_group'] == 1){

                        //给推广者分配佣金
                        $ylj_amount = $spread_data['annuity'] + round($pv * 0.3,2);
                        $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.03,2);


                        Db::name('user')->where('uid',$spread_data['uid'])->update(['annuity'=>$ylj_amount]);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['brokerage_price'=>$yj_amount]);

                        $con = $spread_data['contribute'] + round($pv * 0.03,2);
                        $score = $spread_data['score'] + round($pv * 0.03,2);
                        var_dump(round($pv * 0.3,2));
                        var_dump( round($pv * 0.03,2));
                        // float(168.05)
                        // float(2.95)


                        //贡献值和积分
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['annuity'=>$ylj_amount_mine,"contribute"=>$con,"score"=>$score]);

                        //推广养老金
                        $this->bill_user_log($spread_data['uid'],round($pv * 0.3,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'推广获得养老金'.round($pv * 0.3,2),$store_order_data['mer_id']);
                        //推广佣金
                        $this->bill_user_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.03,2),$store_order_data['mer_id']);
                        $this->con_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        $this->score_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");

                    }

                }

                //锁客收益
                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)){
                        $merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.05,2);

                        Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$merchant_amount]);
                        //推广佣金
                        $this->bill_user_log($merchant_data['uid'],round($pv * 0.05,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.05,2),$store_order_data['mer_id']);

                    }

                }


                //}
                //var_dump($ylj_amount);
            }

            //VIP专区
        }else if($store_order_data['mer_id'] == 496){


            //业务员和以上推广的等级获得推广佣金
            $le_yw_amount = 0;
            //获赠的贡献值和积分
            $gx_jf = 0;
            $yj1 = 0;
            if($store_product_data['price'] == 1180){
                $pv = 1000;
                $gx_jf = 700;
                $yj1 = 100;
                $le_yw_amount = 300;
            }else if($store_product_data['price'] == 10620){
                $pv = 9000;
                $gx_jf = 6300;
                $yj1 = 900;
                $le_yw_amount = 2700;
            }else if($store_product_data['price'] == 11800){
                $pv = 10000;
                $gx_jf = 7000;
                $yj1 = 1000;
                $le_yw_amount = 3000;
            }else if($store_product_data['price'] == 9440){
                $pv = 8000;
                $gx_jf = 5600;
                $yj1 = 800;
                $le_yw_amount = 2400;
            }else if($store_product_data['price'] == 2360){
                $pv = 2000;
                $gx_jf = 1400;
                $yj1 = 200;
                $le_yw_amount = 600;
            }

            $ylj_pri = round($pv * 0.035,2);
            //$pv = round($pv * 0.35,2);

            //分配养老金给消费者
            //普通用户获取贡献值和pv3.5%养老金和积分
            $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
            $gxz_amount_mine = $user_data['contribute'] + $gx_jf;
            $jf_amount_mine = $user_data['score'] + $gx_jf;


            Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,'contribute'=> $gxz_amount_mine,'score'=> $jf_amount_mine]);

            $this->bill_user_log($user_data['uid'],round($pv * 0.35,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.35,2),$store_order_data['mer_id']);

            $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值");
            $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送积分");

            //给推广者分配养老金
            //给推广者分配佣金
            if($user_data['spread_uid'] != 0){
                //查询下单用户上级身份
                $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();

                //user_group=1是消费者，2:业务，3:业务经理，4:初级合伙人，5:中级合伙人,6:高级合伙人，7：董事
                //业务或以上等级推广人
                //获得养老金、佣金、贡献值和积分
                if($spread_data['user_group'] > 1){


                    $con =0;//贡献值
                    $score = 0;//积分
                    //养老金
                    $uer_bill = $spread_data['annuity'] + round($pv * 0.035,2);
                    //$yongjin = $spread_data['brokerage_price'] + $le_yw_amount;

                    $yj_amount_90 = $le_yw_amount * 0.9;
                    $fgj_amount_10 = $le_yw_amount * 0.1;//推广者的佣金抽10%到个人复购金

                    $yongjin = $spread_data['brokerage_price'] + $yj_amount_90;
                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;




                    if($spread_data['user_group'] == 2){

                        $con = $spread_data['contribute'] + round($pv * 0.07,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.07,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");

                    }else if($spread_data['user_group'] == 3){
                        $con = $spread_data['contribute'] + round($pv * 0.09,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.09,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 4){
                        $con = $spread_data['contribute'] + round($pv * 0.11,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.11,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 5){
                        $con = $spread_data['contribute'] + round($pv * 0.13,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.13,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");

                    }else if($spread_data['user_group'] == 6){
                        $con = $spread_data['contribute'] + round($pv * 0.15,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.15,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 7){
                        $con = $spread_data['contribute'] + round($pv * 0.17,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.17,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }



                    //养老金
                    $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
                    //佣金
                    $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']);
                    //复购金
                    // $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);
                }

                //普通的用户推广人
                if($spread_data['user_group'] == 1){

                    //获取贡献值和积分和佣金
                    $gx_jf = $spread_data['contribute'] + round($pv * 0.03,2);

                    //$yj111 = $spread_data['brokerage_price'] + $yj1;

                    $yj_amount_90 = round($pv * 0.9,2);
                    $fgj_amount_10 = round($pv * 0.1,2);//推广者的佣金抽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);
                    var_dump(  $pv);
                    var_dump(  $yj_amount_90);
                    Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $gx_jf,'score'=> $gx_jf,'brokerage_price'=> $yj_amount,'fugou'=>$fgj_amount]);
                    $this->con_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                    $this->score_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");
                    //推广佣金
                    $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']);

                }




            }
            //锁客收益
            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)){
                    $merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.35,2);

                    Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$merchant_amount]);
                    //推广佣金
                    $this->bill_user_log($merchant_data['uid'],round($pv * 0.35,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.35,2),$store_order_data['mer_id']);
                }

            }


        }


//利润分配 end

    }


    public function lst1()
    {

        // $user_datas = Db::name("user")->select();//星级等级
        // foreach($user_datas as $k=>$v){
        //     if($v['user_level_id_old']==2){
        //         Db::name("user")->where("uid",$v['uid'])->update(["user_group"=>2]);
        //     }else if($v['user_level_id_old']==4){
        //         Db::name("user")->where("uid",$v['uid'])->update(["user_group"=>3]);
        //     }
        // }


        // return;

        // $store_product_datas = Db::name('old_user_of_goods_old')->select();

        $week_record = 45500 + 1400;




        $stock_comm = round($week_record * 0.05 ,2);


        // $team_small_big_amount = $this->getbig_samll_datas(17);//下标0是大部门，下标1是小部门
        // var_dump($team_small_big_amount);return;


        //获取股权分红的人

        // $GetAllUserPackNum = db::name("old_user_stock")->sum("pack");//计算所有用户的份数总和

        // $stockuserdatas = db::name("old_user_stock")->select();//获取所有用户

        // if(count($stockuserdatas) > 0){
        //   $one_pack_comm_data = round($stock_comm / $GetAllUserPackNum,2);//获取每份的单佣金

        //     foreach ($stockuserdatas as &$v) {
        //           $v['getcomm'] = $v['pack'] * $one_pack_comm_data;
        //           $v['allgetcomm'] =  $v['allgetcomm'] + $v['getcomm'];
        //           $v['update_time'] = time();

        //           // 更新 user_stock 表中的记录
        //           $res = db::name("old_user_stock")->where("id", $v['id'])->update([
        //               'getcomm' => $v['getcomm'],
        //               'allgetcomm' => $v['allgetcomm'],
        //               'update_time' => $v['update_time']
        //           ]);

        //           $res1 = Db::name("user")->where("id",$v['user_id'])->inc("total_amount_old",$v['getcomm'])->save();
        //           $res2 = Db::name("user")->where("id",$v['user_id'])->inc("amount_old",$v['getcomm'])->save();

        //        $res =true;
        //           if($res){
        //               $das = $this->change_user_log($v['user_id'],'amount_old',1,$v['getcomm'],"member_award_stock","股权分红入账"."-".$v['pack']);//释放佣金

        //                 //入账星级分红记录表
        //               $week_data = [];
        //               $week_data['user_id'] =  $v['user_id'];
        //               $week_data['user_star_id'] =  0;
        //               $week_data['award_num'] =  0;
        //               $week_data['award_num_sm'] =  0;
        //               $week_data['remark'] =  "股权分红主动执行";
        //               $week_data['week_record'] =  $week_record;
        //               $week_data['all_amount'] =  $stock_comm;
        //               $week_data['radio'] =  2;
        //               $week_data['owner_bill'] =  0;  //总流水金额
        //               $week_data['my_bill'] = 0;  //我的流水
        //               $week_data['create_time'] = time();


        //               Db::name("old_user_weekaward")->insert($week_data);

        //$this->bill_user_log111111($v['user_id'],"股权分佣", $stock_comm,"股权明细入账");//股权分佣明细2.0系统
        //           }

        //     }
        //   }

        //股权分红 end



        //var_dump($week_record);die;//9912  8400
        //$star_list = Db::name("user_star")->order("statement_all_num desc")->select()->toArray();//旧星级等级
        $star_list = Db::name("old_user_starlevel")->order("statement_all_num desc")->select()->toArray();//星级等级

        $sales_arr = [];
        foreach ($star_list as $key => $value) {
            # code...
            $star_data = [];
            $star_data['profit_rate'] = $value['profit_rate'];
            $star_data['divider_people'] = [];
            $star_data['title'] = $value['title'];
            $sales_arr[$value['id']] = $star_data;
        }



        $list = Db::name("user")->where("user_level_id_old", "IN", [4,6])->where("status","<>",0)->select()->toArray();
        //var_dump($list);

        foreach ($list as $key => $value) {
            # code...
            $sales_incentive = $this->getStarLevel($value['uid']);//获取个人共建联盟和个人联盟所有金额,来对比星级联盟列表中处于那个阶段的 用户星级
            //var_dump( $sales_incentive);return;
            //这里的意思是将user_starlevel表中新增一个键名为divider_people，然后把符合当前合伙人级别的id都装进去
            //分红比例
            $rate_sales = isset($sales_incentive['profit_rate']) ? $sales_incentive['profit_rate'] :0; //profit_rate是分红的比例
            if($rate_sales > 0) {
                // var_dump($sales_incentive['title']);
                $sales_arr[$sales_incentive['id']]['divider_people'][] = $value['uid']; //$value['id']是自己的userid，$sales_incentive['id']是对应的合伙人级别id
                //$output->writeln('执行用户id-'.$value['id']);

                //      $aa = db::name("user")->where("uid",$value['uid'])->find();

                //   $sales_arr[$sales_incentive['id']]['divider_people_kkkkkkkkkkkkkkkkk'][] = "ID:" . $value['uid'] . " 昵称:" .$aa['user_name'] . " 姓名:" . $aa['uname_old'];


                //   if($sales_incentive['title'] == "初级"){
                //   // var_dump( $value['uid'] );
                //         // if($v['user_level_id_old']==2){
                //              Db::name("user")->where("uid",$value['uid'])->update(["user_group"=>4]);
                //          //}
                //   }
            }
        }
        //return;
        // var_dump($sales_arr);return;
        //移动指定ID
        // 要移动的ID数组
        // echo "以下是移动后的数组";
// 要移动的ID数组
        $ids_to_remove_from_junior = array(12, 69, 144); // 从初级中移除的ID
        $ids_to_remove_from_intermediate = array(49); // 从中级中移除的ID

// 查找初级并获取其divider_people
        $junior = &$sales_arr[1]['divider_people']; // 使用引用，以便直接修改数组

// 查找中级并获取其divider_people
        $intermediate = &$sales_arr[2]['divider_people']; // 使用引用，以便直接修改数组

// 从初级的divider_people中移除特定的ID
        foreach ($ids_to_remove_from_junior as $id) {
            $key = array_search($id, $junior);
            if ($key !== false) {
                unset($junior[$key]); // 移除初级中的特定ID
            }
        }

// 从中级的divider_people中移除特定的ID
        foreach ($ids_to_remove_from_intermediate as $id) {
            $key = array_search($id, $intermediate);
            if ($key !== false) {
                unset($intermediate[$key]); // 移除中级中的特定ID
            }
        }

// 重置数组的索引，因为unset会留下空位
        $sales_arr[1]['divider_people'] = array_values($junior);
        $sales_arr[2]['divider_people'] = array_values($intermediate);






//var_dump($sales_arr);return; //把初级中的   id是 12,69, 144从初级中去掉 ,id是49，从中级中去掉

        //移动指定ID_end

        // var_dump($sales_arr);die;
        //$sales_arr获取分红的id和分红的比例





        //执行分开发放
        foreach($sales_arr as $key =>$value) {
            //比如这个周的总业绩是 8400
            $sales_arr[$key]['fs_money_nums'] = round($week_record * $value['profit_rate']/100,2);//周总业绩(8400) * 合伙人级别的分佣比例(15%) = 可分红的佣金(1260)

            //可分红的业绩(分为两半，各50%，一部分是分给双联盟比例，一部分是小业绩比例)
            $sales_arr[$key]['fs_money'] = round($sales_arr[$key]['fs_money_nums']/2,2);//把本周的业绩(8400) * 合伙人级别的分佣比例(15%) * 0.5 = 630（可分红佣金的 50%）
            $people_moneys = 0;//当前合伙人级别双联盟总业绩

            $user_pv_min = 0;//合伙人大小区业绩，其中少的

            foreach ($value['divider_people'] as $k => $v) {
                # code... 统计总双联盟流水
                $user_pv_nums = $this->getPerformanceOf($v);//这里的$v是当前这个级别包含的userid,比如现在这个中级，的divider_people包含17,39两个uerid

                //$datauser = db::name("user")->where("id",$v)->find();


                //var_dump($user_pv_nums);
                //die;//337400


                // var_dump("id:" . $v ." 用户:".$datauser['user_name']." 双区总业绩:" . $user_pv_nums);
                $people_moneys += $user_pv_nums;



                $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组，下标0是最小的值(业绩小的)，下标1是最大的值(业绩大的)

                //  var_dump("id:" . $v ." 用户:".$datauser['user_name']." 小区总业绩:" . $user_pv_small_num[0]);
                $user_pv_min += $user_pv_small_num[0];


            }
            //同级所有合伙人双联盟总业绩
            $sales_arr[$key]['owner_bill'] = $people_moneys;//当前级别所有的人的双联盟业绩(17和39都是中级合伙人，17的双区业绩是:337400  +  39的双区业绩是:189700 = 431032)
            //同级合伙人所有少的业绩总和
            $sales_arr[$key]['small_bill'] =$user_pv_min;//获取大小区业绩中，业绩少的部分，并将该级别的合伙人业绩最小的那部分全部加起来(17的大区业绩是 337400,小区业绩是 110110，
            //所以他的业绩小的是 110110,39的大区业绩是 189700，小区业绩是 53200，所以他的业绩小的是 53200，我们把该级别所有合伙人的小的那部分业绩加起来的和是 153300)
        }
        //die;

        //计算权重金额 只执行一次

        //执行分红
        foreach ($sales_arr as $key => $value) {
            # code...
            $amont = $value['fs_money'];//可分红的总佣金，分红佣金的一半,中级合伙61.95
            $fs_money_nums = $value['fs_money_nums'];//中级合伙人级别，可分红的总佣金
            $owner_bill = $value['owner_bill'];//当前级别合伙人下面所有的双联盟业绩
            $small_ow_bill = $value['small_bill'];//当前级别合伙人下面所有的小区(业绩小的部分)总业绩

            //执行分红
            if(count($value['divider_people']) <= 0 ) {
                continue;
            }

            // $every_award  = round( $amont/count($value['divider_people']),2);//比如当前为中级，中级有两个人 17和39.那么可分红的佣金是61.95（可分红佣金的50%），两个人平均分，每一份就是30.975
            // if($every_award  == 0) {
            //     continue;
            // }

            //每人分红金额
            foreach ($value['divider_people'] as $v) {
                // var_dump($v);
                // $in_money = $every_award;
                //个人双区总佣金 权重 计算
                $my_bill = $this->getPerformanceOf($v);//比如uerid是12，他的双区总业绩就是287742

                //中级合伙人。userid=17可以分到双区可分红的金额
                $my_weight_money = round($amont * ($my_bill/$owner_bill),2);//可分红的佣金 * (中级合伙人个人的双区总业绩 / 当前等级所有合伙人的双联盟业绩) = 当前用户可以获取到的分红佣金(双区联盟总业绩加权佣金),287742 * (61.95/431032)=41.36

                //个人小区(佣金少的一部分) 权重 计算权重
                $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组，下标0是最小的值(业绩小的)，下标1是最大的值(业绩大的)
                $my_mix_money = round($amont * ($user_pv_small_num[0]/$small_ow_bill),2);

// var_dump("当前级别合伙人双联盟总业绩:" . $owner_bill);
// var_dump("当前级别合伙人小区总业绩:".$small_ow_bill);
// var_dump("当前级别合伙人可分红佣金:" .$amont);
// var_dump("当前级别合伙人可分红总佣金:" .$fs_money_nums);



                //$datauser = db::name("user")->where("uid",$v)->find();
//var_dump("uid:" . $v ." 用户:".$datauser['user_name']." 可获得双区分红佣金:" . $my_weight_money);//可获得的双区分红佣金
//var_dump("uid:" . $v ." 用户:".$datauser['user_name']." 可获得的小区分红佣金:" . $my_mix_money);//可获得的小区(业绩小的部分)分红佣金

                // $in_money += $my_weight_money;
                // var_dump("//////");

//die;
                # code...
                $all_award = $my_weight_money + $my_mix_money;

                # code...
                // $res = Db::name("user")->where("id",$v)->inc("total_amount_old",$all_award)->save();

                //Db::name("user")->where("uid",$v)->inc("amount_old",$all_award)->save();//不用冻结金额和提现额度来限制佣金发放

                //$this->releaseTobeAmount1($v,$all_award,$output);//根据冻结金和提现额度来计算佣金的发放

                //if($res) {
                $this->change_user_log($v,'amount_old',1,$all_award,"member_award","星级分红入账"."-".$value['title']);//释放佣金
                //入账星级分红记录表
                $week_data = [];
                $week_data['user_id'] =  $v;
                $week_data['user_star_id'] =  $key;
                $week_data['award_num'] =  $my_weight_money;
                $week_data['award_num_sm'] =  $my_mix_money;
                $week_data['remark'] =  "星级分红主动执行:" . $all_award;
                $week_data['week_record'] =  $week_record;
                $week_data['all_amount'] =  $fs_money_nums;
                $week_data['radio'] =  2;
                $week_data['owner_bill'] =  $owner_bill;  //总流水金额
                $week_data['my_bill'] = $my_bill;  //我的流水
                $week_data['create_time'] = time();


                Db::name("old_user_weekaward")->insert($week_data);


                $this->bill_user_log111111($v,"合伙人分佣",$all_award,"合伙人分佣明细入账");//联创分佣明细2.0系统

                //}
            }

        }

        // $output->writeln('星级奖励发放成功');
    }

//上上周和上上上周weeksage:2上上周，3是上上上周
// public function getWeekStartEnd($weeksAgo = 2)
// {
//      $now = time();
//     // 计算指定周次的周一 00:00 的时间戳
//     $mondayStart = strtotime('last Monday', strtotime('-' . $weeksAgo . ' weeks', $now));
//     if (date('w', $mondayStart) != 1) {
//         // 如果计算出的周一不是周一（即当天不是周一），则调整到正确的周一
//         $mondayStart = strtotime('last Monday', $mondayStart);
//     }
//     // 计算指定周次的周日 23:59:59 的时间戳
//     $sundayEnd = strtotime('next Sunday', $mondayStart) + 86399 - 1;

//     return [$mondayStart, $sundayEnd];
// }

    //添加平台分佣2.0系统收益明细日志(养老金金额)
    public function bill_user_log111111($uid,$name,$num,$mark){

        $con_data = Db::name('user')->where("uid",$uid)->find();
        //如果是会员专区就即刻到账

        Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]);


        $bill = [
            'uid'=>$uid,
            'link_id'=>0,//关联订单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'=>1,//0待确定，1有效，-1无效
            'commission_type'=>8,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
            //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
            //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
            'order_sn'=>0,//订单号
            'tripartite'=>0,//
            'type_shop'=>0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
            'mer_id'=>0,//商户id
            'source'=>0,//1线下 0线上
            'order_type'=>1,//1自营  2 第三方  订单类型
            'is_red_brokerage'=>0,//1红积分对冲佣金 0正常佣金
            'gzc'=>3,//养老金是否已进入公证处log表0：未进入。1：已进入
            'take_time'=>'',//结算时间
            'district_id'=>'',//
            'street_id'=>'',//
            'month'=>'',//月份


        ];

        Db::name('user_bill')->insert($bill);
    }

//     //上周
    public function getWeekStartEnd()
    {
        $now = time();
        // 计算上周日 00:00 的时间戳
        $last_sunday_start = strtotime('last Sunday', $now);
        // 计算这周一 00:00 的时间戳
        $this_monday_start = strtotime('this Monday', $last_sunday_start);
        // 上周日 23:59:59 的时间戳，即这周一 00:00
        $last_sunday_end = $this_monday_start - 1;
        // 上周一 00:00 的时间戳，即上周日 24:00
        $last_monday_start = $this_monday_start - 604800;

        return [$last_monday_start, $last_sunday_end];
    }

//本周
// public function getWeekStartEnd()
// {
//     $now = time();
//     // 计算本周一 00:00 的时间戳
//     $monday_start = strtotime('last Monday', $now);
//     if (date('w', $now) == 1) {
//         // 如果今天是周一，直接取今天的 00:00
//         $monday_start = strtotime('today', $now);
//     }
//     // 计算本周日 23:59:59 的时间戳
//     $sunday_end = strtotime('next Sunday', $now) + 86399;

//     return [$monday_start,$sunday_end];
// }




    /**
     * 获取用户星级
     */
    public function getStarLevel($user_id,$team_money=0,$person_money=0) {

        if(empty($team_money)) {
            $common_nums = $this->getCommonNums($user_id);//获取共建联盟(当前userid下面所属的所有的共建联盟的userid集合),例子:传入的uerid=12,数据格式就是 array(49,52,54,...)这些都是他的团队id集合
            $team_money = 0;

            //return $common_nums;

            foreach ($common_nums as $key => $value) {
                //return $value;
                # code...
                $amount = $this->getPerformance1($value);//获取流水信息($user_id下面的团队id,团队id中，每个id,获取自己和自己是推荐人(node_id是自己id)的所有消费金额)
                $team_money += $amount;
            }
            //计算自己的共建联盟流水

            $user_team_amount = $this->getperteamcomm($common_nums,$user_id);


            $team_money += $user_team_amount;


        }else{
            $common_nums = $this->getCommonNums($user_id);

        }

        if(empty($person_money)) {
            $person_nums = $this->getPersonageNums($user_id);//获取个人联盟(当前userid下面所属的所有的个人联盟的userid集合)
            $person_amount = 0;
            foreach ($person_nums as $key => $value) {
                # code...
                $amount = $this->getPerformance1($value);
                $person_amount += $amount;
            }
            $person_money = $person_amount;

            //计算自己的个人联盟总流水
            //$user_person_amount = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->sum("money");
            //$user_person_amount = empty($user_person_amount) ? 0 : round($user_person_amount * 0.7,2);
            $user_person_amount = $this->getperteamcomm($person_nums,$user_id);

            $person_money += $user_person_amount;

        }else{
            $person_nums = $this->getPersonageNums($user_id);

        }
        //计算个人在2.0新表中的业绩 start

        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
        $person_money +=  $team_small_big_amount[1];
        $team_money += $team_small_big_amount[0];

        //end



        //默认是小联盟，如果大联盟业绩比小联盟低，那就谁选业绩低的
        $slow = $person_money;
        if($team_money < $person_money) {
            $slow = $team_money;
        }
        $sum_money = $team_money + $person_money;


        // var_dump($sum_money);
        // var_dump($slow);
        $star_list = Db::name("old_user_starlevel")->order("statement_all_num desc")->select();
        $start_level = "";
        foreach ($star_list as $key => $value) {
            # code...

            //星级列表中 statement_all_num是共建联盟，person_statement是个人联盟
            if( $sum_money>=$value['statement_all_num'] && $slow >= $value['person_statement']) {
                return $value;
            }

        }
        return $start_level;

    }
    /**
     * 获取该用户共建联盟
     */
    public function getCommonNums($user_id){
        //先获取共建联盟下用户的id
        $son_ids = Db::name("user")->where("spread_old",$user_id)->where("is_team_old",1)->select()->toArray();
        $new_array_ids =[];
        foreach ($son_ids as $key => $value) {
            # code...
            $son_id = $value['uid'];
            $new_array_ids = array_merge($new_array_ids,[$son_id]);
            $son_value_ids = Db::name("user")->whereRaw("FIND_IN_SET('$son_id',parent_ids_old)")->field("uid")->select()->toArray();

            if(count($son_value_ids) > 0) {
                $son_value_ids = array_column($son_value_ids,"uid");
                $new_array_ids = array_merge($new_array_ids,$son_value_ids);
            }

        }
        return $new_array_ids;
    }
    /**
     * 获取流水信息
     */
    public function getPerformance1($user_id) {
        // $amount = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->sum("money");

        // $amount = isset($amount) ? round($amount*0.7,2) : 0;
        // return $amount;

        $user_team_amount = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->where('money', 1180)->select();


        // 计算 status 为 1 且 money 为 1180 的记录总和（减去相应值后）
        $money1180Sum = 0;
        foreach ($user_team_amount as $record) {
            $money1180Sum += $record['money'] - 300 - 180;
        }

        // 获取 status 为 1 且 money 为 11800 的记录集合

        $money11800Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->where('money', 11800)->select();

        // 计算 status 为 1 且 money 为 11800 的记录总和（减去相应值后）
        $money11800Sum = 0;
        foreach ($money11800Records as $record) {
            $money11800Sum += $record['money'] - 3000 - 1800;
        }


        $money10620Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->where('money', 10620)->select();

        // 计算 status 为 1 且 money 为 10620 的记录总和（减去相应值后）
        $money10620Sum = 0;
        foreach ($money10620Records as $record) {
            $money10620Sum += $record['money'] - 2700 - 1620;
        }

        $money9440Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->where('money', 9440)->select();

        // 计算 status 为 1 且 money 为 9440 的记录总和（减去相应值后）
        $money9440Sum = 0;
        foreach ($money9440Records as $record) {
            $money9440Sum += $record['money'] - 2400 - 1440;
        }

        $money2360Records = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->where('money', 2360)->select();

        // 计算 status 为 1 且 money 为 2360 的记录总和（减去相应值后）
        $money2360Sum = 0;
        foreach ($money2360Records as $record) {
            $money2360Sum += $record['money'] - 600 - 360;
        }

        // 计算除去特定值后的总和
        //$otherMoneyRecords = $this->old_user_of_goods->where('status', 1)->whereNotIn('money', [1180, 11800])->select();
        $otherMoneyRecords = Db::name("old_user_of_goods")->where("node_id",$user_id)->where("status",1)->whereNotIn('money', [1180, 11800 , 10620 , 9440 ,2360])->select();
        $otherMoneySum = 0;
        foreach ($otherMoneyRecords as $record) {
            $otherMoneySum += $record['money'];
        }


        // 分别处理特定值的情况并加上其他值的总和
        $all_record_nums = $money1180Sum + $money11800Sum + $money10620Sum + $money9440Sum +  $money2360Sum + round($otherMoneySum * 0.7,2);

        //end
        return $all_record_nums;




    }
    /**
     * 获取该用户个人联盟
     */
    public function getPersonageNums($user_id){
        $son_ids = Db::name("user")->where("spread_old",$user_id)->where("is_team_old",0)->field("uid")->select();
        $new_array_ids =[];
        foreach ($son_ids as $key => $value) {
            # code...
            $son_id = $value['uid'];
            $new_array_ids = array_merge($new_array_ids,[$son_id]);
            $son_value_ids = Db::name("user")->whereRaw("FIND_IN_SET('$son_id',parent_ids_old)")->field("uid")->select()->toArray();

            if(count($son_value_ids) > 0) {
                $son_value_ids = array_column($son_value_ids,"uid");
                $new_array_ids = array_merge($new_array_ids,$son_value_ids);
            }

        }
        return $new_array_ids;
    }
    /**
     * 获取指定用户业绩
     */
    public function getPerformanceOf($user_id) {

        //共建联盟业绩 个人联盟业绩 共建联盟总pv 个人联盟业绩pv
        $common_nums = $this->getCommonNums($user_id);
        $person_nums = $this->getPersonageNums($user_id);

        $team_amount = 0;
        $person_amount = 0;
        // $common_nums[] = $user_id;
        foreach ($common_nums as $key => $value) {
            # code...
            $amount = $this->getPerformance1($value);
            $team_amount += $amount;
        }
        foreach ($person_nums as $key => $value) {
            # code...
            $amount = $this->getPerformance1($value);
            $person_amount += $amount;
        }



        //添加自己共建联盟的流水
        //$user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->sum("money");
        //$user_team_amount = empty($user_team_amount) ? 0 : round($user_team_amount * 0.7,2);
        $user_team_amount = $this->getperteamcomm($common_nums,$user_id);

        $team_amount += $user_team_amount;



        // //计算自己的个人联盟总流水
        //$user_person_amount = Db::name("old_user_of_goods")->whereIn("user_id",$person_nums)->where("node_id",$user_id)->sum("money");
        // $user_person_amount = empty($user_person_amount) ? 0 : round($user_person_amount * 0.7,2);
        $user_person_amount = $this->getperteamcomm($person_nums,$user_id);


        // var_dump("|||");
        // var_dump($person_amount);
        // var_dump($user_person_amount);



        $person_amount += $user_person_amount;
        //  var_dump($person_amount);
        //  var_dump("|||");



        //var_dump($team_amount);
        //var_dump($person_amount);

        $sum_nums_pv = $team_amount + $person_amount;

        $sum_nums_pv = isset($sum_nums_pv) ? $sum_nums_pv :0;


        //计算个人在2.0新表中的业绩 start

        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
        $total_team_amount3 =  $team_small_big_amount[0] +  $team_small_big_amount[1];
        $sum_nums_pv += $total_team_amount3;

        //end

        return $sum_nums_pv;
    }

    //计算自己和自己团队下面的业绩。新表
    public function calculatePerformance($uid)
    {
        // 初始化业绩数组
        $performance = [

            'personal_performance' => 0, // 个人业绩
            'team_performance' => 0, // 团队业绩
            'total_performance' => 0, // 总业绩
            'team_count' => 0, // 加上自己的团队数量

        ];

        // 定义业绩换算规则
        $performanceMapping = [
            1180 => 700,
            10620 => 6300,
            11800 => 7000,
            9440 => 5600,
            2360 => 1400
        ];

        // 计算个人业绩
        $personalOrder = Db::name('store_order')->where("uid", $uid)->find();

        if ($personalOrder) {
            // 将浮点数转换为整数
            $totalPrice = (int)$personalOrder['total_price'];
            if (isset($performanceMapping[$totalPrice])) {
                $performance['personal_performance'] = $performanceMapping[$totalPrice];
            }
        }

        // 计算旗下团队成员的业绩
        $teamOrders = Db::name('user')
            ->alias('u')
            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
            ->where("u.spread_uid", $uid) // 查询旗下会员
            ->where("so.mer_id", 496)
            // ->where("so.douhuomall", 1)
            // ->where("so.douhuomall_status", 9)
            // ->where("so.status", 0)
            ->select();

        $teamOrders_count = Db::name('user')
            ->alias('u')
            ->join('store_order so', 'u.uid = so.uid', 'LEFT')
            ->where("u.spread_uid", $uid) // 查询旗下会员
            ->where("so.mer_id", 496)
            // ->where("so.douhuomall", 1)
            // ->where("so.douhuomall_status", 9)
            // ->where("so.status", 0)
            ->count();

        $performance['team_count'] = $teamOrders_count + 1; // 赋值团队数量

        foreach ($teamOrders as $order) {
            if ($order['total_price']) {
                // 将浮点数转换为整数
                $totalPrice = (int)$order['total_price'];
                if (isset($performanceMapping[$totalPrice])) {
                    $performance['team_performance'] += $performanceMapping[$totalPrice];
                }
            }
        }

        // 计算总业绩
        $performance['total_performance'] = $performance['personal_performance'] + $performance['team_performance'];

        // 假设总业绩最大值需要通过后续逻辑判断，这里暂时设置为 false
        return $performance;
    }

//获取大小部门业绩（新表小标0是大部门，下标1是小部门）
    public function getbig_samll_datas($user_id) {

        $subordinate_members = Db::name('user')
            // ->alias('u')
            // ->join('store_order so', 'u.uid = so.uid', 'LEFT')
            ->where("spread_uid", $user_id)
            // ->where("so.mer_id", 496)
            // ->group('u.uid')

            ->select();


        //var_dump($subordinate_members);


        // 单独写一个方法获取大小部门的数据
        $arr_team = [];
        foreach ($subordinate_members as $k => $v) {
            // 计算自己和旗下的业绩
            $arr_team[] = $this->calculatePerformance($v['uid']);
        }

        // 初始化变量
        $maxPerformance = 0;
        $maxIndex = -1;

        // 找出 total_performance 最高的记录
        foreach ($arr_team as $index => $item) {
            if ($item['total_performance'] > $maxPerformance) {
                $maxPerformance = $item['total_performance'];
                $maxIndex = $index;
            }
        }

        // 如果找到了最高记录
        if ($maxIndex !== -1) {
            // 提取最高记录
            $maxRecord = $arr_team[$maxIndex];
            // 从原数组中移除该记录
            unset($arr_team[$maxIndex]);
            // 重新索引数组
            $arr_team = array_values($arr_team);
        } else {
            // 如果没有找到记录，可以设置一个默认值
            $maxRecord = null;
        }

        // 计算大部门和小部门的汇总信息
        $majorDepartmentSummary = [
            "total_performance" => $maxRecord ? $maxRecord['total_performance'] : 0,
        ];

        $minorDepartmentSummary = [
            "total_performance" => array_sum(array_column($arr_team, 'total_performance')),
        ];

        // 返回所需的结果
        return [
            $majorDepartmentSummary['total_performance'],
            $minorDepartmentSummary['total_performance']
        ];
    }


    /**
     * 释放待发放佣金
     */
    public function releaseTobeAmount1($user_id,$amount,$output)
    {
        $userInfo = Db::name("user")->find($user_id);
        if(empty($userInfo)) {
            return false;
        }

        $withdraw_quota = empty($userInfo['withdraw_quota_old']) ? 0 : $userInfo['withdraw_quota_old']; //用户的提现额度
        $old_amount = empty($userInfo['tobe_amount_old']) ? 0 : $userInfo['tobe_amount_old']; //用户的冻结额度
        Db::name("user")->where("uid",$user_id)->save(['tobe_amount_old'=>0]);
        $amount += $old_amount;//冻结的金额和分佣的总额
        $inc_amount = 0;
        $inc_tobe_amount = 0;
        $dec_withdraw_quota = 0;

        if(($amount - $withdraw_quota) > 0) { //冻结的金额和待发放的佣金减去提现的金额大于0的情况
            $diff_money = $amount - $withdraw_quota;
            $inc_amount = $withdraw_quota;
            $dec_withdraw_quota = $withdraw_quota;
            $inc_tobe_amount = $diff_money;
        }elseif(($amount - $withdraw_quota)==0){
            $inc_amount = $withdraw_quota;
            $dec_withdraw_quota = $withdraw_quota;
        }else {
            // <0的情况
            $diff_money = $withdraw_quota - $amount;
            $inc_amount = $amount;
            $dec_withdraw_quota = $amount;
        }
        if($inc_tobe_amount != 0 ) {

            $res = Db::name("user")->where("uid",$user_id)->inc("tobe_amount_old",$inc_tobe_amount)->fetchSql()->inc("amount_old",$inc_amount)->dec("withdraw_quota_old",$dec_withdraw_quota)->save();

            //$output->writeln("执行星级分红-额度不足进入冻结-sql语句");
            //$output->writeln($res);
            Db::execute($res);
            // if($res == 0) {
            // $output->writeln($res);
            // return false;
            // }
        }else {
            $res = Db::name("user")->where("uid",$user_id)->inc("amount_old",$inc_amount)->fetchSql()->dec("withdraw_quota_old",$dec_withdraw_quota)->save();
            // $output->writeln("执行星级分红-额度充足-sql语句");
            // $output->writeln($res);
            // Db::execute($res);
        }
        //记录日志 提现额度消费
        if($dec_withdraw_quota > 0) {
            $this->change_user_log($user_id,'withdraw_quota_old',2,$dec_withdraw_quota,"conversion_tobe_amount","佣金额度兑换佣金");
        }
    }

    //发放佣金 示例: $this->change_user_log($v,'amount',1,$all_award,"member_award","星级分红入账"."-".$value['title']);//释放佣金
    function change_user_log($user_id,$type,$change_status,$money,$routine,$remark="",$is_admin=1,$appoint_money = 0)
    {
        $transition = [
            'pv'=>1,
            "gb"=>2,
            "df"=>3,
            "vr"=>4,
            "bt"=>5,
            "withdraw_quota_old"=>6,//提现
            "unsettled_pension"=>7,
            "amount_old"=>8//发放佣金
        ];
        $routineInfo = Db::name("old_routine_log_of_key")->where("key",$routine)->find();
        if(empty($routineInfo)) {
            return false;
        }
        $key_id = isset($routineInfo['id']) ? $routineInfo['id'] : 0;

        if($appoint_money > 0) {
            $alter_money = $appoint_money;
        }else{
            //再去查询变更前的 金额
            $alter_money = Db::name("user")->where('uid',$user_id)->value($type);
        }
        if($change_status == 1) {
            //新增前
            $alter_money = $alter_money-$money;
        }else if($change_status == 2){
            //减少前
            $alter_money = $alter_money + $money;
        }
        if($alter_money < 0) {
            $alter_money =0;
        }
        $inser_data = [];
        $inser_data['user_id'] = $user_id;
        $inser_data['type'] = $transition[$type];
        $inser_data['change_status'] = $change_status;
        $inser_data['money'] = $money;
        $inser_data['routine_log_of_key_id'] = $key_id;
        $inser_data['remark'] = $remark;
        $inser_data['is_admin'] = $is_admin;
        $inser_data['create_time'] = time();
        $inser_data['alter_money'] = isset($alter_money) ? $alter_money : 0;
        Db::name("old_user_log")->insert($inser_data);
    }

    /**
     * 获取大小区中业绩小的业绩
     */
    public function getpersamllcomm($user_id,$team_money=0,$person_money=0) {

        //共建联盟业绩 个人联盟业绩 共建联盟总pv 个人联盟业绩pv
        $common_nums = $this->getCommonNums($user_id);
        $person_nums = $this->getPersonageNums($user_id);

        $team_amount = 0;
        $person_amount = 0;
        // $common_nums[] = $user_id;
        foreach ($common_nums as $key => $value) {
            # code...
            $amount = $this->getPerformance1($value);
            $team_amount += $amount;
        }
        foreach ($person_nums as $key => $value) {
            # code...
            $amount = $this->getPerformance1($value);
            $person_amount += $amount;
        }

        //添加自己共建联盟的流水

        $user_team_amount = $this->getperteamcomm($common_nums,$user_id);
        $team_amount += $user_team_amount;

        // //计算自己的个人联盟总流水

        $user_person_amount = $this->getperteamcomm($person_nums,$user_id);
        $person_amount += $user_person_amount;

        //默认是小联盟，如果大联盟业绩比小联盟低，那就谁选业绩低的
        // 确定最小值和最大值
        $minValue = min($person_amount, $team_amount);
        $maxValue = max($person_amount, $team_amount);


        //计算个人在2.0新表中的业绩 start

        $team_small_big_amount = $this->getbig_samll_datas($user_id);//下标0是大部门，下标1是小部门
        $minValue  +=  $team_small_big_amount[1];
        $maxValue  +=  $team_small_big_amount[0];


        //end



        // 返回包含最小值和最大值的数组
        return array($minValue, $maxValue);
    }

    //封装个人大小联盟流水（$state_type=1不传status）
    public function getperteamcomm($common_nums,$user_id,$state_type=1){
        // $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->sum("money");
        // $user_team_amount = empty($user_team_amount) ? 0 : round($user_team_amount * 0.7,2);

        // 基础查询构建器
        $user_team_amount = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 1180)->select();

        //$money1180Records = $this->old_user_of_goods->where('status', 1)->where('money', 1180)->select();
        // 计算 status 为 1 且 money 为 1180 的记录总和（减去相应值后）
        $money1180Sum = 0;
        foreach ($user_team_amount as $record) {
            $money1180Sum += $record['money'] - 300 - 180;
        }

        // 获取 status 为 1 且 money 为 11800 的记录集合

        $money11800Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 11800)->select();

        // 计算 status 为 1 且 money 为 11800 的记录总和（减去相应值后）
        $money11800Sum = 0;
        foreach ($money11800Records as $record) {
            $money11800Sum += $record['money'] - 3000 - 1800;
        }


        $money10620Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 10620)->select();

        // 计算 status 为 1 且 money 为 10620 的记录总和（减去相应值后）
        $money10620Sum = 0;
        foreach ($money10620Records as $record) {
            $money10620Sum += $record['money'] - 2700 - 1620;
        }


        $money9440Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 9440)->select();

        // 计算 status 为 1 且 money 为 9440 的记录总和（减去相应值后）
        $money9440Sum = 0;
        foreach ($money9440Records as $record) {
            $money9440Sum += $record['money'] - 2400 - 1440;
        }

        $money2360Records = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->where('money', 2360)->select();

        // 计算 status 为 1 且 money 为 2360 的记录总和（减去相应值后）
        $money2360Sum = 0;
        foreach ($money2360Records as $record) {
            $money2360Sum += $record['money'] - 600 - 360;
        }

        // 计算除去特定值后的总和
        //$otherMoneyRecords = $this->old_user_of_goods->where('status', 1)->whereNotIn('money', [1180, 11800])->select();
        $otherMoneyRecords = Db::name("old_user_of_goods")->whereIn("user_id",$common_nums)->where("node_id",$user_id)->whereNotIn('money', [1180, 11800 , 10620 , 9440 ,2360])->select();
        $otherMoneySum = 0;
        foreach ($otherMoneyRecords as $record) {
            $otherMoneySum += $record['money'];
        }

        $all_record_nums = $money1180Sum + $money11800Sum + $money10620Sum + $money9440Sum + $money2360Sum + round($otherMoneySum * 0.7,2);

        return $all_record_nums;
    }

//合伙人分佣结束



    //利润分配
    public function dis_of($group_order_id,$sn){
        //利润分配开始
        $group_order = Db::name('store_group_order')->where('group_order_sn',$sn)->find();
        //var_dump( $group_order);
        $store_order_data = Db::name('store_order')->where('group_order_id',$group_order_id)->find();

        //找到对应的商品id(product_id)
        $store_order_product_data = Db::name('store_order_product')->where('order_id',$store_order_data['order_id'])->find();
        //找到对应的商品让利金额或比例
        $store_product_data = Db::name('store_product')->where('product_id',$store_order_product_data['product_id'])->find();
        //下单用户
        $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find();
        //var_dump($user_data['spread_uid']);

        $concession_pri = $store_product_data['concession_pri'];//商家让利金额


        $spread_uid = 0;//下单用户上级uid
        $fgj_pri=0;//推广者的佣金抽10%到个人复购金

        $pv = 0; //待分配的PV


        //var_dump($store_product_data['concession_pri']);return;
        //精彩生活
        if($store_order_data['mer_id'] == 439){


            //分配参数
            $job_par = [];
            if(!empty($store_order_data)){
                $job_par = json_decode($store_order_data['fzone_paytype'], true);
                //if($job_par['note'] == "现金"){
                //普通消费者
                $ylj_pri = round($concession_pri * 0.3,2);
                $pv = round($concession_pri * 0.35,2);

                //分配养老金给消费者
                $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
                //分配积分和贡献值给消费者
                $con = $user_data['contribute'] + $pv;
                $score = $user_data['score'] + $pv;

                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,$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'],11,"购买精彩生活商品赠送贡献值");
                var_dump($pv);
                var_dump(111111111111);
                return;

                $this->score_log($user_data['uid'],$pv,$store_order_data['order_id'],11,"购买精彩生活商品赠送积分");

                //给推广者分配养老金
                //给推广者分配佣金
                if($user_data['spread_uid'] != 0){
                    //查询下单用户上级身份
                    $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();

                    //业务员或以上的推荐人等级
                    //user_group=1是消费者 3%，2:业务员 5%，3:业务经理7%，4:初级合伙人9%，5:中级合伙人11%,6:高级合伙人13%，7：董事15%
                    if($spread_data['user_group'] > 1){

                        // //给推广者分配佣金
                        $yj_amount = 0;
                        $ylj_amount = $spread_data['annuity'] + round($pv * 0.05,2);
                        $ssf = 0;//变量
                        $yj_amount_90 = 0;//90%的佣金

                        if($spread_data['user_group'] == 2){
                            $ssf =round($pv * 0.07,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.07,2);
                            $score     = $spread_data['score'] + round($pv * 0.07,2);
                            //$yj_amount = $spread_data['brokerage_price'] + round($pv * 0.07,2);

                            $yj_amount_90 = round($pv * 0.07,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.07,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'] == 3){
                            $ssf =round($pv * 0.09,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.09,2);
                            $score     = $spread_data['score'] + round($pv * 0.09,2);
                            //$yj_amount = $spread_data['brokerage_price'] + round($pv * 0.09,2);
                            $yj_amount_90 = round($pv * 0.09,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.09,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 =round($pv * 0.11,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.11,2);
                            $score     = $spread_data['score'] + round($pv * 0.11,2);
                            //$yj_amount = $spread_data['brokerage_price'] + round($pv * 0.11,2);

                            $yj_amount_90 = round($pv * 0.11,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.11,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 =round($pv * 0.13,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.13,2);
                            $score     = $spread_data['score'] + round($pv * 0.13,2);
                            // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.13,2);

                            $yj_amount_90 = round($pv * 0.13,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.13,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 =round($pv * 0.15,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.15,2);
                            $score     = $spread_data['score'] + round($pv * 0.15,2);
                            // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.15,2);

                            $yj_amount_90 = round($pv * 0.15,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.15,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 =round($pv * 0.17,2);
                            $con       = $spread_data['contribute'] + round($pv * 0.17,2);
                            $score     = $spread_data['score'] + round($pv * 0.17,2);
                            // $yj_amount = $spread_data['brokerage_price'] + round($pv * 0.17,2);

                            $yj_amount_90 = round($pv * 0.17,2) * 0.9;
                            $fgj_amount_10 = round($pv * 0.17,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'],$ssf,$store_order_data['order_id'],11,"精彩生活区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],$ssf,$store_order_data['order_id'],11,"精彩生活区商品赠送积分");
                        // //推广佣金
                        $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'],round($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){
                        //给推广者分配佣金
                        // $ylj_amount = $spread_data['annuity'] + round($pv * 0.3,2);
                        $yj_amount_90 = round($pv * 0.03,2) * 0.9;
                        $fgj_amount_10 = round($pv * 0.03,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'] + round($pv * 0.03,2);
                        $score = $spread_data['score'] + round($pv * 0.03,2);

                        //贡献值和积分
                        Db::name('user')->where('uid',$spread_data['uid'])->update(["contribute"=>$con,"score"=>$score]);

                        //推广养老金
                        // $this->bill_user_log($spread_data['uid'],round($pv * 0.3,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'推广获得养老金'.round($pv * 0.3,2),$store_order_data['mer_id']);
                        //推广佣金
                        $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'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        $this->score_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");



                    }



                }

                //锁客收益
                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)){
                        //$merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.05,2);
                        //给推广者分配佣金

                        $yj_amount_90 = round($pv * 0.05,2) * 0.9;
                        $fgj_amount_10 = round($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);



                        Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
                        //推广佣金
                        $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_dump($ylj_amount);
            }

            //VIP专区
        }else if($store_order_data['mer_id'] == 496){

            //业务员和以上推广的等级获得推广佣金
            $le_yw_amount = 0;
            //获赠的贡献值和积分
            $gx_jf = 0;
            $yj1 = 0;
            if($store_product_data['price'] == 1180){
                $pv = 1000;
                $gx_jf = 700;
                $yj1 = 100;
                $le_yw_amount = 300;
            }else if($store_product_data['price'] == 10620){
                $pv = 9000;
                $gx_jf = 6300;
                $yj1 = 900;
                $le_yw_amount = 2700;
            }else if($store_product_data['price'] == 11800){
                $pv = 10000;
                $gx_jf = 7000;
                $yj1 = 1000;
                $le_yw_amount = 3000;
            }

            $ylj_pri = round($pv * 0.035,2);
            //$pv = round($pv * 0.35,2);

            //分配养老金给消费者
            //普通用户获取贡献值和pv3.5%养老金和积分
            $ylj_amount_mine = $user_data['annuity'] + $ylj_pri;
            $gxz_amount_mine = $user_data['contribute'] + $gx_jf;
            $jf_amount_mine = $user_data['score'] + $gx_jf;


            Db::name('user')->where('uid',$user_data['uid'])->update(['annuity'=>$ylj_amount_mine,'contribute'=> $gxz_amount_mine,'score'=> $jf_amount_mine]);

            $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);

            $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值");
            $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送积分");

            //给推广者分配养老金
            //给推广者分配佣金
            if($user_data['spread_uid'] != 0){
                //查询下单用户上级身份
                $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();

                //user_group=1是消费者，2:业务，3:业务经理，4:初级合伙人，5:中级合伙人,6:高级合伙人，7：董事
                //业务或以上等级推广人
                //获得养老金、佣金、贡献值和积分
                if($spread_data['user_group'] > 1){



                    $con =0;//贡献值
                    $score = 0;//积分
                    //养老金
                    $uer_bill = $spread_data['annuity'] + round($pv * 0.035,2);
                    //$yongjin = $spread_data['brokerage_price'] + $le_yw_amount;

                    $yj_amount_90 = $le_yw_amount * 0.9;
                    $fgj_amount_10 = $le_yw_amount * 0.1;//推广者的佣金抽10%到个人复购金

                    $yongjin = $spread_data['brokerage_price'] + $yj_amount_90;
                    $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;




                    if($spread_data['user_group'] == 2){

                        $con = $spread_data['contribute'] + round($pv * 0.07,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.07,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");

                    }else if($spread_data['user_group'] == 3){
                        $con = $spread_data['contribute'] + round($pv * 0.09,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.09,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 4){
                        $con = $spread_data['contribute'] + round($pv * 0.11,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.11,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 5){
                        $con = $spread_data['contribute'] + round($pv * 0.13,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.13,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");

                    }else if($spread_data['user_group'] == 6){
                        $con = $spread_data['contribute'] + round($pv * 0.15,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.15,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }else if($spread_data['user_group'] == 7){
                        $con = $spread_data['contribute'] + round($pv * 0.17,2);
                        $score = $spread_data['brokerage_price'] + round($pv * 0.17,2);
                        Db::name('user')->where('uid',$spread_data['uid'])->update(['contribute'=> $con,'score'=> $score,'brokerage_price'=> $yongjin,'annuity'=>$uer_bill,"fugou"=> $fgj_amount]);

                        //贡献值
                        $this->con_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                        //积分
                        $this->score_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");


                    }
                    //养老金
                    $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
                    //佣金
                    $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']);
                    //复购金
                    $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);

                }

                //普通的用户推广人
                if($spread_data['user_group'] == 1){
                    // $yj_amount = $spread_data['annuity'] + round($pv * 0.01,2);
                    // Db::name('user')->where('uid',$user_data['spread_uid'])->update(['annuity'=>$ylj_amount,'brokerage_price'=>$yj_amount]);
                    // //推广养老金
                    // $this->bill_user_log($user_data['spread_uid'],round($pv * 0.01,2),$store_order_data['order_id'],5,$group_order['group_order_sn'],'推广获得养老金'.round($pv * 0.01,2),$store_order_data['mer_id']);
                    // //推广佣金
                    // $this->bill_user_log($user_data['spread_uid'],round($pv * 0.01,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.01,2),$store_order_data['mer_id']);

                    //获取贡献值和积分和佣金
                    $gx_jf = $spread_data['contribute'] + round($pv * 0.03,2);

                    //$yj111 = $spread_data['brokerage_price'] + $yj1;

                    $yj_amount_90 = round($yj1 * 0.9,2);
                    $fgj_amount_10 = round($yj1 * 0.1,2);//推广者的佣金抽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'=> $gx_jf,'score'=> $gx_jf,'brokerage_price'=> $yj_amount,'fugou'=>$fgj_amount]);
                    $this->con_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送贡献值");
                    $this->score_log($spread_data['uid'],round($pv * 0.03,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分");
                    //推广佣金
                    $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']);
                }




            }
            //锁客收益
            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)){
                    //$merchant_amount = $merchant_user_data['brokerage_price'] + round($pv * 0.35,2);

                    $yj_amount_90 = round($pv * 0.035,2) * 0.9;
                    $fgj_amount_10 = round($pv * 0.035,2) * 0.1;//推广者的佣金抽10%到个人复购金

                    $yj_amount = $merchant_data['brokerage_price'] + $yj_amount_90;
                    $fgj_amount = $merchant_data['fugou'] + $fgj_amount_10;
                    $this->fugou_user_log($merchant_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1);



                    Db::name('user')->where('uid',$merchant_data['uid'])->update(['brokerage_price'=>$yj_amount,'fugou'=>$fgj_amount]);
                    //推广佣金
                    $this->bill_user_log($merchant_data['uid'],round($pv * 0.35,2),$store_order_data['order_id'],3,$group_order['group_order_sn'],'推广获得拥金'.round($pv * 0.35,2),$store_order_data['mer_id']);
                }

            }


        }


    }




}