# bigdataProject

**Repository Path**: kevin-beam/bigdata-project

## Basic Information

- **Project Name**: bigdataProject
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-12-13
- **Last Updated**: 2025-01-02

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 抖音用户数据可视化分析

## 数据来源

https://www.heywhale.com/mw/project/62dea26975127f402e63a9f8
https://www.heywhale.com/mw/project/6711df0d739a15610f8fb74b/dataset
https://www.heywhale.com/mw/dataset/661118b2d37810d31dac577e/file
https://opendata.pku.edu.cn/file.xhtml?fileId=6667&datasetVersionId=587

## 数据集

### 小米su7抖音评论

| ip_label | pl   | pl_count | is_image                                   | user_id | love       | pl_time  |
| -------- | ---- | -------- | ------------------------------------------ | ------- | ---------- | -------- |
| 地区     | 评论 | 评论数量 | 评论图片<br />1 表示包含<br />0 表示不包含 | 用户 id | 评论点赞数 | 评论时间 |

### 抖音网红排行榜

| 抖音号 | 昵称 | 性别 | 个人签名 | 城市 | 生日 | 星座 | 蓝V认证原因 | 粉丝数 | 获赞数 | 视频数 | 采集时间 | 详细数据 |
| ------ | ---- | ---- | -------- | ---- | ---- | ---- | ----------- | ------ | ------ | ------ | -------- | -------- |

### 奥运健儿抖音相关数据

| 达人人名称 | 达人链接 | 达人标签 | 达人类型 | 粉丝数 | 近7日作品数 | 上周总评论数 | 上周总点赞数 | 账号简介 | 认证信息 | 作品数 | 所属ip | 总获赞数 | 近30天新增作品数 | 近30天新增粉丝数 | 近30天互动平均数 | 近30天互动中位数 | 近30天爆文数 |
| ---------- | -------- | -------- | -------- | ------ | ----------- | ------------ | ------------ | -------- | -------- | ------ | ------ | -------- | ---------------- | ---------------- | ---------------- | ---------------- | ------------ |

### 上传原始数据到HDFS

```bash
hdfs dfs -mkdir -p /douyin-data/ods
```

```bash
hdfs dfs -put xiaomisu7.csv /douyin-data/ods
hdfs dfs -put douyindataset.csv /douyin-data/ods
```

### 创建 hive 数据库

```sql
create database douyin;
```

## springboot工程

### 新建工程

![image-20241224170400664](img/image-20241224170400664.png)

![image-20241224170439929](img/image-20241224170439929.png)

### pom.xml

```
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.18</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <groupId>cn.lhz</groupId>
  <artifactId>tour-analysis-hive</artifactId>
  <version>0.0.1</version>
  <name>tour-analysis-hive</name>
  <description>tour-analysis-hive</description>
  <url/>
  <licenses>
    <license/>
  </licenses>
  <developers>
    <developer/>
  </developers>
  <scm>
    <connection/>
    <developerConnection/>
    <tag/>
    <url/>
  </scm>
  <properties>
    <java.version>21</java.version>
    <jdk.version>21</jdk.version>
    <maven.compiler.source>${jdk.version}</maven.compiler.source>
    <maven.compiler.target>${jdk.version}</maven.compiler.target>
    <maven.compiler.compilerVersion>${jdk.version}</maven.compiler.compilerVersion>
    <maven.compiler.encoding>utf-8</maven.compiler.encoding>
    <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <maven.test.failure.ignore>true</maven.test.failure.ignore>
    <maven.test.skip>true</maven.test.skip>
    <commons-io.version>2.17.0</commons-io.version>
    <commons-lang3.version>3.17.0</commons-lang3.version>
    <druid.version>1.2.23</druid.version>
    <dom4j.version>2.1.4</dom4j.version>
    <fastjson.version>2.0.53</fastjson.version>
    <fastjson2.version>2.0.53</fastjson2.version>
    <gson.version>2.11.0</gson.version>
    <generator.version>1.1.2</generator.version>
    <hutool.version>5.8.32</hutool.version>
    <junit5.version>5.11.2</junit5.version>
    <jaxen.version>2.0.0</jaxen.version>
    <jackson.version>2.18.0</jackson.version>
    <layui.version>2.9.18</layui.version>
    <lombok.version>1.18.34</lombok.version>
    <mybatis-plus.version>3.5.9</mybatis-plus.version>
    <mybatis-spring.version>3.0.4</mybatis-spring.version>
    <spring-boot.version>2.7.18</spring-boot.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-thymeleaf</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
      <exclusions>
        <exclusion>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-tomcat</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-boot-starter</artifactId>
      <version>${mybatis-plus.version}</version>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus</artifactId>
      <version>${mybatis-plus.version}</version>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-jsqlparser</artifactId>
      <version>${mybatis-plus.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-configuration-processor</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>cn.hutool</groupId>
      <artifactId>hutool-all</artifactId>
      <version>${hutool.version}</version>
    </dependency>
    <dependency>
      <groupId>com.github.binarywang</groupId>
      <artifactId>java-testdata-generator</artifactId>
      <version>1.1.2</version>
    </dependency>
    <dependency>
      <groupId>org.apache.commons</groupId>
      <artifactId>commons-lang3</artifactId>
      <version>${commons-lang3.version}</version>
    </dependency>
    <dependency>
      <groupId>commons-io</groupId>
      <artifactId>commons-io</artifactId>
      <version>${commons-io.version}</version>
    </dependency>
    <dependency>
      <groupId>com.google.code.gson</groupId>
      <artifactId>gson</artifactId>
      <version>${gson.version}</version>
    </dependency>
    <dependency>
      <groupId>org.webjars</groupId>
      <artifactId>layui</artifactId>
      <version>${layui.version}</version>
    </dependency>

    <!--com.alibaba.druid-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid</artifactId>
      <version>${druid.version}</version>
    </dependency>

    <!--swagger3-->
    <dependency>
      <groupId>io.springfox</groupId>
      <artifactId>springfox-boot-starter</artifactId>
      <version>3.0.0</version>
    </dependency>
    <dependency>
      <groupId>io.springfox</groupId>
      <artifactId>springfox-swagger-ui</artifactId>
      <version>3.0.0</version>
    </dependency>
    <dependency>
      <groupId>com.github.xiaoymin</groupId>
      <artifactId>swagger-bootstrap-ui</artifactId>
      <version>1.9.6</version>
    </dependency>
    <dependency>
      <groupId>com.github.xiaoymin</groupId>
      <artifactId>knife4j-spring-ui</artifactId>
      <version>3.0.3</version>
    </dependency>

    <!-- hive-jdbc -->
    <dependency>
      <groupId>org.apache.hive</groupId>
      <artifactId>hive-jdbc</artifactId>
      <version>3.1.3</version>
      <exclusions>
        <exclusion>
          <groupId>ch.qos.logback</groupId>
          <artifactId>logback-classic</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.apache.logging.log4j</groupId>
          <artifactId>log4j-slf4j-impl</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.eclipse.jetty.orbit</groupId>
          <artifactId>*</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.eclipse.jetty.aggregate</groupId>
          <artifactId>*</artifactId>
        </exclusion>
        <exclusion>
          <groupId>tomcat</groupId>
          <artifactId>*</artifactId>
        </exclusion>
        <exclusion>
          <groupId>javax.servlet</groupId>
          <artifactId>servlet-api</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.mortbay.jetty</groupId>
          <artifactId>*</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>3.13.0</version>
        <configuration>
          <encoding>UTF-8</encoding>
          <source>${jdk.version}</source>
          <target>${jdk.version}</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
        <configuration>
          <excludes>
            <exclude>
              <groupId>org.projectlombok</groupId>
              <artifactId>lombok</artifactId>
            </exclude>
          </excludes>
        </configuration>
      </plugin>
    </plugins>
    <finalName>${project.name}</finalName>
  </build>
  <repositories>
    <repository>
      <id>public</id>
      <name>aliyun nexus</name>
      <url>https://maven.aliyun.com/repository/public</url>
      <releases>
        <enabled>true</enabled>
      </releases>
    </repository>
  </repositories>
  <pluginRepositories>
    <pluginRepository>
      <id>public</id>
      <name>aliyun nexus</name>
      <url>https://maven.aliyun.com/repository/public</url>
      <releases>
        <enabled>true</enabled>
      </releases>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </pluginRepository>
  </pluginRepositories>
</project>

```

### 配置文件

> application.yml

```yml
server:
  port: 8080
  servlet:
    context-path: /api
spring:
  application:
<<<<<<< HEAD
    name: douyin-analysis-hive
  mvc:
    path match:
      matching-strategy: ant_path_matcher
=======
    name: douyin-analysis-presto
>>>>>>> f5a20945be5e93fadca75af3d7977396951ef1e0
  jackson:
    serialization:
      FAIL_ON_EMPTY_BEANS: false
    # json 序列化排除值为 null 的属性
    default-property-inclusion: non_null
    # 配置 Date 类的时间格式，如果不涉及可以不加
    date-format: yyyy-MM-dd HH:mm:ss
    # 配置 Date 类的时区，如果不涉及可以不加
    time-zone: GMT+8
  thymeleaf:
    #缓冲的配置
    cache: false
    check-template: true
    check-template-location: true
    #开启MVC thymeleaf 视图解析
    enabled: true
    #模板的模式，支持 HTML, XML TEXT JAVASCRIPT
    mode: HTML5
    #编码 可不用配置
    encoding: UTF-8
    #配置模板路径，默认是templates，可以不用配置
    prefix: classpath:templates
    # 文件后缀名
    suffix: .html
    #内容类别,可不用配置
    servlet:
      content-type: text/html;charset=utf-8
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
<<<<<<< HEAD
    driver-class-name: org.apache.hive.jdbc.HiveDriver
    url: jdbc:hive2://lihaozhe03:10000/lihaozhe
=======
    driver-class-name: com.facebook.presto.jdbc.PrestoDriver
    url: jdbc:presto://lihaozhe01:8085/hive/douyin-analysis
>>>>>>> f5a20945be5e93fadca75af3d7977396951ef1e0
    username: root
    password:
mybatis-plus:
  # 如果是放在src/main/java目录下 classpath:/com/yourpackage/*/mapper/*Mapper.xml
  # 如果是放在resource目录 classpath:/mapper/*Mapper.xml
  mapper-locations: classpath:mapper/*.xml
  #实体扫描，多个package用逗号或者分号分隔
  type-aliases-package: cn.lhz.dto,cn.lhz.vo
  configuration:
    #配置返回数据库(column下划线命名&&返回java实体是驼峰命名)，自动匹配无需as（没开启这个，SQL需要写as： select user_id as userId）
    map-underscore-to-camel-case: true
    cache-enabled: false
    #配置JdbcTypeForNull, oracle数据库必须配置
    jdbc-type-for-null: 'null'
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
#是否激活 swagger true or false
springfox:
  documentation:
    enabled: true

```

### 工具类

#### util 包下的工具类

#### MybatisPlus配置类

```java
package cn.lhz.config;

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/**
 * @author 
 * @version 
 */
@Configuration
public class MybatisPlusConfig {
  @Bean
  public MybatisPlusInterceptor mybatisPlusInterceptor() {
    MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    // 于 v3.5.9 起，PaginationInnerInterceptor 已分离出来。如需使用，则需单独引入 mybatis-plus-jsqlparser 依赖
    interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.PRESTO));
    return interceptor;
  }
}

```

#### 全局异常处理

```java
package cn.lhz.config;

import cn.lhz.util.response.ResponseResult;
import cn.lhz.util.response.ResultCode;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;

/**
 * 全局异常处理
 *
 * @author 
 * @version 
 */
@ControllerAdvice
@RestControllerAdvice
public class GlobalException {
  @ExceptionHandler(Exception.class)
  public ResponseResult<String> defaultErrorHandler(Exception e) {
    return new ResponseResult<>(ResultCode.EXCEPTION.getCode(), e.getMessage());
  }
}

```

### idea连接hive

#### 添加驱动

![image-20241224170849300](img/image-20241224170849300-17350314591971.png)

#### 配置数据源

![image-20241224170816448](img/image-20241224170816448.png)

##  ODS

**hive 创建抖音用户数据分析库**

```
-- 创建抖音用户数据分析库
drop database if exists douyin_analysis cascade;
create database if not exists douyin_analysis;
use douyin_analysis;
```

### hive创建小米su7数据表

