diff --git a/api/proto/zone/proto/zone_vo_op.go b/api/proto/zone/proto/zone_vo_op.go index cb29e849..97f2c6c6 100644 --- a/api/proto/zone/proto/zone_vo_op.go +++ b/api/proto/zone/proto/zone_vo_op.go @@ -19,6 +19,9 @@ type OpZoneVO struct { StreamerExt *streamerproto.OpListExtVO `json:"streamer_ext"` // 主播信息 ZoneThirdPartner *zone_third_partner_proto.ZoneThirdPartnerApiVO `json:"zone_third_partner"` // 代运营 ZoneCollaboratorList []*zone_collaborator_proto.ZoneCollaboratorApiVO `json:"zone_collaborator_list"` // 协作者 + EntrantNum int64 `json:"entrant_num"` // 空间总人数 + IronfanNum int64 `json:"ironfan_num"` // 铁粉总人数 + SuperfanNum int64 `json:"superfan_num"` // 超粉总人数 } func (vo *OpZoneVO) GetMid() int64 { diff --git a/app/mix/service/xxljob_tasks.go b/app/mix/service/xxljob_tasks.go index c2571164..f5d5c017 100644 --- a/app/mix/service/xxljob_tasks.go +++ b/app/mix/service/xxljob_tasks.go @@ -93,14 +93,14 @@ func (s *CronService) CreateDailyStatement(ctx context.Context, param *xxl.RunRe count, err := DefaultScriptsService.QueryCallCount(consts.H5CallUrl, logpath) if err != nil { logger.Error("query h5 call count fail : %v", err) - return fmt.Sprintf("query h5 call count fail : %v", err) + //return fmt.Sprintf("query h5 call count fail : %v", err) } //获取站外user_id访问zone访问量 zoneListFromOusideCount, err := DefaultScriptsService.QueryCallCount(consts.ZoneListFromOutsideCountCallUrl, logpath) if err != nil { logger.Error("query list_by_user_id_from_outside call count fail : %v", err) - return fmt.Sprintf("query list_by_user_id_from_outside call count fail : %v", err) + //return fmt.Sprintf("query list_by_user_id_from_outside call count fail : %v", err) } //获取用户总量 @@ -109,7 +109,7 @@ func (s *CronService) CreateDailyStatement(ctx context.Context, param *xxl.RunRe }) if err != nil { logger.Error("_DefaultAccount OpCount fail : %v", err) - return fmt.Sprintf("_DefaultAccount OpCount fail : %v", err) + //return fmt.Sprintf("_DefaultAccount OpCount fail : %v", err) } //获取订单总量 @@ -119,7 +119,7 @@ func (s *CronService) CreateDailyStatement(ctx context.Context, param *xxl.RunRe }) if err != nil { logger.Error("_DefaultVas GetOrderCountByStatus fail : %v", err) - return fmt.Sprintf("_DefaultVas GetOrderCountByStatus fail : %v", err) + //return fmt.Sprintf("_DefaultVas GetOrderCountByStatus fail : %v", err) } //获取用户注册来源 @@ -129,7 +129,7 @@ func (s *CronService) CreateDailyStatement(ctx context.Context, param *xxl.RunRe }) if err != nil { logger.Error("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err) - return fmt.Sprintf("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err) + //return fmt.Sprintf("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err) } //获取订单完成量