admin_api/app/Http/Controllers/Game/ActivityController.php

<?php

namespace App\Http\Controllers\Game;

use App\dao\Estatisticas\RechargeWithDraw;
use App\Facade\TableName;
use App\Game\GlobalUserInfo;
use App\Game\RePayConfig;
use App\Game\Services\AgentService;
use App\Game\Services\LZCompressor\LZString as LZ;
use App\Game\Services\OuroGameService;
use App\Game\Services\RouteService;
use App\Game\Services\ServerService;
use App\Game\WebActivity;
use App\Game\WebChannelConfig;
use App\Http\Controllers\Controller;

use App\Game\RedEnvelopeConfig;
use App\Game\RedEnvelopeLog;
use App\Http\helper\Helper;
use App\Http\helper\NumConfig;
use App\Jobs\AfEvent;
use App\Models\AccountsInfo;
use App\Models\Order;
use App\Models\PrivateMail;
use App\Models\RecordUserDataStatistics;
use App\Models\Treasure\GameScoreInfo;
use App\Notification\TelegramBot;
use App\Services\OrderServices;
use App\Services\HolidayWheelService;
use App\Services\ChristmasWheelService;
use App\Services\PayConfig;
use App\Services\SmartFastPay;
use App\Services\StoredProcedure;
use App\Util;
use App\Utility\SetNXLock;
use Illuminate\Http\Request;
use Carbon\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
use PDO;

class ActivityController extends Controller
{
    public function index()
    {

    }

    /**
     * 节假日大转盘 - 获取配置与用户状态
     */
    public function holidayWheelInfo(Request $request)
    {
        $user = $request->user();
        $userId = $user ? $user->UserID : 0;

        $service = new HolidayWheelService();
        $info = $service->getWheelInfo($userId);

        return apiReturnSuc($info);
    }

    /**
     * 节假日大转盘 - 抽奖
     */
    public function holidayWheelSpin(Request $request)
    {
        $user = $request->user();
        if (!$user) {
//            return apiReturnFail('请先登录');
            return apiReturnFail(['web.activity.login_required', __('messages.web.activity.login_required')]); // 请先登录

        }

        $service = new HolidayWheelService();
        try {
            $result = $service->spin($user->UserID);
            return apiReturnSuc($result);
        } catch (\Throwable $e) {
            \Log::error('holiday wheel spin failed', [
                'user_id' => $user->UserID,
                'error' => $e->getMessage(),
            ]);
            // 这里统一返回通用错误，不向前端抛出具体异常信息
            return apiReturnFail(['web.activity.wheel_error', __('messages.web.activity.wheel_error')]);
        }
    }

    /**
     * 圣诞大转盘 - 获取配置与用户状态
     */
    public function christmasWheelInfo(Request $request)
    {
        $user = $request->user();
        $userId = $user ? $user->UserID : 0;

        $service = new ChristmasWheelService();
        $info = $service->getWheelInfo($userId);

        return apiReturnSuc($info);
    }

