PHPsxg/crmeb/services/blockchain/BlockChianService.php

<?php


namespace crmeb\services\blockchain;


use app\models\lala\WalletLog;
use app\models\user\UserMoney;
use crmeb\basic\BaseModel;
use GuzzleHttp\Client;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Log;
use Tron\Address;
use Tron\Api;
use Tron\Exceptions\TronErrorException;
use Tron\TRC20;
use Tron\TRX;

class BlockChianService
{

    //TODO main

    /**
     * 生成地址
     * @param string $code
     * @return array
     */
    public static function createAddress(string $code): array
    {
        $code = strtoupper($code);
        if (method_exists(self::class, $code . 'CreateAddress')) {
            $function = $code . 'CreateAddress';
            return self::$function();
        } else {
            return ["privateKey" => "",
                "address" => "",
                "hexAddress" => ""];
        }
    }

    /**
     * 生成地址
     * @param string $code
     * @param string $address
     * @return float
     */
    public static function balance(string $code, string $address): float
    {
        $code = strtoupper($code);
        if (method_exists(self::class, $code . 'Balance')) {
            $function = $code . 'Balance';
            return self::$function($address);
        } else {
            return 0;
        }
    }

    /**
     * 归集
     * @param array $money_info
     * @param string $summary_address
     * @param Address $gas_address
     * @return bool
     */
    public static function summary(array $money_info, string $summary_address, Address $gas_address): bool
    {
        $code = strtoupper($money_info['money_type']);
        if (method_exists(self::class, $code . 'Summary')) {
            $function = $code . 'Summary';
            return self::$function($money_info, $summary_address, $gas_address);
        } else {
            Log::error('币种' . $code . '尚不支持归集');
            return true;
        }
    }

    /**
     * 交易
     * @param string $code
     * @param Address $from
     * @param Address $to
     * @param float $amount
     * @return bool
     */
    public static function transfer(string $code, Address $from, Address $to, float $amount): bool
    {
        $code = strtoupper($code);
        if (method_exists(self::class, $code . 'Transfer')) {
            $function = $code . 'Transfer';
            return self::$function($from, $to, $amount);
        } else {
            Log::error('币种' . $code . '尚不支持交易');
            return true;
        }
    }

    /**
     * 获取交易
     * @param string $code
     * @param $address
     * @param $start_time
     * @return array
     */
    public static function checkTransfer(string $code, $address, $start_time): array
    {
        $code = strtoupper($code);
        if (method_exists(self::class, $code . 'CheckTransfer')) {
            $function = $code . 'CheckTransfer';
            return self::$function($address, $start_time);
        } else {
            return [];
        }
    }

    /**
     * 查询交易
     * @param string $code
     * @param string $txID
     * @return array
     */
    public static function getTransfer(string $code, string $txID): array
    {
        $code = strtoupper($code);
        if (method_exists(self::class, $code . 'GetTransfer')) {
            $function = $code . 'GetTransfer';
            return self::$function($txID);
        } else {
            return [];
        }
    }

    //TODO main - end


    //TODO auto

