查看MS Office附件的时候，调用soffice生成预览的html

leeight · leeight · commit 508c04b2b06c · 2014-09-22T12:18:39.000+08:00
diff --git a/src/server/RFC2047/RFC2047.go b/src/server/RFC2047/RFC2047.go
@@ -57,6 +57,7 @@ func decodeBuffer(s string) (string, []byte, error) {
 	if charset != "iso-8859-1" &&
 		charset != "utf-8" &&
 		charset != "iso-2022-jp" &&
+		charset != "big5" &&
 		charset != "gb18030" &&
 		charset != "gb2312" &&
 		charset != "gbk" {
@@ -94,7 +95,7 @@ func decodeRFC2047Word(dec []byte, charset string) (string, error) {
 			b.WriteRune(rune(c))
 		}
 		return b.String(), nil
-	case "gb18030", "iso-2022-jp":
+	case "gb18030", "big5", "iso-2022-jp":
 		cd, err := iconv.Open("utf-8", charset)
 		if err != nil {
 			return "", err
diff --git a/src/server/handlers/doc_viewer.go b/src/server/handlers/doc_viewer.go
@@ -1,19 +1,23 @@
 package handlers
 
 import (
+	"io/ioutil"
 	"net/http"
 	"os"
+	"os/exec"
 	"path"
 	"strings"
-	// "net/url"
 
 	"../web"
 )
 
+const kCmd = "/Volumes/HDD/Users/leeight/Applications/LibreOffice.app/Contents/MacOS/soffice"
+
 type DocViewerHandler struct {
 	Context web.Context
 }
 
+// 只有 if (/\.(doc|xls|ppt)x?$/i.test(item.name)) { 会进入这个Handler来处理
 // docid=base64(${uidl}/att/xxx.docx)
 // base64解码之后就可以知道需要回写的url路径
 // 后续浏览附件的时候，如果有xxx.pdf，那么优先浏览这个，否则给出提示即可
@@ -33,62 +37,54 @@ func (h DocViewerHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}
 
 	parts := strings.Split(name, "/")
-	pdfname := parts[0] + "/doc/" + strings.Replace(parts[2], path.Ext(parts[2]), ".pdf", 1)
-	pdfabs := path.Join(config.DownloadDir(), pdfname)
-	log.Info("pdfabs = [%s]", pdfabs)
-	if _, err := os.Stat(pdfabs); err == nil {
-		http.Redirect(w, r, "/downloads/"+pdfname, http.StatusMovedPermanently)
+	htmlname := parts[0] + "/doc/" + strings.Replace(parts[2], path.Ext(parts[2]), ".html", 1)
+	htmlabs := path.Join(config.DownloadDir(), htmlname)
+	if _, err := os.Stat(htmlabs); err == nil {
+		log.Info("htmlabs = [%s]", htmlabs)
+		http.Redirect(w, r, "/downloads/"+htmlname, http.StatusMovedPermanently)
+		return
+	}
+
+	os.MkdirAll(path.Dir(htmlabs), 0755)
+	p := exec.Command(kCmd,
+		"--headless",
+		"--convert-to", "html",
+		"--outdir", path.Dir(htmlabs),
+		abs)
+
+	err := p.Start()
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusServiceUnavailable)
+		return
+	}
+
+	err = p.Wait()
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusServiceUnavailable)
 		return
 	}
 
-	w.Write([]byte(`<!doctype html>
-  <html>
-    <head>
-      <meta charset="utf-8" />
-      <title>预览『` + path.Base(name) + `』</title>
-      <style type="text/css">
-      html, body {
-        height: 100%;
-      }
-      body {
-        font-family: Arial, Helvetica, STHeiti, SimSun, sans-serif;
-        font-size: 12px;
-        color: #000;
-      }
-      p {
-        position: relative;
-        top: 50%;
-        height: 100px;
-        line-height: 100px;
-        font-size: 18px;
-        text-align: center;
-        margin: 0;
-        margin-top: -50px;
-      }
-      </style>
-    </head>
-    <body>
-      <p>你可以<a id="submit-req" href="javascript:void(0)">提交文档转码请求</a>或者<a download="` + path.Base(name) +
-		`" href="/downloads/` + name + `">直接下载</a>文档查看</p>
-    </body>
-    <script type="text/javascript">
-    document.getElementById("submit-req").onclick = function() {
-      var xhr = new XMLHttpRequest();
-      xhr.onreadystatechange = function() {
-        if (xhr.readyState === 4) {
-          if (xhr.status === 200) {
-            alert('提交成功，请稍候重试')
-          } else {
-            alert(xhr.responseText);
-          }
+	if _, err := os.Stat(htmlabs); err == nil {
+		log.Info("htmlabs = [%s]", htmlabs)
+		// 添加自定义的样式，美化一下效果
+		raw, _ := ioutil.ReadFile(htmlabs)
+		style := `
+        <style type="text/css">
+        html{ background: #ebebeb}
+        body{
+          width:980px;
+          margin: 50px auto;
+          background: #fff;
+          padding: 10px;
+          box-shadow: 0 0 0 1px #d1d1d1, 0 0 4px 1px #ccc;
         }
-      }
-      var url = '/api/doc/transfer?docid=' + encodeURIComponent('` + name + `')
-      xhr.open('POST', url, true);
-      xhr.send(null);
-      return false;
-    };
-    </script>
-  </html>
-  `))
+        </style>
+        </head>`
+		raw = []byte(strings.Replace(string(raw), "</head>", style, -1))
+
+		ioutil.WriteFile(htmlabs, raw, 0644)
+
+		http.Redirect(w, r, "/downloads/"+htmlname, http.StatusMovedPermanently)
+		return
+	}
 }
