NN2022060801/app/Http/Controllers/Api/TaskController.php

<?php

namespace App\Http\Controllers\Api;

use App\Services\Api\MemberService;
use App\Services\ConfigService;
use App\Services\EmailService;
use App\Services\RedisService;
use App\Services\UsdtWalletService;
use Illuminate\Http\Request;

/**
 * 任务
 * Class TaskController
 * @package App\Http\Controllers\Api
 */
class TaskController extends webApp
{

    /**
     * 监听处理转账
     * @return array|mixed
     */
    public function catchTransfer()
    {
        $key = md5('OTC');
        $checkKey = request()->get('key');
        if($checkKey != $key){
            return message(1003, false);
        }

        $page = RedisService::get("caches:wallet:catchPage");
        $page = $page? $page : 1;

        $members = MemberService::make()->getCatchMember($page, 500);
        if(empty($members)){
            RedisService::set("caches:wallet:catchPage", 1, 600);
            return message(1019, false);
        }

        $count = 0;
        $failedCount = 0;
        foreach ($members as $v){
            $result = UsdtWalletService::make()->getTransferInLog($v['id'], $v['trc_address']);
            if($result){
                $count++;
                RedisService::set("caches:wallet:catchTransfer:{$v['id']}_result", $result, 600);
            }else{
                $failedCount++;
                RedisService::set("caches:wallet:catchTransfer:{$v['id']}_result", UsdtWalletService::make()->getError(), 600);
            }
        }

        RedisService::set("caches:wallet:catchPage", $page+1, 600);
        if($count>0){
            return message(1020, true,['success'=> $count,'fail'=> $failedCount]);
        }else{
            return message(1021, false);
        }
    }


}