From d4a2cf2f80fd08fa9f2c2e311bea49b28b466bc6 Mon Sep 17 00:00:00 2001 From: xzb <223@qq.com> Date: Thu, 9 Nov 2023 13:43:18 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A1=E8=BD=B4rssp=20=E9=9B=86=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- third_party/axle_device/rssp_axle.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/third_party/axle_device/rssp_axle.go b/third_party/axle_device/rssp_axle.go index 5165141..43fa3dd 100644 --- a/third_party/axle_device/rssp_axle.go +++ b/third_party/axle_device/rssp_axle.go @@ -2,6 +2,7 @@ package axle_device import ( "context" + "fmt" "joylink.club/bj-rtsts-server/config" "joylink.club/bj-rtsts-server/third_party/message" "log/slog" @@ -105,7 +106,7 @@ func (s *rsspAxle) Stop() { func (s *rsspAxle) doTaskSendStatus(sendContext context.Context) { defer func() { if e := recover(); e != nil { - slog.Error("定时发送计轴区段状态任务异常", "error", e, "stack", string(debug.Stack())) + slog.Error(fmt.Sprintf("[%s-%s-%s]定时发送计轴区段状态任务异常", s.city, s.lineId, s.centralizedStation), "error", e, "stack", string(debug.Stack())) debug.PrintStack() } }() @@ -116,7 +117,7 @@ func (s *rsspAxle) doTaskSendStatus(sendContext context.Context) { default: } if s.messageManager == nil { - slog.Warn("定时发送计轴区段状态任务因messageManager不存在退出") + slog.Warn(fmt.Sprintf("[%s-%s-%s]定时发送计轴区段状态任务因messageManager不存在退出", s.city, s.lineId, s.centralizedStation)) return } //收集区段状态