unarchiveFile.go 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. package archive_helper
  2. import (
  3. "archive/zip"
  4. "bytes"
  5. "compress/flate"
  6. "errors"
  7. "github.com/bodgit/sevenzip"
  8. "github.com/go-rod/rod/lib/utils"
  9. "github.com/mholt/archiver/v3"
  10. "golang.org/x/text/encoding/simplifiedchinese"
  11. "golang.org/x/text/transform"
  12. "io"
  13. "io/ioutil"
  14. "path/filepath"
  15. "strings"
  16. )
  17. // UnArchiveFile 7z 以外的都能搞定中文编码的问题,但是 7z 有梗,需要单独的库去解析,且编码是解决不了的,以后他们搞定了再测试
  18. // 所以效果就是,7z 外的压缩包文件解压ok,字幕可以正常从名称解析出是简体还是繁体,但是7z就没办法了,一定乱码
  19. func UnArchiveFile(fileFullPath, desRootPath string) error {
  20. switch filepath.Ext(strings.ToLower(fileFullPath)) {
  21. case ".zip":
  22. z := archiver.Zip{
  23. CompressionLevel: flate.DefaultCompression,
  24. MkdirAll: true,
  25. SelectiveCompression: true,
  26. ContinueOnError: false,
  27. OverwriteExisting: true,
  28. ImplicitTopLevelFolder: false,
  29. }
  30. err := z.Walk(fileFullPath, func(f archiver.File) error {
  31. if f.IsDir() == true {
  32. return nil
  33. }
  34. zfh, ok := f.Header.(zip.FileHeader)
  35. if ok {
  36. err := processOneFile(f, zfh.NonUTF8, desRootPath)
  37. if err != nil {
  38. return err
  39. }
  40. }
  41. return nil
  42. })
  43. if err != nil {
  44. return err
  45. }
  46. case ".tar":
  47. z := archiver.Tar{
  48. MkdirAll: true,
  49. ContinueOnError: false,
  50. OverwriteExisting: true,
  51. ImplicitTopLevelFolder: false,
  52. StripComponents: 1,
  53. }
  54. err := z.Walk(fileFullPath, func(f archiver.File) error {
  55. if f.IsDir() == true {
  56. return nil
  57. }
  58. err := processOneFile(f, false, desRootPath)
  59. if err != nil {
  60. return err
  61. }
  62. return nil
  63. })
  64. if err != nil {
  65. return err
  66. }
  67. case ".rar":
  68. z := archiver.Rar{
  69. MkdirAll: true,
  70. ContinueOnError: false,
  71. OverwriteExisting: true,
  72. ImplicitTopLevelFolder: false,
  73. StripComponents: 1,
  74. }
  75. err := z.Walk(fileFullPath, func(f archiver.File) error {
  76. if f.IsDir() == true {
  77. return nil
  78. }
  79. err := processOneFile(f, false, desRootPath)
  80. if err != nil {
  81. return err
  82. }
  83. return nil
  84. })
  85. if err != nil {
  86. return err
  87. }
  88. case ".7z":
  89. return unArr7z(fileFullPath, desRootPath)
  90. default:
  91. return errors.New("not support un archive file ext")
  92. }
  93. return nil
  94. }
  95. func processOneFile(f archiver.File, notUTF8 bool, desRootPath string) error {
  96. decodeName := f.Name()
  97. if notUTF8 == true {
  98. //ouBytes, err := ChangeFileCoding2UTF8([]byte(f.Name()))
  99. //if err != nil {
  100. // return err
  101. //}
  102. i := bytes.NewReader([]byte(f.Name()))
  103. decoder := transform.NewReader(i, simplifiedchinese.GB18030.NewDecoder())
  104. content, _ := ioutil.ReadAll(decoder)
  105. decodeName = string(content)
  106. //decodeName = string(ouBytes)
  107. }
  108. var chunk []byte
  109. buf := make([]byte, 1024)
  110. for {
  111. n, err := f.Read(buf)
  112. if err != nil && err != io.EOF {
  113. return err
  114. }
  115. //说明读取结束
  116. if n == 0 {
  117. break
  118. }
  119. //读取到最终的缓冲区中
  120. chunk = append(chunk, buf[:n]...)
  121. }
  122. err := utils.OutputFile(filepath.Join(desRootPath, decodeName), chunk)
  123. if err != nil {
  124. return err
  125. }
  126. return nil
  127. }
  128. func unArr7z(fileFullPath, desRootPath string) error {
  129. r, err := sevenzip.OpenReader(fileFullPath)
  130. if err != nil {
  131. return err
  132. }
  133. defer r.Close()
  134. for _, file := range r.File {
  135. err = un7zOneFile(file, desRootPath)
  136. if err != nil {
  137. return err
  138. }
  139. }
  140. return nil
  141. }
  142. func un7zOneFile(file *sevenzip.File, desRootPath string) error {
  143. rc, err := file.Open()
  144. if err != nil {
  145. return err
  146. }
  147. defer rc.Close()
  148. data, err := ioutil.ReadAll(rc)
  149. if err != nil {
  150. return err
  151. }
  152. decodeName := file.Name
  153. decodeName = filepath.Base(decodeName)
  154. err = utils.OutputFile(filepath.Join(desRootPath, decodeName), data)
  155. if err != nil {
  156. return err
  157. }
  158. return nil
  159. }
  160. func IsWantedArchiveExtName(fileName string) bool {
  161. switch strings.ToLower(filepath.Ext(fileName)) {
  162. case ".zip", ".tar", ".rar", "7z":
  163. return true
  164. default:
  165. return false
  166. }
  167. }