chore: 优化分片上传

- 超时时间默认24小时
- 加速分片记录的删除

Author: arrebole

cache/upload.go

@@ -53,7 +53,7 @@ func FindMutUpload(fn func(key string, entity *MutUpload) bool) ([]*MutUpload, e
 		}
 
 		// 删除过期的分片上传记录
-		if time.Since(item.CreateAt).Hours() > 12 {
+		if time.Since(item.CreateAt).Hours() > 24 {
 			FindMutUploadPart(func(key string, part *MutUploadPart) bool {
 				if part.UploadID == item.UploadID {
 					db.Delete([]byte(key), nil)
@@ -93,7 +93,11 @@ type MutUploadPart struct {
 }
 
 func (p *MutUploadPart) Key() string {
-	return fmt.Sprintf("part-%s-%d", p.UploadID, p.PartId)
+	return fmt.Sprintf(
+		"part-%x-%d",
+		md5.Sum([]byte(p.UploadID)),
+		p.PartId,
+	)
 }
 
 // 获取已经上传的分片
@@ -135,11 +139,12 @@ func DeleteByUploadID(uploadID string) error {
 		}
 		return false
 	})
-	FindMutUploadPart(func(key string, entity *MutUploadPart) bool {
-		if entity.UploadID == uploadID {
-			Delete(key)
-		}
-		return false
+	h := fmt.Sprintf(
+		"%x",
+		md5.Sum([]byte(uploadID)),
+	)
+	Range("part-"+h, func(key, data []byte) {
+		Delete(string(key))
 	})
 	return nil
 }

session.go

@@ -571,7 +571,6 @@ func (sess *Session) putFileWithProgress(localPath, upPath string, localInfo os.
 		}
 
 		// 上传分片任务
-		fmt.Println(skips)
 		uploader := partial.NewMultiPartialUploader(
 			DefaultBlockSize,
 			fd,