```
use douyin_analysis;
-- ODS层创建小米su7数据表
drop table if exists douyin_analysis.ods_xiaomisu7;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.ods_xiaomisu7
(
  ip_label    STRING COMMENT '地区',
  pl          STRING COMMENT '评论',
  pl_count    INT COMMENT '评论数量',
  is_image    INT COMMENT '评论图片 1 表示包含 0 表示不包含',
  user_id     STRING COMMENT '用户 id',
  love        INT COMMENT '评论点赞数',
  pl_time     STRING COMMENT '评论时间'
) COMMENT '小米su7抖音评论'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
		LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/1-ODS/xiaomisu7';
    
    
  -- 加载本地数据到数据表
  load data local inpath '/root/data/xiaomisu7.csv' overwrite into table douyin_analysis.ods_xiaomisu7;
  
  -- 查询数据
  select * from ods_xiaomisu7;
  select count(*) as total from ods_xiaomisu7;
```

### hive创建抖音网红排行榜

```
use douyin_analysis;
--ODS创建抖音网红排行表
drop table if exists douyin_analysis.ods_douiynwanghong;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.ods_douyinwanghong
( 
    id STRING COMMENT '抖音号',
    name STRING COMMENT '昵称',
    gender STRING COMMENT '性别',
    signature STRING COMMENT '个人签名',
    city STRING COMMENT '城市',
    birthday STRING COMMENT '生日',
    constellation STRING COMMENT '星座',
    Blue_V STRING COMMENT '蓝v认证原因',
    number_fans STRING COMMENT '粉丝数',
    number_likes INT COMMENT '获赞数',
    number_videos STRING COMMENT '视频数',
    is_time STRING COMMENT '采集时间',
    data STRING COMMENT '详细数据'
   
) COMMENT '抖音网红排行表'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        COLLECTION ITEMS TERMINATED BY '.'
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/1-ODS/douyinwanghong';

-- 加载本地数据到数据表
load data local inpath '/root/data/douyinwanghong.csv' overwrite into table douyin_analysis.ods_douyinwanghong;

-- 查询数据
select * from douyin_analysis.ods_douyinwanghong;
select count(*) from douyin_analysis.ods_douyinwanghong;
```

### hive创建奥运健儿抖音相关数据

```
use douyin_analysis;
-- 创建奥运健儿抖音数据表
drop table if exists douyin_analysis.ods_aoyun;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.ods_aoyun
( 
    i_name STRING COMMENT '达人名称',
    i_link STRING COMMENT '达人链接',
    i_type STRING COMMENT '标签类型',
    f_type STRING COMMENT '粉丝类型',
    f_number_last_week STRING COMMENT '近7日粉丝数',
    f_number_week STRING COMMENT '周总粉丝数',
    f_comments_week STRING COMMENT '周总评价数',
    f_likes_week STRING COMMENT '周总点赞数',
    profile STRING COMMENT '简介',
    certification STRING COMMENT '认证信息',
    works STRING COMMENT '作品信息',
    ip STRING COMMENT '所属IP',
    f_number_last_month STRING COMMENT '近30日新增粉丝数',
    f_likes_last_month STRING COMMENT '近30日新增点赞数',
    f_comments_last_month STRING COMMENT '近30日新增评论数',
    interaction FLOAT COMMENT '互动指数',
    balance STRING COMMENT '粉丝均衡度',
    chinese_works STRING COMMENT '中文作品数'
   
) COMMENT '奥运健儿抖音数据表'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        COLLECTION ITEMS TERMINATED BY '.'
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/1-ODS/aoyun';

-- 加载本地数据到数据表
load data local inpath '/root/data/aoyun.csv' overwrite into table douyin_analysis.ods_aoyun;

-- 查询数据
select * from douyin_analysis.ods_aoyun;
select count(*) from douyin_analysis.ods_aoyun;
```

## DWD

### hive创建小米su7数据表格

```
drop table if exists douyin_analysis.dwd_xiaomisu7;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwd_xiaomisu7
(
  ip_label    STRING COMMENT '地区',
  pl          STRING COMMENT '评论',
  pl_count    INT COMMENT '评论数量',
  is_image    INT COMMENT '评论图片 1 表示包含 0 表示不包含',
  user_id     STRING COMMENT '用户 id',
  love        INT COMMENT '评论点赞数',
  pl_time     STRING COMMENT '评论时间'
) COMMENT '小米su7抖音评论'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
		LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/2-DWD/xiaomisu7';
    
    

-- ETL 处理 ODS层空数据
insert overwrite table douyin_analysis.dwd_xiaomisu7
select 
    coalesce(ip_label, 'unknown') as ip_label,
    coalesce(pl, '') as pl,
    coalesce(pl_count, 0) as pl_count,
    coalesce(is_image, 0) as is_image,
    coalesce(user_id, 'unknown') as user_id,
    coalesce(love, 0) as love,
    coalesce(pl_time, 'unknown') as pl_time
from douyin_analysis.ods_xiaomisu7
where ip_label is not null
  and pl is not null
  and pl_count is not null
  and is_image is not null
  and user_id is not null
  and love is not null
  and pl_time is not null;
```

### hive创建抖音网红排行表

```
--创建DWD层抖音网红排行表
drop table if exists douyin_analysis.dwd_douyinwanghong;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwd_douyinwanghong
(
id              STRING COMMENT '抖音号',
name            STRING COMMENT '昵称',
gender          STRING COMMENT '性别',
signature       STRING COMMENT '个人签名',
city            STRING COMMENT '城市',
birthday        STRING COMMENT '生日',
constellation   STRING COMMENT '星座',
Blue_V          STRING COMMENT '蓝v认证原因',
number_fans     STRING COMMENT '粉丝数',
number_likes    INT COMMENT '获赞数',
number_videos   STRING COMMENT '视频数',
is_time            STRING COMMENT '采集时间',
data            STRING COMMENT '详细数据'
   
) COMMENT '抖音网红排行表'
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
		LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/2-DWD/douyinwanghong';
    
    

-- ETL 处理 ODS层空数据
insert overwrite table douyin_analysis.dwd_douyinwanghong
select 
    coalesce(id, 'unknown') as id,
    coalesce(name, '') as name,
    coalesce(gender, 'unknown') as gender,
    coalesce(signature, '') as signature,
    coalesce(city, 'unknown') as city,
    coalesce(birthday, 'unknown') as birthday,
    coalesce(constellation, 'unknown') as constellation,
    coalesce(Blue_V, '') as Blue_V,
    coalesce(number_fans, '0') as number_fans,
    coalesce(number_likes, 0) as number_likes,
    coalesce(number_videos, '0') as number_videos,
    coalesce(is_time, 'unknown') as is_time,
    coalesce(data, '') as data
from douyin_analysis.ods_douyinwanghong
where id is not null
  and name is not null
  and gender is not null
  and signature is not null
  and city is not null
  and birthday is not null
  and constellation is not null
  and Blue_V is not null
  and number_fans is not null
  and number_likes is not null
  and number_videos is not null
  and is_time is not null
  and data is not null;
```

### hive创建奥运健儿抖音相关数据

```
--创建DWD层奥运健儿抖音数据表
drop table if exists douyin_analysis.dwd_aoyun;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwd_aoyun
(
i_name               STRING COMMENT '达人名称',
i_link               STRING COMMENT '达人链接',
i_type               STRING COMMENT '标签类型',
f_type               STRING COMMENT '粉丝类型',
f_number_last_week   STRING COMMENT '粉丝数',
f_number_week        STRING COMMENT '周总粉丝数',
f_comments_week      STRING COMMENT '周总评价数',
f_likes_week         STRING COMMENT '周总点赞数',
profile              STRING COMMENT '简介',
certification        STRING COMMENT '认证信息',
works                STRING COMMENT '作品信息',
ip                   STRING COMMENT '所属IP',
f_number_last_month  STRING COMMENT '近30日新增粉丝数',
f_likes_last_month   STRING COMMENT '近30日新增点赞数',
f_comments_last_month STRING COMMENT '近30日新增评论数',
interaction          FLOAT COMMENT '互动指数',
balance              STRING COMMENT '粉丝均衡度',
chinese_works        STRING COMMENT '中文作品数'
   
) COMMENT '奥运健儿抖音数据表'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        COLLECTION ITEMS TERMINATED BY '.'
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/1-ODS/douyindataset';
    
    

-- ETL 处理 ODS层空数据
-- 插入数据到目标表，进行ETL处理
insert overwrite table douyin_analysis.dwd_aoyun
select
    coalesce(i_name, 'unknown') AS i_name,
    coalesce(i_link, '') AS i_link,
    coalesce(i_type, 'unknown') AS i_type,
    coalesce(f_type, 'unknown') AS f_type,
    coalesce(f_number_last_week, '0') AS f_number_last_week,
    coalesce(f_number_week, '0') AS f_number_week,
    coalesce(f_comments_week, 0) AS f_comments_week,
    coalesce(f_likes_week, 0) AS f_likes_week,
    coalesce(profile, '') AS profile,
    coalesce(certification, '') AS certification,
    coalesce(works, '') AS works,
    coalesce(ip, 'unknown') AS ip,
    coalesce(f_number_last_month, '0') AS f_number_last_month,
    coalesce(f_likes_last_month, '0') AS f_likes_last_month,
    coalesce(f_comments_last_month, '0') AS f_comments_last_month,
    coalesce(interaction, 0.0) AS interaction,
    coalesce(balance, 'unknown') AS balance,
    coalesce(chinese_works, '0') AS chinese_works
from douyin_analysis.ods_aoyun
where i_name is not null
    AND i_link is not null
    AND i_type is not null
    AND f_type is not null
    AND f_number_last_week is not null
    AND f_number_week is not null
    AND f_comments_week is not null
    AND f_likes_week is not null
    AND profile is not NULL
    AND certification is not null
    AND works is not null
    AND ip is not null
    AND f_number_last_month is not null
    AND f_likes_last_month is not null
    AND f_comments_last_month is not null
    AND interaction is not null
    AND balance is not null
    AND chinese_works is not null;
```

<<<<<<< HEAD
## DWT

### 1.xiaomusu7评论ip属地

```
DROP TABLE IF EXISTS douyin_analysis.dwt_xiaomisu7_ip_count

CREATE TABLE IF NOT EXISTS douyin_analysis.dwt_xiaomisu7_ip_count
(
  ip_label STRING COMMENT '地区',
  count INT COMMENT '出现次数'
) COMMENT '小米su7抖音评论地区出现次数';

INSERT OVERWRITE TABLE douyin_analysis.dwt_xiaomisu7_ip_count
SELECT
  ip_label,
  COUNT(*) as count
FROM douyin_analysis.dwd_xiaomisu7
GROUP BY ip_label;
```

### 2.奥运健儿相关信息

```
DROP TABLE IF EXISTS douyin_analysis.dwt_aoyun_info
-- 创建DWT层表
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_aoyun_info
(
    i_name STRING COMMENT '达人名称',
    certification STRING COMMENT '认证信息'
) COMMENT '奥运健儿抖音达人名称与认证信息'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/2-DWT/aoyun_info';

-- 插入数据到DWT层表
INSERT OVERWRITE TABLE douyin_analysis.dwt_aoyun_info
SELECT
    i_name,
    certification
FROM douyin_analysis.dwd_aoyun;


-- 如果表存在则删除
DROP TABLE IF EXISTS douyin_analysis.dwt_aoyun_info;

-- 创建DWT层表
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_aoyun_info (
    i_name STRING COMMENT '达人名称',
    certification STRING COMMENT '认证信息',
    ip STRING COMMENT 'IP地址',
    f_number_last_month INT COMMENT '上月粉丝数',
    f_likes_last_month INT COMMENT '上月点赞数'
) COMMENT '奥运健儿抖音达人名称与认证信息'
ROW FORMAT DELIMITED 
FIELDS TERMINATED BY ','
LINES TERMINATED BY '\n'
LOCATION '/douyin_analysis/2-DWT/aoyun_info';

-- 插入数据到DWT层表
INSERT OVERWRITE TABLE douyin_analysis.dwt_aoyun_info
SELECT
    i_name,
    certification,
    ip,
    f_number_last_month,
    f_likes_last_month
FROM douyin_analysis.dwd_aoyun;
```

### 3.奥运健儿粉丝数

