ABYSMILER

.gitignore

@@ -18,6 +18,8 @@
 # vendor/
 
 # Go workspace file
-go.work
+**/go.work
+**/go.sum
 
-.idea
+# goland IDE file
+**/.idea/

Go-Project/.gitignore

@@ -0,0 +1,2 @@
+# video files
+/public/

Go-Project/config.yaml

@@ -0,0 +1,9 @@
+mysql:
+  path: 47.113.185.186
+  port: 3306
+  config: charset=utf8&parseTime=True&loc=Local
+  db-name: douyin_simple
+  username: root
+  password: 11LvmIa1wz2tMI5P
+  max-idle-conns: 10
+  max-open-conns: 100

Go-Project/config/config.go

@@ -0,0 +1,6 @@
+package config
+
+type Server struct {
+	Mysql Mysql `mapstructure:"mysql" yaml:"mysql"`
+	//接下来Redis这些也在这相似地定义
+}

Go-Project/config/mysql.go

@@ -0,0 +1,16 @@
+package config
+
+type Mysql struct {
+	Path         string `mapstructure:"path" yaml:"path"`                     // 服务器地址
+	Port         string `mapstructure:"port" yaml:"port"`                     // 端口
+	Config       string `mapstructure:"config" yaml:"config"`                 // 高级配置
+	Dbname       string `mapstructure:"db-name" yaml:"db-name"`               // 数据库名
+	Username     string `mapstructure:"username" yaml:"username"`             // 数据库用户名
+	Password     string `mapstructure:"password" yaml:"password"`             // 数据库密码
+	MaxIdleConns int    `mapstructure:"max-idle-conns" yaml:"max-idle-conns"` // 空闲中的最大连接数
+	MaxOpenConns int    `mapstructure:"max-open-conns" yaml:"max-open-conns"` // 打开到数据库的最大连接数
+}
+
+func (m *Mysql) Dsn() string {
+	return m.Username + ":" + m.Password + "@tcp(" + m.Path + ":" + m.Port + ")/" + m.Dbname + "?" + m.Config
+}

Go-Project/controller/comment.go

@@ -0,0 +1,75 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"github.com/life-studied/douyin-simple/response"
+	"github.com/life-studied/douyin-simple/service"
+	"net/http"
+	"strconv"
+)
+
+// CommentAction no practical effect, just check if token is valid
+func CommentAction(c *gin.Context) {
+	// 获取请求参数
+	videoID, err := strconv.ParseInt(c.Query("video_id"), 10, 64)
+	if err != nil {
+		// 处理videoID解析错误
+		c.JSON(http.StatusBadRequest, response.CommentActionResponse{
+			Response: response.Response{StatusCode: http.StatusBadRequest, StatusMsg: "无效的video_id"},
+		})
+		return
+	}
+	actionType := c.Query("action_type")
+	commentText := c.Query("comment_text")
+
+	token := c.Query("token")
+	user, exists := usersLoginInfo[token]
+	if !exists {
+		c.JSON(http.StatusBadRequest, response.CommentActionResponse{
+			Response: response.Response{StatusCode: http.StatusBadRequest, StatusMsg: "无效的token"},
+		})
+		return
+	}
+	userID := user.Id
+
+	// 判断操作类型
+	if actionType == "1" {
+		commentActionResponse, _ := service.CreateComment(userID, videoID, commentText)
+		c.JSON(http.StatusOK, commentActionResponse)
+
+	} else if actionType == "2" {
+		commentID, err := strconv.ParseInt(c.Query("comment_id"), 10, 64)
+		if err != nil {
+			// 处理commentID解析错误
+			c.JSON(http.StatusBadRequest, response.CommentActionResponse{
+				Response: response.Response{StatusCode: http.StatusBadRequest, StatusMsg: "无效的comment_id"},
+			})
+			return
+		}
+		commentActionResponse, _ := service.DeleteComment(userID, videoID, commentID)
+		c.JSON(http.StatusOK, commentActionResponse)
+	}
+
+	return
+}
+
+func CommentList(c *gin.Context) {
+	videoID, err := strconv.ParseInt(c.Query("video_id"), 10, 64)
+	if err != nil {
+		// 处理videoID解析错误
+		c.JSON(http.StatusBadRequest, response.CommentActionResponse{
+			Response: response.Response{StatusCode: http.StatusBadRequest, StatusMsg: "无效的video_id"},
+		})
+		return
+	}
+
+	// 将获取到的评论添加到commentList列表中
+
+	comments, err := service.GetCommentList(videoID)
+	// 返回response
+	c.JSON(http.StatusOK, response.CommentListResponse{
+		Response:    response.Response{StatusCode: 0, StatusMsg: "OK"},
+		CommentList: comments,
+	})
+	return
+}