    /**
     * 圣诞大转盘 - 抽奖
     */
    public function christmasWheelSpin(Request $request)
    {
        $user = $request->user();
        if (!$user) {
            return apiReturnFail(['web.activity.login_required', __('messages.web.activity.login_required')]); // 请先登录
        }

        $service = new ChristmasWheelService();
        try {
            $result = $service->spin($user->UserID);
            return apiReturnSuc($result);
        } catch (\Throwable $e) {
            \Log::error('christmas wheel spin failed', [
                'user_id' => $user->UserID,
                'error' => $e->getMessage(),
            ]);
            // 这里统一返回通用错误，不向前端抛出具体异常信息
            return apiReturnFail(['web.activity.wheel_error', __('messages.web.activity.wheel_error')]);
        }
    }
    public function List(Request $request)
    {

        return apiReturnSuc(['list'=>WebActivity::query()->whereRaw(RouteService::getStateToWhereRaw($request))->get()->toArray()]);

    }
    public function GetProtectNum(Request $request)
    {

        $user=$request->user();
        if(ServerService::GetGlobalServerInfoByGUID($user->GlobalUID)['Subsite']=='Europe'){
            //欧洲暂时封闭
            return apiReturnSuc();
        }
        $UserID=$user->UserID;
        $res=DB::connection('sqlsrv')->select("exec QPAccountsDB.dbo.GSP_GP_QueryProtect $UserID");

        return apiReturnSuc($res);
    }
    public function AddProtectNum(Request $request)
    {

        $user=$request->user();
        $UserID=$user->UserID;

        if(ServerService::GetGlobalServerInfoByGUID($user->GlobalUID)['Subsite']=='Europe'){
            //欧洲暂时封闭
            return apiReturnSuc();
        }
        $dbh = DB::connection()->getPdo();

        $sql="
        set nocount on use QPAccountsDB;
        DECLARE @return_value INT;
        EXEC @return_value = QPAccountsDB.dbo.GSP_GP_AddProtect @dwUserID = $UserID;
        SELECT @return_value as ReturnValue;";

        $stmt = $dbh->prepare($sql);

        $stmt->execute();

        $result = $stmt->fetch(\PDO::FETCH_ASSOC);

//            dd($user,$result);
        // 获取返回值和错误描述
        $returnValue = $result['ReturnValue']??0;


//        $result=DB::connection('sqlsrv')->select('EXEC @return_value = QPAccountsDB.dbo.GSP_GP_AddProtect @dwUserID = '.$UserID.'; SELECT @return_value AS ReturnValue;');
        // 获取返回值
//        $returnValue = $result[1]->ReturnValue;
        if ($returnValue == 0) {
            return apiReturnSuc($result);
        } else if ($returnValue == 1) {
            return apiReturnFail(['web.protect.score_limit','Score limit reached']);
        } else if ($returnValue == 3) {
            return apiReturnFail(['web.protect.times_limit','Protect times limit reached']);
        } else {
            return apiReturnFail(['web.withdraw.try_again_later','Unknown error']);
        }
    }
    public function GetCheckInInfoConfig(Request $request)
    {
        $user=$request->user();
        $UserID=$user->UserID;
        
        // 使用 Redis 进程锁防止并发调用存储过程导致主键冲突
        $lockKey = 'checkin_get_info_' . $UserID;
        $lockAcquired = SetNXLock::getExclusiveLock($lockKey, 5);
        
        if (!$lockAcquired) {
            // 如果获取锁失败，等待一小段时间后重试一次
//            usleep(100000); // 等待 100ms
            $lockAcquired = SetNXLock::getExclusiveLock($lockKey, 5);
            if (!$lockAcquired) {
                // 如果还是获取不到锁，返回错误
                return apiReturnFail(['web.checkin.try_again_later', 'Please try again later']);
            }
        }
        
        try {
            $res=DB::connection('sqlsrv')->select("exec QPAccountsDB.dbo.GSP_GP_GetUserSignInInfo $UserID");
            $res2=DB::table('QPAccountsDB.dbo.UserSignInInfo')->where('UserID',$UserID)->first();
            $max=count($res);
            $res2=(array)$res2;

            if($res2['NextDayNumber']>$max) {
                $res2['NextDayNumber']= $res2['NextDayNumber'] % $max + 1;
                $res2['RecordDay']='';
                for($i=0;$i<$max;$i++) {

                    $res2['RecordDay'].=$i<($res2['NextDayNumber']-1)?'1':'0';
                }
            }
            $res2['config']=$res;
            return apiReturnSuc($res2);
        } finally {
            // 确保释放锁
            SetNXLock::release($lockKey);
        }

    }
    public function GetCheckInInfo(Request $request)
    {
        $user=$request->user();
        $UserID=$user->UserID;
        try {
            // 定义输出参数
            $errorDescribe = '';

            // 调用存储过程
//            $result = DB::connection('sqlsrv')->select('
//                use QPAccountsDB;
//                DECLARE @strErrorDescribe NVARCHAR(127);
//                DECLARE @return_value INT;
//                EXEC @return_value = QPAccountsDB.dbo.GSP_GP_UserSignIn @dwUserID = $UserID, @strErrorDescribe = @strErrorDescribe OUTPUT;
//                SELECT @return_value as ReturnValue, @strErrorDescribe as ErrorDescribe;
//            ', [$UserID]);
//


            $dbh = DB::connection()->getPdo();

            $sql="
        set nocount on use QPAccountsDB;
        DECLARE @strErrorDescribe NVARCHAR(127);
        DECLARE @return_value INT;
        EXEC @return_value = QPAccountsDB.dbo.GSP_GP_UserSignIn @dwUserID = $UserID, @strErrorDescribe = @strErrorDescribe OUTPUT;
        SELECT @return_value as ReturnValue, @strErrorDescribe as ErrorDescribe;";

            $stmt = $dbh->prepare($sql);

            $stmt->execute();

            $result = $stmt->fetch(\PDO::FETCH_ASSOC);

//            dd($user,$result);
            // 获取返回值和错误描述
            $returnValue = $result['ReturnValue']??0;
//            $errorDescribe = $result['ErrorDescribe'];

            // 根据返回值和错误描述处理
            switch ($returnValue) {
                case 1:
                    return apiReturnFail(['web.checkin.user_signin_error', 'Failed to get user sign-in information']);
                case 2:
                    return apiReturnFail(['web.checkin.user_already_signed_in', 'You have already signed in today']);
                case 3:
                    return apiReturnFail(['web.checkin.signin_event_ended', 'The sign-in activity has ended']);
                case 4:
                    return apiReturnFail(['web.checkin.signin_data_error', 'Failed to read sign-in data']);
                case 5:
                    return apiReturnFail(['web.checkin.recharge_required', 'Recharge is required to sign in'],[],777);
                case 0:
                    $this->triggerSignIn($UserID);
                    return apiReturnSuc($result);
                default:
                    return apiReturnFail(['web.checkin.unknown_error', 'Unknown error']);
            }
        } catch (\Exception $e) {
            TelegramBot::getDefault()->sendProgramNotify("Game Checkin:", $e->getMessage());
            // 捕获异常并返回错误响应
            return apiReturnFail(['web.checkin.exception_occurred', 'An error occurred while processing your request'], [], 500);
        }
    }
    public function RedConfig(Request $request){
        $config=Redis::get("RedEnvelopeConfig");
        if(!$config){
            $config=RedEnvelopeConfig::query()->get();
            Redis::set("RedEnvelopeConfig",json_encode($config));
            Redis::expire("RedEnvelopeConfig",600);
        }else{
            $config=json_decode($config,true);
        }
        return apiReturnSuc($config);
    }
    public function RedCheck(Request $request)
    {
        $maxRedpack=24680;
        $currentDateTime = Carbon::now();
        $currentTime = $currentDateTime->format('H:i:s');

        // 查找当前时间段内的红包配置
        $config = RedEnvelopeConfig::where('StartTime', '<=', $currentTime)
            ->where('EndTime', '>=', $currentTime)
            ->first();


        if ($config) {
            $getted=false;
            if($request->user()) {
                $userID=$request->user()->UserID;
                $checkKey = "redpack_$userID";
                $getted=Redis::exists($checkKey);

            }
            return apiReturnSuc(['status' => $getted?-1:1,'max'=>$maxRedpack]);
        } else {
            // 计算下一个红包时间
            $nextConfig = RedEnvelopeConfig::where('StartTime', '>', $currentTime)
                ->orderBy('StartTime', 'asc')
                ->first();

            if (!$nextConfig) {
                // 如果今天没有更多红包时间段，则查找明天的第一个红包时间段
                $nextConfig = RedEnvelopeConfig::orderBy('StartTime', 'asc')->first();
                $nextTime = Carbon::tomorrow()->setTimeFromTimeString($nextConfig->StartTime);
            } else {
                $nextTime = Carbon::today()->setTimeFromTimeString($nextConfig->StartTime);
            }

            $diffMinutes = $currentDateTime->diffInSeconds($nextTime);

            return apiReturnSuc(['status' => 0,'max'=>$maxRedpack, 'next_in_seconds' => $diffMinutes],['activity.redpack.please_wait','Please wait until next time.']);
        }
    }

    public function RedReceive(Request $request)
    {

        return apiReturnSuc(['status' => -1,'amount'=>0]);
        $user=$request->user();
        $userID = $user->UserID;
        $currentDateTime = Carbon::now();
        $currentTime = $currentDateTime->format('H:i:s');

        $checkKey="redpack_$userID";

        if(Redis::exists($checkKey)){
            return apiReturnSuc(['status' => -1,'amount'=>0]);
        }

        // 查找当前时间段内的红包配置
        $config = RedEnvelopeConfig::where('StartTime', '<=', $currentTime)
            ->where('EndTime', '>=', $currentTime)
            ->first();



        if ($config) {

            // 在红包活动时间段内，生成红包金额
            $amount = $this->generateRedEnvelopeAmount($user,$config);
            if(is_array($amount))return $amount;

            // 记录领取日志
            RedEnvelopeLog::create([
                'UserID'     => $userID,
                'ReceivedAt' => $currentDateTime,
                'Amount'     => $amount,
                'Comment'    => '红包雨活动'
            ]);
            Redis::set($checkKey,1);
            Redis::expire($checkKey,3600);

            return apiReturnSuc(['amount' => $amount,'status' => 1]);
        } else {
            // 不在红包活动时间段内
            return apiReturnFail(['web.activity.redpack_not_available','There is no RedPack']);
        }
    }