diff --git a/src/server/sqlite3-to-mysql.py b/src/server/sqlite3-to-mysql.py
@@ -0,0 +1,40 @@
+#! /usr/bin/env python
+
+import sys
+
+def main():
+    print "SET sql_mode='NO_BACKSLASH_ESCAPES';"
+    lines = sys.stdin.read().splitlines()
+    for line in lines:
+        processLine(line)
+
+def processLine(line):
+    if (
+        line.startswith("PRAGMA") or 
+        line.startswith("BEGIN TRANSACTION;") or
+        line.startswith("COMMIT;") or
+        line.startswith("DELETE FROM sqlite_sequence;") or
+        line.startswith("INSERT INTO \"sqlite_sequence\"")
+       ):
+        return
+    line = line.replace("AUTOINCREMENT", "AUTO_INCREMENT")
+    line = line.replace("DEFAULT 't'", "DEFAULT '1'")
+    line = line.replace("DEFAULT 'f'", "DEFAULT '0'")
+    line = line.replace(",'t'", ",'1'")
+    line = line.replace(",'f'", ",'0'")
+    in_string = False
+    newLine = ''
+    for c in line:
+        if not in_string:
+            if c == "'":
+                in_string = True
+            elif c == '"':
+                newLine = newLine + '`'
+                continue
+        elif c == "'":
+            in_string = False
+        newLine = newLine + c
+    print newLine
+
+if __name__ == "__main__":
+    main()
diff --git a/src/server/tools/doc_converter.go b/src/server/tools/doc_converter.go
@@ -0,0 +1,41 @@
+package main
+
+import (
+	"bytes"
+	"flag"
+	"fmt"
+	"log"
+	"os/exec"
+)
+
+const kCmd = "/Volumes/HDD/Users/leeight/Applications/LibreOffice.app/Contents/MacOS/soffice"
+
+func main() {
+	var fileptr = flag.String("file", "", "The file will be convert to preview html")
+	flag.Parse()
+
+	if *fileptr == "" {
+		return
+	}
+
+	// /Volumes/HDD/Users/leeight/Applications/LibreOffice.app/Contents/MacOS/soffice \
+	// --headless \
+	// --convert-to html \
+	// ../../data/baidu.com/liyubei/downloads/723474/att/使用无障碍平台认证评测记录表-xx平台.xlsx \
+	// --help
+	var out bytes.Buffer
+
+	p := exec.Command(kCmd, "--headless", "--convert-to", "html", "--outdir", "tmp", *fileptr)
+	p.Stdout = &out
+	err := p.Start()
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	err = p.Wait()
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	fmt.Printf("%q\n", out.String())
+}
diff --git a/src/server/tools/fix_threads.go b/src/server/tools/fix_threads.go
@@ -11,6 +11,7 @@ import (
 
 	"../base"
 	"../thread"
+	"../web"
 )
 
 func readAllMessages(db *sql.DB) []*thread.Message {
@@ -130,12 +131,8 @@ func addThread(db *sql.DB, subject string, mids []string) (int64, error) {
 
 func main() {
 	config, err := base.GetConfig("config.yml")
-
-	db, err := sql.Open("sqlite3", config.DbPath())
-	if err != nil {
-		log.Panic(err)
-		return
-	}
+	ctx := web.NewContext(config)
+	db := ctx.GetDb()
 	defer db.Close()
 
 	messages := readAllMessages(db)
