Browse Source

增加代码。

Signed-off-by: zouap <zouap@pcl.ac.cn>
pull/2480/head
zouap 3 years ago
parent
commit
6eb83a3da7
1 changed files with 5 additions and 3 deletions
  1. +5
    -3
      models/user_business_analysis.go

+ 5
- 3
models/user_business_analysis.go View File

@@ -901,8 +901,9 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati
for key, value := range currentUserActivity { for key, value := range currentUserActivity {
log.Info("key=" + fmt.Sprint(key) + " ") log.Info("key=" + fmt.Sprint(key) + " ")
useMetrics := &UserMetrics{CountDate: key} useMetrics := &UserMetrics{CountDate: key}
has, err := statictisSess.Get(useMetrics)
if err == nil && has {
_, err := statictisSess.Get(useMetrics)
log.Info("json=" + useMetrics.HasActivityUserJson + " totalUser=" + fmt.Sprint(useMetrics.TotalUser) + " len(value)=" + fmt.Sprint(len(value)))
if err == nil {
userIdArrays := strings.Split(useMetrics.HasActivityUserJson, ",") userIdArrays := strings.Split(useMetrics.HasActivityUserJson, ",")
for _, userIdStr := range userIdArrays { for _, userIdStr := range userIdArrays {
userIdInt, err := strconv.ParseInt(userIdStr, 10, 64) userIdInt, err := strconv.ParseInt(userIdStr, 10, 64)
@@ -914,10 +915,11 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati
for _, tmpValue := range value { for _, tmpValue := range value {
userIdArray += fmt.Sprint(tmpValue) + "," userIdArray += fmt.Sprint(tmpValue) + ","
} }

useMetrics.HasActivityUser = len(value) useMetrics.HasActivityUser = len(value)
if len(userIdArray) > 0 { if len(userIdArray) > 0 {
useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1] useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1]
log.Info("useMetrics.HasActivityUserJson=" + useMetrics.HasActivityUserJson)
} }
statictisSess.Update(useMetrics) statictisSess.Update(useMetrics)
} }


Loading…
Cancel
Save