From ff20506dd0538ba0803d3cc1fec69eb1c8e3686e Mon Sep 17 00:00:00 2001 From: Linus Torvalds Date: Sun, 1 Mar 2026 00:05:20 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E5=88=9A=E6=89=8D=E7=9A=84?= =?UTF-8?q?=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- back/src/daemon/scheduledAutoCancel.go | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/back/src/daemon/scheduledAutoCancel.go b/back/src/daemon/scheduledAutoCancel.go index 65b5324..0a8ad4d 100644 --- a/back/src/daemon/scheduledAutoCancel.go +++ b/back/src/daemon/scheduledAutoCancel.go @@ -2,6 +2,7 @@ package daemon import ( "context" + "errors" "fmt" "log/slog" "time" @@ -87,9 +88,11 @@ func doCancelJob(jobID int) error { for _, a := range beforeScheduledTickets { ticketIDSlice = append(ticketIDSlice, a.Tid) } - slog.Info("本次操作共涉及如下工单", "t", ticketIDSlice) + slog.Info("本次操作共涉及如下工单", "t", ticketIDSlice, "ID", jobID) + var noErr = true + var result []int32 for _, a := range ticketIDSlice { - _, err := q.CreateTicketTrace(ctx, sqlc.CreateTicketTraceParams{ + t, err := q.CreateTicketTrace(ctx, sqlc.CreateTicketTraceParams{ Tid: a, UpdatedAt: pgtype.Timestamptz{ Time: time.Now(), @@ -107,10 +110,17 @@ func doCancelJob(jobID int) error { Remark: "系统检测到预约已过期,似乎是我们爽约了,我们非常抱歉为您造成的不便,您可以再次提交报修预约,我们会努力做得更好。", }) if err != nil { - return fmt.Errorf("在增加记录时失败了:%w", err) + noErr = false + slog.Error("自动预约处理程序增添trace时失败", "error", err) + continue } + result = append(result, t.Tid) } + slog.Info("本次操作实际操作的工单", "t", result, "ID", jobID) //3.如果没有问题就提交事务 + if !noErr { + return errors.New("增加trace时出现错误,请查看日志。") + } return nil }) return err