controller/common.go → Go-Project/controller/common.go

@@ -17,7 +17,7 @@ type Video struct {
 
 type Comment struct {
 	Id         int64  `json:"id,omitempty"`
-	User       User   `json:"user"`
+	User       User   `json:"user" gorm:"foreignKey:user_id;references:id;"`
 	Content    string `json:"content,omitempty"`
 	CreateDate string `json:"create_date,omitempty"`
 }

Go-Project/controller/demo_data.go

@@ -0,0 +1,12 @@
+package controller
+
+var DemoVideos []Video
+
+var DemoComments = []Comment{
+	{
+		Id:         1,
+		User:       usersLoginInfo["user_1password_1"],
+		Content:    "Test Comment",
+		CreateDate: "05-01",
+	},
+}

Go-Project/controller/favorite.go

@@ -0,0 +1,156 @@
+package controller
+
+import (
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"github.com/life-studied/douyin-simple/service"
+	"net/http"
+)
+
+// FavoriteAction no practical effect, just check if token is valid
+func FavoriteAction(c *gin.Context) {
+	//接收参数，并判断是否合法
+	token, tokenOk := c.GetQuery("token")
+	if !tokenOk {
+		c.JSON(http.StatusBadRequest, Response{StatusCode: 400, StatusMsg: "Lack of token"})
+		return
+	}
+	userFromToken, exist := usersLoginInfo[token]
+	if !exist {
+		c.JSON(http.StatusUnprocessableEntity, Response{StatusCode: 422, StatusMsg: "Token is invalid"})
+		return
+	}
+
+	videoId, videoIdOk := c.GetQuery("video_id")
+	if !videoIdOk {
+		c.JSON(http.StatusBadRequest, Response{StatusCode: 400, StatusMsg: "Lack of video_id"})
+		return
+	}
+	actionType, actionTypeOk := c.GetQuery("action_type")
+	if !actionTypeOk {
+		c.JSON(http.StatusBadRequest, Response{StatusCode: 400, StatusMsg: "Lack of action_type"})
+		return
+	}
+
+	//判断操作类型
+	var video = service.FavoriteVideoID{
+		VideoID: videoId,
+	}
+	var user = service.FavoriteUserID{
+		UserID:   userFromToken.Id,
+		UserName: userFromToken.Name,
+	}
+	if actionType == "1" {
+		err := service.FavoriteVideo(video, user)
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, Response{StatusCode: 500, StatusMsg: "Favorite failed"})
+			//打印报错
+			fmt.Printf("\033[1;37;41m%s\033[0m\n", "|BUG | "+err.Error()+"form Favorite")
+			return
+		}
+
+	} else if actionType == "2" {
+		err := service.UnfavoriteVideo(video, user)
+		if err != nil {
+			c.JSON(http.StatusInternalServerError, Response{StatusCode: 500, StatusMsg: "Unfavorite failed"})
+			//打印报错
+			fmt.Printf("\033[1;37;41m%s\033[0m\n", "|BUG | "+err.Error()+"form Favorite")
+			return
+		}
+	} else {
+		c.JSON(http.StatusUnprocessableEntity, Response{StatusCode: 422, StatusMsg: "Invalid action_type"})
+		return
+	}
+	c.JSON(http.StatusOK, Response{StatusCode: 0, StatusMsg: "Success"})
+}
+
+// FavoriteList all users have same favorite video list
+func FavoriteList(c *gin.Context) {
+	//接收参数，并判断是否合法
+	token, tokenOk := c.GetQuery("token")
+	if !tokenOk {
+		c.JSON(http.StatusBadRequest, VideoListResponse{
+			Response: Response{
+				StatusCode: 400,
+				StatusMsg:  "Lack of token",
+			},
+			VideoList: nil,
+		})
+		return
+	}
+	//检测token
+	userFromToken, exist := usersLoginInfo[token]
+	if !exist {
+		c.JSON(http.StatusUnprocessableEntity, VideoListResponse{
+			Response: Response{
+				StatusCode: 422,
+				StatusMsg:  "Token is invalid",
+			},
+			VideoList: nil,
+		})
+		return
+	}
+	//转为service层使用的结构体类型
+	user := service.FavoriteUserID{
+		UserID:   userFromToken.Id,
+		UserName: userFromToken.Name,
+	}
+	//用不到但是必须要有的接收参数
+	_, userIdOk := c.GetQuery("user_id")
+	if !userIdOk {
+		c.JSON(http.StatusBadRequest, VideoListResponse{
+			Response: Response{
+				StatusCode: 400,
+				StatusMsg:  "Lack of user_id",
+			},
+			VideoList: nil,
+		})
+		return
+	}
+	//获取用户收藏的视频列表
+	videoList, err := service.ReadFavoriteVideo(user)
+	if err != nil {
+		fmt.Printf("\033[1;37;41m%s\033[0m\n", "| BUG | "+err.Error()+"form Favorite")
+		c.JSON(http.StatusInternalServerError, VideoListResponse{
+			Response: Response{
+				StatusCode: 500,
+				StatusMsg:  "Internal server error",
+			},
+			VideoList: nil,
+		})
+		return
+	}
+	//转为前端需要的结构体类型
+	c.JSON(http.StatusOK, serviceToVideoList(videoList))
+}
+
+func serviceToVideoList(favoriteVideoList []service.FavoriteVideoList) (response VideoListResponse) {
+
+	response.Response = Response{
+		StatusCode: 0,
+		StatusMsg:  "Success",
+	}
+	response.VideoList = make([]Video, 0, len(favoriteVideoList))
+	for _, favoriteVideo := range favoriteVideoList {
+		response.VideoList = append(response.VideoList, Video{
+			Id:            favoriteVideo.Id,
+			Author:        serviceToUser(favoriteVideo.Author),
+			PlayUrl:       favoriteVideo.PlayUrl,
+			CoverUrl:      favoriteVideo.CoverUrl,
+			FavoriteCount: favoriteVideo.FavoriteCount,
+			CommentCount:  favoriteVideo.CommentCount,
+			IsFavorite:    true,
+		})
+	}
+	return response
+}
+
+func serviceToUser(favoriteUser service.FavoriteUserID) (user User) {
+	user = User{
+		Id:            favoriteUser.UserID,
+		Name:          favoriteUser.UserName,
+		FollowCount:   favoriteUser.FollowCount,
+		FollowerCount: favoriteUser.FollowerCount,
+	}
+	return user
+}

Go-Project/controller/feed.go

@@ -0,0 +1,37 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"github.com/life-studied/douyin-simple/service"
+	"net/http"
+)
+
+type FeedResponse struct {
+	Response
+	VideoList []Video `json:"video_list,omitempty"`
+	NextTime  int64   `json:"next_time,omitempty"`
+}
+
+// Feed same demo video list for every request
+func Feed(c *gin.Context) {
+	strLatestTime, exists := c.GetQuery("latest_time")
+	if !exists {
+		c.JSON(http.StatusBadRequest, FeedResponse{Response: Response{StatusCode: 1, StatusMsg: "latest_time is empty"}})
+		return
+	}
+	nextTime, startId, err := service.GetNextTime(strLatestTime)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, FeedResponse{Response: Response{StatusCode: 1, StatusMsg: err.Error()}})
+		return
+	}
+	var endId int64
+	if startId+30 > int64(len(DemoVideos)) {
+		endId = int64(len(DemoVideos))
+	} else {
+		endId = startId + 30
+	}
+	c.JSON(http.StatusOK, FeedResponse{Response: Response{StatusCode: 0},
+		VideoList: DemoVideos[startId:endId],
+		NextTime:  nextTime,
+	})
+}