From 8aee3f559b222209485c870adfb732e7f0a67f3a Mon Sep 17 00:00:00 2001 From: 3xxx Date: Mon, 19 Feb 2018 23:09:25 +0800 Subject: [PATCH] add onlyoffice --- controllers/default.go | 12 +- controllers/onlyoffice.go | 803 ++++++++++++++++++++++++++++ controllers/project.go | 26 +- models/OnlyofficeModel.go | 185 +++++++ routers/router.go | 17 + views/T.navbar.tpl | 25 +- views/onlyoffice/T.navbar.tpl | 155 ++++++ views/onlyoffice/docs.tpl | 903 ++++++++++++++++++++++++++++++++ views/onlyoffice/onlyoffice.tpl | 34 ++ 9 files changed, 2133 insertions(+), 27 deletions(-) create mode 100644 controllers/onlyoffice.go create mode 100644 models/OnlyofficeModel.go create mode 100644 views/onlyoffice/T.navbar.tpl create mode 100644 views/onlyoffice/docs.tpl create mode 100644 views/onlyoffice/onlyoffice.tpl diff --git a/controllers/default.go b/controllers/default.go index 1333b3c3..8788b192 100644 --- a/controllers/default.go +++ b/controllers/default.go @@ -1,15 +1,22 @@ package controllers import ( + // "encoding/json" "engineercms/models" "github.com/astaxie/beego" "github.com/astaxie/beego/utils/pagination" + // "io" + // "net/http" + // "github.com/astaxie/beego/httplib" + // "bytes" + // "io/ioutil" + // "mime/multipart" + // "os" "path" "regexp" "strconv" "strings" "time" - // "github.com/astaxie/beego/httplib" ) type MainController struct { @@ -54,7 +61,7 @@ func (c *MainController) Get() { if matched == true { // beego.Info("移动端~") // c.TplName = "mproject.tpl" - c.Redirect("/project/25002", 301) + c.Redirect("/project/", 301) } else { // beego.Info("电脑端！") achemployee := make([]AchEmployee, 0) @@ -258,7 +265,6 @@ func (c *MainController) Getmeritmsapi() { } func (c *MainController) Test() { - // beego.Info(c.Ctx.Input.UserAgent()) u := c.Ctx.Input.UserAgent() // re := regexp.MustCompile("Trident") diff --git a/controllers/onlyoffice.go b/controllers/onlyoffice.go new file mode 100644 index 00000000..8756b5fe --- /dev/null +++ b/controllers/onlyoffice.go @@ -0,0 +1,803 @@ +package controllers + +import ( + "encoding/json" + "engineercms/models" + "github.com/astaxie/beego" + "io/ioutil" + "net/http" + "net/url" + "os" + "path" + "regexp" + "strconv" + "strings" + "time" + // "mime/multipart" + // "github.com/astaxie/beego/httplib" + // "bytes" + // "github.com/astaxie/beego/utils/pagination" + // "io" +) + +type OnlyController struct { + beego.Controller +} + +type Callback struct { + Key string `json:"key"` + Status int `json:"status"` + Url string `json:"url"` + Changesurl string `json:"changesurl"` + History history `json:"history"` + Users []string `json:"users"` + Actions []action `json:"actions"` + Lastsave string `json:"lastsave"` + Notmodified bool `json:"notmodified"` +} + +type action struct { + Type int + userid string +} + +type history struct { + changes []change + serverVersion string +} + +type change struct { + created string + User User1 +} + +type User1 struct { + id string + name string +} + +type Onlyoffice1 struct { + Id int64 + Code string + Title string + Ext string + Created time.Time + Updated time.Time +} + +type OnlyLink struct { + Id int64 + Code string + Title string + Label string + End time.Time + Principal string + Uid int64 + Created time.Time + Updated time.Time + Docxlink []DocxLink + Xlsxlink []XlsxLink + Pptxlink []PptxLink +} + +type DocxLink struct { + Id int64 + Title string + // Link string + Created time.Time + Updated time.Time +} + +type XlsxLink struct { + Id int64 + Title string + // Link string + Created time.Time + Updated time.Time +} + +type PptxLink struct { + Id int64 + Title string + // Link string + Created time.Time + Updated time.Time +} + +func (c *OnlyController) Get() { + username, role := checkprodRole(c.Ctx) + if role == 1 { + c.Data["IsAdmin"] = true + } else if role > 1 && role < 5 { + c.Data["IsLogin"] = true + } else { + c.Data["IsAdmin"] = false + c.Data["IsLogin"] = false + } + c.Data["Username"] = username + c.Data["Ip"] = c.Ctx.Input.IP() + c.Data["role"] = role + // beego.Info(c.Ctx.Input.UserAgent()) + u := c.Ctx.Input.UserAgent() + // re := regexp.MustCompile("Trident") + // loc := re.FindStringIndex(u) + // loc[0] > 1 + c.Data["IsOnlyOffice"] = true + matched, err := regexp.MatchString("AppleWebKit.*Mobile.*", u) + if err != nil { + beego.Error(err) + } + if matched == true { + beego.Info("移动端~") + c.TplName = "onlyoffice/docs.tpl" + } else { + beego.Info("电脑端！") + c.TplName = "onlyoffice/docs.tpl" + } + // var u = navigator.userAgent, app = navigator.appVersion; + // return { + // trident: u.indexOf('Trident') > -1, //IE内核 + // presto: u.indexOf('Presto') > -1, //opera内核 + // webKit: u.indexOf('AppleWebKit') > -1, //苹果、谷歌内核 + // gecko: u.indexOf('Gecko') > -1 && u.indexOf('KHTML') == -1,//火狐内核 + // mobile: !!u.match(/AppleWebKit.*Mobile.*/), //是否为移动终端 + // ios: !!u.match(/\(i[^;]+;( U;)? CPU.+Mac OS X/), //ios终端//两个感叹号的作用就在于，如果明确设置了变量的值（非null/undifined/0/”“等值),结果就会根据变量的实际值来返回，如果没有设置，结果就会返回false。 + // android: u.indexOf('Android') > -1 || u.indexOf('Adr') > -1, //android终端 + // iPhone: u.indexOf('iPhone') > -1 , //是否为iPhone或者QQHD浏览器 + // iPad: u.indexOf('iPad') > -1, //是否iPad + // webApp: u.indexOf('Safari') == -1, //是否web应该程序，没有头部与底部 + // //webApp: ("standalone" in window.navigator)&&window.navigator.standalone, //是否web应该程序，没有头部与底部 + // weixin: u.indexOf('MicroMessenger') > -1, //是否微信 （2015-01-22新增） + // qq: u.match(/\sQQ/i) == " qq" //是否QQ + + // public static boolean isMobileDevice(String requestHeader){ + /** + * android : 所有android设备 + * mac os : iphone ipad + * windows phone:Nokia等windows系统的手机 + */ + // String[] deviceArray = new String[]{"android","mac os","windows phone"}; + // if(requestHeader == null) + // return false; + // requestHeader = requestHeader.toLowerCase(); + // for(int i=0;i0){ + // return true; + // } + // } + // return false; + + // } + + // Enumeration typestr = request.getHeaderNames(); + // String s1 = request.getHeader("user-agent"); + // if(s1.contains("Android")) { + // System.out.println("Android移动客户端"); + // } else if(s1.contains("iPhone")) { + // System.out.println("iPhone移动客户端"); + // } else if(s1.contains("iPad")) { + // System.out.println("iPad客户端"); + // } else { + // System.out.println("其他客户端"); + // } + // if (/(iPhone|iPad|iPod|iOS)/i.test(navigator.userAgent)) { + // //alert(navigator.userAgent); + // window.location.href ="iPhone.html"; + // } else if (/(Android)/i.test(navigator.userAgent)) { + // //alert(navigator.userAgent); + // window.location.href ="Android.html"; + // } else { + // window.location.href ="pc.html"; + // }; +} + +//提供给列表页的table中json数据 +//取得某个侧栏id下的成果给table +func (c *OnlyController) GetData() { + var err error + docs, err := models.GetDocs() + if err != nil { + beego.Error(err) + } + + link := make([]OnlyLink, 0) + Docxslice := make([]DocxLink, 0) + Xlsxslice := make([]XlsxLink, 0) + Pptxslice := make([]PptxLink, 0) + for _, w := range docs { + Attachments, err := models.GetOnlyAttachments(w.Id) + if err != nil { + beego.Error(err) + } + linkarr := make([]OnlyLink, 1) + linkarr[0].Id = w.Id + linkarr[0].Code = w.Code + linkarr[0].Title = w.Title + linkarr[0].Label = w.Label + linkarr[0].End = w.End + linkarr[0].Principal = w.Principal + linkarr[0].Uid = w.Uid + linkarr[0].Created = w.Created + linkarr[0].Updated = w.Updated + for _, v := range Attachments { + // beego.Info(v.FileName) + // fileext := path.Ext(v.FileName) + if path.Ext(v.FileName) == ".docx" || path.Ext(v.FileName) == ".DOCX" || path.Ext(v.FileName) == ".doc" || path.Ext(v.FileName) == ".DOC" { + docxarr := make([]DocxLink, 1) + docxarr[0].Id = v.Id + docxarr[0].Title = v.FileName + Docxslice = append(Docxslice, docxarr...) + } else if path.Ext(v.FileName) == ".XLSX" || path.Ext(v.FileName) == ".xlsx" || path.Ext(v.FileName) == ".XLS" || path.Ext(v.FileName) == ".xls" { + xlsxarr := make([]XlsxLink, 1) + xlsxarr[0].Id = v.Id + xlsxarr[0].Title = v.FileName + // pdfarr[0].Link = Url + Xlsxslice = append(Xlsxslice, xlsxarr...) + } else if path.Ext(v.FileName) == ".pptx" || path.Ext(v.FileName) == ".PPTX" || path.Ext(v.FileName) == ".ppt" || path.Ext(v.FileName) == ".PPT" { + pptxarr := make([]PptxLink, 1) + pptxarr[0].Id = v.Id + pptxarr[0].Title = v.FileName + // pdfarr[0].Link = Url + Pptxslice = append(Pptxslice, pptxarr...) + } + } + linkarr[0].Docxlink = Docxslice + linkarr[0].Xlsxlink = Xlsxslice + linkarr[0].Pptxlink = Pptxslice + Docxslice = make([]DocxLink, 0) //再把slice置0 + Xlsxslice = make([]XlsxLink, 0) //再把slice置0 + Pptxslice = make([]PptxLink, 0) + + link = append(link, linkarr...) + } + c.Data["json"] = link //products + c.ServeJSON() +} + +//协作页面的显示 +func (c *OnlyController) OnlyOffice() { + id := c.Ctx.Input.Param(":id") + //pid转成64为 + idNum, err := strconv.ParseInt(id, 10, 64) + if err != nil { + beego.Error(err) + } + //根据附件id取得附件的prodid，路径 + onlyattachment, err := models.GetOnlyAttachbyId(idNum) + if err != nil { + beego.Error(err) + } + c.Data["Doc"] = onlyattachment + + c.Data["Key"] = strconv.FormatInt(onlyattachment.Updated.UnixNano(), 10) + + var uname string + v := c.GetSession("uname") + if v != nil { + uname = v.(string) + c.Data["Uname"] = v.(string) + + user, err := models.GetUserByUsername(uname) + if err != nil { + beego.Error(err) + } + c.Data["Uid"] = user.Id + // useridstring = strconv.FormatInt(user.Id, 10) + } else { + c.Data["Uname"] = c.Ctx.Input.IP() + c.Data["Uid"] = c.Ctx.Input.IP() + } + + if path.Ext(onlyattachment.FileName) == ".docx" || path.Ext(onlyattachment.FileName) == ".DOCX" { + c.Data["fileType"] = "docx" + c.Data["documentType"] = "text" + } else if path.Ext(onlyattachment.FileName) == ".XLSX" || path.Ext(onlyattachment.FileName) == ".xlsx" { + c.Data["fileType"] = "xlsx" + c.Data["documentType"] = "spreadsheet" + } else if path.Ext(onlyattachment.FileName) == ".pptx" || path.Ext(onlyattachment.FileName) == ".PPTX" { + c.Data["fileType"] = "pptx" + c.Data["documentType"] = "presentation" + } else if path.Ext(onlyattachment.FileName) == ".doc" || path.Ext(onlyattachment.FileName) == ".DOC" { + c.Data["fileType"] = "doc" + c.Data["documentType"] = "text" + } else if path.Ext(onlyattachment.FileName) == ".txt" || path.Ext(onlyattachment.FileName) == ".TXT" { + c.Data["fileType"] = "txt" + c.Data["documentType"] = "text" + } else if path.Ext(onlyattachment.FileName) == ".XLS" || path.Ext(onlyattachment.FileName) == ".xls" { + c.Data["fileType"] = "xls" + c.Data["documentType"] = "spreadsheet" + } else if path.Ext(onlyattachment.FileName) == ".csv" || path.Ext(onlyattachment.FileName) == ".CSV" { + c.Data["fileType"] = "csv" + c.Data["documentType"] = "spreadsheet" + } else if path.Ext(onlyattachment.FileName) == ".ppt" || path.Ext(onlyattachment.FileName) == ".PPT" { + c.Data["fileType"] = "ppt" + c.Data["documentType"] = "presentation" + } + + u := c.Ctx.Input.UserAgent() + matched, err := regexp.MatchString("AppleWebKit.*Mobile.*", u) + if err != nil { + beego.Error(err) + } + if matched == true { + // beego.Info("移动端~") + c.TplName = "onlyoffice/onlyoffice.tpl" + } else { + // beego.Info("电脑端！") + c.TplName = "onlyoffice/onlyoffice.tpl" + } +} + +//协作页面的保存和回调 +//关闭浏览器标签后获取最新文档保存到文件夹 +func (c *OnlyController) UrltoCallback() { + // pk1 := c.Ctx.Input.RequestBody + id := c.Input().Get("id") + //pid转成64为 + idNum, err := strconv.ParseInt(id, 10, 64) + if err != nil { + beego.Error(err) + } + //根据附件id取得附件的prodid，路径 + onlyattachment, err := models.GetOnlyAttachbyId(idNum) + if err != nil { + beego.Error(err) + } + + var callback Callback + json.Unmarshal(c.Ctx.Input.RequestBody, &callback) + + if callback.Status == 1 || callback.Status == 4 { + c.Data["json"] = map[string]interface{}{"error": 0} + c.ServeJSON() + } else if callback.Status == 2 { + resp, err := http.Get(callback.Url) + if err != nil { + beego.Error(err) + } + body, err := ioutil.ReadAll(resp.Body) + if err != nil { + beego.Error(err) + } + defer resp.Body.Close() + if err != nil { + beego.Error(err) + } + + f, err := os.OpenFile(".\\attachment\\onlyoffice\\"+onlyattachment.FileName, os.O_RDWR|os.O_CREATE|os.O_APPEND, os.ModePerm) + if err != nil { + beego.Error(err) + } + defer f.Close() + _, err = f.Write(body) + // _, err = f.WriteString(str) + // _, err = io.Copy(body, f) + if err != nil { + beego.Error(err) + } else { + err = models.UpdateOnlyAttachment(idNum) + if err != nil { + beego.Error(err) + } + } + c.Data["json"] = map[string]interface{}{"error": 0} + c.ServeJSON() + } +} + +//批量添加一对一模式 +//要避免同名覆盖的严重bug！！！！ +func (c *OnlyController) AddOnlyAttachment() { + //取得客户端用户名 + v := c.GetSession("uname") + var user models.User + var err error + if v != nil { + uname := v.(string) + user, err = models.GetUserByUsername(uname) + if err != nil { + beego.Error(err) + } + } + + var filepath, DiskDirectory, Url string + + err = os.MkdirAll(".\\attachment\\onlyoffice\\", 0777) //..代表本当前exe文件目录的上级，.表示当前目录，没有.表示盘的根目录 + if err != nil { + beego.Error(err) + } + DiskDirectory = ".\\attachment\\onlyoffice\\" + Url = "/attachment/onlyoffice/" + + //获取上传的文件 + _, h, err := c.GetFile("file") + if err != nil { + beego.Error(err) + } + if h != nil { + //保存附件 + //将附件的编号和名称写入数据库 + _, code, title, _, _, _, _ := Record(h.Filename) + // filename1, filename2 := SubStrings(attachment) + //当2个文件都取不到filename1的时候，数据库里的tnumber的唯一性检查出错。 + if code == "" { + code = title //如果编号为空，则用文件名代替，否则多个编号为空导致存入数据库唯一性检查错误 + } + //存入成果数据库 + //如果编号重复，则不写入，只返回Id值。 + //根据id添加成果code, title, label, principal, content string, projectid int64 + prodlabel := c.Input().Get("prodlabel") + prodprincipal := c.Input().Get("prodprincipal") + // type Duration int64 + // const ( + // Nanosecond Duration = 1 + // Microsecond = 1000 * Nanosecond + // Millisecond = 1000 * Microsecond + // Second = 1000 * Millisecond + // Minute = 60 * Second + // Hour = 60 * Minute + // ) + // hours := 8 + inputdate := c.Input().Get("proddate") + // beego.Info(inputdate) + var t1, end time.Time + // var convdate1, convdate2 string + const lll = "2006-01-02" + if len(inputdate) > 9 { //如果是datepick获取的时间，则不用加8小时 + t1, err = time.Parse(lll, inputdate) //这里t1要是用t1:=就不是前面那个t1了 + if err != nil { + beego.Error(err) + } + // convdate := t1.Format(lll) + // catalog.Datestring = convdate + end = t1 + // t1 = printtime.Add(+time.Duration(hours) * time.Hour) + } else { //如果取系统时间，则需要加8小时 + date := time.Now() + convdate := date.Format(lll) + // catalog.Datestring = convdate + date, err = time.Parse(lll, convdate) + if err != nil { + beego.Error(err) + } + end = date + } + // beego.Info(end) + prodId, err := models.AddDoc(code, title, prodlabel, prodprincipal, end, user.Id) + if err != nil { + beego.Error(err) + } + //改名，替换文件名中的#和斜杠 + title = strings.Replace(title, "#", "号", -1) + title = strings.Replace(title, "/", "-", -1) + FileSuffix := path.Ext(h.Filename) + + filepath = DiskDirectory + "\\" + code + title + FileSuffix + //把成果id作为附件的parentid，把附件的名称等信息存入附件数据库 + //如果附件名称相同，则不能上传，数据库添加 + attachmentname := code + title + FileSuffix + + _, _, err2 := models.AddOnlyAttachment(attachmentname, 0, 0, prodId) + if err2 != nil { + beego.Error(err2) + } else { + //存入文件夹 + //判断文件是否存在，如果不存在就写入 + if _, err := os.Stat(filepath); err != nil { + if os.IsNotExist(err) { + //return false + err = c.SaveToFile("file", filepath) //存文件 + if err != nil { + beego.Error(err) + } + c.Data["json"] = map[string]interface{}{"state": "SUCCESS", "title": h.Filename, "original": h.Filename, "url": Url + "/" + h.Filename} + c.ServeJSON() + } + } + + } + } +} + +//协作页面下载的文档，采用绝对路径型式 +func (c *OnlyController) DownloadDoc() { + // c.Data["IsLogin"] = checkAccount(c.Ctx) + //4.取得客户端用户名 + // var uname, useridstring string + // v := c.GetSession("uname") + // if v != nil { + // uname = v.(string) + // c.Data["Uname"] = v.(string) + // user, err := models.GetUserByUsername(uname) + // if err != nil { + // beego.Error(err) + // } + // useridstring = strconv.FormatInt(user.Id, 10) + // } + + //1.url处理中文字符路径，[1:]截掉路径前面的/斜杠 + // filePath := path.Base(ctx.Request.RequestURI) + filePath, err := url.QueryUnescape(c.Ctx.Request.RequestURI[1:]) // attachment/SL2016测试添加成果/A/FB/1/Your First Meteor Application.pdf + if err != nil { + beego.Error(err) + } + + // fileext := path.Ext(filePath) + //根据路由path.Dir——再转成数组strings.Split——查出项目id——加上名称——查出下级id + // beego.Info(path.Dir(filePath)) + // filepath1 := path.Dir(filePath) + // array := strings.Split(filepath1, "/") + // beego.Info(strings.Split(filepath1, "/")) + http.ServeFile(c.Ctx.ResponseWriter, c.Ctx.Request, filePath) +} + +//编辑成果信息 +func (c *OnlyController) UpdateDoc() { + id := c.Input().Get("pid") + code := c.Input().Get("code") + title := c.Input().Get("title") + label := c.Input().Get("label") + principal := c.Input().Get("principal") + + //id转成64为 + idNum, err := strconv.ParseInt(id, 10, 64) + if err != nil { + beego.Error(err) + } + + inputdate := c.Input().Get("proddate") + // beego.Info(inputdate) + var t1, end time.Time + // var convdate1, convdate2 string + const lll = "2006-01-02" + if len(inputdate) > 9 { //如果是datepick获取的时间，则不用加8小时 + t1, err = time.Parse(lll, inputdate) //这里t1要是用t1:=就不是前面那个t1了 + if err != nil { + beego.Error(err) + } + // convdate := t1.Format(lll) + // catalog.Datestring = convdate + end = t1 + // t1 = printtime.Add(+time.Duration(hours) * time.Hour) + } else { //如果取系统时间，则需要加8小时 + date := time.Now() + convdate := date.Format(lll) + // catalog.Datestring = convdate + date, err = time.Parse(lll, convdate) + if err != nil { + beego.Error(err) + } + end = date + } + //根据id添加成果code, title, label, principal, content string, projectid int64 + err = models.UpdateDoc(idNum, code, title, label, principal, end) + if err != nil { + beego.Error(err) + } + c.Data["json"] = "ok" + c.ServeJSON() +} + +//删除成果，包含成果里的附件。删除附件用attachment中的 +func (c *OnlyController) DeleteDoc() { + ids := c.GetString("ids") + array := strings.Split(ids, ",") + for _, v := range array { + // pid = strconv.FormatInt(v1, 10) + //id转成64位 + idNum, err := strconv.ParseInt(v, 10, 64) + if err != nil { + beego.Error(err) + } + //循环删除成果 + //根据成果id取得所有附件 + attachments, err := models.GetOnlyAttachments(idNum) + if err != nil { + beego.Error(err) + } + for _, w := range attachments { + //取得附件的成果id + attach, err := models.GetOnlyAttachbyId(w.Id) + if err != nil { + beego.Error(err) + } + + path := ".\\attachment\\onlyoffice\\" + attach.FileName + //删除附件 + err = os.Remove(path) + if err != nil { + beego.Error(err) + } + //删除附件数据表 + err = models.DeleteOnlyAttachment(w.Id) + if err != nil { + beego.Error(err) + } + } + + err = models.DeleteDoc(idNum) //删除成果数据表 + if err != nil { + beego.Error(err) + } else { + c.Data["json"] = "ok" + c.ServeJSON() + } + } +} + +// 原来golang下载文件这么简单 +// 分为三步 +// 第一步 用http.get 获取到res.Body 这个流 +// 第二步 用os.Creat创建文件并取到文件 +// 第三步 io.Copy把得到的res.Body拷贝到文件的流里面 + +// import ( +// "fmt" +// "github.com/PuerkitoBio/goquery" +// "io" +// "net/http" +// "os" +// ) + +// func main() { +// x, _ := goquery.NewDocument("http://www.fengyun5.com/Sibao/600/1.html") +// urls, _ := x.Find("#content img").Attr("src") +// res, _ := http.Get(urls) +// file, _ := os.Create("xxx.jpg") +// io.Copy(file, res.Body) +// fmt.Println("下载完成！") +// } + +// func downloadFile(fileFullPath string, res *restful.Response) { +// file, err := os.Open(fileFullPath) + +// if err != nil { +// res.WriteEntity(_dto.ErrorDto{Err: err}) +// return +// } + +// defer file.Close() +// fileName := path.Base(fileFullPath) +// fileName = url.QueryEscape(fileName) // 防止中文乱码 +// res.AddHeader("Content-Type", "application/octet-stream") +// res.AddHeader("content-disposition", "attachment; filename=\""+fileName+"\"") +// _, error := io.Copy(res.ResponseWriter, file) +// if error != nil { +// res.WriteErrorString(http.StatusInternalServerError, err.Error()) +// return +// } +// } + +//判断某个文件是否存在 package main + +// import ( +// "fmt" +// "os" +// ) + +// func main() { +// originalPath := "test.txt" +// result := Exists(originalPath) +// fmt.Println(result) +// } + +// func Exists(name string) bool { +// if _, err := os.Stat(name); err != nil { +// if os.IsNotExist(err) { +// return false +// } +// } +// return true +// } + +//****模拟表单上传附件******************** +//***最开始先httpget到onlyoffice的output.doc， +//再读出来 +//再新建一个文件 +//把读出来的写入新建的文件 +//把新建的文件模拟表单上传 +//接受上传的文件，保存到attachment对应的onlyoffice文件夹中 +// req := httplib.Get("http://192.168.99.100:9000/cache/files/E7FAFC9C22A8_5080/output.docx/output.docx?md5=-fOxyXjPpAyxS_QZdt5jBw==&expires=1520306521&disposition=attachment&ooname=output.docx") +// str, err := req.Bytes() //req.String() +// 打开根目录文件f, err := os.OpenFile("tt", os.O_RDWR|os.O_CREATE|os.O_APPEND, os.ModePerm) //可读写，追加的方式打开（或创建文件） +// f, err := os.Create("") + +// 模拟表单上传bodyBuf := &bytes.Buffer{} +// bodyWriter := multipart.NewWriter(bodyBuf) +//关键的一步操作 +// fileWriter, err := bodyWriter.CreateFormFile("uploadfile", onlyattachment.FileName) +// if err != nil { +// beego.Error(err) +// } +//打开文件句柄操作 +// fh, err := os.Open("tt") +// if err != nil { +// beego.Error(err) +// } +// defer fh.Close() + +//iocopy +// _, err = io.Copy(fileWriter, fh) +// if err != nil { +// beego.Error(err) +// } + +// contentType := bodyWriter.FormDataContentType() +// bodyWriter.Close() + +// resp1, err := http.Post("http://192.168.99.1/onlyoffice/post?id="+id, contentType, bodyBuf) +// if err != nil { +// beego.Error(err) +// } +// defer resp1.Body.Close() + +// err = c.SaveToFile("tt", "\\attachment\\wiki\\2018February\\1.doc") +// if err != nil { +// beego.Error(err) +// } + +// resp_body, err := ioutil.ReadAll(resp1.Body) +// if err != nil { +// beego.Error(err) +// } +// beego.Info(resp1.Status) +// beego.Info(string(resp_body)) +// fmt.Println(resp1.Status) +// fmt.Println(string(resp_body)) +// return nil +//****************************** + +// // 创建表单文件 +// // CreateFormFile 用来创建表单，第一个参数是字段名，第二个参数是文件名 +// buf := new(bytes.Buffer) +// writer := multipart.NewWriter(buf) +// formFile, err := writer.CreateFormFile("uploadfile", "test.jpg") +// if err != nil { +// log.Fatalf("Create form file failed: %s\n", err) +// } + +// // 从文件读取数据，写入表单 +// srcFile, err := os.Open("test.jpg") +// if err != nil { +// log.Fatalf("%Open source file failed: s\n", err) +// } +// defer srcFile.Close() +// _, err = io.Copy(formFile, srcFile) +// if err != nil { +// log.Fatalf("Write to form file falied: %s\n", err) +// } +// // 发送表单 +// contentType := writer.FormDataContentType() +// writer.Close() // 发送之前必须调用Close()以写入结尾行 +// _, err = http.Post("http://localhost:9090/upload", contentType, buf) +// if err != nil { +// log.Fatalf("Post failed: %s\n", err) +// } + +//——关闭浏览器最后一个标签，存储文件——取消这种方法 +// func (c *OnlyController) PostOnlyoffice() { +// id := c.Input().Get("id") +// //pid转成64为 +// idNum, err := strconv.ParseInt(id, 10, 64) +// if err != nil { +// beego.Error(err) +// } + +// //获取上传的文件 +// _, h, err := c.GetFile("uploadfile") +// if err != nil { +// beego.Error(err) +// } +// if h != nil { +// //存入文件夹 +// err = c.SaveToFile("uploadfile", ".\\attachment\\onlyoffice\\"+h.Filename) +// if err != nil { +// beego.Error(err) +// } else { +// err = models.UpdateOnlyAttachment(idNum) +// if err != nil { +// beego.Error(err) +// } +// } +// } +// } diff --git a/controllers/project.go b/controllers/project.go index 0bc1996b..65f943c0 100644 --- a/controllers/project.go +++ b/controllers/project.go @@ -48,7 +48,7 @@ func (c *ProjController) Get() { c.Data["IsLogin"] = false } c.Data["Username"] = username - c.Data["IsProjects"] = true + c.Data["IsProject"] = true c.Data["Ip"] = c.Ctx.Input.IP() c.Data["role"] = role c.TplName = "projects.tpl" @@ -120,18 +120,18 @@ func (c *ProjController) GetProject() { c.Data["role"] = role id := c.Ctx.Input.Param(":id") - switch id { - case "25001": - c.Data["IsProject"] = true - case "25002": - c.Data["IsDesign"] = true - case "25003": - c.Data["IsConstruct"] = true - case "25004": - c.Data["IsSupervision"] = true - case "25005": - c.Data["IsBuild"] = true - } + // switch id { + // case "25001": + c.Data["IsProject"] = true + // case "25002": + // c.Data["IsDesign"] = true + // case "25003": + // c.Data["IsConstruct"] = true + // case "25004": + // c.Data["IsSupervision"] = true + // case "25005": + // c.Data["IsBuild"] = true + // } c.Data["Id"] = id // var categories []*models.ProjCategory var err error diff --git a/models/OnlyofficeModel.go b/models/OnlyofficeModel.go new file mode 100644 index 00000000..55fdf503 --- /dev/null +++ b/models/OnlyofficeModel.go @@ -0,0 +1,185 @@ +package models + +import ( + // "github.com/astaxie/beego" + "github.com/astaxie/beego/orm" + _ "github.com/mattn/go-sqlite3" + // "strconv" + // "strings" + "time" +) + +type OnlyOffice struct { + Id int64 `form:"-"` + Code string `orm:"null"` + Title string `orm:"null"` + Label string `orm:"null"` + End time.Time `orm:"null;type(datetime)"` + Principal string `orm:"null"` + // Ext string `orm:"null"` + Uid int64 `orm:"null"` + Created time.Time `orm:"auto_now_add;type(datetime)"` + Updated time.Time `orm:"auto_now;type(datetime)"` +} + +//附件 +type OnlyAttachment struct { + Id int64 + FileName string + FileSize int64 + Downloads int64 + DocId int64 //*Topic `orm:"rel(fk)"` + Created time.Time `orm:"auto_now_add;type(datetime)"` + Updated time.Time `orm:"auto_now;type(datetime)"` +} + +func init() { + orm.RegisterModel(new(OnlyOffice), new(OnlyAttachment)) +} + +//取得所有项目 +func GetDocs() (docs []*OnlyOffice, err error) { + o := orm.NewOrm() + qs := o.QueryTable("OnlyOffice") + _, err = qs.All(&docs) + if err != nil { + return docs, err + } + return docs, err +} + +//添加成果到项目侧栏某个id下 +//如果这个侧栏id下的这个成果编号已经存在，则返回id +////应该用ReadOrCreate尝试从数据库读取，不存在的话就创建一个 +func AddDoc(code, title, label, principal string, end time.Time, uid int64) (id int64, err error) { + o := orm.NewOrm() + var prod OnlyOffice + err = o.QueryTable("OnlyOffice").Filter("code", code).One(&prod) + if err == orm.ErrNoRows { // 没有找到记录 + product := &OnlyOffice{ + Code: code, + Title: title, + Label: label, + Principal: principal, + End: end, + Uid: uid, + Created: time.Now(), + Updated: time.Now(), + } + id, err = o.Insert(product) + if err != nil { + return 0, err + } + } else if err == orm.ErrMultiRows { + return 0, err + } else if err == nil { + return prod.Id, err + } + return id, err +} + +//添加附件到成果id下 +//如果附件名称已经存在，则不再追加写入数据库 +//应该用ReadOrCreate尝试从数据库读取，不存在的话就创建一个 +func AddOnlyAttachment(filename string, filesize, downloads, productid int64) (id int64, err1, err2 error) { + o := orm.NewOrm() + var attach OnlyAttachment + err1 = o.QueryTable("OnlyAttachment").Filter("DocId", productid).Filter("filename", filename).One(&attach) + if err1 == orm.ErrNoRows { // 没有找到记录 + attachment := &OnlyAttachment{ + FileName: filename, + FileSize: filesize, + Downloads: downloads, + DocId: productid, + Created: time.Now(), + Updated: time.Now(), + } + id, err2 = o.Insert(attachment) + if err2 != nil { + return 0, err1, err2 + } + } else if err1 == orm.ErrMultiRows { + return 0, err1, err2 + } else if err1 == nil { + return attach.Id, err1, err2 + } + return id, err1, err2 +} + +//根据成果id取得所有附件 +func GetOnlyAttachments(id int64) (attachments []*OnlyAttachment, err error) { + o := orm.NewOrm() + qs := o.QueryTable("OnlyAttachment") + _, err = qs.Filter("DocId", id).All(&attachments) + if err != nil { + return nil, err + } + return attachments, err +} + +//根据附件id查询附件 +func GetOnlyAttachbyId(Id int64) (attach OnlyAttachment, err error) { + o := orm.NewOrm() + qs := o.QueryTable("OnlyAttachment") + err = qs.Filter("id", Id).One(&attach) + return attach, err +} + +//修改附件的日期 +func UpdateOnlyAttachment(cid int64) (err error) { + o := orm.NewOrm() + attachment := &OnlyAttachment{Id: cid} + if o.Read(attachment) == nil { + attachment.Updated = time.Now() + _, err := o.Update(attachment, "Updated") + if err != nil { + return err + } + } + return err +} + +//修改成果信息 +func UpdateDoc(cid int64, code, title, label, principal string, end time.Time) error { + o := orm.NewOrm() + product := &OnlyOffice{Id: cid} + if o.Read(product) == nil { + product.Code = code + product.Title = title + product.Label = label + product.Principal = principal + product.End = end + product.Updated = time.Now() + _, err := o.Update(product) + if err != nil { + return err + } + } + return nil +} + +//删除_把附件也一并删除（在controllers中实现吧） +func DeleteDoc(cid int64) error { + o := orm.NewOrm() + product := &OnlyOffice{Id: cid} + if o.Read(product) == nil { + _, err := o.Delete(product) + if err != nil { + return err + } + } + return nil +} + +//删除附件 +func DeleteOnlyAttachment(cid int64) error { + o := orm.NewOrm() + attachment := &OnlyAttachment{Id: cid} + if o.Read(attachment) == nil { + _, err := o.Delete(attachment) + if err != nil { + return err + } + } + return nil +} diff --git a/routers/router.go b/routers/router.go index 16d9e3a5..7c843b95 100644 --- a/routers/router.go +++ b/routers/router.go @@ -11,6 +11,23 @@ import ( func init() { beego.Router("/test", &controllers.MainController{}, "*:Test") + beego.Router("/url-to-callback", &controllers.OnlyController{}, "*:UrltoCallback") + // beego.Router("/onlyoffice/post", &controllers.OnlyController{}, "post:PostOnlyoffice") + beego.Router("/onlyoffice", &controllers.OnlyController{}, "get:Get") + //table获取所有数据给上面界面使用 + beego.Router("/onlyoffice/data", &controllers.OnlyController{}, "*:GetData") + //添加一个文档 + beego.Router("/onlyoffice/addattachment", &controllers.OnlyController{}, "post:AddOnlyAttachment") + //在onlyoffice中打开文档协作 + beego.Router("/onlyoffice/:id:string", &controllers.OnlyController{}, "*:OnlyOffice") + //删除 + beego.Router("/onlyoffice/deletedoc", &controllers.OnlyController{}, "*:DeleteDoc") + //修改 + beego.Router("/onlyoffice/updatedoc", &controllers.OnlyController{}, "*:UpdateDoc") + + //下载doc + beego.Router("/attachment/onlyoffice/*", &controllers.OnlyController{}, "get:DownloadDoc") + beego.Router("/role/test", &controllers.RoleController{}, "*:Test") beego.Router("/1/slide", &controllers.MainController{}, "*:Slide") beego.Router("/postdata", &controllers.MainController{}, "*:Postdata") diff --git a/views/T.navbar.tpl b/views/T.navbar.tpl index 2564a794..6cd91d6f 100644 --- a/views/T.navbar.tpl +++ b/views/T.navbar.tpl @@ -5,10 +5,13 @@ 首页
  • - 项目 + 项目 +
    • +
  • + OnlyOffice
    • -
  • +
  • 进度 @@ -82,8 +85,8 @@ {{.Username}} @@ -94,8 +97,8 @@ {{.Username}} @@ -107,8 +110,8 @@ {{.Username}} @@ -118,8 +121,8 @@ {{.Username}} diff --git a/views/onlyoffice/T.navbar.tpl b/views/onlyoffice/T.navbar.tpl new file mode 100644 index 00000000..6cd91d6f --- /dev/null +++ b/views/onlyoffice/T.navbar.tpl @@ -0,0 +1,155 @@ +{{define "navbar"}} + +{{end}} + diff --git a/views/onlyoffice/docs.tpl b/views/onlyoffice/docs.tpl new file mode 100644 index 00000000..690bc082 --- /dev/null +++ b/views/onlyoffice/docs.tpl @@ -0,0 +1,903 @@ + + + + + fei-ONLYOFFICE + + + + + + + + + + + + + + + + + + + + + + + + + + +
    {{template "navbar" .}}
    + + + +
    +

    文档列表

    +
    + + + + + + + + + + +
    + + + + + + + + + + + + + + + + + + + +
    #编号名称关键字负责人DOCXXLSXPPTX结束时间建立时间更新时间
    + + + +
    + +
    + + +
    + +
    + +
    + +
    + +
    + + + + + \ No newline at end of file diff --git a/views/onlyoffice/onlyoffice.tpl b/views/onlyoffice/onlyoffice.tpl new file mode 100644 index 00000000..1d394aea --- /dev/null +++ b/views/onlyoffice/onlyoffice.tpl @@ -0,0 +1,34 @@ + + + + fei-OnlyOffice + + + +
    + + + + \ No newline at end of file