update 完善假数据:用户id与数据的绑定关系

game/game_cluster/nodes/logstash/fakedata/main.go

@@ -19,6 +19,13 @@ import (
 //                                    currency, reason, before_balance, amount, after_balance, server_id)
 // values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
 
+type NameData struct {
+	User_id   string
+	User_name string
+	Tg_id     string
+	X_id      string
+}
+
 func main() {
 	dsn := "clickhouse://default:123456@192.168.0.193:9000/default?dial_timeout=10s&read_timeout=20s"
 
@@ -41,20 +48,29 @@ func main() {
 	datas := make([]*eventmodels.AssetsEventContent, 0, 8)
 	count := 100
 
-	names := make([]string, 0, 8)
+	nameDatas := make([]*NameData, 0, 8)
 	for i := 0; i < 10; i++ {
+		user_id := faker.Name()
 		name := faker.Name()
-		names = append(names, name)
+		tg_id := faker.Name()
+		x_id := faker.Name()
+		nameObj := &NameData{
+			User_id:   user_id,
+			User_name: name,
+			Tg_id:     tg_id,
+			X_id:      x_id,
+		}
+		nameDatas = append(nameDatas, nameObj)
 	}
 
 	server_id := "m-web-admin-1"
 	for i := 0; i < count; i++ {
-		index := rand.Intn(len(names))
-		user_id := names[index]
-		user_name := names[index]
-		tg_id := faker.Name()
-		x_id := faker.Name()
-		parent_user_id := names[index]
+		index := rand.Intn(len(nameDatas))
+		user_id := nameDatas[index].User_id
+		user_name := nameDatas[index].User_name
+		tg_id := nameDatas[index].Tg_id
+		x_id := nameDatas[index].X_id
+		parent_user_id := nameDatas[index].User_name
 		is_robot := false
 		points_rank_seq := faker.RandomUnixTime()
 		throw_dice_rank_seq := faker.RandomUnixTime()
@@ -130,7 +146,7 @@ func main() {
 
 	// sqlStr := `select SUM(amount) as total_amount from assets_event_contents where user_id = ? and currency = ?`
 	var total_amount int64
-	for _, name := range names {
+	for _, nameObj := range nameDatas {
 		// err := db.Raw(sqlStr, name, "USDT").Pluck("SUM(amount) as total_amount", &total_amount).Error
 		// if err != nil {
 		// 	fmt.Printf("Pluck error:%v", err)
@@ -139,7 +155,7 @@ func main() {
 
 		where := &eventmodels.AssetsEventContent{
 			UserBasic: eventmodels.UserBasic{
-				UserId: name,
+				UserId: nameObj.User_id,
 				// UserId: "1", // 不存在的用户
 			},
 			EventBasic: eventmodels.EventBasic{
@@ -153,6 +169,6 @@ func main() {
 			return
 		}
 
-		fmt.Printf("name:%s total_amount:%v", name, total_amount)
+		fmt.Printf("User_id:%s total_amount:%v", nameObj.User_id, total_amount)
 	}
 }