From d7f54d66a9c9a93530d50340b577a0b7585b7243 Mon Sep 17 00:00:00 2001 From: li Date: Tue, 31 Mar 2026 10:46:20 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E7=8E=B0=E8=B4=A7/=E5=90=88=E7=BA=A6?= =?UTF-8?q?=E8=BD=AC=E8=B4=A6=E5=B8=82=E5=9C=BA=E4=BB=B7=E6=A0=BC=E8=BD=AC?= =?UTF-8?q?=E6=8D=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. 添加合约账户为可选转账目标(原量化账户) 2. BTC/ETH 现货→合约：按市场价转为USDT存入合约账户 3. 合约→BTC/ETH 现货：USDT按市场价转为BTC/ETH 4. USDT 现货↔合约：1:1直接转移 5. get_transfer 返回 exchange 汇率字段 --- application/api/controller/Wallet.php | 201 +++++++++++++++++++++----- 1 file changed, 165 insertions(+), 36 deletions(-) diff --git a/application/api/controller/Wallet.php b/application/api/controller/Wallet.php index 10f8d58..afabd55 100755 --- a/application/api/controller/Wallet.php +++ b/application/api/controller/Wallet.php @@ -539,17 +539,40 @@ class Wallet extends Api { $user_id = $this->auth->id; $curr_id = $this->request->post("id",1); - $user_curr = Db::name("app_currency_user a")->field("a.curr_id,a.num,b.process,b.exchange") + + // 查询指定币种的现货余额（num 字段） + $user_curr = Db::name("app_currency_user a")->field("a.curr_id,a.num,b.process,b.exchange,b.name") ->join("app_currency b","a.curr_id=b.id","left") ->where("a.user_id",$user_id) ->where("a.curr_id",$curr_id) ->find(); - -// $apt_curr = Db::name("app_currency")->where("id",2)->find(); -// $apt_free = Config::get("site.apt_free"); -// $apt_process = sprintf("%.6f",$user_curr['process']*$user_curr['exchange']/$apt_curr['exchange']*$apt_free); + + // 若用户尚无该币种记录，num 返回 0 + $spot_num = $user_curr ? $user_curr['num'] : 0; + + // 按币种确定链选项与默认手续费 + // curr_id=1: USDT → ERC-20 + TRC-20，手续费 10 + // curr_id=3: BTC → BTC 链，手续费 0.0001 + // curr_id=4: ETH → ERC-20，手续费 0.005 + // 其他：沿用数据库 process 字段，默认链 TRC-20 + if($curr_id == 1){ + $lian = ["ERC-20","TRC-20"]; + $fee = 10; + }elseif($curr_id == 3){ + // BTC：仅原生 BTC 链，无 ERC-20/TRC-20 + $lian = ["BTC"]; + $fee = 0.0001; + }elseif($curr_id == 4){ + // ETH：仅 ERC-20，无 TRC-20 + $lian = ["ERC-20"]; + $fee = 0.005; + }else{ + $lian = ["TRC-20"]; + $fee = $user_curr ? $user_curr['process'] : 0; + } + $apt_process = 0; - + if($this->auth->secret){ $is_google = true; }else{ @@ -564,29 +587,22 @@ class Wallet extends Api $withdraw_text = Config::get("site.withdraw_text_en"); break; } - if($curr_id == 1){ - $lian = ["ERC-20","TRC-20"]; - }elseif($curr_id == 4){ - $lian = ["ERC-20"]; - }else{ - $lian = ["TRC-20"]; - } $data = array( - "lian" => $lian, - "curr_id" => $curr_id, - "num" => $user_curr['num'], - "process" => $user_curr['process'], - "erc_process" => $user_curr['process'], - "yhk_process" => 0, - "apt_process" => $apt_process, + "lian" => $lian, + "curr_id" => $curr_id, + "num" => $spot_num, + "process" => $fee, + "erc_process" => $fee, + "yhk_process" => 0, + "apt_process" => $apt_process, "withdraw_text" => $withdraw_text, - "is_google" => $is_google, - "m_prefix" => $this->auth->m_prefix, - "mobile" => $this->auth->mobile, - "email" => $this->auth->email, - "apy_pay" => $this->auth->apy_pay, + "is_google" => $is_google, + "m_prefix" => $this->auth->m_prefix, + "mobile" => $this->auth->mobile, + "email" => $this->auth->email, + "apy_pay" => $this->auth->apy_pay, ); - + $this->success('success',$data); } @@ -796,10 +812,10 @@ class Wallet extends Api $zhuanghu = array( ['id'=>1,"name"=>__("现货账户")], ['id'=>2,"name"=>__("法币账户")], -// ['id'=>3,"name"=>__("量化账户")], + ['id'=>3,"name"=>__("合约账户")], ); - //获取可划转币种 - $curr = Db::name("app_currency a")->field("a.id as curr_id,a.name,b.num,b.num_fb,b.num_lh") + //获取可划转币种 + 汇率用于实时价格转换 + $curr = Db::name("app_currency a")->field("a.id as curr_id,a.name,a.exchange,b.num,b.num_fb,b.num_lh") ->join("app_currency_user b","a.id=b.curr_id","left") ->where("a.is_tran",1) ->where("b.user_id",$user_id) @@ -832,7 +848,7 @@ class Wallet extends Api $curr_id = $this->request->post("curr_id",1); $num = $this->request->post("num"); $pay_pwd = $this->request->post("pay_pwd"); - + if(!is_numeric($num) || $num <= 0){ $this->error(__("请输入有效数量")); } @@ -844,11 +860,124 @@ class Wallet extends Api { $this->error(__('交易密码错误')); } - + $curr = Db::name("app_currency")->where("id",$curr_id)->where("is_tran",1)->find(); if(empty($curr)){ - $this->error(__("改币种不支持划转")); + $this->error(__("该币种不支持划转")); } + + // ========== 合约账户特殊处理：BTC/ETH按市场价转USDT ========== + // 合约账户只存USDT，非USDT币种需要按市场价转换 + $is_contract_transfer = ($left_id == 3 || $right_id == 3); + $need_conversion = $is_contract_transfer && $curr_id != 1; // 非USDT需转换 + + if($need_conversion) { + // 获取市场汇率 + $exchange_rate = floatval($curr['exchange']); + if($exchange_rate <= 0) { + $this->error(__("汇率异常")); + } + $usdt_amount = sprintf("%.6f", $num * $exchange_rate); + + // 获取两个币种的用户记录 + $user_curr_coin = Db::name("app_currency_user")->where("curr_id",$curr_id)->where("user_id",$user_id)->find(); + $user_curr_usdt = Db::name("app_currency_user")->where("curr_id",1)->where("user_id",$user_id)->find(); + + if(empty($user_curr_coin) || empty($user_curr_usdt)){ + $this->error(__("账户数据异常")); + } + + if($right_id == 3) { + // 现货 → 合约：扣现货BTC/ETH的num，加USDT的num_lh + if($user_curr_coin['num'] < $num){ + $this->error(__("余额不足")); + } + $left_msg = "现货账户"; + $right_msg = "合约账户"; + + //redis防重复 + $symbol = "transfer_sub" . $this->auth->id; + $submited = pushRedis($symbol); + if (!$submited) { $this->error(__("操作频繁")); } + + Db::startTrans(); + try { + // 扣币种现货 + Db::name("app_currency_user")->where("id",$user_curr_coin['id']) + ->update(['num' => $user_curr_coin['num'] - $num]); + // 加USDT合约 + Db::name("app_currency_user")->where("id",$user_curr_usdt['id']) + ->update(['num_lh' => $user_curr_usdt['num_lh'] + $usdt_amount]); + // 记录 + Db::name("app_detailed")->insert([ + "user_id" => $user_id, "curr_id" => $curr_id, "price" => $num, + "cart" => 2, "type" => 8, "description" => $curr['name']." ".$left_msg."转到".$right_msg."(≈".$usdt_amount." USDT)", + "createtime" => time(), "before_num" => $user_curr_coin['num'], "after_num" => $user_curr_coin['num'] - $num, + ]); + Db::name("app_detailed_lh")->insert([ + "user_id" => $user_id, "curr_id" => 1, "price" => $usdt_amount, + "cart" => 1, "type" => 1, "description" => $curr['name']." ".$left_msg."转到".$right_msg."(按".$exchange_rate."转换)", + "createtime" => time(), "before_num" => $user_curr_usdt['num_lh'], "after_num" => $user_curr_usdt['num_lh'] + $usdt_amount, + ]); + Db::name("app_transfer_log")->insert([ + "user_id" => $user_id, "curr_id" => $curr_id, "form" => $left_id, "to" => $right_id, + "num" => $num, "msg" => $num." ".$curr['name']." → ".$usdt_amount." USDT", "addtime" => time(), + ]); + Db::commit(); + lopRedis($symbol); + $this->success(__('划转成功')." (".$num." ".$curr['name']." ≈ ".$usdt_amount." USDT)"); + } catch (Exception $e) { + Db::rollback(); + lopRedis($symbol); + $this->error(__('系统繁忙')); + } + } else { + // 合约 → 现货：扣USDT的num_lh，加BTC/ETH的num + // num参数此时是USDT数量 + $btc_amount = sprintf("%.8f", $num / $exchange_rate); + if($user_curr_usdt['num_lh'] < $num){ + $this->error(__("合约账户余额不足")); + } + $left_msg = "合约账户"; + $right_msg = "现货账户"; + + $symbol = "transfer_sub" . $this->auth->id; + $submited = pushRedis($symbol); + if (!$submited) { $this->error(__("操作频繁")); } + + Db::startTrans(); + try { + Db::name("app_currency_user")->where("id",$user_curr_usdt['id']) + ->update(['num_lh' => $user_curr_usdt['num_lh'] - $num]); + Db::name("app_currency_user")->where("id",$user_curr_coin['id']) + ->update(['num' => $user_curr_coin['num'] + $btc_amount]); + Db::name("app_detailed_lh")->insert([ + "user_id" => $user_id, "curr_id" => 1, "price" => $num, + "cart" => 2, "type" => 1, "description" => $left_msg."转到".$curr['name']." ".$right_msg, + "createtime" => time(), "before_num" => $user_curr_usdt['num_lh'], "after_num" => $user_curr_usdt['num_lh'] - $num, + ]); + Db::name("app_detailed")->insert([ + "user_id" => $user_id, "curr_id" => $curr_id, "price" => $btc_amount, + "cart" => 1, "type" => 8, "description" => $num." USDT → ".$btc_amount." ".$curr['name']."(按".$exchange_rate."转换)", + "createtime" => time(), "before_num" => $user_curr_coin['num'], "after_num" => $user_curr_coin['num'] + $btc_amount, + ]); + Db::name("app_transfer_log")->insert([ + "user_id" => $user_id, "curr_id" => $curr_id, "form" => $left_id, "to" => $right_id, + "num" => $num, "msg" => $num." USDT → ".$btc_amount." ".$curr['name'], "addtime" => time(), + ]); + Db::commit(); + lopRedis($symbol); + $this->success(__('划转成功')." (".$num." USDT ≈ ".$btc_amount." ".$curr['name'].")"); + } catch (Exception $e) { + Db::rollback(); + lopRedis($symbol); + $this->error(__('系统繁忙')); + } + } + return; + } + + // ========== 普通划转（含USDT现货↔合约1:1转移）========== $user_curr = Db::name("app_currency_user")->where("curr_id",$curr_id)->where("user_id",$user_id)->find(); switch ($left_id) { case 1: @@ -864,7 +993,7 @@ class Wallet extends Api $left_type = 1; break; case 3: - $left_msg = "量化账户"; + $left_msg = "合约账户"; $left_field = "num_lh"; $left_table = "app_detailed_lh"; $left_type = 1; @@ -887,7 +1016,7 @@ class Wallet extends Api $right_type = 1; break; case 3: - $right_msg = "量化账户"; + $right_msg = "合约账户"; $right_field = "num_lh"; $right_table = "app_detailed_lh"; $right_type = 1; @@ -905,7 +1034,7 @@ class Wallet extends Api if (!$submited) { $this->error(__("操作频繁")); } - + $left_detail = array( "user_id" => $user_id, "curr_id" => $curr_id, @@ -941,7 +1070,7 @@ class Wallet extends Api $left_field => $user_curr[$left_field] - $num, $right_field => $user_curr[$right_field] + $num, ); - + Db::startTrans(); try { Db::name("app_transfer_log")->insert($transfer_log);