|
@@ -896,7 +896,7 @@ func CounDataByDateAndReCount(wikiCountMap map[string]int, startTime time.Time, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
RefreshUserStaticAllTabel(wikiCountMap, userMetrics) |
|
|
RefreshUserStaticAllTabel(wikiCountMap, userMetrics) |
|
|
|
|
|
|
|
|
|
|
|
log.Info("start to update UserMetrics") |
|
|
//insert userMetrics table |
|
|
//insert userMetrics table |
|
|
var useMetrics UserMetrics |
|
|
var useMetrics UserMetrics |
|
|
useMetrics.CountDate = CountDate.Unix() |
|
|
useMetrics.CountDate = CountDate.Unix() |
|
@@ -946,7 +946,7 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati |
|
|
if len(userIdArray) > 0 { |
|
|
if len(userIdArray) > 0 { |
|
|
useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1] |
|
|
useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1] |
|
|
} |
|
|
} |
|
|
updateSql := "update public.user_metrics set has_activity_user_json=" + useMetrics.HasActivityUserJson + ",regist_activity_user=" + fmt.Sprint(useMetrics.HasActivityUser) + " where count_date=" + fmt.Sprint(key) |
|
|
|
|
|
|
|
|
updateSql := "update public.user_metrics set has_activity_user_json='" + useMetrics.HasActivityUserJson + "',regist_activity_user=" + fmt.Sprint(useMetrics.HasActivityUser) + " where count_date=" + fmt.Sprint(key) |
|
|
statictisSess.Exec(updateSql) |
|
|
statictisSess.Exec(updateSql) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|