update 增加任务假数据

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

@@ -132,6 +132,13 @@ func main() {
 		fmt.Printf("CreateInBatches withdrawDatas error:%v", err)
 		return
 	}
+
+	taskDatas := getTaskFakeData(users)
+	err = db.CreateInBatches(taskDatas, len(taskDatas)).Error
+	if err != nil {
+		fmt.Printf("CreateInBatches taskDatas error:%v", err)
+		return
+	}
 }
 
 func connectDb() *gorm.DB {

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

@@ -0,0 +1,26 @@
+package main
+
+import (
+	"github.com/bxcodec/faker/v3"
+	"github.com/mhaya/game/game_cluster/internal/mdb/eventmodels"
+)
+
+func getTaskFakeData(users []*eventmodels.UserBasic) []*eventmodels.TaskFinishEventContent {
+	datas := make([]*eventmodels.TaskFinishEventContent, 0, 8)
+
+	for i := 0; i < count; i++ {
+		userBasic := getUserBasic(users)
+		eventBasic := getEventBasic()
+
+		datas = append(datas, &eventmodels.TaskFinishEventContent{
+			UserBasic:     *userBasic,
+			EventBasic:    *eventBasic,
+			TaskId:        faker.TimeString(),
+			TaskCondition: faker.AmountWithCurrency(),
+			TaskType:      faker.Name(),
+			TaskName:      faker.Name(),
+		})
+	}
+
+	return datas
+}