```
-- 创建 DWT 层奥运健儿抖音数据表
drop table if exists douyin_analysis.dwt_aoyun;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_aoyun
(
    i_name               STRING COMMENT '达人名称',
    total_f_number_last_week  BIGINT COMMENT '按达人名称汇总的上周粉丝总数'
) COMMENT '奥运健儿抖音 DWT 层汇总表'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        COLLECTION ITEMS TERMINATED BY '.'
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/2-DWT/douyindataset';

-- ETL 处理，从 DWD 层插入数据到 DWT 层
insert overwrite table douyin_analysis.dwt_aoyun
select
    i_name,
    sum(f_number_last_week) as total_f_number_last_week
from douyin_analysis.dwd_aoyun
group by i_name;
```

### 4.抖音网红性别,星座分布

```
-- 创建DWT层抖音网红部分信息表
drop table if exists douyin_analysis.dwt_douyinwanghong_partial;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_douyinwanghong_partial
(
name            STRING COMMENT '昵称',
gender          STRING COMMENT '性别',
constellation   STRING COMMENT '星座'
) COMMENT '抖音网红部分信息表'
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        LINES TERMINATED BY '\n'
LOCATION '/douyin_analysis/3-DWT/douyinwanghong_partial';

-- ETL处理，从DWD层表中筛选数据并插入DWT层表
insert overwrite table douyin_analysis.dwt_douyinwanghong_partial
select 
    coalesce(name, '') as name,
    coalesce(gender, 'unknown') as gender,
    coalesce(constellation, 'unknown') as constellation
from douyin_analysis.dwd_douyinwanghong;
```

### 5.抖音网红性别数量表

```
-- 创建DWT层抖音网红性别数量表
drop table if exists douyin_analysis.dwt_douyinwanghong_gender_count;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_douyinwanghong_gender_count
(
    gender          STRING COMMENT '性别',
    count           INT COMMENT '该性别网红数量'
) COMMENT '抖音网红性别数量表'
    ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        LINES TERMINATED BY '\n'
    LOCATION '/douyin_analysis/3-DWT/douyinwanghong_gender_count';

-- ETL处理，从dwt_douyinwanghong_partial表中统计不同性别数量并插入dwt_douyinwanghong_gender_count表
insert overwrite table douyin_analysis.dwt_douyinwanghong_gender_count
select
    gender,
    count(*) as count
from douyin_analysis.dwt_douyinwanghong_partial
group by gender;
```

### 6.抖音网红星座数量表

```
-- 创建DWT层抖音网红星座数量表
drop table if exists douyin_analysis.dwt_douyinwanghong_constellation_count;
CREATE EXTERNAL TABLE IF NOT EXISTS douyin_analysis.dwt_douyinwanghong_constellation_count
(
constellation   STRING COMMENT '星座',
count           INT COMMENT '该星座网红数量'
) COMMENT '抖音网红星座数量表'
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
        LINES TERMINATED BY '\n'
LOCATION '/douyin_analysis/3 - DWT/douyinwanghong_constellation_count';
-- ETL处理，从dwt_douyinwanghong_partial表中统计不同星座数量并插入dwt_douyinwanghong_constellation_count表
insert overwrite table douyin_analysis.dwt_douyinwanghong_constellation_count
select 
    constellation,
    count(*) as count
from douyin_analysis.dwt_douyinwanghong_partial
group by constellation;
```

## api数据接口



### 1.xaiomusu7抖音用户评论分布地图
#### dto
```bash
package cn.lhz.dto;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor

public class DwdXiaomisu7 {
    private String i_name;
    private String i_link;
    private String i_type;
    private String f_type;
    private int f_number_last_week;
    private int f_number_week;
    private int f_comments_week;
    private int f_likes_week;
    private String profile;
    private String certification;
    private int works;
    private String ip;
    private int f_number_last_month;
    private int f_likes_last_month;
    private int f_comments_last_month;
    private int interaction;
    private int balance;
    private int chinese_works;

}

```

#### Mapper
```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdXiaomisu7;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface Xiaomisu7Mapper extends BaseMapper<DwdXiaomisu7> {
}
```

#### Service
```bash
package cn.lhz.service;


import cn.lhz.dto.DwdXiaomisu7;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface Xiaomisu7Service extends IService<DwdXiaomisu7> {
}
```

#### Servicelmpl
```bash
package cn.lhz.service.impl;


import cn.lhz.dto.DwdXiaomisu7;
import cn.lhz.mapper.Xiaomisu7Mapper;
import cn.lhz.service.Xiaomisu7Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class Xiaomisu7ServiceImpl extends ServiceImpl<Xiaomisu7Mapper, DwdXiaomisu7> implements Xiaomisu7Service {

}
```

#### Controller
```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/xiaomisu7")
public class Xiaomisu7Controller {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtXiaomisu7Info() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      // 查询dwt_xiaomisu7_ip_count表
      ResultSet res = stmt.executeQuery("SELECT count,ip_label  FROM dwt_xiaomisu7_ip_count ");
      while (res.next()) {
        String ipLabel = res.getString("ip_label");
        // 去除双引号
        if (ipLabel.startsWith("\"") && ipLabel.endsWith("\"")) {
          ipLabel = ipLabel.substring(1, ipLabel.length() - 1);
        }
        // 过滤特定的ip_label值
        if (!"IP未知".equals(ipLabel) &&!"意大利".equals(ipLabel) &&!"美国".equals(ipLabel) &&!"马来西亚".equals(ipLabel)) {
          Map<String, Object> rowMap = new HashMap<>();
          rowMap.put("name", ipLabel);
          // 将value转换为Long类型，确保不带双引号
          Long value = res.getLong("count");
          rowMap.put("value", value);
          resultList.add(rowMap);
        }
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}

```

#### api数据展示

![image-20241229103531012](img/image-20241229103531012.png)

### 2.奥运健儿粉丝数量排行

#### dto

```bash
package cn.lhz.dto;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
public class DwdAoyun {
    private String iName; // 指标名称
    private String iLink; // 指标链接
    private String iType; // 指标类型
    private String fType; // 粉丝类型
    private String fNumberLastWeek; // 上周粉丝数
    private String fNumberWeek; // 本周粉丝数
    private String fCommentsWeek; // 本周评论数
    private String fLikesWeek; // 本周点赞数
    private String profile; // 个人简介
    private String certification; // 认证信息
    private String works; // 作品
    private String ip; // IP地址
    private String fNumberLastMonth; // 上月粉丝数
    private String fLikesLastMonth; // 上月点赞数
    private String fCommentsLastMonth; // 上月评论数
    private Float interaction; // 互动数
    private String balance; // 余额
    private String chineseWorks; // 中文作品
}

```

#### Mapper

```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdAoyun;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface AoyunFansMapper extends BaseMapper<DwdAoyun> {
}
```

#### Service

```bash
package cn.lhz.service;

import cn.lhz.dto.DwdAoyun;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface AoyunFansService extends IService<DwdAoyun> {
}
```

#### Servicelmpl

```bash
package cn.lhz.service.impl;

import cn.lhz.dto.DwdAoyun;
import cn.lhz.mapper.AoyunFansMapper;
import cn.lhz.service.AoyunFansService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class AoyunFansServiceImpl extends ServiceImpl<AoyunFansMapper, DwdAoyun> implements AoyunFansService {

}
```

#### Controller

```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/aoyunfans")
public class AoyunFansController {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtAoyunfans() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      // 查询dwt_aoyun_info表
      ResultSet res = stmt.executeQuery("SELECT i_name, total_f_number_last_week FROM dwt_aoyun_fans");
      while (res.next()) {
        Map<String, Object> rowMap = new HashMap<>();
        rowMap.put("name", res.getString("i_name"));
        rowMap.put("value", res.getString("total_f_number_last_week"));
        resultList.add(rowMap);
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}
```

#### api数据展示

<<<<<<< HEAD
![image-20241229103559982](img/image-20241229103559982.png)

### 3.奥运健儿认证信息

#### dto

```bash
package cn.lhz.dto;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
public class DwdAoyun {
    private String iName; // 指标名称
    private String iLink; // 指标链接
    private String iType; // 指标类型
    private String fType; // 粉丝类型
    private String fNumberLastWeek; // 上周粉丝数
    private String fNumberWeek; // 本周粉丝数
    private String fCommentsWeek; // 本周评论数
    private String fLikesWeek; // 本周点赞数
    private String profile; // 个人简介
    private String certification; // 认证信息
    private String works; // 作品
    private String ip; // IP地址
    private String fNumberLastMonth; // 上月粉丝数
    private String fLikesLastMonth; // 上月点赞数
    private String fCommentsLastMonth; // 上月评论数
    private Float interaction; // 互动数
    private String balance; // 余额
    private String chineseWorks; // 中文作品
}

```

#### Mapper

```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdAoyun;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface AoyunMapper extends BaseMapper<DwdAoyun> {
}
```

#### Service

```bash
package cn.lhz.service;

import cn.lhz.dto.DwdAoyun;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface AoyunService extends IService<DwdAoyun> {
}
```

#### Servicelmpl

```bash
package cn.lhz.service.impl;

import cn.lhz.dto.DwdAoyun;
import cn.lhz.mapper.AoyunMapper;
import cn.lhz.service.AoyunService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class AoyunServiceImpl extends ServiceImpl<AoyunMapper, DwdAoyun> implements AoyunService {

}
```

#### Controller

```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/aoyun")
public class AoyunController {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtAoyunInfo() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      // 查询dwt_aoyun_info表
      ResultSet res = stmt.executeQuery("SELECT i_name, certification,ip,f_number_last_month,f_likes_last_month FROM dwt_aoyun_info");
      while (res.next()) {
        Map<String, Object> rowMap = new HashMap<>();
        rowMap.put("name", res.getString("i_name"));
        rowMap.put("value1", res.getString("certification"));
        rowMap.put("value2", res.getString("ip"));
        rowMap.put("value3", res.getString("f_number_last_month"));
        rowMap.put("value4", res.getString("f_likes_last_month"));
        resultList.add(rowMap);
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}
```

#### api数据展示

![image-20241229103612581](img/image-20241229103612581.png)

### 4.抖音网红性别比例

#### dto

```bash
package cn.lhz.dto;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
public class DwdDouyinwanghong {
    private String id;
    private String name;
    private String gender;
    private String signature;
    private String city;
    private String birthday;
    private String constellation;
    private String blue_v;
    private String number_fans;
    private int number_likes;
    private String number_videos;
    private String is_time;
    private String data;
}

```

#### Mapper

```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface DouyinwanghongMapper extends BaseMapper<DwdDouyinwanghong> {
}
```

#### Service

```bash
package cn.lhz.service;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface DouyinwanghongService extends IService<DwdDouyinwanghong> {
}
```

#### Servicelmpl

```bash
package cn.lhz.service.impl;

import cn.lhz.dto.DwdDouyinwanghong;
import cn.lhz.mapper.DouyinwanghongMapper;
import cn.lhz.service.DouyinwanghongService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class DouyinwanghongServiceImpl extends ServiceImpl<DouyinwanghongMapper, DwdDouyinwanghong> implements DouyinwanghongService {

}
```

#### Controller

```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/douyinwanghonggender")
public class DouyinwanghongGenderController {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtDouyinwanghongGender() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      ResultSet res = stmt.executeQuery("SELECT Gender, count FROM dwt_douyinwanghong_gender_count");
      while (res.next()) {
        String gender = res.getString("Gender");
        // 过滤掉 name 为 "未知" 的值
        if (!gender.equals("未知")) {
          Map<String, Object> rowMap = new HashMap<>();
          rowMap.put("name", gender);
          rowMap.put("value", res.getString("count"));
          resultList.add(rowMap);
        }
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}

```

#### api数据展示

![image-20241229103633504](img/image-20241229103633504.png)

### 5.抖音网红相关信息

#### dto

```bash
package cn.lhz.dto;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
public class DwdDouyinwanghong {
    private String id;
    private String name;
    private String gender;
    private String signature;
    private String city;
    private String birthday;
    private String constellation;
    private String blue_v;
    private String number_fans;
    private int number_likes;
    private String number_videos;
    private String is_time;
    private String data;
}

```

#### Mapper

```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface DouyinwanghongMapper extends BaseMapper<DwdDouyinwanghong> {
}
```

#### Service

```bash
package cn.lhz.service;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface DouyinwanghongService extends IService<DwdDouyinwanghong> {
}
```

#### Servicelmpl

```bash
package cn.lhz.service.impl;

import cn.lhz.dto.DwdDouyinwanghong;
import cn.lhz.mapper.DouyinwanghongMapper;
import cn.lhz.service.DouyinwanghongService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class DouyinwanghongServiceImpl extends ServiceImpl<DouyinwanghongMapper, DwdDouyinwanghong> implements DouyinwanghongService {

}
```

#### Controller

