php/app/controller/api/Notify.php

<?php
namespace app\controller\api;

use AdaPaySdk\AdapayTools;
use app\common\repositories\merchant\order\OrderMerchantRepository;
use app\common\repositories\movie\MovieRepository;
use app\common\repositories\store\order\StoreOrderRepository;
use app\common\repositories\store\order\StoreRefundOrderRepository;
use app\common\repositories\system\merchant\MerchantRepository;
use app\common\repositories\user\UserRepository;
use app\controller\api\merchant\sxy\Access;
use app\controller\api\store\service\Huafei;
use think\facade\Cache;
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']: '';

        if (!empty($post['id'])) {
            $requestId = $post['id'];
            $redisKey = 'api-notify-request-id:' . $requestId;
            $ttl = 60;
            $redisHandler = Cache::store('redis')->handler();
            $isSet = $redisHandler->set($redisKey, 1, ['nx', 'ex' => $ttl]);
            if ($isSet) {
                Db::name("log")->insert([
                    'data' => '汇付回调处理成功 (ID: ' . $requestId . ')'
                ]);
            } else {
                // 重复回调
                Db::name("log")->insert([
                    'data' => '汇付回调错误：重复回调 (ID: ' . $requestId . ')'
                ]);
                return app('json')->success(['result' => 'ERROR']);
            }
        } else {
            Db::name("log")->insert([
                'data' => '汇付回调错误：' . $type . '缺少必要参数（id）'
            ]);
            return app('json')->success(['result' => 'ERROR']);
        }

        # 先校验签名和返回的数据的签名的数据是否一致
        $adapay_tools=new AdapayTools();
        if (!empty($post['app_id']) && $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;
                                Db::name('order_huafei_hf')->where('order_no',$requestId[0])->update([
                                    'rand'=>$requestId[1],
                                    'pay_type'=>$pay_type,
                                    'pay_wx'=>systemConfig('pay_wx'),
                                    'app_id'=>$post['app_id'],
                                    'payment_id'=>$post_data_str['id'],
                                    'reverse_amt'=>$post_data_str['pay_amt'],
                                    'status'=>1
                                ]);
                            }catch (\Exception $e) {
                                Db::name('log')->insert(['data'=>'话费充值支付回调错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                            }
                            //话费充值支付成功推送
                            try{
                                $push = app()->make(Huafei::class)->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price'], $order_data['order_id']);
                                if($push['code'] != '0000'){
                                    $pay_wx = systemConfig('pay_wx');
                                    //推送失败 给新支付的这一笔退款
                                    Db::name('log')->insert(['data' => '给新话费充值支付的这一笔退款']);
                                    if ($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 == '1' ? 2 : 1, $pay_wx, $key);
                                    Db::name('log')->insert(['data'=>'话费充值汇付支付撤销返回结果：'.json_encode($hf_refund_res)]);
                                    //把赠送出去的养老金 积分 贡献值 复购金 改为已失效
                                    Db::name('user_bill')->where('type_shop', 9)->where('order_sn', $order_data['order_no'])->update(['status'=> -1]);
                                    Db::name('user_sign_score')->where('order_type', 9)->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
                                    Db::name('user_sign_gongxian')->where('order_type', 9)->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
                                    Db::name('user_sign_fugou')->where('order_type', 9)->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
                                    Db::name('user_sign_hongbao')->where('order_type', 9)->where('order_id', $order_data['order_no'])->update(['status'=> 0]);
                                }
                            }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);
                                $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type == '1' ? 2 : 1, $group_order['pay_wx'], $key);

                                Db::name('log')->insert(['data'=>'汇付支付撤销返回结果：'.json_encode($hf_refund_res)]);
                                break;
                            }
                            if($group_order['paid'] == 1) 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();
                            //找到对应的商品id的规格
                            $store_product_attr_value = Db::name('store_product_attr_value')->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 =  $store_order_data['con_pri'];

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

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

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

                                //分配参数
                                $job_par = [];
                                if(!empty($store_order_data)){
                                    $job_par = json_decode($store_order_data['fzone_paytype'], true);
                                    //if($job_par['note'] == "现金"){
                                    //普通消费者
                                    $ylj_pri = bcmul($concession_pri, 0.3,2);
                                    $pv = bcmul($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,$store_order_data['order_sn'],'消费获得养老金'.$ylj_pri,$store_order_data['mer_id'],0);
                                    $this->con_log_pv($user_data['uid'],$pv,$store_order_data['order_id'],0,"购买精彩生活商品赠送pv");
                                    $this->con_log($user_data['uid'],$pv,$store_order_data['order_id'],0,"购买精彩生活商品赠送贡献值");
                                    $this->score_log($user_data['uid'],$pv,$store_order_data['order_id'],0,"购买精彩生活商品赠送积分");
                                    if (!empty($user_data['is_old'])) {
                                        // 红包
                                        $this->giveHongBao($user_data['uid'], $pv, $store_order_data['order_id'], '购买精彩生活商品赠送红包');
                                    }

                                    //给推广者分配养老金
                                    //给推广者分配佣金
                                    // if ($user_data['spread_uid'] != 0) {
                                        //查询下单用户上级身份
                                        $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
                                        $StoreOrderRepository = app()->make(StoreOrderRepository::class);
                                        $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']);
                                    if ($spread_data['user_group'] == 1) {
                                        $yj_amount_90 = bcmul($pv * 0.9, $rate, 2);
                                        $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金

                                        $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);

                                        //推广养老金
                                        //推广佣金
                                        $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金', $store_order_data['mer_id'], 0);
                                        // 贡献值
                                        $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 0, "推广精彩生活商品赠送贡献值");
                                        //积分
                                        $this->score_log($spread_data['uid'], bcmul($pv, $rate, 2), $store_order_data['order_id'], 0, "推广精彩生活商品赠送积分");
                                        if($store_order_data['share_uid'] && $store_order_data['share_uid'] != 1123){
                                            $this->bill_user_log($store_order_data['share_uid'], bcmul($pv * 0.9, 0.03, 2), $store_order_data['order_id'], 20, $store_order_data['order_sn'], '分享获得佣金', $store_order_data['mer_id'], 0);
                                            $this->fugou_user_log($store_order_data['share_uid'], bcmul($pv * 0.1, 0.03, 2), $store_order_data['order_id'], 1);
                                        }
                                    } else if ($spread_data['user_group'] > 1) {

                                        $ssf = bcmul($pv, $rate, 2);
                                        $yj_amount_90 = bcmul($pv * 0.9, $rate, 2);
                                        $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金
                                        $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);

                                        //贡献值
                                        $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 0, "推广精彩生活区商品赠送贡献值");
                                        //积分
                                        $this->score_log($spread_data['uid'], $ssf, $store_order_data['order_id'], 0, "推广精彩生活区商品赠送积分");
                                        // //推广佣金
                                        $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金', $store_order_data['mer_id'], 0);
                                        //养老金
                                        $this->bill_user_log($spread_data['uid'], bcmul($pv, 0.05, 2), $store_order_data['order_id'], 5, $store_order_data['order_sn'], '推广获得养老金' . bcmul($pv, 0.05, 2), $store_order_data['mer_id'], 0);
                                        if($store_order_data['share_uid'] && $store_order_data['share_uid'] != 1123){
                                            $this->bill_user_log($store_order_data['share_uid'], bcmul($pv * 0.9, 0.03, 2), $store_order_data['order_id'], 20, $store_order_data['order_sn'], '分享获得佣金', $store_order_data['mer_id'], 0);
                                            $this->fugou_user_log($store_order_data['share_uid'], bcmul($pv * 0.1, 0.03, 2), $store_order_data['order_id'], 1);
                                        }
                                    }

                                    //锁客收益
                                    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 = bcmul($pv, 0.05,2) * 0.9;
                                            $fgj_amount_10 = bcmul($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,$store_order_data['order_sn'],'锁客获得佣金',$store_order_data['mer_id'],0);

                                        }

                                    }


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

                                //VIP专区
                            }else if($store_order_data['mer_id'] == 496){
                                $wenan = '会员专区';
                                //业务员和以上推广的等级获得推广佣金
                                $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;
                                }else if($store_product_data['price'] == 5900){
                                    $pv = 5000;
                                    $gx_jf = 3500;
                                    $yj1 = 500;
                                    $le_yw_amount = 1500;
                                }

                                $ylj_pri = bcmul($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]);

                                // 如果是会员专区的商品 不仅要将奖励的状态设置为生效，还要将订单的 结算状态修改为已结算
                                Db::name('store_order')->where('group_order_id', $group_order_id)->update(['is_settlement' => 1]);

                                $this->bill_user_log($user_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['order_sn'],'消费获得养老金'.round($pv * 0.035,2),$store_order_data['mer_id']);
 
                                $this->con_log_pv($user_data['uid'],$gx_jf,$store_order_data['order_id'],0,"购买会员专区商品赠送pv",1);
                                // $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],11,"购买会员专区商品赠送贡献值",1);
                                $this->con_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],0,"购买会员专区商品赠送贡献值",1);
                                $this->score_log($user_data['uid'],$gx_jf,$store_order_data['order_id'],0,"购买会员专区商品赠送积分",1);


                                //查询下单用户上级身份（2.0新表用户）
                                $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
                                //查询下单用户上级身份（1.0表用户，会员升级）

                                $spread_data_old = 0;
                                if($user_data['spread_old'] != 0){
                                    $sf = Db::name('old_user_jbp')->where('id',$user_data['invite_id_od'])->find();
                                    if(!empty($sf)){
                                        $spread_data_old = $sf;
                                    }

                                }

                                //给推广者分配养老金
                                //给推广者分配佣金(2.0系统中)
                           
                                 // if ($user_data['spread_uid'] != 0) {
                                // if ($user_data['uid'] > 611) {

                                    $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
                                    $StoreOrderRepository = app()->make(StoreOrderRepository::class);
                                    $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']);
                                    //user_group=1是消费者，2:业务，3:业务经理，4:初级合伙人，5:中级合伙人,6:高级合伙人，7：董事
                                    //业务或以上等级推广人
                                    //获得养老金、佣金、贡献值和积分
                                    if($spread_data['user_group'] > 1){



                                        $con =0;//贡献值
                                        $score = 0;//积分
                                        //养老金
                                        $uer_bill = $spread_data['annuity'] + bcmul($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'] + bcmul($pv, 0.07,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                            //$this->score_log($spread_data['uid'],round($pv * 0.07,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);

                                        }else if($spread_data['user_group'] == 3){
                                            $con = $spread_data['contribute'] + bcmul($pv, 0.09,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                            //$this->score_log($spread_data['uid'],round($pv * 0.09,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);


                                        }else if($spread_data['user_group'] == 4){
                                            $con = $spread_data['contribute'] + bcmul($pv, 0.11,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                           // $this->score_log($spread_data['uid'],round($pv * 0.11,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);


                                        }else if($spread_data['user_group'] == 5){
                                            $con = $spread_data['contribute'] + bcmul($pv, 0.13,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                           // $this->score_log($spread_data['uid'],round($pv * 0.13,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);

                                        }else if($spread_data['user_group'] == 6){
                                            $con = $spread_data['contribute'] + bcmul($pv, 0.15,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                           // $this->score_log($spread_data['uid'],round($pv * 0.15,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);


                                        }else if($spread_data['user_group'] == 7){
                                            $con = $spread_data['contribute'] + bcmul($pv, 0.17,2);
                                            $score = $spread_data['brokerage_price'] + bcmul($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,"推广会员专区商品赠送贡献值",1);
                                            //积分
                                            //$this->score_log($spread_data['uid'],round($pv * 0.17,2),$store_order_data['order_id'],11,"推广会员专区商品赠送积分",1);


                                        }

                                        $this->score_log($spread_data['uid'],bcmul($gx_jf, $rate, 2),$store_order_data['order_id'],0,"推广会员专区商品赠送积分",1);


                                        $this->con_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],0,"推广会员专区商品赠送贡献值",1);

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

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

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

                                        $yj_amount_90 = bcmul($yj1, 0.9,2);
                                        $fgj_amount_10 = bcmul($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,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($gx_jf * 0.3,2),$store_order_data['order_id'],0,"推广会员专区商品赠送贡献值",1);
                                        $this->score_log($spread_data['uid'],bcmul($gx_jf, $rate, 2),$store_order_data['order_id'],0,"推广会员专区商品赠送积分",1);
                                        //推广佣金
                                        $this->bill_user_log($spread_data['uid'],$yj_amount_90,$store_order_data['order_id'],3,$store_order_data['order_sn'],'推广获得佣金',$store_order_data['mer_id']);
                                    }




                                // }else if($spread_data_old != 0){
                                //
                                //     //1.0jbp系统中，如果有用户升级会员，给推荐人贡献值(90%)和养老金(10%)
                                //
                                //     $spread_data = Db::name('user')->where('uid',$spread_data_old['id'])->find();
                                //     // $spread_data = Db::name('user')->where('uid',473)->find();
                                //
                                //     //养老金
                                //     $uer_bill = $spread_data['annuity'] + bcmul($pv, 0.035,2);
                                //
                                //
                                //     $yj_amount_90 = bcmul($le_yw_amount,0.9,2);
                                //     $fgj_amount_10 = bcmul($le_yw_amount,0.1,2);//推广者的佣金抽10%到个人复购金
                                //
                                //     $yongjin = $spread_data['brokerage_price'] + $yj_amount_90;
                                //     $fgj_amount = $spread_data['fugou'] + $fgj_amount_10;
                                //
                                //
                                //     $this->con_log($spread_data['uid'],round($gx_jf,2),$store_order_data['order_id'],0,"推广会员专区商品赠送贡献值",1);
                                //     //养老金
                                //     $this->bill_user_log($spread_data['uid'],round($pv * 0.035,2),$store_order_data['order_id'],5,$store_order_data['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,$store_order_data['order_sn'],'推广获得佣金',$store_order_data['mer_id']);
                                //     //复购金
                                //     $this->fugou_user_log($spread_data['uid'],$fgj_amount_10,$store_order_data['order_id'],1,1);
                                //
                                //
                                //     $orderInfo=[
                                //         'num'=>1,
                                //         'gb_num'=>1,
                                //         'price'=>$store_product_data['price']
                                //     ];
                                //     $goods_of_info1 = Db::name("old_user_of_goods")->where("id", $store_order_data['user_of_goods_id'])->find();//用户的订单价格表
                                //
                                //     if(!empty($goods_of_info1)){
                                //        // $spread_data = Db::name('test_log')->insert(['note'=>"goodsofinf22222o:".json_encode($goods_of_info1)]);
                                //
                                //         $this->member_update($orderInfo,$goods_of_info1,$user_data['uid']);
                                //     }
                                //
                                //
                                //
                                // }

                                //锁客收益  todo 会员专区不做锁客 20250415
//                                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 = bcmul($pv * 0.9, 0.035,2);
//                                        $fgj_amount_10 = bcmul($pv * 0.1, 0.035,2);//推广者的佣金抽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,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,$store_order_data['order_sn'],'推广获得佣金',$store_order_data['mer_id']);
//                                    }
//
//                                }


                                $fzone_paytype = json_decode($store_order_data['fzone_paytype'],true);
                                $user_data = Db::name('user')->where('uid',$store_order_data['uid'])->find();

                                //会员专区的现金+VR支付
                                if($fzone_paytype['type'] == 'a3'){
                                  

                                    $dev_vr = $user_data['vr'] - $fzone_paytype['other'];

                                    if($dev_vr >= 0){
                                        $user_data_dev_vr = Db::name('user')->where('uid',$store_order_data['uid'])->update(["vr"=>$dev_vr]);
                                    
                                        if($user_data_dev_vr){
                                            //支出账号存到log日志
                                            $log_data = [
                                                'uid'=>$user_data['uid'],
                                                'number'=>$fzone_paytype['other'],
                                                'mark'=>"购买会员专区商品消费VR:" . $fzone_paytype['other'],
                                                'desc'=>"VR",
                                                'order_id'=>0,
                                                'surplus'=>$dev_vr,
                                                'order_type'=>0,
                                                'type'=>2,
                                                'addtime'=>time()
                                            ];
                                            $user_res_log = Db::name("user_sign_vr")->insert( $log_data);
                                        }
                                    }else{
                                        $log_data = [
                                          
                                            'note'=>"uid:" . $store_order_data['uid'] . " 购买会员专区商品消费VR:" .$fzone_paytype['other'] . " 用户消费前的VR余额:" .  $user_data['vr'] . "描述:" ."未扣成功!" . "备注:" . json_encode($fzone_paytype),
                                           
                                            'create_time'=>date("Y-m-d H:i:s",time())
                                        ];
                                        Db::name("test_log")->insert( $log_data);
                                    }

                                    
                                }

                                //会员专区，给用户升级判断 todo 疑似重复升级代码先做注释
//                                $orderList = Db::name("store_order")->where("uid", $store_order_data['uid'])->where("mer_id", 496)->where("status", "in", [0, 1, 2, 3])->select();
//                                // 初始化总和变量
//                                $totalPayPrice = 0;
//
//                                // 遍历查询结果
//                                foreach ($orderList as $order) {
//                                    // 累加 pay_price
//                                    $totalPayPrice += $order['pay_price'];
//                                }
//
//                                $userdata = Db::name("user")->where("uid", $store_order_data['uid'])->find();
//
//                                if ($totalPayPrice >= 1180 && $totalPayPrice < 11800) {
//
//                                    if ($userdata['user_group'] <= 1) {
//                                        Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 2]);
//                                    }
//
//                                } else if ($totalPayPrice >= 11800) {
//                                    if ($userdata['user_group'] <= 2) {
//                                        Db::name("user")->where("uid", $store_order_data['uid'])->update(["user_group" => 3]);
//                                    }
//                                }


                            } else {
                                $wenan = '商贸区';
                                // 商贸区
                                /** @var \app\common\repositories\merchant\MerchantRepository $merchant */
                                $merchant = app()->make(MerchantRepository::class);
                                $merchantInfo = $merchant->get($store_order_data['mer_id']);
                                // 1企业2个体3个人
                                if ($merchantInfo && !empty($store_order_data) && in_array($merchantInfo['type'], [1, 2, 3])) {
                                    //商家让利部分的拆分
                                    $ylj_pri = bcmul($concession_pri, 0.3, 2); // 让利部分30%给消费者做养老金
                                    $pv = bcmul($concession_pri, 0.35, 2); // 35%做业绩PV分配

                                    // 让利部分30%给消费者做养老金{$ylj_pri}
                                    $this->bill_user_log($user_data['uid'], $ylj_pri, $store_order_data['order_id'], 5, $store_order_data['order_sn'], '购买商贸区商品获得养老金' . $ylj_pri, $store_order_data['mer_id'], 0);
                                    // 购买商贸区赠送贡献值
                                    $this->con_log($user_data['uid'], $pv, $store_order_data['order_id'], 0, "购买商贸区商品赠送贡献值");
                                    // 购买商贸区赠送PV值
                                    $this->con_log_pv($user_data['uid'], $pv, $store_order_data['order_id'], 0, "购买商贸区赠送PV值");
                                    // 积分
                                    $this->score_log($user_data['uid'], $pv, $store_order_data['order_id'], 0, "购买商贸区商品赠送积分");
                                    if (!empty($user_data['is_old'])) {
                                        // 红包
                                        $this->giveHongBao($user_data['uid'], $pv, $store_order_data['order_id'], '购买商贸区商品赠送红包');
                                    }
                                    $StoreOrderRepository = app()->make(StoreOrderRepository::class);
                                    $StoreOrderRepository->con_log_fenrun($merchantInfo['uid'],$concession_pri,$store_order_data['order_id'],0,'商贸区下单产生分润值');
                                    $spread_data = Db::name('user')->where('uid',$user_data['spread_uid'])->find();
                                    if($spread_data) {
                                        $StoreOrderRepository = app()->make(StoreOrderRepository::class);
                                        $rate = $StoreOrderRepository->getUserGroupRate($spread_data['user_group']);
                                        if ($spread_data['user_group'] == 1) {
                                            $yj_amount_90 = bcmul($pv * 0.9, $rate, 2);
                                            $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金

                                            $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);

                                            //推广养老金
                                            //推广佣金
                                            $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金', $store_order_data['mer_id'], 0);
                                            // 贡献值
                                            $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 0, "推广商贸区商品赠送贡献值");
                                            //积分
                                            $this->score_log($spread_data['uid'], bcmul($pv, $rate, 2), $store_order_data['order_id'], 0, "推广商贸区商品赠送积分");
                                        } else if ($spread_data['user_group'] > 1) {

                                            $ssf = bcmul($pv, $rate, 2);
                                            $yj_amount_90 = bcmul($pv * 0.9, $rate, 2);
                                            $fgj_amount_10 = bcmul($pv * 0.1, $rate, 2);//推广者的佣金抽10%到个人复购金
                                            $this->fugou_user_log($spread_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);

                                            //贡献值
                                            $this->con_log($spread_data['uid'], $pv, $store_order_data['order_id'], 0, "推广商贸区商品赠送贡献值");
                                            //积分
                                            $this->score_log($spread_data['uid'], $ssf, $store_order_data['order_id'], 0, "推广商贸区商品赠送积分");
                                            // //推广佣金
                                            $this->bill_user_log($spread_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金', $store_order_data['mer_id'], 0);
                                            //养老金
                                            $this->bill_user_log($spread_data['uid'], bcmul($pv, 0.05, 2), $store_order_data['order_id'], 5, $store_order_data['order_sn'], '推广获得养老金' . bcmul($pv, 0.05, 2), $store_order_data['mer_id'], 0);
                                        }
                                    }

                                    //锁客收益
                                    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 = bcmul($pv * 0.9, 0.05, 2);
                                            $fgj_amount_10 = bcmul($pv * 0.1, 0.05, 2);//推广者的佣金抽10%到个人复购金
                                            $this->fugou_user_log($merchant_data['uid'], $fgj_amount_10, $store_order_data['order_id'], 1);
                                            //推广佣金
                                            $this->bill_user_log($merchant_data['uid'], $yj_amount_90, $store_order_data['order_id'], 3, $store_order_data['order_sn'], '推广获得佣金', $user_data['mer_id'], 0);
                                        }
                                    }

                                    //京豆赠送
                                    if ($store_order_data['mer_id'] > 0) {
                                        /** @var OrderMerchantRepository $orderMerchantRepository */
                                        $orderMerchantRepository = app()->make(OrderMerchantRepository::class);
                                        $jdAndGonxianConfig = $orderMerchantRepository->getMerchantContribution($store_product_attr_value['extension_one']);
                                        $merchant_data = Db::name('merchant')->where('mer_id', $store_order_data['mer_id'])->find();

                                        //商户获得贡献值  ---- 3月29日  商户不再获得贡献值 改为获得分润值
                    //                    if ($concession_pri >= 0.01) {
                    //                        $gonxian = bcmul($concession_pri, $jdAndGonxianConfig['gonxian'], 2);
                    //                        $gongxian_data = [
                    //                            "uid" => $merchant_data["uid"],
                    //                            "mer_id" => $user_data['mer_id'],
                    //                            "pv" => $pv,
                    //                            "number" => $gonxian,
                    //                            "addtime" => time(),
                    //                            "status" => -1,
                    //                            "order_type" => 2,
                    //                            "order_id" => $store_order_data['order_id'],
                    //                            "mark" => "锁客商家获得贡献值",
                    //                            "desc" => '',
                    //                            "surplus" => $gonxian,
                    //                            "type" => 1
                    //                        ];
                    //                        Db::name("user_sign_gongxian")->insert($gongxian_data);//添加记录
                    //                    } else {
                    //                        Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，贡献值低于0.01无法入库 特此记录！']);
                    //                    }

                                        //商户获得京豆
                                        $jd = bcmul($concession_pri, $jdAndGonxianConfig['jd'], 2);
                                        if ($jd >= 0.01) {
                                            $jd_data = [
                                                "uid" => $merchant_data["uid"],
                                                "mer_id" => $store_order_data['mer_id'],
                                                "number" => $jd,
                                                "addtime" => time(),
                                                "status" => -1,
                                                "order_type" => 0,
                                                "order_id" => $store_order_data['order_id'],
                                                "mark" => "线上用户消费商家获得京豆",
                                                "desc" => '',
                                                "surplus" => $jd,
                                                "type" => 1
                                            ];
                                            Db::name("user_sign_jingdou")->insert($jd_data);//添加记录
                                        } else {
                                            Db::name('log')->insert(['data' => '订单号：' . $store_order_data['order_id'] . '付款额度较低或 商家、平台设置的返佣比例较低，京豆低于0.01无法入库 特此记录！']);
                                        }
                                    }
                                }
                            }

                         

                            //判断是否是精彩生活区的商品
                            if($store_order_data['mer_id'] == 439){
                                //供应链的状态
                                Db::name('store_order')->where('group_order_id', $group_order_id)->update(['douhuomall'=>1,'douhuomall_status'=>9]);
                            }
                            
                             //判断是否是自营商品，如果是自营商品需要更改这个值
                             
                            if($store_order_data['mer_id'] == 496 || $store_order_data['mer_id'] != 439){
                                //自营商品
                                Db::name('store_order')->where('group_order_id', $group_order_id)->update(['distribution_mode'=>1]);
                            }
                            
                            
                          


                            //利润分配 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]);

                                        //消费积分日志
                                        $log_data = [
                                            "uid" => $user_data['uid'],
                                            "reward_socre" => $array_fzone_paytype['other'],
                                            "addtime" => time(),
                                            "status" => 1,
                                            "order_id" => $store_order_data['order_id'],
                                            "mark" => "购买" . $wenan . "商品消费积分",
                                            "surplus" => $vrpri,
                                            "pm" => 2,
                                            "source_type" => 5,
                                            "order_type" => 0,
                                        ];
                                        Db::name("user_sign_score")->insert($log_data);
                                    }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)]);
                                }
                            } else if($array_fzone_paytype['type']=='b4'){
                                if(!empty($array_fzone_paytype['other']) && is_numeric($array_fzone_paytype['other']) == true){
                                    $jdpri = $user_data['jingdou'] -  $array_fzone_paytype['other'];

                                    // 现金+京豆
                                    if($jdpri  >= 0 ){
                                        Db::name("user")->where("uid", $user_data['uid'])->update(['jingdou'=>$jdpri]);
                                        Db::name('user_sign_jingdou')->insert([
                                            'uid' => $user_data['uid'],
                                            'number' => $array_fzone_paytype['other'],
                                            'status' => 1,
                                            'mark' => '购买' . $wenan . '商品消费京豆',
                                            'addtime' => time(),
                                            'surplus' => $jdpri,
                                            'settlement_time' => date('Y-m-d H:i:s'),
                                            'type' => 2,
                                            'order_type' => 0,
                                            'order_id' => $store_order_data['order_id']
                                        ]);
                                    }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;
                        case 'movie': // 电影订单支付回调
                            /** @var MovieRepository $movieRepository */
                            $movieRepository = app()->make(MovieRepository::class);
                            $movieRepository->updateMovieOrderAndcalculationCommissionDividendAward($pay_type, $requestId[0], $post_data_str);
                            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 member_update($orderInfo,$goods_of_info,$user_id)
    {


        //code...
        $pay_gb =  bcmul($orderInfo['num'], $orderInfo['gb_num'],2);
        //$pay_vr =  round($orderInfo['num'] * $orderInfo['vr_num'],2);
        //付款按照700的VR付款 start
        $vr_num = 0;
        if ($orderInfo['price'] == 1180) {
            $vr_num = 700;
        } elseif ($orderInfo['price'] == 11800) {
            $vr_num = 7000;
        } elseif ($orderInfo['price'] == 11800) {
            $vr_num = 2100;
        }elseif($orderInfo['price'] == 10620){
            $vr_num = 6300;
        }



        $pay_gb1 = $vr_num;
        $pay_vr1 =$orderInfo['price'];//记录VR值


        // $result = Db::name("old_user_jbp")->where("id",$user_id)->dec("vr",$orderInfo['price'])->save();//1.0jbp旧表
        // Db::name("user")->where("uid",$user_id)->dec("vr",$orderInfo['price'])->save();//2.0新表
    

        $result = true;
        if($result) {
            $invite_id = $goods_of_info['spread_id'];


            $zs_ylj = 0; //养老金赋值


            if($orderInfo['price'] == 1180){
                //修改订单到账状态
                $zs_ylj = bcmul(700, 0.05,2);//计算的养老金 金额
            }elseif($orderInfo['price'] == 11800){
                $zs_ylj = bcmul(7000, 0.05,2);//计算的养老金 金额
            }elseif($orderInfo['price'] == 3540){
                $zs_ylj = bcmul(2100, 0.05,2);//计算的养老金 金额
            }elseif($orderInfo['price'] == 10620){
                $zs_ylj = bcmul(6300, 0.05,2);//计算的养老金 金额
            }elseif($orderInfo['price'] == 9440){
                $zs_ylj = bcmul(5600, 0.05,2);//八单计算的养老金 金额
            }elseif($orderInfo['price'] == 2360){
                $zs_ylj = bcmul(1400, 0.05,2);//两单计算的养老金 金额
            }


          //  $spread_data = Db::name('test_log')->insert(['note'=>"price1:" . $orderInfo['price'] ." pri2:" .   $zs_ylj]);

            $uid = $user_id;
            $new_user_id = $uid;
            if(empty($new_user_id)) {
                abort(0,"当前绑定会员查询错误");
            }

            $new_nums =Db::name("old_user_of_goods")->where("user_id", $uid)->sum("money");

            //增加过后权益对比 获取当前权益等级
            $old_level_id = Db::name("old_user_jbp")->where("id",$uid)->find();

            $old_level_info = Db::name("old_user_level")->where("id",$old_level_id['user_level_id'])->find();


            $level_info = [];
            $level_list = Db::name("old_user_level")->order("money desc")->select();


            //计算会员等级 升级
            foreach ($level_list as $key => $value) {
                # code...
                if($new_nums>=$value['money']) {
                    $level_info =  $value;
                    break;
                }
            }

            $zs_gb = $orderInfo['price'] * 3;
            $zs_withdraw_quota = $orderInfo['price'];


            if($old_level_info['id'] == $level_info['id']) {
                //未到达升级权益 不改变用户等级
                $update_status = false;
            }else{
                $update_status = true;
                $user_level = $level_info['id'];
                //var_dump( $user_level);
                Db::name("old_user_jbp")->where("id",$new_user_id)->save(['user_level_id'=>$user_level]);//1.0jbp旧表
                Db::name("user")->where("uid",$new_user_id)->save(['user_level_id_old'=>$user_level]);//2.0新表

                // todo 同时改变他的权益
            }

          

        

            //检查是不是订单价格是1180或者11800，更改VR
            //if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440  || $goods_of_info['money'] == 2360){
                //修改订单到账状态

               // $spread_data = Db::name('test_log')->insert(['note'=>"goodid:" . $goods_of_info['id'] .' money:'.$goods_of_info['money'].' pay_vr:'.$pay_vr1]);

                Db::name("old_user_of_goods")->where("id",$goods_of_info['id'])->save(['status'=>1,'money'=>$orderInfo['price'],'pay_gb'=>0,'pay_vr'=>$pay_vr1,'pay_bt'=>0,'create_time'=>time()]);

               // $spread_data = Db::name('test_log')->insert(['note'=>"money:" . $goods_of_info['money'] ." pay_vr:" .   $pay_vr1]);
           // }
        }



        if($result) {
            //更改订单状态

            Db::commit();
            $new_user_name = Db::name("old_user_jbp")->where("id",$new_user_id)->value("user_name");
            $new_user_name = empty($new_user_name) ? "" : $new_user_name;

            //记录日志信息

            if($user_id == $invite_id) {
                //报单中心=推荐人 GB记录日志有问题需要传入指定参数去计算
                //$money = Db::name("old_user_jbp")->where("id",$user_id)->value("gb");
                //$appoint_money = $money - $zs_invite_gb;

                //if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440  || $goods_of_info['money'] == 2360){


                    $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);

               // }
            }else{

               // if($goods_of_info['money'] == 1180 || $goods_of_info['money'] == 11800 || $goods_of_info['money'] == 3540 || $goods_of_info['money'] == 10620 || $goods_of_info['money'] == 9440  || $goods_of_info['money'] == 2360){


                    $this->change_user_log66($user_id,"vr",2,$pay_vr1,"declare_expend",'权益消费VR-'.$new_user_name);

                //}
            }
            // $this->change_user_log66($new_user_id,'gb',1,$zs_gb,"levle_update_zs","权益升级达标赠送");
            $this->change_user_log66($new_user_id,'withdraw_quota_old',1,$zs_withdraw_quota,"levle_update_zs","权益升级达标赠送");
            // $this->change_user_log66($invite_id,'gb',1,$zs_invite_gb,"levle_update_zs","邀请-".$new_user_name);
            // echo 123;return;
            //处理查看是否有待发放佣金
            // $zs_withdraw_quota
            Db::name("old_user_jbp")->where("id",$new_user_id)->inc("total_withdraw_quota",$zs_withdraw_quota)->save();//1.0jbp旧表
            Db::name("user")->where("uid",$new_user_id)->inc("total_withdraw_quota_old",$zs_withdraw_quota)->save();
            // $this->releaseTobeAmount($new_user_id,$zs_withdraw_quota);
            // $this->success("支付成功",['is_cash'=>0]);
        }
        Db::rollback();
        // $this->error("操作失败");
    }

    function change_user_log66($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;
        }
        $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 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 giveHongBao($uid, $pv, $order_id, $mark, $status = -1)
    {
        //添加红包
        $hongbao = bcmul($pv, 0.45, 2);
        $hongbao_data = [
            "uid" => $uid,
            "number" => $hongbao,
            "addtime" => time(),
            "status" => $status,
            "order_type" => 0,
            "order_id" => $order_id,
            "mark" => $mark,
            "desc" => '',
            "surplus" => $hongbao,
            "type" => 1, //1消费赠送
            'settlement_time' => date('Y-m-d H:i:s')
        ];
        Db::name("user_sign_hongbao")->insert($hongbao_data);//添加记录
    }

    public function con_log_pv($uid, $pv, $order_id, $order_type, $mark, $status = -1)
    {
        // 添加pv记录
        $pv_data = [
            "uid" => $uid,
            "pv" => $pv,
            "addtime" => time(),
            "status" => $status,
            "order_type" => $order_type,
            "order_id" => $order_id,
            "mark" => $mark,
        ];
        // 当状态为1时是实时结算
        if($status == 1) {
            // Db::name('user')->where('uid', $uid)->inc('pv', (float)$pv)->update();
            $con_data = Db::name('user')->where("uid", $uid)->find();
            Db::name('user')->where("uid", $uid)->update(['pv' => ($con_data['pv']?:0) + $pv]);
            $pv_data['settlement_time'] = date('Y-m-d H:i:s');
        }
        Db::name("user_pv_log")->insert($pv_data);//添加pv记录
    }

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

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

        $con = [
            'uid'=>$uid,
            'number'=>$num,//赠送数量
            'status'=>$status,//红包状态
            '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);

        //如果状态是1那就是即刻入账，
        if($status == 1){
          

            // //如果当前用户是业务经理之前的等级，那么需要将当前用户的直推用户贡献值加到自己贡献值中去
            // if( $con_data['user_group'] <= 2 ){
           
                $spread_data = Db::name('user')->where("spread_uid",$uid)->select();

                if (strpos($mark, "购买") !== false) {
                    Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]);
                    /** @var UserRepository $userRepository */
                    $userRepository = app()->make(UserRepository::class);
                    $userRepository->setUserIdentity($uid);
                }

                if (strpos($mark, "推广") !== false) {
                    Db::name('user')->where("uid",$uid)->update(['per_contribute'=>$con_data['per_contribute'] + $num]);
                    /** @var UserRepository $userRepository */
                    $userRepository = app()->make(UserRepository::class);
                    $userRepository->setUserIdentity($uid);
                }

                //if(count($spread_data) > 0){
                    // $all_ids = [];
                    // foreach($spread_data as $k=>$v){
                    //     $all_ids[] = $v['uid'];
                    // }
    
                    // // 查询当前用户及其子级的所有订单
                    // $orders = Db::name("store_order")
                    // ->whereIn('status', [0, 1, 2, 3])
                    // ->whereIn("uid", $all_ids)
                    // ->whereIn("total_price", [1180, 11800, 10620, 2360, 9440])
                    // ->select();
    
                    // // 计算总业绩
                    // $totalPv = 0;
                    // foreach ($orders as $order) {
                    //     switch ($order['total_price']) {
                    //     case 1180:
                    //         $totalPv += 700;
                    //         break;
                    //     case 11800:
                    //         $totalPv += 7000;
                    //         break;
                    //     case 10620:
                    //         $totalPv += 6300;
                    //         break;
                    //     case 2360:
                    //         $totalPv += 1400;
                    //         break;
                    //     case 9440:
                    //         $totalPv += 5600;
                    //         break;
                    //     }
                    // }
                    
                  
                  

               // }

            // }else{
                
            //     // 检查是否包含“推广”
            //     // if (strpos($mark, "推广") !== false) {
            //     //     echo "字符串1包含'推广'\n";
            //     // }

                // 检查是否包含“购买”
//                if (strpos($mark, "购买") !== false) {
//                    Db::name('user')->where("uid",$uid)->update(['contribute'=>$con_data['contribute'] + $num]);
//                    /** @var UserRepository $userRepository */
//                    $userRepository = app()->make(UserRepository::class);
//                    $userRepository->setUserIdentity($uid);
//                }

                 
               
               
            // }

        }
    }

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

        $score_data = Db::name('user')->where("uid",$uid)->find();
        //如果状态是1那就是即刻入账，
        if($status == 1){
            $con_data_score = Db::name('user')->where("uid",$uid)->update(['score'=>$score_data['score'] + $num]);
        }

        $score = [
            'uid'=>$uid,
            'continuity_day'=>0,//连续签到天数
            'reward_socre'=>$num,//积分数量
            'signin_time'=>0,//签到时间
            'source_uid'=>0,//赠送积分用户来源id
            'status'=>$status,//积分状态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=0){

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

         //查询支付方式
         $array_fzone_paytype = json_decode($order_from_mer['fzone_paytype'],true);
         $pay_type = 3;//默认是微信
         if($array_fzone_paytype['note'] != "现金"){
             $pay_type = 4;
         }
        $take_time = '';
        $sm_status = 0;//储存当前用户是否有实名的状态

        if($order_from_mer['mer_id'] == 496){
            $take_time = time();
            //如果是会员区的直推就即刻到账
            if($comm_order_type == 3){
                Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]);
            }
            //如果是会员区的养老金，查看是否有实名，如果实名就改变订单状态和user-bill的状态
            if($comm_order_type == 5){

              
                //当前用户是否有实名，然后改变user_bill和order_store的gzc状态
                $get_cer_datas = Db::name('user_certification')->where("uid", $uid)->find();
                if (!empty($get_cer_datas)) {
                    if (!empty($get_cer_datas['user_card'])) {

                        $sm_status = 1;
                        $ds = 1;
                        Db::name('store_order')->where("order_id", $order_id)->update(['gzc' => 1]);
                    }
                }
            }
            $ds = 1;
        }


        $name = '';
       
        if($comm_order_type==3){
            $name = '直推奖';
        }else if($comm_order_type==5){
            $name = '养老金';
            //$user_bill_status = Db::name('store_order')->where("order_id",$order_id)->update(['gzc'=>1]);
        } else if ($comm_order_type == 20) {
            $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'=> $sm_status,//养老金是否已进入公证处log表0：未进入。1：已进入
            'is_gzc' => $sm_status,//0：未发起 1：已发起 2：已成功
            'take_time'=>$take_time,//结算时间
            'district_id'=>'',//
            'street_id'=>'',//
            'month'=>'',//月份

        ];

        $bill_id = Db::name('user_bill')->insertGetId($bill);

        if ($sm_status == 1) {
            //添加养老金到公证处日志
            $ylj_data_log = [
                'user_name' => $get_cer_datas['user_name'],
                "mobile" => $get_cer_datas['mobile'],
                "user_card" => $get_cer_datas['user_card'],//身份证
                "pension" => $num,//养老金额度
                "out_trade_no" => $order_from_mer['order_sn'],//订单号
                "account_type" => $pay_type,//支付方式(3:微信,4:组合)
                "order_type" => 0,//订单类型(2:)
                "pay_time" => date('Y-m-d H:i:s'),
                "create_time" => date('Y-m-d H:i:s'),
                "update_time" => date('Y-m-d H:i:s'),
                "uid" => $uid,
                "platform_no" => 'IN10' . (int)(microtime(true) * 1000) . mt_rand(10000, 99999),
                "link_id" => $bill_id
            ];
            Db::name('gzc_logs')->insert($ylj_data_log);
        }
    }

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

        $fugou_data = Db::name('user')->where("uid",$uid)->find();
        //如果状态是1那就是即刻入账，
        if($status == 1){
            $con_data_fugoujin = Db::name('user')->where("uid",$uid)->update(['fugou'=>$fugou_data['fugou'] + $num]);
        }

        $bill = [
            'uid'=>$uid,
            'number'=>$num,//数量
            'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
            'mark'=>"复购金",//备注
            'desc'=>"抽取佣金的10%作为复购金",//描述
            'order_id'=>$order_id,//订单id
            'surplus'=>0,//剩余
            'order_type'=>0,//关联订单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 buchong(){
        $list = Db::name('user_sign_fugou')->where('order_id', 2147483647)->where('mark', '购买话费商品赠送复购金')->where('status', -1)->select();
        foreach($list as $k => $v){
            $score = Db::name('user_sign_score')->where('uid', $v['uid'])->where('addtime', $v['addtime'])->where('mark', '购买话费商品赠送积分')->find();
            if($score){
                $update_data['status'] = $score['status'];
                $update_data['order_id'] = $score['order_id'];
                Db::name('user_sign_fugou')->where("id", $v['id'])->update($update_data);
            }
        }


        // foreach($list as $k => $v){
        //     $fzone_paytype = json_decode($v['fzone_paytype'], true);
        //     if(isset($fzone_paytype['jingdou'])) $update_data['fzone_pay_jingdou'] = $fzone_paytype['jingdou'];
        //     if(isset($fzone_paytype['vr'])) $update_data['fzone_pay_vr'] = $fzone_paytype['vr'];
        //     if(isset($fzone_paytype['jifen'])) $update_data['fzone_pay_jifen'] = $fzone_paytype['jifen'];
        //     if(isset($fzone_paytype['price'])) $update_data['fzone_pay_price'] = $fzone_paytype['price'];
        //     if(isset($fzone_paytype['other'])) $update_data['fzone_pay_other'] = $fzone_paytype['other'];
        //     if(isset($fzone_paytype['type'])) $update_data['fzone_pay_type'] = $fzone_paytype['type'];
        //     if(isset($fzone_paytype['note'])) $update_data['fzone_pay_note'] = $fzone_paytype['note'];
        //     Db::name('store_order')->where("order_id", $v['order_id'])->update($update_data);
        // }
        return app('json')->success(['result' => 'ok']);
    }







}