| @@ -719,7 +719,7 @@ func TimingCountDataByDateAndReCount(date string, isReCount bool) { | |||||
| endTime = endTime.UTC() | endTime = endTime.UTC() | ||||
| log.Info("startTime time:" + startTime.Format("2006-01-02 15:04:05")) | log.Info("startTime time:" + startTime.Format("2006-01-02 15:04:05")) | ||||
| log.Info("endTime time:" + endTime.Format("2006-01-02 15:04:05")) | log.Info("endTime time:" + endTime.Format("2006-01-02 15:04:05")) | ||||
| //warnEmailMessage := "用户统计信息入库失败,请尽快定位。" | |||||
| warnEmailMessage := "用户统计信息入库失败,请尽快定位。" | |||||
| startYear := time.Date(USER_YEAR, 1, 1, 0, 0, 0, 1, t.Location()) | startYear := time.Date(USER_YEAR, 1, 1, 0, 0, 0, 1, t.Location()) | ||||
| endYear := startYear.AddDate(1, 0, 0) | endYear := startYear.AddDate(1, 0, 0) | ||||
| @@ -727,14 +727,14 @@ func TimingCountDataByDateAndReCount(date string, isReCount bool) { | |||||
| models.RefreshUserYearTable(startYear, endYear) | models.RefreshUserYearTable(startYear, endYear) | ||||
| //query wiki data | //query wiki data | ||||
| // log.Info("start to time count data") | |||||
| // wikiMap, err := queryWikiCountMap(startTime, endTime) | |||||
| // //other user info data | |||||
| // err = models.CounDataByDateAndReCount(wikiMap, startTime, endTime, isReCount) | |||||
| // if err != nil { | |||||
| // log.Error("count user info error." + err.Error()) | |||||
| // mailer.SendWarnNotifyMail(setting.Warn_Notify_Mails, warnEmailMessage) | |||||
| // } | |||||
| log.Info("start to time count data") | |||||
| wikiMap, err := queryWikiCountMap(startTime, endTime) | |||||
| //other user info data | |||||
| err = models.CounDataByDateAndReCount(wikiMap, startTime, endTime, isReCount) | |||||
| if err != nil { | |||||
| log.Error("count user info error." + err.Error()) | |||||
| mailer.SendWarnNotifyMail(setting.Warn_Notify_Mails, warnEmailMessage) | |||||
| } | |||||
| log.Info("end to count all user info data") | log.Info("end to count all user info data") | ||||
| } | } | ||||