    /**
     * 自动获取交易记录
     * @return bool
     */
    public static function autoGetTransfer(): bool
    {

        $address = UserMoney::select();
        foreach ($address as $v) {
            if ($v['address']) {
                $res = BlockChianService::checkTransfer($v['money_type'], $v['address'], $v['max_timestamp'] + 1);
                if ($res) {
                    switch ($v['money_type']) {
                        case 'USDT':
                            if (isset($res['data'])) {
                                foreach ($res['data'] as $vv) {
                                    $data = [
                                        'symbol' => $v['money_type'],
                                        'transaction_id' => $vv['transaction_id'],
                                        'from' => $vv['from'],
                                        'to' => $vv['to'],
                                        'type' => $vv['type'],
                                        'amount' => bcdiv($vv['value'], bcpow(10, $vv['token_info']['decimals']), 8),
                                        'block_timestamp' => $vv['block_timestamp'],
                                    ];
                                    if (!WalletLog::be($data)) {
                                        WalletLog::beginTrans();
                                        try {
                                            WalletLog::create($data);
                                            WalletLog::commitTrans();
                                        } catch (\Exception $e) {
                                            WalletLog::rollbackTrans();
                                            Log::error('AutoLoadTransferFail:' . $e->getMessage());
                                            return false;
                                        }
                                    }
                                }
                            }
                            break;
                        default:
                            break;
                    }
                }
                UserMoney::beginTrans();
                try {
                    UserMoney::where('address', $v['address'])->update(['max_timestamp' => time() * 1000]);
                    UserMoney::commitTrans();
                } catch (\Exception $e) {
                    UserMoney::rollbackTrans();
                    Log::error('AutoLoadTransferFail:' . $e->getMessage());
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * 自动确认交易
     * @return bool
     */
    public static function autoCheckTransfer(): bool
    {
        BaseModel::beginTrans();
        try {
            $list = WalletLog::where('state', 0)->select();
            foreach ($list as $v) {
                $res = BlockChianService::getTransfer($v['symbol'], $v['transaction_id']);
                if ($res['status']) {
                    switch ($v['symbol']) {
                        case 'USDT':
                            if (isset($res['data'])) {
                                if (isset($res['data']->contractRet)) {
                                    if ($res['data']->contractRet === 'SUCCESS') {
                                        $update['state'] = 1;
                                        WalletLog::where('id', $v['id'])->update($update);
                                        $user = UserMoney::where('address', $v['to'])->where('money_type', $v['symbol'])->value('uid');
                                        if ($user) {
                                            UserMoney::incomeMoney($user, $v['symbol'], $v['amount'], 'recharge', '用户充值', '用户充值' . $v['amount'] . $v['symbol'], $v['id']);
                                        }
                                    } else {
                                        $update['state'] = 2;
                                        WalletLog::where('id', $v['id'])->update($update);
                                    }
                                }
                            }
                            break;
                        default:
                            break;
                    }
                }
            }
            BaseModel::commitTrans();
            return true;
        } catch (\Exception $e) {
            BaseModel::rollbackTrans();
            Log::error('AutoCheckTransferFail:' . $e->getMessage());
            return false;
        }
    }

    /**
     * 自动归集
     * @return bool
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function autoSummary(): bool
    {
        $money_types = sys_data('money_type');
        $res = true;
        foreach ($money_types as $v) {
            if ($v['charge']) {
                //TODO 接入链上充值
                $addresses = UserMoney::where('max_timestamp', '>', 0)->select()->toArray();
                foreach ($addresses as $vv) {
                    $res = $res && self::summary($vv, $v['summary_address'], new Address($v['gas_address'], $v['gas_key']));
                }
            }
        }
        return $res;
    }

    //TODO auto - end


    //TODO USDT

    /**
     * USDT 创建地址
     * @return array
     */
    public static function USDTCreateAddress(): array
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TB5UtaMMv9apgcKxxYBLkjqmixab9N7EsR',// USDT TRC20
                'decimals' => 6,
            ];
            $trxWallet = new TRC20($api, $config);
            $address = $trxWallet->generateAddress();
            return [
                'privateKey' => $address->privateKey,
                'address' => $address->address,
                'hexAddress' => $address->hexAddress
            ];
        } catch (\Exception $e) {
            return [
                'privateKey' => '',
                'address' => '',
                'hexAddress' => ''
            ];
        }

    }

    /**
     * USDT 余额
     * @param $address
     * @return float
     */
    public static function USDTBalance($address): float
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t',// USDT TRC20
                'decimals' => 6,
            ];
            $trxWallet = new TRC20($api, $config);
            $balance = $trxWallet->balance(new Address($address));
            return (float)$balance;
        } catch (\Exception $e) {
            return 0;
        }
    }

    /**
     * USDT 交易
     * @param $from
     * @param $to
     * @param $amount
     * @return array
     */
    public static function USDTTransfer($from, $to, $amount): array
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TB5UtaMMv9apgcKxxYBLkjqmixab9N7EsR',// USDT TRC20
                'decimals' => 6,
            ];
            $trxWallet = new TRC20($api, $config);
            $transfer = $trxWallet->transfer($from, $to, $amount);
            return ['msg' => 'success', 'data' => $transfer, 'status' => true];
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }

    }

    /**
     * USDT 获取交易记录
     * @param $address
     * @param $start_time
     * @return array|mixed
     */
    public static function USDTCheckTransfer($address, $start_time)
    {
        try {
            $uri = "https://api.trongrid.io/v1/accounts/{$address}/transactions/trc20";
            $contract_address = 'TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t';// USDT TRC20
            return json_decode(do_request($uri, [
                'min_timestamp' => $start_time,
                'limit' => 200,
                'contract_address' => $contract_address,
                'order_by' => 'block_timestamp,asc'
            ], null, false), true);
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }
    }

    /**
     * USDT 确认交易记录
     * @param $txID
     * @return array
     */
    public static function USDTGetTransfer($txID)
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t',// USDT TRC20
                'decimals' => 6,
            ];
            $trxWallet = new TRC20($api, $config);
            $transfer = $trxWallet->transactionReceipt($txID);
            return ['msg' => 'success', 'data' => $transfer, 'status' => true];
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }
    }

    /**
     * USDT 归集
     * @param $money_info
     * @param $summary_address
     * @param $gas_address
     * @return bool
     * @throws TronErrorException
     */
    public static function USDTSummary($money_info, $summary_address, $gas_address): bool
    {
        $uri = 'https://api.trongrid.io';
        $api = new Api(new Client(['base_uri' => $uri]));
        $config = [
            'contract_address' => 'TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t',// USDT TRC20
            'decimals' => 6,
        ];
        $trxWallet = new TRC20($api, $config);
        $address = new Address($money_info['address'], $money_info['privateKey'], $money_info['hexAddress']);
        $balance = $trxWallet->balance($address);
        //var_dump($balance);
        if ($balance > 0) {
            $trx = new TRX($api);
            $trx_balance = $trx->balance($address);
            if ($trx_balance < sys_config('trx_gas', 10)) {
                $trade_trx = ceil(10 - $trx_balance);
                //执行手续费转账
                $gas_trx_balance = $trx->balance($gas_address);
                if ($gas_trx_balance < $trade_trx + 2) {
                    Log::error('USDT手续费账户余额不足');
                    return false;
                }
                try {
                    $res = $trx->transfer($gas_address, $address, $trade_trx);
//                    var_dump($res);
                    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 {
                //执行转账
                try {
                    $res = self::USDTTransfer($address, new Address($summary_address), $balance);
                    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;
    }

    //TODO USDT - end


    //TODO LALA

    /**
     * LALA 创建地址
     * @return array
     */
    public static function LALACreateAddress(): array
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL',// LALA TRC20
                'decimals' => 8,
            ];
            $trxWallet = new TRC20($api, $config);
            $address = $trxWallet->generateAddress();
            return [
                'privateKey' => $address->privateKey,
                'address' => $address->address,
                'hexAddress' => $address->hexAddress
            ];
        } catch (\Exception $e) {
            return [
                'privateKey' => '',
                'address' => '',
                'hexAddress' => ''
            ];
        }

    }

    /**
     * USDT 余额
     * @param $address
     * @return float
     */
    public static function LALABalance($address): float
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL',// USDT TRC20
                'decimals' => 8,
            ];
            $trxWallet = new TRC20($api, $config);
            $balance = $trxWallet->balance(new Address($address));
            return (float)$balance;
        } catch (\Exception $e) {
            return 0;
        }
    }

    /**
     *  LALA 交易
     * @param $from
     * @param $to
     * @param $amount
     * @return array
     */
    public static function LALATransfer($from, $to, $amount): array
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL',// LALA TRC20
                'decimals' => 8,
            ];
            $trxWallet = new TRC20($api, $config);
            $transfer = $trxWallet->transfer($from, $to, $amount);
            return ['msg' => 'success', 'data' => $transfer, 'status' => true];
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }

    }


    /**
     *  LALA 获取交易记录
     * @param $address
     * @param $start_time
     * @return array
     */
    public static function LALACheckTransfer($address, $start_time)
    {
        try {
            $uri = "https://api.trongrid.io/v1/accounts/{$address}/transactions/trc20";
            $contract_address = 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL';// LALA TRC20
            return json_decode(do_request($uri, [
                'min_timestamp' => $start_time,
                'limit' => 200,
                'contract_address' => $contract_address,
                'order_by' => 'block_timestamp,asc'
            ], null, false), true);
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }
    }


    /**
     *  LALA 确认交易
     * @param $txID
     * @return array
     */
    public static function LALAGetTransfer($txID)
    {
        try {
            $uri = 'https://api.trongrid.io';
            $api = new Api(new Client(['base_uri' => $uri]));
            $config = [
                'contract_address' => 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL',// LALA TRC20
                'decimals' => 8,
            ];
            $trxWallet = new TRC20($api, $config);
            $transfer = $trxWallet->transactionReceipt($txID);
            return ['msg' => 'success', 'data' => $transfer, 'status' => true];
        } catch (\Exception $e) {
            return ['msg' => $e->getMessage(), 'status' => false, 'data' => $e->getTrace()];
        }
    }

    /**
     * LALA 归集
     * @param $money_info
     * @param $summary_address
     * @param $gas_address
     * @return bool
     * @throws TronErrorException
     */
    public static function LALASummary($money_info, $summary_address, $gas_address): bool
    {
        $uri = 'https://api.trongrid.io';
        $api = new Api(new Client(['base_uri' => $uri]));
        $config = [
            'contract_address' => 'TLuwWZ8MkB6FFJDLYc19u7d4tFq2GV3rPL',// LALA TRC20
            'decimals' => 8,
        ];
        $trxWallet = new TRC20($api, $config);
        $address = new Address($money_info['address'], $money_info['privateKey'], $money_info['hexAddress']);
        $balance = $trxWallet->balance($address);
        //var_dump($balance);
        if ($balance > 0) {
            $trx = new TRX($api);
            $trx_balance = $trx->balance($address);
            //var_dump($trx_balance);
            if ($trx_balance < sys_config('trx_gas', 10)) {
                $trade_trx = ceil(10 - $trx_balance);
                //执行手续费转账
                $gas_trx_balance = $trx->balance($gas_address);
                if ($gas_trx_balance < $trade_trx + 2) {
                    Log::error('LALA手续费账户余额不足');
                    return false;
                }
                try {
                    $res = $trx->transfer($gas_address, $address, $trade_trx);
//                    var_dump($res);
                    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 {
                //执行转账
                try {
                    $res = self::LALATransfer($address, new Address($summary_address), $balance);
//                    var_dump($res);
                    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;
    }

    //TODO LALA - end
}