修改文案

@@ -266,8 +266,13 @@ func (srv *MessagePersonalService) TodayMessageTaskStageAnomaly(param *command.G
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 		}
 		}
 	}
 	}
+	uidStr := strconv.Itoa(param.UserId)
 	//我作为任务相关人
 	//我作为任务相关人
 	for _, val := range taskStageList0 {
 	for _, val := range taskStageList0 {
+
+		if val.LeaderId == uidStr {
+			continue
+		}
 		s := fmt.Sprintf("【您关注的【%s】里程碑未按时完成，请知晓。】", val.TaskAlias)
 		s := fmt.Sprintf("【您关注的【%s】里程碑未按时完成，请知晓。】", val.TaskAlias)
 		msgList = append(msgList, adapter.MessageListAdapter{
 		msgList = append(msgList, adapter.MessageListAdapter{
 			Content: s,
 			Content: s,
@@ -277,6 +282,7 @@ func (srv *MessagePersonalService) TodayMessageTaskStageAnomaly(param *command.G
 			"task_alias": val.TaskAlias,
 			"task_alias": val.TaskAlias,
 			"task_name":  val.TaskName,
 			"task_name":  val.TaskName,
 		}
 		}
+
 		payloadStr, _ := json.Marshal(payload)
 		payloadStr, _ := json.Marshal(payload)
 		newMessage := domain.MessagePersonal{
 		newMessage := domain.MessagePersonal{
 			Id:           0,
 			Id:           0,

@@ -403,6 +403,7 @@ type TaskData3 struct {
 	TaskName   string `pg:"task_name"`
 	TaskName   string `pg:"task_name"`
 	TaskAlias  string `pg:"task_alias"`
 	TaskAlias  string `pg:"task_alias"`
 	LeaderName string `pg:"leader_name"`
 	LeaderName string `pg:"leader_name"`
+	LeaderId   string `pg:"leader_id"`
 }
 }
 
 
 // 根据负责人获取超期未完成的异常的里程碑任务
 // 根据负责人获取超期未完成的异常的里程碑任务
@@ -410,6 +411,7 @@ func (d *TaskDao) TaskStageAnomalyByLeader(leaderId []string) ([]TaskData3, erro
 	sqlStr := `select distinct 
 	sqlStr := `select distinct 
 		task.id as task_id,
 		task.id as task_id,
 		task.leader ->>'name' as leader_name,
 		task.leader ->>'name' as leader_name,
+		task.leader ->>'id' as leader_id,
 		task.alias as task_alias,
 		task.alias as task_alias,
 		task.name as task_name
 		task.name as task_name
 	from task
 	from task
@@ -428,6 +430,7 @@ func (d *TaskDao) TaskStageAnomalyByRelatedUser(relatedUserId int) ([]TaskData3,
 	sqlStr := `select distinct 
 	sqlStr := `select distinct 
 	task.id as task_id,
 	task.id as task_id,
 	task.leader ->>'name' as leader_name,
 	task.leader ->>'name' as leader_name,
+	task.leader ->>'id' as leader_id,
 	task.alias as task_alias,
 	task.alias as task_alias,
 	task.name as task_name
 	task.name as task_name
 	from task
 	from task