BookResult.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708
  1. package models
  2. import (
  3. "bytes"
  4. "io/ioutil"
  5. "os"
  6. "path/filepath"
  7. "strconv"
  8. "strings"
  9. "time"
  10. "encoding/json"
  11. "net/http"
  12. "regexp"
  13. "github.com/PuerkitoBio/goquery"
  14. "github.com/beego/beego/v2/adapter"
  15. "github.com/beego/beego/v2/client/orm"
  16. "github.com/beego/beego/v2/core/logs"
  17. "github.com/beego/beego/v2/server/web"
  18. "github.com/mindoc-org/mindoc/conf"
  19. "github.com/mindoc-org/mindoc/converter"
  20. "github.com/mindoc-org/mindoc/utils/cryptil"
  21. "github.com/mindoc-org/mindoc/utils/filetil"
  22. "github.com/mindoc-org/mindoc/utils/gopool"
  23. "github.com/mindoc-org/mindoc/utils/requests"
  24. "github.com/mindoc-org/mindoc/utils/ziptil"
  25. "github.com/russross/blackfriday/v2"
  26. )
  27. var (
  28. exportLimitWorkerChannel = gopool.NewChannelPool(conf.GetExportLimitNum(), conf.GetExportQueueLimitNum())
  29. )
  30. type BookResult struct {
  31. BookId int `json:"book_id"`
  32. BookName string `json:"book_name"`
  33. ItemId int `json:"item_id"`
  34. ItemName string `json:"item_name"`
  35. Identify string `json:"identify"`
  36. OrderIndex int `json:"order_index"`
  37. Description string `json:"description"`
  38. Publisher string `json:"publisher"`
  39. PrivatelyOwned int `json:"privately_owned"`
  40. PrivateToken string `json:"private_token"`
  41. BookPassword string `json:"book_password"`
  42. DocCount int `json:"doc_count"`
  43. CommentStatus string `json:"comment_status"`
  44. CommentCount int `json:"comment_count"`
  45. CreateTime time.Time `json:"create_time"`
  46. CreateName string `json:"create_name"`
  47. RealName string `json:"real_name"`
  48. ModifyTime time.Time `json:"modify_time"`
  49. Cover string `json:"cover"`
  50. Theme string `json:"theme"`
  51. Label string `json:"label"`
  52. MemberId int `json:"member_id"`
  53. Editor string `json:"editor"`
  54. AutoRelease bool `json:"auto_release"`
  55. HistoryCount int `json:"history_count"`
  56. //RelationshipId int `json:"relationship_id"`
  57. //TeamRelationshipId int `json:"team_relationship_id"`
  58. RoleId conf.BookRole `json:"role_id"`
  59. RoleName string `json:"role_name"`
  60. Status int `json:"status"`
  61. IsEnableShare bool `json:"is_enable_share"`
  62. IsUseFirstDocument bool `json:"is_use_first_document"`
  63. LastModifyText string `json:"last_modify_text"`
  64. IsDisplayComment bool `json:"is_display_comment"`
  65. IsDownload bool `json:"is_download"`
  66. AutoSave bool `json:"auto_save"`
  67. }
  68. func NewBookResult() *BookResult {
  69. return &BookResult{}
  70. }
  71. func (m *BookResult) String() string {
  72. ret, err := json.Marshal(*m)
  73. if err != nil {
  74. return ""
  75. }
  76. return string(ret)
  77. }
  78. // 根据项目标识查询项目以及指定用户权限的信息.
  79. func (m *BookResult) FindByIdentify(identify string, memberId int) (*BookResult, error) {
  80. if identify == "" || memberId <= 0 {
  81. return m, ErrInvalidParameter
  82. }
  83. o := orm.NewOrm()
  84. var book Book
  85. err := NewBook().QueryTable().Filter("identify", identify).One(&book)
  86. if err != nil {
  87. logs.Error("获取项目失败 ->", err)
  88. return m, err
  89. }
  90. roleId, err := NewBook().FindForRoleId(book.BookId, memberId)
  91. if err != nil {
  92. return m, ErrPermissionDenied
  93. }
  94. var relationship2 Relationship
  95. //查找项目创始人
  96. err = NewRelationship().QueryTable().Filter("book_id", book.BookId).Filter("role_id", 0).One(&relationship2)
  97. if err != nil {
  98. logs.Error("根据项目标识查询项目以及指定用户权限的信息 -> ", err)
  99. return m, ErrPermissionDenied
  100. }
  101. member, err := NewMember().Find(relationship2.MemberId)
  102. if err != nil {
  103. return m, err
  104. }
  105. m.ToBookResult(book)
  106. m.RoleId = roleId
  107. m.MemberId = memberId
  108. m.CreateName = member.Account
  109. if member.RealName != "" {
  110. m.RealName = member.RealName
  111. }
  112. if m.RoleId == conf.BookFounder {
  113. m.RoleName = "创始人"
  114. } else if m.RoleId == conf.BookAdmin {
  115. m.RoleName = "管理员"
  116. } else if m.RoleId == conf.BookEditor {
  117. m.RoleName = "编辑者"
  118. } else if m.RoleId == conf.BookObserver {
  119. m.RoleName = "观察者"
  120. }
  121. doc := NewDocument()
  122. err = o.QueryTable(doc.TableNameWithPrefix()).Filter("book_id", book.BookId).OrderBy("modify_time").One(doc)
  123. if err == nil {
  124. member2 := NewMember()
  125. member2.Find(doc.ModifyAt)
  126. m.LastModifyText = member2.Account + " 于 " + doc.ModifyTime.Local().Format("2006-01-02 15:04:05")
  127. }
  128. return m, nil
  129. }
  130. func (m *BookResult) FindToPager(pageIndex, pageSize int) (books []*BookResult, totalCount int, err error) {
  131. o := orm.NewOrm()
  132. count, err := o.QueryTable(NewBook().TableNameWithPrefix()).Count()
  133. if err != nil {
  134. return
  135. }
  136. totalCount = int(count)
  137. sql := `SELECT
  138. book.*,rel.relationship_id,rel.role_id,m.account AS create_name,m.real_name
  139. FROM md_books AS book
  140. LEFT JOIN md_relationship AS rel ON rel.book_id = book.book_id AND rel.role_id = 0
  141. LEFT JOIN md_members AS m ON rel.member_id = m.member_id
  142. ORDER BY book.order_index DESC ,book.book_id DESC LIMIT ?,?`
  143. offset := (pageIndex - 1) * pageSize
  144. _, err = o.Raw(sql, offset, pageSize).QueryRows(&books)
  145. return
  146. }
  147. //实体转换
  148. func (m *BookResult) ToBookResult(book Book) *BookResult {
  149. m.BookId = book.BookId
  150. m.BookName = book.BookName
  151. m.Identify = book.Identify
  152. m.OrderIndex = book.OrderIndex
  153. m.Description = strings.Replace(book.Description, "\r\n", "<br/>", -1)
  154. m.PrivatelyOwned = book.PrivatelyOwned
  155. m.PrivateToken = book.PrivateToken
  156. m.BookPassword = book.BookPassword
  157. m.DocCount = book.DocCount
  158. m.CommentStatus = book.CommentStatus
  159. m.CommentCount = book.CommentCount
  160. m.CreateTime = book.CreateTime
  161. m.ModifyTime = book.ModifyTime
  162. m.Cover = book.Cover
  163. m.Label = book.Label
  164. m.Status = book.Status
  165. m.Editor = book.Editor
  166. m.Theme = book.Theme
  167. m.AutoRelease = book.AutoRelease == 1
  168. m.IsEnableShare = book.IsEnableShare == 0
  169. m.IsUseFirstDocument = book.IsUseFirstDocument == 1
  170. m.Publisher = book.Publisher
  171. m.HistoryCount = book.HistoryCount
  172. m.IsDownload = book.IsDownload == 0
  173. m.AutoSave = book.AutoSave == 1
  174. m.ItemId = book.ItemId
  175. if book.Theme == "" {
  176. m.Theme = "default"
  177. }
  178. if book.Editor == "" {
  179. m.Editor = "markdown"
  180. }
  181. doc := NewDocument()
  182. o := orm.NewOrm()
  183. err := o.QueryTable(doc.TableNameWithPrefix()).Filter("book_id", book.BookId).OrderBy("modify_time").One(doc)
  184. if err == nil {
  185. member2 := NewMember()
  186. member2.Find(doc.ModifyAt)
  187. m.LastModifyText = member2.Account + " 于 " + doc.ModifyTime.Local().Format("2006-01-02 15:04:05")
  188. }
  189. if m.ItemId > 0 {
  190. if item, err := NewItemsets().First(m.ItemId); err == nil {
  191. m.ItemName = item.ItemName
  192. }
  193. }
  194. return m
  195. }
  196. //后台转换
  197. func BackgroundConvert(sessionId string, bookResult *BookResult) error {
  198. if err := converter.CheckConvertCommand(); err != nil {
  199. logs.Error("检查转换程序失败 -> ", err)
  200. return err
  201. }
  202. err := exportLimitWorkerChannel.LoadOrStore(bookResult.Identify, func() {
  203. bookResult.Converter(sessionId)
  204. })
  205. if err != nil {
  206. logs.Error("将导出任务加入任务队列失败 -> ", err)
  207. return err
  208. }
  209. exportLimitWorkerChannel.Start()
  210. return nil
  211. }
  212. //导出PDF、word等格式
  213. func (m *BookResult) Converter(sessionId string) (ConvertBookResult, error) {
  214. convertBookResult := ConvertBookResult{}
  215. outputPath := filepath.Join(conf.GetExportOutputPath(), strconv.Itoa(m.BookId))
  216. viewPath := web.BConfig.WebConfig.ViewsPath
  217. pdfpath := filepath.Join(outputPath, "book.pdf")
  218. epubpath := filepath.Join(outputPath, "book.epub")
  219. mobipath := filepath.Join(outputPath, "book.mobi")
  220. docxpath := filepath.Join(outputPath, "book.docx")
  221. //先将转换的文件储存到临时目录
  222. tempOutputPath := filepath.Join(os.TempDir(), sessionId, m.Identify, "source") //filepath.Abs(filepath.Join("cache", sessionId))
  223. sourceDir := strings.TrimSuffix(tempOutputPath, "source")
  224. if filetil.FileExists(sourceDir) {
  225. if err := os.RemoveAll(sourceDir); err != nil {
  226. logs.Error("删除临时目录失败 ->", sourceDir, err)
  227. }
  228. }
  229. if err := os.MkdirAll(outputPath, 0766); err != nil {
  230. logs.Error("创建目录失败 -> ", outputPath, err)
  231. }
  232. if err := os.MkdirAll(tempOutputPath, 0766); err != nil {
  233. logs.Error("创建目录失败 -> ", tempOutputPath, err)
  234. }
  235. os.MkdirAll(filepath.Join(tempOutputPath, "Images"), 0755)
  236. //defer os.RemoveAll(strings.TrimSuffix(tempOutputPath,"source"))
  237. if filetil.FileExists(pdfpath) && filetil.FileExists(epubpath) && filetil.FileExists(mobipath) && filetil.FileExists(docxpath) {
  238. convertBookResult.EpubPath = epubpath
  239. convertBookResult.MobiPath = mobipath
  240. convertBookResult.PDFPath = pdfpath
  241. convertBookResult.WordPath = docxpath
  242. return convertBookResult, nil
  243. }
  244. docs, err := NewDocument().FindListByBookId(m.BookId)
  245. if err != nil {
  246. return convertBookResult, err
  247. }
  248. tocList := make([]converter.Toc, 0)
  249. for _, item := range docs {
  250. if item.ParentId == 0 {
  251. toc := converter.Toc{
  252. Id: item.DocumentId,
  253. Link: strconv.Itoa(item.DocumentId) + ".html",
  254. Pid: item.ParentId,
  255. Title: item.DocumentName,
  256. }
  257. tocList = append(tocList, toc)
  258. }
  259. }
  260. for _, item := range docs {
  261. if item.ParentId != 0 {
  262. toc := converter.Toc{
  263. Id: item.DocumentId,
  264. Link: strconv.Itoa(item.DocumentId) + ".html",
  265. Pid: item.ParentId,
  266. Title: item.DocumentName,
  267. }
  268. tocList = append(tocList, toc)
  269. }
  270. }
  271. ebookConfig := converter.Config{
  272. Charset: "utf-8",
  273. Cover: m.Cover,
  274. Timestamp: time.Now().Format("2006-01-02 15:04:05"),
  275. Description: string(blackfriday.Run([]byte(m.Description))),
  276. Footer: "<p style='color:#8E8E8E;font-size:12px;'>本文档使用 <a href='https://www.iminho.me' style='text-decoration:none;color:#1abc9c;font-weight:bold;'>MinDoc</a> 构建 <span style='float:right'>- _PAGENUM_ -</span></p>",
  277. Header: "<p style='color:#8E8E8E;font-size:12px;'>_SECTION_</p>",
  278. Identifier: "",
  279. Language: "zh-CN",
  280. Creator: m.CreateName,
  281. Publisher: m.Publisher,
  282. Contributor: m.Publisher,
  283. Title: m.BookName,
  284. Format: []string{"epub", "mobi", "pdf", "docx"},
  285. FontSize: "14",
  286. PaperSize: "a4",
  287. MarginLeft: "72",
  288. MarginRight: "72",
  289. MarginTop: "72",
  290. MarginBottom: "72",
  291. Toc: tocList,
  292. More: []string{},
  293. }
  294. if m.Publisher != "" {
  295. ebookConfig.Footer = "<p style='color:#8E8E8E;font-size:12px;'>本文档由 <span style='text-decoration:none;color:#1abc9c;font-weight:bold;'>" + m.Publisher + "</span> 生成<span style='float:right'>- _PAGENUM_ -</span></p>"
  296. }
  297. if m.RealName != "" {
  298. ebookConfig.Creator = m.RealName
  299. }
  300. if tempOutputPath, err = filepath.Abs(tempOutputPath); err != nil {
  301. logs.Error("导出目录配置错误:" + err.Error())
  302. return convertBookResult, err
  303. }
  304. for _, item := range docs {
  305. name := strconv.Itoa(item.DocumentId)
  306. fpath := filepath.Join(tempOutputPath, name+".html")
  307. f, err := os.OpenFile(fpath, os.O_CREATE|os.O_RDWR, 0755)
  308. if err != nil {
  309. return convertBookResult, err
  310. }
  311. var buf bytes.Buffer
  312. if err := adapter.ExecuteViewPathTemplate(&buf, "document/export.tpl", viewPath, map[string]interface{}{"Model": m, "Lists": item, "BaseUrl": conf.BaseUrl}); err != nil {
  313. return convertBookResult, err
  314. }
  315. html := buf.String()
  316. if err != nil {
  317. f.Close()
  318. return convertBookResult, err
  319. }
  320. bufio := bytes.NewReader(buf.Bytes())
  321. doc, err := goquery.NewDocumentFromReader(bufio)
  322. doc.Find("img").Each(func(i int, contentSelection *goquery.Selection) {
  323. if src, ok := contentSelection.Attr("src"); ok {
  324. //var encodeString string
  325. dstSrcString := "Images/" + filepath.Base(src)
  326. //如果是本地路径则直接读取文件内容
  327. if strings.HasPrefix(src, "/") {
  328. spath := filepath.Join(conf.WorkingDirectory, src)
  329. if filetil.CopyFile(spath, filepath.Join(tempOutputPath, dstSrcString)); err != nil {
  330. logs.Error("复制图片失败 -> ", err, src)
  331. return
  332. }
  333. } else {
  334. client := &http.Client{}
  335. if req, err := http.NewRequest("GET", src, nil); err == nil {
  336. req.Header.Set("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/67.0.3396.99 Safari/537.36")
  337. req.Header.Set("Referer", src)
  338. //10秒连接超时时间
  339. client.Timeout = time.Second * 100
  340. if resp, err := client.Do(req); err == nil {
  341. defer resp.Body.Close()
  342. if body, err := ioutil.ReadAll(resp.Body); err == nil {
  343. //encodeString = base64.StdEncoding.EncodeToString(body)
  344. if err := ioutil.WriteFile(filepath.Join(tempOutputPath, dstSrcString), body, 0755); err != nil {
  345. logs.Error("下载图片失败 -> ", err, src)
  346. return
  347. }
  348. } else {
  349. logs.Error("下载图片失败 -> ", err, src)
  350. return
  351. }
  352. } else {
  353. logs.Error("下载图片失败 -> ", err, src)
  354. return
  355. }
  356. }
  357. }
  358. contentSelection.SetAttr("src", dstSrcString)
  359. }
  360. })
  361. //移除文档底部的更新信息
  362. if selection := doc.Find("div.wiki-bottom").First(); selection.Size() > 0 {
  363. selection.Remove()
  364. }
  365. html, err = doc.Html()
  366. if err != nil {
  367. f.Close()
  368. return convertBookResult, err
  369. }
  370. f.WriteString(html)
  371. f.Close()
  372. }
  373. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "css", "kancloud.css"), filepath.Join(tempOutputPath, "styles", "css", "kancloud.css")); err != nil {
  374. logs.Error("复制CSS样式出错 -> static/css/kancloud.css", err)
  375. }
  376. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "css", "export.css"), filepath.Join(tempOutputPath, "styles", "css", "export.css")); err != nil {
  377. logs.Error("复制CSS样式出错 -> static/css/export.css", err)
  378. }
  379. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "editor.md", "css", "editormd.preview.css"), filepath.Join(tempOutputPath, "styles", "editor.md", "css", "editormd.preview.css")); err != nil {
  380. logs.Error("复制CSS样式出错 -> static/editor.md/css/editormd.preview.css", err)
  381. }
  382. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "css", "markdown.preview.css"), filepath.Join(tempOutputPath, "styles", "css", "markdown.preview.css")); err != nil {
  383. logs.Error("复制CSS样式出错 -> static/css/markdown.preview.css", err)
  384. }
  385. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "editor.md", "lib", "highlight", "styles", "github.css"), filepath.Join(tempOutputPath, "styles", "css", "github.css")); err != nil {
  386. logs.Error("复制CSS样式出错 -> static/editor.md/lib/highlight/styles/github.css", err)
  387. }
  388. if err := filetil.CopyDir(filepath.Join(conf.WorkingDirectory, "static", "font-awesome"), filepath.Join(tempOutputPath, "styles", "font-awesome")); err != nil {
  389. logs.Error("复制CSS样式出错 -> static/font-awesome", err)
  390. }
  391. if err := filetil.CopyFile(filepath.Join(conf.WorkingDirectory, "static", "editor.md", "lib", "mermaid", "mermaid.css"), filepath.Join(tempOutputPath, "styles", "css", "mermaid.css")); err != nil {
  392. logs.Error("复制CSS样式出错 -> static/editor.md/lib/mermaid/mermaid.css", err)
  393. }
  394. eBookConverter := &converter.Converter{
  395. BasePath: tempOutputPath,
  396. OutputPath: filepath.Join(strings.TrimSuffix(tempOutputPath, "source"), "output"),
  397. Config: ebookConfig,
  398. Debug: true,
  399. ProcessNum: conf.GetExportProcessNum(),
  400. }
  401. os.MkdirAll(eBookConverter.OutputPath, 0766)
  402. if err := eBookConverter.Convert(); err != nil {
  403. logs.Error("转换文件错误:" + m.BookName + " -> " + err.Error())
  404. return convertBookResult, err
  405. }
  406. logs.Info("文档转换完成:" + m.BookName)
  407. if err := filetil.CopyFile(filepath.Join(eBookConverter.OutputPath, "output", "book.mobi"), mobipath); err != nil {
  408. logs.Error("复制文档失败 -> ", filepath.Join(eBookConverter.OutputPath, "output", "book.mobi"), err)
  409. }
  410. if err := filetil.CopyFile(filepath.Join(eBookConverter.OutputPath, "output", "book.pdf"), pdfpath); err != nil {
  411. logs.Error("复制文档失败 -> ", filepath.Join(eBookConverter.OutputPath, "output", "book.pdf"), err)
  412. }
  413. if err := filetil.CopyFile(filepath.Join(eBookConverter.OutputPath, "output", "book.epub"), epubpath); err != nil {
  414. logs.Error("复制文档失败 -> ", filepath.Join(eBookConverter.OutputPath, "output", "book.epub"), err)
  415. }
  416. if err := filetil.CopyFile(filepath.Join(eBookConverter.OutputPath, "output", "book.docx"), docxpath); err != nil {
  417. logs.Error("复制文档失败 -> ", filepath.Join(eBookConverter.OutputPath, "output", "book.docx"), err)
  418. }
  419. convertBookResult.MobiPath = mobipath
  420. convertBookResult.PDFPath = pdfpath
  421. convertBookResult.EpubPath = epubpath
  422. convertBookResult.WordPath = docxpath
  423. return convertBookResult, nil
  424. }
  425. //导出Markdown原始文件
  426. func (m *BookResult) ExportMarkdown(sessionId string) (string, error) {
  427. outputPath := filepath.Join(conf.WorkingDirectory, "uploads", "books", strconv.Itoa(m.BookId), "book.zip")
  428. os.MkdirAll(filepath.Dir(outputPath), 0644)
  429. tempOutputPath := filepath.Join(os.TempDir(), sessionId, "markdown")
  430. defer os.RemoveAll(tempOutputPath)
  431. bookUrl := conf.URLFor("DocumentController.Index", ":key", m.Identify) + "/"
  432. err := exportMarkdown(tempOutputPath, 0, m.BookId, tempOutputPath, bookUrl)
  433. if err != nil {
  434. return "", err
  435. }
  436. if err := ziptil.Compress(outputPath, tempOutputPath); err != nil {
  437. logs.Error("导出Markdown失败->", err)
  438. return "", err
  439. }
  440. return outputPath, nil
  441. }
  442. //递归导出Markdown文档
  443. func exportMarkdown(p string, parentId int, bookId int, baseDir string, bookUrl string) error {
  444. o := orm.NewOrm()
  445. var docs []*Document
  446. _, err := o.QueryTable(NewDocument().TableNameWithPrefix()).Filter("book_id", bookId).Filter("parent_id", parentId).All(&docs)
  447. if err != nil {
  448. logs.Error("导出Markdown失败->", err)
  449. return err
  450. }
  451. for _, doc := range docs {
  452. //获取当前文档的子文档数量,如果数量不为0,则将当前文档命名为READMD.md并设置成目录。
  453. subDocCount, err := o.QueryTable(NewDocument().TableNameWithPrefix()).Filter("parent_id", doc.DocumentId).Count()
  454. if err != nil {
  455. logs.Error("导出Markdown失败->", err)
  456. return err
  457. }
  458. var docPath string
  459. if subDocCount > 0 {
  460. if doc.Identify != "" {
  461. docPath = filepath.Join(p, doc.Identify, "README.md")
  462. } else {
  463. docPath = filepath.Join(p, strconv.Itoa(doc.DocumentId), "README.md")
  464. }
  465. } else {
  466. if doc.Identify != "" {
  467. if strings.HasSuffix(doc.Identify, ".md") || strings.HasSuffix(doc.Identify, ".markdown") {
  468. docPath = filepath.Join(p, doc.Identify)
  469. } else {
  470. docPath = filepath.Join(p, doc.Identify+".md")
  471. }
  472. } else {
  473. docPath = filepath.Join(p, strings.TrimSpace(doc.DocumentName)+".md")
  474. }
  475. }
  476. dirPath := filepath.Dir(docPath)
  477. os.MkdirAll(dirPath, 0766)
  478. markdown := doc.Markdown
  479. //如果当前文档不为空
  480. if strings.TrimSpace(doc.Markdown) != "" {
  481. re := regexp.MustCompile(`!\[(.*?)\]\((.*?)\)`)
  482. //处理文档中图片
  483. markdown = re.ReplaceAllStringFunc(doc.Markdown, func(image string) string {
  484. images := re.FindAllSubmatch([]byte(image), -1)
  485. if len(images) <= 0 || len(images[0]) < 3 {
  486. return image
  487. }
  488. originalImageUrl := string(images[0][2])
  489. imageUrl := strings.Replace(string(originalImageUrl), "\\", "/", -1)
  490. //如果是本地路径,则需要将图片复制到项目目录
  491. if strings.HasPrefix(imageUrl, "http://") || strings.HasPrefix(imageUrl, "https://") {
  492. imageExt := cryptil.Md5Crypt(imageUrl) + filepath.Ext(imageUrl)
  493. dstFile := filepath.Join(baseDir, "uploads", time.Now().Format("200601"), imageExt)
  494. if err := requests.DownloadAndSaveFile(imageUrl, dstFile); err == nil {
  495. imageUrl = strings.TrimPrefix(strings.Replace(dstFile, "\\", "/", -1), strings.Replace(baseDir, "\\", "/", -1))
  496. if !strings.HasPrefix(imageUrl, "/") && !strings.HasPrefix(imageUrl, "\\") {
  497. imageUrl = "/" + imageUrl
  498. }
  499. }
  500. } else if strings.HasPrefix(imageUrl, "/") {
  501. filetil.CopyFile(filepath.Join(conf.WorkingDirectory, imageUrl), filepath.Join(baseDir, imageUrl))
  502. }
  503. imageUrl = strings.Replace(strings.TrimSuffix(image, originalImageUrl+")")+imageUrl+")", "\\", "/", -1)
  504. return imageUrl
  505. })
  506. linkRe := regexp.MustCompile(`\[(.*?)\]\((.*?)\)`)
  507. markdown = linkRe.ReplaceAllStringFunc(markdown, func(link string) string {
  508. links := linkRe.FindAllStringSubmatch(link, -1)
  509. if len(links) > 0 && len(links[0]) >= 3 {
  510. originalLink := links[0][2]
  511. //如果当前链接位于当前项目内
  512. if strings.HasPrefix(originalLink, bookUrl) {
  513. docIdentify := strings.TrimSpace(strings.TrimPrefix(originalLink, bookUrl))
  514. tempDoc := NewDocument()
  515. if id, err := strconv.Atoi(docIdentify); err == nil && id > 0 {
  516. err := o.QueryTable(NewDocument().TableNameWithPrefix()).Filter("document_id", id).One(tempDoc, "identify", "parent_id", "document_id")
  517. if err != nil {
  518. logs.Error(err)
  519. return link
  520. }
  521. } else {
  522. err := o.QueryTable(NewDocument().TableNameWithPrefix()).Filter("identify", docIdentify).One(tempDoc, "identify", "parent_id", "document_id")
  523. if err != nil {
  524. logs.Error(err)
  525. return link
  526. }
  527. }
  528. tempLink := recursiveJoinDocumentIdentify(tempDoc.ParentId, "") + strings.TrimPrefix(originalLink, bookUrl)
  529. if !strings.HasSuffix(tempLink, ".md") && !strings.HasSuffix(doc.Identify, ".markdown") {
  530. tempLink = tempLink + ".md"
  531. }
  532. relative := strings.TrimPrefix(strings.Replace(p, "\\", "/", -1), strings.Replace(baseDir, "\\", "/", -1))
  533. repeat := 0
  534. if relative != "" {
  535. relative = strings.TrimSuffix(strings.TrimPrefix(relative, "/"), "/")
  536. repeat = strings.Count(relative, "/") + 1
  537. }
  538. logs.Info(repeat, "|", relative, "|", p, "|", baseDir)
  539. tempLink = strings.Repeat("../", repeat) + tempLink
  540. link = strings.TrimSuffix(link, originalLink+")") + tempLink + ")"
  541. }
  542. }
  543. return link
  544. })
  545. } else {
  546. markdown = "# " + doc.DocumentName + "\n"
  547. }
  548. if err := ioutil.WriteFile(docPath, []byte(markdown), 0644); err != nil {
  549. logs.Error("导出Markdown失败->", err)
  550. return err
  551. }
  552. if subDocCount > 0 {
  553. if err = exportMarkdown(dirPath, doc.DocumentId, bookId, baseDir, bookUrl); err != nil {
  554. return err
  555. }
  556. }
  557. }
  558. return nil
  559. }
  560. func recursiveJoinDocumentIdentify(parentDocId int, identify string) string {
  561. o := orm.NewOrm()
  562. doc := NewDocument()
  563. err := o.QueryTable(NewDocument().TableNameWithPrefix()).Filter("document_id", parentDocId).One(doc, "identify", "parent_id", "document_id")
  564. if err != nil {
  565. logs.Error(err)
  566. return identify
  567. }
  568. if doc.Identify == "" {
  569. identify = strconv.Itoa(doc.DocumentId) + "/" + identify
  570. } else {
  571. identify = doc.Identify + "/" + identify
  572. }
  573. if doc.ParentId > 0 {
  574. identify = recursiveJoinDocumentIdentify(doc.ParentId, identify)
  575. }
  576. return identify
  577. }
  578. //查询项目的第一篇文档
  579. func (m *BookResult) FindFirstDocumentByBookId(bookId int) (*Document, error) {
  580. o := orm.NewOrm()
  581. doc := NewDocument()
  582. err := o.QueryTable(doc.TableNameWithPrefix()).Filter("book_id", bookId).Filter("parent_id", 0).OrderBy("order_sort").One(doc)
  583. return doc, err
  584. }