import ("archive/zip")

        returnFileName := task.Name + "_" + task.Version + ".zip"
        ctx.Resp.Header().Set("Content-Disposition", "attachment; filename="+returnFileName)
        ctx.Resp.Header().Set("Content-Type", "application/octet-stream")
        w := zip.NewWriter(ctx.Resp)
        defer w.Close()
        for _, oneFile := range allFile {
            if oneFile.IsDir {
                log.Info("zip dir name:" + oneFile.FileName)
            } else {
                log.Info("zip file name:" + oneFile.FileName)
                fDest, err := w.Create(oneFile.FileName)
                if err != nil {
                    log.Info("create zip entry error, download file failed: %s\n", err.Error())
                    ctx.ServerError("download file failed:", err)
                    return
                }
                body, err := storage.ObsDownloadAFile(setting.Bucket, path+oneFile.FileName)
                if err != nil {
                    log.Info("download file failed: %s\n", err.Error())
                    ctx.ServerError("download file failed:", err)
                    return
                } else {
                    defer body.Close()
                    p := make([]byte, 1024)
                    var readErr error
                    var readCount int
                    // 读取对象内容
                    for {
                        readCount, readErr = body.Read(p)
                        if readCount > 0 {
                            fDest.Write(p[:readCount])
                        }
                        if readErr != nil {
                            break
                        }
                    }
                }
            }
        }