feat:xiugai

client.go

@@ -27,31 +27,32 @@ var (
 
 /* restful方式上传
  * @param domain 域名，例如：https://ossservice.jianyu360.cn
- * @param bucketId 桶id
- * @param objectName 对象名称
- * @param stream 文件流
- * @param gzip 是否压缩
+ * @param args 参数
+ * @param args.BucketID 文件名
+ * @param args.objectName 对象名称
+ * @param args.Stream 文件流
+ * @param args.Gzip 是否压缩
  * @return {"error_code":0,"error_msg":"上传成功"}
  */
-func UpLoadByRestful(domain, bucketId, objectName string, stream []byte, gzip bool) (reply *api.Result) {
+func UpLoadByRestful(domain string, args *entity.UploadArgs) (reply *api.Result) {
 	reply = &api.Result{Error_code: -1}
 
 	// 创建一个缓冲区来存储表单数据
 	body := &bytes.Buffer{}
 	writer := multipart.NewWriter(body)
-	writer.WriteField("bucket_id", bucketId)
-	writer.WriteField("object_name", objectName)
-	writer.WriteField("gzip", strconv.FormatBool(gzip))
+	writer.WriteField("bucket_id", args.BucketID)
+	writer.WriteField("object_name", args.ObjectName)
+	writer.WriteField("gzip", strconv.FormatBool(args.Gzip))
 
 	// 创建表单字段
-	part, err := writer.CreateFormFile("file", objectName)
+	part, err := writer.CreateFormFile("file", args.ObjectName)
 	if err != nil {
 		reply.Error_msg = err.Error()
 		return
 	}
 
 	// 模拟文件流
-	fileStream := bytes.NewReader(stream)
+	fileStream := bytes.NewReader(args.Stream)
 
 	// 将文件流复制到表单字段
 	_, err = io.Copy(part, fileStream)
@@ -71,17 +72,18 @@ func UpLoadByRestful(domain, bucketId, objectName string, stream []byte, gzip bo
 
 /* restful方式下载
  * @param domain 域名，例如：https://ossservice.jianyu360.cn
- * @param bucketId 桶id
- * @param objectName 对象名称
+ * @param args 参数
+ * @param args.BucketID 文件名
+ * @param args.objectName 对象名称
  * @return {"error_code":0,"error_msg":"下载成功","data":文件流}
  */
-func DownloadByRestful(domain, bucketId, objectName string) (reply *api.Result) {
+func DownloadByRestful(domain string, args *entity.Args) (reply *api.Result) {
 	reply = &api.Result{}
 	// 创建一个缓冲区来存储表单数据
 	body := &bytes.Buffer{}
 	writer := multipart.NewWriter(body)
-	writer.WriteField("bucket_id", bucketId)
-	writer.WriteField("object_name", objectName)
+	writer.WriteField("bucket_id", args.BucketID)
+	writer.WriteField("object_name", args.ObjectName)
 	if respBody, err := Post(domain+constant.DownloadUrl, writer, body); err != nil {
 		reply.Error_msg = err.Error()
 	} else {
@@ -93,17 +95,18 @@ func DownloadByRestful(domain, bucketId, objectName string) (reply *api.Result)
 
 /* restful方式删除
  * @param domain 域名，例如：https://ossservice.jianyu360.cn
- * @param bucketId 桶id
- * @param objectName 对象名称
+ * @param args 参数
+ * @param args.BucketID 文件名
+ * @param args.objectName 对象名称
  * @return {"error_code":0,"error_msg":"删除成功"}
  */
-func DeleteByRestful(domain, bucketId, objectName string) (reply *api.Result) {
+func DeleteByRestful(domain string, args *entity.Args) (reply *api.Result) {
 	reply = &api.Result{}
 	// 创建一个缓冲区来存储表单数据
 	body := &bytes.Buffer{}
 	writer := multipart.NewWriter(body)
-	writer.WriteField("bucket_id", bucketId)
-	writer.WriteField("object_name", objectName)
+	writer.WriteField("bucket_id", args.BucketID)
+	writer.WriteField("object_name", args.ObjectName)
 	if respBody, err := Post(domain+constant.DeleteUrl, writer, body); err != nil {
 		reply.Error_msg = err.Error()
 	} else {
@@ -114,17 +117,18 @@ func DeleteByRestful(domain, bucketId, objectName string) (reply *api.Result) {
 
 /* restful方式获取标讯正文
  * @param domain 域名，例如：https://ossservice.jianyu360.cn
- * @param bucketId 桶id
- * @param objectName 对象名称
+ * @param args 参数
+ * @param args.BucketID 文件名
+ * @param args.objectName 对象名称
  * @return {"error_code":0,"error_msg":"获取正文成功","data":"正文内容"}
  */
-func GetBidDetailByRestful(domain, bucketId, objectName string) (reply *api.Result) {
+func GetBidDetailByRestful(domain string, args *entity.Args) (reply *api.Result) {
 	reply = &api.Result{}
 	// 创建一个缓冲区来存储表单数据
 	body := &bytes.Buffer{}
 	writer := multipart.NewWriter(body)
-	writer.WriteField("bucket_id", bucketId)
-	writer.WriteField("object_name", objectName)
+	writer.WriteField("bucket_id", args.BucketID)
+	writer.WriteField("object_name", args.ObjectName)
 	if respBody, err := Post(domain+constant.GetBidDetailUrl, writer, body); err != nil {
 		reply.Error_msg = err.Error()
 	} else {