```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/douyinwanghong")
public class DouyinwanghongController {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtDouyinwanghong() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      ResultSet res = stmt.executeQuery("SELECT name, Gender,constellation FROM dwt_douyinwanghong_partial");
      while (res.next()) {
        Map<String, Object> rowMap = new HashMap<>();
        rowMap.put("name", res.getString("name"));
        rowMap.put("value1", res.getString("Gender"));
        rowMap.put("value2", res.getString("constellation"));
        resultList.add(rowMap);
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}
```

#### api数据展示

![image-20241229103646136](img/image-20241229103646136.png)

### 6.抖音网红星座分布

#### dto

```bash
package cn.lhz.dto;


import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;


/**
 * @author 牛枥凯
 * @version 1.0.0 2024/12/27 上午11:26
 */
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
public class DwdDouyinwanghong {
    private String id;
    private String name;
    private String gender;
    private String signature;
    private String city;
    private String birthday;
    private String constellation;
    private String blue_v;
    private String number_fans;
    private int number_likes;
    private String number_videos;
    private String is_time;
    private String data;
}

```

#### Mapper

```bash
package cn.lhz.mapper;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
@Mapper
public interface DouyinwanghongMapper extends BaseMapper<DwdDouyinwanghong> {
}
```

#### Service

```bash
package cn.lhz.service;

import cn.lhz.dto.DwdDouyinwanghong;
import com.baomidou.mybatisplus.extension.service.IService;

/**
 * @author 牛枥凯
 * @version 1.0.0
 */
public interface DouyinwanghongService extends IService<DwdDouyinwanghong> {
}
```

#### Servicelmpl

```bash
package cn.lhz.service.impl;

import cn.lhz.dto.DwdDouyinwanghong;
import cn.lhz.mapper.DouyinwanghongMapper;
import cn.lhz.service.DouyinwanghongService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

@Service
public class DouyinwanghongServiceImpl extends ServiceImpl<DouyinwanghongMapper, DwdDouyinwanghong> implements DouyinwanghongService {

}
```

#### Controller

```bash
package cn.lhz.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/douyinwanghongconstellation")
public class DouyinwanghongConstellationController {

  @GetMapping("/dwtInfo")
  public List<Map<String, Object>> getDwtDouyinwanghongConstellation() {
    List<Map<String, Object>> resultList = new ArrayList<>();
    try {
      // 加载Hive JDBC驱动
      Class.forName("org.apache.hive.jdbc.HiveDriver");
      // 获取连接，需根据实际情况修改URL、用户名和密码
      Connection con = DriverManager.getConnection("jdbc:hive2://lihaozhe03:10000/douyin_analysis", "root", "Lihaozhe!!@@1122");
      Statement stmt = con.createStatement();
      ResultSet res = stmt.executeQuery("SELECT constellation, count FROM dwt_douyinwanghong_constellation_count");
      while (res.next()) {
        String constellation = res.getString("constellation");
        // 过滤掉不需要的值
        if (!constellation.equals("") && !constellation.equals("2018-09-12") && !constellation.equals("未知")) {
          Map<String, Object> rowMap = new HashMap<>();
          rowMap.put("name", constellation);
          rowMap.put("value", res.getString("count"));
          resultList.add(rowMap);
        }
      }
      // 关闭资源
      res.close();
      stmt.close();
      con.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultList;
  }
}

```

#### api数据展示

![image-20241229103659069](img/image-20241229103659069.png)

## 前端框架搭建vue+echarts+datav

### 创建工程

```
=======
### 创建工程

```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
npm create vite@latest
cd douyin-analysis-datav
npm install
npm run dev
```

### 安装项目依赖模块

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
npm install @types/node --save-dev

npm install vue-router@4

npm install animate.css --save
npm install gsap --save

npm install fetch --save
npm install axios --save

npm install pinia

npm install less less-loader -D
npm install sass sass-loader --save-dev
npm install scss scss-loader --save-dev

npm install element-plus --save
npm install -D unplugin-vue-components unplugin-auto-import

npm install echarts echarts-wordcloud --save
npm install @kjgl77/datav-vue3
```

### 配置项目

#### vite.config.ts

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
import {defineConfig} from 'vite'
import vue from '@vitejs/plugin-vue'
import AutoImport from 'unplugin-auto-import/vite'
import Components from 'unplugin-vue-components/vite'
import {ElementPlusResolver} from 'unplugin-vue-components/resolvers'
import { resolve } from 'path'
const base_url:string = 'http://localhost:8080'
// https://vitejs.dev/config/
export default defineConfig({
  plugins: [
    vue(),
    AutoImport({
      resolvers: [ElementPlusResolver()],
    }),
    Components({
      // resolvers: [ElementPlusResolver({importStyle: "sass"})],
      resolvers: [ElementPlusResolver()],
    }),
  ],
  server: {
    host: '0.0.0.0',
    strictPort: true,
    open: false,
    proxy: {
      // 使用 proxy 实例
      '/api': {
        target: base_url,
        changeOrigin: true,
        rewrite: (path) => path.replace(/^\/api/, 'api'),
      },
    }
  },
  resolve:{//路径别名
    alias:{
      '@': resolve(__dirname,'./src')
    }
  },
  css: {
    preprocessorOptions: {
      scss: {
        // additionalData: '@import "./src/styles/scss_variable.scss";'
        additionalData: `@use "./src/styles/scss_variable.scss" as *;`,
      }
    }
  }
})
```

#### app.vue

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
<script setup lang="ts">
import DataV from "./components/DataV.vue";
</script>

<template>
  <data-v/>
</template>

<style scoped>
</style>
```

#### main.ts

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
import {createApp} from 'vue'
// import './style.css'
import './assets/css/commons.css'
import 'animate.css'
import {createPinia} from "pinia"
import App from './App.vue'
import DataVVue3 from '@kjgl77/datav-vue3'
import router from './routers/router.ts'
// import axios from 'axios'
// axios.defaults.headers.common['Authorization'] = 'Bearer ' + localStorage.getItem('token')
// axios.defaults.baseURL = 'http://localhost:8080'
const app = createApp(App)
// 需要注意的是从pinia中解构出来的createPinia是一个函数,挂载前需要先调用执行
// const pinia = createPinia()
// app.use(pinia)
app.use(createPinia())
app.use(DataVVue3)
app.use(router)
app.mount('#app')
```

#### tsconfig.node.json

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
{
  "compilerOptions": {
    "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo",
    "target": "ES2022",
    "lib": ["ES2023"],
    "module": "ESNext",
    "skipLibCheck": true,

    /* Bundler mode */
    "moduleResolution": "Bundler",
    "allowImportingTsExtensions": true,
    "isolatedModules": true,
    "moduleDetection": "force",
    "noEmit": true,

    /* Linting */
    "strict": true,
    "noUnusedLocals": true,
    "noUnusedParameters": true,
    "noFallthroughCasesInSwitch": true,
    "noUncheckedSideEffectImports": true,

    /* 路径别名 */
    "types": ["node"],
    "baseUrl": ".",
    "paths": {
      "@/*": ["src/*"]
    }
  },
  "include": ["vite.config.ts"]
}
```

#### router.ts

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
// 1. 定义路由组件.
// 也可以从其他文件导入
import {createMemoryHistory, createRouter, RouteRecordRaw} from 'vue-router'
import page1 from "../views/page1/IndexView01.vue";
import page2 from "../views/page2/IndexView02.vue";
import page2 from "../views/page2/IndexView03.vue";

// 2. 定义一些路由
const routes: Array<RouteRecordRaw> = [
  {
    name: 'page1',
    path: '/',
    component: page1,
  },
  {
    name: 'page2',
    path: '/page2',
    component: page2,
  },
{
    name: 'page3',
    path: '/page3',
    component: page3,
  },
  // 处理 404
  {path: '/:pathMatch(.*)*', redirect: "/"},
]
// 3. 创建路由实例并传递 `routes` 配置
// 你可以在这里输入更多的配置，但我们在这里
// 暂时保持简单
const router = createRouter({
  // 4. 内部提供了 history 模式的实现。
  // memory 模式。createMemoryHistory
  // hash 模式。createWebHashHistory
  // html5 模式。createWebHistory
  history: createMemoryHistory(),
  routes,
})

export default router
```

#### scss_variable.scss
<<<<<<< HEAD

> src/styles/scss_variable.scss

```
=======
> src/styles/scss_variable.scss
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
html, body {
  width: 100vw;
  height: 100vh;
  margin: 0;
  padding: 0;
}

#app_container {
  margin: 0;
  padding: 0;
  height: 100vh;
  background-color: #1F2327;
  background-image: url('src/assets/img/bg3.png');
  color: #fff;

  #dv-full-screen-container {
    // 全屏容器可在此处设置背景图片
  }
}

.lhz-row, .lhz-col {
  width: 100%;
  height: 100%;
  display: flex;
  flex: 1;
}

.lhz-row {
  flex-direction: row;
  justify-content: space-between;
}

.lhz-col {
  flex-direction: column;
  align-items: center;
}
```

### 公共组件

#### ChartLhz.vue

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
<script setup lang="ts">
import * as echarts from 'echarts';
import 'echarts-wordcloud'
import {onMounted, reactive, ref} from "vue";

const chartLhz = ref();

// const chartLhz = useTemplateRef('chartLhz');
// 接受父组件传递的图表的配置项和数据
const props = defineProps(['chart_option'])
const {chart_option} = props;
// 指定图表的配置项和数据
const option = reactive({});

function chartLhzInit() {
  // 基于准备好的dom，初始化echarts实例
  let LhzChart = echarts.init(chartLhz.value);
  // 指定图表的配置项和数据
  for (const filed in chart_option) {
    // 将父组件中传递过来的对象属性赋值给本地的对象
    option[filed] = chart_option[filed];
  }
  // 使用刚指定的配置项和数据显示图表。
  LhzChart.setOption(option);
  window.addEventListener('resize', () => {
    LhzChart.resize();
  })
}

onMounted(() => {
  // 在挂载阶段 初始化 echarts 实例
  chartLhzInit();
});
</script>

<template>
  <div id="chartLhz" ref="chartLhz"></div>
</template>

<style scoped lang="scss">
#chartLhz {
  width: 100%;
  height: 100%;
}
</style>
```

#### ChartMap.vue

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
<script setup>
import * as echarts from 'echarts';
import {ref, reactive, onMounted} from "vue";
import china_geo from '@/stores/china_full.json'

const chartMap = ref()
const convertData = function (data) {
  let res = [];
  for (let i = 0; i < data.length; i++) {
    let geoCoord = china_geo.features[i].properties;
    if (geoCoord) {
      res.push({
        name: data[i].name,
        value: geoCoord.center.concat(data[i].value)
      });
    }
  }
  return res;
};

// const chartMap = useTemplateRef('chartMap')
function chartMapInit() {
  // 基于准备好的dom，初始化echarts实例
  const myChart = echarts.init(chartMap.value, 'dark');
  // 注入地图数据 GeoJson 注意第一个参数为 china 才会显示 海南岛缩略图 其它名字不会
  echarts.registerMap('china', china_geo);
  // 指定图表的配置项和数据
  const option = reactive({
    title: {
      text: '',
      left: 'center'
    },
    tooltip: {
      trigger: 'item',
      formatter: function (params) {
        // console.log(params);
        return `${params.data.name}：${params.data.value[2]}`
      }
    },
    // 地图配置
    geo: {
      type: 'map',
      // chinaMap 这个参数 为 echarts.registerMap('chinaMap', response); 参数中第一个参数
      // 注意参数为 china 才会显示 海南岛缩略图 其它名字不会
      map: 'china',
      // 是否开启鼠标缩放和平移漫游。默认不开启。如果只想要开启缩放或者平移，可以设置成 'scale' 或者 'move'。设置成 true 为都开启
      roam: true,
      // 图形上的文本标签，可用于说明图形的一些数据信息，比如值，名称等
      label: {
        // 是否显示标签
        show: true
      },
      // 默认缩放比例
      zoom: 1.1,
      // 地图中心点坐标
      // 当前视角的中心点，默认使用原始坐标（经纬度）。如果设置了projection则用投影后的坐标表示。
      // center: [125.3245, 43.886841]

    },
    series: [
      {
        geoIndex: 0,
        type: 'effectScatter',
        // 配置何时显示特效
        // 'render' 绘制完成后显示特效
        // 'emphasis' 高亮（hover）的时候显示特效。
        showEffectOn: 'render',
        // data: [{ name: '北京市', value: [116.405285, 39.904989, 9] }],
        data: convertData(china_province),
        // 使用地理坐标系，通过 geoIndex 指定相应的地理坐标系组件。
        coordinateSystem: 'geo',
        symbolSize: function (param) {
          // console.log(param[2]);
          return param[2] / 2
        },
      },

    ],
    // 是视觉映射组件，用于进行『视觉编码』，也就是将数据映射到视觉元素（视觉通道
    visualMap: {
      min: 0,
      max: 50,
      // 筛选
      calculable: true
    }
  });

  // 使用刚指定的配置项和数据显示图表。
  myChart.setOption(option);
  window.addEventListener('resize', function () {
    myChart.resize();
  });
}

