Updata:解决冲突
This commit is contained in:
commit
01d54a8f96
@ -2,6 +2,7 @@ package file
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
"fonchain-fiee/api/files"
|
"fonchain-fiee/api/files"
|
||||||
"fonchain-fiee/pkg/service"
|
"fonchain-fiee/pkg/service"
|
||||||
@ -291,22 +292,28 @@ func SecurityScan(ctx *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// 使用独立的 context,避免原请求 context 被取消
|
go func() {
|
||||||
// scanCtx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
|
// 使用独立的 context,避免原请求 context 被取消
|
||||||
// defer cancel()
|
scanCtx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
|
||||||
// 执行安全扫描
|
defer cancel()
|
||||||
|
// 执行安全扫描
|
||||||
|
|
||||||
resp, err := service.FilesProvider.SecurityScan(ctx, &req)
|
_, err := service.FilesProvider.SecurityScan(scanCtx, &req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
// 记录错误日志
|
// 记录错误日志
|
||||||
zap.L().Error("安全扫描失败",
|
zap.L().Error("安全扫描失败",
|
||||||
zap.String("url", req.Url),
|
zap.String("url", req.Url),
|
||||||
zap.String("fileName", req.FileName),
|
zap.String("fileName", req.FileName),
|
||||||
zap.Error(err))
|
zap.Error(err))
|
||||||
service.Error(ctx, errors.New("安全扫描失败"))
|
} else {
|
||||||
}
|
zap.L().Info("安全扫描完成",
|
||||||
|
zap.String("url", req.Url),
|
||||||
service.Success(ctx, resp)
|
zap.String("fileName", req.FileName))
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
service.Success(ctx, gin.H{
|
||||||
|
"message": "安全扫描任务已提交,正在后台处理",
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func UpdateFileSecurityStatus(ctx *gin.Context) {
|
func UpdateFileSecurityStatus(ctx *gin.Context) {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user