package com.rongyichuang.message.service;

import com.rongyichuang.message.entity.Message;
import com.rongyichuang.message.entity.MessageType;
import com.rongyichuang.message.repository.MessageRepository;
import com.rongyichuang.player.entity.Player;
import com.rongyichuang.player.repository.PlayerRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.Optional;

/**
 * 消息服务类
 */
@Service
public class MessageService {
    
    private static final Logger log = LoggerFactory.getLogger(MessageService.class);
    
    @Autowired
    private MessageRepository messageRepository;
    
    @Autowired
    private PlayerRepository playerRepository;
    

    
    /**
     * 创建审核通过消息
     */
    @Transactional
    public void createApprovalMessage(Long targetId, Long playerId, String projectName) {
        Long userId = getUserIdByPlayerId(playerId);
        if (userId == null) {
            log.error("无法获取选手对应的用户ID，选手ID: {}", playerId);
            return;
        }
        
        Message message = new Message();
        message.setTargetType(MessageType.REVIEW_APPROVED.getValue());
        message.setTargetId(targetId);
        message.setPlayerId(playerId);
        message.setUserId(userId);
        message.setContent(projectName + " 审核通过");
        message.setState(1); // 有效状态
        message.setWxMsgSuccess(false); // 默认未发送微信消息
        message.setWxMsgErrCount(0); // 默认错误次数为0
        
        messageRepository.save(message);
        log.info("创建审核通过消息成功，targetId: {}, playerId: {}, userId: {}", targetId, playerId, userId);
    }
    
    /**
     * 创建审核驳回消息
     */
    @Transactional
    public void createRejectionMessage(Long targetId, Long playerId, String projectName) {
        Long userId = getUserIdByPlayerId(playerId);
        if (userId == null) {
            log.error("无法获取选手对应的用户ID，选手ID: {}", playerId);
            return;
        }
        
        Message message = new Message();
        message.setTargetType(MessageType.REVIEW_REJECTED.getValue());
        message.setTargetId(targetId);
        message.setPlayerId(playerId);
        message.setUserId(userId);
        message.setContent(projectName + " 审核不通过");
        message.setState(1); // 有效状态
        message.setWxMsgSuccess(false); // 默认未发送微信消息
        message.setWxMsgErrCount(0); // 默认错误次数为0
        
        messageRepository.save(message);
        log.info("创建审核驳回消息成功，targetId: {}, playerId: {}, userId: {}", targetId, playerId, userId);
    }
    
    /**
     * 创建晋级消息
     */
    @Transactional
    public void createPromotionMessage(Long targetId, Long playerId, String projectName) {
        Long userId = getUserIdByPlayerId(playerId);
        if (userId == null) {
            log.error("无法获取选手对应的用户ID，选手ID: {}", playerId);
            return;
        }
        
        Message message = new Message();
        message.setTargetType(MessageType.COMPETITION_PROMOTED.getValue());
        message.setTargetId(targetId);
        message.setPlayerId(playerId);
        message.setUserId(userId);
        message.setContent(projectName + " 比赛晋级");
        message.setState(1); // 有效状态
        message.setWxMsgSuccess(false); // 默认未发送微信消息
        message.setWxMsgErrCount(0); // 默认错误次数为0
        
        messageRepository.save(message);
        log.info("创建晋级消息成功，targetId: {}, playerId: {}, userId: {}", targetId, playerId, userId);
    }
    
    /**
     * 通过选手ID获取对应的用户ID
     */
    private Long getUserIdByPlayerId(Long playerId) {
        try {
            Optional<Player> playerOpt = playerRepository.findById(playerId);
            if (playerOpt.isPresent()) {
                Player player = playerOpt.get();
                return player.getUserId();
            } else {
                log.warn("未找到选手记录，选手ID: {}", playerId);
                return null;
            }
        } catch (Exception e) {
            log.error("查询选手记录时发生异常，选手ID: {}", playerId, e);
            return null;
        }
    }

    /**
     * 根据用户ID获取消息列表，按时间倒序
     */
    public List<Message> getMessagesByUserId(Long userId) {
        log.info("Getting messages for user ID: {}", userId);
        return messageRepository.findByUserIdOrderByCreateTimeDesc(userId);
    }


}