wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20240515

This commit is contained in:
Leufolium 2024-05-15 16:07:33 +08:00
parent 0e6368fc0c
commit 5016e7b7be
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
api/proto/zone/proto/zone_vo_op.go
View File

@ -19,6 +19,9 @@ type OpZoneVO struct {
StreamerExt *streamerproto.OpListExtVO `json:"streamer_ext"` // 主播信息 StreamerExt *streamerproto.OpListExtVO `json:"streamer_ext"` // 主播信息
ZoneThirdPartner *zone_third_partner_proto.ZoneThirdPartnerApiVO `json:"zone_third_partner"` // 代运营 ZoneThirdPartner *zone_third_partner_proto.ZoneThirdPartnerApiVO `json:"zone_third_partner"` // 代运营
ZoneCollaboratorList []*zone_collaborator_proto.ZoneCollaboratorApiVO `json:"zone_collaborator_list"` // 协作者 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 { func (vo *OpZoneVO) GetMid() int64 {

10
app/mix/service/xxljob_tasks.go
View File

@ -93,14 +93,14 @@ func (s *CronService) CreateDailyStatement(ctx context.Context, param *xxl.RunRe
count, err := DefaultScriptsService.QueryCallCount(consts.H5CallUrl, logpath) count, err := DefaultScriptsService.QueryCallCount(consts.H5CallUrl, logpath)
if err != nil { if err != nil {
logger.Error("query h5 call count fail : %v", err) 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访问量 //获取站外user_id访问zone访问量
zoneListFromOusideCount, err := DefaultScriptsService.QueryCallCount(consts.ZoneListFromOutsideCountCallUrl, logpath) zoneListFromOusideCount, err := DefaultScriptsService.QueryCallCount(consts.ZoneListFromOutsideCountCallUrl, logpath)
if err != nil { if err != nil {
logger.Error("query list_by_user_id_from_outside call count fail : %v", err) 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 { if err != nil {
logger.Error("_DefaultAccount OpCount fail : %v", err) 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 { if err != nil {
logger.Error("_DefaultVas GetOrderCountByStatus fail : %v", err) 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 { if err != nil {
logger.Error("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err) logger.Error("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err)
return fmt.Sprintf("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err) //return fmt.Sprintf("_DefaultAccount OpCountLastHourNewUserSource fail : %v", err)
} }
//获取订单完成量 //获取订单完成量