RWACha-API/application/api/controller/Offline.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\library\EthSign;
use app\common\library\Token;
use app\common\model\LedgerWalletModel;
use app\common\model\OfflineRechargeRecordModel;
use app\common\model\OfflineWithdrawRecordModel;
use app\common\model\ParametersModel;
use app\common\model\UserModel;
use fast\Action;
use fast\Asset;
use fast\Random;
use think\Config;
use think\Db;
use Exception;
use think\Env;
use think\Hook;
use think\Log;
use think\Model;
use think\Validate;

/**
 * 会员接口
 */
class Offline extends Api
{

    public function withdrawFee()
    {
        $resp   = [
            'usdt'                => '0', // 系统余额(U)
            'withdraw_min_amount' => getConfig('withdraw_min_amount'), // 最低提现U数量
            'withdraw_fee_rate'   => getConfig('withdrawal_fee')       // 手续费比例
        ];
        $this->success('', $resp);
    }

    /**
     * 提现
     * @return void
     */
    public function withdrawCash()
    {
        $amount = $this->request->post('amount'); // 金额
        $sign = $this->request->post('sign'); // 签名信
        $address = $this->request->post('to_address'); // 地址
        if(empty($sign)  || empty($address)){
            $this->error('参数错误');
        }
        $real   = bcdiv($amount, getConfig('convert_rate'), 6); // 折合转换 U = 1
        $min    = getConfig('withdraw_min_amount');
        $rate   = getConfig('withdrawal_fee');
        if ($amount <= 0) {
            $this->error('提现金额必须大于0');
        } else if ($amount < $min) {
            $this->error('提现金额不能小于' . $min);
        }
        
        // 扣除手续费后
        if ($rate > 0 && $rate < 1) { // 比例范围只在0-1之间
            $real = bcmul($real, bcsub(1, $rate, 6), 6);
        }
        $uid = $this->auth->getTokenUserID();

        // 用户信息
        $user = (new UserModel())->getById($uid);
        if (empty($user)) {
            $this->error('用户不存在');
        }

        if($user['is_withdraw']){
            $this->error('提现失败，请联系客服。');
        }

        // 验签
        $signMsg = "withdraw"; // 与前端约定的固定值
        if (!checkSign($signMsg, $sign, $address)) {
            $this->error('签名校验失败');
        }

        // 启动事务
        Db::startTrans();
        try {
            // 更新USDT和账变
            (new LedgerWalletModel())->changeWalletAccount($uid, Asset::TOKEN, -$amount, Action::UsdtWithdrawCash);

            // 创建提现记录
            $txHash = Random::uuid();
            (new OfflineWithdrawRecordModel())->createWithdraw($txHash, $uid, $amount, $real, $address, 'usdt');

            // 提交事务
            Db::commit();
        } catch (Exception $e) {
            // 回滚事务
            Db::rollback();
            $this->error('提交失败:' . $e->getMessage());
        }

        $this->success('提现申请已提交');
    }

    /**
     * 提现地址
     * @return void
     */
    public function withdrawList()
    {
        $where     = ['user_id' => $this->auth->getTokenUserID()];
        $paginator = (new OfflineWithdrawRecordModel)->where($where)->order('id DESC')->paginate($this->pageSize);
        $this->success('', $this->buildResp($paginator->total(), $paginator->currentPage(), $paginator->items()));
    }


    /**
     * 充值记录
     * @return void
     */
    public function rechargeList()
    {
        $where     = ['user_id' => $this->auth->getTokenUserID()];
        $paginator = (new OfflineRechargeRecordModel)->where($where)->order('id DESC')->paginate($this->pageSize);
        $this->success('', $this->buildResp($paginator->total(), $paginator->currentPage(), $paginator->items()));
    }

    /**
     * 获取签名-带连接符号
     * @return string
     */
    protected  static function getSignKey(array $arr, string $secretKey)//: string
    {
        ksort($arr);
        $arr['apiSecret'] = $secretKey;
        $string = '';
        foreach ($arr as $key => $value)
            $string .= '&'.$key .'='.$value;
        return ltrim($string, '&');
    }


    //post
    private static  function curlPostData($url , $data=array())
    {
        $headers = array("Content-type:application/x-www-form-urlencoded;charset=UTF-8");
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HTTPHEADER,$headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
        // POST数据
        curl_setopt($ch, CURLOPT_POST, 1);
        // 把post的变量加上
        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
        $output = curl_exec($ch);
        curl_close($ch);
        return $output;
    }

    //get
    private static function curlGetData($url){
        Log::info('查询余额');
        Log::info($url);
        # 初始化一个curl会话
        $ch = curl_init();
        # 判断是否是https
        if (stripos($url, "https://") !== false) {
            # 禁用后cURL将终止从服务端进行验证
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
            # 	使用的SSL版本(2 或 3)
            curl_setopt($ch, CURLOPT_SSLVERSION, 1);
        }
        # 设置请求地址
        curl_setopt($ch, CURLOPT_URL, $url);
        # 	在启用CURLOPT_RETURNTRANSFER的时候，返回原生的（Raw）输出
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);

        # 执行这个请求
        $output = curl_exec($ch);
        # 关闭这个请求
        curl_close($ch);
        return $output;
    }

}