Compare commits
5
Commits
a409c5b4dd
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dadd3f7cea | ||
|
|
40f4f36aa6 | ||
|
|
2b1705a970 | ||
|
|
7ab80ec429 | ||
|
|
3c17503a21 |
@@ -75,7 +75,7 @@ GOOS=windows GOARCH=amd64 go build -o acfunlive.exe
|
||||
"qualities": [] // 开播时读到的码率档位列表,缓存下来让没开播时也能显示对应关系
|
||||
}
|
||||
],
|
||||
"directory": "", // 录制文件保存的文件夹,留空是程序运行时的 -record 文件夹
|
||||
"directory": "", // 录播和弹幕文件的保存根目录,录制时就直接写在这里;留空用运行时的 -record 文件夹
|
||||
"webPort": 51880, // web UI 的端口,为 0 时不启动 web UI
|
||||
|
||||
"autoMerge": false, // 直播结束后自动把弹幕层合并进录播
|
||||
@@ -127,7 +127,7 @@ GOOS=windows GOARCH=amd64 go build -o acfunlive.exe
|
||||
|
||||
档位表要开播后读直播源列表才知道(写在`config.json`的`qualities`里缓存)。没读到过的行,选项后面不会带档位名,旁边的`档位`按钮可以去直播间接一次(主播没开播时会失败并提示,服务端本身要重试三次、约 5 秒,所以点下去会先给一句`正在读取码率档位…`)。读档位的时机是:录制开始取流时、页面上点`档位`按钮、以及发现主播在直播但还没有档位缓存时自动读一次(同一个主播 10 秒内只读一次)。录制始终是原画质直接保存(`-c copy`),不会重新编码,所以只能在这几个档位里挑。
|
||||
|
||||
录播原片和弹幕文件(`.ass`、`.nick.ass`、`.jsonl`)保存在保存目录下的`recordSubdir`子文件夹里(默认`record`),两者同名配对才能自动合并;合并后的成片保存在`mergeSubdir`子文件夹里(默认`merged`),留空则用默认值,两个名字不能相同。如果设置了`mergeOutputDir`,成片优先移动到那里。
|
||||
录播原片和弹幕文件(`.ass`、`.nick.ass`、`.jsonl`)保存在保存目录下的`recordSubdir`子文件夹里(默认`record`),**录制过程中 ffmpeg 就直接写在这里**,不会再先落到别处中转;两者同名配对才能自动合并。保存目录的优先级是:`directory` > 命令行`-record`指定的文件夹 > 程序所在目录。合并后的成片保存在`mergeSubdir`子文件夹里(默认`merged`),留空则用默认值,两个名字不能相同。如果设置了`mergeOutputDir`,成片优先移动到那里。
|
||||
|
||||
合成**先在录播文件夹里做完,写完了才落到成片文件夹**(同一个盘时是直接改名,几乎瞬时;跨盘会自动拷贝):成片文件夹是网络盘、外接盘或者中途断线时,不会在里面留下一个写到一半、看起来却像正常成片的文件。合成失败或中途强杀程序时,临时文件(`acfunlive_chunk_*`、`*.acfunlive.part`)不会出现在文件管理的列表里,程序下次启动会自动清掉。
|
||||
|
||||
@@ -169,7 +169,7 @@ web UI 默认通过`http://localhost:51880`访问(端口对应`webPort`),
|
||||
| 监控 | 当前转换任务的进度卡片、添加主播、主播列表(默认打开的分区),以及运行日志 |
|
||||
| 录制 | 保存目录和子文件夹、录播格式、默认码率上限、ffmpeg 路径 |
|
||||
| 合并 | 自动合并开关、成片输出目录和合成码率、手动合并(可一次排多个任务,每个任务单独配参数) |
|
||||
| 转码 | 把录播或成片重新压一遍:每个文件单独配置编码器、码率、帧率、分辨率、音频,并预估产物大小 |
|
||||
| 转码 | 把录播、成片或磁盘上任意位置的视频重新压一遍:每个文件单独配置编码器、码率、帧率、分辨率、音频,并预估产物大小 |
|
||||
| 通知 | 推送哪些事件,以及 QQ 机器人 / MeoW 两个渠道的配置和测试连通 |
|
||||
| 文件 | 磁盘剩余容量、录播和成片的文件列表 |
|
||||
| 设置 | 是否允许外网访问、管理口令的查看与更换 |
|
||||
@@ -271,9 +271,16 @@ web UI 的`合并`分区里的`手动合并`用来自己挑视频和弹幕出片
|
||||
|
||||
### 转码
|
||||
|
||||
`转码`分区用来把录播或成片重新压一遍:体积太大想压小、想换成 HEVC、想降分辨率或帧率、想换音轨,都在这里做。**转码不动原文件**,成片另存到输出目录(留空就是成片文件夹)。
|
||||
`转码`分区用来把视频重新压一遍:体积太大想压小、想换成 HEVC、想降分辨率或帧率、想换音轨,都在这里做。源文件不限于本程序录的录播和成片,磁盘上任何位置的文件都能丢进来。**转码不动原文件**,成片另存到输出目录(留空就是成片文件夹)。
|
||||
|
||||
从文件列表里多选加入之后,每个文件一行,参数各自独立:
|
||||
源文件有两个入口,挑哪个都行:
|
||||
|
||||
- **从文件列表挑**:录播和成片文件夹里的文件列在左边,按 Ctrl 点可以多选,选中后点`加入列表`。
|
||||
- **自己填路径**:右边的输入框一行一个路径,可以是从资源管理器复制来的绝对路径,也可以是录播/成片文件夹里的文件名(只写文件名就按这两个文件夹找)。点`浏览…`可以从磁盘上任意位置挑,支持多选、可以跨文件夹跨盘攒,选完只往输入框里追加,不会清掉已经填好的。
|
||||
|
||||
两个入口进来的文件进的是同一个待转码列表,每条互不影响。
|
||||
|
||||
每个文件一行,参数各自独立:
|
||||
|
||||
| 参数 | 说明 |
|
||||
| --- | --- |
|
||||
|
||||
@@ -85,6 +85,14 @@ func findMovedFile(path string) string {
|
||||
return ""
|
||||
}
|
||||
|
||||
// 收拢到实际位置:找不着时退回原路径,让后面的报错还能指出「本来想找哪儿」
|
||||
func resolveAfterMove(path string) string {
|
||||
if p := findMovedFile(path); p != "" {
|
||||
return p
|
||||
}
|
||||
return path
|
||||
}
|
||||
|
||||
// 录播因为断流可能分成多段:单段直接使用,多段先拼成完整视频并把弹幕时间映射到拼接后的时间轴。
|
||||
// 返回合并要用的视频、字幕文件和弹幕相对视频起点的时间偏移、**实际参与合并的源文件**,
|
||||
// 以及清理临时文件的函数。used 是给「合并完删源视频」用的:中途回退成「只合并第一个分段」时,
|
||||
@@ -92,6 +100,10 @@ func findMovedFile(path string) string {
|
||||
func prepareForMerge(ffmpegFile string, segs []recordSegment, jsonlFile string, danmuStartNs int64) (string, string, float64, []string, func(), error) {
|
||||
noop := func() {}
|
||||
|
||||
// 弹幕文件同样会被移动过去。以前只有视频分段走了查找,弹幕还拿着录制时的路径,
|
||||
// 结果就是视频找得到、弹幕找不到,合并以「jsonl 文件不存在」告终
|
||||
jsonlFile = resolveAfterMove(jsonlFile)
|
||||
|
||||
// 录制结束时文件可能已经被移动到保存目录,逐个找实际位置
|
||||
files := make([]string, 0, len(segs))
|
||||
starts := make([]int64, 0, len(segs))
|
||||
@@ -288,6 +300,10 @@ func autoMergeOutFile(jsonlFile string) string {
|
||||
func autoMergeJob(uid int, segs []recordSegment, jsonlFile string, danmuStartNs int64) error {
|
||||
lPrintln("开始自动合并" + longID(uid) + "的录播和弹幕层")
|
||||
|
||||
// 录制结束时弹幕文件可能已被移动到保存目录,先把路径收拢到实际位置:
|
||||
// 中间成片写到哪、事后删哪几个弹幕文件都按这一条路径来,用旧路径会指向错误的地方
|
||||
jsonlFile = resolveAfterMove(jsonlFile)
|
||||
|
||||
// 视频和弹幕是一次录制产生的,文件名去掉扩展名后应该一致(扩展名由 recordFormat 决定)
|
||||
if len(segs) > 0 {
|
||||
videoBase := filepath.Base(strings.TrimSuffix(segs[0].file, filepath.Ext(segs[0].file)))
|
||||
|
||||
@@ -0,0 +1,76 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"os"
|
||||
"path/filepath"
|
||||
"testing"
|
||||
)
|
||||
|
||||
// 录制结束时文件会被移动到保存目录,视频分段和弹幕文件都要按新位置找。
|
||||
// 以前只有视频分段走了查找,弹幕还拿着录制时的路径:视频找到了、弹幕找不到,
|
||||
// 整场合并以「jsonl 文件不存在」告终(用户看到的就是合成失败 + 一条失败推送)。
|
||||
func TestPrepareForMergeFindsMovedJsonl(t *testing.T) {
|
||||
savedConfig := config
|
||||
defer func() { config = savedConfig }()
|
||||
|
||||
root := t.TempDir()
|
||||
config.Directory = root
|
||||
config.RecordSubdir = "record"
|
||||
if err := os.MkdirAll(recordSaveDir(), 0755); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
name := "2026-09-27 22-40-42 甲 标题"
|
||||
// 录制时的位置:文件已经被搬走,这里不该再有
|
||||
oldDir := t.TempDir()
|
||||
oldVideo := filepath.Join(oldDir, name+".mp4")
|
||||
oldJsonl := filepath.Join(oldDir, name+".jsonl")
|
||||
// 实际位置
|
||||
newVideo := filepath.Join(recordSaveDir(), name+".mp4")
|
||||
newJsonl := filepath.Join(recordSaveDir(), name+".jsonl")
|
||||
for _, p := range []string{newVideo, newJsonl} {
|
||||
if err := os.WriteFile(p, []byte("{}\n"), 0644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
segs := []recordSegment{{file: oldVideo, startNs: 0}}
|
||||
video, jsonl, _, _, cleanup, err := prepareForMerge("没有这个-ffmpeg.exe", segs, oldJsonl, 0)
|
||||
defer cleanup()
|
||||
if err != nil {
|
||||
t.Fatalf("单段不该报错:%v", err)
|
||||
}
|
||||
if video != newVideo {
|
||||
t.Errorf("视频应当按保存目录里的实际位置找:\n got %s\n want %s", video, newVideo)
|
||||
}
|
||||
if jsonl != newJsonl {
|
||||
t.Errorf("弹幕文件应当按保存目录里的实际位置找:\n got %s\n want %s", jsonl, newJsonl)
|
||||
}
|
||||
}
|
||||
|
||||
// 文件确实不在(既没在录制时的位置、也不在保存目录)时,要退回原路径而不是空串:
|
||||
// 否则报错会变成「文件不存在:」,看不出到底缺的是哪个
|
||||
func TestResolveAfterMoveKeepsOriginalWhenMissing(t *testing.T) {
|
||||
savedConfig := config
|
||||
defer func() { config = savedConfig }()
|
||||
|
||||
root := t.TempDir()
|
||||
config.Directory = root
|
||||
config.RecordSubdir = "record"
|
||||
|
||||
gone := filepath.Join(t.TempDir(), "这个目录是对的但文件不在.mp4")
|
||||
if got := resolveAfterMove(gone); got != gone {
|
||||
t.Errorf("找不到时应当退回原路径:got %q want %q", got, gone)
|
||||
}
|
||||
|
||||
real := filepath.Join(root, "record", "在保存目录里.mp4")
|
||||
if err := os.MkdirAll(filepath.Dir(real), 0755); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if err := os.WriteFile(real, []byte("x"), 0644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if got := resolveAfterMove(real); got != real {
|
||||
t.Errorf("文件就在原路径时不该改:got %q want %q", got, real)
|
||||
}
|
||||
}
|
||||
@@ -129,7 +129,7 @@ var configMu sync.Mutex
|
||||
// 设置数据
|
||||
type configData struct {
|
||||
UIDs uidList `json:"uids"` // 要录制的主播 uid 列表和各自的开关
|
||||
Directory string `json:"directory"` // 弹幕文件录制结束后会被移动到该文件夹
|
||||
Directory string `json:"directory"` // 录播和弹幕文件保存的根目录,留空用 -record 指定的文件夹
|
||||
WebPort int `json:"webPort"` // web UI 的本地端口,为 0 时不启动 web UI
|
||||
|
||||
AutoMerge bool `json:"autoMerge"` // 直播结束后自动把弹幕层合并进录播
|
||||
@@ -190,25 +190,29 @@ func saveRootDir() string {
|
||||
if config.Directory != "" {
|
||||
return absOrSelf(config.Directory)
|
||||
}
|
||||
if recordDir == nil {
|
||||
return ""
|
||||
if recordDir != nil && *recordDir != "" {
|
||||
return absOrSelf(*recordDir)
|
||||
}
|
||||
return absOrSelf(*recordDir)
|
||||
// 命令行参数还没解析时(比如 initialize 之前被调用)退回程序所在目录,
|
||||
// 再不济退回当前工作目录:这里返回空串的话,后面拼出来的就是个相对路径,
|
||||
// ffmpeg 会按自己的当前目录去写,录制文件就不知道落到哪去了
|
||||
if exeDir != "" {
|
||||
return absOrSelf(exeDir)
|
||||
}
|
||||
if wd, err := os.Getwd(); err == nil {
|
||||
return wd
|
||||
}
|
||||
return "."
|
||||
}
|
||||
|
||||
// 录播和弹幕文件保存的文件夹
|
||||
// 录播和弹幕文件保存的文件夹。
|
||||
// 录制过程中 ffmpeg 就直接写在这里,不会再中途挪窝:以前单独有一个「录制中的目录」,
|
||||
// 它只认 -record 参数不看 directory 设置,配了保存目录的人会发现文件先落在程序目录下,
|
||||
// 录完才搬一次(跨盘就是整份文件再复制一遍),提前中断还会留在那儿。
|
||||
func recordSaveDir() string {
|
||||
return filepath.Join(saveRootDir(), config.RecordSubdir)
|
||||
}
|
||||
|
||||
// 录制过程中文件直接写入的文件夹
|
||||
func recordingDir() string {
|
||||
if recordDir == nil {
|
||||
return config.RecordSubdir
|
||||
}
|
||||
return filepath.Join(absOrSelf(*recordDir), config.RecordSubdir)
|
||||
}
|
||||
|
||||
// 合并成片保存的文件夹
|
||||
func mergeSaveDir() string {
|
||||
if config.MergeOutputDir != "" {
|
||||
@@ -400,6 +404,20 @@ func currentAuthToken() string {
|
||||
return config.AuthToken
|
||||
}
|
||||
|
||||
// 检查配置里的文件夹字段,返回错误信息,空字符串表示通过。
|
||||
// 启动读配置、web UI 改设置、转码排队都用这一份 —— 以前各自实现,
|
||||
// 启动那份直接 os.Stat + checkErr,目录不存在时会 panic 崩掉整个进程。
|
||||
func checkDirField(path, name string) string {
|
||||
if path == "" {
|
||||
return ""
|
||||
}
|
||||
info, err := os.Stat(path)
|
||||
if err != nil || !info.IsDir() {
|
||||
return name + " 必须是存在的文件夹:" + path
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
// 检查 config.json 里的配置
|
||||
func checkConfig() {
|
||||
for _, u := range config.UIDs {
|
||||
@@ -412,21 +430,15 @@ func checkConfig() {
|
||||
lPrintErr(configFile + "里的 webPort 必须为 0(不启动 web UI)或者大于 1023 且少于 65536")
|
||||
os.Exit(1)
|
||||
}
|
||||
if config.Directory != "" {
|
||||
info, err := os.Stat(config.Directory)
|
||||
checkErr(err)
|
||||
if !info.IsDir() {
|
||||
lPrintErrf("%s里的directory必须是存在的文件夹:%s", configFile, config.Directory)
|
||||
os.Exit(1)
|
||||
}
|
||||
// 目录不在(盘没插、路径拼错)要给人话提示然后退出,不能直接 panic:
|
||||
// 崩溃时文件系统风险未知,而且服务被托管时会被反复拉起来
|
||||
if msg := checkDirField(config.Directory, configFile+"里的directory"); msg != "" {
|
||||
lPrintErr(msg)
|
||||
os.Exit(1)
|
||||
}
|
||||
if config.MergeOutputDir != "" {
|
||||
info, err := os.Stat(config.MergeOutputDir)
|
||||
checkErr(err)
|
||||
if !info.IsDir() {
|
||||
lPrintErrf("%s里的mergeOutputDir必须是存在的文件夹:%s", configFile, config.MergeOutputDir)
|
||||
os.Exit(1)
|
||||
}
|
||||
if msg := checkDirField(config.MergeOutputDir, configFile+"里的mergeOutputDir"); msg != "" {
|
||||
lPrintErr(msg)
|
||||
os.Exit(1)
|
||||
}
|
||||
if config.MergeBitrate < 0 {
|
||||
lPrintErrf("%s里的mergeBitrate不能小于 0", configFile)
|
||||
@@ -480,7 +492,7 @@ func checkConfig() {
|
||||
config.FFmpegPath = ""
|
||||
}
|
||||
// 确保保存文件夹存在
|
||||
for _, d := range []string{recordingDir(), recordSaveDir(), mergeSaveDir()} {
|
||||
for _, d := range []string{recordSaveDir(), mergeSaveDir()} {
|
||||
if err := os.MkdirAll(d, 0755); err != nil {
|
||||
lPrintErrf("创建文件夹 %s 失败:%v", d, err)
|
||||
os.Exit(1)
|
||||
@@ -1119,7 +1131,9 @@ func (s *streamer) moveDanmuFiles(assFile string) {
|
||||
s.moveFile(jsonlFile)
|
||||
}
|
||||
|
||||
// 移动文件
|
||||
// 把送出文件到保存目录下,路径一致时什么也不做。
|
||||
// 录制的产出本来就写在 recordSaveDir() 里(见 recordSaveDir 的注释),
|
||||
// 这里是条保险:路径由别处给进来、或者运行中被改过保存目录时,仍以当前配置为准收拢一次。
|
||||
func (s *streamer) moveFile(oldFile string) {
|
||||
if oldFile == "" {
|
||||
return
|
||||
|
||||
@@ -4,6 +4,7 @@ import (
|
||||
"encoding/json"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"testing"
|
||||
)
|
||||
|
||||
@@ -145,3 +146,48 @@ func TestReloadConfigKeepsMergeTempFiles(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 保存目录填错(盘没插、路径拼错)时启动必须给一句人话再退出,
|
||||
// 不能 panic 崩掉整个进程 —— 服务被托管时崩了还会被反复拉起来
|
||||
func TestCheckDirFieldReportsMissingDir(t *testing.T) {
|
||||
root := t.TempDir()
|
||||
if msg := checkDirField("", "directory"); msg != "" {
|
||||
t.Errorf("留空表示不指定,不该报错:%s", msg)
|
||||
}
|
||||
if msg := checkDirField(root, "directory"); msg != "" {
|
||||
t.Errorf("存在的文件夹不该报错:%s", msg)
|
||||
}
|
||||
if msg := checkDirField(filepath.Join(root, "没有这个目录"), "directory"); !strings.Contains(msg, "必须是存在的文件夹") {
|
||||
t.Errorf("目录不存在时要给出提示,实际返回 %q", msg)
|
||||
}
|
||||
file := filepath.Join(root, "afile")
|
||||
if err := os.WriteFile(file, []byte("x"), 0644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if msg := checkDirField(file, "directory"); msg == "" {
|
||||
t.Error("指向文件而不是文件夹时应当报错")
|
||||
}
|
||||
}
|
||||
|
||||
// checkConfig 里曾经直接 os.Stat + checkErr:目录不在时会 panic 崩掉进程。
|
||||
// 这条路径没法在测试里真跑一遍(失败时是 os.Exit(1),会把整个测试进程带走),
|
||||
// 所以退一步把「只能给提示再退出」钉在源码上。
|
||||
func TestCheckConfigNeverPanicsOnMissingDir(t *testing.T) {
|
||||
src, err := os.ReadFile("config.go")
|
||||
if err != nil {
|
||||
t.Skip("读不到 config.go:" + err.Error())
|
||||
}
|
||||
text := string(src)
|
||||
start := strings.Index(text, "func checkConfig()")
|
||||
if start < 0 {
|
||||
t.Fatal("config.go 里找不到 checkConfig")
|
||||
}
|
||||
rest := text[start:]
|
||||
end := strings.Index(rest, "\n}\n")
|
||||
if end < 0 {
|
||||
t.Fatal("checkConfig 的函数体没有正常收尾")
|
||||
}
|
||||
if strings.Contains(rest[:end], "checkErr(") {
|
||||
t.Error("checkConfig 里不能用 checkErr:出错会变成 panic 崩进程,改成 lPrintErr + os.Exit(1)")
|
||||
}
|
||||
}
|
||||
|
||||
+1
-1
@@ -24,5 +24,5 @@ func transFilename(filename string) string {
|
||||
}
|
||||
filename = filename[:cut]
|
||||
}
|
||||
return filepath.Join(recordingDir(), filename)
|
||||
return filepath.Join(recordSaveDir(), filename)
|
||||
}
|
||||
|
||||
@@ -0,0 +1,86 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"testing"
|
||||
)
|
||||
|
||||
// 录制过程中 ffmpeg 是按 transFilename 给的路径写文件的。
|
||||
// 以前这条路径走的是 -record 参数而不是 directory 设置,配了保存目录的人会看到
|
||||
// 文件先落在程序目录里、录完才搬一次;这里把「必须等于最终保存目录」钉死。
|
||||
func TestTransFilenameSavesIntoConfiguredDir(t *testing.T) {
|
||||
savedConfig, savedRecordDir := config, recordDir
|
||||
defer func() { config, recordDir = savedConfig, savedRecordDir }()
|
||||
|
||||
root, dashDir := t.TempDir(), t.TempDir()
|
||||
recordDir = &dashDir
|
||||
config.RecordSubdir = "record"
|
||||
|
||||
// 配了 directory:不管 -record 参数是什么,都得以它为准
|
||||
config.Directory = root
|
||||
got := filepath.Clean(transFilename("2026-09-27 22-40-42 甲 标题.mp4"))
|
||||
want := filepath.Join(root, "record", "2026-09-27 22-40-42 甲 标题.mp4")
|
||||
if got != filepath.Clean(want) {
|
||||
t.Errorf("配了 directory 后录制路径不对:\n got %s\n want %s", got, want)
|
||||
}
|
||||
if !strings.HasPrefix(got, filepath.Clean(root)) {
|
||||
t.Errorf("录制路径落在了保存目录之外:%s", got)
|
||||
}
|
||||
|
||||
// 没配 directory:回落到 -record 指定的文件夹
|
||||
config.Directory = ""
|
||||
got = filepath.Clean(transFilename("x.mp4"))
|
||||
if filepath.Dir(got) != filepath.Clean(filepath.Join(dashDir, "record")) {
|
||||
t.Errorf("directory 为空时应回落到 -record 目录:%s", got)
|
||||
}
|
||||
|
||||
// 连 -record 都还没解析时也不能拼出相对路径,否则 ffmpeg 会写到进程的工作目录去
|
||||
blank := ""
|
||||
recordDir = &blank
|
||||
if root := saveRootDir(); !filepath.IsAbs(root) {
|
||||
t.Errorf("传入的参数都没解析时 saveRootDir 仍应是绝对路径,实际 %q", root)
|
||||
}
|
||||
if got := filepath.Clean(transFilename("x.mp4")); !filepath.IsAbs(got) {
|
||||
t.Errorf("录制路径不能是相对路径:%q", got)
|
||||
}
|
||||
}
|
||||
|
||||
// 保存目录和录制目录现在是一个,moveFile 再挪一遍等于白复制一份(跨盘时尤其慢)
|
||||
func TestMoveFileKeepsFileInSaveDir(t *testing.T) {
|
||||
savedConfig, savedRecordDir := config, recordDir
|
||||
defer func() { config, recordDir = savedConfig, savedRecordDir }()
|
||||
|
||||
root := t.TempDir()
|
||||
recordDir = &root
|
||||
config.Directory = root
|
||||
config.RecordSubdir = "record"
|
||||
|
||||
if err := os.MkdirAll(recordSaveDir(), 0755); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
p := filepath.Join(recordSaveDir(), "2026-09-27 22-40-42 甲 标题.mp4")
|
||||
if err := os.WriteFile(p, []byte("fake"), 0644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
s := &streamer{UID: 1}
|
||||
s.moveFile(p)
|
||||
if _, err := os.Stat(p); err != nil {
|
||||
t.Errorf("文件已经在保存目录里了,moveFile 不该动它:%v", err)
|
||||
}
|
||||
|
||||
// 别处给进来的路径(比如手填的绝对路径)仍要收拢到保存目录
|
||||
outside := filepath.Join(t.TempDir(), "outside.mp4")
|
||||
if err := os.WriteFile(outside, []byte("fake"), 0644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
s.moveFile(outside)
|
||||
if _, err := os.Stat(outside); !os.IsNotExist(err) {
|
||||
t.Errorf("保存目录之外的文件应当被移动,原位置却还在")
|
||||
}
|
||||
if _, err := os.Stat(filepath.Join(recordSaveDir(), "outside.mp4")); err != nil {
|
||||
t.Errorf("文件没有出现在保存目录里:%v", err)
|
||||
}
|
||||
}
|
||||
+1
-1
@@ -16,7 +16,7 @@ func transFilename(filename string) string {
|
||||
// 转换文件名不允许的特殊字符
|
||||
re := regexp.MustCompile(`[<>:"/\\|?*\r\n]`)
|
||||
filename = re.ReplaceAllString(filename, "-")
|
||||
dir := recordingDir()
|
||||
dir := recordSaveDir()
|
||||
outFilename := filepath.Join(dir, filename)
|
||||
if utf8.RuneCountInString(outFilename) <= maxPathRunes {
|
||||
return outFilename
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
module github.com/orzogc/acfunlive
|
||||
|
||||
go 1.26.0
|
||||
go 1.27.3
|
||||
|
||||
require (
|
||||
github.com/PuerkitoBio/goquery v1.13.0
|
||||
|
||||
+34
-12
@@ -66,17 +66,29 @@ type transcodeOptions struct {
|
||||
Audio string `json:"audio"` // 音频处理,空 = 直接拷贝
|
||||
}
|
||||
|
||||
// 一个待转码的文件
|
||||
// 一个待转码的文件。
|
||||
// 定位源文件有两种写法,二选一:Path 填了就用它(绝对路径、相对路径都行,可以是从资源管理器
|
||||
// 复制来的带引号路径),没填才按 Dir + Name 在录播/成片文件夹里找
|
||||
type transcodeJobReq struct {
|
||||
Path string `json:"path"`
|
||||
Dir string `json:"dir"` // record / merge
|
||||
Name string `json:"name"` // 文件名
|
||||
OutName string `json:"outName"` // 输出文件名,留空自动
|
||||
Options transcodeOptions `json:"options"`
|
||||
}
|
||||
|
||||
// 报错时给用户看的名字:按路径传进来的 Name 是空的,直接拼进消息会变成「:参数不合法」
|
||||
func (j transcodeJobReq) label() string {
|
||||
if p := strings.TrimSpace(j.Path); p != "" {
|
||||
return filepath.Base(strings.Trim(p, `"'`))
|
||||
}
|
||||
return j.Name
|
||||
}
|
||||
|
||||
// 探测到的源文件信息,页面用它显示原始参数和算预估体积
|
||||
type transcodeProbe struct {
|
||||
Name string `json:"name"`
|
||||
Path string `json:"path"` // 源文件绝对路径,页面拿它当任务的身份(同名文件在不同目录不会认错)
|
||||
Dir string `json:"dir"`
|
||||
Size int64 `json:"size"`
|
||||
Duration float64 `json:"duration"`
|
||||
@@ -531,9 +543,19 @@ func formatByteSize(n int64) string {
|
||||
return fmt.Sprintf("%.1f %s", v, units[i])
|
||||
}
|
||||
|
||||
// 转码任务的输入必须来自文件管理里的两个文件夹,和手动合并一致
|
||||
func resolveTranscodeInput(dir, name string) (string, error) {
|
||||
full, err := resolveFile(dir, name)
|
||||
// 转码任务的输入:填了路径就按路径找(任意文件夹都行),否则按文件名在录播/成片文件夹里找。
|
||||
// 两条路都要过一遍格式白名单 —— 路径这条能指向磁盘上任何文件,不挡的话
|
||||
// 用户手滑把 .jsonl 弹幕丢进来,要等 ffmpeg 跑起来才报一句看不懂的错
|
||||
func resolveTranscodeJob(j transcodeJobReq) (string, error) {
|
||||
var (
|
||||
full string
|
||||
err error
|
||||
)
|
||||
if p := strings.TrimSpace(j.Path); p != "" {
|
||||
full, err = resolveMergeInput(p)
|
||||
} else {
|
||||
full, err = resolveFile(j.Dir, j.Name)
|
||||
}
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
@@ -650,7 +672,7 @@ func runTranscode(job transcodeJobReq, outDir string, idx, total int) (string, e
|
||||
if ffmpegFile == "" {
|
||||
return "", errors.New("找不到 ffmpeg,请先在设置里填写 ffmpeg 路径")
|
||||
}
|
||||
in, err := resolveTranscodeInput(job.Dir, job.Name)
|
||||
in, err := resolveTranscodeJob(job)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
@@ -803,7 +825,7 @@ func transcodeProbeHandler(w http.ResponseWriter, r *http.Request) {
|
||||
|
||||
out := make([]transcodeProbe, 0, len(req.Files))
|
||||
for _, f := range req.Files {
|
||||
full, err := resolveTranscodeInput(f.Dir, f.Name)
|
||||
full, err := resolveTranscodeJob(f)
|
||||
if err != nil {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
@@ -815,7 +837,7 @@ func transcodeProbeHandler(w http.ResponseWriter, r *http.Request) {
|
||||
}
|
||||
m := probeMediaCached(ffmpegFile, full)
|
||||
out = append(out, transcodeProbe{
|
||||
Name: filepath.Base(full), Dir: f.Dir, Size: st.Size(),
|
||||
Name: filepath.Base(full), Path: full, Dir: f.Dir, Size: st.Size(),
|
||||
Duration: m.duration, Width: m.width, Height: m.height, Fps: m.fps,
|
||||
// 视频码率在这里就扣掉音轨:后面预估体积还要单独加一次音频,
|
||||
// 直接用容器总码率会把音轨算成两份
|
||||
@@ -852,10 +874,10 @@ func transcodeEstimateHandler(w http.ResponseWriter, r *http.Request) {
|
||||
out := make([]transcodeEstimate, 0, len(req.Jobs))
|
||||
for _, j := range req.Jobs {
|
||||
if msg := j.Options.validate(ffmpegFile); msg != "" {
|
||||
http.Error(w, j.Name+":"+msg, http.StatusBadRequest)
|
||||
http.Error(w, j.label()+":"+msg, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
full, err := resolveTranscodeInput(j.Dir, j.Name)
|
||||
full, err := resolveTranscodeJob(j)
|
||||
if err != nil {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
@@ -907,10 +929,10 @@ func transcodeHandler(w http.ResponseWriter, r *http.Request) {
|
||||
// 探测走缓存,刚才「加入列表」和「估算体积」时已经探过,这里不会再多起 ffmpeg
|
||||
for _, j := range req.Jobs {
|
||||
if msg := j.Options.validate(ffmpegFile); msg != "" {
|
||||
http.Error(w, j.Name+":"+msg, http.StatusBadRequest)
|
||||
http.Error(w, j.label()+":"+msg, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
full, err := resolveTranscodeInput(j.Dir, j.Name)
|
||||
full, err := resolveTranscodeJob(j)
|
||||
if err != nil {
|
||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
@@ -934,7 +956,7 @@ func transcodeHandler(w http.ResponseWriter, r *http.Request) {
|
||||
if outDir == "" {
|
||||
outDir = mergeSaveDir()
|
||||
} else {
|
||||
if msg := checkWebDir(outDir, "输出目录"); msg != "" {
|
||||
if msg := checkDirField(outDir, "输出目录"); msg != "" {
|
||||
http.Error(w, msg, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
@@ -1,10 +1,14 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"math"
|
||||
"net/http"
|
||||
"net/http/httptest"
|
||||
"os"
|
||||
"os/exec"
|
||||
"path/filepath"
|
||||
"strconv"
|
||||
"strings"
|
||||
"testing"
|
||||
)
|
||||
@@ -477,6 +481,94 @@ func has(args []string, v string) bool {
|
||||
return false
|
||||
}
|
||||
|
||||
// ==================== 源文件定位 ====================
|
||||
|
||||
// 填了路径就按路径找,录播/成片文件夹之外的文件也要能转;没填才回落到 dir + name
|
||||
func TestResolveTranscodeJobByPath(t *testing.T) {
|
||||
setupMergeTest(t)
|
||||
outside := t.TempDir()
|
||||
video := filepath.Join(outside, "别处的录播.mp4")
|
||||
writeTestFile(t, video, "x")
|
||||
|
||||
// 绝对路径要认,从资源管理器复制来的带引号路径也要认
|
||||
for _, in := range []string{video, `"` + video + `"`} {
|
||||
got, err := resolveTranscodeJob(transcodeJobReq{Path: in})
|
||||
if err != nil {
|
||||
t.Fatalf("%q 应当能解析:%v", in, err)
|
||||
}
|
||||
if normalizePath(got) != normalizePath(video) {
|
||||
t.Errorf("%q 解析成了 %q,想要 %q", in, got, video)
|
||||
}
|
||||
}
|
||||
|
||||
// 不填路径时还是按录播目录 + 文件名找,老写法不能坏
|
||||
rec := filepath.Join(recordSaveDir(), "录播里的.mp4")
|
||||
writeTestFile(t, rec, "x")
|
||||
got, err := resolveTranscodeJob(transcodeJobReq{Dir: "record", Name: "录播里的.mp4"})
|
||||
if err != nil {
|
||||
t.Fatalf("dir + name 应当能解析:%v", err)
|
||||
}
|
||||
if normalizePath(got) != normalizePath(rec) {
|
||||
t.Errorf("dir + name 解析成了 %q,想要 %q", got, rec)
|
||||
}
|
||||
}
|
||||
|
||||
// 路径这条能指向磁盘上任何文件,格式白名单必须照样过一遍
|
||||
func TestResolveTranscodeJobRejectsBadPath(t *testing.T) {
|
||||
setupMergeTest(t)
|
||||
outside := t.TempDir()
|
||||
danmu := filepath.Join(outside, "某场.jsonl")
|
||||
writeTestFile(t, danmu, "{}")
|
||||
sub := filepath.Join(outside, "子文件夹")
|
||||
if err := os.MkdirAll(sub, 0755); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
bad := map[string]transcodeJobReq{
|
||||
"不是视频后缀": {Path: danmu},
|
||||
"指向文件夹": {Path: sub},
|
||||
"路径不存在": {Path: filepath.Join(outside, "没有这个文件.mp4")},
|
||||
"路径和名字都没填": {},
|
||||
}
|
||||
for name, j := range bad {
|
||||
if _, err := resolveTranscodeJob(j); err == nil {
|
||||
t.Errorf("%s:应当被挡住,实际通过了", name)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 探测接口要认 {path} —— 这是「转码任意文件」的实际入口,只测 resolve 不足以证明接线对了。
|
||||
// 这里故意用一个不是视频的文件:探测拿不到流信息,但接口仍要 200 并把路径原样回显
|
||||
func TestTranscodeProbeHandlerAcceptsPath(t *testing.T) {
|
||||
setupMergeTest(t)
|
||||
outside := t.TempDir()
|
||||
video := filepath.Join(outside, "别处.mp4")
|
||||
writeTestFile(t, video, "not a real video")
|
||||
|
||||
body := `{"files":[{"path":` + strconv.Quote(video) + `}]}`
|
||||
req := httptest.NewRequest("POST", "/api/transcode/probe", strings.NewReader(body))
|
||||
rec := httptest.NewRecorder()
|
||||
transcodeProbeHandler(rec, req)
|
||||
if rec.Code != http.StatusOK {
|
||||
t.Fatalf("按路径探测应当 200,实际 %d:%s", rec.Code, rec.Body.String())
|
||||
}
|
||||
var resp struct {
|
||||
Files []struct {
|
||||
Name string `json:"name"`
|
||||
Path string `json:"path"`
|
||||
} `json:"files"`
|
||||
}
|
||||
if err := json.Unmarshal(rec.Body.Bytes(), &resp); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if len(resp.Files) != 1 || resp.Files[0].Name != "别处.mp4" {
|
||||
t.Fatalf("探测结果不对:%+v", resp.Files)
|
||||
}
|
||||
if normalizePath(resp.Files[0].Path) != normalizePath(video) {
|
||||
t.Errorf("回显的 path 是 %q,想要 %q", resp.Files[0].Path, video)
|
||||
}
|
||||
}
|
||||
|
||||
func indexOf(args []string, v string) int {
|
||||
for i, a := range args {
|
||||
if a == v {
|
||||
|
||||
@@ -439,13 +439,24 @@ const webuiHTML = `<!DOCTYPE html>
|
||||
<!-- 转码 -->
|
||||
<section class="pane" data-pane="trc">
|
||||
<div class="card">
|
||||
<div class="card-h"><h2>选择要转码的文件</h2><span class="sub">从录播和成片文件夹里挑</span></div>
|
||||
<div class="bar" style="margin-top:0">
|
||||
<select id="tcFilePick" multiple size="6" style="flex:1 1 260px;min-width:0"></select>
|
||||
<div style="flex:1 1 160px;display:flex;flex-direction:column;gap:8px">
|
||||
<button class="ghost" onclick="addTranscodeFiles()">加入列表</button>
|
||||
<button class="ghost" onclick="clearTranscodeFiles()">清空列表</button>
|
||||
<span class="hint" style="margin:0">按住 Ctrl 点可以一次选多个</span>
|
||||
<div class="card-h"><h2>选择要转码的文件</h2><span class="sub">从录播/成片文件夹挑,或者自己填路径</span></div>
|
||||
<div class="grid">
|
||||
<div class="f">
|
||||
<label>从文件列表挑(可多选,按 Ctrl 点选)</label>
|
||||
<select id="tcFilePick" multiple size="6"></select>
|
||||
<div class="bar">
|
||||
<button class="ghost" onclick="addTranscodeFiles()">加入列表</button>
|
||||
<button class="ghost" onclick="clearTranscodeFiles()">清空列表</button>
|
||||
</div>
|
||||
</div>
|
||||
<div class="f">
|
||||
<label>自己填路径(一行一个;在录播/成片文件夹里的可以只写文件名)</label>
|
||||
<textarea id="tcPaths" rows="6" spellcheck="false" placeholder="一行一个路径,例如 D:\别处\某场录播.mp4"></textarea>
|
||||
<div class="bar">
|
||||
<button class="ghost" onclick="browseTranscodePaths()">浏览…</button>
|
||||
<button class="ghost" onclick="addTranscodePathsFromBox()">加入列表</button>
|
||||
<button class="ghost" onclick="clearTranscodePathBox()">清空输入框</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="hint">加入列表后会先读一遍每个文件的分辨率、帧率、码率和时长,参数按读出来的值给默认。转码不动原文件,成片另存到下面的输出目录。</div>
|
||||
@@ -1030,6 +1041,7 @@ async function loadFiles(b){
|
||||
var d = await r.json();
|
||||
fileList = d.files || [];
|
||||
recDir = d.recordDir || "";
|
||||
mergeDir = d.mergeDir || "";
|
||||
fillMergePickers();
|
||||
fillTranscodePick();
|
||||
document.getElementById("diskInfo").textContent =
|
||||
@@ -1078,11 +1090,13 @@ var pickMulti = false; // 多选模式(视频框这种一行一个、可以选
|
||||
var pickCb = null; // 选完后交给它的回调,不为空时不再往输入框里填
|
||||
var pickSel = []; // 多选已勾选的绝对路径,换目录也不清,所以能跨文件夹/跨盘攒
|
||||
var recDir = ""; // 录播目录,挑弹幕和视频时从它开始
|
||||
var mergeDir = ""; // 成片目录,转码挑文件时从它开始(比空的录播目录更有东西可挑)
|
||||
var lastPickKey = "", lastPickAt = 0; // 列表里连点同一项只算一次
|
||||
var lastNavAt = 0; // 刚跳转过目录的这段时间里忽略列表上的点击,双击文件夹才不会连进两层
|
||||
|
||||
// cb 不为空时选完不填框,而是把选中的路径交给它(手动合并、转码这种一行一个的列表用)
|
||||
function openPick(id, kind, multi, cb){
|
||||
// cb 不为空时选完不填框,而是把选中的路径交给它(手动合并、转码这种一行一个的列表用);
|
||||
// startAt 不为空时从它开始(不给就按框里已填的内容推)
|
||||
function openPick(id, kind, multi, cb, startAt){
|
||||
var el = id ? document.getElementById(id) : null;
|
||||
pickField = id;
|
||||
pickKind = kind === "file" ? "file" : "dir";
|
||||
@@ -1098,9 +1112,9 @@ function openPick(id, kind, multi, cb){
|
||||
document.getElementById("pick").classList.toggle("multi", pickMulti);
|
||||
document.getElementById("pick").classList.add("on");
|
||||
// 多行框(视频)取第一行当起点,整段拿去当路径会解析出一个乱七八糟的目录
|
||||
var start = el ? el.value.split("\n")[0].trim() : "";
|
||||
var start = startAt || (el ? el.value.split("\n")[0].trim() : "");
|
||||
// 框里是文件名而不是路径时(弹幕名、视频名这种)不算路径:这两个框从录播目录开始,其它从程序所在目录开始
|
||||
if(start.indexOf("/") < 0 && start.indexOf("\\") < 0) start = (id === "mrgDanmu" || !id) ? recDir : "";
|
||||
if(!startAt && start.indexOf("/") < 0 && start.indexOf("\\") < 0) start = (id === "mrgDanmu" || !id) ? recDir : "";
|
||||
pickGo(start);
|
||||
}
|
||||
function closePick(){ document.getElementById("pick").classList.remove("on"); }
|
||||
@@ -1573,37 +1587,76 @@ function defaultTranscodeOpts(){
|
||||
function defaultTranscodeOut(p){
|
||||
return p.name.replace(/\.[^.]+$/, "") + "_转码.mp4";
|
||||
}
|
||||
// 一个转码任务的身份:有绝对路径就用它(同名文件在不同文件夹里不会认成一个),没有才退回 dir+name
|
||||
function tcJobKey(x){
|
||||
if(!x) return "";
|
||||
if(x.path) return String(x.path).toLowerCase();
|
||||
return ((x.dir ? x.dir + "/" : "") + (x.name || "")).toLowerCase();
|
||||
}
|
||||
// 从「文件列表」下拉框里把勾中的加进待转码列表
|
||||
async function addTranscodeFiles(){
|
||||
var sel = document.getElementById("tcFilePick");
|
||||
var picks = [];
|
||||
var cands = [];
|
||||
Array.prototype.forEach.call(sel.options, function(o){
|
||||
if(o.selected){
|
||||
var f = tcVideos[parseInt(o.value, 10)];
|
||||
if(f && !tcJobs.some(function(j){ return j.dir === f.dir && j.name === f.name; })) picks.push(f);
|
||||
}
|
||||
if(!o.selected) return;
|
||||
var f = tcVideos[parseInt(o.value, 10)];
|
||||
if(f) cands.push({dir: f.dir, name: f.name});
|
||||
});
|
||||
if(!picks.length){ showMsg(false, tcJobs.length ? "选中的文件已经在列表里了" : "请先选择要转码的文件"); return; }
|
||||
if(!cands.length){ showMsg(false, tcJobs.length ? "请先在左侧列表里勾选文件" : "请先选择要转码的文件"); return; }
|
||||
await addTranscodeCands(cands);
|
||||
}
|
||||
// 把输入框里的路径加进待转码列表(一行一个,空行忽略)
|
||||
function addTranscodePathsFromBox(){
|
||||
var lines = transcodePathLines();
|
||||
if(!lines.length){ showMsg(false, "请先在输入框里填文件路径,或者点「浏览…」挑"); return; }
|
||||
return addTranscodeCands(lines.map(function(p){ return {path: p}; }));
|
||||
}
|
||||
function transcodePathLines(){
|
||||
var el = document.getElementById("tcPaths");
|
||||
if(!el) return [];
|
||||
return el.value.split("\n").map(function(s){ return s.trim(); }).filter(function(s){ return s; });
|
||||
}
|
||||
function clearTranscodePathBox(){ document.getElementById("tcPaths").value = ""; }
|
||||
// 浏览按钮:走和手动合并一样的目录选择器,可多选、可跨文件夹跨盘攒;
|
||||
// 选完只往输入框里追加,不清掉已经填好的
|
||||
function browseTranscodePaths(){
|
||||
openPick(null, "file", true, function(paths){
|
||||
var el = document.getElementById("tcPaths");
|
||||
var lines = transcodePathLines();
|
||||
(paths || []).forEach(function(p){
|
||||
if(p && lines.indexOf(p) < 0) lines.push(p);
|
||||
});
|
||||
el.value = lines.join("\n");
|
||||
}, mergeDir);
|
||||
}
|
||||
// 加入待转码列表的统一入口:cands 每项要么 {path}(浏览/手填来的),要么 {dir,name}(文件列表挑的)
|
||||
async function addTranscodeCands(cands){
|
||||
if(!cands || !cands.length) return;
|
||||
var r = null;
|
||||
try{
|
||||
r = await api("/api/transcode/probe", {method:"POST", headers:{"Content-Type":"application/json"},
|
||||
body: JSON.stringify({files: picks.map(function(f){ return {dir: f.dir, name: f.name}; })})});
|
||||
body: JSON.stringify({files: cands})});
|
||||
}catch(e){}
|
||||
if(r && r.status === 401){ showLogin("管理口令已失效,请重新输入"); return; }
|
||||
if(!r || !r.ok){ showMsg(false, r ? await r.text() : "连接失败"); return; }
|
||||
var d = null;
|
||||
try{ d = await r.json(); }catch(e){ showMsg(false, "读文件信息失败"); return; }
|
||||
if(d && d.encoders && d.encoders.length) tcEncoders = d.encoders;
|
||||
var skipped = [];
|
||||
var skipped = [], dup = 0, added = 0;
|
||||
(d.files || []).forEach(function(p){
|
||||
// 只有音轨(或只有封面图)的文件排进去也是白排,ffmpeg 会直接报没视频流
|
||||
if(!p.hasVideo){ skipped.push(p.name); return; }
|
||||
tcJobs.push({dir: p.dir, name: p.name, size: p.size, dur: p.duration, w: p.width, h: p.height,
|
||||
fps: p.fps, vkbps: p.videoKbps, akbps: p.audioKbps, audio: !!p.hasAudio, codec: p.videoCodec,
|
||||
out: defaultTranscodeOut(p), opts: defaultTranscodeOpts(), est: null});
|
||||
var key = tcJobKey(p);
|
||||
if(tcJobs.some(function(j){ return tcJobKey(j) === key; })){ dup++; return; }
|
||||
tcJobs.push({path: p.path || "", dir: p.dir || "", name: p.name, size: p.size, dur: p.duration,
|
||||
w: p.width, h: p.height, fps: p.fps, vkbps: p.videoKbps, akbps: p.audioKbps,
|
||||
audio: !!p.hasAudio, codec: p.videoCodec, out: defaultTranscodeOut(p), opts: defaultTranscodeOpts(), est: null});
|
||||
added++;
|
||||
});
|
||||
renderTranscodeRows();
|
||||
estimateTranscode();
|
||||
if(skipped.length) showMsg(false, "这些文件里没有视频轨,已跳过:" + skipped.join("、"));
|
||||
else if(!added && dup) showMsg(false, "选中的文件已经在列表里了");
|
||||
}
|
||||
function clearTranscodeFiles(){
|
||||
if(tcBusy) return;
|
||||
@@ -1655,7 +1708,7 @@ function renderTranscodeRows(){
|
||||
return h === 0 || !job.h || h < job.h;
|
||||
});
|
||||
return '<div class="trow" data-i="' + i + '">'
|
||||
+ '<div class="th"><span class="tn">' + esc(job.name) + '</span>'
|
||||
+ '<div class="th"><span class="tn" title="' + esc(job.path || job.name) + '">' + esc(job.name) + '</span>'
|
||||
+ '<span class="tm">' + esc(meta) + '</span>'
|
||||
+ '<button class="mini" onclick="removeTranscodeFile(' + i + ')">移除</button></div>'
|
||||
+ '<div class="tg">'
|
||||
@@ -1728,7 +1781,7 @@ function scheduleEstimate(){
|
||||
async function estimateTranscode(){
|
||||
if(!tcJobs.length){ updateTranscodeTotal(); return; }
|
||||
var seq = ++tcEstSeq;
|
||||
var body = {jobs: tcJobs.map(function(j){ return {dir: j.dir, name: j.name, options: j.opts}; })};
|
||||
var body = {jobs: tcJobs.map(function(j){ return {path: j.path || "", dir: j.dir, name: j.name, options: j.opts}; })};
|
||||
var r = null;
|
||||
try{
|
||||
r = await api("/api/transcode/estimate", {method:"POST", headers:{"Content-Type":"application/json"}, body: JSON.stringify(body)});
|
||||
@@ -1819,7 +1872,7 @@ async function startTranscode(){
|
||||
var n = tcJobs.length;
|
||||
if(!confirm(n > 1 ? ("开始转码这 " + n + " 个文件?会按列表顺序一个一个来。") : "开始转码?")) return;
|
||||
var body = {outDir: document.getElementById("tcOutDir").value.trim(),
|
||||
jobs: tcJobs.map(function(j){ return {dir: j.dir, name: j.name, outName: j.out, options: j.opts}; })};
|
||||
jobs: tcJobs.map(function(j){ return {path: j.path || "", dir: j.dir, name: j.name, outName: j.out, options: j.opts}; })};
|
||||
var b = document.getElementById("tcGo");
|
||||
b.disabled = true;
|
||||
var r = null;
|
||||
@@ -2378,18 +2431,6 @@ func statusHandler(w http.ResponseWriter, r *http.Request) {
|
||||
checkErr(err)
|
||||
}
|
||||
|
||||
// 检查配置里的文件夹字段,返回错误信息,空字符串表示通过
|
||||
func checkWebDir(path, name string) string {
|
||||
if path == "" {
|
||||
return ""
|
||||
}
|
||||
info, err := os.Stat(path)
|
||||
if err != nil || !info.IsDir() {
|
||||
return name + " 必须是存在的文件夹:" + path
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
// 修改设置(保存目录和自动合并相关)
|
||||
func webConfigHandler(w http.ResponseWriter, r *http.Request) {
|
||||
var req struct {
|
||||
@@ -2428,11 +2469,11 @@ func webConfigHandler(w http.ResponseWriter, r *http.Request) {
|
||||
http.Error(w, "请求不是合法的 json:"+err.Error(), http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
if msg := checkWebDir(req.Directory, "directory"); msg != "" {
|
||||
if msg := checkDirField(req.Directory, "directory"); msg != "" {
|
||||
http.Error(w, msg, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
if msg := checkWebDir(req.MergeOutputDir, "mergeOutputDir"); msg != "" {
|
||||
if msg := checkDirField(req.MergeOutputDir, "mergeOutputDir"); msg != "" {
|
||||
http.Error(w, msg, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
@@ -2541,9 +2582,6 @@ func webConfigHandler(w http.ResponseWriter, r *http.Request) {
|
||||
config.MeowHTMLHeight = clampMeowHTMLHeight(req.MeowHTMLHeight)
|
||||
config.MeowImgURL = meowImgURL
|
||||
// 修改了子文件夹名后确保新文件夹存在
|
||||
if err := os.MkdirAll(recordingDir(), 0755); err != nil {
|
||||
lPrintWarnf("创建文件夹 %s 失败:%v", recordingDir(), err)
|
||||
}
|
||||
if err := os.MkdirAll(recordSaveDir(), 0755); err != nil {
|
||||
lPrintWarnf("创建文件夹 %s 失败:%v", recordSaveDir(), err)
|
||||
}
|
||||
|
||||
@@ -350,6 +350,7 @@ func TestWebuiSettingFieldsMatchInputs(t *testing.T) {
|
||||
"pickPath": "路径选择弹窗的内部状态",
|
||||
"mrgVideoPick": "手动合并:视频列表,随合并请求提交",
|
||||
"tcFilePick": "转码:待选文件列表,随转码请求提交",
|
||||
"tcPaths": "转码:手填的文件路径列表,随转码请求提交",
|
||||
"tcOutDir": "转码:输出目录,随转码请求提交",
|
||||
}
|
||||
for id := range ids {
|
||||
|
||||
Reference in New Issue
Block a user