Merge branch 'dev' of http://gitea.tools.fontree.cn:3000/fiee/fonchain-fiee into dev

pkg/service/bundle/bundleBalance.go

@@ -314,6 +314,15 @@ func WorkAnalysisConfirm(c *gin.Context) { // 确认数据分析并扣除余量
 		service.Error(c, errors.New(common.UpdateWorkStatusFailed))
 		return
 	}
+	// 如果是艺人手动确认，确认操作后，自动标记为待阅读状态
+	_, err = service.CastProvider.UpdateWorkAnalysisStatus(c, &cast.UpdateWorkAnalysisStatusReq{
+		WorkAction: cast.WorkActionENUM_READ,
+		Uuid:       req.Uuid,
+	})
+	if err != nil {
+		service.Error(c, errors.New(common.UpdateWorkStatusFailed))
+		return
+	}
 	service.Success(c, res)
 }
 

pkg/service/cast/analysis.go

@@ -75,18 +75,6 @@ func UpdateWorkAnalysisStatus(ctx *gin.Context) {
 		service.Error(ctx, err)
 		return
 	}
-	// 如果是艺人手动确认，确认操作后，自动标记为待阅读状态
-	if req.WorkAction == cast.WorkActionENUM_CONFIRM {
-		readReq := &cast.UpdateWorkAnalysisStatusReq{
-			WorkAction: cast.WorkActionENUM_READ,
-			Uuid:       req.Uuid,
-		}
-		_, err = service.CastProvider.UpdateWorkAnalysisStatus(newCtx, readReq)
-		if err != nil {
-			service.Error(ctx, err)
-			return
-		}
-	}
 	service.Success(ctx, nil)
 	return
 }

pkg/service/file/file.go

@@ -2,7 +2,6 @@ package file
 
 import (
 	"bytes"
-	"context"
 	"errors"
 	"fonchain-fiee/api/files"
 	"fonchain-fiee/pkg/service"
@@ -292,25 +291,25 @@ func SecurityScan(ctx *gin.Context) {
 		return
 	}
 	//后台异步执行扫描
-	go func() {
+	// go func() {
 
-		// 使用独立的 context，避免原请求 context 被取消
-		scanCtx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
-		defer cancel()
-		// 执行安全扫描
-		_, err := service.FilesProvider.SecurityScan(scanCtx, &req)
-		if err != nil {
-			// 记录错误日志
-			zap.L().Error("安全扫描失败",
-				zap.String("url", req.Url),
-				zap.String("fileName", req.FileName),
-				zap.Error(err))
-		} else {
-			zap.L().Info("安全扫描完成",
-				zap.String("url", req.Url),
-				zap.String("fileName", req.FileName))
-		}
-	}()
+	// 使用独立的 context，避免原请求 context 被取消
+	// scanCtx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
+	// defer cancel()
+	// 执行安全扫描
+	_, err := service.FilesProvider.SecurityScan(ctx, &req)
+	if err != nil {
+		// 记录错误日志
+		zap.L().Error("安全扫描失败",
+			zap.String("url", req.Url),
+			zap.String("fileName", req.FileName),
+			zap.Error(err))
+	} else {
+		zap.L().Info("安全扫描完成",
+			zap.String("url", req.Url),
+			zap.String("fileName", req.FileName))
+	}
+	// }()
 	// 立即返回成功，表示任务已提交
 	service.Success(ctx, gin.H{
 		"message": "安全扫描任务已提交，正在后台处理",