kknongchang_2506/app/Module/Activity/Services/ActivityService.php

<?php

namespace App\Module\Activity\Services;

use App\Module\Activity\Dtos\ActivityConfigDto;
use App\Module\Activity\Dtos\ActivityParticipationDto;
use App\Module\Activity\Dtos\UserActivityDataDto;
use App\Module\Activity\Logics\ActivityLogic;
use App\Module\Activity\Logics\ParticipationLogic;
use App\Module\Activity\Logics\ProgressLogic;
use App\Module\Activity\Logics\RewardLogic;
use Exception;
use Illuminate\Support\Facades\Log;
use UCore\Helper\Logger;

/**
 * 活动服务类
 */
class ActivityService
{
    /**
     * 获取活动详情
     *
     * @param int $activityId 活动ID
     * @param bool $withConditions 是否包含条件
     * @return ActivityConfigDto|null
     */
    public static function getActivityDetail(int $activityId, bool $withConditions = false): ?ActivityConfigDto
    {
        try {
            $activityLogic = new ActivityLogic();
            return $activityLogic->getActivityDetail($activityId, $withConditions);
        } catch (Exception $e) {
            Logger::error('获取活动详情失败', [
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);
            return null;
        }
    }

    /**
     * 获取用户可参与的活动列表
     *
     * @param int $userId 用户ID
     * @return array
     */
    public static function getUserAvailableActivities(int $userId): array
    {
        try {
            $activityLogic = new ActivityLogic();
            return $activityLogic->getUserAvailableActivities($userId);
        } catch (Exception $e) {
            Logger::error('获取用户可参与活动列表失败', [
                'user_id' => $userId,
                'error' => $e->getMessage()
            ]);
            return [];
        }
    }

    /**
     * 参与活动
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @return array
     */
    public static function participateActivity(int $userId, int $activityId): array
    {
        try {
            $activityLogic = new ActivityLogic();
            $participation = $activityLogic->participateActivity($userId, $activityId);

            return [
                'success' => true,
                'message' => '参与活动成功',
                'participation' => $participation
            ];
        } catch (Exception $e) {
            Logger::error('参与活动失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);

            return [
                'success' => false,
                'message' => $e->getMessage()
            ];
        }
    }

    /**
     * 更新活动进度
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @param int $progress 进度值
     * @param array|null $progressData 进度数据
     * @return array
     */
    public static function updateActivityProgress(int $userId, int $activityId, int $progress, ?array $progressData = null): array
    {
        try {
            $activityLogic = new ActivityLogic();
            $result = $activityLogic->updateActivityProgress($userId, $activityId, $progress, $progressData);

            return [
                'success' => $result,
                'message' => $result ? '更新进度成功' : '更新进度失败'
            ];
        } catch (Exception $e) {
            Logger::error('更新活动进度失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'progress' => $progress,
                'error' => $e->getMessage()
            ]);

            return [
                'success' => false,
                'message' => $e->getMessage()
            ];
        }
    }

    /**
     * 增加活动进度
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @param int $increment 增量值
     * @param array|null $progressData 进度数据
     * @return array
     */
    public static function incrementActivityProgress(int $userId, int $activityId, int $increment, ?array $progressData = null): array
    {
        try {
            $progressLogic = new ProgressLogic();
            $participationLogic = new ParticipationLogic();

            // 获取用户参与记录
            $participation = $participationLogic->getUserParticipation($userId, $activityId);

            if (!$participation) {
                return [
                    'success' => false,
                    'message' => '用户未参与此活动'
                ];
            }

            // 获取当前进度
            $userData = $progressLogic->getUserActivityProgress($userId, $activityId);
            $currentProgress = $userData ? $userData->progress : 0;

            // 增加进度
            $newUserData = $progressLogic->incrementUserActivityProgress($userId, $activityId, $increment, $progressData);

            // 更新活动进度
            $activityLogic = new ActivityLogic();
            $activityLogic->updateActivityProgress($userId, $activityId, $newUserData->progress, $newUserData->progressData);

            return [
                'success' => true,
                'message' => '增加进度成功',
                'old_progress' => $currentProgress,
                'new_progress' => $newUserData->progress
            ];
        } catch (Exception $e) {
            Logger::error('增加活动进度失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'increment' => $increment,
                'error' => $e->getMessage()
            ]);

            return [
                'success' => false,
                'message' => $e->getMessage()
            ];
        }
    }

    /**
     * 领取活动奖励
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @return array
     */
    public static function claimActivityReward(int $userId, int $activityId): array
    {
        try {
            $activityLogic = new ActivityLogic();
            $result = $activityLogic->claimActivityReward($userId, $activityId);

            return [
                'success' => $result,
                'message' => $result ? '领取奖励成功' : '领取奖励失败'
            ];
        } catch (Exception $e) {
            Logger::error('领取活动奖励失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);

            return [
                'success' => false,
                'message' => $e->getMessage()
            ];
        }
    }

    /**
     * 获取用户参与记录
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @return ActivityParticipationDto|null
     */
    public static function getUserParticipation(int $userId, int $activityId): ?ActivityParticipationDto
    {
        try {
            $participationLogic = new ParticipationLogic();
            return $participationLogic->getUserParticipation($userId, $activityId);
        } catch (Exception $e) {
            Logger::error('获取用户参与记录失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);
            return null;
        }
    }

    /**
     * 获取用户活动进度
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @return UserActivityDataDto|null
     */
    public static function getUserActivityProgress(int $userId, int $activityId): ?UserActivityDataDto
    {
        try {
            $progressLogic = new ProgressLogic();
            return $progressLogic->getUserActivityProgress($userId, $activityId);
        } catch (Exception $e) {
            Logger::error('获取用户活动进度失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);
            return null;
        }
    }

    /**
     * 检查用户是否可以领取活动奖励
     *
     * @param int $userId 用户ID
     * @param int $activityId 活动ID
     * @return bool
     */
    public static function canClaimReward(int $userId, int $activityId): bool
    {
        try {
            $rewardLogic = new RewardLogic();
            return $rewardLogic->canClaimReward($userId, $activityId);
        } catch (Exception $e) {
            Logger::error('检查用户是否可以领取活动奖励失败', [
                'user_id' => $userId,
                'activity_id' => $activityId,
                'error' => $e->getMessage()
            ]);
            return false;
        }
    }

    /**
     * 获取用户进行中的活动
     *
     * @param int $userId 用户ID
     * @return array
     */
    public static function getUserInProgressActivities(int $userId): array
    {
        try {
            $participationLogic = new ParticipationLogic();
            return $participationLogic->getUserInProgressActivities($userId);
        } catch (Exception $e) {
            Logger::error('获取用户进行中的活动失败', [
                'user_id' => $userId,
                'error' => $e->getMessage()
            ]);
            return [];
        }
    }

    /**
     * 获取用户已完成但未领取奖励的活动
     *
     * @param int $userId 用户ID
     * @return array
     */
    public static function getUserCompletedUnclaimedActivities(int $userId): array
    {
        try {
            $participationLogic = new ParticipationLogic();
            return $participationLogic->getUserCompletedUnclaimedActivities($userId);
        } catch (Exception $e) {
            Logger::error('获取用户已完成但未领取奖励的活动失败', [
                'user_id' => $userId,
                'error' => $e->getMessage()
            ]);
            return [];
        }
    }
}