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 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 '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'] ?? '';
                            Db::name('store_order')->where('group_order_id', $group_order_id)->update(['pay_open_id' => $post_data_str['expend']['open_id']]);
                            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;
    }
}