|
@@ -885,7 +885,11 @@ func CounDataByDateAndReCount(wikiCountMap map[string]int, startTime time.Time, |
|
|
log.Info("query user error. return.") |
|
|
log.Info("query user error. return.") |
|
|
} |
|
|
} |
|
|
useMetrics.TotalUser = int(count) |
|
|
useMetrics.TotalUser = int(count) |
|
|
useMetrics.ActivateIIndex = float64(useMetrics.ActivateRegistUser) / float64(useMetrics.ActivateRegistUser+useMetrics.NotActivateRegistUser) |
|
|
|
|
|
|
|
|
if useMetrics.ActivateRegistUser+useMetrics.NotActivateRegistUser == 0 { |
|
|
|
|
|
useMetrics.ActivateIndex = 0 |
|
|
|
|
|
} else { |
|
|
|
|
|
useMetrics.ActivateIndex = float64(useMetrics.ActivateRegistUser) / float64(useMetrics.ActivateRegistUser+useMetrics.NotActivateRegistUser) |
|
|
|
|
|
} |
|
|
statictisSess.Insert(&useMetrics) |
|
|
statictisSess.Insert(&useMetrics) |
|
|
//update new user activity |
|
|
//update new user activity |
|
|
updateNewUserAcitivity(userNewAddActivity, statictisSess) |
|
|
updateNewUserAcitivity(userNewAddActivity, statictisSess) |
|
@@ -893,7 +897,9 @@ func CounDataByDateAndReCount(wikiCountMap map[string]int, startTime time.Time, |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, statictisSess *xorm.Session) { |
|
|
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 { |
|
|
for key, value := range currentUserActivity { |
|
|
|
|
|
log.Info("key=" + fmt.Sprint(key) + " ") |
|
|
useMetrics := &UserMetrics{CountDate: key} |
|
|
useMetrics := &UserMetrics{CountDate: key} |
|
|
has, err := statictisSess.Get(useMetrics) |
|
|
has, err := statictisSess.Get(useMetrics) |
|
|
if err == nil && has { |
|
|
if err == nil && has { |
|
|