upload_api.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. /*
  2. * @description:
  3. * @Author: CP
  4. * @Date: 2021-03-31 15:06:21
  5. * @FilePath: \design_quantity\web\api\upload_api.go
  6. */
  7. package api
  8. import (
  9. "bytes"
  10. "fmt"
  11. "io"
  12. "log"
  13. "os"
  14. "strings"
  15. "time"
  16. "github.com/kataras/iris/v12"
  17. "go.mod/conf"
  18. "go.mod/services"
  19. )
  20. type UploadApi struct {
  21. //框架-web应用上下文环境
  22. Ctx iris.Context
  23. // // 需要用的service
  24. ServiceContract services.ContractService
  25. }
  26. // Upload : 处理文件上传
  27. func (c *UploadApi) Post() {
  28. errCode := 0
  29. defer func() {
  30. if errCode < 0 {
  31. c.Ctx.JSON(iris.Map{"code": -1, "msg": "上传失败"})
  32. } else {
  33. c.Ctx.JSON(iris.Map{"code": 0, "msg": "上传成功"})
  34. }
  35. return
  36. }()
  37. file, head, err := c.Ctx.FormFile("file")
  38. if err != nil {
  39. log.Printf("Failed to get form data, err:%s\n", err.Error())
  40. errCode = -1
  41. return
  42. }
  43. defer file.Close()
  44. buf := bytes.NewBuffer(nil)
  45. if _, err := io.Copy(buf, file); err != nil {
  46. log.Printf("Failed to get file data, err:%s\n", err.Error())
  47. errCode = -2
  48. return
  49. }
  50. // 文件元信息-todo
  51. // FileName := head.Filename
  52. FileSize := int64(len(buf.Bytes()))
  53. UploadAt := fmt.Sprintf("%d", time.Now().UnixNano())
  54. Location := conf.MergeLocalRootDir + UploadAt + head.Filename // 存储地址
  55. newFile, err := os.Create(Location)
  56. if err != nil {
  57. log.Printf("Failed to create file, err:%s\n", err.Error())
  58. errCode = -3
  59. return
  60. }
  61. defer newFile.Close()
  62. nByte, err := newFile.Write(buf.Bytes())
  63. if int64(nByte) != FileSize || err != nil {
  64. log.Printf("Failed to save data into file, writtenSize:%d, err:%s\n", nByte, err.Error())
  65. errCode = -4
  66. return
  67. }
  68. fmt.Println(c.Ctx.FormValue("id"))
  69. // treeVM := &viewmodels.TreeSectionContract{}
  70. // err = c.Ctx.ReadForm(treeVM)
  71. // if err != nil {
  72. // log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  73. // errCode = -6
  74. // return
  75. // }
  76. // fmt.Println(treeVM)
  77. // id, err := utils.GetDecryptId(treeVM.Id)
  78. // if err != nil {
  79. // errCode = -6
  80. // return
  81. // }
  82. justString := strings.Join(head.Header["Content-Type"], "")
  83. fmt.Println(justString)
  84. err = c.ServiceContract.SaveUpload(Location, head.Filename, 55, justString)
  85. if err != nil {
  86. errCode = -6
  87. return
  88. }
  89. }