");
            // var_dump($rst);
            $rst1 =  Db::name("user_billions_surplus_log")->field("user_billion_id")
                ->where("surplus_id",$result['surplus_id'])
                ->select()->toArray();
            $a = array();
            foreach($rst1 as $key=>$value){
                $a[] = $value['user_billion_id'];
            }
            //  print_r("
");
            //   var_dump($result['surplus_id']);
            // var_dump($a);

            foreach($rst as $key=>$value){
                $b = array_search($value['billions_id'],$a);
                //  var_dump($b);
                // var_dump($value['billions_id']);
                if($b===false){
                    $r[$i]['billions_id'] = $value['billions_id'];
                    $r[$i]['surplus_id'] = $result['surplus_id'];
                    $r[$i]['user_id'] = $value['user_id'];
                    $r[$i]['order_price'] = $value['order_price'];
                    $r[$i]['subsidy_price'] = $value['subsidy_price'];
                    $i = $i+1;
                    if($i == 1000){
                        break;
                    }
                }
            }
            //   print_r("
");
            // var_dump($r);die;
            // foreach($rst as $key=>$value){
            //     $rs = Db::name("user_billions_surplus_log")
            //     ->field("surplus_id")
            //     ->where("user_billion_id",$value['billions_id'])
            //      ->where("surplus_id",$result['surplus_id'])
            //     ->find();
            //     if($rs == null){
            //         $r[$i]['billions_id'] = $value['billions_id'];
            //         $r[$i]['surplus_id'] = $rs['surplus_id'];
            //         $r[$i]['user_id'] = $value['user_id'];
            //         $r[$i]['order_price'] = $value['order_price'];
            //         $r[$i]['subsidy_price'] = $value['subsidy_price'];
            //         $i = $i+1;
            //         if($i == 1000){
            //             break;
            //         }
            //     }
            // }
            // print_r("