    /**
     * @param $user
     * @param RedEnvelopeConfig $config
     * @return array|int
     */
    private function generateRedEnvelopeAmount($user, $config)
    {
        //超过限额
        if($config->PrizePool>=3000){
            return 0;
        }
        $UserID=$user->UserID;
//        $recharinfo=DB::connection('write')->table('QPAccountsDB.dbo.YN_VIPAccount')
//            ->where('UserID', $UserID)->first();
//        // 根据用户的充值金额决定红包金额


        $userTotal = DB::connection('write')->table('QPRecordDB.dbo.RecordUserTotalStatistics')
            ->where('UserID', $UserID)
            ->first();
        $deposit = 0;
        $withdraw = 0;
        $revenue = 0;
        if($userTotal){
            $deposit = $userTotal->Recharge;
            $withdraw = $userTotal->Withdraw;
            $revenue = $userTotal->Revenue;
        }

        $amount = 0;

        if ($deposit == 0) {
            // 未充值用户无法领取红包
            return apiReturnFail(['web.activity.redpack_no_recharge', 'message' => 'You need deposit first!']);
        } elseif ($deposit < 50) {
            // 50以下
            if (rand(1, 100) <= 50) {
                $amount=0;
            } else {
                $amount = rand(1, 2);
            }
        } elseif ($deposit < 100) {
            // 50-100
            if (rand(1, 100) <= 40) {
                $amount=0;
            } else {
                $amount = rand(1, 5);
            }
        } elseif ($deposit < 500) {
            // 100-500
            if (rand(1, 100) <= 25) {
                $amount=0;
            } else {
                $amount = rand(5, 10);
            }
        } elseif ($deposit < 1000) {
            // 500-1000
            if (rand(1, 100) <= 20) {
                $amount=0;
            } else {
                $amount = rand(5, 15);
            }
        } elseif ($deposit < 5000) {
            // 1000-5000
            if (rand(1, 100) <= 10) {
                $amount=0;
            } else {
                $amount = rand(10, 30);
            }
        } elseif ($deposit < 20000) {
            // 5000-20000
            $amount = rand(20, 100);
        } elseif ($deposit < 200000) {
            // 20000-200000
            $amount = rand(100, 150);
        } else {
            // 200000以上
            $amount = rand(100, 300);
        }

        if($amount){


            //平台资产》充 减半
            if($withdraw + $revenue > $deposit*100 && $deposit>1000){
                $rate = max(($withdraw + $revenue) / ($deposit*100) * 2,2);
                $amount  = intval($amount/$rate);
            }

            //出》入 0
            if($withdraw > $deposit*100){
                $amount  = 0;
            }
        }


        if($amount){
            $config->increment('PrizePool', $amount);
            OuroGameService::AddScore($UserID,$amount*NumConfig::NUM_VALUE,OuroGameService::REASON_RedEnvelope);
//            OuroGameService::AddDrawBase($UserID,$amount*100,2);
        }
        return $amount;
    }
    public function repayFirst()
    {

        $str="10014268,2000,BRA2851903748065310014268
10014270,2000,BRA2855489212693610014270
10014271,2000,BRA2852393071882610014271
10014274,1000,BRA2853030100749910014274
10014276,1000,BRA2853245554392310014276
10014277,2000,BRA2853344779876810014277
10014277,2000,BRA2855290186893810014277
10014277,2000,BRA2864525856913410014277
10014281,1000,BRA2854641828657010014281
10014282,2000,BRA2854744724737410014282
10014285,2000,BRA2855039889866610014285
10014287,2000,BRA2855391649287010014287
10014288,1000,BRA2855464384803010014288
10014292,2000,BRA2856246492161510014292
10014297,1000,BRA2857229048633010014297
10014300,2000,BRA2858261561088610014300
10014301,2000,BRA2858433689840310014301
10014302,1000,BRA2858522897364510014302
10014305,2000,BRA2859083559189210014305
10014306,2000,BRA2859074387476010014306
10014308,2000,BRA2859253433784710014308
10014309,2000,BRA2859266221396810014309
10014311,1000,BRA2859721671820010014311
10014314,2000,BRA2860714714541810014314
10014316,2000,BRA2861078506701410014316
10014318,2000,BRA2861340050408610014318
10014324,2000,BRA2863987369403910014324
10014326,2000,BRA2862573151411810014326
10014327,2000,BRA2862997500499910014327
10014330,1000,BRA2863297592217210014330
10014332,2000,BRA2863120608306010014332
10014335,1000,BRA2975317980447310014335
10014339,2000,BRA2864730304211810014339
10014351,2000,BRA2869670282797610014351
10014352,2000,BRA2971319703907510014352
10014358,2000,BRA2973553150552010014358
10014372,2000,BRA2995159192410010014372
10014373,2000,BRA2995376698241510014373
10014375,2000,BRA2996350286730710014375
10014383,2000,BRA2902200217093410014383";
        $arr=explode("\n",$str);
        $sort=[];
        $g201 = DB::table('agent.dbo.recharge_gear')->where('gift_id', 201)->select('gift_id', 'money', 'give', 'favorable_price', 'second_give')->first();
        $g211 = DB::table('agent.dbo.recharge_gear')->where('gift_id', 211)->select('gift_id', 'money', 'give', 'favorable_price', 'second_give')->first();
        foreach ($arr as $k=>$v){
            [$UserID,$amount,$sn]=explode(',',$v);
            if(isset($sort[$UserID]))continue;
            $sort[$UserID]=$amount;

            if($amount==1000)$first=$g201;
            else $first=$g211;

            if ($first && $first->second_give > 0) {
                $bonus = '30000,' . $amount;
                PrivateMail::sendMail(2, $UserID, "Suplemento de erro de primeiro depósito", "Nós adicionamos para você, por favor, aceite.", $bonus, $sn, $amount);
                $fpkey = 'Firstpay_' . $UserID;
                $data = (array)$first;
                $data['buytime'] = time();
                $data['czReason'] = 1;
                $data['cjReason'] = 45;
                Redis::set($fpkey, json_encode($data));
                DB::table(TableName::agent() . 'guide_payment')->updateOrInsert([
                    'UserID'     => $UserID,
                    'GiftID'     => $amount==1000?201:211,
                    'CreateTime' => now()
                ], ['UserID' => $UserID]);
            }
        }
        dd($sort);

    }
    public static function decrypt($str){
        if (!isset($str)||!$str||empty($str)) {
            # code...
            return '';
        }
        $str=implode("+",explode(" ",$str));
        try {
            $destr=LZ::decompressFromBase64($str);
        }catch (\Exception $exception){
            Util::WriteLog('gamelz',$str);
            TelegramBot::getDefault()->sendProgramNotify("Game LZ decrypt:".$str);
            TelegramBot::getDefault()->sendProgramNotify("Game LZ decrypt:", $exception->getMessage().$exception->getTraceAsString());
            $destr=$str;
        }
        return $destr;


    }

    // ==================== VIP提现诱导功能 ====================