onMounted(() => {
  chartMapInit()
})
</script>

<template>
  <div id="chartMap" ref="chartMap"></div>
</template>

<style scoped lang="scss">
#chartMap {
  width: 100%;
  height: 100%;
}
</style>
```

#### PileUp.vue

<<<<<<< HEAD
```
=======
```bash
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
<script setup lang="ts">
import ChartLhz from "./ChartLhz.vue";
import {computed} from "vue";

const props = defineProps(['chart_option', 'title', 'type', 'dataZoom', 'grid'])
const {chart_option, title, type, dataZoom, grid} = props;
const options = computed(() => {
  let option = {
    // 标题
    title: {
      // 标题内容
      text: '',
      left: 'center',
      top: 10,
      textStyle: {
        // 主标题文字的颜色。
        color: '#FF6060'
      },
    },
    tooltip: {
      trigger: 'axis',
      axisPointer: {
        // Use axis to trigger tooltip
        type: 'shadow' // 'shadow' as default; can also be 'line' or 'shadow'
      }
    },
    legend: {
      top: '30px',
      textStyle: {
        color: '#ffffff',
        fontSize: 16
      }
    },
    grid: grid,
    xAxis: {
      // 坐标轴类型。 category 类目轴
      type: 'category',
      // 数据
      data: [],
      axisLabel: {
        show: true,
        color: '#ffffff',
        fontSize: 16,
        interval: 0
      },
    },
    yAxis: {
      // value 值轴
      type: 'value',
      axisLabel: {
        show: false,
        color: '#ffffff',
        fontSize: 16,
        interval: 0
      },
    },
    // 值轴数据
    series: [],
    dataZoom: dataZoom,
  };
  option.title.text = title;
  option.xAxis.data = chart_option.shift()
  let name_list = chart_option.pop();
  for (let i = 0; i < chart_option.length; i++) {
    option.series.push({
      name: name_list[i],
      type: type,
      smooth: true,
      data: chart_option[i],
    })
  }
  return option;
});
</script>

<template>
  <chart-lhz :chart_option="options" v-if="chart_option"/>
</template>

<style scoped lang="scss">

</style>
```

### 页面布局

#### 主页布局

src/components/DataV.vue

<<<<<<< HEAD
```
=======
```javascript
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
<script setup lang="ts">
import TopHeader from "../views/TopHeader/IndexView.vue";
</script>

<template>
  <div id="app_container">
    <!-- 全屏容器 -->
    <dv-full-screen-container>
      <div class="common-layout">
        <el-container>
          <el-header>
            <top-header/>
          </el-header>
          <el-main>
            <router-view/>
          </el-main>
        </el-container>
      </div>
    </dv-full-screen-container>
  </div>
</template>

<style scoped lang="scss">
@use "@/styles/scss_variable";
//.el-main{
//  padding-top: 50px;
//}
</style>
```

#### 头部标题

src/views/TopHeader/IndexView.vue

<<<<<<< HEAD
```
=======
```javascript
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
script setup lang="ts">
import {ref,reactive} from 'vue'
import {useRouter} from "vue-router";

// 引入路由对象
const router = useRouter();

// 路由列表

// 默认算中页面 index值
const activeIndex = ref('0');
// 点击按钮触发该函数
const handleSelect = (key: string) => {
  const routes = ['page1', 'page2', 'page3'];
  // 路由跳转
  router.push({ name: routes[parseInt(key)] });
  // 更新激活的菜单项
  activeIndex.value = key;
  return { activeIndex, handleSelect };
};




</script>

<template>
  <div id="top-header">
    <img id="title_img" src="@/assets/img/title.png" alt="">
    <div>
      抖音用户数据分析
      <el-menu
          :default-active="activeIndex"
          class="el-menu-demo"
          mode="horizontal"
          background-color=transparent
          text-color="#fff"
          :ellipsis="false"
          @select="handleSelect">
        <el-menu-item index="0">小米su7抖音评论用户分布图</el-menu-item>
        <el-menu-item index="1">奥运健儿相关信息</el-menu-item>
        <el-menu-item index="2">抖音网红相关信息</el-menu-item>
      </el-menu>
    </div>
  </div>
</template>

<style scoped lang="scss">
#top-header {
  text-align: center;

  #title_img {
    width: 100%;
  }

  #title_img + div {
    font-size: 3em;
    position: relative;
    top: -1.8em;
  }
}

.el-menu--horizontal > .el-menu-item:nth-child(2) {
  margin-right: auto;
}

.el-menu {
  position: relative;
  top: -0.8em;
<<<<<<< HEAD
=======
}
</style>
```


## 抖音用户数据分析

![输入图片说明](img/%7BF273C028-5245-40B4-A0B5-A0E5EBC577DA%7D.png)
### 小米su7抖音评论地图展示
> src/views/page1/Chart01.vue
```bash
<script setup lang="ts">
import axios from 'axios';
import * as echarts from 'echarts';
import china_geo from '@/stores/china.json'
import { onMounted, ref } from "vue";

const chartMap = ref()

// 格式化城市名称的函数保持不变
function formatCityName(cityName) {
  const replacements = {
    "上海": "上海市",
    "北京": "北京市",
    "天津": "天津市",
    "广州": "广东省",
    "成都": "四川省",
    "杭州": "浙江省",
    "武汉": "湖北省",
    "济南": "山东省",
    "深圳": "广东省",
    "青岛": "山东省",
    // 可以继续添加更多的替换规则
  };
  return replacements[cityName] || cityName;
}

function initChart(data: { name: string, value: [number, number, number] }[]) {
  // 基于准备好的dom，初始化echarts实例
  const myChart = echarts.init(chartMap.value);
  // 注入地图数据 GeoJson 注意第一个参数为 china 才会显示 海南岛缩略图 其它名字不会
  echarts.registerMap('china', china_geo);
  // 指定图表的配置项和数据
  const option = {
    backgroundColor: 'rgba(0, 0, 0, 0)',
    // backgroundColor: 'transparent',
    title: {
      text: '小米su7抖音用户分布图',
      left: 'center',
      top: '30px',
      textStyle: {
        color: '#fff',
        fontWeight: 'bold',
        fontSize: '30px',
      }
    },
    tooltip: {
      trigger: 'item',
      formatter: function (params) {
        return `${params.data.name}：${params.data.value[2]}`
      },
      backgroundColor: "rgba(0, 0, 0,.6)",
      borderColor: "rgba(147, 235, 248,.8)",
      textStyle: {
        color: "#FFF",
      },
    },
    // 地图配置
    geo: {
      type: 'map',
      // chinaMap 这个参数 为 echarts.registerMap('chinaMap', response); 参数中第一个参数
      // 注意参数为 china 才会显示 海南岛缩略图 其它名字不会
      map: 'china',
      // 是否开启鼠标缩放和平移漫游。默认不开启。如果只想要开启缩放或者平移，可以设置成 'scale' 或者 'move'。设置成 true 为都开启
      roam: true,
      // 图形上的文本标签，可用于说明图形的一些数据信息，比如值，名称等
      label: {
        // 是否显示标签
        show: true
      },
      // 默认缩放比例
      zoom: 1.1,
    },
    series: [
      {
        geoIndex: 0,
        type: 'effectScatter',
        // 配置何时显示特效
        // 'render' 绘制完成后显示特效
        // 'emphasis' 高亮（hover）的时候显示特效。
        showEffectOn: 'render',
        data: data,
        // 使用地理坐标系，通过 geoIndex 指定相应的地理坐标系组件。
        coordinateSystem: 'geo',
        symbolSize: function (param: number[]) {
          return param[2]/4
        },
      },
    ],
    // 是视觉映射组件，用于进行『视觉编码』，也就是将数据映射到视觉元素（视觉通道)
    visualMap: {
      left: 20,
      bottom: 20,
      pieces: [
        { lte: 49, label: "1 - 49个" },
        { gte: 50, lte: 99, label: "50 - 99个" },
        { gte: 100, label: "100及以上" },
      ],
      inRange: {
        // 渐变颜色，从小到大
        color: [
          "#97df1a",
          "#437287",
          "#c87575",
        ],
      },
      textStyle: {
        color: "#fff",
      },
    },
  };
  // 使用刚指定的配置项和数据显示图表。
  myChart.setOption(option, true)
  window.addEventListener('resize', function () {
    myChart.resize();
  });
}

function getData() {
  const mockData = [
    {
      "city": "上海",
      "user_count": 32
    },
    {
      "city": "云南省",
      "user_count": 17
    },
    {
      "city": "内蒙古自治区",
      "user_count": 10
    },
    {
      "city": "北京市",
      "user_count": 11
    },
    {
      "city": "吉林省",
      "user_count": 6
    },
    {
      "city": "四川省",
      "user_count": 57
    },
    {
      "city": "天津市",
      "user_count": 2
    },
    {
      "city": "宁夏回族自治区",
      "user_count": 1
    },
    {
      "city": "安徽省",
      "user_count": 36
    },
    {
      "city": "山东省",
      "user_count": 29
    },
    {
      "city": "山西省",
      "user_count": 10
    },
    {
      "city": "广东省",
      "user_count": 174
    },
    {
      "city": "广西省",
      "user_count": 30
    },
    {
      "city": "新疆维吾尔自治区",
      "user_count": 10
    },
    {
      "city": "江苏省",
      "user_count": 80
    },
    {
      "city": "江西省",
      "user_count": 36
    },
    {
      "city": "河北省",
      "user_count": 26
    },
    {
      "city": "河南省",
      "user_count": 32
    },
    {
      "city": "浙江省",
      "user_count": 67
    },
    {
      "city": "海南省",
      "user_count": 6
    },
    {
      "city": "湖北省",
      "user_count": 167
    },
    {
      "city": "湖南省",
      "user_count": 48
    },
    {
      "city": "甘肃省",
      "user_count": 3
    },
    {
      "city": "福建省",
      "user_count": 23
    },
    {
      "city": "西藏自治区",
      "user_count": 3
    },
    {
      "city": "贵州省",
      "user_count": 18
    },
    {
      "city": "辽宁省",
      "user_count": 11
    },
    {
      "city": "重庆市",
      "user_count": 9
    },
    {
      "city": "陕西省",
      "user_count": 20
    },
    {
      "city": "青海省",
      "user_count": 2
    },
    {
      "city": "黑龙江省",
      "user_count": 3
    }
  ];
  let data: { name: string, value: [number, number, number] }[] = [];
  mockData.forEach((province) => {
    const formattedCityName = formatCityName(province.city);
    const obj = china_geo.features.find(item => item.properties.name === formattedCityName);
    if (obj) {
      const rs: { name: string, value: [number, number, number] } = {
        name: obj.properties.name,
        value: [obj.properties.center[0], obj.properties.center[1], province.user_count]
      };
      data.push(rs);
    } else {
      console.warn(`未找到城市 ${province.city} 对应的地理信息`);
    }
  });
  initChart(data);
}

onMounted(() => {
  getData();
})
</script>

<template>
  <dv-border-box-8 style="text-align: center">
    <div ref="chartMap" id="chartMap"></div>
  </dv-border-box-8>
</template>

<style scoped lang="scss">
#chartMap {
  width: 100%;
  height: 90% }
</style>
```
### 奥运健儿相关信息
![输入图片说明](img/%7B21E1827E-49DD-4F0F-BC85-7D59A1E003BC%7D.png)

