更新

@@ -198,7 +198,10 @@ func (srv *MessagePersonalService) TodayMessageTaskStageAnomaly(param *command.G
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 	for _, val := range taskStageList2 {
 		s := fmt.Sprintf("您下级%s负责的项目【%s】里程碑未按时完成，请前往辅导。", val.LeaderName, val.Name)
@@ -220,7 +223,10 @@ func (srv *MessagePersonalService) TodayMessageTaskStageAnomaly(param *command.G
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 	for _, val := range taskStageList3 {
 		s := fmt.Sprintf("【您下级%s关注的项目【%s】里程碑未按时完成，请前往辅导。】", val.LeaderName, val.Name)
@@ -242,7 +248,10 @@ func (srv *MessagePersonalService) TodayMessageTaskStageAnomaly(param *command.G
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 
 	if err := transactionContext.CommitTransaction(); err != nil {
@@ -354,7 +363,10 @@ func (srv *MessagePersonalService) TodayMessageTaskRecordAnomaly(param *command.
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 	for _, val := range taskStageList2 {
 		s := fmt.Sprintf("【您下级%s负责的项目【%s】已超过N日未反馈进度，请前往辅导。】", val.LeaderName, val.Name)
@@ -376,7 +388,10 @@ func (srv *MessagePersonalService) TodayMessageTaskRecordAnomaly(param *command.
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 	for _, val := range taskStageList3 {
 		s := fmt.Sprintf("【您下级%s关注的项目【%s】已超过N日未反馈进度，请前往辅导。】", val.LeaderName, val.Name)
@@ -398,7 +413,10 @@ func (srv *MessagePersonalService) TodayMessageTaskRecordAnomaly(param *command.
 			UpdatedAt:    time.Time{},
 			Payload:      string(payloadStr),
 		}
-		messageRepo.Save(&newMessage)
+		err = messageRepo.Save(&newMessage)
+		if err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		}
 	}
 	if err := transactionContext.CommitTransaction(); err != nil {
 		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())