增加删除文件接口

QMPlusServer/controller/api/fileUploadAndDownload.go

@@ -23,7 +23,7 @@ func UploadFile(c *gin.Context) {
 		servers.ReportFormat(c, false, fmt.Sprintf("上传文件失败，%v", err), gin.H{})
 	} else {
 		//文件上传后拿到文件路径
-		err, filePath := servers.Upload(header, USER_HEADER_BUCKET, USER_HEADER_IMG_PATH)
+		err, filePath, key := servers.Upload(header, USER_HEADER_BUCKET, USER_HEADER_IMG_PATH)
 		if err != nil {
 			servers.ReportFormat(c, false, fmt.Sprintf("接收返回值失败，%v", err), gin.H{})
 		} else {
@@ -33,6 +33,7 @@ func UploadFile(c *gin.Context) {
 			file.Name = header.Filename
 			s := strings.Split(file.Name, ".")
 			file.Tag = s[len(s)-1]
+			file.Key = key
 			err := file.Upload()
 			if err != nil {
 				servers.ReportFormat(c, false, fmt.Sprintf("修改数据库链接失败，%v", err), gin.H{})
@@ -43,6 +44,35 @@ func UploadFile(c *gin.Context) {
 	}
 }
 
+// @Tags FileUploadAndDownload
+// @Summary 删除文件
+// @Security ApiKeyAuth
+// @Produce  application/json
+// @Param data body dbModel.FileUploadAndDownload true "传入文件里面id即可"
+// @Success 200 {string} json "{"success":true,"data":{},"msg":"返回成功"}"
+// @Router /fileUploadAndDownload/deleteFile [post]
+func DeleteFile(c *gin.Context) {
+	var file dbModel.FileUploadAndDownload
+	_ = c.ShouldBind(&file)
+	err, f := file.FindFile()
+	if err != nil {
+		servers.ReportFormat(c, false, fmt.Sprintf("删除失败，%v", err), gin.H{})
+	} else {
+		err = servers.DeleteFile(USER_HEADER_BUCKET, f.Key)
+		if err != nil {
+			servers.ReportFormat(c, false, fmt.Sprintf("删除失败，%v", err), gin.H{})
+		} else {
+			err = file.DeleteFile()
+			if err != nil {
+				servers.ReportFormat(c, false, fmt.Sprintf("删除失败，%v", err), gin.H{})
+			} else {
+				servers.ReportFormat(c, true, fmt.Sprintf("删除成功，%v", err), gin.H{})
+			}
+		}
+	}
+
+}
+
 // @Tags FileUploadAndDownload
 // @Summary 分页文件列表
 // @Security ApiKeyAuth

QMPlusServer/controller/api/user.go

@@ -136,7 +136,7 @@ func UploadHeaderImg(c *gin.Context) {
 		servers.ReportFormat(c, false, fmt.Sprintf("上传文件失败，%v", err), gin.H{})
 	} else {
 		//文件上传后拿到文件路径
-		err, filePath := servers.Upload(header, USER_HEADER_BUCKET, USER_HEADER_IMG_PATH)
+		err, filePath, _ := servers.Upload(header, USER_HEADER_BUCKET, USER_HEADER_IMG_PATH)
 		if err != nil {
 			servers.ReportFormat(c, false, fmt.Sprintf("接收返回值失败，%v", err), gin.H{})
 		} else {

QMPlusServer/controller/servers/upload.go

@@ -13,7 +13,7 @@ var accessKey string = "25j8dYBZ2wuiy0yhwShytjZDTX662b8xiFguwxzZ" // 你在七
 var secretKey string = "pgdbqEsf7ooZh7W3xokP833h3dZ_VecFXPDeG5JY" // 你在七牛云的secretKey  这里是我个人测试号的key 仅供测试使用 恳请大家不要乱传东西
 
 // 接收两个参数 一个文件流 一个 bucket 你的七牛云标准空间的名字
-func Upload(file *multipart.FileHeader, bucket string, urlPath string) (err error, path string) {
+func Upload(file *multipart.FileHeader, bucket string, urlPath string) (err error, path string, key string) {
 	putPolicy := storage.PutPolicy{
 		Scope: bucket,
 	}
@@ -36,7 +36,7 @@ func Upload(file *multipart.FileHeader, bucket string, urlPath string) (err erro
 	f, e := file.Open()
 	if e != nil {
 		fmt.Println(e)
-		return e, ""
+		return e, "", ""
 	}
 	dataLen := file.Size
 	fileKey := fmt.Sprintf("%d%s", time.Now().Unix(), file.Filename) // 文件名格式 自己可以改 建议保证唯一性
@@ -44,7 +44,26 @@ func Upload(file *multipart.FileHeader, bucket string, urlPath string) (err erro
 	if err != nil {
 		fmt.Println(err)
 		//qmlog.QMLog.Info(err)
-		return err, ""
+		return err, "", ""
 	}
-	return err, urlPath + "/" + ret.Key
+	return err, urlPath + "/" + ret.Key, ret.Key
+}
+
+func DeleteFile(bucket string, key string) error {
+
+	mac := qbox.NewMac(accessKey, secretKey)
+	cfg := storage.Config{
+		// 是否使用https域名进行资源管理
+		UseHTTPS: false,
+	}
+	// 指定空间所在的区域，如果不指定将自动探测
+	// 如果没有特殊需求，默认不需要指定
+	//cfg.Zone=&storage.ZoneHuabei
+	bucketManager := storage.NewBucketManager(mac, &cfg)
+	err := bucketManager.Delete(bucket, key)
+	if err != nil {
+		fmt.Println(err)
+		return err
+	}
+	return nil
 }