    /**
     * 获取用户VIP提现任务进度
     */
    public function getVipWithdrawTasks(Request $request)
    {
        $user = $request->user();
        $userId = $user->UserID;

        // 检查用户是否已充值
        $user_recharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
            ->where('UserID', $userId)
            ->value('Recharge') ?: 0;

        if ($user_recharge <= 0 &&!$request->input('is_test', 0)) {
//            return apiReturnFail('请先充值后再查看任务-'.$userId);
            return apiReturnFail(['web.vip_task.recharge_first', __('messages.web.vip_task.recharge_first')]); // 请先充值后再查看任务

        }

        // 获取用户任务数据
        $taskData = $this->getUserTaskData($userId);
        
        // 获取任务配置
        $taskConfig = $this->getTaskConfig();

        // 判断奖励状态：0-不能领取, 1-待领取, 2-已领取
        $stage1_reward_status = 0; // 不能领取
        if ($taskData['stage1_completed']) {
            $stage1_reward_status = $taskData['stage1_withdrawn'] ? 2 : 1; // 已领取 : 待领取
        }

        $stage2_reward_status = 0; // 不能领取
        if ($taskData['stage1_completed']) { // 阶段2需要阶段1完成才能解锁
            if ($taskData['stage2_completed']) {
                $stage2_reward_status = $taskData['stage2_withdrawn'] ? 2 : 1; // 已领取 : 待领取
            }
        }

        $stage3_reward_status = 0; // 不能领取
        if ($taskData['stage2_completed']) { // 阶段3需要阶段2完成才能解锁
            // 循环任务：需要充值总额和下注流水两个条件都完成才能领取
            $rechargeTarget = $taskData['stage3_recharge_target'] ?? 200;
            $betTarget = $taskData['stage3_bet_target'] ?? 1000;
            $rechargeProgress = $taskData['stage3_recharge_progress'] ?? 0;
            $betProgress = $taskData['stage3_bet_progress'] ?? 0;
            
            // 两个条件都完成才能领取奖励
            if ($rechargeProgress >= $rechargeTarget && $betProgress >= $betTarget) {
                $stage3_reward_status = 1; // 待领取
            }
        }

        // 构建阶段1任务列表
        $stage1Tasks = [];
        foreach ($taskConfig['stage1']['tasks'] as $taskCfg) {
            $taskKey = $taskCfg['id'];
            $progressKey = $taskCfg['progress_key'];
            $completed = $taskData[$taskKey] ?? false;
            
            $stage1Tasks[] = [
                'id' => $taskCfg['id'],
                'title' => $taskCfg['title'],
                'type' => $taskCfg['type'],
                'completed' => $completed,
                'status' => $completed ? 1 : 0,
//                'status_text' => $completed ? '已完成' : '未完成',
                'status_text' => $completed ? __('messages.web.vip_task.completed') : __('messages.web.vip_task.not_completed'), // 已完成 : 未完成

                'progress' => intval(min($taskData[$progressKey] ?? 0,$taskCfg['target'])),
                'target' => $taskCfg['target']
            ];
        }

        // 构建任务结构
        $tasks = [
            'stage1' => [
                'stage' => 1,
//                'title' => '阶段任务1',
                'title' => __('messages.web.vip_task.stage1_title'), // 阶段任务1

                'reward' => $taskConfig['stage1']['reward'],
                'completed' => $taskData['stage1_completed'],
                'reward_status' => $stage1_reward_status,
//                'reward_status_text' => ['不能领取', '待领取', '已领取'][$stage1_reward_status],
                'reward_status_text' => [__('messages.web.vip_task.cannot_claim'), __('messages.web.vip_task.can_claim'), __('messages.web.vip_task.claimed')][$stage1_reward_status], // 不能领取, 待领取, 已领取

                'can_claim' => $stage1_reward_status === 1,
                'tasks' => $stage1Tasks
            ],
            'stage2' => [
                'stage' => 2,
//                'title' => '阶段任务2',
                'title' => __('messages.web.vip_task.stage2_title'), // 阶段任务2

                'reward' => $taskConfig['stage2']['reward'],
                'unlocked' => $taskData['stage1_completed'],
                'completed' => $taskData['stage2_completed'],
                'reward_status' => $stage2_reward_status,
//                'reward_status_text' => ['不能领取', '待领取', '已领取'][$stage2_reward_status],
                'reward_status_text' => [__('messages.web.vip_task.cannot_claim'), __('messages.web.vip_task.can_claim'), __('messages.web.vip_task.claimed')][$stage2_reward_status], // 不能领取, 待领取, 已领取

                'can_claim' => $stage2_reward_status === 1,
                'tasks' => array_map(function($taskCfg) use ($taskData) {
                    $taskKey = $taskCfg['id'];
                    $progressKey = $taskCfg['progress_key'];
                    $completed = $taskData[$taskKey] ?? false;
                    
                    return [
                        'id' => $taskCfg['id'],
                        'title' => $taskCfg['title'],
                        'type' => $taskCfg['type'],
                        'completed' => $completed,
                        'status' => $completed ? 1 : 0,
//                        'status_text' => $completed ? '已完成' : '未完成',
                        'status_text' => $completed ? __('messages.web.vip_task.completed') : __('messages.web.vip_task.not_completed'), // 已完成 : 未完成
                        'progress' => intval(min($taskData[$progressKey] ?? 0,$taskCfg['target'])),
                        'target' => $taskCfg['target']
                    ];
                }, $taskConfig['stage2']['tasks'])
            ],
            'stage3' => [
                'stage' => 3,
//                'title' => '阶段任务3（循环任务）',
                'title' => __('messages.web.vip_task.stage3_title'), // 阶段任务3（循环任务）

                // 根据循环次数判断奖励：第一次（loop_count=0或不存在）奖励20，之后每次10
                'reward' => (($taskData['stage3_loop_count'] ?? 0) == 0) ? 20 : 10,
                'unlocked' => $taskData['stage2_completed'],
                'completed' => ($taskData['stage3_task1'] ?? false) && ($taskData['stage3_task2'] ?? false),
                'reward_status' => $stage3_reward_status,
//                'reward_status_text' => ['不能领取', '待领取', '已领取'][$stage3_reward_status],
                'reward_status_text' => [__('messages.web.vip_task.cannot_claim'), __('messages.web.vip_task.can_claim'), __('messages.web.vip_task.claimed')][$stage3_reward_status], // 不能领取, 待领取, 已领取

                'can_claim' => $stage3_reward_status === 1,
                'is_loop' => true,
                'current_loop' => $taskData['stage3_loop_count'],
                'tasks' => array_map(function($taskCfg) use ($taskData) {
                    $taskKey = $taskCfg['id'];
                    $progressKey = $taskCfg['progress_key'] ?? '';
                    $targetKey = $taskCfg['target_key'] ?? '';
                    
                    // 获取当前进度和目标值
                    $currentProgress = $taskData[$progressKey] ?? 0;
                    $currentTarget = $targetKey ? ($taskData[$targetKey] ?? $taskCfg['target']) : $taskCfg['target'];
                    
                    // 判断是否完成
                    $completed = $currentProgress >= $currentTarget;
                    
                    // 动态生成任务标题（使用模板替换目标值）
                    $title = $taskCfg['title_template'] ?? $taskCfg['title'] ?? '';
                    if (!empty($title) && strpos($title, '{target}') !== false) {
                        $title = str_replace('{target}', $currentTarget, $title);
                    }
                    
                    return [
                        'id' => $taskCfg['id'],
                        'title' => $title,
                        'type' => $taskCfg['type'],
                        'completed' => $completed,
                        'status' => $completed ? 1 : 0,
//                        'status_text' => $completed ? '已完成' : '未完成',
                        'status_text' => $completed ? __('messages.web.vip_task.completed') : __('messages.web.vip_task.not_completed'), // 已完成 : 未完成
                        'progress' => intval(min($currentProgress, $currentTarget)),
                        'target' => $currentTarget
                    ];
                }, $taskConfig['stage3']['tasks'])
            ]
        ];

        return apiReturnSuc($tasks);
    }