");
            // var_dump($r);die;
            // die;
            // $r = Db::name("user_billions")->alias("a")
            // ->field("a.billions_id,b.surplus_id,a.user_id,a.order_price,a.subsidy_price")
            // ->join("user_billions_surplus_log b","a.billions_id = b.billions_id","left")
            // ->where("a.billions_id","<=",$result['billions_id'])
            // ->where("b.surplus_id IS NULL")
            // ->where("a.state",0)
            // ->limit(1000)
            // ->select()->toArray();
            if(count($r)>0){
                foreach($r as $key=>$value){
                    $ranking = BillionsLogic::getRanking($value['billions_id']);
                    $data['price'] = 0;
                    if($ranking <= $result['user_start_num']){
                        if($result['user_start_price'] >0){
                            if($result['user_start_avg_price'] <= $result['user_start_price']){
                                $dec_price = $data['price'] = $result['user_start_avg_price'];
                            }else{
                                $dec_price = $data['price'] = $result['user_start_price'];
                            }
                            Db::name("user_billions_surplus")
                                ->where("surplus_id",$result['surplus_id'])
                                ->dec("user_start_price",$dec_price)
                                ->update();
                        }
                    }else{
                        if($result['user_price'] <= $result['residue_price']){
                            $dec_price = $data['price'] = $result['user_price'];
                        }else{
                            $dec_price = $data['price'] = $result['residue_price'];
                        }
                        Db::name("user_billions_surplus")
                            ->where("surplus_id",$result['surplus_id'])
                            ->dec("residue_price",$dec_price)
                            ->update();
                    }
                    $data['surplus_id'] = $result['surplus_id'];
                    $data['user_id'] = $value['user_id'];
                    $data['billions_id'] = $result['billions_id'];
                    $data['user_billion_id'] = $value['billions_id'];
                    $data['dtime'] = date("Y-m-d H:i:s");
                    Db::name("user_billions_surplus_log")->save($data);
                    if($value['order_price'] <= $data['price'] + $value['subsidy_price']){
                        // 查询用户总余额账户
                        $first_user_all_account = Db::name("subsidy_withdrawal")->where("user_id",$value['user_id'])->find();
                        if($first_user_all_account != null){
                            // 判断账户是否可用
                            if($first_user_all_account['state'] == 0 || $first_user_all_account['state'] == 2){
                                return -2;
                            }
                            // 更新主表
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->where("user_id",$value['user_id'])->inc("total_amount",$value['order_price'])->update();
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_user_all_account['id'];
                            $dat['user_id'] = $value['user_id'];
                            $dat['billions_id'] = $value['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] = $value['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $value['user_id'],
                                    'money' => $value['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }else{
                            $d['user_id'] = $value['user_id'];
                            $d['total_amount'] = $value['order_price'];
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->insertGetId($d);
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_update_subsidy_withdrawal;
                            $dat['user_id'] = $value['user_id'];
                            $dat['billions_id'] = $value['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] =  $value['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $value['user_id'],
                                    'money' => $value['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }
                        // 更新排队状态
                        $first_update_user_billions = Db::name("user_billions")->where("billions_id",$value['billions_id'])->update(['subsidy_price'=> $value['order_price'],"state"=>2]);
                        if(!$first_update_user_billions){
                            return -3;
                        }
                    }else{
                        $subsidy_price_sum = round($value['subsidy_price']+$data['price'],8);
                        Db::name("user_billions")->where("billions_id",$value['billions_id'])->update(['subsidy_price'=>$subsidy_price_sum]);
                    }
                }
            }else{
                if($result['user_start_price']>0){
                    $rets = Db::name("user_billions")->where("state",0)->limit(1)->select()->toArray();
                    if($rets[0]['order_price'] <= $result['user_start_price'] + $rets[0]['subsidy_price']){
                        $p = $result['user_start_price'] + $rets[0]['subsidy_price'] - $rets[0]['order_price'];
                        Db::name("user_billions_surplus")
                            ->where("surplus_id",$result['surplus_id'])
                            // ->dec("user_start_price",0)
                            ->update(['user_start_price'=>$p]);
                        // 查询用户总余额账户
                        $first_user_all_account = Db::name("subsidy_withdrawal")->where("user_id",$rets[0]['user_id'])->find();
                        if($first_user_all_account != null){
                            // 判断账户是否可用
                            if($first_user_all_account['state'] == 0 || $first_user_all_account['state'] == 2){
                                return -2;
                            }
                            // 更新主表
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->where("user_id",$rets[0]['user_id'])->inc("total_amount",$rets[0]['order_price'])->update();
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_user_all_account['id'];
                            $dat['user_id'] = $rets[0]['user_id'];
                            $dat['billions_id'] = $rets[0]['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] = $rets[0]['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $rets[0]['user_id'],
                                    'money' => $rets[0]['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }else{
                            $d['user_id'] = $rets[0]['user_id'];
                            $d['total_amount'] = $rets[0]['order_price'];
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->insertGetId($d);
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_update_subsidy_withdrawal;
                            $dat['user_id'] = $rets[0]['user_id'];
                            $dat['billions_id'] = $rets[0]['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] =  $rets[0]['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $rets[0]['user_id'],
                                    'money' => $rets[0]['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }
                        // 更新排队状态
                        $first_update_user_billions = Db::name("user_billions")->where("billions_id",$rets[0]['billions_id'])->update(['subsidy_price'=> $rets[0]['order_price'],"state"=>2]);
                        if(!$first_update_user_billions){
                            return -3;
                        }
                    }else{
                        Db::name("user_billions_surplus")
                            ->where("surplus_id",$result['surplus_id'])
                            ->dec("user_start_price",0)
                            ->update();
                        $subsidy_price_sum = round($rets[0]['subsidy_price']+$result['user_start_price'],8);
                        Db::name("user_billions")->where("billions_id",$rets[0]['billions_id'])->update(['subsidy_price'=>$subsidy_price_sum]);
                    }
                }





                if($result['residue_price']>0){
                    $rets = Db::name("user_billions")->where("state",0)->limit(1)->select()->toArray();
                    if($rets[0]['order_price'] <= $result['residue_price'] + $rets[0]['subsidy_price']){
                        $p = $result['residue_price'] + $rets[0]['subsidy_price'] - $rets[0]['order_price'];
                        Db::name("user_billions_surplus")
                            ->where("surplus_id",$result['surplus_id'])
                            // ->dec("user_start_price",0)
                            ->update(['residue_price'=>$p]);
                        // 查询用户总余额账户
                        $first_user_all_account = Db::name("subsidy_withdrawal")->where("user_id",$rets[0]['user_id'])->find();
                        if($first_user_all_account != null){
                            // 判断账户是否可用
                            if($first_user_all_account['state'] == 0 || $first_user_all_account['state'] == 2){
                                return -2;
                            }
                            // 更新主表
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->where("user_id",$rets[0]['user_id'])->inc("total_amount",$rets[0]['order_price'])->update();
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_user_all_account['id'];
                            $dat['user_id'] = $rets[0]['user_id'];
                            $dat['billions_id'] = $rets[0]['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] = $rets[0]['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $rets[0]['user_id'],
                                    'money' => $rets[0]['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }else{
                            $d['user_id'] = $rets[0]['user_id'];
                            $d['total_amount'] = $rets[0]['order_price'];
                            $first_update_subsidy_withdrawal = Db::name("subsidy_withdrawal")->insertGetId($d);
                            if(!$first_update_subsidy_withdrawal){
                                return -4;
                            }
                            $dat['subsidy_withdrawal_id'] = $first_update_subsidy_withdrawal;
                            $dat['user_id'] = $rets[0]['user_id'];
                            $dat['billions_id'] = $rets[0]['billions_id'];
                            $dat['type'] = 1;
                            $dat['money'] =  $rets[0]['order_price'];
                            $dat['create_time'] = date("Y-m-d H:i:s");
                            // 插入提现记录
                            $first_save_record = Db::name("subsidy_withdrawal_record")->save($dat);
                            if ($first_save_record) {
                                $send = array(
                                    'user_id' => $rets[0]['user_id'],
                                    'money' => $rets[0]['order_price']
                                );
                                sendBillionsSubsidySMS($send);
                            }

                            if(!$first_save_record){
                                return -5;
                            }
                        }
                        // 更新排队状态
                        $first_update_user_billions = Db::name("user_billions")->where("billions_id",$rets[0]['billions_id'])->update(['subsidy_price'=> $rets[0]['order_price'],"state"=>2]);
                        if(!$first_update_user_billions){
                            return -3;
                        }
                    }else{
                        Db::name("user_billions_surplus")
                            ->where("surplus_id",$result['surplus_id'])
                            ->update(["residue_price"=>0]);
                        $subsidy_price_sum = round($rets[0]['order_price']+$result['residue_price'],8);
                        Db::name("user_billions")->where("billions_id",$rets[0]['billions_id'])->update(['subsidy_price'=>$subsidy_price_sum]);
                    }
                }
            }


            print_r("
");
            var_dump($r);
            // foreach($r as $key=>$value){
            //     var_dump($value['billions_id']);
            //      $data['name'] = $value['billions_id'];
            //      Db::name("user_billions_test")->save($data);

            // }

            //  var_dump($r);
        }

    }
    // 退款
    public function retund(){die();
        $config = WeChatServer::getPayConfigBySource(1)['config'];
        if (empty($config)) {
            throw new Exception('请联系管理员设置微信相关配置!');
        }
        if (!isset($config['cert_path']) || !isset($config['key_path'])) {
            throw new Exception('请联系管理员设置微信证书!');
        }
        if (!file_exists($config['cert_path']) || !file_exists($config['key_path'])) {
            throw new Exception('微信证书不存在,请联系管理员!');
        }

        $result = WeChatPayServer::refund($config, [
            'transaction_id' => "4200002417202409298999399108",
            'refund_sn' => "202409291431067057",
            'total_fee' => intval(strval(650 * 100)),//订单金额,单位为分
            'refund_fee' => intval(strval(650 * 100)),//退款金额
        ]);
        var_dump($result);
        if (isset($result['return_code']) && $result['return_code'] == 'FAIL') {
            throw new Exception($result['return_msg']);
        }
        if (isset($result['err_code_des'])) {
            throw new Exception($result['err_code_des']);
        }
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            //更新退款日志记录
            $dat['wechat_refund_id'] = $result['refund_id'] ?? 0;
            $dat['refund_msg'] = json_encode($result, JSON_UNESCAPED_UNICODE);
            $dat['dtime'] = date("Y-m-d H:i:s");
            Db::name("local_pay_return")->save($dat);
        } else {
            throw new Exception('微信支付退款失败');
        }
    }
}