From 657751a7d766121c1e61bba8399fe25f1cb41ab9 Mon Sep 17 00:00:00 2001
From: keven1024 <keven@fudaoyuan.icu>
Date: Sun, 1 Jun 2025 17:58:48 +0800
Subject: [PATCH] feat(worker): add file creation timestamp and file type in
 GenStandardFile function; implement new image processing functions

---
 worker/internal/services/file.go |  3 +++
 worker/internal/tasks/image.go   | 19 ++++++++++++-------
 2 files changed, 15 insertions(+), 7 deletions(-)

diff --git a/worker/internal/services/file.go b/worker/internal/services/file.go
index 084d6ab..ce71991 100644
--- a/worker/internal/services/file.go
+++ b/worker/internal/services/file.go
@@ -4,6 +4,7 @@ import (
 	"errors"
 	"os"
 	"path/filepath"
+	"time"
 	"worker/internal/models"
 	"worker/internal/utils"
 )
@@ -51,6 +52,8 @@ func GenStandardFile(filePath string, mimeType string) (GenStandardFileReturn, e
 			FileHash: compressedFileHash,
 			MimeType: mimeType,
 		},
+		FileType:  models.FileTypeUpload,
+		CreatedAt: time.Now().Unix(),
 	})
 
 	return GenStandardFileReturn{
diff --git a/worker/internal/tasks/image.go b/worker/internal/tasks/image.go
index 7ac0894..ed04af1 100644
--- a/worker/internal/tasks/image.go
+++ b/worker/internal/tasks/image.go
@@ -55,13 +55,18 @@ func CompressImage(ctx context.Context, task *asynq.Task) error {
 
 	models.SetRedisTaskInfo(task.ResultWriter().TaskID(), map[string]any{
 		"status": "success",
-		"old_file": map[string]any{
-			"id":   payload.FileId,
-			"size": originalFileInfo.FileSize,
-		},
-		"new_file": map[string]any{
-			"id":   compressedFileInfo.FileId,
-			"size": compressedFileInfo.FileSize,
+		"result": []any{
+			map[string]any{
+				"status": "success",
+				"old_file": map[string]any{
+					"id":   payload.FileId,
+					"size": originalFileInfo.FileSize,
+				},
+				"new_file": map[string]any{
+					"id":   compressedFileInfo.FileId,
+					"size": compressedFileInfo.FileSize,
+				},
+			},
 		},
 	})