diff --git a/.idea/.cache/.Apifox_Helper/.toolWindow.db b/.idea/.cache/.Apifox_Helper/.toolWindow.db
index 7d3a966..1bfb44b 100644
Binary files a/.idea/.cache/.Apifox_Helper/.toolWindow.db and b/.idea/.cache/.Apifox_Helper/.toolWindow.db differ
diff --git a/.idea/ApifoxUploaderProjectSetting.xml b/.idea/ApifoxUploaderProjectSetting.xml
index 517f9ea..f7f3101 100644
--- a/.idea/ApifoxUploaderProjectSetting.xml
+++ b/.idea/ApifoxUploaderProjectSetting.xml
@@ -6,9 +6,10 @@
+
-
-
+
+
\ No newline at end of file
diff --git a/video-common/src/main/java/com/nuaa/video/common/utils/MinioUtils.java b/video-common/src/main/java/com/nuaa/video/common/utils/MinioUtils.java
index dd0c11d..c4eb866 100644
--- a/video-common/src/main/java/com/nuaa/video/common/utils/MinioUtils.java
+++ b/video-common/src/main/java/com/nuaa/video/common/utils/MinioUtils.java
@@ -224,4 +224,24 @@ public class MinioUtils {
throw new RuntimeException("获取文件基础URL失败", e);
}
}
+
+ public String uploadObject(String fileType, String fileName, InputStream inputStream, long size, String contentType) throws Exception {
+ // 检查存储桶是否存在
+ createBucket(bucketName);
+
+ // 生成对象名称
+ String objectName = fileType + "/" + fileName;
+
+ // 上传文件
+ minioClient.putObject(
+ PutObjectArgs.builder()
+ .bucket(bucketName)
+ .object(objectName)
+ .stream(inputStream, size, -1)
+ .contentType(contentType)
+ .build()
+ );
+
+ return objectName;
+ }
}
\ No newline at end of file
diff --git a/video-content/pom.xml b/video-content/pom.xml
index 0abb635..29d2388 100644
--- a/video-content/pom.xml
+++ b/video-content/pom.xml
@@ -12,12 +12,87 @@
video-content
+
com.nuaa.video
video-common
${project.version}
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-security
+
+
+
+
+ com.alibaba.cloud
+ spring-cloud-starter-alibaba-nacos-discovery
+
+
+
+
+ com.alibaba.cloud
+ spring-cloud-starter-alibaba-nacos-config
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-actuator
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-validation
+
+
+
+
+ org.springframework.cloud
+ spring-cloud-starter-openfeign
+
+
+
+
+ org.springframework.cloud
+ spring-cloud-starter-loadbalancer
+
+
+
+
+ com.alibaba.cloud
+ spring-cloud-starter-alibaba-sentinel
+
+
+
+
+ com.mysql
+ mysql-connector-j
+ runtime
+
+
+
+
+ com.baomidou
+ mybatis-plus-spring-boot3-starter
+ 3.5.11
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
+
org.apache.rocketmq
@@ -29,7 +104,38 @@
net.bramp.ffmpeg
ffmpeg
- 0.7.0
+ 0.8.0
+
+
+
+
+ org.projectlombok
+ lombok
+ true
+
+
+
+
+ cn.hutool
+ hutool-all
+ 5.8.26
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+ org.projectlombok
+ lombok
+
+
+
+
+
+
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/ContentApplication.java b/video-content/src/main/java/com/nuaa/video/content/ContentApplication.java
index 413dbbb..c1c698f 100644
--- a/video-content/src/main/java/com/nuaa/video/content/ContentApplication.java
+++ b/video-content/src/main/java/com/nuaa/video/content/ContentApplication.java
@@ -1,11 +1,20 @@
package com.nuaa.video.content;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableScheduling;
+/**
+ * 内容服务启动类
+ */
@SpringBootApplication
@EnableDiscoveryClient
+@EnableFeignClients
+@EnableScheduling
+@MapperScan("com.nuaa.video.content.mapper")
public class ContentApplication {
public static void main(String[] args) {
SpringApplication.run(ContentApplication.class, args);
diff --git a/video-content/src/main/java/com/nuaa/video/content/config/FFmpegConfig.java b/video-content/src/main/java/com/nuaa/video/content/config/FFmpegConfig.java
new file mode 100644
index 0000000..d3341f1
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/config/FFmpegConfig.java
@@ -0,0 +1,68 @@
+package com.nuaa.video.content.config;
+
+import lombok.Data;
+import net.bramp.ffmpeg.FFmpeg;
+import net.bramp.ffmpeg.FFprobe;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.IOException;
+
+/**
+ * FFmpeg配置类
+ */
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "ffmpeg")
+public class FFmpegConfig {
+
+ /**
+ * binary配置
+ */
+ private Binary binary = new Binary();
+
+ /**
+ * probe配置
+ */
+ private Probe probe = new Probe();
+
+ /**
+ * 临时文件配置
+ */
+ private Temp temp = new Temp();
+
+ @Data
+ public static class Binary {
+ /**
+ * FFmpeg可执行文件路径
+ */
+ private String path = "/usr/bin/ffmpeg";
+ }
+
+ @Data
+ public static class Probe {
+ /**
+ * FFprobe可执行文件路径
+ */
+ private String path = "/usr/bin/ffprobe";
+ }
+
+ @Data
+ public static class Temp {
+ /**
+ * 临时文件目录
+ */
+ private String path = "/tmp/ffmpeg";
+ }
+
+ @Bean
+ public FFmpeg ffmpeg() throws IOException {
+ return new FFmpeg(binary.getPath());
+ }
+
+ @Bean
+ public FFprobe ffprobe() throws IOException {
+ return new FFprobe(probe.getPath());
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/config/MinioConfig.java b/video-content/src/main/java/com/nuaa/video/content/config/MinioConfig.java
new file mode 100644
index 0000000..b878e3b
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/config/MinioConfig.java
@@ -0,0 +1,52 @@
+package com.nuaa.video.content.config;
+
+import com.nuaa.video.common.utils.MinioUtils;
+import io.minio.MinioClient;
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * MinIO配置类
+ */
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "minio")
+public class MinioConfig {
+
+ /**
+ * 服务地址
+ */
+ private String endpoint;
+
+ /**
+ * 访问密钥
+ */
+ private String accessKey;
+
+ /**
+ * 密钥
+ */
+ private String secretKey;
+
+ /**
+ * 存储桶名称
+ */
+ private String bucketName;
+
+ @Bean
+ public MinioClient minioClient() {
+ return MinioClient.builder()
+ .endpoint(endpoint)
+ .credentials(accessKey, secretKey)
+ .build();
+ }
+
+ @Bean
+ public MinioUtils minioUtils(MinioClient minioClient) {
+ MinioUtils minioUtils = new MinioUtils(minioClient);
+ // 如果MinioUtils有setBucketName方法或需要其他配置，在这里设置
+ return minioUtils;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/config/RocketConfig.java b/video-content/src/main/java/com/nuaa/video/content/config/RocketConfig.java
new file mode 100644
index 0000000..286df2d
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/config/RocketConfig.java
@@ -0,0 +1,29 @@
+package com.nuaa.video.content.config;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.spring.autoconfigure.RocketMQProperties;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RocketConfig {
+
+ @Value("${spring.rocketmq.producer.group}")
+ private String producerGroup;
+
+ @Value("${spring.rocketmq.name-server}")
+ private String nameServer;
+
+ @Bean(name = "rocketMQTemplate")
+ public RocketMQTemplate rocketMQTemplate() {
+ RocketMQTemplate rocketMQTemplate = new RocketMQTemplate();
+ DefaultMQProducer defaultMQProducer = new DefaultMQProducer(producerGroup);
+ defaultMQProducer.setProducerGroup(producerGroup);
+ defaultMQProducer.setNamesrvAddr(nameServer);
+ rocketMQTemplate.setProducer(defaultMQProducer);
+ return rocketMQTemplate;
+ }
+
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/config/SecurityConfig.java b/video-content/src/main/java/com/nuaa/video/content/config/SecurityConfig.java
new file mode 100644
index 0000000..6a0f26a
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/config/SecurityConfig.java
@@ -0,0 +1,43 @@
+package com.nuaa.video.content.config;
+
+import com.nuaa.video.content.filter.JwtAuthenticationFilter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
+import org.springframework.security.config.http.SessionCreationPolicy;
+import org.springframework.security.web.SecurityFilterChain;
+import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
+
+/**
+ * 安全配置类
+ */
+@Configuration
+@EnableWebSecurity
+@RequiredArgsConstructor
+public class SecurityConfig {
+
+ private final JwtAuthenticationFilter jwtAuthenticationFilter;
+
+ @Bean
+ public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
+ http
+ .csrf(csrf -> csrf.disable())
+ .cors(cors -> cors.disable())
+ .sessionManagement(session -> session.sessionCreationPolicy(SessionCreationPolicy.STATELESS))
+ .authorizeHttpRequests(auth -> auth
+ .requestMatchers(
+ "/content/video/public/**",
+ "/content/category/list",
+ "/content/tag/list",
+ "/actuator/**",
+ "/error"
+ ).permitAll()
+ .anyRequest().authenticated()
+ )
+ .addFilterBefore(jwtAuthenticationFilter, UsernamePasswordAuthenticationFilter.class);
+
+ return http.build();
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/CategoryController.java b/video-content/src/main/java/com/nuaa/video/content/controller/CategoryController.java
new file mode 100644
index 0000000..edea5a0
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/CategoryController.java
@@ -0,0 +1,80 @@
+package com.nuaa.video.content.controller;
+
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.entity.ContentCategory;
+import com.nuaa.video.content.service.CategoryService;
+import com.nuaa.video.content.vo.CategoryVO;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 分类控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/category")
+@RequiredArgsConstructor
+public class CategoryController {
+
+ private final CategoryService categoryService;
+
+ /**
+ * 获取分类树
+ */
+ @GetMapping("/tree")
+ public Result> getCategoryTree() {
+ return categoryService.getCategoryTree();
+ }
+
+ /**
+ * 获取分类列表
+ */
+ @GetMapping("/list")
+ public Result> getCategoryList() {
+ return categoryService.getCategoryList();
+ }
+
+ /**
+ * 添加分类
+ */
+ @PostMapping
+ public Result addCategory(@RequestBody ContentCategory category, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ category.setCreatedBy(userId.toString());
+ category.setUpdatedBy(userId.toString());
+ return categoryService.addCategory(category);
+ }
+
+ /**
+ * 更新分类
+ */
+ @PutMapping
+ public Result updateCategory(@RequestBody ContentCategory category, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ category.setUpdatedBy(userId.toString());
+ return categoryService.updateCategory(category);
+ }
+
+ /**
+ * 删除分类
+ */
+ @DeleteMapping("/{id}")
+ public Result deleteCategory(@PathVariable Long id) {
+ return categoryService.deleteCategory(id);
+ }
+
+ /**
+ * 从请求中获取用户ID
+ */
+ private Long getUserIdFromRequest(HttpServletRequest request) {
+ Object userIdObj = request.getAttribute("userId");
+ if (userIdObj instanceof Long) {
+ return (Long) userIdObj;
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/DanmakuController.java b/video-content/src/main/java/com/nuaa/video/content/controller/DanmakuController.java
new file mode 100644
index 0000000..811b6fd
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/DanmakuController.java
@@ -0,0 +1,67 @@
+package com.nuaa.video.content.controller;
+
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.dto.DanmakuDTO;
+import com.nuaa.video.content.service.DanmakuService;
+import com.nuaa.video.content.vo.DanmakuVO;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 弹幕控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/danmaku")
+@RequiredArgsConstructor
+public class DanmakuController {
+
+ private final DanmakuService danmakuService;
+
+ /**
+ * 发送弹幕
+ */
+ @PostMapping
+ public Result sendDanmaku(@RequestBody @Valid DanmakuDTO danmakuDTO, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return danmakuService.sendDanmaku(danmakuDTO, userId);
+ }
+
+ /**
+ * 获取视频指定时间段的弹幕
+ */
+ @GetMapping("/time")
+ public Result> getVideoTimeDanmaku(
+ @RequestParam Long videoId,
+ @RequestParam Float startTime,
+ @RequestParam Float endTime) {
+ return danmakuService.getVideoTimeDanmaku(videoId, startTime, endTime);
+ }
+
+ /**
+ * 获取视频所有弹幕
+ */
+ @GetMapping("/all/{videoId}")
+ public Result> getVideoAllDanmaku(@PathVariable Long videoId) {
+ return danmakuService.getVideoAllDanmaku(videoId);
+ }
+
+ /**
+ * 从请求中获取用户ID
+ */
+ private Long getUserIdFromRequest(HttpServletRequest request) {
+ Object userIdObj = request.getAttribute("userId");
+ if (userIdObj instanceof Long) {
+ return (Long) userIdObj;
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/FavoriteController.java b/video-content/src/main/java/com/nuaa/video/content/controller/FavoriteController.java
new file mode 100644
index 0000000..32eac93
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/FavoriteController.java
@@ -0,0 +1,107 @@
+package com.nuaa.video.content.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.entity.ContentUserFavorite;
+import com.nuaa.video.content.entity.ContentVideo;
+import com.nuaa.video.content.service.FavoriteService;
+import com.nuaa.video.content.vo.FavoriteVO;
+import com.nuaa.video.content.vo.VideoListVO;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 收藏夹控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/favorite")
+@RequiredArgsConstructor
+public class FavoriteController {
+
+ private final FavoriteService favoriteService;
+
+ /**
+ * 获取用户收藏夹列表
+ */
+ @GetMapping("/list")
+ public Result> getUserFavorites(HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return favoriteService.getUserFavorites(userId);
+ }
+
+ /**
+ * 创建收藏夹
+ */
+ @PostMapping
+ public Result createFavorite(@RequestBody ContentUserFavorite favorite, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ favorite.setUserId(userId);
+ favorite.setCreatedBy(userId.toString());
+ favorite.setUpdatedBy(userId.toString());
+ return favoriteService.createFavorite(favorite, userId);
+ }
+
+ /**
+ * 更新收藏夹
+ */
+ @PutMapping
+ public Result updateFavorite(@RequestBody ContentUserFavorite favorite, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ favorite.setUpdatedBy(userId.toString());
+ return favoriteService.updateFavorite(favorite, userId);
+ }
+
+ /**
+ * 删除收藏夹
+ */
+ @DeleteMapping("/{id}")
+ public Result deleteFavorite(@PathVariable Long id, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return favoriteService.deleteFavorite(id, userId);
+ }
+
+ /**
+ * 获取收藏夹中的视频
+ */
+ @GetMapping("/{favoriteId}/videos")
+ public Result> getFavoriteVideos(
+ @PathVariable Long favoriteId,
+ @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+ @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize,
+ HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ Page page = new Page<>(pageNum, pageSize);
+ return favoriteService.getFavoriteVideos(favoriteId, page, userId);
+ }
+
+ /**
+ * 从请求中获取用户ID
+ */
+ private Long getUserIdFromRequest(HttpServletRequest request) {
+ Object userIdObj = request.getAttribute("userId");
+ if (userIdObj instanceof Long) {
+ return (Long) userIdObj;
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/TagController.java b/video-content/src/main/java/com/nuaa/video/content/controller/TagController.java
new file mode 100644
index 0000000..e151b59
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/TagController.java
@@ -0,0 +1,93 @@
+package com.nuaa.video.content.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.entity.ContentTag;
+import com.nuaa.video.content.service.TagService;
+import com.nuaa.video.content.vo.TagVO;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 标签控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/tag")
+@RequiredArgsConstructor
+public class TagController {
+
+ private final TagService tagService;
+
+ /**
+ * 获取标签列表
+ */
+ @GetMapping("/list")
+ public Result> getTagList() {
+ return tagService.getTagList();
+ }
+
+ /**
+ * 分页获取标签列表
+ */
+ @GetMapping("/page")
+ public Result> getTagPage(
+ @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+ @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize,
+ @RequestParam(value = "keyword", required = false) String keyword) {
+ Page page = new Page<>(pageNum, pageSize);
+ return tagService.getTagPage(page, keyword);
+ }
+
+ /**
+ * 添加标签
+ */
+ @PostMapping
+ public Result addTag(@RequestBody ContentTag tag, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ tag.setCreatedBy(userId.toString());
+ tag.setUpdatedBy(userId.toString());
+ return tagService.addTag(tag);
+ }
+
+ /**
+ * 更新标签
+ */
+ @PutMapping
+ public Result updateTag(@RequestBody ContentTag tag, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ tag.setUpdatedBy(userId.toString());
+ return tagService.updateTag(tag);
+ }
+
+ /**
+ * 删除标签
+ */
+ @DeleteMapping("/{id}")
+ public Result deleteTag(@PathVariable Long id) {
+ return tagService.deleteTag(id);
+ }
+
+ /**
+ * 获取视频标签
+ */
+ @GetMapping("/video/{videoId}")
+ public Result> getVideoTags(@PathVariable Long videoId) {
+ return tagService.getVideoTags(videoId);
+ }
+
+ /**
+ * 从请求中获取用户ID
+ */
+ private Long getUserIdFromRequest(HttpServletRequest request) {
+ Object userIdObj = request.getAttribute("userId");
+ if (userIdObj instanceof Long) {
+ return (Long) userIdObj;
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/VideoController.java b/video-content/src/main/java/com/nuaa/video/content/controller/VideoController.java
new file mode 100644
index 0000000..0f4c764
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/VideoController.java
@@ -0,0 +1,230 @@
+package com.nuaa.video.content.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.dto.*;
+import com.nuaa.video.content.entity.ContentVideo;
+import com.nuaa.video.content.service.VideoService;
+import com.nuaa.video.content.vo.UploadResultVO;
+import com.nuaa.video.content.vo.VideoInfoVO;
+import com.nuaa.video.content.vo.VideoListVO;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * 视频控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/video")
+@RequiredArgsConstructor
+public class VideoController {
+
+ private final VideoService videoService;
+
+ /**
+ * 上传视频
+ */
+ @PostMapping("/upload")
+ public Result uploadVideo(@RequestParam("file") MultipartFile file, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.uploadVideo(file, userId);
+ }
+
+ /**
+ * 创建视频
+ */
+ @PostMapping
+ public Result createVideo(@RequestBody @Valid VideoUploadDTO uploadDTO, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.createVideo(uploadDTO, userId);
+ }
+
+ /**
+ * 获取视频详情
+ */
+ @GetMapping("/{id}")
+ public Result getVideoInfo(@PathVariable Long id, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ return videoService.getVideoInfo(id, userId);
+ }
+
+ /**
+ * 获取视频列表
+ */
+ @GetMapping("/list")
+ public Result> getVideoList(
+ @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+ @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize,
+ VideoQueryDTO queryDTO,
+ HttpServletRequest request) {
+ Page page = new Page<>(pageNum, pageSize);
+ Long userId = getUserIdFromRequest(request);
+ return videoService.getVideoList(page, queryDTO, userId);
+ }
+
+ /**
+ * 更新视频信息
+ */
+ @PutMapping
+ public Result updateVideo(@RequestBody @Valid VideoUpdateDTO updateDTO, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.updateVideo(updateDTO, userId);
+ }
+
+ /**
+ * 删除视频
+ */
+ @DeleteMapping("/{id}")
+ public Result deleteVideo(@PathVariable Long id, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.deleteVideo(id, userId);
+ }
+
+ /**
+ * 点赞视频
+ */
+ @PostMapping("/like/{videoId}")
+ public Result likeVideo(@PathVariable Long videoId, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.likeVideo(videoId, userId);
+ }
+
+ /**
+ * 取消点赞
+ */
+ @DeleteMapping("/like/{videoId}")
+ public Result unlikeVideo(@PathVariable Long videoId, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.unlikeVideo(videoId, userId);
+ }
+
+ /**
+ * 投币
+ */
+ @PostMapping("/coin/{videoId}")
+ public Result coinVideo(
+ @PathVariable Long videoId,
+ @RequestParam(value = "amount", defaultValue = "1") Integer amount,
+ HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.coinVideo(videoId, userId, amount);
+ }
+
+ /**
+ * 收藏视频
+ */
+ @PostMapping("/favorite")
+ public Result favoriteVideo(@RequestBody @Valid FavoriteDTO favoriteDTO, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.favoriteVideo(favoriteDTO, userId);
+ }
+
+ /**
+ * 取消收藏
+ */
+ @DeleteMapping("/favorite/{videoId}")
+ public Result unfavoriteVideo(@PathVariable Long videoId, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.unfavoriteVideo(videoId, userId);
+ }
+
+ /**
+ * 分享视频
+ */
+ @PostMapping("/share/{videoId}")
+ public Result shareVideo(
+ @PathVariable Long videoId,
+ @RequestParam(value = "platform", required = false) String platform,
+ HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.shareVideo(videoId, userId, platform);
+ }
+
+ /**
+ * 播放记录
+ */
+ @PostMapping("/play")
+ public Result playVideo(@RequestBody @Valid PlayRecordDTO recordDTO, HttpServletRequest request) {
+ Long userId = getUserIdFromRequest(request);
+ if (userId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.playVideo(recordDTO, userId);
+ }
+
+ /**
+ * 获取用户视频列表
+ */
+ @GetMapping("/user/{userId}")
+ public Result> getUserVideos(
+ @PathVariable Long userId,
+ @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+ @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize,
+ HttpServletRequest request) {
+ Page page = new Page<>(pageNum, pageSize);
+ Long currentUserId = getUserIdFromRequest(request);
+ return videoService.getUserVideos(userId, page, currentUserId);
+ }
+
+ /**
+ * 视频审核
+ */
+ @PostMapping("/review/{videoId}")
+ public Result reviewVideo(
+ @PathVariable Long videoId,
+ @RequestParam Integer status,
+ @RequestParam(required = false) String reason,
+ HttpServletRequest request) {
+ Long reviewerId = getUserIdFromRequest(request);
+ if (reviewerId == null) {
+ return Result.error("未获取到用户ID");
+ }
+ return videoService.reviewVideo(videoId, reviewerId, status, reason);
+ }
+
+ /**
+ * 从请求中获取用户ID
+ */
+ private Long getUserIdFromRequest(HttpServletRequest request) {
+ Object userIdObj = request.getAttribute("userId");
+ if (userIdObj instanceof Long) {
+ return (Long) userIdObj;
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/controller/VideoStatController.java b/video-content/src/main/java/com/nuaa/video/content/controller/VideoStatController.java
new file mode 100644
index 0000000..a7ac2ce
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/controller/VideoStatController.java
@@ -0,0 +1,57 @@
+package com.nuaa.video.content.controller;
+
+import com.nuaa.video.common.model.vo.Result;
+import com.nuaa.video.content.entity.ContentVideoStatDaily;
+import com.nuaa.video.content.service.VideoStatService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 视频统计控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("/content/stat")
+@RequiredArgsConstructor
+public class VideoStatController {
+
+ private final VideoStatService videoStatService;
+
+ /**
+ * 获取视频每日统计
+ */
+ @GetMapping("/daily/{videoId}")
+ public Result> getVideoStatDaily(
+ @PathVariable Long videoId,
+ @RequestParam @DateTimeFormat(pattern = "yyyy-MM-dd") LocalDate startDate,
+ @RequestParam @DateTimeFormat(pattern = "yyyy-MM-dd") LocalDate endDate) {
+ return videoStatService.getVideoStatDaily(videoId, startDate, endDate);
+ }
+
+ /**
+ * 获取视频播放趋势(按小时)
+ */
+ @GetMapping("/play/trend/{videoId}")
+ public Result> getVideoPlayTrend(
+ @PathVariable Long videoId,
+ @RequestParam(required = false) @DateTimeFormat(pattern = "yyyy-MM-dd") LocalDate date) {
+ if (date == null) {
+ date = LocalDate.now();
+ }
+ return videoStatService.getVideoPlayTrend(videoId, date);
+ }
+
+ /**
+ * 获取视频互动统计
+ */
+ @GetMapping("/interaction/{videoId}")
+ public Result> getVideoInteractionStats(@PathVariable Long videoId) {
+ return videoStatService.getVideoInteractionStats(videoId);
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/DanmakuDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/DanmakuDTO.java
new file mode 100644
index 0000000..351a12c
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/DanmakuDTO.java
@@ -0,0 +1,48 @@
+package com.nuaa.video.content.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 弹幕DTO
+ */
+@Data
+public class DanmakuDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频ID
+ */
+ @NotNull(message = "视频ID不能为空")
+ private Long videoId;
+
+ /**
+ * 弹幕内容
+ */
+ @NotBlank(message = "弹幕内容不能为空")
+ private String content;
+
+ /**
+ * 弹幕颜色
+ */
+ private String color = "#FFFFFF";
+
+ /**
+ * 字体大小
+ */
+ private Integer fontSize = 25;
+
+ /**
+ * 位置(0:滚动,1:顶部,2:底部)
+ */
+ private Integer position = 0;
+
+ /**
+ * 发送时间(秒)
+ */
+ @NotNull(message = "发送时间不能为空")
+ private Float time;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/FavoriteDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/FavoriteDTO.java
new file mode 100644
index 0000000..7e6a1ad
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/FavoriteDTO.java
@@ -0,0 +1,26 @@
+package com.nuaa.video.content.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 收藏DTO
+ */
+@Data
+public class FavoriteDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频ID
+ */
+ @NotNull(message = "视频ID不能为空")
+ private Long videoId;
+
+ /**
+ * 收藏夹ID
+ */
+ @NotNull(message = "收藏夹ID不能为空")
+ private Long favoriteId;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/PlayRecordDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/PlayRecordDTO.java
new file mode 100644
index 0000000..8382a11
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/PlayRecordDTO.java
@@ -0,0 +1,31 @@
+package com.nuaa.video.content.dto;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 播放记录DTO
+ */
+@Data
+public class PlayRecordDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频ID
+ */
+ @NotNull(message = "视频ID不能为空")
+ private Long videoId;
+
+ /**
+ * 播放时长(秒)
+ */
+ @NotNull(message = "播放时长不能为空")
+ private Integer playTime;
+
+ /**
+ * 是否看完(0:未看完,1:已看完)
+ */
+ private Integer isFinished;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/VideoQueryDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/VideoQueryDTO.java
new file mode 100644
index 0000000..04e35be
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/VideoQueryDTO.java
@@ -0,0 +1,69 @@
+package com.nuaa.video.content.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 视频查询DTO
+ */
+@Data
+public class VideoQueryDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 关键词
+ */
+ private String keyword;
+
+ /**
+ * 分类ID
+ */
+ private Long categoryId;
+
+ /**
+ * 标签ID列表
+ */
+ private List tagIds;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 排序字段
+ */
+ private String orderBy;
+
+ /**
+ * 排序方向
+ */
+ private String orderDirection;
+
+ /**
+ * 状态
+ */
+ private Integer status;
+
+ /**
+ * 是否推荐
+ */
+ private Integer isRecommend;
+
+ /**
+ * 是否置顶
+ */
+ private Integer isTop;
+
+ /**
+ * 当前页码
+ */
+ private Integer pageNum = 1;
+
+ /**
+ * 每页记录数
+ */
+ private Integer pageSize = 10;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/VideoUpdateDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/VideoUpdateDTO.java
new file mode 100644
index 0000000..d5aeacb
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/VideoUpdateDTO.java
@@ -0,0 +1,47 @@
+package com.nuaa.video.content.dto;
+
+import jakarta.validation.constraints.Size;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 视频更新DTO
+ */
+@Data
+public class VideoUpdateDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频ID
+ */
+ private Long id;
+
+ /**
+ * 视频标题
+ */
+ @Size(min = 5, max = 100, message = "视频标题长度必须在5-100之间")
+ private String title;
+
+ /**
+ * 视频描述
+ */
+ @Size(max = 1000, message = "视频描述长度不能超过1000")
+ private String description;
+
+ /**
+ * 分类ID
+ */
+ private Long categoryId;
+
+ /**
+ * 标签ID列表
+ */
+ private List tagIds;
+
+ /**
+ * 封面URL
+ */
+ private String coverUrl;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/dto/VideoUploadDTO.java b/video-content/src/main/java/com/nuaa/video/content/dto/VideoUploadDTO.java
new file mode 100644
index 0000000..f4b510b
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/dto/VideoUploadDTO.java
@@ -0,0 +1,76 @@
+package com.nuaa.video.content.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 视频上传DTO
+ */
+@Data
+public class VideoUploadDTO implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频标题
+ */
+ @NotBlank(message = "视频标题不能为空")
+ @Size(min = 5, max = 100, message = "视频标题长度必须在5-100之间")
+ private String title;
+
+ /**
+ * 视频描述
+ */
+ @Size(max = 1000, message = "视频描述长度不能超过1000")
+ private String description;
+
+ /**
+ * 分类ID
+ */
+ @NotNull(message = "分类ID不能为空")
+ private Long categoryId;
+
+ /**
+ * 标签ID列表
+ */
+ private List tagIds;
+
+ /**
+ * 封面URL
+ */
+ private String coverUrl;
+
+ /**
+ * 视频URL
+ */
+ private String videoUrl;
+
+ /**
+ * 视频时长(秒)
+ */
+ private Integer duration;
+
+ /**
+ * 视频宽度
+ */
+ private Integer width;
+
+ /**
+ * 视频高度
+ */
+ private Integer height;
+
+ /**
+ * 视频格式
+ */
+ private String format;
+
+ /**
+ * 视频大小(字节)
+ */
+ private Long size;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentCategory.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentCategory.java
new file mode 100644
index 0000000..a11feae
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentCategory.java
@@ -0,0 +1,79 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频分类实体
+ */
+@Data
+@TableName("content_category")
+public class ContentCategory implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 分类ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 分类名称
+ */
+ private String name;
+
+ /**
+ * 分类编码
+ */
+ private String code;
+
+ /**
+ * 父分类ID
+ */
+ private Long parentId;
+
+ /**
+ * 分类层级
+ */
+ private Integer level;
+
+ /**
+ * 排序
+ */
+ private Integer sort;
+
+ /**
+ * 图标
+ */
+ private String icon;
+
+ /**
+ * 状态(0:禁用,1:正常)
+ */
+ private Integer status;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentDanmaku.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentDanmaku.java
new file mode 100644
index 0000000..a517db5
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentDanmaku.java
@@ -0,0 +1,64 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 弹幕实体
+ */
+@Data
+@TableName("content_danmaku")
+public class ContentDanmaku implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 弹幕ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 弹幕内容
+ */
+ private String content;
+
+ /**
+ * 弹幕颜色
+ */
+ private String color;
+
+ /**
+ * 字体大小
+ */
+ private Integer fontSize;
+
+ /**
+ * 位置(0:滚动,1:顶部,2:底部)
+ */
+ private Integer position;
+
+ /**
+ * 发送时间(秒)
+ */
+ private Float time;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentTag.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentTag.java
new file mode 100644
index 0000000..77f3433
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentTag.java
@@ -0,0 +1,49 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频标签实体
+ */
+@Data
+@TableName("content_tag")
+public class ContentTag implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 标签ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 标签名称
+ */
+ private String name;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentUserFavorite.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentUserFavorite.java
new file mode 100644
index 0000000..c90c785
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentUserFavorite.java
@@ -0,0 +1,69 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 用户收藏夹实体
+ */
+@Data
+@TableName("content_user_favorite")
+public class ContentUserFavorite implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 收藏夹ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 收藏夹名称
+ */
+ private String name;
+
+ /**
+ * 收藏夹描述
+ */
+ private String description;
+
+ /**
+ * 是否私有(0:公开,1:私有)
+ */
+ private Integer isPrivate;
+
+ /**
+ * 视频数量
+ */
+ private Integer videoCount;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideo.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideo.java
new file mode 100644
index 0000000..de32edd
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideo.java
@@ -0,0 +1,204 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * 视频信息实体
+ */
+@Data
+@TableName("content_video")
+public class ContentVideo implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 视频ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 视频标题
+ */
+ private String title;
+
+ /**
+ * 视频描述
+ */
+ private String description;
+
+ /**
+ * 封面URL
+ */
+ private String coverUrl;
+
+ /**
+ * 视频URL
+ */
+ private String videoUrl;
+
+ /**
+ * 视频时长(秒)
+ */
+ private Integer duration;
+
+ /**
+ * 视频宽度
+ */
+ private Integer width;
+
+ /**
+ * 视频高度
+ */
+ private Integer height;
+
+ /**
+ * 视频格式
+ */
+ private String format;
+
+ /**
+ * 视频大小(字节)
+ */
+ private Long size;
+
+ /**
+ * 分类ID
+ */
+ private Long categoryId;
+
+ /**
+ * 状态(0:审核中,1:已发布,2:已下架,3:审核不通过)
+ */
+ private Integer status;
+
+ /**
+ * 点赞数
+ */
+ private Integer likeCount;
+
+ /**
+ * 投币数
+ */
+ private Integer coinCount;
+
+ /**
+ * 收藏数
+ */
+ private Integer favoriteCount;
+
+ /**
+ * 评论数
+ */
+ private Integer commentCount;
+
+ /**
+ * 播放数
+ */
+ private Long viewCount;
+
+ /**
+ * 分享数
+ */
+ private Integer shareCount;
+
+ /**
+ * 弹幕数
+ */
+ private Integer danmakuCount;
+
+ /**
+ * 是否推荐(0:否,1:是)
+ */
+ private Integer isRecommend;
+
+ /**
+ * 是否置顶(0:否,1:是)
+ */
+ private Integer isTop;
+
+ /**
+ * 发布时间
+ */
+ private LocalDateTime publishTime;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 更新人
+ */
+ private String updatedBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+
+ /**
+ * 标签ID列表(非数据库字段)
+ */
+ @TableField(exist = false)
+ private List tagIds;
+
+ /**
+ * 标签名称列表(非数据库字段)
+ */
+ @TableField(exist = false)
+ private List tagNames;
+
+ /**
+ * 分类名称(非数据库字段)
+ */
+ @TableField(exist = false)
+ private String categoryName;
+
+ /**
+ * 用户昵称(非数据库字段)
+ */
+ @TableField(exist = false)
+ private String userNickname;
+
+ /**
+ * 用户头像(非数据库字段)
+ */
+ @TableField(exist = false)
+ private String userAvatar;
+
+ /**
+ * 是否已点赞(非数据库字段)
+ */
+ @TableField(exist = false)
+ private Boolean isLiked;
+
+ /**
+ * 是否已收藏(非数据库字段)
+ */
+ @TableField(exist = false)
+ private Boolean isFavorited;
+
+ /**
+ * 是否已投币(非数据库字段)
+ */
+ @TableField(exist = false)
+ private Boolean isCoined;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoCoin.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoCoin.java
new file mode 100644
index 0000000..5578934
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoCoin.java
@@ -0,0 +1,44 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频投币实体
+ */
+@Data
+@TableName("content_video_coin")
+public class ContentVideoCoin implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 投币数量
+ */
+ private Integer amount;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoFavorite.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoFavorite.java
new file mode 100644
index 0000000..d3d91b9
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoFavorite.java
@@ -0,0 +1,44 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频收藏实体
+ */
+@Data
+@TableName("content_video_favorite")
+public class ContentVideoFavorite implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 收藏夹ID
+ */
+ private Long favoriteId;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoLike.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoLike.java
new file mode 100644
index 0000000..804ed0a
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoLike.java
@@ -0,0 +1,39 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频点赞实体
+ */
+@Data
+@TableName("content_video_like")
+public class ContentVideoLike implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoPlayRecord.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoPlayRecord.java
new file mode 100644
index 0000000..6dbc5d6
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoPlayRecord.java
@@ -0,0 +1,54 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频播放记录实体
+ */
+@Data
+@TableName("content_video_play_record")
+public class ContentVideoPlayRecord implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 用户ID
+ */
+ private Long userId;
+
+ /**
+ * 播放时长(秒)
+ */
+ private Integer playTime;
+
+ /**
+ * 是否看完(0:未看完,1:已看完)
+ */
+ private Integer isFinished;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+ /**
+ * 更新时间
+ */
+ private LocalDateTime updateTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoReview.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoReview.java
new file mode 100644
index 0000000..767626a
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoReview.java
@@ -0,0 +1,54 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频审核记录实体
+ */
+@Data
+@TableName("content_video_review")
+public class ContentVideoReview implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 审核员ID
+ */
+ private Long reviewerId;
+
+ /**
+ * 审核状态(1:通过,2:不通过)
+ */
+ private Integer status;
+
+ /**
+ * 审核原因
+ */
+ private String reason;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoStatDaily.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoStatDaily.java
new file mode 100644
index 0000000..fa194db
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoStatDaily.java
@@ -0,0 +1,75 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+/**
+ * 视频每日统计实体
+ */
+@Data
+@TableName("content_video_stat_daily")
+public class ContentVideoStatDaily implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 统计日期
+ */
+ private LocalDate statDate;
+
+ /**
+ * 新增点赞数
+ */
+ private Integer likeIncrement;
+
+ /**
+ * 新增投币数
+ */
+ private Integer coinIncrement;
+
+ /**
+ * 新增收藏数
+ */
+ private Integer favoriteIncrement;
+
+ /**
+ * 新增评论数
+ */
+ private Integer commentIncrement;
+
+ /**
+ * 新增播放数
+ */
+ private Long viewIncrement;
+
+ /**
+ * 新增分享数
+ */
+ private Integer shareIncrement;
+
+ /**
+ * 新增弹幕数
+ */
+ private Integer danmakuIncrement;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoTag.java b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoTag.java
new file mode 100644
index 0000000..e35ba43
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/entity/ContentVideoTag.java
@@ -0,0 +1,44 @@
+package com.nuaa.video.content.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 视频标签关联实体
+ */
+@Data
+@TableName("content_video_tag")
+public class ContentVideoTag implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 主键ID
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Long id;
+
+ /**
+ * 视频ID
+ */
+ private Long videoId;
+
+ /**
+ * 标签ID
+ */
+ private Long tagId;
+
+ /**
+ * 创建人
+ */
+ private String createdBy;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/enums/DanmakuPositionEnum.java b/video-content/src/main/java/com/nuaa/video/content/enums/DanmakuPositionEnum.java
new file mode 100644
index 0000000..704adba
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/enums/DanmakuPositionEnum.java
@@ -0,0 +1,31 @@
+package com.nuaa.video.content.enums;
+
+import lombok.Getter;
+
+/**
+ * 弹幕位置枚举
+ */
+@Getter
+public enum DanmakuPositionEnum {
+
+ ROLLING(0, "滚动"),
+ TOP(1, "顶部"),
+ BOTTOM(2, "底部");
+
+ private final Integer code;
+ private final String desc;
+
+ DanmakuPositionEnum(Integer code, String desc) {
+ this.code = code;
+ this.desc = desc;
+ }
+
+ public static DanmakuPositionEnum getByCode(Integer code) {
+ for (DanmakuPositionEnum positionEnum : values()) {
+ if (positionEnum.getCode().equals(code)) {
+ return positionEnum;
+ }
+ }
+ return ROLLING; // 默认滚动
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/enums/VideoStatusEnum.java b/video-content/src/main/java/com/nuaa/video/content/enums/VideoStatusEnum.java
new file mode 100644
index 0000000..ed7f3d5
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/enums/VideoStatusEnum.java
@@ -0,0 +1,32 @@
+package com.nuaa.video.content.enums;
+
+import lombok.Getter;
+
+/**
+ * 视频状态枚举
+ */
+@Getter
+public enum VideoStatusEnum {
+
+ REVIEWING(0, "审核中"),
+ PUBLISHED(1, "已发布"),
+ DISABLED(2, "已下架"),
+ REJECTED(3, "审核不通过");
+
+ private final Integer code;
+ private final String desc;
+
+ VideoStatusEnum(Integer code, String desc) {
+ this.code = code;
+ this.desc = desc;
+ }
+
+ public static VideoStatusEnum getByCode(Integer code) {
+ for (VideoStatusEnum statusEnum : values()) {
+ if (statusEnum.getCode().equals(code)) {
+ return statusEnum;
+ }
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git a/video-content/src/main/java/com/nuaa/video/content/feign/UserFeignClient.java b/video-content/src/main/java/com/nuaa/video/content/feign/UserFeignClient.java
new file mode 100644
index 0000000..6b18d50
--- /dev/null
+++ b/video-content/src/main/java/com/nuaa/video/content/feign/UserFeignClient.java
@@ -0,0 +1,60 @@
+package com.nuaa.video.content.feign;
+
+import com.nuaa.video.common.model.vo.Result;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestHeader;
+
+/**
+ * 用户服务Feign客户端
+ */
+@FeignClient(name = "video-user", fallbackFactory = UserFeignClientFallbackFactory.class)
+public interface UserFeignClient {
+
+ /**
+ * 获取用户简要信息
+ *
+ * @param userId 用户ID
+ * @return 用户信息
+ */
+ @GetMapping("/user/profile/public/{userId}")
+ Result