CancelBatch 取消批量上传
(batchID string)
| 426 | |
| 427 | // CancelBatch 取消批量上传 |
| 428 | func (m *BatchUploadManager) CancelBatch(batchID string) error { |
| 429 | batch, err := m.GetBatch(batchID) |
| 430 | if err != nil { |
| 431 | return err |
| 432 | } |
| 433 | |
| 434 | m.mu.Lock() |
| 435 | batch.Status = "cancelled" |
| 436 | batch.UpdatedAt = time.Now() |
| 437 | m.mu.Unlock() |
| 438 | |
| 439 | m.progressStorage.SaveBatch(batch) |
| 440 | return nil |
| 441 | } |
| 442 | |
| 443 | // IsBatchCancelled 判断批次是否已取消 |
| 444 | func (m *BatchUploadManager) IsBatchCancelled(batchID string) bool { |