#### 奥运健儿认证信息滚屏展示
> src/views/page2/Chart01.vue
```bash
<template xmlns="">
  <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
  <div class="container">
    <!-- 标题部分 -->
    <div class="title">奥运健儿认证信息滚屏展示</div>
    <!-- 相关表格部分 -->
    <div class="dv-scroll-board">
    <!-- 使用 dv-scroll-board 组件来展示滚动表格 -->
    <!-- :config 属性绑定表格配置数据，动态生成表格内容 -->
    <!-- 设置组件样式，使其宽度占满父容器，高度为 370 像素 -->
    <dv-scroll-board
        :config="table"
        style=" height: 370px"
    />
    </div>
  </div>
</template>

<script setup lang="ts">
import { defineProps, ref, onMounted } from 'vue';
import axios from 'axios';

const table = ref({
  columnWidth: 400,
  headerHeight: 30,
  headerBGC: 'rgba(14,183,221,0)',
  oddRowBGC: 'rgba(14,183,221,0)',
  evenRowBGC: 'rgba(14,183,221,0)',
  column: [
    {
      field: "name",
      width: 100, // 明确设置姓名这一列的宽度为100px
    },
    {
      field: "certificationInfo",
      width: 200,
    },
    {
      field: "ipLocation",
      width: 100,
    },
    {
      field: "newFollowers",
      width: 150,
    },
    {
      field: "newLikes",
      width: 150,
    },
  ],
  header: [
    "姓名",
    "认证信息",
    "ip属地",
    "30日内新增粉丝数",
    "30日内点赞数",
  ],
  data: [],
  scrollSpeed: 20,
});

// 定义一个函数来获取数据
async function fetchData() {
  try {
    const response = await axios.get('/api/aoyun/dwtInfo'); // 替换为实际的API接口地址
    const transformedData = response.data.map(item => ({
      name: item.name,
      certificationInfo: item.value1,
      ipLocation: item.value2,
      newFollowers: item.value3,
      newLikes: item.value4,
    }));
    table.value.data = transformedData;
  } catch (error) {
    console.error('获取数据失败:', error);
  }
}

// 在组件挂载时调用fetchData函数
onMounted(() => {
  fetchData();
});
</script>

<style scoped>
/* 整体容器样式，设置为弹性布局，方便垂直排列标题和表格 */
.container {
  display: flex; /* 使用flex布局以便于内容的对齐和分布 */
  flex-direction: column; /* 设置主轴方向为垂直方向，使子元素按列排列 */
  align-items: center; /* 水平居中对齐子元素 */
  height: 100vh; /* 占满屏幕高度，vh为视窗高度单位，100vh等于当前视窗的高度 */
}


/* 标题样式，可根据喜好调整字体、颜色等样式 */
.title {
  font-size: 20px; /* 设置标题字体大小为20像素 */
  font-weight: bold; /* 加粗标题字体 */
  margin-bottom: 10px; /* 在标题下方添加10像素的外边距 */
  width: 100%; /* 确保标题占满宽度 */
  text-align: center; /* 居中显示标题 */
}


/* 表格样式，确保表格占满宽度 */
.dv-scroll-board {
  width: 1200px;
}
</style>
```
#### 奥运健儿粉丝数排行
> src/views/page2/Chart02.vue
```bash
<template>
  <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
  <div class="container">
    <!-- 标题部分 -->
    <div class="title">奥运健儿粉丝数排行</div>
    <!-- 图表容器 -->
    <div ref="chartRef" style="width: 120%; height:350px; position: absolute; left: 50%; transform: translateX(-50%);"></div>
  </div>
</template>

<script setup lang="ts">
import axios from 'axios';
import { onMounted, ref } from 'vue';
import * as echarts from 'echarts';

const chartRef = ref(null);
let myChart = null;

// 从API获取数据
const fetchData = async () => {
  try {
    const response = await axios.get('/api/aoyunfans/dwtInfo'); // 替换为实际的API URL
    return response.data;
  } catch (error) {
    console.error('Error fetching data:', error);
    return null;
  }
};

const initChart = async () => {
  const data = await fetchData();
  if (!data) return;

  const names = data.map((item: { name: string }) => item.name);
  const fansNumbers = data.map((item: { value: number }) => item.value);

  myChart = echarts.init(chartRef.value);
  const option = {
    xAxis: {
      type: 'category',
      data: names,
      name: '',
      axisLabel: {
        interval: 0,
        rotate: 330
      },
      nameLocation: 'center',
      nameTextStyle: {
        fontSize: 14,
        fontWeight: 'bold'
      }
    },
    yAxis: {
      type: 'log',
      name: '粉丝数（人）',
      nameLocation: 'start',
      nameTextStyle: {
        fontSize: 14,
        fontWeight: 'bold'
      },
      axisLabel: {
        show: true,
        formatter: '{value} 人',
        inside: true,
        verticalAlign: 'top',
        padding: [0, 0, 10, 0]
      }
    },
    series: [
      {
        data: fansNumbers,
        type: 'line',
        lineStyle: {
          color: '#4FC3F7'
        },
        symbol: 'circle',
        symbolSize: 8,
        label: {
          show: false // 隐藏原有的数据标签
        }
      }
    ],
    tooltip: {
      trigger: 'axis'
    }
  };

  myChart.setOption(option);
};



onMounted(() => {
  initChart();
});
</script>

<style scoped>
.container {
  display: flex;
  flex-direction: column;
  align-items: center;
}

.title {
  font-size: 20px;
  font-weight: bold;
  margin-bottom: 10px;
}
</style>
```
### 抖音网红相关信息
![输入图片说明](img/%7B14BD01E7-0B16-4B92-ABB3-A30F00A984D5%7D.png)
#### 抖音网红性别比例
> src/views/page3/chart01.vue
```bash
<template>
  <h1 @click="handlerPage">抖音网红性别比例</h1>
  <div ref="chartRef" style="width: 100%; height: 100%;"></div>
</template>

<script setup>
import * as echarts from 'echarts';
import axios from 'axios';
import { onMounted, ref } from 'vue';

const chartRef = ref(null);
let myChart = null;
let option = null;

// 通过API接口获取数据
const fetchData = async () => {
  try {
    const response = await axios.get('/api/douyinwanghonggender/dwtInfo'); // 替换为实际API地址
    const data = response.data.map(item => ({
      name: item.name,
      value: item.value
    }));
    return data;
  } catch (error) {
    console.error('Error fetching data:', error);
    return [];
  }
};

const initChart = async () => {
  const data = await fetchData();
  if (!data || data.length === 0) return;
  option = {
    title: {
      left: 'center',
      textStyle: {
        color: '#333',
        fontSize: 18
      }
    },
    tooltip: {
      trigger: 'item',
      formatter: function (params) {
        const total = data.reduce((acc, cur) => acc + cur.value, 0);
        const percentage = ((params.value / total) * 100).toFixed(2);
        return `${params.name} : ${params.value}人（占比：${percentage}%）`;
      }
    },
    legend: {
      orient: 'vertical',
      left: 'right',
      textStyle: {
        color: '#333'
      }
    },
    grid: {
      left: '5%',
      right: '5%',
      bottom: '30%',
      top: '10%',
      containLabel: true
    },
    series: [
      {
        name: '性别分布',
        type: 'pie',
        radius: '50%',
        data: data,
        label: {
          show: true,
          formatter: function (params) {
            const total = data.reduce((acc, cur) => acc + cur.value, 0);
            const percentage = ((params.value / total) * 100).toFixed(2);
            return `${params.name} : ${params.value}人`;
          }
        },
        emphasis: {
          itemStyle: {
            shadowBlur: 5,
            shadowOffsetX: 0,
            shadowColor: 'rgba(0, 0, 0, 0.5)'
          }
        }
      }
    ]
  };
  if (myChart) {
    myChart.setOption(option);
  }
};

onMounted(() => {
  if (chartRef.value) {
    myChart = echarts.init(chartRef.value);
    initChart();
  }
});
</script>

<style scoped>
</style>
```
#### 抖音网红星座分布
> src/views/page3/Chart02.vue
```bash
<template>
  <h1>抖音网红星座分布</h1>
  <div ref="chartContainer" style="width: 100%; height: 100%;position: relative"></div>
</template>

<script>
import * as echarts from 'echarts';
import { ref, onMounted, onBeforeUnmount } from 'vue';
import axios from 'axios';

export default {
  setup() {
    // 用于获取图表容器的引用
    const chartContainer = ref(null);

    let datas = ref([]); // 用于存储从API获取的数据

    let yData = []; // y轴数据
    let xName = []; // x轴名称
    let max = 30; // 最大数值
    let colorList = ['#0066ff', '#2196F3'];

    // 通过API接口获取数据
    const fetchData = async () => {
      try {
        const response = await axios.get('/api/douyinwanghongconstellation/dwtInfo'); // 替换为实际API地址
        datas.value = response.data;
      } catch (error) {
        console.error('Error fetching data:', error);
        datas.value = [];
      }
    };

    // 处理数据，提取y轴数据以及构建x轴名称相关信息
    const processData = () => {
      yData = datas.value.map((n) => {
        return n.value;
      });
      datas.value.forEach((item) => {
        xName.push({ name: item.name, max: max, value: item.value });
      });
    };

    // 实现单个提示框方法
    const buildSeries = function (data) {
      const helper = data.map((item, index) => {
        const arr = new Array(data.length);
        arr.splice(index, 1, item);
        return arr;
      });
      return [data, ...helper].map((item, index) => {
        return {
          type: 'radar',
          symbol: 'circle',
          symbolSize: 4, // 原点大小
          lineStyle: {
            color: index === 0 ? colorList[0] : 'transparent'
          },
          areaStyle: {
            color: colorList[0],
            opacity: 0.6,
            emphasis: {
              color: colorList[0],
              opacity: 0.6
            }
          },
          tooltip: {
            show: index === 0 ? false : true,
            trigger: 'item',
            formatter: function () {
              return xName[index - 1].name + '：' + yData[index - 1];
            }
          },
          z: index === 0 ? 1 : 2,
          // 设置区域边框和区域的颜色
          itemStyle: {
            normal: {
              // 点的样式
              color: colorList[0],
              opacity: 0
            },
            // 鼠标经过的
            emphasis: {
              show: index === 0 ? false : true,
              // 某个点的样式
              color: index === 0 ? '' : '#a3ffe7',
              opacity: index === 0 ? 0 : 1,
              // 中心点连接点的线条
              lineStyle: {
                color: index === 0 ? colorList[0] : '#a3ffe7',
                opacity: index === 0 ? 1 : 0.2
              }
            }
          },
          data: [
            {
              value: item,
              label: {
                show: false,
                fontSize: 16,
                position: 'right',
                color: colorList[0],
                formatter: function (params) {
                  return params.value;
                }
              }
            }
          ]
        };
      });
    };

    const option = {
      backgroundColor: 'transparent',
      tooltip: {},
      radar: {
        splitNumber: 4, // 中间辅助线
        center: ['50%', '50%'], // 图表位置
        radius: '65%', // 图表大小
        // 设置雷达图中间射线的颜色
        axisLine: {
          lineStyle: {
            color: 'rgba(242, 242, 242,.1)',
            fontSize: 40
          }
        },
        // 网格线
        splitLine: {
          lineStyle: {
            color: 'rgba(242, 242, 242,.08)'
          }
        },
        indicator: xName,
        // 雷达图背景的颜色，在这儿随便设置了一个颜色，完全不透明度为0，就实现了透明背景
        splitArea: {
          areaStyle: {
            // 图表背景的颜色
            color: ['#555555', '#444444', '#333333', '#222222'],
            shadowColor: 'rgba(0, 0, 0,.15)',
            shadowBlur: 2
          }
        },
        axisName: {
          lineHeight: 18,
          color: '#fff',
          fontSize: 14,
          formatter: (labelName) => {
            return labelName;
          }
        }
      },
      // 标轴值
      polar: {
        radius: '65%'
      },
      angleAxis: {
        zlevel: 0,
        min: 0,
        max: 360,
        clockwise: false,
        axisTick: {
          show: false
        },
        axisLabel: {
          show: false
        },
        axisLine: {
          show: false
        },
        splitLine: {
          show: false
        }
      },
      radiusAxis: {
        zlevel: 0,
        min: 0,
        max: 30,
        interval: 5,
        axisLabel: {
          textStyle: {
            color: '#AFAFAF',
            fontSize: 10
          }
        },
        axisLine: {
          show: false
        },
        splitLine: {
          show: false
        },
        splitArea: {
          show: false
        }
      },
      series: []
    };

    let currentIndex = -1;
    let myChart = null;
    let timer = null;

    // 在组件挂载完成后初始化图表
    onMounted(async () => {
      await fetchData();
      processData();
      option.series = buildSeries(yData);
      myChart = echarts.init(chartContainer.value);
      myChart.setOption(option);
      // 启动定时器实现动态高亮效果
      timer = setInterval(() => {
        let dataLen = option.series[0].data[0].value.length + 1;
        // 取消之前高亮的图形
        myChart.dispatchAction({
          type: 'downplay',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
        currentIndex = (currentIndex + 1) % dataLen;
        // 高亮当前图形
        myChart.dispatchAction({
          type: 'highlight',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
        // 显示 tooltip
        myChart.dispatchAction({
          type: 'showTip',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
      }, 2000);
    });

    // 在组件销毁前清除定时器，避免内存泄漏等问题
    onBeforeUnmount(() => {
      clearInterval(timer);
    });

    return {
      chartContainer
    };
  }
};
</script>

<style scoped>
</style>
```
#### 奥运健儿认证信息滚屏展示
> src/views/page3/Chart03.vue
 ```bash
<template>
  <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
  <div class="container">
    <!-- 标题部分 -->
    <div class="title">奥运健儿认证信息滚屏展示</div>
    <!-- 相关表格部分 -->
    <dv-scroll-board
        :config="table"
        style="width: 180px; height: 600px"
    />
  </div>
</template>

<script setup lang="ts">
import { ref, onMounted } from 'vue';
import axios from 'axios';

const table = ref({
  columnWidth: 400,
  headerHeight: 30,
  headerBGC: 'transparent',
  oddRowBGC: 'transparent',
  evenRowBGC: 'transparent',
  column: [
    {
      field: "姓名",
      width: 5
    },
    {
      field: "性别",
      width: 10,
    },
    {
      field: "星座",
      width: 5,
    },
  ],
  header: [
    "姓名",
    "性别",
    "星座"
  ],
  data: [],
  scrollSpeed: 200,
  rowHeight: 15,
  columnSpacing: 1,
  rowSpacing: 5 // 如果组件支持该属性，可通过此设置行间距
});

// 通过API接口获取数据
const fetchData = async () => {
  try {
    const response = await axios.get('/api/douyinwanghong/dwtInfo'); // 替换为实际API地址
    table.value.data = response.data.map(item => ({
      姓名: item.name,
      性别: item.gender,
      星座: item.constellation
    }));
  } catch (error) {
    console.error('Error fetching data:', error);
    table.value.data = [];
  }
};

// 在组件挂载完成后获取数据
onMounted(() => {
  fetchData();
});
</script>

<style scoped>
/* 整体容器样式，设置为弹性布局，方便垂直排列标题和表格 */
.container {
  display: flex;
  flex-direction: column;
  align-items: center;
}

/* 标题样式，可根据喜好调整字体、颜色等样式 */
.title {
  font-size: 20px;
  font-weight: bold;
  margin-bottom: 10px;
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4
}
</style>
 ```

