shrx/application/admin/controller/general/Txmx.php

<?php

namespace app\admin\controller\general;

use app\admin\model\Admin;
use app\api\controller\Pay;
use app\common\controller\Backend;
use app\common\model\GasLog;
use blockchain\TronService;
use blockchain\Web3Service;
use fast\Random;
use think\Config;
use think\Log;
use think\Session;
use think\Validate;
use app\common\model\Txjl;
use think\Db;
use Tron\Address;

/**
 * 个人配置
 *
 * @icon fa fa-user
 */
class Txmx extends Backend
{

    /**
     * 查看
     */
    public function index()
    {
        //设置过滤方法
        $this->request->filter(['strip_tags']);
        if ($this->request->isAjax()) {
            $model = model('Txjl');
            list($where, $sort, $order, $offset, $limit) = $this->buildparams();

            $total = $model
                ->where($where)
                ->where('admin_id', $this->auth->id)
                ->order($sort, $order)
                ->count();

            $list = $model
                ->where($where)
                ->where('admin_id', $this->auth->id)
                ->order($sort, $order)
                ->limit($offset, $limit)
                ->select();

            $result = array("total" => $total, "rows" => $list);

            return json($result);
        }
        $admin = Admin::get($this->auth->id);
        Session::set("admin", $admin->toArray());
        return $this->view->fetch();
    }