    /**
     * 领取任务奖励（提现）
     */
    public function claimVipWithdrawReward(Request $request)
    {
        $user = $request->user();
        $userId = $user->UserID;
        $stage = (int)$request->input('stage');
        $taskId = $request->input('task_id', '');

        $redisLockKey = "vip_withdraw_claim_{$userId}";
        if (!Redis::set($redisLockKey, 1, 'EX', 10, 'NX')) {
//            return apiReturnFail('操作太频繁，请稍后再试');
            return apiReturnFail(['web.vip_task.operation_frequent', __('messages.web.vip_task.operation_frequent')]); //'操作太频繁，请稍后再试'

        }

        try {
            // 获取用户任务数据
            $taskData = $this->getUserTaskData($userId);
            $rewardAmount = 0;

            // 阶段1
            if ($stage === 1) {
                if (!$taskData['stage1_completed']) {
                    Redis::del($redisLockKey);
//                    return apiReturnFail('任务未完成');
                    return apiReturnFail(['web.vip_task.task_not_completed', __('messages.web.vip_task.task_not_completed')]); // 任务未完成

                }
                if ($taskData['stage1_withdrawn']) {
                    Redis::del($redisLockKey);
                    return apiReturnFail(['web.vip_task.reward_claimed', __('messages.web.vip_task.reward_claimed')]); // 奖励已领取

//                    return apiReturnFail('奖励已领取');
                }
                $rewardAmount = 10;
                $this->updateTaskProgress($userId, 'stage1_withdrawn', 1);
            }
            // 阶段2
            elseif ($stage === 2) {
                if (!$taskData['stage2_completed']) {
                    Redis::del($redisLockKey);
//                    return apiReturnFail('任务未完成');
                    return apiReturnFail(['web.vip_task.task_not_completed', __('messages.web.vip_task.task_not_completed')]); // 任务未完成

                }
                if ($taskData['stage2_withdrawn']) {
                    Redis::del($redisLockKey);
                    return apiReturnFail(['web.vip_task.reward_claimed', __('messages.web.vip_task.reward_claimed')]); // 奖励已领取

//                    return apiReturnFail('奖励已领取');
                }
                $rewardAmount = 10;
                $this->updateTaskProgress($userId, 'stage2_withdrawn', 1);
            }
            // 阶段3
            elseif ($stage === 3) {
                $taskId = $request->input('task_id', 'stage3_task1');
                
                // 检查两个条件是否都完成
                $rechargeTarget = $taskData['stage3_recharge_target'] ?? 200;
                $betTarget = $taskData['stage3_bet_target'] ?? 1000;
                $rechargeProgress = $taskData['stage3_recharge_progress'] ?? 0;
                $betProgress = $taskData['stage3_bet_progress'] ?? 0;
                
                if ($rechargeProgress < $rechargeTarget || $betProgress < $betTarget) {
                    Redis::del($redisLockKey);
                    return apiReturnFail(['web.vip_task.task_not_completed', __('messages.web.vip_task.task_not_completed')]); // 任务未完成
                }
                
                // 根据循环次数判断奖励：第一次（loop_count=0或不存在）奖励20，之后每次10
                $currentLoopCount = $taskData['stage3_loop_count'] ?? 0;
                $rewardAmount = ($currentLoopCount == 0) ? 20 : 10;
                
                // 领取后刷新任务：充值目标+100，下注目标+1000
                $newRechargeTarget = $rechargeTarget + 100;
                $newBetTarget = $betTarget + 1000;
                $newLoopCount = $currentLoopCount + 1;
                
                // 更新任务数据
                $redisKey = "vip_withdraw_task_{$userId}";
                $data = Redis::get($redisKey);
                if ($data) {
                    $taskData = json_decode($data, true);
                    $taskData['stage3_recharge_target'] = $newRechargeTarget;
                    $taskData['stage3_bet_target'] = $newBetTarget;
                    $taskData['stage3_loop_count'] = $newLoopCount;
                    $taskData['stage3_task1'] = false;
                    $taskData['stage3_task2'] = false;
                    
                    // 保存到数据库
                    $this->saveUserTaskData($userId, $taskData);
                    
                    // 更新Redis缓存
                    Redis::setex($redisKey, 86400, json_encode($taskData));
                }
            } else {
                Redis::del($redisLockKey);
                return apiReturnFail(['web.vip_task.invalid_stage', __('messages.web.vip_task.invalid_stage')]); // 无效的阶段

//                return apiReturnFail('无效的阶段');
            }

            // 添加提现额度到用户账户
            if ($rewardAmount > 0) {

                $dbh = DB::connection()->getPdo();

                $score=$rewardAmount*NumConfig::NUM_VALUE;

                $sql="DECLARE  @return_value int
        set nocount on use QPAccountsDB
        EXEC  @return_value = GSP_GR_GetFreeWithDraw '$userId','$score'
        SELECT 'ReturnValue' = @return_value";
                $stmt = $dbh->prepare($sql);
                $stmt->execute();
                $retval = $stmt->fetch(\PDO::FETCH_ASSOC);
                try {
//        set @ret = 1	--可提额度不足
//        set @ret = 2	--低于最低可提现金额
//        set @ret = 3	--高于最高可提现金额
//        set @ret = 4	--超过每天提现次数上限
//        set @ret = 5	--身上钱不够
//        set @ret = 6	--开在游戏里面
//        set @ret = 7	--未充值的用户TX额度
                    if (isset($retval['ReturnValue'])) {
                        $ReturnValue = $retval['ReturnValue'];
                        // set @ret = 1 -- Insufficient withdrawal amount
// set @ret = 2 -- Lower than the minimum withdrawal amount
// set @ret = 3 -- Higher than the maximum withdrawal amount
// set @ret = 4 -- Exceeded the daily withdrawal limit
// set @ret = 5 -- Not enough money on hand
// set @ret = 6 -- Opened in the game
// set @ret = 7 -- Undeposited user TX amount
                        $errors = [
                            [],
                            ['web.withdraw.no_withdraw_value', "The withdrawable amount is not enough"],
                            ['web.withdraw.too_low', 'Lower than the minimum withdrawal amount'],
                            ['web.withdraw.too_high', 'Higher than the maximum withdrawal amount'],
                            ['web.withdraw.day_max', 'Exceeded the daily withdrawal limit'],
                            ['web.withdraw.no_enouth_score', 'Not enough money on hand'],
                            ['web.withdraw.in_game', 'Sorry, You\'re in game for now'],
                            ['web.withdraw.no_deposit', ' You need deposit first!'],
                        ];
                        return apiReturnFail($errors[$ReturnValue], [], $ReturnValue == 7 ? 777 : 301);
                    }else{
                        //return apiReturnSuc($retval);
                    }
                }catch (\Exception $e){
                   // TelegramBot::getDefault()->sendProgramNotify("WithDraw Error:", var_export($retval,true).':'.$e->getTraceAsString());
                    //return apiReturnSuc($retval);
                }
                
                // 记录日志
                \Log::info('VIP提现任务奖励', [
                    'user_id' => $userId,
                    'stage' => $stage,
                    'task_id' => $taskId,
                    'amount' => $rewardAmount
                ]);
            }

            Redis::del($redisLockKey);
            return apiReturnSuc([
                'amount' => $rewardAmount,
//                'message' => "成功领取 {$rewardAmount} 提现额度"
                'message' => __('messages.web.vip_task.claim_success', ['amount' => $rewardAmount]) // "成功领取 {$rewardAmount} 提现额度"

            ]);

        } catch (\Exception $e) {
            Redis::del($redisLockKey);
            \Log::error('VIP提现任务领取失败', [
                'user_id' => $userId,
                'error' => $e->getMessage()
            ]);
            return apiReturnFail(['web.vip_task.claim_failed', __('messages.web.vip_task.claim_failed', ['error' => $e->getMessage()])]); // 领取失败：

//            return apiReturnFail('领取失败：' . $e->getMessage());
        }
    }

