From 05c846c295738cea4f7465a10cd6f16f779e4805 Mon Sep 17 00:00:00 2001
From: Amnesia <7299924@qq.com>
Date: Sat, 14 Mar 2026 19:56:31 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E5=91=BD=E5=90=8D?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/internal/feed/service.go                   | 2 +-
 backend/internal/middleware/rabbitmq/rabbitMQ.go   | 6 +++---
 backend/internal/middleware/rabbitmq/timelineMQ.go | 6 +++---
 backend/internal/video/video_service.go            | 4 ++--
 4 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/backend/internal/feed/service.go b/backend/internal/feed/service.go
index 24aac3c..95e6939 100644
--- a/backend/internal/feed/service.go
+++ b/backend/internal/feed/service.go
@@ -539,7 +539,7 @@ func (f *FeedService) buildFeedVideos(ctx context.Context, videos []*video.Video
 func buildOrderedResult(orderedIDs []uint, dataMap map[uint]*video.Video) []*video.Video {
 	res := make([]*video.Video, 0, len(orderedIDs))
 	for _, id := range orderedIDs {
-		if v, exit := dataMap[id]; exit && v != nil {
+		if v, exits := dataMap[id]; exits && v != nil {
 			res = append(res, v)
 		}
 	}
diff --git a/backend/internal/middleware/rabbitmq/rabbitMQ.go b/backend/internal/middleware/rabbitmq/rabbitMQ.go
index 5647835..b4a715e 100644
--- a/backend/internal/middleware/rabbitmq/rabbitMQ.go
+++ b/backend/internal/middleware/rabbitmq/rabbitMQ.go
@@ -23,15 +23,15 @@ func NewRabbitMQ(cfg *config.RabbitMQConfig) (*RabbitMQ, error) {
 		return nil, errors.New("rabbitmq config is nil")
 	}
 	url := "amqp://" + cfg.Username + ":" + cfg.Password + "@" + cfg.Host + ":" + strconv.Itoa(cfg.Port) + "/"
-	Conn, err := amqp.Dial(url)
+	conn, err := amqp.Dial(url)
 	if err != nil {
 		return nil, err
 	}
-	Ch, err := Conn.Channel()
+	ch, err := conn.Channel()
 	if err != nil {
 		return nil, err
 	}
-	return &RabbitMQ{Conn: Conn, Ch: Ch}, nil
+	return &RabbitMQ{Conn: conn, Ch: ch}, nil
 }
 
 func (r *RabbitMQ) Close() error {
diff --git a/backend/internal/middleware/rabbitmq/timelineMQ.go b/backend/internal/middleware/rabbitmq/timelineMQ.go
index 6060623..898ed0a 100644
--- a/backend/internal/middleware/rabbitmq/timelineMQ.go
+++ b/backend/internal/middleware/rabbitmq/timelineMQ.go
@@ -19,7 +19,7 @@ const (
 
 type TimelineEvent struct {
 	EventID    string    `json:"event_id"`
-	ViedoID    uint      `json:"video_id"`
+	VideoID    uint      `json:"video_id"`
 	CreateTime int64     `json:"create_time"`
 	OccurredAt time.Time `json:"occurred_at"`
 }
@@ -36,7 +36,7 @@ func NewTimelineMQ(base *RabbitMQ) (*TimelineMQ, error) {
 
 func (t *TimelineMQ) PublishVideo(ctx context.Context, videoID uint, createTime time.Time) error {
 	if t == nil || t.RabbitMQ == nil {
-		return errors.New("timelike mq is not initialized")
+		return errors.New("timeline mq is not initialized")
 	}
 	if videoID == 0 {
 		return errors.New("videoID are required")
@@ -47,7 +47,7 @@ func (t *TimelineMQ) PublishVideo(ctx context.Context, videoID uint, createTime
 	}
 	timeline := TimelineEvent{
 		EventID:    id,
-		ViedoID:    videoID,
+		VideoID:    videoID,
 		CreateTime: createTime.UnixMilli(),
 		OccurredAt: time.Now(),
 	}
diff --git a/backend/internal/video/video_service.go b/backend/internal/video/video_service.go
index b9be9ef..92eba9a 100644
--- a/backend/internal/video/video_service.go
+++ b/backend/internal/video/video_service.go
@@ -50,14 +50,14 @@ func (vs *VideoService) Publish(ctx context.Context, video *Video) error {
 			return err
 		}
 
-		Msg := OutboxMsg{
+		msg := OutboxMsg{
 			VideoID:    video.ID,
 			EventType:  "video_published",
 			Status:     "pending",
 			CreateTime: video.CreateTime,
 		}
 
-		if err := tx.Create(Msg).Error; err != nil {
+		if err := tx.Create(&msg).Error; err != nil {
 			return err
 		}
 		return nil