package com.rongyichuang;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.test.context.ActiveProfiles;

import java.util.List;
import java.util.Map;

@SpringBootTest
@ActiveProfiles("test")
public class CreateJudgeForUser2Test {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Test
    public void createJudgeForUser2() {
        System.out.println("=== 为用户ID=2创建评委记录 ===");
        
        try {
            // 1. 首先检查用户ID=2的基本信息
            String getUserInfoSql = "SELECT id, phone, name FROM t_user WHERE id = 2";
            Map<String, Object> userInfo = jdbcTemplate.queryForMap(getUserInfoSql);
            System.out.println("用户信息: ID=" + userInfo.get("id") + 
                             ", 手机号=" + userInfo.get("phone") + 
                             ", 姓名=" + userInfo.get("name"));
            
            // 2. 检查是否已经有评委记录
            String checkJudgeSql = "SELECT COUNT(*) as count FROM t_judge WHERE user_id = 2";
            Map<String, Object> judgeExists = jdbcTemplate.queryForMap(checkJudgeSql);
            
            if (((Number) judgeExists.get("count")).intValue() > 0) {
                System.out.println("用户ID=2已经有评委记录，无需重复创建");
                return;
            }
            
            // 3. 创建评委记录
            String userName = (String) userInfo.get("name");
            String userPhone = (String) userInfo.get("phone");
            if (userName == null || userName.trim().isEmpty()) {
                userName = "评委_" + userPhone; // 如果没有姓名，使用手机号
            }
            
            // 先查看现有评委记录的字段，复制一个类似的记录
            String copyExistingJudgeSql = "INSERT INTO t_judge (name, user_id, phone, gender, state, description, version, stage_id) " +
                                        "SELECT ?, ?, ?, gender, state, '系统自动创建的评委', 0, stage_id FROM t_judge WHERE id = 65 LIMIT 1";
            int result = jdbcTemplate.update(copyExistingJudgeSql, userName, 2, userPhone);
            
            if (result > 0) {
                System.out.println("✅ 成功为用户ID=2创建评委记录");
                
                // 4. 获取新创建的评委ID
                String getNewJudgeIdSql = "SELECT id, name FROM t_judge WHERE user_id = 2";
                Map<String, Object> newJudge = jdbcTemplate.queryForMap(getNewJudgeIdSql);
                Long judgeId = ((Number) newJudge.get("id")).longValue();
                String judgeName = (String) newJudge.get("name");
                
                System.out.println("新评委信息: ID=" + judgeId + ", 姓名=" + judgeName);
                
                // 5. 查看当前有哪些活动可以分配权限
                String getActivitiesSql = "SELECT id, name, state FROM t_activity WHERE state = 1 ORDER BY id DESC LIMIT 5";
                List<Map<String, Object>> activities = jdbcTemplate.queryForList(getActivitiesSql);
                
                System.out.println("当前可用的活动（最新5个）:");
                for (Map<String, Object> activity : activities) {
                    System.out.println("  活动ID: " + activity.get("id") + 
                                     ", 活动名称: " + activity.get("name") + 
                                     ", 状态: " + activity.get("state"));
                }
                
                // 6. 为评委分配最新活动的权限（假设分配最新的活动）
                if (!activities.isEmpty()) {
                    Map<String, Object> latestActivity = activities.get(0);
                    Long activityId = ((Number) latestActivity.get("id")).longValue();
                    String activityName = (String) latestActivity.get("name");
                    
                    // 检查是否已经有权限
                    String checkPermissionSql = "SELECT COUNT(*) as count FROM t_activity_judge WHERE judge_id = ? AND activity_id = ?";
                    Map<String, Object> permissionExists = jdbcTemplate.queryForMap(checkPermissionSql, judgeId, activityId);
                    
                    if (((Number) permissionExists.get("count")).intValue() == 0) {
                        String insertPermissionSql = "INSERT INTO t_activity_judge (judge_id, activity_id, state, create_time, update_time) VALUES (?, ?, 1, NOW(), NOW())";
                        int permissionResult = jdbcTemplate.update(insertPermissionSql, judgeId, activityId);
                        
                        if (permissionResult > 0) {
                            System.out.println("✅ 成功为评委分配活动权限: " + activityName + " (ID=" + activityId + ")");
                        } else {
                            System.out.println("❌ 分配活动权限失败");
                        }
                    } else {
                        System.out.println("评委已经有该活动的权限");
                    }
                }
                
            } else {
                System.out.println("❌ 创建评委记录失败");
            }
            
        } catch (Exception e) {
            System.out.println("创建评委记录时发生异常: " + e.getMessage());
            e.printStackTrace();
        }
    }
}