NewFeedList

.gitignore

@@ -20,4 +20,8 @@
 # Go workspace file
 go.work
 
-.idea
+.idea
+
+.vscode
+
+log

README.md

@@ -19,4 +19,9 @@ go build && ./simple-demo
 
 ### 测试数据
 
-测试数据写在 demo_data.go 中，用于列表接口的 mock 测试
+测试数据写在 demo_data.go 中，用于列表接口的 mock 测试
+
+### 目录结构说明
+
+- document: 项目相关的一些文档记录
+- model: gorm模型

config/config.yml

@@ -0,0 +1,34 @@
+env:
+    debug: true
+server:
+    port: "8080"
+mysql:
+    local:
+        host: "127.0.0.1"
+        port: "3306"
+        database: "douyin"
+        username: "root"
+        password: "root"
+    default:
+        host: "xinzf0520.top"
+        port: "20607"
+        database: "douyin"
+        username: "dyweadmin"
+        password: "JXU2MTNGJXU5NzUyJXU5Rjk5JXU2MzA3JXU1RjE1JXU0RjYw"
+redis:
+    local:
+        host: "127.0.0.1"
+        port: "6379"
+        password: ""
+    default:
+        host: "xinzf0520.top"
+        port: "20606"
+        password: "JXU2MTNGJXU5NzUyJXU5Rjk5JXU2MzA3JXU1RjE1JXU0RjYw"
+    databases:
+        default: 0
+log:
+    level: "debug"
+    filename: "./log/log.log"
+    max_size: 200
+    max_age: 7
+    max_backups: 10

controller/comment.go

@@ -1,47 +1,68 @@
 package controller
 
 import (
-	"github.com/gin-gonic/gin"
+	"context"
+	"fmt"
 	"net/http"
-)
+	"strconv"
+	"sync"
 
