🐛 日志格式 & 邮箱错误处理

internal/framework/logger/zap.go

@@ -1,18 +1,32 @@
 package logger
 
 import (
-	"go.uber.org/zap"
 	"log"
+	"time"
+
+	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
 )
 
 var Logger *zap.Logger
 
 func init() {
-	logger, err := zap.NewProduction()
+	// Create a production config and customize the time encoder
+	config := zap.NewProductionConfig()
+	config.EncoderConfig.EncodeTime = BeijingTimeEncoder
 
+	// Build the logger with the custom config
+	logger, err := config.Build()
 	if err != nil {
 		log.Fatalf("cannot init zap logger: %+v", err)
 	}
 
 	Logger = logger
 }
+
+// BeijingTimeEncoder formats time in Beijing timezone
+func BeijingTimeEncoder(t time.Time, enc zapcore.PrimitiveArrayEncoder) {
+	// Set timezone to Beijing (UTC+8)
+	beijingLoc, _ := time.LoadLocation("Asia/Shanghai")
+	enc.AppendString(t.In(beijingLoc).Format("2006-01-02 15:04:05"))
+}

internal/framework/schedule/email_handler.go

@@ -19,11 +19,18 @@ type EmailTaskHandler struct {
 
 func (h *EmailTaskHandler) ProcessTask(ctx context.Context, task *asynq.Task) (err error) {
 	defer utils.Pass(&err)
-
 	var payload email.SendPayload
-
 	e := gob.NewDecoder(bytes.NewReader(task.Payload())).Decode(&payload)
 	utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
+	logger.Logger.Info("开始处理邮件发送", zap.String("邮箱", payload.To))
+	defer func() {
+		if r := recover(); r != nil {
+			// 打印日志
+			logger.Logger.Error("邮件发送失败", zap.String("邮箱", payload.To), zap.Error(r.(error)))
+			// 重新抛出相同的 panic
+			panic(r)
+		}
+	}()
 
 	message := mail.NewMsg()