    /**
     * 获取用户任务数据（从Redis和数据库）
     */
    private function getUserTaskData($userId)
    {
        $redisKey = "vip_withdraw_task_{$userId}";
        $data = Redis::get($redisKey);

        if ($data) {
            $taskData = json_decode($data, true);
        } else {
            // 从数据库加载任务数据
            $dbData = DB::table('agent.dbo.vip_withdraw_tasks')
                ->where('user_id', $userId)
                ->first();
            
            if ($dbData) {
                $taskData = json_decode($dbData->task_data, true);
            } else {
                // 初始化任务数据
                $taskData = $this->initUserTaskData($userId);
            }
        }

        // 实时更新统计数据
        $this->updateRealTimeStats($userId, $taskData);

        // 检查任务完成状态
        $this->checkTaskCompletion($taskData);

        // 保存到数据库（持久化）
        $this->saveUserTaskData($userId, $taskData);

        // 保存到Redis（缓存24小时）
        Redis::setex($redisKey, 86400, json_encode($taskData));

        return $taskData;
    }

    /**
     * 保存用户任务数据到数据库
     */
    private function saveUserTaskData($userId, $taskData)
    {
        try {
            DB::table('agent.dbo.vip_withdraw_tasks')->updateOrInsert(
                ['user_id' => $userId],
                [
                    'task_data' => json_encode($taskData, JSON_UNESCAPED_UNICODE),
                    'updated_at' => date('Y-m-d H:i:s')
                ]
            );
        } catch (\Exception $e) {
            \Log::error('VIP提现任务数据保存失败', [
                'user_id' => $userId,
                'error' => $e->getMessage()
            ]);
        }
    }

    /**
     * 获取任务配置
     */
    private function getTaskConfig()
    {
        return [
            'stage1' => [
                'reward' => 10,
                'tasks' => [
                    [
                        'id' => 'stage1_task1',
                        'title' => 'Claim daily bonus once',
                        'type' => 'sign_in',
                        'target' => 1,
                        'progress_key' => 'sign_in_count'
                    ],
                    [
                        'id' => 'stage1_task2',
                        'title' => 'Bet amount reaches 100',
                        'type' => 'bet_amount',
                        'target' => 100,
                        'progress_key' => 'total_bet'
                    ],
                    [
                        'id' => 'stage1_task3',
                        'title' => 'Deposit amount reaches 29',
                        'type' => 'recharge',
                        'target' => 29,
                        'progress_key' => 'recharge_count'
                    ]
                ]
            ],
            'stage2' => [
                'reward' => 10,
                'tasks' => [
                    [
                        'id' => 'stage2_task1',
                        'title' => 'Deposit amount reaches 100',
                        'type' => 'recharge',
                        'target' => 100,
                        'progress_key' => 'played_games_count'
                    ],
                    [
                        'id' => 'stage2_task2',
                        'title' => 'Bet amount reaches 200',
                        'type' => 'bet_amount',
                        'target' => 200,
                        'progress_key' => 'total_bet'
                    ],
                    [
                        'id' => 'stage2_task3',
                        'title' => 'Start inviting once',
                        'type' => 'invite',
                        'target' => 1,
                        'progress_key' => 'invite_count'
                    ]
                ]
            ],
            'stage3' => [
                'tasks' => [
                    [
                        'id' => 'stage3_task1',
                        'title_template' => 'Deposit amount reaches {target}', // 使用模板，动态替换目标值
                        'type' => 'recharge',
                        'target' => 200,
                        'reward' => 20,
                        'progress_key' => 'stage3_recharge_progress',
                        'target_key' => 'stage3_recharge_target'
                    ],
                    [
                        'id' => 'stage3_task2',
                        'title_template' => 'Bet amount reaches {target}', // 使用模板，动态替换目标值
                        'type' => 'bet_amount',
                        'target' => 1000,
                        'reward' => 20,
                        'progress_key' => 'stage3_bet_progress',
                        'target_key' => 'stage3_bet_target'
                    ]
                ]
            ]
        ];
    }

    /**
     * 初始化用户任务数据
     */
    private function initUserTaskData($userId)
    {
        return [
            // 阶段1任务
            'stage1_task1' => false,
            'stage1_task2' => false,
            'stage1_task3' => false,
            'stage1_completed' => false,
            'stage1_withdrawn' => false,

            // 阶段2任务
            'stage2_task1' => false,
            'stage2_task2' => false,
            'stage2_task3' => false,
            'stage2_completed' => false,
            'stage2_withdrawn' => false,

            // 阶段3任务（循环）
            'stage3_task1' => false,
            'stage3_task2' => false,
            'stage3_task1_withdrawn' => false,
            'stage3_loop_count' => 0,
            'stage3_recharge_target' => 200,  // 充值目标（初始200，每次+100）
            'stage3_bet_target' => 1000,       // 下注目标（初始1000，每次+1000）
            'stage3_recharge_progress' => 0,   // 当前充值总额
            'stage3_bet_progress' => 0,        // 当前下注流水
            'stage3_current_bet' => 0,
            'stage3_available_amount' => 0,

            // 统计数据
            'total_bet' => 0,
            'recharge_count' => 0,
            'played_games_count' => 0,
            'invite_count' => 0,
            'sign_in_count' => 0
        ];
    }

