php/app/controller/api/Notify.php

<?php
namespace app\controller\api;

use AdaPaySdk\AdapayTools;
use app\common\repositories\store\order\StoreRefundOrderRepository;
use app\controller\api\merchant\sxy\Access;
use app\controller\api\store\service\Huafei;
use think\facade\Db;
use think\facade\Log;
use think\facade\Request;

class Notify
{

    public function notify($type){
//        Db::name('log')->insert(['data'=>'汇付支付回调---'.json_encode($type)]);
        set_time_limit(0);
        $post = Request::param();
        Db::name("log")->insert(array('data'=>'【汇付异步接受到的参数】'.json_encode($post),));//日志记录

        $post_data_str = isset($post['data']) ? $post['data']: '';
        $post_sign_str = isset($post['sign']) ? $post['sign']: '';

        # 先校验签名和返回的数据的签名的数据是否一致
        $adapay_tools=new AdapayTools();
        if ($post['app_id'] == 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0'){
            AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAKvkKGN19wxH9Uusx8gXnt89oYbgvIRkzO2pD0nzSF/MS65m2j5DgKMG5lryL6bfco2p9syoxKI7IE9pLFtFTyI477cNoUsvWiIYikx5uKz0CDdBcR8AAapfrs5XKgJMcogulqDm4/7QUDuQJoATdvEpA6yfiaW2EqSnMpvZKsdFAgMBAAECgYAgmVOjkUK6HIeDw4/b/cbOlbSljMeT4D4RMIfKwY3PRUJxH+Zx+oFR6cQUKWwqHKRwA3Tf2X35OndlOBAGez2Hc1M08brGSlCB/Ze654mOP5H+bImKfmWQxJiVbbY4ef6msgNAp+FicWLvo6WDuymmP7gvoQbC5E90tRKDCvyawQJBANy/GaYU209Dikbd6E2rWKaS9dgx9f/wZOqmUMUzsDicMO4nK1qojyEm8inkoSRyzv0vLXqD/j/buhE4FjO/YbECQQDHV66K4NKNvuKAbI0NNXothxe2PS6lJrBU5QWgt4Q6CsQ8v+WyFq9AUjEahN11Evm2DCnEBddZKmSctZTgry/VAkAgCEMKjKA+Ykige/cHvkOA+HZgRu+xkgqy2iuCUjvSGygmhtyNrUQHxYUCe0C+70IGD2CEFL9COPpJIWBnZfAhAkATbV0qVbzPaaIDaBDbD7Ini7no3c+U8s9Ohr9kqV3uliwHy5/kGkfcGeaFMhuvFDlX35mWbAdPvkzt5NhsiUY9AkBNdE3yUz+f7A92oZr4bHX7r5gyUTumRiBYyiJ8dgMl6lT8OpQZpBxdswyWg2nkmPoCjoASZx8LoCBhsK4SBcfz');

        }else{
            AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
        }
//        AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
//        $adapay_tools->SetParams();
        $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
        $post_data_str=json_decode($post_data_str,true);

        if ($sign_flag){
            try {
                if(empty($post_data_str['error_msg'])){
                    Db::name("log")->insert(array('data'=>'【验签通过-支付】:时间：'.date('Y-m-d H:i:s',time()),));//日志记录
                    $requestId = [];
                    if(strpos($post_data_str['order_no'],'_') !== false){
                        $requestId = explode("_",$post_data_str['order_no']);
                    }
                    $pay_type = $post_data_str['pay_channel'];
                    $pay_type = $pay_type == 'wx_lite' ? 1 : 4;
                    switch ($type){
                        case 'huafei':
                            //话费充值支付成功推送
                            try{
                                $order_data = Db::name('order_huafei_hf') -> where('order_no', $requestId[0])->find();
                                if($order_data['status']==1) return false;
                                $pay_type = $pay_type == 1 ? 'wx' : 'al';
                                Db::name('order_huafei_hf')->where('order_no',$requestId[0])->update(['rand'=>$requestId[1],'pay_type'=>1,'status'=>1]);
                            }catch (\Exception $e) {
                                Db::name('log')->insert(['data'=>'话费充值支付回调错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                            }
                            //话费充值支付成功推送
                            try{
                                $Huafei = new Huafei();
                                $Huafei->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price']);
                            }catch (\Exception $e) {
                                Db::name('log')->insert(['data'=>'话费充值支付回调推送订单错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                            }
                            break;
                        case 'pay':
                            //商城集合订单
                            Db::name('store_group_order') -> where('group_order_sn',$requestId[0]) -> update(['rand'=>$requestId[1]]);
                            // 判断代付是否支付过
                            $group_order = Db::name('store_group_order')->where('group_order_sn', $requestId[0])->find();
                            $group_order_id = $group_order['group_order_id']??'';
                            $old_pay_open_id = Db::name('store_order')->where('group_order_id', $group_order_id)->value('pay_open_id');
                            if ($old_pay_open_id && $old_pay_open_id != $post_data_str['expend']['open_id']) {
                                // 给新支付的这一笔退款
                                Db::name('log')->insert(['data' => '给新支付的这一笔退款']);

                                if ($group_order['pay_wx'] == 3){
                                    $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
                                }else{
                                    $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
                                }
                                $refund_traits = [
                                    'payment_id'  => $post_data_str['id'],
                                    'app_id'      => $post['app_id'],
                                    'order_no'    => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(),
                                    'reverse_amt' => $post_data_str['pay_amt'],
                                    'notify_url'  => env('APP_URL') . "/api/hf_notify/reverse_order",
                                ];
                                $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type['pay_type'] == '1' ? 2 : 1, $group_order['pay_wx'], $key);

                                Db::name('log')->insert(['data'=>'汇付支付撤销返回结果：'.json_encode($hf_refund_res)]);
                                break;
                            }
                            $post_data_str['expend']['open_id'] = $post_data_str['expend']['open_id'] ?? '';

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

                            //精彩生活
                            // if($store_order_data['mer_id'] == 439){
                            //     if(!empty($store_order_data)){}
                            // }

                            //$group_order = Db::name('store_group_order')->where('group_order_sn',$group_order_id)->find();
                            //var_dump($group_order['group_order_id']);return;
                            //分配逻辑
                            $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();


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


                                        $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)){


                                        $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']);
                                    }

                                }


                            }

                            //判断是否是精彩生活区的商品
                            if($store_order_data['mer_id'] == 439){
                                //供应链的状态
                                Db::name('store_order')->where('group_order_id', $group_order_id)->update(['douhuomall'=>1,'douhuomall_status'=>9]);
                            }


                            //利润分配 end
                            //商城订单
                            //判断下，如果是组合支付中，现金+积分的形式支付情况下

                            $array_fzone_paytype = json_decode(  $store_order_data['fzone_paytype'],true);

                            if($array_fzone_paytype['type']=='b2'){
                                if(!empty($array_fzone_paytype['other']) && is_numeric($array_fzone_paytype['other']) == true){
                                    $vrpri = $user_data['score'] -  $array_fzone_paytype['other'];

                                    // // //现金+积分
                                    if($vrpri  >= 0 ){

                                        Db::name("user")->where("uid", $user_data['uid'])->update(['score'=>$vrpri]);
                                    }else{
                                        $note_arr = ["uid"=>$user_data['uid'],"dec_score"=>$array_fzone_paytype['other'],"rem_score"=>$user_data['score'],"msg"=>"积分不足","fzone_paytype"=>$store_order_data['fzone_paytype']];
                                        Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
                                    }
                                }else{
                                    $note_arr = ["uid"=>$user_data['uid'],"msg"=>"数据异常","fzone_paytype"=>$store_order_data['fzone_paytype']];
                                    Db::name("test_log")->insert(['create_time'=>date('Y-m-d H:i:s'),'note'=>json_encode($note_arr, JSON_UNESCAPED_UNICODE)]);
                                }
                            }
                            //end 现金+积分

                            //如果注释了event事件，需要手动修改订单状态 1：代发货
                            Db::name('store_order')->where('group_order_id', $group_order_id)->update(['status'=>0]);

                            $orderss = Db::name('store_order')->where('group_order_id', $group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s'),'pay_open_id' => $post_data_str['expend']['open_id']]);

                            Db::name('store_group_order')->where('group_order_id',$group_order_id)->update(['paid'=>1,'pay_time'=>date('Y-m-d H:i:s')]);

                            event('pay_success_order', ['order_sn' => $requestId[0],'pay_type'=>$pay_type]);

                            break;
                        case 'pay_channel':
                            //渠道商
                            try{
                                $order_data=Db::name('channel_order') -> where('order_no',$requestId[0]) -> find();
                                if($order_data['status']==1){
                                    return false;
                                }
                                $pay_type = $pay_type == 1 ? 'wx' : 'al';
                                Db::name('channel_user')->where('uid',$order_data['uid'])->update(['status'=>1]);
                                Db::name('channel_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'pay_type'=>$pay_type,'status'=>1]);

                            }catch (\Exception $e) {
                                Db::name('log')->insert(['data'=>'支付渠道商错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                            }

                            try{
                                $access = new Access();
                                //分佣
                                $access->channel_fenyong($requestId[0]);
//                            //给7个激活码
//                            for($i=0;$i<=6;$i++){
//                                Db::name('activation_code')->insertGetId([
//                                    'uid'=>$order_data['uid'],
//                                    'code'=>$this->randomFromDev(20),
//                                    'ctime'=>time(),
//                                    'status'=>1,
//                                    'utime'=>time(),
//                                    'use_uid'=>0,
//                                    'type'=>2
//                                ]);
//                            }
                                //赠送返本商户
                                $mer = Db::name('user_mer') -> where('uid',$order_data['uid']) -> find();
                                if(!$mer){
                                    Db::name('user_mer') -> insert(['uid'=>$order_data['uid'],'mer'=>10]);
                                }else{
                                    Db::name('user_mer') -> where('uid',$order_data['uid'])->inc('mer', 10) ->update();;
                                }
                                //赠送商户
                                $merchant=Db::name('merchant')->where('uid',$order_data['uid'])->find();
                                if(!$merchant)
                                    Db::name('merchant_intention')->insert(['uid'=>$order_data['uid'],'status'=>3,'activation_code'=>rand('000000000','999999999')]);
                                //赠送大仓会员资格
                                $dacang_user = Db::name('da_cang_user')->where('uid', $order_data['uid'])->find();
                                $time = date('Y-m-d', time());
                                $time = strtotime($time);
                                $end_time = $time + 31536000 - 1;
                                $dc_id = 1;
                                //如果不是金卡会员,赠送金卡会员一年
                                if (!$dacang_user) {
                                    Db::name('da_cang_user')->insert(['uid' => $order_data['uid'], 'ctime' => time(), 'end_time' => $end_time, 'dc_id' => $dc_id,'status'=>1,'type'=>1]);
                                }else{
                                    //如果是银卡会员,变成金卡，一年 || 是否已过期,如果已过期,赠送金卡会员一年
                                    if($dacang_user['type'] == 2 || $dacang_user['end_time'] < $time){
                                        Db::name('da_cang_user')->where('uid', $order_data['uid'])->where('dc_id', $dc_id)->update(['end_time' => $end_time,'status'=>1,'type'=>1]);
                                    }

                                }
                            }catch (\Exception $exception){
                                Db::name('log')->insert(['data'=>'渠道商处理错误：'.$exception->getFile().'：'.$exception->getLine().'【'.$exception->getMessage().'】']);
                            }
                            break;
                        case 'pay_annual':
                            //商户
                            $annual_cost_order=Db::name('merchant_annual_cost_order')-> where('order_no',$requestId[0])->find();
                            if($annual_cost_order['status'] == 0) {


                                $pay_type = $pay_type == 1 ? 'wx' : 'al';
                                Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->update(['rand' => $requestId[1],'pay_type'=>$pay_type,'status' => 1]);
                                //如果有商户id就是续费
                                $mer_id = Db::name('merchant_annual_cost_order')->where('order_no', $requestId[0])->value('mer_id');
                                if ($mer_id !== 0) {
                                    $expire_time = strtotime(date('Y-m-d')) + 86400 * 365 + 86400 - 1;
                                    Db::name('merchant')->where('mer_id', $mer_id)->update(['expire_time' => $expire_time, 'status' => 1]);
                                }
                                $mer = Db::name('user_mer') -> where('uid',$annual_cost_order['uid']) -> find();
                                if(!$mer){
                                    Db::name('user_mer') -> insert(['uid'=>$annual_cost_order['uid'],'mer'=>2]);
                                }else{
                                    Db::name('user_mer') -> where('uid',$annual_cost_order['uid'])->inc('mer', 2) ->update();;
                                }
                                $access = new Access();
                                $access->nianfei_yj($annual_cost_order['id']);
                            }
                            break;
                        case 'pay_activation':
                            try{
                                $order_data=Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> find();
                                if($order_data['status']==1){
                                    return false;
                                }
                                $access = new Access();
                                $id=Db::name('activation_code')->insertGetId([
                                    'uid'=>$order_data['uid'],
                                    'code'=>$access->randomFromDev(20),
                                    'ctime'=>time(),
                                    'status'=>1,
                                    'utime'=>time(),
                                    'use_uid'=>0,
                                    'type'=>1
                                ]);
                                Db::name('activation_code_order') -> where('order_no',$requestId[0]) -> update(['rand'=>$requestId[1],'status'=>1,'code_id'=>$id]);

                            }catch (\Exception $e) {
                                Db::name('log')->insert(['data'=>'支付激活码错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                            }
                            //处理佣金
                            $num=$access->activation_yj($requestId[0]);
                            //分账
                            $access->activation_spilet($requestId[0],$num);
                            break;
                        case 'notify_order':
                            Db::name("log")->insert(array('data'=>'汇付退款回调'));//日志记录
                            break;
                        case 'marketing':
                            $marketing_order=Db::name('marketing_order')-> where('order_no',$requestId[0])->find();
                            if($marketing_order['status']==1){
                                return app('json')->success(['result' => 'SUCCESS']);
                            }
//                            $pay_type = $pay_type == 1 ? 'wx' : 'ali';

                            $checkUser = Db::name("MarketingUser") -> where('uid',$marketing_order['uid'])->find();

                            $handle = $this -> marketing($marketing_order,$checkUser);
                            if ($handle){
                                //分账
                                $this -> pay_user_annual($marketing_order['uid']);
                            }
                            break;
                        case 'pay_user_annual':
                            $user_pension_account_order=Db::name('user_pension_account_order')-> where('order_no',$requestId[0])->find();
                            if($user_pension_account_order['status']==1){
                                return app('json')->success(['result' => 'SUCCESS']);
                            }
                            $this -> pay_user_annual($user_pension_account_order['uid'],$requestId[0]);
                            break;
                        default:
                            Db::name("log")->insert(array('data'=>$type));//日志记录
                    }


                }
                return app('json')->success(['result' => 'SUCCESS']);
            }catch (\Exception $exception){

                Db::name("log")->insert(array('data'=>'汇付回调错误：'.$exception->getFile().'：'.$exception->getLine().'【'.$exception->getMessage().'】'));//日志记录
                return app('json')->success(['result' => 'ERROR']);
            }
        }

    }

    public function pay_user_annual($uid,$order_no=''){
        Db::startTrans();
        try {
            if ($order_no != ''){
                Db::name('user_pension_account_order')-> where('order_no',$order_no) -> update(['status'=>1]);
            }

            $check = Db::name("user_pension_account") -> where("uid",$uid) -> find();
            $start_time = date('Y-m-d');
            $end_time = date("Y-m-d 23:59:59",strtotime("+1 year", strtotime($start_time)));
            $give = 0;
            //存在既续费
            if ($check){
                Db::name("user_pension_account") -> where("uid",$uid) -> update(['start_time'=>$start_time,'end_time'=>$end_time]);
                $give = $check['give'];
            }else{
                //新用户订单
                Db::name("user_pension_account") -> insert([
                    "uid" => $uid,
                    "start_time" => $start_time,
                    "end_time" => $end_time,
                    "status" => 1,
                ]);
            }
            if ($give == 0){
                Db::name("user_pension_account") -> where("uid",$uid) -> update(['give' => 1]);
                $mark = "开通养老金账户";
                $billData=[
                    'uid'=>$uid,
                    'pm'=>1,
                    'title'=>'养老金',
                    'category'=>'now_money',
                    'type'=>'commission',
                    'number'=>0.01,
                    'balance'=>0,
                    'mark'=>$mark,
                    'create_time'=>date("Y-m-d H:i:s",time()),
                    'status'=>1,
                    'order_sn'=>'',
                    'type_shop'=>0,
                    'commission_type'=>5,
                    'order_type'=>1,
                    'gzc'=>0
                ];
                Db::name('user_bill')->insert($billData);
                Db::name("user")->where("uid",$uid)->inc('annuity', 0.01) ->update();
                Db::name("user")->where("uid",$uid)->inc('annuity_num', 1) ->update();
            }
            // 提交事务
            Db::commit();
            return true;
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            Log::error($e->getMessage());
        }
    }
    public function marketing($order,$marketingUser,$pay_type="wx"){
        Db::startTrans();
        try {
            Db::name('marketing_order') -> where('order_no',$order['order_no']) -> update(['pay_type'=>$pay_type,'status'=>1]);
            Db::name('marketing_user') -> where('uid',$order['uid']) -> update(['type'=>$order['type']]);
            //分红份数及资金
            $divvy_number = ceil(bcdiv($order['pay_price'],99));
            $divvy_money = $order['pay_price'];
            Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_number', $divvy_number) ->update();
            Db::name('marketing_user') -> where('uid',$order['uid']) -> inc('divvy_money', $divvy_money) ->update();
            //上级
            $spread_uid = $marketingUser['spread_uid'];
            //养老金
            //本人给养老金10%
            $ylj=bcmul($order['pay_price'],'0.1',5);//10%的养老金
            $ylj=round($ylj,2);
            $title='养老金';

            if ($order['type'] == 1){
                $identity = "普通会员";
            }elseif ($order['type'] == 2){
                $identity = "创客";
            }elseif ($order['type'] == 3){
                $identity = "合伙人";
            }else{
                $identity = "";
            }
            $mark = "成为{$identity}获得{$ylj}养老金";
            $billData=[
                'uid'=>$order['uid'],
                'link_id'=>$order['id'],
                'pm'=>1,
                'title'=>$title,
                'category'=>'now_money',
                'type'=>'commission',
                'number'=>$ylj,
                'balance'=>0,
                'mark'=>$mark,
                'create_time'=>date("Y-m-d H:i:s",time()),
                'status'=>1,
                'order_sn'=>$order['order_no'],
                'type_shop'=>0,
                'commission_type'=>5,
                'order_type'=>1,
                'gzc'=>0
            ];

            Db::name('user_bill')->insert($billData);
            Db::name("user")->where("uid",$order['uid'])->inc('annuity', $ylj) ->update();
            Db::name("user")->where("uid",$order['uid'])->inc('annuity_num', 1) ->update();

            //上级佣金
            $checkSpread = Db::name("MarketingUser") -> where('uid',$spread_uid)->value("type");
            //检查上级身份  必须是会员或以上
            if ($checkSpread > 0){
                $commission=bcmul($order['pay_price'],'0.3',5);//30%的佣金
                $commission=round($commission,2);
                $spreadTitle='佣金';
                $spreadMark = "推广{$identity}获得{$commission}佣金";
                $spreadBillData=[
                    'uid'=>$spread_uid,
                    'link_id'=>$order['id'],
                    'pm'=>1,
                    'title'=>$spreadTitle,
                    'category'=>'now_money',
                    'type'=>'commission',
                    'number'=>$commission,
                    'balance'=>0,
                    'mark'=>$spreadMark,
                    'create_time'=>date("Y-m-d H:i:s",time()),
                    'status'=>1,
                    'order_sn'=>$order['order_no'],
                    'type_shop'=>0,
                    'commission_type'=>11,
                    'order_type'=>1
                ];
                Db::name('user_bill')->insert($spreadBillData);
                Db::name('user')->where('uid',$spread_uid)->inc('brokerage_price',$commission)->update();
            }
            $spread_list = $marketingUser['spread_list'];
            $spread_list = str_replace(['[', ']'], '', $spread_list);
            $spread_list = explode(',',$spread_list);
            //计算所有上级的累计销售业绩 赠送积分
            $achievement = $this -> achievement($spread_list,$order['uid'],$order['pay_price']);

            foreach($achievement as $key => $value){
                $spreadTitle='业务销售奖励积分';
                $achievementMark = "团队推广{$identity}获得{$value['commission']}积分";
                $integral = Db::name("marketing_user") -> where('uid',$spread_uid) -> value("integral");
                $achievementBillData=[
                    'uid'=>$key,
                    'pm'=>1,
                    'title'=>$spreadTitle,
                    'integral'=>$value['commission'],
                    'residual_integral' => $integral + $value['commission'],
//                    'mark'=>$achievementMark,
                    'order_sn'=>$order['order_no'],
                ];
                Db::name('marketing_integral')->insert($achievementBillData);
                Db::name('marketing_user')->where('uid',$spread_uid)->inc('integral',$value['commission'])->update();
            }


            if ($order['type'] == 2 || $order['type'] == 3) {
                //赠送商户
                $merchant=Db::name('merchant')->where('uid',$order['uid'])->find();
                if(!$merchant) {
                    $access = new Access();
                    $activation_code = $access->randomFromDev(20);
//                    Db::name('activation_code')->insertGetId([
//                        'uid' => $order['uid'],
//                        'code' => $activation_code,
//                        'ctime' => time(),
//                        'status' => 1,
//                        'utime' => time(),
//                        'use_uid' => $order['uid'],
//                        'type' => 1
//                    ]);
                    Db::name('merchant_intention')->insert(['uid' => $order['uid'], 'status' => 3, 'activation_code' => $activation_code]);
                }
            }
            // 提交事务
            Db::commit();
            return true;
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            Log::error($e->getMessage());
            return false;
        }

    }

    public function achievement($lists,$uid,$pay_price){

        $newList = [];
        $lastAchievement = 0;
        $lastCommission = 0;
        $total = 0;
        $list=array_reverse($lists);

        foreach($list as $value){
            $checkSpread = Db::name("MarketingUser") -> where('uid',$value)->value("type");
            //检查上级身份  必须是会员或以上
            if ($checkSpread <= 0) continue;
            $achievement = Db::name('marketing_order')
                ->where('uid','in',function($query) use ($value,$uid){
                    $query->name('marketing_user')-> where("spread_list like '%[$value]%' or uid = $value","") -> where("uid","<>",$uid) -> field("uid");
                })
                -> where("status",1)
                ->sum("pay_price");
            if ($achievement >= 50000 && $achievement < 300000){
                $c = round(bcmul($pay_price,'0.1',5),2);//10%
                //如果业绩大于5万，小于30万。并且业绩等级等于1。奖励等于上个人的奖励减半
                if ($lastAchievement == 1){
                    $c = round(bcmul($lastCommission,0.5,5),2);
                }
                $lastCommission = $c;
                $lastAchievement = 1;
                $total += $c;
                $newList[$value] = [
                    "achievement" => $achievement,
                    "commission" => $c
                ];
            }elseif ($achievement >= 300000 && $achievement < 1000000){
                $c = round(bcmul($pay_price,'0.15',5),2);//15%
                //如果业绩大于5万，小于30万。并且业绩等级等于2。奖励等于上个人的奖励减半
                if ($lastAchievement == 2){
                    $c = round(bcmul($lastCommission,0.5,5),2);
                }else{
                    $c = $c - $total;
                }

                $lastAchievement = 2;
                if ($c > 0){
                    $total += $c;
                    $lastCommission = $c;
                    $newList[$value] = [
                        "achievement" => $achievement,
                        "commission" => $c
                    ];
                }else{
                    $lastCommission = 0;
                }
            }elseif ($achievement >= 1000000){
                $c = round(bcmul($pay_price,'0.2',5),2);//20%
                //如果业绩大于5万，小于30万。并且业绩等级等于3。奖励等于上个人的奖励减半
                if ($lastAchievement == 3){
                    $c = round(bcmul($lastCommission,0.5,5),2);
                }else{
                    $c = $c - $total;
                }
                $total += $c;
                $lastAchievement = 3;
                if ($c > 0){
                    $total += $c;
                    $lastCommission = $c;
                    $newList[$value] = [
                        "achievement" => $achievement,
                        "commission" => $c
                    ];
                }else{
                    $lastCommission = 0;
                }
            }

        }
        return $newList;
    }




    //添加贡献值日志
    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);
    }












}