feat: 支持用户操作日志记录

Author: DokiDoki1103

internal/api/router.go

@@ -32,9 +32,12 @@ func SetAPIRouter(router *gin.Engine) {
 	apiRouter.DELETE("/questions/:id", controller.DeleteQuestion)
 
 	apiRouter.GET("/user/login", controller.UserLogin)                    // 登录接口
+	apiRouter.GET("/user", controller.Auth, controller.UserList)          // 自己创建的用户列表
 	apiRouter.POST("/user", controller.Auth, controller.CreateUser)       // 创建用户
 	apiRouter.DELETE("/user/:id", controller.Auth, controller.DeleteUser) // 删除用户
 
+	apiRouter.GET("/logs", controller.LogList) // 删除用户
+
 }
 
 type embedFileSystem struct {

internal/controller/logs.go

@@ -0,0 +1,18 @@
+package controller
+
+import (
+	"github.com/gin-gonic/gin"
+	"github.com/itihey/tikuAdapter/internal/dao"
+)
+
+func LogList(c *gin.Context) {
+	find, err := dao.Log.Where(dao.Log.UserID.Eq(0)).Find()
+	if err != nil {
+		c.JSON(400, gin.H{
+			"message": "参数错误",
+		})
+		return
+	}
+	c.JSON(200, find)
+
+}

internal/controller/tiku.go

@@ -1,13 +1,16 @@
 package controller
 
 import (
+	"encoding/json"
 	"github.com/gin-gonic/gin"
 	"github.com/itihey/tikuAdapter/internal/dao"
 	"github.com/itihey/tikuAdapter/internal/entity"
 	"github.com/itihey/tikuAdapter/internal/middleware"
+	"github.com/itihey/tikuAdapter/pkg/logger"
 	"github.com/itihey/tikuAdapter/pkg/util"
 	"net/http"
 	"strconv"
+	"time"
 )
 
 // Page 分页
@@ -100,13 +103,27 @@ func UpdateQuestions(c *gin.Context) {
 		})
 		return
 	}
+	// 找到旧答案
+	oldTiku, err := dao.Tiku.Where(dao.Tiku.ID.Eq(int32(id))).First()
+
 	updates, err := dao.Tiku.Where(dao.Tiku.ID.Eq(int32(id))).Updates(tiku)
 	if err != nil {
 		c.JSON(500, gin.H{
 			"message": "服务器错误",
 		})
 		return
 	}
+	if updates.RowsAffected == 1 {
+		l := entity.Log{
+			Qid:        oldTiku.ID,
+			Action:     1,
+			UserID:     0,
+			CreateTime: time.Now(),
+			OldAnswer:  oldTiku.Answer,
+			NewAnswer:  tiku.Answer,
+		}
+		dao.Log.Create(&l)
+	}
 	c.JSON(200, gin.H{
 		"data": updates,
 	})
@@ -121,6 +138,19 @@ func DeleteQuestion(c *gin.Context) {
 		})
 		return
 	}
+
+	// 记录删除日志
+	oldTiku, err := dao.Tiku.Where(dao.Tiku.ID.Eq(int32(id))).First()
+	marshal, _ := json.Marshal(oldTiku)
+	l := entity.Log{
+		Qid:        oldTiku.ID,
+		Action:     2,
+		UserID:     0,
+		CreateTime: time.Now(),
+		OldAnswer:  string(marshal),
+	}
+	dao.Log.Create(&l)
+
 	dao.Tiku.Where(dao.Tiku.ID.Eq(int32(id))).Delete()
 	c.JSON(200, gin.H{
 		"message": "删除成功",
@@ -143,6 +173,18 @@ func CreateQuestion(c *gin.Context) {
 		middleware.FillHash(t)
 		err := dao.Tiku.Create(t)
 		if err == nil {
+			marshal, _ := json.Marshal(t)
+			l := entity.Log{
+				Qid:        t.ID,
+				Action:     0,
+				UserID:     0,
+				CreateTime: time.Now(),
+				OldAnswer:  string(marshal),
+			}
+			err := dao.Log.Create(&l)
+			if err != nil {
+				logger.SysError(err.Error())
+			}
 			count++
 		}
 	}
@@ -153,7 +195,6 @@ func CreateQuestion(c *gin.Context) {
 
 // Courses 获取这个平台的所有课程名称
 func Courses(c *gin.Context) {
-
 	tx := dao.Tiku.Select(dao.Tiku.CourseName)
 
 	if c.Query("plat") != "" {

internal/controller/user.go

@@ -80,6 +80,19 @@ func UserLogin(c *gin.Context) {
 	}
 }
 
+// UserList 自己开通的用户的列表
+func UserList(c *gin.Context) {
+	parent, _ := c.Get(`user`)
+	users, err := dao.User.Where(dao.User.ParentID.Eq(parent.(*entity.User).ID)).Find()
+	if err != nil {
+		c.JSON(400, gin.H{
+			"message": "获取用户列表失败",
+		})
+		return
+	}
+	c.JSON(200, users)
+}
+
 // CreateUser 创建用户
 func CreateUser(c *gin.Context) {
 	parent, _ := c.Get(`user`)
@@ -94,6 +107,15 @@ func CreateUser(c *gin.Context) {
 		return
 	}
 
+	// 检测用户名是否被使用
+	_, err = dao.User.Where(dao.User.Username.Eq(user.Username)).First()
+	if err == nil {
+		c.JSON(400, gin.H{
+			"message": "用户名已经被使用",
+		})
+		return
+	}
+
 	user.ParentID = parent.(*entity.User).ID
 
 	err = dao.User.Create(&user)