From fc654b5da7ebdea83b4bbf9705d93ee489bff853 Mon Sep 17 00:00:00 2001 From: engigu Date: Mon, 30 Dec 2024 23:52:04 +0800 Subject: [PATCH] chore: cron messge send msg logging --- service/cron_msg_service/startup_cron_msg.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/service/cron_msg_service/startup_cron_msg.go b/service/cron_msg_service/startup_cron_msg.go index 1520e1a..8edb20a 100644 --- a/service/cron_msg_service/startup_cron_msg.go +++ b/service/cron_msg_service/startup_cron_msg.go @@ -31,7 +31,7 @@ func (s MsgCronTask) Register() { } length := len(data) if length > 0 { - logrus.Infof("完成用户自定义的定时消息注册，个数：%d", length) + logrus.Infof("完成用户自定义的定时消息注册，注册个数：%d", length) } } @@ -47,6 +47,7 @@ func AddCronMsgToCronServer(msg models.CronMessages) { }, }) constant.CronMsgIdMapMemoryCache[msg.ID] = taskId + logrus.Infof("新增定时消息成功，消息id: %s， 当前任务总数：%d", msg.ID, len(constant.CronMsgIdMapMemoryCache)) } // 执行任务的构造函数 @@ -68,7 +69,11 @@ func CronMsgSendF(msg models.CronMessages) { }), } taskData, _ := sender.SendPreCheck() - sender.Send(taskData) + _, err = sender.Send(taskData) + if err != nil { + logrus.Error("执行定时消息失败：%s", err.Error()) + return + } } // UpdateCronMsgToCronServer 更新定时服务的任务 @@ -83,7 +88,7 @@ func UpdateCronMsgToCronServer(msg models.CronMessages) { // 注册新的定时任务 AddCronMsgToCronServer(msg) } - logrus.Infof("完成定时消息的定时更新，消息id: %s， 总数：%d", msg.ID, len(constant.CronMsgIdMapMemoryCache)) + logrus.Infof("完成定时消息的定时更新，消息id: %s， 当前任务总数：%d", msg.ID, len(constant.CronMsgIdMapMemoryCache)) } // RemoveCronMsgToCronServer 删除定时任务中心的任务 @@ -93,7 +98,7 @@ func RemoveCronMsgToCronServer(msg models.CronMessages) { delete(constant.CronMsgIdMapMemoryCache, msg.ID) cron_service.RemoveTask(entryId) } - logrus.Infof("完成定时消息的定时删除，消息id: %s， 总数：%d", msg.ID, len(constant.CronMsgIdMapMemoryCache)) + logrus.Infof("删除定时消息完成，消息id: %s， 剩余任务总数：%d", msg.ID, len(constant.CronMsgIdMapMemoryCache)) } // StartUpMsgCronTask 启动注册定时任务