    /**
     * 更新个人信息
     */
    public function update()
    {
        if ($this->request->isPost()) {
            $params = $this->request->post("row/a");
            if ($params) {
                $site = config('site');
                $money = $params['money'];
                if ($money < $site['zstx']) {
                    $this->error($site['txbz']);
                }
                if (!$params['type']) {
                    $this->error('请填写提现类型');
                }
                if (!$params['name']) {
                    $this->error('请填写提现名字');
                }
                if (!$params['cord']) {
                    $this->error('请填写提现帐号');
                }
                $user_id = $this->auth->id;
                $vadmin = Db::name('admin')->where('id', $user_id)->find();
                if ($vadmin && $money != 0) {
                    if ($vadmin['money'] < $money) {
                        $this->error('余额不足');
                    }
                    Db::startTrans();
                    try {
                        $moneys = $money;
                        //更新会员信息
                        $before = $vadmin['money'];
                        $after = $vadmin['money'] - $moneys;
                        Db::name('admin')->where('id', $user_id)->setDec('money', $moneys);
                        //写入日志
                        Db::name('admin_money_log')->insertGetId(['admin_id' => $user_id, 'money' => $moneys, 'createtime' => time(), 'before' => $before, 'after' => $after, 'memo' => '用户提现']);

                        $site['txsxf'] = isset($site['txsxf']) ? $site['txsxf'] : 0;
                        $sxf = $money * $site['txsxf'];
                        $up = [
                            'admin_id' => $user_id,
                            'type' => $params['type'],
                            'name' => $params['name'],
                            'cord' => $params['cord'],
                            'money' => $money,
                            'moneydz' => $money - $sxf,
                            'sxf' => $sxf,
                            'iscl' => 1,
                            'islx' => 2,
                            'memo' => '后台用户提现'
                        ];
                        //写入提现记录
                        Txjl::create($up);
                        $admin = Admin::get($this->auth->id);
                        Session::set("admin", $admin->toArray());
                        Db::commit();
                        $this->success('提交成功');
                    } catch (Exception $e) {
                        Db::rollback();
                        $this->error($e->getMessage());
                    }

                } else {
                    $this->error(__('金额不对'));
                }
            }
            $this->error();
        }
        return;
    }
//    public function summary(){
//        $blockchain = config('blockchain');
//        $trcUsdtAddress=$blockchain['trc']['tokens']['usdt']['address'];
//        $trcgasAddress = $blockchain['trc']['tokens']['usdt']['gas_address'];
//        $bscUsdtAddress = $blockchain['bsc']['tokens']['usdt']['address'];
//        $bscgasAddress = $blockchain['bsc']['tokens']['usdt']['gas_address'];
//        $list = Db::name('user_usdt_address')->where('last_recharge','>',0)->select();
//        foreach ($list as $key => $value) {
//            $trx_money_info = [
//                'address' => $value['trx_address'],
//                'hexAddress' => $value['trx_16_address'],
//                'privateKey' => $value['trx_key'],
//            ];
//            $this->trx_summary($trx_money_info,$trcUsdtAddress,$trcgasAddress );
//            $bsc_money_info = [
//                'address' => $value['bsc_address'],
//                'privateKey' => $value['bsc_address	'],
//            ];
//            $this->bsc_summary($bsc_money_info,$bscUsdtAddress,$bscgasAddress );
//        }
//    }

//    归集（把所有用户的USDT归集到指定地址）
    public function summary()
    {
//        $blockchain = config('blockchain');
//
//        // TRC 配置
//        $trcUsdtAddress = $blockchain['trc']['tokens']['usdt']['address'];
//        $trcGasAddress = new Address(
//            $blockchain['trc']['tokens']['usdt']['gas_address'],
//            '',
//            ''
//        );
//
//        // BSC 配置
//        $bscUsdtAddress = $blockchain['bsc']['tokens']['usdt']['address'];
//        $bscGasAddress = new Address(
//            $blockchain['bsc']['tokens']['usdt']['gas_address'],
//            '',
//            ''
//        );
        $site = config('site');
//        $trcUsdtAddress = $site['trxdz']['trx_address'];
        $trx_hex_address =  Pay::base58ToHex($site['trxdz']['trx地址']);  // 16进制地址
        $trx_hex_gas_address =  Pay::base58ToHex($site['trxdz']['trx手续费账号地址']);  // 16进制地址
        $trcUsdtAddress = new Address(
            $site['trxdz']['trx地址'],
            $site['trxdz']['trx密钥'],
            $trx_hex_address
        );
        $trcGasAddress = new Address(
            $site['trxdz']['trx_gas_address'],
            $site['trxdz']['trx_gas_private_key'],
            $trx_hex_gas_address
        );
        $bscUsdtAddress = $site['bscdz']['bsc_address'];
        $bscGasAddress = new Address(
            $site['bscdz']['bsc_gas_address'],
            $site['bscdz']['bsc_gas_private_key'],
            ''
        );
        $list = Db::name('user_usdt_address')->where('last_recharge', '>', 0)->select();
        try {
            foreach ($list as $value) {
                // TRX 归集
                $this->trx_summary(
                    [
                        'address' => $value['trx_address'],
                        'hexAddress' => $value['trx_16_address'],
                        'privateKey' => $value['trx_key'],
                    ],
                    $trcUsdtAddress,
                    $trcGasAddress
                );
                @file_put_contents("usdt.txt",  "-456\r\n", 8);
                // BSC 归集
                $this->bsc_summary(
                    [
                        'address' => $value['bsc_address'],
                        'privateKey' => $value['bsc_key'], // 确保字段名正确
                    ],
                    $bscUsdtAddress,
                    $bscGasAddress
                );
            }
            @file_put_contents("usdt.txt",   "- 到这了吗\r\n", 8);
//            $this->success('转账完成');
        } catch (\Exception $e) {
            Log::error('归集失败' . $e->getMessage());
            return false;
        }
        @file_put_contents("usdt.txt",   "- 这里呢\r\n", 8);
        return json(['code' => 1, 'data' => '转账完成']);
    }

//                                 转出的用户地址           转入地址                    手续费账号地址
    public function trx_summary(array $money_info, Address $summary_address, Address $gas_address)
    {
        //实例化TRON
        $service = TronService::instance('usdt');
        //实例化出款地址[有Usdt余额的用户钱包]
        $address = new Address($money_info['address'], $money_info['privateKey'], $money_info['hexAddress']);
        //获取代币余额
        $balance = $service->tokenBalance($address);
        @file_put_contents("usdt.txt", $balance . "- trxd交易链usdt余额\r\n", 8);
        //USDT余额大于0，触发归集
        if ($balance > 0) {
            //查询地址中主币【GAS费余额】
            $trx_balance = $service->balance($money_info['address']);
            @file_put_contents("usdt.txt", $trx_balance . "- trx的gas余额\r\n", 8);
            $gas_address_arr = get_object_vars($gas_address);

            if ($trx_balance < 30) {
                //如果主币小于30个，即gas费不够【BSC的gas费需要比较少，大约0.001个bnb就不少了，按照实际情况设置】
                //计算要达到30个trx需要再转几个给用户地址
                $trade_trx = ceil(30 - $trx_balance);
                //处理手续费转账，从系统地址分配gas给用户
                //查询系统地址的TRX余额
                $gas_trx_balance = $service->balance($gas_address_arr['address']);
                @file_put_contents("usdt.txt", $gas_trx_balance . "-trx手续费账号的gas余额\r\n", 8);
                //系统地址TRX余额不足，退出处理
                if ($gas_trx_balance < $trade_trx + 2) {
                    Log::error('手续费账户余额不足');
                    return false;
                }
                try {
                    //执行转账                 form          to
                    $res = $service->transfer($gas_address, $address, $trade_trx);
                    @file_put_contents("usdt.txt", json_encode($res) . "-转账TRX手续费\r\n", 8);
                    if ($res['msg']=='success'){
                        $tx_id = $res['data']->txID;
                        $up = [
                            'order_id' => $tx_id,
                            'type' => 'trx',
                            'is_gas' => 0,
                            'from_address' => $gas_address->address,
                            'to_address' => $address['address'],
                            'createtime' => time(),
                        ];
                        $id = Db::name('summary_log')->insertGetId($up);
                    }
                    GasLog::create(['to_address' => $address, 'num' => $trade_trx, 'type' => 'trx']);
                    if (isset($res->txID)) {
                        Log::error('转账TRX交易哈希：' . $res->txID);
                        return true;
                    } else {
                        Log::error('转账TRX失败');
                        return false;
                    }
                } catch (\Exception $e) {
                    Log::error('转账TRX失败' . $e->getMessage());
                    return false;
                }
            } else {
                //账户内TRX充足，执行USDT转账交易
                try {
                    //将账户内的USDT余额转入归集指定地址
                    $res = $service->tokenTransfer($address, $summary_address, $balance);
                    @file_put_contents("usdt.txt", json_encode($res) . "-转账usdt\r\n", 8);
                    @file_put_contents('trasfer.txt', json_encode($res), FILE_APPEND);
                    if ($res['msg']=='success'){
                        $tx_id = $res['data']->txID;
                        $up = [
                            'order_id' => $tx_id,
                            'type' => 'trx',
                            'is_gas' => 1,
                            'from_address' => $address['address'],
                            'to_address' => $summary_address->address,
                            'createtime' => time(),
                        ];
                        $id = Db::name('summary_log')->insertGetId($up);
                    }
                    if ($res['status']) {
                        Log::error('转账交易哈希：' . $res['data']->txID);
                        return true;
                    } else {
                        Log::error('转账失败' . $res['msg']);
                        return false;
                    }
                } catch (\Exception $e) {
                    Log::error('转账失败' . $e->getMessage());
                    return false;
                }
            }
        }
        return true;
    }
//                                 转出的用户地址           转入地址                    手续费处理地址
    public function bsc_summary(array $money_info, string $summary_address, Address $gas_address)
    {
        @file_put_contents("usdt.txt",  "-123\r\n", 8);
        //实例化TRON
        $service = Web3Service::instance('bsc', 'usdt', $money_info['privateKey']);
//        $service = Web3Service::instance('bsc', 'tusd', '');
        //实例化出款地址[有Usdt余额的用户钱包]
        $address = new Address($money_info['address'], $money_info['privateKey'], '');
        //获取代币余额
        $balance = $service->getTokenBalance($money_info['address']);
        @file_put_contents("usdt.txt", $balance . "-bsc的usdt余额\r\n", 8);
        //USDT余额大于0，触发归集
        if ($balance > 0) {
            //查询地址中主币【GAS费余额】
            $trx_balance = $service->getBalance($money_info['address']);
            if ($trx_balance < 0.001) {
                //如果主币小于30个，即gas费不够【BSC的gas费需要比较少，大约0.001个bnb就不少了，按照实际情况设置】
                //计算要达到30个trx需要再转几个给用户地址
                $trade_trx = ceil(0.001 - $trx_balance);
                //处理手续费转账，从系统地址分配gas给用户
                //查询系统地址的TRX余额
                $gas_address_arr = get_object_vars($gas_address);

                $gas_trx_balance = $service->getBalance($gas_address_arr['address']);
                @file_put_contents("usdt.txt", $gas_trx_balance . "-bsc的手续费账户内gas余额\r\n", 8);
                //系统地址TRX余额不足，退出处理
                if ($gas_trx_balance < $trade_trx ) {
                    Log::error('手续费账户余额不足');
                    @file_put_contents("usdt.txt",  "-手续费账户余额不足\r\n", 8);
                    return false;
                }
                try {
                    //执行转账 手续费
                    $service = Web3Service::instance('bsc', 'usdt', $gas_address->privateKey);
                    $res = $service->transfer($money_info['address'], $trade_trx);
                    @file_put_contents("usdt.txt", json_encode($res) . "-转账bsc手续费\r\n", 8);
                    GasLog::create(['to_address' => $money_info['address'], 'num' => $trade_trx, 'type' => 'bsc']);
                    $up = [
                        'order_id' => $res,
                        'type' => 'bsc',
                        'is_gas' => 0,
                        'from_address' => $gas_address->address,
                        'to_address' => $summary_address,
                        'createtime' => time(),
                    ];
                    $id = Db::name('summary_log')->insertGetId($up);
                    if (isset($res->txID)) {
                        Log::error('转账BSC交易哈希：' . $res->txID);
                        return true;
                    } else {
                        Log::error('转账BSC失败');
                        return false;
                    }
                } catch (\Exception $e) {
                    Log::error('转账BSC失败' . $e->getMessage());
                    return false;
                }
            } else {
                //账户内TRX充足，执行USDT转账交易
                try {
                    //将账户内的USDT余额转入归集指定地址
                    $res = $service->transferToken($summary_address, $balance);
                    @file_put_contents("usdt.txt", json_encode($res) . "bsc-转账usdt\r\n", 8);
                    @file_put_contents('trasfer.txt', json_encode($res), FILE_APPEND);
                    $up = [
                        'order_id' => $res,
                        'type' => 'bsc',
                        'is_gas' => 1,
                        'from_address' => $money_info,
                        'to_address' => $summary_address,
                        'createtime' => time(),
                    ];
                    $id = Db::name('summary_log')->insertGetId($up);
                    if ($res['status']) {
                        Log::error('转账交易哈希：' . $res['data']->txID);
                        return true;
                    } else {
                        Log::error('转账失败' . $res['msg']);
                        return false;
                    }
                } catch (\Exception $e) {
                    Log::error('转账失败' . $e->getMessage());
                    return false;
                }
            }
        }
        return true;
    }
}