bot-28/app/Http/Controllers/admin/Wallet.php

<?php

namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Models\Recharge;
use App\Services\BalanceLogService;
use App\Services\RechargeService;
use App\Services\TopUpService;
use Exception;

use Illuminate\Support\Facades\DB;
use Illuminate\Validation\ValidationException;
use App\Models\Wallet as WalletModel;
use App\Models\Withdraw;

class Wallet extends Controller
{

    /**
     * @api {get} /admin/wallet/getPendingTasks 待处理任务
     * @apiDescription 后台每隔10秒，轮询请求这个接口获取待处理的任务数，如果有待处理的任务，则播放音乐
     * @apiGroup 充值管理
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     *
     * @apiSuccess (data) {Object} data
     * @apiSuccess (data) {int} data.recharge_task 待处理充值任务
     * @apiSuccess (data) {int} data.withdraw_task 待处理提现任务
     */
    function getPendingTasks()
    {
        $data['recharge_task'] = Recharge::where('type', 2)
            ->where('status', 1)->count();
        $data['withdraw_task'] = Withdraw::where('status', 0)->count();
        return $this->success($data);
    }

    /**
     * @api {post} /admin/wallet/topUp 人工充值
     * @apiGroup 充值管理
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     * @apiParam {float} amount 充值金额
     * - 可以是负数  负数则为扣款
     * @apiParam {string} member_id 会员ID
     * @apiParam {string} remark 充值/扣款 说明
     */
    public function topUp()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'amount' => ['required', 'numeric'],
                'member_id' => ['required', 'string', 'min:1'],
                'remark' => ['required', 'string', 'min:1']
            ]);
            $memberId = request()->input('member_id');
            $amount = request()->input('amount');
            $remark = request()->input('remark');


            $wallet = WalletModel::where('member_id', $memberId)
                ->first();
            if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);

            $available_balance = bcadd($wallet->available_balance, $amount, 10);
            $changeType = ($amount > 0 ? "人工充值" : "人工扣款");
            BalanceLogService::addLog(
                $memberId,
                $amount,
                $wallet->available_balance,
                $available_balance,
                $changeType,
                null,
                $remark
            );
            $wallet->available_balance = $available_balance;
            $wallet->save();
            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }

        $available_balance = floatval($available_balance);
        // 去除多余0后，再用 sprintf 补足两位
        $available_balance = sprintf('%.2f', $available_balance);
        TopUpService::notifyTransferSuccess($memberId, "您的账户余额更新：".($amount>0?'+':'')."{$amount} \n总余额为：{$available_balance}");
        return $this->success();
    }

    /**
     * @api {post} /admin/wallet/verifyRecharge 审核
     * @apiGroup 充值管理
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     * @apiParam {int} id 充值表的ID
     * @apiParam {int} status 状态
     * - 1 通过
     * - 2 拒绝
     * @apiParam {string} [remark] 说明
     * - 当status =2 时，此参数必填
     */
    public function verifyRecharge()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'id' => ['required', 'integer', 'min:1'],
                'status' => ['required', 'integer', 'in:1,2'],
                'remark' => ['required_if:status,2', 'string', 'min:1']
            ]);
            $id = request()->input('id');
            $status = request()->input('status');
            $remark = request()->input('remark', '');
            $recharge = Recharge::where('id', $id)
                ->where('type', 2)
                ->where('status', 0)->first();
            if (!$recharge) throw new Exception("数据不存在", HttpStatus::CUSTOM_ERROR);
            $amount = floatval($recharge->amount);
            if ($status == 2) {
                $recharge->status = 2;
                $recharge->save();
                $text = "充值结果通知\n";
                $text .= "充值数量：{$amount} USDT\n";
                $text .= "充值地址：{$recharge->to_address}\n";
                $text .= "状态：失败\n";
                $text .= "原因：{$remark}\n";
                TopUpService::notifyTransferSuccess($recharge->member_id, $text);
            } else {
                $recharge->status = 1;
                $recharge->save();
                $wallet = WalletModel::where('member_id', $recharge->member_id)
                    ->first();
                $available_balance = bcadd($wallet->available_balance, $amount, 10);
                BalanceLogService::addLog(
                    $recharge->member_id,
                    $amount,
                    $wallet->available_balance,
                    $available_balance,
                    "充值",
                    $recharge->id,
                    "用户充值后台审核到账"
                );
                $wallet->available_balance = $available_balance;
                $wallet->save();

                $text = "充值结果通知\n";
                $text .= "充值数量：{$amount} USDT\n";
                $text .= "充值地址：{$recharge->to_address}\n";
                $text .= "状态：成功\n";
                TopUpService::notifyTransferSuccess($recharge->member_id, $text);
            }
            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }
        return $this->success();
    }

    /**
     * @api {get} /admin/wallet 充值列表
     * @apiGroup 充值管理
     * @apiDescription 如果列表的type=2 并且 status = 0 <br/>那么代表这条数据是需要后台手动审核的
     * 需要有审核按钮，审核通过或者拒绝，其它情况则不需要审核按钮
     *
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     *
     * @apiParam {int} [page=1]
     * @apiParam {int} [limit=10]
     * @apiParam {string} [member_id] 房主 tg会员ID
     * @apiParam {int} [status] 状态
     * - 0 待确认
     * - 1 已确认
     * - 2 失败
     * - 3 已忽略
     * @apiSuccess (data) {Object} data
     * @apiSuccess (data) {int} data.total 数量
     * @apiSuccess (data) {Object[]} data.data 列表
     * @apiSuccess (data) {int} data.data.id
     * @apiSuccess (data) {int} data.data.member_id tg会员id
     * @apiSuccess (data) {string} data.data.net 链接类型
     * @apiSuccess (data) {string} data.data.coin 币种
     * @apiSuccess (data) {string} data.data.amount 充值数量
     * @apiSuccess (data) {string} data.data.to_address 充值地址（平台地址）
     * @apiSuccess (data) {string} data.data.from_address 转出地址（用户发起地址）
     * @apiSuccess (data) {string} data.data.txid 链上交易哈希
     * @apiSuccess (data) {string} data.data.block_time 区块时间
     * @apiSuccess (data) {string} data.data.block_height
     * @apiSuccess (data) {int} data.data.confirmations 确认数
     * @apiSuccess (data) {string} data.data.updated_at
     * @apiSuccess (data) {string} data.data.created_at
     * @apiSuccess (data) {int} data.data.status 状态
     * - 0 待确认
     * - 1 已确认
     * - 2 失败
     * - 3 已忽略
     * @apiSuccess (data) {int} data.data.type 充值类型
     * - 1 自动
     * - 2 手动
     * @apiSuccess (data) {string} data.data.image 充值转账凭证图片
     */
    public function index()
    {
        try {
            request()->validate([
                'member_id' => ['nullable', 'string', 'min:1'],
                'status' => ['nullable', 'string', 'min:0', 'max:3'],
                'type' => ['nullable', 'integer', 'in:1,2'],
            ]);
            $search = request()->all();
            $result = RechargeService::paginate($search);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(intval($e->getCode()));
        }
        return $this->success($result);
    }

    public function test()
    {
        // $contractAddress = TronHelper::getContractAddress('USDT');
        // $result = TronHelper::getTrc20Balance('TTJ1vH18Q4K3seDcjD4912KDHHzm327rtL',$contractAddress);
        // $result = TronHelper::getBalance('TDeGNiweUm86JBJHQ7kXwQ8XQKtrKorHad','USDT');
        // dump($result);

        // echo WalletService::createRechargeQrCode('TDeGNiweUm86JBJHQ7kXwQ8XQKtrKorHad');
        // $result = TronHelper::getTrc20UsdtRecharges('TGQaMxtyWeGowy8xqwh98JNNLtc77nzZ8M');
        // $result = TronHelper::getTransactionConfirmations('06407fa9a2ba51c88f1ed01c2296f0069bf305477d3847d41bc3f35cf9190f74');
        // var_dump($result);
        $result = RechargeService::syncUsdtRechargeRecords('7630843396');
        // RechargeService::handleRechargeConfirmation('45f313ccc3a2f4113f6cc9a7511e8b5096daa1de76cb57397e152a491c17249f');
        // WalletService::getUserWallet('1777');
    }
}