bot-28/app/Services/RechargeService.php

<?php


namespace App\Services;

use App\Services\BaseService;
use App\Models\Recharge;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Cache;
use App\Services\WalletService;
use App\Services\CollectService;
use App\Services\UserService;
use App\Services\BalanceLogService;
use App\Helpers\TronHelper;
use App\Models\Config;

/**
 * 用户充值记录
 */
class RechargeService extends BaseService
{
    public static string $MODEL = Recharge::class;
    /**
     * @description: 模型
     * @return {string}
     */
    public static function model(): string
    {
        return Recharge::class;
    }

    /**
     * @description: 枚举
     * @return {*}
     */
    public static function enum(): string
    {
        return '';
    }

    /**
     * @description: 获取查询条件
     * @param {array} $search 查询内容
     * @return {array}
     */
    public static function getWhere(array $search = []): array
    {
        $where = [];
        if (isset($search['coin']) && !empty($search['coin'])) {
            $where[] = ['coin', '=', $search['coin']];
        }
        if (isset($search['net']) && !empty($search['net'])) {
            $where[] = ['net', '=', $search['net']];
        }
        if (isset($search['to_address']) && !empty($search['to_address'])) {
            $where[] = ['to_address', '=', $search['to_address']];
        }
        if (isset($search['id']) && !empty($search['id'])) {
            $where[] = ['id', '=', $search['id']];
        }
        if (isset($search['member_id']) && !empty($search['member_id'])) {
            $where[] = ['member_id', '=', $search['member_id']];
        }
        if (isset($search['txid']) && !empty($search['txid'])) {
            $where[] = ['txid', '=', $search['txid']];
        }
        if (isset($search['status']) && $search['status'] != '') {
            $where[] = ['status', '=', $search['status']];
        }
        if (isset($search['type']) && $search['type'] != '') {
            $where[] = ['type', '=', $search['type']];
        }
        return $where;
    }

    /**
     * @description: 查询单条数据
     * @param array $search
     * @return \App\Models\Coin|null
     */
    public static function findOne(array $search): ?Recharge
    {
        return static::$MODEL::where(self::getWhere($search))->first();
    }

    /**
     * @description: 查询所有数据
     * @param array $search
     * @return \Illuminate\Database\Eloquent\Collection
     */
    public static function findAll(array $search = [])
    {
        return static::$MODEL::where(self::getWhere($search))->get();
    }

    /**
     * @description: 分页查询
     * @param array $search
     * @return array
     */
    public static function paginate(array $search = [])
    {
        $limit = isset($search['limit']) ? $search['limit'] : 15;
        $paginator = static::$MODEL::where(self::getWhere($search))
            ->with(['member'])
            ->orderBy("created_at", 'desc')
            ->paginate($limit);
        $list = $paginator->items();
        $totalAmount = 0;
        $totalSuccess = 0;
        $totalFail = 0;
        foreach ($list as $item) {
            $item['amount'] = floatval($item['amount']);
            $totalAmount += $item['amount'];
            if ($item['status'] == 1) $totalSuccess += $item['amount'];
            if ($item['status'] == 2) $totalFail += $item['amount'];
        }


        return [
            'total' => $paginator->total(),
            'total_amount' => $totalAmount,
            'total_success' => $totalSuccess,
            'total_fail' => $totalFail,
            'data' => $list];
    }


    /**
     * @description: 同步会员的USDT充值记录
     * @param {*} $memberId
     * @return {*}
     */
    public static function syncUsdtRechargeRecords($memberId, $walletInfo = null)
    {
        $walletInfo = $walletInfo ?: WalletService::findOne(['member_id' => $memberId, 'coin' => 'USDT']);
        if (empty($walletInfo) || empty($walletInfo->address)) {
            return 0;
        }

        $data = TronHelper::getTrc20UsdtRecharges($walletInfo->address);
        if (empty($data)) {
            return 0;
        }

        foreach ($data as $k => $v) {
            $v['member_id'] = $walletInfo->member_id ?: $memberId;
            $v['net'] = $walletInfo->net;
            $v['type'] = static::$MODEL::TYPE_AUTO;
            $v['created_at'] = now();
            $v['updated_at'] = now();
            $data[$k] = $v;
        }
        $m = new (static::$MODEL);
        $result = $m->insertOrIgnore($data);
        return $result;
    }

    /**
     * @description: 同步所有USDT钱包的新充值记录
     * @return int
     */
    public static function syncAllUsdtRechargeRecords()
    {
        $wallets = WalletService::findAll(['coin' => 'USDT']);
        $total = 0;

        foreach ($wallets as $walletInfo) {
            if (empty($walletInfo->member_id) || empty($walletInfo->address)) {
                continue;
            }

            $total += self::syncUsdtRechargeRecords($walletInfo->member_id, $walletInfo);
        }

        return $total;
    }

    /**
     * @description: 充值确认
     * @param {*} $txid
     * @return {*}
     */
    public static function handleRechargeConfirmation($txid)
    {
        $info = self::findOne(['txid' => $txid]); // 获取充值的信息

        // 汇率
        $rate = Config::where('field', 'exchange_rate_rmb')->first()->val ?? 1;

        // 待处理进行充值
        if ($info['status'] == static::$MODEL::STATUS_STAY) {
            $result = TronHelper::getTransactionConfirmations($txid);

            if ($result['success']) {
                $data = [];
                $data['block_height'] = $result['block_number'];
                $data['confirmations'] = $result['latest_block'] - $result['block_number'];
                $data['exchange_rate'] = $rate;

                if ($data['confirmations'] >= TronHelper::CONFIRMED_NUMBER) {
                    $data['status'] = static::$MODEL::STATUS_SUCCESS;
                    $where = self::getWhere(['txid' => $txid, 'status' => static::$MODEL::STATUS_STAY]);
                    $recharge = static::$MODEL::where($where)->update($data);

                    $amount = floatval($info->amount);
                    $rate_amount = bcmul($amount, $rate, 10); // 汇率转换后分数

                    // 更新成功，变动可用余额
                    if ($recharge) {
                        $balanceData = WalletService::updateBalance($info->member_id, $rate_amount);
                        BalanceLogService::addLog($info->member_id, $rate_amount, $balanceData['before_balance'], $balanceData['after_balance'], '充值', $info->id, '');

                        CollectService::createCollect($info->to_address, $info->coin, $info->net);

                        $amount = floatval($info->amount);
                        $text = "充值结果通知\n";
                        $text .= "充值数量：{$amount} USDT\n";
                        $text .= "充值地址：{$info->to_address}\n";
                        $text .= "汇率：1 USDT = {$rate} RMB\n";
                        $text .= "折合金额：" . number_format($rate_amount, 2) . " RMB\n";
                        $text .= "状态：成功\n";
                        TopUpService::notifyTransferSuccess($info->member_id, $text);
                    }
                }
            }
        }

    }

    /**
     * @description: 同步待处理的充值记录
     * @return {*}
     */
    public static function syncRechargeStay()
    {
        $list = self::findAll(['status' => static::$MODEL::STATUS_STAY, 'type' => static::$MODEL::TYPE_AUTO]);
        foreach ($list as $k => $v) {
            self::handleRechargeConfirmation($v->txid);
        }
    }
}