ffmpeg_helper.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675
  1. package ffmpeg_helper
  2. import (
  3. "bytes"
  4. "errors"
  5. "fmt"
  6. "github.com/allanpk716/ChineseSubFinder/internal/common"
  7. "github.com/allanpk716/ChineseSubFinder/internal/logic/sub_parser/ass"
  8. "github.com/allanpk716/ChineseSubFinder/internal/logic/sub_parser/srt"
  9. "github.com/allanpk716/ChineseSubFinder/internal/pkg/language"
  10. "github.com/allanpk716/ChineseSubFinder/internal/pkg/log_helper"
  11. "github.com/allanpk716/ChineseSubFinder/internal/pkg/my_util"
  12. "github.com/allanpk716/ChineseSubFinder/internal/pkg/sub_parser_hub"
  13. "github.com/tidwall/gjson"
  14. "os"
  15. "os/exec"
  16. "path/filepath"
  17. "strings"
  18. )
  19. type FFMPEGHelper struct {
  20. SubParserHub *sub_parser_hub.SubParserHub // 字幕内容的解析器
  21. }
  22. func NewFFMPEGHelper() *FFMPEGHelper {
  23. return &FFMPEGHelper{
  24. SubParserHub: sub_parser_hub.NewSubParserHub(ass.NewParser(), srt.NewParser()),
  25. }
  26. }
  27. // Version 获取版本信息,如果不存在 FFMPEG 和 ffprobe 则报错
  28. func (f FFMPEGHelper) Version() (string, error) {
  29. outMsg0, err := f.getVersion("ffmpeg")
  30. if err != nil {
  31. return "", err
  32. }
  33. outMsg1, err := f.getVersion("ffprobe")
  34. if err != nil {
  35. return "", err
  36. }
  37. return outMsg0 + "\r\n" + outMsg1, nil
  38. }
  39. // GetFFMPEGInfo 获取 视频的 FFMPEG 信息,包含音频和字幕
  40. // 优先会导出 中、英、日、韩 类型的,字幕如果没有语言类型,则也导出,然后需要额外的字幕语言的判断去辅助标记(读取文件内容)
  41. func (f *FFMPEGHelper) GetFFMPEGInfo(videoFileFullPath string, exportType ExportType) (bool, *FFMPEGInfo, error) {
  42. const args = "-v error -show_format -show_streams -print_format json"
  43. cmdArgs := strings.Fields(args)
  44. cmdArgs = append(cmdArgs, videoFileFullPath)
  45. cmd := exec.Command("ffprobe", cmdArgs...)
  46. buf := bytes.NewBufferString("")
  47. //指定输出位置
  48. cmd.Stderr = buf
  49. cmd.Stdout = buf
  50. err := cmd.Start()
  51. if err != nil {
  52. return false, nil, err
  53. }
  54. err = cmd.Wait()
  55. if err != nil {
  56. return false, nil, err
  57. }
  58. // 解析得到的字符串反馈
  59. bok, ffMPEGInfo := f.parseJsonString2GetFFProbeInfo(videoFileFullPath, buf.String())
  60. if bok == false {
  61. return false, nil, nil
  62. }
  63. nowCacheFolderPath, err := ffMPEGInfo.GetCacheFolderFPath()
  64. if err != nil {
  65. return false, nil, err
  66. }
  67. // 在函数调用完毕后,判断是否需要清理
  68. defer func() {
  69. if bok == false && ffMPEGInfo != nil {
  70. err := os.RemoveAll(nowCacheFolderPath)
  71. if err != nil {
  72. log_helper.GetLogger().Errorln("GetFFMPEGInfo - RemoveAll", err.Error())
  73. return
  74. }
  75. }
  76. }()
  77. // 查找当前这个视频外置字幕列表
  78. err = ffMPEGInfo.GetExternalSubInfos(f.SubParserHub)
  79. if err != nil {
  80. return false, nil, err
  81. }
  82. // 判断这个视频是否已经导出过内置的字幕和音频文件了
  83. if ffMPEGInfo.IsExported(exportType) == false {
  84. // 说明缓存不存在,需要导出,这里需要注意,如果导出失败了,这个文件夹要清理掉
  85. if my_util.IsDir(nowCacheFolderPath) == true {
  86. // 如果存在则,先清空一个这个文件夹
  87. err = my_util.ClearFolder(nowCacheFolderPath)
  88. if err != nil {
  89. bok = false
  90. return bok, nil, err
  91. }
  92. }
  93. // 开始导出
  94. // 构建导出的命令参数
  95. exportAudioArgs, exportSubArgs := f.getAudioAndSubExportArgs(videoFileFullPath, ffMPEGInfo)
  96. // 上面导出的信息,可能是 nil 参数,那么就直接把导出的 List 信息给置为 nil,让后续有依据可以跳出,不继续执行
  97. if exportType == Subtitle {
  98. if exportSubArgs == nil {
  99. ffMPEGInfo.SubtitleInfoList = nil
  100. return true, ffMPEGInfo, nil
  101. }
  102. } else if exportType == Audio {
  103. if exportAudioArgs == nil {
  104. ffMPEGInfo.AudioInfoList = nil
  105. return true, ffMPEGInfo, nil
  106. }
  107. } else if exportType == SubtitleAndAudio {
  108. if exportAudioArgs == nil || exportSubArgs == nil {
  109. if exportAudioArgs == nil {
  110. ffMPEGInfo.AudioInfoList = nil
  111. }
  112. if exportSubArgs == nil {
  113. ffMPEGInfo.SubtitleInfoList = nil
  114. }
  115. return true, ffMPEGInfo, nil
  116. }
  117. } else {
  118. log_helper.GetLogger().Errorln("GetFFMPEGInfo.getAudioAndSubExportArgs Not Support ExportType")
  119. return false, nil, nil
  120. }
  121. // 上面的操作为了就是确保后续的导出不会出问题
  122. // 执行导出,音频和内置的字幕
  123. execErrorString, err := f.exportAudioAndSubtitles(exportAudioArgs, exportSubArgs, exportType)
  124. if err != nil {
  125. log_helper.GetLogger().Errorln("exportAudioAndSubtitles", execErrorString)
  126. bok = false
  127. return bok, nil, err
  128. }
  129. // 导出后,需要把现在导出的文件的路径给复制给 ffMPEGInfo 中
  130. // 音频是否导出了
  131. ffMPEGInfo.isAudioExported(nowCacheFolderPath)
  132. // 字幕都要导出了
  133. ffMPEGInfo.isSubExported(nowCacheFolderPath)
  134. // 创建 exportedMakeFileName 这个文件
  135. // 成功,那么就需要生成这个 exportedMakeFileName 文件
  136. err = ffMPEGInfo.CreateExportedMask()
  137. if err != nil {
  138. return false, nil, err
  139. }
  140. }
  141. return bok, ffMPEGInfo, nil
  142. }
  143. // GetAudioDurationInfo 获取音频的长度信息
  144. func (f *FFMPEGHelper) GetAudioDurationInfo(audioFileFullPath string) (bool, float64, error) {
  145. const args = "-v error -show_format -show_streams -print_format json -f s16le -ac 1 -ar 16000"
  146. cmdArgs := strings.Fields(args)
  147. cmdArgs = append(cmdArgs, audioFileFullPath)
  148. cmd := exec.Command("ffprobe", cmdArgs...)
  149. buf := bytes.NewBufferString("")
  150. //指定输出位置
  151. cmd.Stderr = buf
  152. cmd.Stdout = buf
  153. err := cmd.Start()
  154. if err != nil {
  155. return false, 0, err
  156. }
  157. err = cmd.Wait()
  158. if err != nil {
  159. return false, 0, err
  160. }
  161. bok, duration := f.parseJsonString2GetAudioInfo(buf.String())
  162. if bok == false {
  163. return false, 0, errors.New("ffprobe get " + audioFileFullPath + " duration error")
  164. }
  165. return true, duration, nil
  166. }
  167. // ExportAudioAndSubArgsByTimeRange 根据输入的时间轴导出音频分段信息 "0:1:27" "28.2"
  168. func (f *FFMPEGHelper) ExportAudioAndSubArgsByTimeRange(audioFullPath, subFullPath string, startTimeString, timeLength string) (string, string, string, error) {
  169. outStartTimeString := strings.ReplaceAll(startTimeString, ":", "-")
  170. outStartTimeString = strings.ReplaceAll(outStartTimeString, ".", "#")
  171. outTimeLength := strings.ReplaceAll(timeLength, ".", "#")
  172. frontName := strings.ReplaceAll(filepath.Base(audioFullPath), filepath.Ext(audioFullPath), "")
  173. outAudioName := frontName + "_" + outStartTimeString + "_" + outTimeLength + filepath.Ext(audioFullPath)
  174. outSubName := frontName + "_" + outStartTimeString + "_" + outTimeLength + common.SubExtSRT
  175. var outAudioFullPath = filepath.Join(filepath.Dir(audioFullPath), outAudioName)
  176. var outSubFullPath = filepath.Join(filepath.Dir(audioFullPath), outSubName)
  177. // 导出音频
  178. if my_util.IsFile(outAudioFullPath) == true {
  179. err := os.Remove(outAudioFullPath)
  180. if err != nil {
  181. return "", "", "", err
  182. }
  183. }
  184. args := f.getAudioExportArgsByTimeRange(audioFullPath, startTimeString, timeLength, outAudioFullPath)
  185. execFFMPEG, err := f.execFFMPEG(args)
  186. if err != nil {
  187. return "", "", execFFMPEG, err
  188. }
  189. // 导出字幕
  190. if my_util.IsFile(outSubFullPath) == true {
  191. err := os.Remove(outSubFullPath)
  192. if err != nil {
  193. return "", "", "", err
  194. }
  195. }
  196. args = f.getSubExportArgsByTimeRange(subFullPath, startTimeString, timeLength, outSubFullPath)
  197. execFFMPEG, err = f.execFFMPEG(args)
  198. if err != nil {
  199. return "", "", execFFMPEG, err
  200. }
  201. return outAudioFullPath, outSubFullPath, "", nil
  202. }
  203. // ExportSubArgsByTimeRange 根据输入的时间轴导出字幕分段信息 "0:1:27" "28.2"
  204. func (f *FFMPEGHelper) ExportSubArgsByTimeRange(subFullPath, outName string, startTimeString, timeLength string) (string, string, error) {
  205. outStartTimeString := strings.ReplaceAll(startTimeString, ":", "-")
  206. outStartTimeString = strings.ReplaceAll(outStartTimeString, ".", "#")
  207. outTimeLength := strings.ReplaceAll(timeLength, ".", "#")
  208. frontName := strings.ReplaceAll(filepath.Base(subFullPath), filepath.Ext(subFullPath), "")
  209. outSubName := frontName + "_" + outStartTimeString + "_" + outTimeLength + "_" + outName + common.SubExtSRT
  210. var outSubFullPath = filepath.Join(filepath.Dir(subFullPath), outSubName)
  211. // 导出字幕
  212. if my_util.IsFile(outSubFullPath) == true {
  213. err := os.Remove(outSubFullPath)
  214. if err != nil {
  215. return "", "", err
  216. }
  217. }
  218. args := f.getSubExportArgsByTimeRange(subFullPath, startTimeString, timeLength, outSubFullPath)
  219. execFFMPEG, err := f.execFFMPEG(args)
  220. if err != nil {
  221. return "", execFFMPEG, err
  222. }
  223. return outSubFullPath, "", nil
  224. }
  225. // parseJsonString2GetFFProbeInfo 使用 ffprobe 获取视频的 stream 信息,从中解析出字幕和音频的索引
  226. func (f *FFMPEGHelper) parseJsonString2GetFFProbeInfo(videoFileFullPath, inputFFProbeString string) (bool, *FFMPEGInfo) {
  227. streamsValue := gjson.Get(inputFFProbeString, "streams.#")
  228. if streamsValue.Exists() == false {
  229. return false, nil
  230. }
  231. ffmpegInfo := NewFFMPEGInfo(videoFileFullPath)
  232. // 进行字幕和音频的缓存,优先当然是导出 中、英、日、韩 相关的字幕和音频
  233. // 但是如果都没得这些的时候,那么也需要导出至少一个字幕或者音频,用于字幕的校正
  234. cacheAudios := make([]AudioInfo, 0)
  235. cacheSubtitleInfos := make([]SubtitleInfo, 0)
  236. for i := 0; i < int(streamsValue.Num); i++ {
  237. oneIndex := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.index", i))
  238. oneCodecName := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.codec_name", i))
  239. oneCodecType := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.codec_type", i))
  240. oneTimeBase := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.time_base", i))
  241. oneStartTime := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.start_time", i))
  242. oneLanguage := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.tags.language", i))
  243. // 任意一个字段不存在则跳过
  244. if oneIndex.Exists() == false {
  245. continue
  246. }
  247. if oneCodecName.Exists() == false {
  248. continue
  249. }
  250. if oneCodecType.Exists() == false {
  251. continue
  252. }
  253. if oneTimeBase.Exists() == false {
  254. continue
  255. }
  256. if oneStartTime.Exists() == false {
  257. continue
  258. }
  259. // 这里需要区分是字幕还是音频
  260. if oneCodecType.String() == codecTypeSub {
  261. // 字幕
  262. // 只解析 subrip 类型的,不支持 hdmv_pgs_subtitle 的字幕导出
  263. if f.isSupportSubCodecName(oneCodecName.String()) == false {
  264. continue
  265. }
  266. // 这里非必须解析到 language 字段,把所有的都导出来,然后通过额外字幕语言判断即可
  267. oneDurationTS := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.duration_ts", i))
  268. oneDuration := gjson.Get(inputFFProbeString, fmt.Sprintf("streams.%d.duration", i))
  269. // 必须存在的
  270. if oneDurationTS.Exists() == false {
  271. continue
  272. }
  273. if oneDuration.Exists() == false {
  274. continue
  275. }
  276. // 非必须存在的
  277. nowLanguageString := ""
  278. if oneLanguage.Exists() == true {
  279. nowLanguageString = oneLanguage.String()
  280. // 只导出 中、英、日、韩
  281. if language.IsSupportISOString(nowLanguageString) == false {
  282. subInfo := NewSubtitleInfo(int(oneIndex.Num), oneCodecName.String(), oneCodecType.String(),
  283. oneTimeBase.String(), oneStartTime.String(),
  284. int(oneDurationTS.Num), oneDuration.String(), nowLanguageString)
  285. // 不符合的也存在下来,万一,符合要求的一个都没得的时候,就需要从里面挑几个出来了
  286. cacheSubtitleInfos = append(cacheSubtitleInfos, *subInfo)
  287. continue
  288. }
  289. }
  290. subInfo := NewSubtitleInfo(int(oneIndex.Num), oneCodecName.String(), oneCodecType.String(),
  291. oneTimeBase.String(), oneStartTime.String(),
  292. int(oneDurationTS.Num), oneDuration.String(), nowLanguageString)
  293. ffmpegInfo.SubtitleInfoList = append(ffmpegInfo.SubtitleInfoList, *subInfo)
  294. } else if oneCodecType.String() == codecTypeAudio {
  295. // 音频
  296. // 这里必要要能够解析到 language 字段
  297. if oneLanguage.Exists() == false {
  298. // 不符合的也存在下来,万一,符合要求的一个都没得的时候,就需要从里面挑几个出来了
  299. audioInfo := NewAudioInfo(int(oneIndex.Num), oneCodecName.String(), oneCodecType.String(),
  300. oneTimeBase.String(), oneStartTime.String(), oneLanguage.String())
  301. cacheAudios = append(cacheAudios, *audioInfo)
  302. continue
  303. }
  304. // 只导出 中、英、日、韩
  305. if language.IsSupportISOString(oneLanguage.String()) == false {
  306. // 不符合的也存在下来,万一,符合要求的一个都没得的时候,就需要从里面挑几个出来了
  307. audioInfo := NewAudioInfo(int(oneIndex.Num), oneCodecName.String(), oneCodecType.String(),
  308. oneTimeBase.String(), oneStartTime.String(), oneLanguage.String())
  309. cacheAudios = append(cacheAudios, *audioInfo)
  310. continue
  311. }
  312. audioInfo := NewAudioInfo(int(oneIndex.Num), oneCodecName.String(), oneCodecType.String(),
  313. oneTimeBase.String(), oneStartTime.String(), oneLanguage.String())
  314. ffmpegInfo.AudioInfoList = append(ffmpegInfo.AudioInfoList, *audioInfo)
  315. } else {
  316. continue
  317. }
  318. }
  319. // 如何没有找到合适的字幕,那么就要把缓存的字幕选一个填充进去
  320. if len(ffmpegInfo.SubtitleInfoList) == 0 {
  321. if len(cacheSubtitleInfos) != 0 {
  322. ffmpegInfo.SubtitleInfoList = append(ffmpegInfo.SubtitleInfoList, cacheSubtitleInfos[0])
  323. }
  324. }
  325. // 如何没有找到合适的音频,那么就要把缓存的音频选一个填充进去
  326. if len(ffmpegInfo.AudioInfoList) == 0 {
  327. if len(cacheAudios) != 0 {
  328. ffmpegInfo.AudioInfoList = append(ffmpegInfo.AudioInfoList, cacheAudios[0])
  329. }
  330. } else {
  331. // 音频只需要导出一个就行了,取第一个
  332. newAudioList := make([]AudioInfo, 0)
  333. newAudioList = append(newAudioList, ffmpegInfo.AudioInfoList[0])
  334. ffmpegInfo.AudioInfoList = newAudioList
  335. }
  336. return true, ffmpegInfo
  337. }
  338. // parseJsonString2GetAudioInfo 获取 pcm 音频的长度
  339. func (f *FFMPEGHelper) parseJsonString2GetAudioInfo(inputFFProbeString string) (bool, float64) {
  340. durationValue := gjson.Get(inputFFProbeString, "format.duration")
  341. if durationValue.Exists() == false {
  342. return false, 0
  343. }
  344. return true, durationValue.Float()
  345. }
  346. // exportAudioAndSubtitles 导出音频和字幕文件
  347. func (f *FFMPEGHelper) exportAudioAndSubtitles(audioArgs, subArgs []string, exportType ExportType) (string, error) {
  348. // 输入的两个数组,有可能是 nil
  349. // 这里导出依赖的是 ffmpeg 这个程序,需要的是构建导出的语句
  350. if exportType == SubtitleAndAudio {
  351. execErrorString, err := f.execFFMPEG(audioArgs)
  352. if err != nil {
  353. return execErrorString, err
  354. }
  355. execErrorString, err = f.execFFMPEG(subArgs)
  356. if err != nil {
  357. return execErrorString, err
  358. }
  359. } else if exportType == Audio {
  360. execErrorString, err := f.execFFMPEG(audioArgs)
  361. if err != nil {
  362. return execErrorString, err
  363. }
  364. } else if exportType == Subtitle {
  365. execErrorString, err := f.execFFMPEG(subArgs)
  366. if err != nil {
  367. return execErrorString, err
  368. }
  369. } else {
  370. return "", errors.New("FFMPEGHelper ExportType not support")
  371. }
  372. return "", nil
  373. }
  374. // execFFMPEG 执行 ffmpeg 命令
  375. func (f *FFMPEGHelper) execFFMPEG(cmds []string) (string, error) {
  376. if cmds == nil || len(cmds) == 0 {
  377. return "", nil
  378. }
  379. cmd := exec.Command("ffmpeg", cmds...)
  380. buf := bytes.NewBufferString("")
  381. //指定输出位置
  382. cmd.Stderr = buf
  383. cmd.Stdout = buf
  384. err := cmd.Start()
  385. if err != nil {
  386. return buf.String(), err
  387. }
  388. err = cmd.Wait()
  389. if err != nil {
  390. return buf.String(), err
  391. }
  392. return "", nil
  393. }
  394. // getAudioAndSubExportArgs 构建从原始视频导出字幕、音频的 ffmpeg 的参数 audioArgs, subArgs
  395. func (f *FFMPEGHelper) getAudioAndSubExportArgs(videoFileFullPath string, ffmpegInfo *FFMPEGInfo) ([]string, []string) {
  396. /*
  397. 导出多个字幕
  398. ffmpeg.exe -i xx.mp4 -vn -an -map 0:7 subs-7.srt -map 0:6 subs-6.srt
  399. 导出音频,从 1m 27s 开始,导出向后的 28 s,转换为 mp3 格式
  400. ffmpeg.exe -i xx.mp4 -vn -map 0:1 -ss 00:1:27 -f mp3 -t 28 audio.mp3
  401. 导出音频,转换为 mp3 格式
  402. ffmpeg.exe -i xx.mp4 -vn -map 0:1 -f mp3 audio.mp3
  403. 导出音频,转换为 16000k 16bit 单通道 采样率的 test.pcm
  404. ffmpeg.exe -i xx.mp4 -vn -map 0:1 -ss 00:1:27 -t 28 -acodec pcm_s16le -f s16le -ac 1 -ar 16000 test.pcm
  405. 截取字幕的时间片段
  406. ffmpeg.exe -i "subs-3.srt" -ss 00:1:27 -t 28 subs-3-cut-from-org.srt
  407. */
  408. var subArgs = make([]string, 0)
  409. var audioArgs = make([]string, 0)
  410. // 基础的输入视频参数
  411. subArgs = append(subArgs, "-i")
  412. audioArgs = append(audioArgs, "-i")
  413. subArgs = append(subArgs, videoFileFullPath)
  414. audioArgs = append(audioArgs, videoFileFullPath)
  415. // 字幕导出的参数构建
  416. subArgs = append(subArgs, "-vn") // 不输出视频流
  417. subArgs = append(subArgs, "-an") // 不输出音频流
  418. nowCacheFolderPath, err := ffmpegInfo.GetCacheFolderFPath()
  419. if err != nil {
  420. log_helper.GetLogger().Errorln("getAudioAndSubExportArgs", videoFileFullPath, err.Error())
  421. return nil, nil
  422. }
  423. if len(ffmpegInfo.SubtitleInfoList) == 0 {
  424. // 如果没有,就返回空
  425. subArgs = nil
  426. } else {
  427. for _, subtitleInfo := range ffmpegInfo.SubtitleInfoList {
  428. f.addSubMapArg(&subArgs, subtitleInfo.Index,
  429. filepath.Join(nowCacheFolderPath, subtitleInfo.GetName()+common.SubExtSRT))
  430. f.addSubMapArg(&subArgs, subtitleInfo.Index,
  431. filepath.Join(nowCacheFolderPath, subtitleInfo.GetName()+common.SubExtASS))
  432. }
  433. }
  434. // 音频导出的参数构建
  435. audioArgs = append(audioArgs, "-vn")
  436. if len(ffmpegInfo.AudioInfoList) == 0 {
  437. // 如果没有,就返回空
  438. audioArgs = nil
  439. } else {
  440. for _, audioInfo := range ffmpegInfo.AudioInfoList {
  441. f.addAudioMapArg(&audioArgs, audioInfo.Index,
  442. filepath.Join(nowCacheFolderPath, audioInfo.GetName()+extPCM))
  443. }
  444. }
  445. return audioArgs, subArgs
  446. }
  447. // getAudioAndSubExportArgsByTimeRange 导出某个时间范围内的音频和字幕文件文件 startTimeString 00:1:27 timeLeng 向后多少秒
  448. func (f *FFMPEGHelper) getAudioExportArgsByTimeRange(audioFullPath string, startTimeString, timeLeng, outAudioFullPath string) []string {
  449. /*
  450. ffmpeg.exe -ar 16000 -ac 1 -f s16le -i aa.pcm -ss 00:1:27 -t 28 -acodec pcm_s16le -f s16le -ac 1 -ar 16000 bb.pcm
  451. ffmpeg.exe -i aa.srt -ss 00:1:27 -t 28 bb.srt
  452. */
  453. var audioArgs = make([]string, 0)
  454. // 指定读取的音频文件编码格式
  455. audioArgs = append(audioArgs, "-ar")
  456. audioArgs = append(audioArgs, "16000")
  457. audioArgs = append(audioArgs, "-ac")
  458. audioArgs = append(audioArgs, "1")
  459. audioArgs = append(audioArgs, "-f")
  460. audioArgs = append(audioArgs, "s16le")
  461. audioArgs = append(audioArgs, "-i")
  462. audioArgs = append(audioArgs, audioFullPath)
  463. audioArgs = append(audioArgs, "-ss")
  464. audioArgs = append(audioArgs, startTimeString)
  465. audioArgs = append(audioArgs, "-t")
  466. audioArgs = append(audioArgs, timeLeng)
  467. // 指定导出的音频文件编码格式
  468. audioArgs = append(audioArgs, "-acodec")
  469. audioArgs = append(audioArgs, "pcm_s16le")
  470. audioArgs = append(audioArgs, "-f")
  471. audioArgs = append(audioArgs, "s16le")
  472. audioArgs = append(audioArgs, "-ac")
  473. audioArgs = append(audioArgs, "1")
  474. audioArgs = append(audioArgs, "-ar")
  475. audioArgs = append(audioArgs, "16000")
  476. audioArgs = append(audioArgs, outAudioFullPath)
  477. return audioArgs
  478. }
  479. func (f *FFMPEGHelper) getSubExportArgsByTimeRange(subFullPath string, startTimeString, timeLength, outSubFullPath string) []string {
  480. /*
  481. ffmpeg.exe -i aa.srt -ss 00:1:27 -t 28 bb.srt
  482. */
  483. var subArgs = make([]string, 0)
  484. subArgs = append(subArgs, "-i")
  485. subArgs = append(subArgs, subFullPath)
  486. subArgs = append(subArgs, "-ss")
  487. subArgs = append(subArgs, startTimeString)
  488. subArgs = append(subArgs, "-t")
  489. subArgs = append(subArgs, timeLength)
  490. subArgs = append(subArgs, outSubFullPath)
  491. return subArgs
  492. }
  493. // addSubMapArg 构建字幕的导出参数
  494. func (f *FFMPEGHelper) addSubMapArg(subArgs *[]string, index int, subSaveFullPath string) {
  495. *subArgs = append(*subArgs, "-map")
  496. *subArgs = append(*subArgs, fmt.Sprintf("0:%d", index))
  497. *subArgs = append(*subArgs, subSaveFullPath)
  498. }
  499. // addAudioMapArg 构建音频的导出参数
  500. func (f *FFMPEGHelper) addAudioMapArg(subArgs *[]string, index int, audioSaveFullPath string) {
  501. // -acodec pcm_s16le -f s16le -ac 1 -ar 16000
  502. *subArgs = append(*subArgs, "-map")
  503. *subArgs = append(*subArgs, fmt.Sprintf("0:%d", index))
  504. *subArgs = append(*subArgs, "-acodec")
  505. *subArgs = append(*subArgs, "pcm_s16le")
  506. *subArgs = append(*subArgs, "-f")
  507. *subArgs = append(*subArgs, "s16le")
  508. *subArgs = append(*subArgs, "-ac")
  509. *subArgs = append(*subArgs, "1")
  510. *subArgs = append(*subArgs, "-ar")
  511. *subArgs = append(*subArgs, "16000")
  512. *subArgs = append(*subArgs, audioSaveFullPath)
  513. }
  514. func (f FFMPEGHelper) getVersion(exeName string) (string, error) {
  515. const args = "-version"
  516. cmdArgs := strings.Fields(args)
  517. cmd := exec.Command(exeName, cmdArgs...)
  518. buf := bytes.NewBufferString("")
  519. //指定输出位置
  520. cmd.Stderr = buf
  521. cmd.Stdout = buf
  522. err := cmd.Start()
  523. if err != nil {
  524. return "", err
  525. }
  526. err = cmd.Wait()
  527. if err != nil {
  528. return "", err
  529. }
  530. return buf.String(), nil
  531. }
  532. // isSupportSubCodecName 是否是 FFMPEG 支持的 CodecName
  533. func (f FFMPEGHelper) isSupportSubCodecName(name string) bool {
  534. switch name {
  535. case Subtitle_StreamCodec_subrip,
  536. Subtitle_StreamCodec_ass,
  537. Subtitle_StreamCodec_ssa,
  538. Subtitle_StreamCodec_srt:
  539. return true
  540. default:
  541. return false
  542. }
  543. }
  544. const (
  545. codecTypeSub = "subtitle"
  546. codecTypeAudio = "audio"
  547. extMP3 = ".mp3"
  548. extPCM = ".pcm"
  549. )
  550. type ExportType int
  551. const (
  552. Subtitle ExportType = iota // 导出字幕
  553. Audio // 导出音频
  554. SubtitleAndAudio // 导出字幕和音频
  555. )
  556. /*
  557. FFMPEG 支持的字幕 Codec Name:
  558. ..S... arib_caption ARIB STD-B24 caption
  559. DES... ass ASS (Advanced SSA) subtitle (decoders: ssa ass ) (encoders: ssa ass )
  560. DES... dvb_subtitle DVB subtitles (decoders: dvbsub ) (encoders: dvbsub )
  561. ..S... dvb_teletext DVB teletext
  562. DES... dvd_subtitle DVD subtitles (decoders: dvdsub ) (encoders: dvdsub )
  563. D.S... eia_608 EIA-608 closed captions (decoders: cc_dec )
  564. D.S... hdmv_pgs_subtitle HDMV Presentation Graphic Stream subtitles (decoders: pgssub )
  565. ..S... hdmv_text_subtitle HDMV Text subtitle
  566. D.S... jacosub JACOsub subtitle
  567. D.S... microdvd MicroDVD subtitle
  568. DES... mov_text MOV text
  569. D.S... mpl2 MPL2 subtitle
  570. D.S... pjs PJS (Phoenix Japanimation Society) subtitle
  571. D.S... realtext RealText subtitle
  572. D.S... sami SAMI subtitle
  573. ..S... srt SubRip subtitle with embedded timing
  574. ..S... ssa SSA (SubStation Alpha) subtitle
  575. D.S... stl Spruce subtitle format
  576. DES... subrip SubRip subtitle (decoders: srt subrip ) (encoders: srt subrip )
  577. D.S... subviewer SubViewer subtitle
  578. D.S... subviewer1 SubViewer v1 subtitle
  579. DES... text raw UTF-8 text
  580. ..S... ttml Timed Text Markup Language
  581. D.S... vplayer VPlayer subtitle
  582. DES... webvtt WebVTT subtitle
  583. DES... xsub XSUB
  584. */
  585. const (
  586. Subtitle_StreamCodec_subrip = "subrip"
  587. Subtitle_StreamCodec_ass = "ass"
  588. Subtitle_StreamCodec_ssa = "ssa"
  589. Subtitle_StreamCodec_srt = "srt"
  590. )