更新

@@ -332,9 +332,7 @@ func (srv *MessagePersonalService) TodayMessageTaskRecordAnomaly(param *command.
 			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())
-	}
+
 	msgList := []adapter.MessageListAdapter{}
 	for _, val := range taskStageList {
 		s := fmt.Sprintf("【您负责的项目【%s】已超过N日未反馈进度，请前往该战略任务进行反馈。】", val.Name)

@@ -444,7 +444,7 @@ func (d *TaskDao) TaskAnomaly(leaderId []string, anomaly int) ([]TaskStageData,
 	task.leader ->>'name' as leader_name,
 	task.anomaly 
 	from task 
-	where task.anomaly >=? and task.leader ->'id'='?' `
+	where task.anomaly >=? and task.leader ->'id' in(?) `
 	result := []TaskStageData{}
 	tx := d.transactionContext.PgTx
 	_, err := tx.Query(&result, sqlStr, anomaly, pg.In(leaderId))