    /**
     * 更新实时统计数据
     */
    private function updateRealTimeStats($userId, &$taskData)
    {

        $userTotalStatistics = DB::table('QPRecordDB.dbo.RecordUserTotalStatistics')
            ->where('UserID', $userId)
            ->first();

        // 获取总下注金额
        $totalBet =$userTotalStatistics ?$userTotalStatistics->TotalBet: 0;
        $taskData['total_bet'] = $totalBet / NumConfig::NUM_VALUE;

        // 获取充值次数
        $rechargeCount = $userTotalStatistics?$userTotalStatistics->Recharge:0;
        $taskData['recharge_count'] = min($rechargeCount,29);

        // 获取玩过的游戏数量（去重）
//        $playedGames = DB::table('QPRecordDB.dbo.RecordUserGameCount')
//            ->where('UserID', $userId)
//            ->distinct()
//            ->count('GameID');
        $taskData['played_games_count'] = min($rechargeCount,100);;

        // 邀请人数从Redis读取（通过 triggerInvite 方法触发）
        if (!isset($taskData['invite_count'])) {
            $taskData['invite_count'] = 0;
        }

        // 签到次数从Redis读取（通过 triggerSignIn 方法触发）
        if (!isset($taskData['sign_in_count'])) {
            $taskData['sign_in_count'] = 0;
        }
        
        // 如存在未充值前的签到标记，且在同一天内完成充值，则补记签到
        $pendingKey = "vip_withdraw_sign_pending_{$userId}";
        $pendingSign = Redis::get($pendingKey);
        if ($pendingSign && $pendingSign == date('Ymd')) {
            $userRecharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
                ->where('UserID', $userId)
                ->value('Recharge') ?: 0;
            if ($userRecharge > 0) {
                if (($taskData['sign_in_count'] ?? 0) < 1) {
                    $taskData['sign_in_count'] = 1;
                }
                \Log::info('VIP提现任务-签到补记成功（同日充值）', [
                    'user_id' => $userId,
                    'sign_in_count' => $taskData['sign_in_count']
                ]);
            }
        }
        if ($pendingSign) {
            Redis::del($pendingKey);
        }
        
        // 如存在“未充值前的签到标记”，且用户已完成充值，则补记签到次数
        $pendingKey = "vip_withdraw_sign_pending_{$userId}";
        if (Redis::exists($pendingKey)) {
            $userRecharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
                ->where('UserID', $userId)
                ->value('Recharge') ?: 0;
            if ($userRecharge > 0) {
                if (($taskData['sign_in_count'] ?? 0) < 1) {
                    $taskData['sign_in_count'] = 1;
                }
                Redis::del($pendingKey);
                \Log::info('VIP提现任务-签到补记成功', [
                    'user_id' => $userId,
                    'sign_in_count' => $taskData['sign_in_count']
                ]);
            }
        }

        // 阶段3任务进度更新
        if ($taskData['stage2_completed'] ?? false) {
            // 获取充值总额（从 RecordUserTotalStatistics）
            $rechargeTotal = $userTotalStatistics ? ($userTotalStatistics->Recharge) : 0;
            $taskData['stage3_recharge_progress'] = $rechargeTotal;
            
            // 获取下注流水（使用 total_bet）
            $taskData['stage3_bet_progress'] = $taskData['total_bet'] ?? 0;
            
            // 初始化目标值（如果不存在）
            if (!isset($taskData['stage3_recharge_target'])) {
                $taskData['stage3_recharge_target'] = 200;
            }
            if (!isset($taskData['stage3_bet_target'])) {
                $taskData['stage3_bet_target'] = 1000;
            }
        }
        
        // 保留原有的 stage3_current_bet 逻辑（用于兼容）
        if (!isset($taskData['stage3_current_bet'])) {
            $taskData['stage3_current_bet'] = 0;
        }
        if (!isset($taskData['stage3_last_total_bet'])) {
            $taskData['stage3_last_total_bet'] = $totalBet; // 记录原始总下注（原始单位）
        }
        // 计算本次新增下注（转为金额单位）
        $deltaBet = $totalBet - ($taskData['stage3_last_total_bet'] ?? 0);
        if ($deltaBet > 0) {
            $taskData['stage3_current_bet'] += ($deltaBet / NumConfig::NUM_VALUE);
            $taskData['stage3_last_total_bet'] = $totalBet;
        }
    }

    /**
     * 检查任务完成状态
     */
    private function checkTaskCompletion(&$taskData)
    {
        // 阶段1任务检查
        $taskData['stage1_task1'] = $taskData['sign_in_count'] >= 1;
        $taskData['stage1_task2'] = $taskData['total_bet'] >= 100;
        $taskData['stage1_task3'] = $taskData['recharge_count'] >= 29;
        $taskData['stage1_completed'] = $taskData['stage1_task1'] && 
                                         $taskData['stage1_task2'] && 
                                         $taskData['stage1_task3'];

        // 阶段2任务检查
        if ($taskData['stage1_completed']) {
            $taskData['stage2_task1'] = $taskData['played_games_count'] >= 100;
            $taskData['stage2_task2'] = $taskData['total_bet'] >= 200;
            $taskData['stage2_task3'] = $taskData['invite_count'] >= 1;
            $taskData['stage2_completed'] = $taskData['stage2_task1'] && 
                                             $taskData['stage2_task2'] && 
                                             $taskData['stage2_task3'];
        }

        // 阶段3任务检查（循环）：需要充值总额和下注流水两个条件都完成
        if ($taskData['stage2_completed']) {
            $rechargeTarget = $taskData['stage3_recharge_target'] ?? 200;
            $betTarget = $taskData['stage3_bet_target'] ?? 1000;
            $rechargeProgress = $taskData['stage3_recharge_progress'] ?? 0;
            $betProgress = $taskData['stage3_bet_progress'] ?? 0;
            
            $taskData['stage3_task1'] = $rechargeProgress >= $rechargeTarget;
            $taskData['stage3_task2'] = $betProgress >= $betTarget;
        }
    }

    /**
     * 更新任务进度
     */
    private function updateTaskProgress($userId, $key, $value)
    {
        $redisKey = "vip_withdraw_task_{$userId}";
        $data = Redis::get($redisKey);
        
        if ($data) {
            $taskData = json_decode($data, true);
            $taskData[$key] = $value;
            
            // ✅ 保存到数据库（持久化）
            $this->saveUserTaskData($userId, $taskData);
            
            // ✅ 更新Redis缓存（24小时）
            Redis::setex($redisKey, 86400, json_encode($taskData));
        }
    }

    /**
     * 重置阶段3循环任务
     */
    private function resetStage3Tasks($userId)
    {
        $redisKey = "vip_withdraw_task_{$userId}";
        $data = Redis::get($redisKey);
        
        if ($data) {
            $taskData = json_decode($data, true);
            $taskData['stage3_task1'] = false;
            $taskData['stage3_task1_withdrawn'] = false;
            $taskData['stage3_current_bet'] = 0;
            $taskData['stage3_cycle_start'] = (int)date('Ymd');
            $taskData['stage3_loop_count'] = ($taskData['stage3_loop_count'] ?? 0) + 1;
            
            // ✅ 保存到数据库（持久化）
            $this->saveUserTaskData($userId, $taskData);
            
            // ✅ 更新Redis缓存（24小时）
            Redis::setex($redisKey, 86400, json_encode($taskData));
        }
    }

