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 catchTrcRecharge()
    {
        $key = md5('OTC');
        $checkKey = request()->get('key');
        if($checkKey != $key){
            return showJson(1003, false);
        }

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

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

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

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


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

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

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

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

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


}