增加代码。

Signed-off-by: zouap <zouap@pcl.ac.cn>

models/user_business_analysis.go

@@ -901,9 +901,9 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati
 	for key, value := range currentUserActivity {
 		log.Info("key=" + fmt.Sprint(key) + " ")
 		useMetrics := &UserMetrics{CountDate: key}
-		_, err := statictisSess.Get(useMetrics)
+		has, err := statictisSess.Get(useMetrics)
 		log.Info("json=" + useMetrics.HasActivityUserJson + " totalUser=" + fmt.Sprint(useMetrics.TotalUser) + " len(value)=" + fmt.Sprint(len(value)))
-		if err == nil {
+		if err == nil && has {
 			userIdArrays := strings.Split(useMetrics.HasActivityUserJson, ",")
 			for _, userIdStr := range userIdArrays {
 				userIdInt, err := strconv.ParseInt(userIdStr, 10, 64)
@@ -921,7 +921,9 @@ func updateNewUserAcitivity(currentUserActivity map[int64]map[int64]int64, stati
 				useMetrics.HasActivityUserJson = userIdArray[0 : len(userIdArray)-1]
 				log.Info("useMetrics.HasActivityUserJson=" + useMetrics.HasActivityUserJson)
 			}
-			statictisSess.Update(useMetrics)
+			updateSql := "update public.user_metrics set has_activity_user_json=" + useMetrics.HasActivityUserJson + " where count_date=" + fmt.Sprint(key)
+			statictisSess.Exec(updateSql)
+			//statictisSess.Update(useMetrics)
 		}
 	}
 }