-type CommentListResponse struct {
-	Response
-	CommentList []Comment `json:"comment_list,omitempty"`
-}
-
-type CommentActionResponse struct {
-	Response
-	Comment Comment `json:"comment,omitempty"`
-}
+	"github.com/BaiZe1998/douyin-simple-demo/db/model"
+	"github.com/BaiZe1998/douyin-simple-demo/dto"
+	"github.com/BaiZe1998/douyin-simple-demo/pkg/util"
+	"github.com/BaiZe1998/douyin-simple-demo/service"
+	"github.com/gin-gonic/gin"
+)
 
 // CommentAction no practical effect, just check if token is valid
 func CommentAction(c *gin.Context) {
 	token := c.Query("token")
 	actionType := c.Query("action_type")
-
-	if user, exist := usersLoginInfo[token]; exist {
+	videoId, _ := strconv.ParseInt(c.Query("video_id"), 10, 64)
+	userClaims, _ := util.ParseToken(token)
+	userModel, _ := model.QueryUserById(context.Background(), userClaims.ID)
+	users := dto.User{
+		Id:            userModel.ID,
+		Name:          userModel.Name,
+		FollowCount:   userModel.FollowCount,
+		FollowerCount: userModel.FollowerCount,
+		IsFollow:      false,
+	}
+	if userModel.ID > 0 {
 		if actionType == "1" {
 			text := c.Query("comment_text")
-			c.JSON(http.StatusOK, CommentActionResponse{Response: Response{StatusCode: 0},
-				Comment: Comment{
-					Id:         1,
-					User:       user,
-					Content:    text,
-					CreateDate: "05-01",
-				}})
-			return
+			//comment addcomment
+			responseComment := service.AddComment(text, users, videoId)
+			c.JSON(http.StatusOK,
+				dto.CommentActionResponse{
+					Response: dto.Response{StatusCode: 0},
+					Comment:  responseComment,
+				})
+		} else {
+			commentId, _ := strconv.ParseInt(c.Query("comment_id"), 10, 64)
+			//comment delete
+			model.DeleteCommnet(context.Background(), videoId, commentId)
+
+			c.JSON(http.StatusOK, Response{StatusCode: 0})
 		}
-		c.JSON(http.StatusOK, Response{StatusCode: 0})
+		var wg sync.WaitGroup
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+			service.UpdatCacheCommentList(context.Background(), videoId, 10, 0)
+		}()
 	} else {
 		c.JSON(http.StatusOK, Response{StatusCode: 1, StatusMsg: "User doesn't exist"})
 	}
 }
 
 // CommentList all videos have same demo comment list
 func CommentList(c *gin.Context) {
-	c.JSON(http.StatusOK, CommentListResponse{
-		Response:    Response{StatusCode: 0},
-		CommentList: DemoComments,
+	videoId, _ := strconv.ParseInt(c.Query("video_id"), 10, 64)
+	res, total, _ := service.GetCacheCommentList(context.Background(), videoId, 10, 0)
+	c.JSON(http.StatusOK, dto.CommentListResponse{
+		Response:    dto.Response{StatusCode: 0, StatusMsg: ""},
+		CommentList: res,
 	})
+	fmt.Println(total)
 }

controller/common.go

@@ -1,29 +1,32 @@
 package controller
 
+import "github.com/BaiZe1998/douyin-simple-demo/dto"
+
 type Response struct {
 	StatusCode int32  `json:"status_code"`
 	StatusMsg  string `json:"status_msg,omitempty"`
+	NextTime   int64  `json:"next_time,omitempty"`
 }
 
 type Video struct {
-	Id            int64  `json:"id,omitempty"`
-	Author        User   `json:"author"`
-	PlayUrl       string `json:"play_url" json:"play_url,omitempty"`
-	CoverUrl      string `json:"cover_url,omitempty"`
-	FavoriteCount int64  `json:"favorite_count,omitempty"`
-	CommentCount  int64  `json:"comment_count,omitempty"`
-	IsFavorite    bool   `json:"is_favorite,omitempty"`
+	Id            int64    `json:"id,omitempty"`
+	Author        dto.User `json:"author"`
+	PlayUrl       string   `json:"play_url" json:"play_url,omitempty"`
+	CoverUrl      string   `json:"cover_url,omitempty"`
+	FavoriteCount int64    `json:"favorite_count,omitempty"`
+	CommentCount  int64    `json:"comment_count,omitempty"`
+	IsFavorite    bool     `json:"is_favorite,omitempty"`
 }
 
 type Comment struct {
-	Id         int64  `json:"id,omitempty"`
-	User       User   `json:"user"`
-	Content    string `json:"content,omitempty"`
-	CreateDate string `json:"create_date,omitempty"`
+	Id         int64    `json:"id,omitempty"`
+	User       dto.User `json:"dto.user"`
+	Content    string   `json:"content,omitempty"`
+	CreateDate string   `json:"create_date,omitempty"`
 }
 
 type User struct {
-	Id            int64  `json:"id,omitempty"`
+	Id            string `json:"id,omitempty"`
 	Name          string `json:"name,omitempty"`
 	FollowCount   int64  `json:"follow_count,omitempty"`
 	FollowerCount int64  `json:"follower_count,omitempty"`

controller/demo_data.go

@@ -1,30 +1,45 @@
 package controller
 
-var DemoVideos = []Video{
+import "github.com/BaiZe1998/douyin-simple-demo/dto"
+
+var DemoVideos = []dto.Video{
 	{
 		Id:            1,
-		Author:        DemoUser,
-		PlayUrl:       "https://www.w3schools.com/html/movie.mp4",
+		Author:        DemoUser1,
+		PlayUrl:       "http://niuyefan.oss-cn-beijing.aliyuncs.com/douyin/bear.mp4",
 		CoverUrl:      "https://cdn.pixabay.com/photo/2016/03/27/18/10/bear-1283347_1280.jpg",
-		FavoriteCount: 0,
-		CommentCount:  0,
+		FavoriteCount: 2,
+		CommentCount:  2,
 		IsFavorite:    false,
 	},
 }
 
-var DemoComments = []Comment{
-	{
-		Id:         1,
-		User:       DemoUser,
-		Content:    "Test Comment",
-		CreateDate: "05-01",
-	},
-}
+// var DemoComments = []Comment{
+// 	{
+// 		Id:         1,
+// 		User:       DemoUser1,
+// 		Content:    "Test Comment",
+// 		CreateDate: "05-01",
+// 	},
+// 	{
+// 		Id:         2,
+// 		User:       DemoUser1,
+// 		Content:    "Test Commen22",
+// 		CreateDate: "05-012",
+// 	},
+// }
 
-var DemoUser = User{
+var DemoUser1 = dto.User{
 	Id:            1,
 	Name:          "TestUser",
 	FollowCount:   0,
 	FollowerCount: 0,
 	IsFollow:      false,
 }
+var DemoUser = User{
+	Id:            "1",
+	Name:          "TestUser",
+	FollowCount:   0,
+	FollowerCount: 0,
+	IsFollow:      false,
+}

controller/favorite.go

@@ -1,27 +1,42 @@
 package controller
 
 import (
+	"github.com/BaiZe1998/douyin-simple-demo/dto"
+	"github.com/BaiZe1998/douyin-simple-demo/service"
 	"github.com/gin-gonic/gin"
 	"net/http"
+	"strconv"
 )
 
 // FavoriteAction no practical effect, just check if token is valid
 func FavoriteAction(c *gin.Context) {
-	token := c.Query("token")
-
-	if _, exist := usersLoginInfo[token]; exist {
-		c.JSON(http.StatusOK, Response{StatusCode: 0})
-	} else {
-		c.JSON(http.StatusOK, Response{StatusCode: 1, StatusMsg: "User doesn't exist"})
+	UserIdFromC, _ := c.Get("user_id")
+	UserID, _ := UserIdFromC.(int64)
+	VideoID, _ := strconv.ParseInt(c.Query("video_id"), 10, 64)
+	actionType, _ := strconv.ParseInt(c.Query("action_type"), 10, 64)
+	if err := service.FavoriteAction(c, UserID, VideoID, int(actionType)); err != nil {
+		c.JSON(http.StatusBadRequest, dto.Response{
+			StatusCode: 1,
+			StatusMsg:  err.Error(),
+		})
 	}
+	c.JSON(http.StatusOK, VideoListResponse{
+		Response: Response{
+			StatusCode: 0,
+			StatusMsg:  "操作成功",
+		},
+	})
 }
 
 // FavoriteList all users have same favorite video list
 func FavoriteList(c *gin.Context) {
+	UserIdFromC, _ := c.Get("user_id")
+	UserID, _ := UserIdFromC.(int64)
+	videoList, _ := service.GetFavoriteList(c, UserID)
 	c.JSON(http.StatusOK, VideoListResponse{
 		Response: Response{
 			StatusCode: 0,
 		},
-		VideoList: DemoVideos,
+		VideoList: videoList,
 	})
 }

controller/feed.go

@@ -1,22 +1,33 @@
 package controller
 
 import (
-	"github.com/gin-gonic/gin"
+	"log"
 	"net/http"
-	"time"
-)
 
-type FeedResponse struct {
-	Response
-	VideoList []Video `json:"video_list,omitempty"`
-	NextTime  int64   `json:"next_time,omitempty"`
-}
+	"github.com/BaiZe1998/douyin-simple-demo/dto"
+	"github.com/BaiZe1998/douyin-simple-demo/pkg/util"
+	"github.com/BaiZe1998/douyin-simple-demo/service"
+	"github.com/gin-gonic/gin"
+)
 
 // Feed same demo video list for every request
 func Feed(c *gin.Context) {
-	c.JSON(http.StatusOK, FeedResponse{
-		Response:  Response{StatusCode: 0},
-		VideoList: DemoVideos,
-		NextTime:  time.Now().Unix(),
+	lastTime := c.Query("latest_time")
+	token := c.Query("token")
+	userInfo, parseTokenErr := util.ParseToken(token)
+
+	if parseTokenErr != nil {
+		dto.WriteLog(
+			"error", "解析token错误",
+		)
+	}
+
+	videoList, reTime := service.QueryFeedResponse1(userInfo.ID, lastTime)
+	log.Println(reTime.Unix())
+	c.JSON(http.StatusOK, dto.FeedResponse{
+		Response: dto.Response{StatusCode: 0,
+			StatusMsg: "",
+			NextTime:  reTime.Unix()},
+		VideoList: videoList,
 	})
 }