diff --git a/main.go b/main.go index 2360192..fa009fa 100644 --- a/main.go +++ b/main.go @@ -71,10 +71,10 @@ func main() { logrus.WithFields(logrus.Fields{ "prefix": fmt.Sprintf("[PID:%d]", os.Getpid()), - }).Infof(startInfo) + }).Info(startInfo) err := server.ListenAndServe() if err != nil { - logrus.Errorf("Server err: ", err) + logrus.Errorf("Server err: %v", err) } } diff --git a/service/cron_msg_service/startup_cron_msg.go b/service/cron_msg_service/startup_cron_msg.go index f64921d..850f560 100644 --- a/service/cron_msg_service/startup_cron_msg.go +++ b/service/cron_msg_service/startup_cron_msg.go @@ -75,7 +75,7 @@ func CronMsgSendF(msg models.CronMessages) { taskData, _ := sender.SendPreCheck() _, err = sender.Send(taskData) if err != nil { - logrus.Error("执行定时消息失败:%s", err.Error()) + logrus.Errorf("执行定时消息失败:%s", err.Error()) return } } diff --git a/service/send_message_service/send_message.go b/service/send_message_service/send_message.go index 402e553..65b489b 100644 --- a/service/send_message_service/send_message.go +++ b/service/send_message_service/send_message.go @@ -112,7 +112,7 @@ func (sm *SendMessageService) SendPreCheck() (models.TaskIns, error) { // 模板模式:使用模板ID获取实例 if sm.TemplateID == "" { errStr = "模板模式下 TemplateID 不能为空" - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } @@ -120,12 +120,12 @@ func (sm *SendMessageService) SendPreCheck() (models.TaskIns, error) { insList, err := models.GetTemplateInsList(sm.TemplateID) if err != nil { errStr = fmt.Sprintf("模板[%s]实例查询失败:%s", sm.TemplateID, err) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } if len(insList) == 0 { errStr = fmt.Sprintf("模板[%s]没有关联任何实例!", sm.TemplateID) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } @@ -143,7 +143,7 @@ func (sm *SendMessageService) SendPreCheck() (models.TaskIns, error) { // 传统任务模式:使用任务ID查询 if sm.TaskID == "" { errStr = "任务模式下 TaskID 不能为空" - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } @@ -153,17 +153,17 @@ func (sm *SendMessageService) SendPreCheck() (models.TaskIns, error) { task, err := sendTaskService.GetTaskWithIns() if err != nil { errStr = fmt.Sprintf("任务[%s]查询失败!", sm.TaskID) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } if task.ID == "" { errStr = fmt.Sprintf("任务[%s]不存在!", sm.TaskID) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } if len(task.InsData) == 0 { errStr = fmt.Sprintf("任务[%s]没有关联任何实例!!", sm.TaskID) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } // 设置任务名称用于日志记录 @@ -175,7 +175,7 @@ func (sm *SendMessageService) SendPreCheck() (models.TaskIns, error) { default: // SendMode 未设置或无效 errStr = fmt.Sprintf("SendMode 未设置或无效: %s,必须是 '%s' 或 '%s'", sm.SendMode, SendModeTask, SendModeTemplate) - entry.Errorf(errStr) + entry.Error(errStr) return task, errors.New(errStr) } } diff --git a/service/settings_service/init_site.go b/service/settings_service/init_site.go index 85d7947..4b437a7 100644 --- a/service/settings_service/init_site.go +++ b/service/settings_service/init_site.go @@ -19,7 +19,7 @@ func (es *InitSettingService) CommonAddSetting(section string, key string, value Value: value, }) if err != nil { - logrus.Error("初始化%s:%s失败", section, key) + logrus.Errorf("初始化%s:%s失败", section, key) } else { logrus.Infof("初始化%s:%s成功", section, key) }