panlei
2019-11-05 20f1fd7aed6ecc3fcd1dc811205dd3460975c3e6
WeedFSClient.go
@@ -6,9 +6,9 @@
   "errors"
   "fmt"
   "io"
   "log"
   "mime/multipart"
   "net/http"
   "github.com/kirinlabs/HttpRequest"
   "time"
)
@@ -32,7 +32,7 @@
   client := &http.Client{Timeout: timeout}
   resp, err := client.Do(request)
   if err != nil {
      log.Fatal(err)
      fmt.Println("UploadFile client.Do(request) err:", err)
      return "", err
   }
   defer func() {
@@ -55,7 +55,7 @@
      body := &bytes.Buffer{}
      _, err := body.ReadFrom(resp.Body)
      if err != nil {
         log.Fatal(err)
         fmt.Println("UploadFile body.ReadForm(resp.Body) err:", err)
      }
      m := make(map[string]interface{})
@@ -64,12 +64,20 @@
      }
      filePath := m["fileUrl"].(string)
      return filePath,nil
      //if strings.Contains(filePath,"/"){
      //   idx := strings.Index(filePath,"/")
      //   filePath = filePath[idx+1:]
      //   return filePath,nil
      //} else {
      //   return "",errors.New("file upload error")
      //}
   }
}
// 获得一个fid
func GetFid(url string)(weedPath string ,err error) {
   res,err := HttpRequest.NewRequest().Post(url)
   if err != nil {
      fmt.Println("网络传输错误!")
   }
   var m map[string]interface{}
   err = res.Json(&m)
   if err != nil {
      return "",err
   }
   return "http://"+m["url"].(string)+"/"+m["fid"].(string),err
}