|
|
|
@@ -897,12 +897,9 @@ func CounDataByDateAndReCount(wikiCountMap map[string]int, startTime time.Time, |
|
|
|
} |
|
|
|
|
|
|
|
func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, statictisSess *xorm.Session) { |
|
|
|
log.Info("go here len=" + fmt.Sprint(len(currentUserActivity))) |
|
|
|
for key, value := range currentUserActivity { |
|
|
|
log.Info("key=" + fmt.Sprint(key) + " ") |
|
|
|
useMetrics := &UserMetrics{CountDate: key} |
|
|
|
has, err := statictisSess.Get(useMetrics) |
|
|
|
log.Info("json=" + useMetrics.HasActivityUserJson + " totalUser=" + fmt.Sprint(useMetrics.TotalUser) + " len(value)=" + fmt.Sprint(len(value))) |
|
|
|
if err == nil && has { |
|
|
|
userIdArrays := strings.Split(useMetrics.HasActivityUserJson, ",") |
|
|
|
for _, userIdStr := range userIdArrays { |
|
|
|
@@ -915,15 +912,12 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati |
|
|
|
for _, tmpValue := range value { |
|
|
|
userIdArray += fmt.Sprint(tmpValue) + "," |
|
|
|
} |
|
|
|
|
|
|
|
useMetrics.HasActivityUser = len(value) |
|
|
|
if len(userIdArray) > 0 { |
|
|
|
useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1] |
|
|
|
log.Info("useMetrics.HasActivityUserJson=" + useMetrics.HasActivityUserJson) |
|
|
|
} |
|
|
|
updateSql := "update public.user_metrics set has_activity_user_json=" + useMetrics.HasActivityUserJson + " where count_date=" + fmt.Sprint(key) |
|
|
|
updateSql := "update public.user_metrics set has_activity_user_json=" + useMetrics.HasActivityUserJson + ",has_activity_user=" + fmt.Sprint(useMetrics.HasActivityUser) + " where count_date=" + fmt.Sprint(key) |
|
|
|
statictisSess.Exec(updateSql) |
|
|
|
//statictisSess.Update(useMetrics) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|