Update core/tasks/batchimport/progress.go

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
This commit is contained in:
Krau
2026-01-17 21:19:33 +08:00
committed by GitHub
parent fb20fee2bc
commit b2c9d6612e

View File

@@ -42,10 +42,16 @@ func (p *Progress) OnStart(ctx context.Context, info TaskInfo) {
p.lastUpdatePercent.Store(0) p.lastUpdatePercent.Store(0)
log.FromContext(ctx).Debugf("Batch import task progress tracking started for message %d in chat %d", p.MessageID, p.ChatID) log.FromContext(ctx).Debugf("Batch import task progress tracking started for message %d in chat %d", p.MessageID, p.ChatID)
sizeMB := float64(info.TotalSize()) / (1024 * 1024)
statsText := i18n.T(i18nk.BotMsgProgressImportStartStats, map[string]any{
"size": fmt.Sprintf("%.2f", sizeMB),
"count": info.Count(),
})
entityBuilder := entity.Builder{} entityBuilder := entity.Builder{}
if err := styling.Perform(&entityBuilder, if err := styling.Perform(&entityBuilder,
styling.Plain(i18n.T(i18nk.BotMsgProgressImportStartPrefix, nil)), styling.Plain(i18n.T(i18nk.BotMsgProgressImportStartPrefix, nil)),
styling.Code(fmt.Sprintf("%.2f MB (%d个文件)", float64(info.TotalSize())/(1024*1024), info.Count())), styling.Code(statsText),
); err != nil { ); err != nil {
log.FromContext(ctx).Errorf("Failed to build entities: %s", err) log.FromContext(ctx).Errorf("Failed to build entities: %s", err)
return return