|
|
|
@@ -663,10 +663,8 @@ func refreshUserStaticTable(wikiCountMap map[string]int, tableName string, pageS |
|
|
|
log.Info("truncate all data from table: " + tableName) |
|
|
|
statictisSess.Exec("TRUNCATE TABLE " + tableName) |
|
|
|
|
|
|
|
StartTimeNextDay := pageStartTime.AddDate(0, 0, 1) |
|
|
|
EndTimeNextDay := pageEndTime.AddDate(0, 0, 1) |
|
|
|
log.Info("pageStartTime:" + pageStartTime.Format("2006-01-02 15:04:05") + " nextDay:" + StartTimeNextDay.Format("2006-01-02 15:04:05")) |
|
|
|
log.Info("pageEndTime time:" + pageEndTime.Format("2006-01-02 15:04:05") + " nextDay:" + EndTimeNextDay.Format("2006-01-02 15:04:05")) |
|
|
|
log.Info("pageStartTime:" + pageStartTime.Format("2006-01-02 15:04:05")) |
|
|
|
log.Info("pageEndTime time:" + pageEndTime.Format("2006-01-02 15:04:05")) |
|
|
|
|
|
|
|
start_unix := pageStartTime.Unix() |
|
|
|
end_unix := pageEndTime.Unix() |
|
|
|
@@ -682,7 +680,7 @@ func refreshUserStaticTable(wikiCountMap map[string]int, tableName string, pageS |
|
|
|
FocusRepoCountMap := queryWatch(start_unix, end_unix) |
|
|
|
StarRepoCountMap := queryStar(start_unix, end_unix) |
|
|
|
WatchedCountMap, WatchOtherMap := queryFollow(start_unix, end_unix) |
|
|
|
CommitCodeSizeMap, err := GetAllUserKPIStats(StartTimeNextDay, EndTimeNextDay) |
|
|
|
CommitCodeSizeMap, err := GetAllUserKPIStats(pageStartTime, pageEndTime) |
|
|
|
if err != nil { |
|
|
|
log.Info("query commit code errr.") |
|
|
|
} else { |
|
|
|
|