fix-1309

routers/repo/repo_statistic.go

@@ -51,12 +51,14 @@ func RepoStatisticDaily(date string) {
 
 	isInitMinMaxRadar := false
 
+	var error_projects = make([]string, 0)
 	for _, repo := range repos {
-		log.Info("start statistic: %s", getDistinctProjectName(repo))
+		projectName := getDistinctProjectName(repo)
+		log.Info("start statistic: %s", projectName)
 		var numDevMonths, numWikiViews, numContributor, numKeyContributor, numCommitsGrowth, numCommitLinesGrowth, numContributorsGrowth, numCommits int64
 		repoGitStat, err := models.GetRepoKPIStats(repo)
 		if err != nil {
-			log.Error("GetRepoKPIStats failed: %s", getDistinctProjectName(repo))
+			log.Error("GetRepoKPIStats failed: %s", projectName)
 		} else {
 			numDevMonths = repoGitStat.DevelopAge
 			numKeyContributor = repoGitStat.KeyContributors
@@ -79,26 +81,26 @@ func RepoStatisticDaily(date string) {
 		var numVersions int64
 		numVersions, err = models.GetReleaseCountByRepoID(repo.ID, models.FindReleasesOptions{})
 		if err != nil {
-			log.Error("GetReleaseCountByRepoID failed(%s): %v", getDistinctProjectName(repo), err)
+			log.Error("GetReleaseCountByRepoID failed(%s): %v", projectName, err)
 		}
 
 		var datasetSize int64
 		datasetSize, err = getDatasetSize(repo)
 		if err != nil {
-			log.Error("getDatasetSize failed(%s): %v", getDistinctProjectName(repo), err)
+			log.Error("getDatasetSize failed(%s): %v", projectName, err)
 		}
 
 		var numComments int64
 		numComments, err = models.GetCommentCountByRepoID(repo.ID)
 		if err != nil {
-			log.Error("GetCommentCountByRepoID failed(%s): %v", getDistinctProjectName(repo), err)
+			log.Error("GetCommentCountByRepoID failed(%s): %v", projectName, err)
 		}
 
 		beginTime, endTime := getStatTime(date)
 		var numVisits int
 		numVisits, err = repository.AppointProjectView(repo.OwnerName, repo.Name, beginTime, endTime)
 		if err != nil {
-			log.Error("AppointProjectView failed(%s): %v", getDistinctProjectName(repo), err)
+			log.Error("AppointProjectView failed(%s): %v", projectName, err)
 		}
 
 		repoStat := models.RepoStatistic{
@@ -162,9 +164,10 @@ func RepoStatisticDaily(date string) {
 		}
 
 		if _, err = models.InsertRepoStat(&repoStat); err != nil {
-			log.Error("InsertRepoStat failed(%s): %v", getDistinctProjectName(repo), err)
-			log.Error("failed statistic: %s", getDistinctProjectName(repo))
-			mailer.SendWarnNotifyMail(setting.Warn_Notify_Mails, warnEmailMessage)
+			log.Error("InsertRepoStat failed(%s): %v", projectName, err)
+			log.Error("failed statistic: %s", projectName)
+			error_projects = append(error_projects, projectName)
+
 			continue
 		}
 
@@ -247,6 +250,10 @@ func RepoStatisticDaily(date string) {
 		log.Info("finish statistic: %s", getDistinctProjectName(repo))
 	}
 
+	if len(error_projects) > 0 {
+		mailer.SendWarnNotifyMail(setting.Warn_Notify_Mails, warnEmailMessage)
+	}
+
 	//radar  map
 	log.Info("begin statistic radar")
 	for _, radarInit := range reposRadar {