## 抖音用户数据分析

![输入图片说明](img/%7BF273C028-5245-40B4-A0B5-A0E5EBC577DA%7D.png)

### 小米su7抖音评论地图展示

> src/views/page1/Chart01.vue

```
<script setup lang="ts">
import axios from 'axios';
import * as echarts from 'echarts';
import china_geo from '@/stores/china.json'
import { onMounted, ref } from "vue";

const chartMap = ref()

// 格式化城市名称的函数保持不变
function formatCityName(cityName) {
  const replacements = {
    "上海": "上海市",
    "北京": "北京市",
    "天津": "天津市",
    "广州": "广东省",
    "成都": "四川省",
    "杭州": "浙江省",
    "武汉": "湖北省",
    "济南": "山东省",
    "深圳": "广东省",
    "青岛": "山东省",
    // 可以继续添加更多的替换规则
  };
  return replacements[cityName] || cityName;
}

function initChart(data: { name: string, value: [number, number, number] }[]) {
  // 基于准备好的dom，初始化echarts实例
  const myChart = echarts.init(chartMap.value);
  // 注入地图数据 GeoJson 注意第一个参数为 china 才会显示 海南岛缩略图 其它名字不会
  echarts.registerMap('china', china_geo);
  // 指定图表的配置项和数据
  const option = {
    backgroundColor: 'rgba(0, 0, 0, 0)',
    // backgroundColor: 'transparent',
    title: {
      text: '小米su7抖音用户分布图',
      left: 'center',
      top: '30px',
      textStyle: {
        color: '#fff',
        fontWeight: 'bold',
        fontSize: '30px',
      }
    },
    tooltip: {
      trigger: 'item',
      formatter: function (params) {
        return `${params.data.name}：${params.data.value[2]}`
      },
      backgroundColor: "rgba(0, 0, 0,.6)",
      borderColor: "rgba(147, 235, 248,.8)",
      textStyle: {
        color: "#FFF",
      },
    },
    // 地图配置
    geo: {
      type: 'map',
      // chinaMap 这个参数 为 echarts.registerMap('chinaMap', response); 参数中第一个参数
      // 注意参数为 china 才会显示 海南岛缩略图 其它名字不会
      map: 'china',
      // 是否开启鼠标缩放和平移漫游。默认不开启。如果只想要开启缩放或者平移，可以设置成 'scale' 或者 'move'。设置成 true 为都开启
      roam: true,
      // 图形上的文本标签，可用于说明图形的一些数据信息，比如值，名称等
      label: {
        // 是否显示标签
        show: true
      },
      // 默认缩放比例
      zoom: 1.1,
    },
    series: [
      {
        geoIndex: 0,
        type: 'effectScatter',
        // 配置何时显示特效
        // 'render' 绘制完成后显示特效
        // 'emphasis' 高亮（hover）的时候显示特效。
        showEffectOn: 'render',
        data: data,
        // 使用地理坐标系，通过 geoIndex 指定相应的地理坐标系组件。
        coordinateSystem: 'geo',
        symbolSize: function (param: number[]) {
          return param[2]/4
        },
      },
    ],
    // 是视觉映射组件，用于进行『视觉编码』，也就是将数据映射到视觉元素（视觉通道)
    visualMap: {
      left: 20,
      bottom: 20,
      pieces: [
        { lte: 49, label: "1 - 49个" },
        { gte: 50, lte: 99, label: "50 - 99个" },
        { gte: 100, label: "100及以上" },
      ],
      inRange: {
        // 渐变颜色，从小到大
        color: [
          "#97df1a",
          "#437287",
          "#c87575",
        ],
      },
      textStyle: {
        color: "#fff",
      },
    },
  };
  // 使用刚指定的配置项和数据显示图表。
  myChart.setOption(option, true)
  window.addEventListener('resize', function () {
    myChart.resize();
  });
}

function getData() {
  const mockData = [
    {
      "city": "上海",
      "user_count": 32
    },
    {
      "city": "云南省",
      "user_count": 17
    },
    {
      "city": "内蒙古自治区",
      "user_count": 10
    },
    {
      "city": "北京市",
      "user_count": 11
    },
    {
      "city": "吉林省",
      "user_count": 6
    },
    {
      "city": "四川省",
      "user_count": 57
    },
    {
      "city": "天津市",
      "user_count": 2
    },
    {
      "city": "宁夏回族自治区",
      "user_count": 1
    },
    {
      "city": "安徽省",
      "user_count": 36
    },
    {
      "city": "山东省",
      "user_count": 29
    },
    {
      "city": "山西省",
      "user_count": 10
    },
    {
      "city": "广东省",
      "user_count": 174
    },
    {
      "city": "广西省",
      "user_count": 30
    },
    {
      "city": "新疆维吾尔自治区",
      "user_count": 10
    },
    {
      "city": "江苏省",
      "user_count": 80
    },
    {
      "city": "江西省",
      "user_count": 36
    },
    {
      "city": "河北省",
      "user_count": 26
    },
    {
      "city": "河南省",
      "user_count": 32
    },
    {
      "city": "浙江省",
      "user_count": 67
    },
    {
      "city": "海南省",
      "user_count": 6
    },
    {
      "city": "湖北省",
      "user_count": 167
    },
    {
      "city": "湖南省",
      "user_count": 48
    },
    {
      "city": "甘肃省",
      "user_count": 3
    },
    {
      "city": "福建省",
      "user_count": 23
    },
    {
      "city": "西藏自治区",
      "user_count": 3
    },
    {
      "city": "贵州省",
      "user_count": 18
    },
    {
      "city": "辽宁省",
      "user_count": 11
    },
    {
      "city": "重庆市",
      "user_count": 9
    },
    {
      "city": "陕西省",
      "user_count": 20
    },
    {
      "city": "青海省",
      "user_count": 2
    },
    {
      "city": "黑龙江省",
      "user_count": 3
    }
  ];
  let data: { name: string, value: [number, number, number] }[] = [];
  mockData.forEach((province) => {
    const formattedCityName = formatCityName(province.city);
    const obj = china_geo.features.find(item => item.properties.name === formattedCityName);
    if (obj) {
      const rs: { name: string, value: [number, number, number] } = {
        name: obj.properties.name,
        value: [obj.properties.center[0], obj.properties.center[1], province.user_count]
      };
      data.push(rs);
    } else {
      console.warn(`未找到城市 ${province.city} 对应的地理信息`);
    }
  });
  initChart(data);
}

onMounted(() => {
  getData();
})
</script>

<template>
  <dv-border-box-8 style="text-align: center">
    <div ref="chartMap" id="chartMap"></div>
  </dv-border-box-8>
</template>

<style scoped lang="scss">
#chartMap {
  width: 100%;
  height: 90% }
</style>
```

### 奥运健儿相关信息

![输入图片说明](img/%7B21E1827E-49DD-4F0F-BC85-7D59A1E003BC%7D.png)

### 奥运健儿认证信息滚屏展示

> src/views/page2/Chart01.vue

```
<template xmlns="">
  <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
  <div class="container">
    <!-- 标题部分 -->
    <div class="title">奥运健儿认证信息滚屏展示</div>
    <!-- 相关表格部分 -->
    <div class="dv-scroll-board">
    <!-- 使用 dv-scroll-board 组件来展示滚动表格 -->
    <!-- :config 属性绑定表格配置数据，动态生成表格内容 -->
    <!-- 设置组件样式，使其宽度占满父容器，高度为 370 像素 -->
    <dv-scroll-board
        :config="table"
        style=" height: 370px"
    />
    </div>
  </div>
</template>

<script setup lang="ts">
import { defineProps, ref, onMounted } from 'vue';
import axios from 'axios';

const table = ref({
  columnWidth: 400,
  headerHeight: 30,
  headerBGC: 'rgba(14,183,221,0)',
  oddRowBGC: 'rgba(14,183,221,0)',
  evenRowBGC: 'rgba(14,183,221,0)',
  column: [
    {
      field: "name",
      width: 100, // 明确设置姓名这一列的宽度为100px
    },
    {
      field: "certificationInfo",
      width: 200,
    },
    {
      field: "ipLocation",
      width: 100,
    },
    {
      field: "newFollowers",
      width: 150,
    },
    {
      field: "newLikes",
      width: 150,
    },
  ],
  header: [
    "姓名",
    "认证信息",
    "ip属地",
    "30日内新增粉丝数",
    "30日内点赞数",
  ],
  data: [],
  scrollSpeed: 20,
});

// 定义一个函数来获取数据
async function fetchData() {
  try {
    const response = await axios.get('/api/aoyun/dwtInfo'); // 替换为实际的API接口地址
    const transformedData = response.data.map(item => ({
      name: item.name,
      certificationInfo: item.value1,
      ipLocation: item.value2,
      newFollowers: item.value3,
      newLikes: item.value4,
    }));
    table.value.data = transformedData;
  } catch (error) {
    console.error('获取数据失败:', error);
  }
}

// 在组件挂载时调用fetchData函数
onMounted(() => {
  fetchData();
});
</script>

<style scoped>
/* 整体容器样式，设置为弹性布局，方便垂直排列标题和表格 */
.container {
  display: flex; /* 使用flex布局以便于内容的对齐和分布 */
  flex-direction: column; /* 设置主轴方向为垂直方向，使子元素按列排列 */
  align-items: center; /* 水平居中对齐子元素 */
  height: 100vh; /* 占满屏幕高度，vh为视窗高度单位，100vh等于当前视窗的高度 */
}


<<<<<<< HEAD
/* 标题样式，可根据喜好调整字体、颜色等样式 */
.title {
  font-size: 20px; /* 设置标题字体大小为20像素 */
  font-weight: bold; /* 加粗标题字体 */
  margin-bottom: 10px; /* 在标题下方添加10像素的外边距 */
  width: 100%; /* 确保标题占满宽度 */
  text-align: center; /* 居中显示标题 */
}


/* 表格样式，确保表格占满宽度 */
.dv-scroll-board {
  width: 1200px;
}
</style>
```

### 奥运健儿粉丝数排行

> src/views/page2/Chart02.vue

