fix

Author: spiritysdx

server/internal/services/danmaku_burn.go

@@ -8,6 +8,7 @@ import (
 	"os/exec"
 	"path/filepath"
 	"strings"
+	"sync"
 	"time"
 
 	"github.com/gobup/server/internal/database"
@@ -25,6 +26,11 @@ const (
 	DanmakuFontsDir = "/usr/share/fonts"
 )
 
+// burningSourceParts 内存级防重入锁：防止同一源分P被多个 goroutine 并发烧录。
+// 键为源分P的数据库 ID（uint），值恒为 true。
+// 适用场景：Path A（上传完成实时触发）和 Path B/C（定时回补/启动恢复）同时调用 BurnDanmakuToVideo。
+var burningSourceParts sync.Map
+
 // DanmakuBurnService 弹幕烧录服务
 type DanmakuBurnService struct{}
 
@@ -35,6 +41,12 @@ func NewDanmakuBurnService() *DanmakuBurnService {
 // BurnDanmakuToVideo 将弹幕烧录到视频文件
 // 返回：生成的带弹幕视频路径，错误
 func (s *DanmakuBurnService) BurnDanmakuToVideo(part *models.RecordHistoryPart, history *models.RecordHistory, room *models.RecordRoom) (string, error) {
+	// 内存级防重入：阻止同一源分P被并发烧录（解决 Path A 与 Path B/C 的 TOCTOU 竞争）
+	if _, loaded := burningSourceParts.LoadOrStore(part.ID, true); loaded {
+		return "", fmt.Errorf("[弹幕烧录] 源分P %d 正在烧录中，本次调用跳过（已有并发任务持有锁）", part.ID)
+	}
+	defer burningSourceParts.Delete(part.ID)
+
 	db := database.GetDB()
 
 	// 检查源视频文件是否存在

server/internal/upload/publish.go

@@ -377,6 +377,18 @@ func (s *Service) PublishHistory(historyID uint, userID uint) error {
 	// 注意：投稿后不修改UploadStatus，保持为2（已上传）
 	db.Save(&history)
 
+	// 如果弹幕烧录功能已开启，标记此次一起投稿的弹幕版分P 为 appended_to_video=true。
+	// 防止 AppendDanmakuBurnedPartsToApprovedVideos 定时任务在审核通过后再次追加已经包含在初始投稿里的弹幕版分P。
+	if room.EnableDanmakuBurn {
+		affected := db.Model(&models.RecordHistoryPart{}).Where(
+			"history_id = ? AND is_temp_file = ? AND temp_file_type = ? AND upload = ?",
+			historyID, true, "danmaku_burn", true,
+		).Update("appended_to_video", true)
+		if affected.RowsAffected > 0 {
+			log.Printf("[投稿成功] 已标记 %d 个弹幕版分P 为 appended_to_video=true (history_id=%d)", affected.RowsAffected, historyID)
+		}
+	}
+
 	log.Printf("投稿成功: AV%d, BV%s", avID, bvid)
 
 	// 兜底检测机制：使用新的API验证投稿是否真的成功
@@ -723,6 +735,14 @@ func (s *Service) AppendPartsToExisting(newHistoryID uint, existingHistory *mode
 // UpdatePublishedVideoWithBurnedParts 回补更新已投稿视频，追加弹幕版分P
 // 当弹幕版分P上传完成后，检查对应的历史记录是否已投稿，如果已投稿且没有弹幕版，则追加弹幕版分P
 func (s *Service) UpdatePublishedVideoWithBurnedParts(burnedPartID uint) error {
+	// 内存级防重入：防止 Path A（上传完成立即调用）与 Path B/C（定时任务发现 appended_to_video=false）并发调用
+	// 导致同一弹幕版分P 在 B 站视频里出现两次
+	if _, loaded := s.appendingBurnedParts.LoadOrStore(burnedPartID, true); loaded {
+		log.Printf("[回补弹幕版] 烧录版分P %d 正在追加中，跳过并发调用", burnedPartID)
+		return nil
+	}
+	defer s.appendingBurnedParts.Delete(burnedPartID)
+
 	db := database.GetDB()
 
 	// 获取弹幕版分P

server/internal/upload/service.go

@@ -21,12 +21,13 @@ const (
 )
 
 type Service struct {
-	uploadingParts      sync.Map // partID -> true，防止同一分P并发上传
-	publishingHistories sync.Map // historyID -> true，防止同一历史记录并发投稿
-	wxPusher            *services.WxPusherService
-	templateSvc         *services.TemplateService
-	progressTracker     *ProgressTracker
-	queueManager        *QueueManager
+	uploadingParts       sync.Map // partID -> true，防止同一分P并发上传
+	publishingHistories  sync.Map // historyID -> true，防止同一历史记录并发投稿
+	appendingBurnedParts sync.Map // burnedPartID -> true，防止同一烧录版分P并发调用 EditVideo
+	wxPusher             *services.WxPusherService
+	templateSvc          *services.TemplateService
+	progressTracker      *ProgressTracker
+	queueManager         *QueueManager
 }
 
 func NewService() *Service {