    /**
     * 手动触发签到（供其他地方调用）
     * 注意：只有充值用户才会计数
     */
    public function triggerSignIn($userId)
    {
        // 检查用户是否已充值（仅用于记录日志，不再阻断签到进度）
        $user_recharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
            ->where('UserID', $userId)
            ->value('Recharge') ?: 0;
        $hasRecharge = $user_recharge > 0;
        
        $pendingKey = "vip_withdraw_sign_pending_{$userId}";
        
        if (!$hasRecharge) {
            // 未充值用户，先把签到标记在Redis中，等待充值后结算（仅限同一天）
            Redis::setex($pendingKey, 86400, date('Ymd')); // 标记签到日期
            
            \Log::info('VIP提现任务-签到记录（待充值）', [
                'user_id' => $userId,
                'note'    => '用户尚未充值，签到标记已暂存Redis',
                'redis_key' => $pendingKey
            ]);
            
            return true;
        }
        
        // 用户已充值，如存在待结算签到标记，检查是否为同一天
        $pendingSign = Redis::get($pendingKey);
        if ($pendingSign && $pendingSign == date('Ymd')) {
            // 同一天内补记签到次数（若尚未计数）
            $redisKey = "vip_withdraw_task_{$userId}";
            $data = Redis::get($redisKey);
            
            if ($data) {
                $taskData = json_decode($data, true);
                if (($taskData['sign_in_count'] ?? 0) < 1) {
                    $taskData['sign_in_count'] = 1;
                    $this->saveUserTaskData($userId, $taskData);
                    Redis::setex($redisKey, 86400, json_encode($taskData));
                }
            } else {
                $dbData = DB::table('agent.dbo.vip_withdraw_tasks')
                    ->where('user_id', $userId)
                    ->first();
                if ($dbData) {
                    $taskData = json_decode($dbData->task_data, true);
                } else {
                    $taskData = $this->initUserTaskData($userId);
                }
                if (($taskData['sign_in_count'] ?? 0) < 1) {
                    $taskData['sign_in_count'] = 1;
                    $this->saveUserTaskData($userId, $taskData);
                }
                Redis::setex($redisKey, 86400, json_encode($taskData));
            }
            
            \Log::info('VIP提现任务-签到补记成功（同日充值）', [
                'user_id' => $userId
            ]);
        }
        Redis::del($pendingKey);
        
        $redisKey = "vip_withdraw_task_{$userId}";
        $data = Redis::get($redisKey);
        
        if ($data) {
            $taskData = json_decode($data, true);
            $taskData['sign_in_count'] = ($taskData['sign_in_count'] ?? 0) + 1;
            
            // ✅ 保存到数据库（持久化）
            $this->saveUserTaskData($userId, $taskData);
            
            // ✅ 更新Redis缓存（24小时）
            Redis::setex($redisKey, 86400, json_encode($taskData));
            
            \Log::info('VIP提现任务-签到触发成功', [
                'user_id' => $userId,
                'sign_in_count' => $taskData['sign_in_count']
            ]);
            
            return true;
        } else {
            // 如果Redis没有数据，从数据库加载或初始化
            $dbData = DB::table('agent.dbo.vip_withdraw_tasks')
                ->where('user_id', $userId)
                ->first();
            
            if ($dbData) {
                $taskData = json_decode($dbData->task_data, true);
            } else {
                $taskData = $this->initUserTaskData($userId);
            }
            
            $taskData['sign_in_count'] = ($taskData['sign_in_count'] ?? 0) + 1;
            
            // ✅ 保存到数据库（持久化）
            $this->saveUserTaskData($userId, $taskData);
            
            // ✅ 更新Redis缓存（24小时）
            Redis::setex($redisKey, 86400, json_encode($taskData));
            
            \Log::info('VIP提现任务-签到触发成功（首次）', [
                'user_id' => $userId,
                'sign_in_count' => 1
            ]);
            
            return true;
        }
    }

    /**
     * 手动触发邀请（供其他地方调用）
     * 注意：只有充值用户且阶段1完成后才会计数
     */
    public function triggerInvite($userId)
    {
        // 检查用户是否已充值
        $user_recharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
            ->where('UserID', $userId)
            ->value('Recharge') ?: 0;
        
        if ($user_recharge <= 0) {
            \Log::info('VIP提现任务-邀请触发失败', [
                'user_id' => $userId,
                'reason' => '用户未充值'
            ]);
            return false;
        }
        
        $redisKey = "vip_withdraw_task_{$userId}";
        $data = Redis::get($redisKey);
        
        if ($data) {
            $taskData = json_decode($data, true);
            
            // 检查阶段1是否完成
            if (!isset($taskData['stage1_completed']) || !$taskData['stage1_completed']) {
                // 阶段1未完成，不计数
                \Log::info('VIP提现任务-邀请触发失败', [
                    'user_id' => $userId,
                    'reason' => '阶段1未完成',
                    'stage1_completed' => $taskData['stage1_completed'] ?? false
                ]);
                return false;
            }
            
            // 阶段1已完成，增加邀请计数
            $taskData['invite_count'] = ($taskData['invite_count'] ?? 0) + 1;
            
            // ✅ 保存到数据库（持久化）
            $this->saveUserTaskData($userId, $taskData);
            
            // ✅ 更新Redis缓存（24小时）
            Redis::setex($redisKey, 86400, json_encode($taskData));
            
            \Log::info('VIP提现任务-邀请触发成功', [
                'user_id' => $userId,
                'invite_count' => $taskData['invite_count']
            ]);
            
            return true;
        } else {
            // 如果Redis没有数据，从数据库加载
            $dbData = DB::table('agent.dbo.vip_withdraw_tasks')
                ->where('user_id', $userId)
                ->first();
            
            if ($dbData) {
                $taskData = json_decode($dbData->task_data, true);
                
                // 检查阶段1是否完成
                if (!isset($taskData['stage1_completed']) || !$taskData['stage1_completed']) {
                    \Log::info('VIP提现任务-邀请触发失败', [
                        'user_id' => $userId,
                        'reason' => '阶段1未完成'
                    ]);
                    return false;
                }
                
                // 增加邀请计数
                $taskData['invite_count'] = ($taskData['invite_count'] ?? 0) + 1;
                
                // ✅ 保存到数据库（持久化）
                $this->saveUserTaskData($userId, $taskData);
                
                // ✅ 更新Redis缓存（24小时）
                Redis::setex($redisKey, 86400, json_encode($taskData));
                
                \Log::info('VIP提现任务-邀请触发成功（从数据库加载）', [
                    'user_id' => $userId,
                    'invite_count' => $taskData['invite_count']
                ]);
                
                return true;
            } else {
                // 用户数据不存在或阶段1未完成
                \Log::info('VIP提现任务-邀请触发失败', [
                    'user_id' => $userId,
                    'reason' => '用户数据不存在或阶段1未完成'
                ]);
                return false;
            }
        }
    }

}