kknongchang_2506/app/Module/Task/Logics/TaskLogic.php

<?php

namespace App\Module\Task\Logics;

use App\Module\Task\Enums\TASK_STATUS;
use App\Module\Task\Events\TaskRewardClaimedEvent;
use App\Module\Task\Models\Task;
use App\Module\Task\Models\TaskRewardLog;
use App\Module\Task\Models\TaskUserTask;
use App\Module\Task\Services\TaskRewardGroupService;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * 任务逻辑类
 * 
 * 处理任务相关的业务逻辑，包括任务奖励的发放等
 */
class TaskLogic
{
    /**
     * 领取任务奖励
     *
     * @param int $userId 用户ID
     * @param int $taskId 任务ID
     * @return array 领取结果
     */
    public function claimTaskReward(int $userId, int $taskId): array
    {
        try {
            // 开始事务
            DB::beginTransaction();
            
            // 获取用户任务
            $userTask = TaskUserTask::where('user_id', $userId)
                ->where('task_id', $taskId)
                ->first();
                
            if (!$userTask) {
                throw new \Exception('未接取该任务');
            }
            
            // 检查任务状态
            if ($userTask->status !== TASK_STATUS::COMPLETED->value) {
                throw new \Exception('任务未完成，不能领取奖励');
            }
            
            if ($userTask->status === TASK_STATUS::REWARDED->value) {
                throw new \Exception('已领取过奖励');
            }
            
            // 获取任务信息
            $task = Task::find($taskId);
            if (!$task) {
                throw new \Exception('任务不存在');
            }
            
            // 使用奖励组服务发放奖励
            $result = TaskRewardGroupService::distributeRewards(
                $userId, 
                $taskId, 
                $userTask->id
            );
            
            if (!$result['success']) {
                throw new \Exception($result['message'] ?? '奖励发放失败');
            }
            
            // 更新任务状态
            $userTask->status = TASK_STATUS::REWARDED->value;
            $userTask->rewarded_at = Carbon::now();
            $userTask->save();
            
            // 触发奖励领取事件
            event(new TaskRewardClaimedEvent(
                $userId,
                $taskId,
                $task->name,
                $result['rewards'] ?? [],
                $userTask->rewarded_at,
                true
            ));
            
            // 提交事务
            DB::commit();
            
            return [
                'success' => true,
                'message' => '奖励领取成功',
                'rewards' => $result['rewards'] ?? [],
            ];
        } catch (\Exception $e) {
            // 回滚事务
            DB::rollBack();
            
            Log::error('任务奖励领取失败', [
                'user_id' => $userId,
                'task_id' => $taskId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);
            
            return [
                'success' => false,
                'message' => $e->getMessage(),
            ];
        }
    }
    
    /**
     * 获取任务奖励信息
     *
     * @param int $taskId 任务ID
     * @return array 奖励信息
     */
    public function getTaskRewardInfo(int $taskId): array
    {
        try {
            // 获取任务信息
            $task = Task::find($taskId);
            if (!$task) {
                return [
                    'success' => false,
                    'message' => '任务不存在',
                    'rewards' => []
                ];
            }
            
            // 使用奖励组服务获取奖励信息
            $rewards = TaskRewardGroupService::getTaskRewards($taskId);
            
            return [
                'success' => true,
                'message' => '获取奖励信息成功',
                'rewards' => $rewards
            ];
        } catch (\Exception $e) {
            Log::error('获取任务奖励信息失败', [
                'task_id' => $taskId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);
            
            return [
                'success' => false,
                'message' => $e->getMessage(),
                'rewards' => []
            ];
        }
    }
    
    /**
     * 迁移任务奖励到奖励组
     *
     * @param int $taskId 任务ID
     * @return array 迁移结果
     */
    public function migrateTaskReward(int $taskId): array
    {
        return TaskRewardGroupService::migrateTaskRewardsToRewardGroup($taskId);
    }
}