package com.rongyichuang.player.service;

import com.rongyichuang.player.dto.response.*;
import com.rongyichuang.rating.dto.response.RatingItemResponse;
import com.rongyichuang.rating.entity.RatingScheme;
import com.rongyichuang.rating.repository.RatingSchemeRepository;
import com.rongyichuang.common.entity.Media;
import com.rongyichuang.common.repository.MediaRepository;
import jakarta.persistence.EntityManager;
import jakarta.persistence.PersistenceContext;
import org.springframework.stereotype.Service;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;
import java.util.ArrayList;
import java.util.stream.Collectors;

/**
 * 比赛报名详情服务（用于评分页面）
 */
@Service
public class ActivityPlayerDetailService {

    private static final Logger log = LoggerFactory.getLogger(ActivityPlayerDetailService.class);

    @PersistenceContext
    private EntityManager em;

    private final MediaRepository mediaRepository;
    private final RatingSchemeRepository ratingSchemeRepository;

    public ActivityPlayerDetailService(MediaRepository mediaRepository, 
                                     RatingSchemeRepository ratingSchemeRepository) {
        this.mediaRepository = mediaRepository;
        this.ratingSchemeRepository = ratingSchemeRepository;
    }

    /**
     * 获取比赛报名详情（用于评分）
     * @param activityPlayerId 报名记录ID
     * @return 报名详情
     */
    public ActivityPlayerDetailResponse getDetailForRating(Long activityPlayerId) {
        log.info("获取报名详情用于评分，activityPlayerId: {}", activityPlayerId);

        // 查询基本信息
        String sql = """
            SELECT ap.id, ap.description, ap.activity_id,
                   p.id as player_id, p.name as player_name, p.phone, p.description as player_desc,
                   a.name as activity_name, a.rating_scheme_id
            FROM t_avtivity_player ap
            JOIN t_player p ON p.id = ap.player_id
            JOIN t_activity a ON a.id = ap.activity_id
            WHERE ap.id = ?
            """;

        @SuppressWarnings("unchecked")
        List<Object[]> results = em.createNativeQuery(sql)
                .setParameter(1, activityPlayerId)
                .getResultList();

        if (results.isEmpty()) {
            log.warn("未找到报名记录，activityPlayerId: {}", activityPlayerId);
            return null;
        }

        Object[] row = results.get(0);
        ActivityPlayerDetailResponse response = new ActivityPlayerDetailResponse();
        response.setId(activityPlayerId);
        response.setDescription(row[1] != null ? row[1].toString() : "");
        response.setActivityName(row[7] != null ? row[7].toString() : "");

        // 构建学员信息
        PlayerInfoResponse playerInfo = new PlayerInfoResponse();
        playerInfo.setId(row[3] != null ? Long.valueOf(row[3].toString()) : null);
        playerInfo.setName(row[4] != null ? row[4].toString() : "");
        playerInfo.setPhone(row[5] != null ? row[5].toString() : "");
        playerInfo.setDescription(row[6] != null ? row[6].toString() : "");

        // 查询学员头像（target_type=5）
        if (playerInfo.getId() != null) {
            List<Media> avatarMedias = mediaRepository.findByTargetTypeAndTargetIdAndState(5, playerInfo.getId(), 1);
            if (!avatarMedias.isEmpty()) {
                Media avatar = avatarMedias.get(0);
                String avatarUrl = avatar.getPath();
                playerInfo.setAvatarUrl(avatarUrl);
                log.info("找到学员头像: {}", avatarUrl);
            }
        }
        response.setPlayerInfo(playerInfo);

        // 查询提交的资料（target_type=4）
        List<Media> submissionMedias = mediaRepository.findByTargetTypeAndTargetIdAndState(4, activityPlayerId, 1);
        List<SubmissionMediaResponse> submissionFiles = submissionMedias.stream()
                .map(this::convertToSubmissionMedia)
                .collect(Collectors.toList());
        response.setSubmissionFiles(submissionFiles);
        log.info("找到提交资料 {} 个", submissionFiles.size());

        // 查询评分模板
        Long ratingSchemeId = row[8] != null ? Long.valueOf(row[8].toString()) : null;
        if (ratingSchemeId != null) {
            RatingFormResponse ratingForm = buildRatingForm(ratingSchemeId);
            response.setRatingForm(ratingForm);
        }

        return response;
    }

    /**
     * 转换媒体文件为提交资料响应
     */
    private SubmissionMediaResponse convertToSubmissionMedia(Media media) {
        SubmissionMediaResponse response = new SubmissionMediaResponse();
        response.setId(media.getId());
        response.setName(media.getName());
        response.setUrl(media.getPath());
        response.setFileExt(media.getFileExt());
        response.setFileSize(media.getFileSize() != null ? media.getFileSize().longValue() : null);
        response.setMediaType(media.getMediaType());
        return response;
    }

    /**
     * 构建评分表单
     */
    private RatingFormResponse buildRatingForm(Long ratingSchemeId) {
        log.info("构建评分表单，ratingSchemeId: {}", ratingSchemeId);

        RatingScheme scheme = ratingSchemeRepository.findById(ratingSchemeId).orElse(null);
        if (scheme == null) {
            log.warn("未找到评分模板，ratingSchemeId: {}", ratingSchemeId);
            return null;
        }

        RatingFormResponse response = new RatingFormResponse();
        response.setSchemeId(scheme.getId());
        response.setSchemeName(scheme.getName());
        response.setTotalMaxScore(scheme.getTotalScore());

        // 转换评分项目
        if (scheme.getItems() != null) {
            List<RatingItemResponse> items = scheme.getItems().stream()
                    .map(RatingItemResponse::new)
                    .collect(Collectors.toList());
            response.setItems(items);
        }

        log.info("评分模板构建完成，包含 {} 个评分项目", 
                response.getItems() != null ? response.getItems().size() : 0);

        return response;
    }
}