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 java.util.List;
import java.util.Map;

@SpringBootTest
public class CheckMediaRecordsTest {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Test
    public void checkMediaRecords() {
        System.out.println("=== 检查数据库表结构 ===");
        
        try {
            // 首先查看所有表
            String showTables = "SHOW TABLES";
            List<Map<String, Object>> tables = jdbcTemplate.queryForList(showTables);
            
            System.out.println("数据库中的表:");
            for (Map<String, Object> table : tables) {
                System.out.println("- " + table.values().iterator().next());
            }
            
            // 检查是否有media相关的表
            System.out.println("\n=== 检查media相关表 ===");
            for (Map<String, Object> table : tables) {
                String tableName = table.values().iterator().next().toString();
                if (tableName.toLowerCase().contains("media")) {
                    System.out.println("找到media相关表: " + tableName);
                    
                    try {
                        // 查看表结构
                        String descTable = "DESC " + tableName;
                        List<Map<String, Object>> columns = jdbcTemplate.queryForList(descTable);
                        System.out.println("表结构:");
                        for (Map<String, Object> column : columns) {
                            System.out.println("  " + column.get("Field") + " - " + column.get("Type"));
                        }
                        
                        // 查看记录数量
                        String countSql = "SELECT COUNT(*) as count FROM " + tableName;
                        Map<String, Object> countResult = jdbcTemplate.queryForMap(countSql);
                        System.out.println("记录数量: " + countResult.get("count"));
                        
                        // 如果有记录，查看最近几条
                        Long count = (Long) countResult.get("count");
                        if (count > 0) {
                            String sampleSql = "SELECT * FROM " + tableName + " ORDER BY id DESC LIMIT 3";
                            List<Map<String, Object>> samples = jdbcTemplate.queryForList(sampleSql);
                            System.out.println("最近3条记录:");
                            for (Map<String, Object> sample : samples) {
                                System.out.println("  " + sample);
                            }
                            
                            // 如果是t_media表，专门查询targetType=5的记录
                            if ("t_media".equals(tableName)) {
                                try {
                                    List<Map<String, Object>> targetType5Records = jdbcTemplate.queryForList(
                                        "SELECT * FROM t_media WHERE target_type = 5 ORDER BY create_time DESC"
                                    );
                                    System.out.println("targetType=5的记录数量: " + targetType5Records.size());
                                    if (!targetType5Records.isEmpty()) {
                                        System.out.println("targetType=5的记录:");
                                        for (Map<String, Object> record : targetType5Records) {
                                            System.out.println("  " + record);
                                        }
                                    } else {
                                        System.out.println("没有找到targetType=5的记录");
                                    }
                                } catch (Exception e) {
                                    System.out.println("查询targetType=5记录失败: " + e.getMessage());
                                }
                            }
                        }
                    } catch (Exception e) {
                        System.out.println("查询表 " + tableName + " 时出错: " + e.getMessage());
                    }
                    System.out.println();
                }
            }
            
            // 查看activity_player相关的表
            System.out.println("=== 检查activity_player相关表 ===");
            for (Map<String, Object> table : tables) {
                String tableName = table.values().iterator().next().toString();
                if (tableName.toLowerCase().contains("activity") && tableName.toLowerCase().contains("player")) {
                    System.out.println("找到activity_player相关表: " + tableName);
                    
                    try {
                        // 查看记录数量
                        String countSql = "SELECT COUNT(*) as count FROM " + tableName;
                        Map<String, Object> countResult = jdbcTemplate.queryForMap(countSql);
                        System.out.println("记录数量: " + countResult.get("count"));
                        
                        // 查看最近几条记录
                        String sampleSql = "SELECT * FROM " + tableName + " ORDER BY id DESC LIMIT 3";
                        List<Map<String, Object>> samples = jdbcTemplate.queryForList(sampleSql);
                        System.out.println("最近3条记录:");
                        for (Map<String, Object> sample : samples) {
                            System.out.println("  " + sample);
                        }
                    } catch (Exception e) {
                        System.out.println("查询表 " + tableName + " 时出错: " + e.getMessage());
                    }
                    System.out.println();
                }
            }
            
        } catch (Exception e) {
            System.out.println("数据库查询出错: " + e.getMessage());
            e.printStackTrace();
        }
    }
}