1

dbstruct/streamer_acct.go

@@ -8,6 +8,7 @@ type EsStreamerAcct struct {
 	Age                          int64  `json:"age"`                               // 年龄
 	Height                       int64  `json:"height"`                            // 身高
 	Weight                       int64  `json:"weight"`                            // 体重
+	Fans                         int64  `json:"fans"`                              // 粉丝量
 	City                         string `json:"city"`                              // 所在城市
 	Constellation                string `json:"constellation"`                     // 星座
 	LastZoneMomentCreateDayStart int64  `json:"last_zone_moment_create_day_start"` // 最后空间动态创建日始整点

importfunc/streamer_into_es.go

@@ -108,6 +108,7 @@ func ImportStreamerIntoEs() {
 			Age:                          util.DerefInt64(streamer.Age),
 			Height:                       util.DerefInt64(streamer.Height),
 			Weight:                       util.DerefInt64(streamer.Weight),
+			Fans:                         util.DerefInt64(streamer.Fans),
 			City:                         util.DerefString(streamer.City),
 			Constellation:                util.DerefString(streamer.Constellation),
 			LastZoneMomentCreateDayStart: lastZoneMomentCreateDay,