```
<template>
  <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
  <div class="container">
    <!-- 标题部分 -->
    <div class="title">奥运健儿粉丝数排行</div>
    <!-- 图表容器 -->
    <div ref="chartRef" style="width: 120%; height:350px; position: absolute; left: 50%; transform: translateX(-50%);"></div>
  </div>
</template>

<script setup lang="ts">
import axios from 'axios';
import { onMounted, ref } from 'vue';
import * as echarts from 'echarts';

const chartRef = ref(null);
let myChart = null;

// 从API获取数据
const fetchData = async () => {
  try {
    const response = await axios.get('/api/aoyunfans/dwtInfo'); // 替换为实际的API URL
    return response.data;
  } catch (error) {
    console.error('Error fetching data:', error);
    return null;
  }
};

const initChart = async () => {
  const data = await fetchData();
  if (!data) return;

  const names = data.map((item: { name: string }) => item.name);
  const fansNumbers = data.map((item: { value: number }) => item.value);

  myChart = echarts.init(chartRef.value);
  const option = {
    xAxis: {
      type: 'category',
      data: names,
      name: '',
      axisLabel: {
        interval: 0,
        rotate: 330
      },
      nameLocation: 'center',
      nameTextStyle: {
        fontSize: 14,
        fontWeight: 'bold'
      }
    },
    yAxis: {
      type: 'log',
      name: '粉丝数（人）',
      nameLocation: 'start',
      nameTextStyle: {
        fontSize: 14,
        fontWeight: 'bold'
      },
      axisLabel: {
        show: true,
        formatter: '{value} 人',
        inside: true,
        verticalAlign: 'top',
        padding: [0, 0, 10, 0]
      }
    },
    series: [
      {
        data: fansNumbers,
        type: 'line',
        lineStyle: {
          color: '#4FC3F7'
        },
        symbol: 'circle',
        symbolSize: 8,
        label: {
          show: false // 隐藏原有的数据标签
        }
      }
    ],
    tooltip: {
      trigger: 'axis'
    }
  };

  myChart.setOption(option);
};



onMounted(() => {
  initChart();
});
</script>

<style scoped>
.container {
  display: flex;
  flex-direction: column;
  align-items: center;
}

.title {
  font-size: 20px;
  font-weight: bold;
  margin-bottom: 10px;
}
</style>
```

### 抖音网红相关信息
=======
>>>>>>> 1b752e22e2b332403ea01d6b78e12def7b27cea4

![输入图片说明](img/%7B14BD01E7-0B16-4B92-ABB3-A30F00A984D5%7D.png)

### 抖音网红性别比例

> src/views/page3/chart01.vue

```
<template>
  <h1 @click="handlerPage">抖音网红性别比例</h1>
  <div ref="chartRef" style="width: 100%; height: 100%;"></div>
</template>

<script setup>
import * as echarts from 'echarts';
import axios from 'axios';
import { onMounted, ref } from 'vue';

const chartRef = ref(null);
let myChart = null;
let option = null;

// 通过API接口获取数据
const fetchData = async () => {
  try {
    const response = await axios.get('/api/douyinwanghonggender/dwtInfo'); // 替换为实际API地址
    const data = response.data.map(item => ({
      name: item.name,
      value: item.value
    }));
    return data;
  } catch (error) {
    console.error('Error fetching data:', error);
    return [];
  }
};

const initChart = async () => {
  const data = await fetchData();
  if (!data || data.length === 0) return;
  option = {
    title: {
      left: 'center',
      textStyle: {
        color: '#333',
        fontSize: 18
      }
    },
    tooltip: {
      trigger: 'item',
      formatter: function (params) {
        const total = data.reduce((acc, cur) => acc + cur.value, 0);
        const percentage = ((params.value / total) * 100).toFixed(2);
        return `${params.name} : ${params.value}人（占比：${percentage}%）`;
      }
    },
    legend: {
      orient: 'vertical',
      left: 'right',
      textStyle: {
        color: '#333'
      }
    },
    grid: {
      left: '5%',
      right: '5%',
      bottom: '30%',
      top: '10%',
      containLabel: true
    },
    series: [
      {
        name: '性别分布',
        type: 'pie',
        radius: '50%',
        data: data,
        label: {
          show: true,
          formatter: function (params) {
            const total = data.reduce((acc, cur) => acc + cur.value, 0);
            const percentage = ((params.value / total) * 100).toFixed(2);
            return `${params.name} : ${params.value}人`;
          }
        },
        emphasis: {
          itemStyle: {
            shadowBlur: 5,
            shadowOffsetX: 0,
            shadowColor: 'rgba(0, 0, 0, 0.5)'
          }
        }
      }
    ]
  };
  if (myChart) {
    myChart.setOption(option);
  }
};

onMounted(() => {
  if (chartRef.value) {
    myChart = echarts.init(chartRef.value);
    initChart();
  }
});
</script>

<style scoped>
</style>
```

### 抖音网红星座分布

> src/views/page3/Chart02.vue

```
<template>
  <h1>抖音网红星座分布</h1>
  <div ref="chartContainer" style="width: 100%; height: 100%;position: relative"></div>
</template>

<script>
import * as echarts from 'echarts';
import { ref, onMounted, onBeforeUnmount } from 'vue';
import axios from 'axios';

export default {
  setup() {
    // 用于获取图表容器的引用
    const chartContainer = ref(null);

    let datas = ref([]); // 用于存储从API获取的数据

    let yData = []; // y轴数据
    let xName = []; // x轴名称
    let max = 30; // 最大数值
    let colorList = ['#0066ff', '#2196F3'];

    // 通过API接口获取数据
    const fetchData = async () => {
      try {
        const response = await axios.get('/api/douyinwanghongconstellation/dwtInfo'); // 替换为实际API地址
        datas.value = response.data;
      } catch (error) {
        console.error('Error fetching data:', error);
        datas.value = [];
      }
    };

    // 处理数据，提取y轴数据以及构建x轴名称相关信息
    const processData = () => {
      yData = datas.value.map((n) => {
        return n.value;
      });
      datas.value.forEach((item) => {
        xName.push({ name: item.name, max: max, value: item.value });
      });
    };

    // 实现单个提示框方法
    const buildSeries = function (data) {
      const helper = data.map((item, index) => {
        const arr = new Array(data.length);
        arr.splice(index, 1, item);
        return arr;
      });
      return [data, ...helper].map((item, index) => {
        return {
          type: 'radar',
          symbol: 'circle',
          symbolSize: 4, // 原点大小
          lineStyle: {
            color: index === 0 ? colorList[0] : 'transparent'
          },
          areaStyle: {
            color: colorList[0],
            opacity: 0.6,
            emphasis: {
              color: colorList[0],
              opacity: 0.6
            }
          },
          tooltip: {
            show: index === 0 ? false : true,
            trigger: 'item',
            formatter: function () {
              return xName[index - 1].name + '：' + yData[index - 1];
            }
          },
          z: index === 0 ? 1 : 2,
          // 设置区域边框和区域的颜色
          itemStyle: {
            normal: {
              // 点的样式
              color: colorList[0],
              opacity: 0
            },
            // 鼠标经过的
            emphasis: {
              show: index === 0 ? false : true,
              // 某个点的样式
              color: index === 0 ? '' : '#a3ffe7',
              opacity: index === 0 ? 0 : 1,
              // 中心点连接点的线条
              lineStyle: {
                color: index === 0 ? colorList[0] : '#a3ffe7',
                opacity: index === 0 ? 1 : 0.2
              }
            }
          },
          data: [
            {
              value: item,
              label: {
                show: false,
                fontSize: 16,
                position: 'right',
                color: colorList[0],
                formatter: function (params) {
                  return params.value;
                }
              }
            }
          ]
        };
      });
    };

    const option = {
      backgroundColor: 'transparent',
      tooltip: {},
      radar: {
        splitNumber: 4, // 中间辅助线
        center: ['50%', '50%'], // 图表位置
        radius: '65%', // 图表大小
        // 设置雷达图中间射线的颜色
        axisLine: {
          lineStyle: {
            color: 'rgba(242, 242, 242,.1)',
            fontSize: 40
          }
        },
        // 网格线
        splitLine: {
          lineStyle: {
            color: 'rgba(242, 242, 242,.08)'
          }
        },
        indicator: xName,
        // 雷达图背景的颜色，在这儿随便设置了一个颜色，完全不透明度为0，就实现了透明背景
        splitArea: {
          areaStyle: {
            // 图表背景的颜色
            color: ['#555555', '#444444', '#333333', '#222222'],
            shadowColor: 'rgba(0, 0, 0,.15)',
            shadowBlur: 2
          }
        },
        axisName: {
          lineHeight: 18,
          color: '#fff',
          fontSize: 14,
          formatter: (labelName) => {
            return labelName;
          }
        }
      },
      // 标轴值
      polar: {
        radius: '65%'
      },
      angleAxis: {
        zlevel: 0,
        min: 0,
        max: 360,
        clockwise: false,
        axisTick: {
          show: false
        },
        axisLabel: {
          show: false
        },
        axisLine: {
          show: false
        },
        splitLine: {
          show: false
        }
      },
      radiusAxis: {
        zlevel: 0,
        min: 0,
        max: 30,
        interval: 5,
        axisLabel: {
          textStyle: {
            color: '#AFAFAF',
            fontSize: 10
          }
        },
        axisLine: {
          show: false
        },
        splitLine: {
          show: false
        },
        splitArea: {
          show: false
        }
      },
      series: []
    };

    let currentIndex = -1;
    let myChart = null;
    let timer = null;

    // 在组件挂载完成后初始化图表
    onMounted(async () => {
      await fetchData();
      processData();
      option.series = buildSeries(yData);
      myChart = echarts.init(chartContainer.value);
      myChart.setOption(option);
      // 启动定时器实现动态高亮效果
      timer = setInterval(() => {
        let dataLen = option.series[0].data[0].value.length + 1;
        // 取消之前高亮的图形
        myChart.dispatchAction({
          type: 'downplay',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
        currentIndex = (currentIndex + 1) % dataLen;
        // 高亮当前图形
        myChart.dispatchAction({
          type: 'highlight',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
        // 显示 tooltip
        myChart.dispatchAction({
          type: 'showTip',
          seriesIndex: currentIndex,
          dataIndex: 0
        });
      }, 2000);
    });

    // 在组件销毁前清除定时器，避免内存泄漏等问题
    onBeforeUnmount(() => {
      clearInterval(timer);
    });

    return {
      chartContainer
    };
  }
};
</script>

<style scoped>
</style>
```

### 抖音网红相关信息滚屏展示

> src/views/page3/Chart03.vue

```
<template>
 <!-- 整体容器，方便后续对标题和表格部分统一布局等操作 -->
 <div class="container">
   <!-- 标题部分 -->
   <div class="title">奥运健儿认证信息滚屏展示</div>
   <!-- 相关表格部分 -->
   <dv-scroll-board
       :config="table"
       style="width: 180px; height: 600px"
   />
 </div>
</template>

<script setup lang="ts">
import { ref, onMounted } from 'vue';
import axios from 'axios';

const table = ref({
 columnWidth: 400,
 headerHeight: 30,
 headerBGC: 'transparent',
 oddRowBGC: 'transparent',
 evenRowBGC: 'transparent',
 column: [
   {
     field: "姓名",
     width: 5
   },
   {
     field: "性别",
     width: 10,
   },
   {
     field: "星座",
     width: 5,
   },
 ],
 header: [
   "姓名",
   "性别",
   "星座"
 ],
 data: [],
 scrollSpeed: 200,
 rowHeight: 15,
 columnSpacing: 1,
 rowSpacing: 5 // 如果组件支持该属性，可通过此设置行间距
});

// 通过API接口获取数据
const fetchData = async () => {
 try {
   const response = await axios.get('/api/douyinwanghong/dwtInfo'); // 替换为实际API地址
   table.value.data = response.data.map(item => ({
     姓名: item.name,
     性别: item.gender,
     星座: item.constellation
   }));
 } catch (error) {
   console.error('Error fetching data:', error);
   table.value.data = [];
 }
};

// 在组件挂载完成后获取数据
onMounted(() => {
 fetchData();
});
</script>

<style scoped>
/* 整体容器样式，设置为弹性布局，方便垂直排列标题和表格 */
.container {
 display: flex;
 flex-direction: column;
 align-items: center;
}

/* 标题样式，可根据喜好调整字体、颜色等样式 */
.title {
 font-size: 20px;
 font-weight: bold;
 margin-bottom: 10px;
}
</style>
```