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

by Robin at 20240416

This commit is contained in:
Leufolium 2024-04-16 07:41:52 +08:00
parent 0ef8e776a8
commit da6d60020c
20 changed files with 383 additions and 212 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/errcode/errcode.go
View File

@ -172,6 +172,7 @@ var ErrCodeMsgMap = map[ErrCode]string{
ErrCodeZoneSrvFail: "空间服务错误",
ErrCodeZoneNotExist: "空间不存在",
ErrCodeUnlockedZone: "访客未解锁该空间",
ErrCodeZoneMomentSrvFail: "私密圈动态服务错误",
ErrCodeZoneMomentNotExist: "私密圈动态不存在",
@ -437,6 +438,7 @@ const (
ErrCodeZoneSrvOk ErrCode = ErrCodeOk
ErrCodeZoneSrvFail ErrCode = -33001 // 空间服务错误
ErrCodeZoneNotExist ErrCode = -33002 // 空间不存在
ErrCodeUnlockedZone ErrCode = -33003 // 未解锁的空间
// ZoneMoment: 34xxx
ErrCodeZoneMomentSrvOk ErrCode = ErrCodeOk

10
api/proto/zone/proto/zone_vo_api.go
View File

@ -13,6 +13,8 @@ type ApiZoneVO struct {
VisitorRole int64 `json:"visitor_role"`
Previews *dbstruct.MediaComponent `json:"previews"`
Expenditure int64 `json:"expenditure"`
IsIronfanshipUnlocked int64 `json:"is_ironfanship_unlocked"`
IsSuperfanshipUnlocked int64 `json:"is_superfanship_unlocked"`
}
func (vo *ApiZoneVO) GetMid() int64 {
@ -35,3 +37,11 @@ func (vo *ApiZoneVO) CopyStreamerExt(streamerExt streamerproto.StreamerExtVO) {
}
}
}
func (vo *ApiZoneVO) SetIsIronfanshipUnlocked(is_ironfanship_unlocked int64) {
vo.IsIronfanshipUnlocked = is_ironfanship_unlocked
}
func (vo *ApiZoneVO) SetIsSuperfanshipUnlocked(is_superfanship_unlocked int64) {
vo.IsSuperfanshipUnlocked = is_superfanship_unlocked
}

0
api/proto/zonemoment/proto/moment_vo_api.go → api/proto/zonemoment/proto/zonemoment_vo_api.go
View File

13
api/proto/zonesession/proto/not_null_def_api.go Normal file
View File

@ -0,0 +1,13 @@
package proto
import (
"service/library/validator"
)
func (p *ApiUpsertReq) ProvideNotNullValue() (params []*validator.JsonParam) {
params = make([]*validator.JsonParam, 0)
params = append(params, validator.NewInt64PtrParam("请确认创建动态的所属空间id！", p.Zid))
return
}

10
api/proto/zonesession/proto/zonesession_api.go
View File

@ -5,15 +5,15 @@ import (
)
// op 更新
type ApiUpdateReq struct {
type ApiUpsertReq struct {
base.BaseRequest
Zid int64 `json:"zid"`
Zid *int64 `json:"zid"`
}
type ApiUpdateData struct {
type ApiUpsertData struct {
}
type ApiUpdateResp struct {
type ApiUpsertResp struct {
base.BaseResponse
Data *ApiUpdateData `json:"data"`
Data *ApiUpsertData `json:"data"`
}

7
api/proto/zonesession/proto/zonesession_op.go
View File

@ -50,9 +50,10 @@ type OpUpdateResp struct {
// op 列表
type OpListReq struct {
base.BaseRequest
Mid int64 `json:"mid"`
Offset int `json:"offset"`
Limit int `json:"limit"`
Mid int64 `json:"mid"`
Zids []int64 `json:"zids"`
Offset int `json:"offset"`
Limit int `json:"limit"`
}
type OpListData struct {

2
app/mix/controller/init.go
View File

@ -238,7 +238,7 @@ func Init(r *gin.Engine) {
// 空间对话
apiZoneSessionGroup := r.Group("/api/zone_session", PrepareToC())
apiZoneSessionGroup.POST("update", middleware.JSONParamValidator(zonesessionproto.ApiUpdateReq{}), middleware.JwtAuthenticator(), ApiUpdateZoneSession)
apiZoneSessionGroup.POST("upsert", middleware.JSONParamValidator(zonesessionproto.ApiUpsertReq{}), middleware.JwtAuthenticator(), ApiUpsertZoneSession)
// 空间代运营表
apiZoneThirdPartnerGroup := r.Group("/api/zone_third_partner", PrepareToC())

8
app/mix/controller/zone_session_api.go
View File

@ -10,11 +10,11 @@ import (
"github.com/gin-gonic/gin"
)
func ApiUpdateZoneSession(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*zonesessionproto.ApiUpdateReq)
ec := service.DefaultService.ApiUpdateZoneSession(ctx, req)
func ApiUpsertZoneSession(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*zonesessionproto.ApiUpsertReq)
ec := service.DefaultService.ApiUpsertZoneSession(ctx, req)
if ec != errcode.ErrCodeZoneSessionSrvOk {
logger.Error("ApiUpdateZoneSession fail, req: %v, ec: %v", util.ToJson(req), ec)
logger.Error("ApiUpsertZoneSession fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}

5
app/mix/dao/mongo.go
View File

@ -4458,7 +4458,10 @@ func (m *Mongo) GetZoneSessionList(ctx *gin.Context, req *zonesessionproto.OpLis
list := make([]*dbstruct.ZoneSession, 0)
col := m.getColZoneSession()
query := qmgo.M{
"sub_mid": req.Mid,
"sub_mid": req.Mid,
"obj_zid": qmgo.M{
"$in": req.Zids,
},
"del_flag": 0,
}
err := col.Find(ctx, query).Sort("-ct").Skip(int64(req.Offset)).Limit(int64(req.Limit)).All(&list)

24
app/mix/dao/mysql_zone.go
View File

@ -3,12 +3,13 @@ package dao
import (
"database/sql"
"fmt"
"github.com/gin-gonic/gin"
"github.com/jmoiron/sqlx"
"service/bizcommon/util"
"service/dbstruct"
"service/library/logger"
"time"
"github.com/gin-gonic/gin"
"github.com/jmoiron/sqlx"
)
// 获取空间解锁信息
@ -27,6 +28,25 @@ func (m *Mysql) GetZoneUnlock(ctx *gin.Context, tx *sqlx.Tx, mid, zid int64) (zu
return
}
// 获取空间解锁信息 by mid
func (m *Mysql) GetZoneUnlockListByMid(ctx *gin.Context, tx *sqlx.Tx, mid int64) (list []*dbstruct.ZoneUnlock, err error) {
list = make([]*dbstruct.ZoneUnlock, 0)
if tx != nil {
err = tx.SelectContext(ctx, &list, fmt.Sprintf("select * from %s where mid=?", TableVasZoneUnlock), mid)
} else {
db := m.getDBVas()
err = db.SelectContext(ctx, &list, fmt.Sprintf("select * from %s where mid=?", TableVasZoneUnlock), mid)
}
if err == sql.ErrNoRows {
err = nil
return
}
if err != nil {
return
}
return
}
// 获取空间解锁信息 by zid
func (m *Mysql) GetZoneUnlockListByZid(ctx *gin.Context, tx *sqlx.Tx, zid int64) (list []*dbstruct.ZoneUnlock, err error) {
list = make([]*dbstruct.ZoneUnlock, 0)

245
app/mix/service/apiservice.go
View File

@ -2213,10 +2213,19 @@ func (s *Service) ApiGetZoneList(ctx *gin.Context, req *zoneproto.ApiListReq) (l
func (s *Service) ApiGetZoneListByMid(ctx *gin.Context, req *zoneproto.ApiListByMidReq) (volist []*zoneproto.ApiZoneVO, ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneSrvOk
// 若uid为空，则判断为主播查自己的空间
if req.Uid == nil {
req.Uid = goproto.Int64(req.BaseRequest.Mid)
}
// 查询该用户解锁的空间
zidZuMap, err := _DefaultVas.GetZoneUnlockMapByMid(ctx, req.BaseRequest.Mid)
if err != nil {
logger.Error("GetZoneUnlockMapByMid fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
return
}
list, err := _DefaultZone.OpListByMid(ctx, &zoneproto.OpListByMidReq{
BaseRequest: req.BaseRequest,
Uid: req.Uid,
@ -2230,7 +2239,7 @@ func (s *Service) ApiGetZoneListByMid(ctx *gin.Context, req *zoneproto.ApiListBy
}
// 填充必要信息
volist, err = s.utilFillZonesWithApiVOInfo(ctx, list, req.BaseRequest.Mid)
volist, err = s.utilFillZonesWithApiVOInfo(ctx, list, req.BaseRequest.Mid, zidZuMap)
if err != nil {
logger.Error("utilFillZonesWithApiVOInfo fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
@ -2243,8 +2252,17 @@ func (s *Service) ApiGetZoneListByMid(ctx *gin.Context, req *zoneproto.ApiListBy
func (s *Service) ApiGetZoneListByVisitorMid(ctx *gin.Context, req *zoneproto.ApiListByVisitorMidReq) (volist []*zoneproto.ApiZoneVO, ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneSrvOk
// 查询该用户解锁的空间
zidZuMap, err := _DefaultVas.GetZoneUnlockMapByMid(ctx, req.BaseRequest.Mid)
if err != nil {
logger.Error("GetZoneUnlockMapByMid fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
return
}
zids := make([]int64, 0)
zids = append(zids, 1)
for _, zidZu := range zidZuMap {
zids = append(zids, zidZu.GetZid())
}
list, err := _DefaultZone.OpListByZids(ctx, zids)
if err != nil {
@ -2254,7 +2272,7 @@ func (s *Service) ApiGetZoneListByVisitorMid(ctx *gin.Context, req *zoneproto.Ap
}
// 填充必要信息
volist, err = s.utilFillZonesWithApiVOInfo(ctx, list, req.BaseRequest.Mid)
volist, err = s.utilFillZonesWithApiVOInfo(ctx, list, req.BaseRequest.Mid, zidZuMap)
if err != nil {
logger.Error("utilFillZonesWithApiVOInfo fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
@ -2381,7 +2399,7 @@ func (s *Service) ApiCreateZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
textaudit.AddTasks(textaudittasks)
// 设置价格
if util.DerefInt64(req.ZoneMoment.CType) == consts.ZoneMomentCType_Paid {
if req.ZoneMoment.GetCType() == consts.ZoneMomentCType_Paid {
err = _DefaultVas.UpdateZoneMomentPrice(ctx, &vasproto.UpdateZoneMomentPriceReq{
ZoneMomentPrice: &dbstruct.ZoneMomentPrice{
MomentId: momentId,
@ -2403,7 +2421,7 @@ func (s *Service) ApiCreateZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
func (s *Service) ApiUpdateZoneMoment(ctx *gin.Context, req *zonemomentproto.ApiUpdateReq) (ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneMomentSrvOk
zonemoment, err := _DefaultZoneMoment.GetById(ctx, util.DerefInt64(req.Id))
zonemoment, err := _DefaultZoneMoment.GetById(ctx, req.ZoneMoment.GetId())
if err != nil {
logger.Error("_DefaultZoneMoment GetById fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneMomentSrvFail
@ -2416,13 +2434,13 @@ func (s *Service) ApiUpdateZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
// 抹消审核信息，回退到初始
isReauditRequired := false
if req.ZoneMoment.MediaComp != nil && util.DerefInt64(req.ZoneMoment.MType) == consts.MediaTypeImg {
if req.ZoneMoment.MediaComp != nil && req.ZoneMoment.GetMType() == consts.MediaTypeImg {
isReauditRequired = true
req.ZoneMoment.ImageAuditStatus = goproto.Int64(consts.ImageAudit_Created) // 创建
req.ZoneMoment.ImageAuditOpinion = goproto.String("") // 信息抹除
req.ZoneMoment.MediaAmount = goproto.Int64(int64(len(req.ZoneMoment.MediaComp.GetImageIds())))
}
if req.ZoneMoment.MediaComp != nil && util.DerefInt64(req.ZoneMoment.MType) == consts.MediaTypeVideo {
if req.ZoneMoment.MediaComp != nil && req.ZoneMoment.GetMType() == consts.MediaTypeVideo {
req.ZoneMoment.MediaAmount = goproto.Int64(int64(len(req.ZoneMoment.MediaComp.GetVideoIds())))
}
if req.ZoneMoment.Text != nil {
@ -2457,7 +2475,7 @@ func (s *Service) ApiUpdateZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
if isReauditRequired {
mediaCountInc := len(zonemoment.MediaComp.GetImageIds())
videoCountInc := len(zonemoment.MediaComp.GetVideoIds())
err := _DefaultZone.RecordStatisticsById(ctx, util.DerefInt64(zonemoment.Zid), -1, -int64(mediaCountInc), -int64(videoCountInc))
err := _DefaultZone.RecordStatisticsById(ctx, zonemoment.GetZid(), -1, -int64(mediaCountInc), -int64(videoCountInc))
if err != nil {
logger.Error("RecordStatisticsById fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
@ -2484,7 +2502,7 @@ func (s *Service) ApiDeleteZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
ec = errcode.ErrCodeZoneSrvFail
return
}
zid := util.DerefInt64(zonemoment.Zid)
zid := zonemoment.GetZid()
zone, err := _DefaultZone.GetById(ctx, zid)
if err != nil {
logger.Error("_DefaultZone GetById fail, err: %v", err)
@ -2518,7 +2536,7 @@ func (s *Service) ApiDeleteZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
Id: goproto.Int64(zid),
LastZoneMomentCt: goproto.Int64(0),
},
}, util.DerefInt64(zone.LastZoneMomentCt))
}, zone.GetLastZoneMomentCt())
if err != nil {
logger.Error("OpUpdate fail, err: %v", err)
ec = errcode.ErrCodeZoneMomentSrvFail
@ -2527,13 +2545,13 @@ func (s *Service) ApiDeleteZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
} else {
//还有动态，看最后一条更新的动态的更新时间是否比删除的那条动态更早，若更早，则需要把空间的更新时间回拨
lastzonemoment := list[0]
if util.DerefInt64(lastzonemoment.Ut) < util.DerefInt64(zonemoment.Ut) {
if lastzonemoment.GetUt() < zonemoment.GetUt() {
err = _DefaultZone.OpUpdateByIdAndLastZoneMomentCt(ctx, &zoneproto.OpUpdateReq{
Zone: &dbstruct.Zone{
Id: goproto.Int64(zid),
LastZoneMomentCt: lastzonemoment.Ut,
},
}, util.DerefInt64(zone.LastZoneMomentCt))
}, zone.GetLastZoneMomentCt())
if err != nil {
logger.Error("OpUpdate fail, err: %v", err)
ec = errcode.ErrCodeZoneMomentSrvFail
@ -2548,11 +2566,17 @@ func (s *Service) ApiDeleteZoneMoment(ctx *gin.Context, req *zonemomentproto.Api
func (s *Service) ApiGetZoneMomentListByVisitorMid(ctx *gin.Context, req *zonemomentproto.ApiListByVisitorMidReq) (volist []*zonemomentproto.ApiZoneMomentVO, ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneMomentSrvOk
// 1.查询访客关注的空间
// 1.查询该用户解锁的空间
zidZuMap, err := _DefaultVas.GetZoneUnlockMapByMid(ctx, req.BaseRequest.Mid)
if err != nil {
logger.Error("GetZoneUnlockMapByMid fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
return
}
zids := make([]int64, 0)
zids = append(zids, 1)
zids = append(zids, 2)
zids = append(zids, 3)
for _, zidZu := range zidZuMap {
zids = append(zids, zidZu.GetZid())
}
// 2.根据关注的zids查询得到这一轮的动态基底
list, err := _DefaultZoneMoment.OpListByZids(ctx, &zonemomentproto.OpListByZidsReq{
@ -2570,96 +2594,28 @@ func (s *Service) ApiGetZoneMomentListByVisitorMid(ctx *gin.Context, req *zonemo
}
// 3.填充信息
volist = make([]*zonemomentproto.ApiZoneMomentVO, 0)
midSet := make(map[int64]*dbstruct.Moment)
mids := make([]int64, 0)
for _, zonemoment := range list {
vo := &zonemomentproto.ApiZoneMomentVO{
ZoneMoment: zonemoment,
}
volist = append(volist, vo)
mid := zonemoment.GetMid()
if midSet[mid] == nil {
midSet[mid] = &dbstruct.Moment{}
mids = append(mids, mid)
}
}
// 4.通过mids获取主播信息map
ignoreMap := make(map[string]bool)
ignoreMap["zones"] = true
streamerExtMap, err := s.utilGetStreamerExtMapByMids(ctx, mids, consts.InterfaceType_Api, ignoreMap)
volist, err = s.utilFillZoneMomentsWithApiVOInfo(ctx, list, req.BaseRequest.Mid, zidZuMap)
if err != nil {
logger.Error("utilGetStreamerExtMapByMids fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeStreamerSrvFail
logger.Error("utilFillZoneMomentsWithApiVOInfo fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneMomentSrvFail
return
}
// 5.获取访客已解锁的铁粉资格
unlockedIronfanshipMap := make(map[int64]*int64, 0)
// 6.获取访客已解锁的超粉资格
unlockedSuperfanshipMap := make(map[int64]*int64, 0)
// 7.获取访客创建的空间
zoneMap, err := _DefaultZone.GetZoneMapByMids(ctx, []int64{req.BaseRequest.Mid})
if err != nil {
logger.Error("_DefaultZone GetZoneMapByMids fail, req: %v, err: %v", err)
return
}
zones := zoneMap[req.BaseRequest.Mid]
zoneZidMap := make(map[int64]*dbstruct.Zone, 0)
for _, zone := range zones {
zoneZidMap[util.DerefInt64(zone.Id)] = zone
}
// 获取动态的一些静态数据信息
momentIds := make([]int64, 0)
zmStatMap, _ := _DefaultVas.GetZoneMomentStatByIds(ctx, momentIds)
// 8.填充所有信息
for _, vo := range volist {
// 主播信息
vo.CopyStreamerExt(streamerExtMap[vo.GetMid()])
// 是否点赞
if err = s.utilFillIsZoneMomentThumbedUpFillable(ctx, vo.GetMid(), vo); err != nil {
logger.Error("utilFillIsZoneMomentThumbedUpFillable fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneMomentThumbsUpSrvFail
return
}
// 是否解锁铁粉
if unlockedIronfanshipMap[vo.GetMid()] == nil {
vo.SetIsIronfanshipUnlocked(consts.IsIronfanshipUnlocked_No)
} else {
vo.SetIsIronfanshipUnlocked(consts.IsIronfanshipUnlocked_Yes)
}
// 是否解锁超粉
if unlockedSuperfanshipMap[vo.GetMid()] == nil {
vo.SetIsSuperfanshipUnlocked(consts.IsSuperfanshipUnlocked_No)
} else {
vo.SetIsSuperfanshipUnlocked(consts.IsSuperfanshipUnlocked_Yes)
}
// 是否解锁动态
s.utilFillIsZoneMomentUnlocked(vo, zoneZidMap)
// 动态价格
if zmStat, ok := zmStatMap[vo.ZoneMoment.GetId()]; ok {
vo.BuyerCnt = zmStat.BuyerCnt
}
}
return
}
func (s *Service) ApiGetZoneMomentListByZid(ctx *gin.Context, req *zonemomentproto.ApiListByZidReq) (volist []*zonemomentproto.ApiZoneMomentVO, ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneMomentSrvOk
// 1.查询访客是否是空间创建者，不是创建者，则只查询公开动态
// 1.查询该用户解锁的空间
zidZuMap, err := _DefaultVas.GetZoneUnlockMapByMid(ctx, req.BaseRequest.Mid)
if err != nil {
logger.Error("GetZoneUnlockMapByMid fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
return
}
// 2.查询访客是否是空间创建者，不是创建者，则只查询公开动态
zoneMap, err := _DefaultZone.GetZoneMapByMids(ctx, []int64{req.BaseRequest.Mid})
if err != nil {
logger.Error("_DefaultZone GetZoneMapByMids fail, req: %v, err: %v", util.ToJson(req), err)
@ -2669,13 +2625,18 @@ func (s *Service) ApiGetZoneMomentListByZid(ctx *gin.Context, req *zonemomentpro
zones := zoneMap[req.BaseRequest.Mid]
zoneZidMap := make(map[int64]*dbstruct.Zone, 0)
for _, zone := range zones {
zoneZidMap[util.DerefInt64(zone.Id)] = zone
zoneZidMap[zone.GetId()] = zone
}
if zoneZidMap[util.DerefInt64(req.Zid)] == nil {
if zidZuMap[util.DerefInt64(req.Zid)] == nil {
logger.Error("Visitor has not unlocked this zone, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeUnlockedZone
return
}
req.Status = goproto.Int64(consts.ZoneMoment_Public)
}
// 2.根据关注的zids查询得到这一轮的动态基底
// 3.根据关注的zids查询得到这一轮的动态基底
list, err := _DefaultZoneMoment.OpListByZid(ctx, &zonemomentproto.OpListByZidReq{
Zid: req.Zid,
MType: req.MType,
@ -2693,66 +2654,13 @@ func (s *Service) ApiGetZoneMomentListByZid(ctx *gin.Context, req *zonemomentpro
return
}
// 3.初始化返回的volist，获取mids，并将动态基底填充进去
volist = make([]*zonemomentproto.ApiZoneMomentVO, 0)
for _, zonemoment := range list {
vo := &zonemomentproto.ApiZoneMomentVO{
ZoneMoment: zonemoment,
}
volist = append(volist, vo)
}
if len(list) == 0 {
return
}
// 4.通过mids获取主播信息map
ignoreMap := make(map[string]bool)
ignoreMap["zones"] = true
streamerExtMap, err := s.utilGetStreamerExtMapByMids(ctx, []int64{volist[0].GetMid()}, consts.InterfaceType_Api, ignoreMap)
// 4.初始化返回的volist，获取mids，并将动态基底填充进去
volist, err = s.utilFillZoneMomentsWithApiVOInfo(ctx, list, req.BaseRequest.Mid, zidZuMap)
if err != nil {
logger.Error("utilGetStreamerExtMapByMids fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeStreamerSrvFail
logger.Error("utilFillZoneMomentsWithApiVOInfo fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneMomentSrvFail
return
}
streamerExt := streamerExtMap[volist[0].GetMid()]
// 5.获取访客已解锁的铁粉资格
unlockedIronfanshipMap := make(map[int64]*int64, 0)
// 6.获取访客已解锁的超粉资格
unlockedSuperfanshipMap := make(map[int64]*int64, 0)
// 7.填充所有信息
for _, vo := range volist {
// 主播信息
vo.CopyStreamerExt(streamerExt)
// 是否点赞
if err = s.utilFillIsZoneMomentThumbedUpFillable(ctx, vo.GetMid(), vo); err != nil {
logger.Error("utilFillIsZoneMomentThumbedUpFillable fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneMomentThumbsUpSrvFail
return
}
// 是否解锁铁粉
if unlockedIronfanshipMap[vo.GetMid()] == nil {
vo.SetIsIronfanshipUnlocked(consts.IsIronfanshipUnlocked_No)
} else {
vo.SetIsIronfanshipUnlocked(consts.IsIronfanshipUnlocked_Yes)
}
// 是否解锁超粉
if unlockedSuperfanshipMap[vo.GetMid()] == nil {
vo.SetIsSuperfanshipUnlocked(consts.IsSuperfanshipUnlocked_No)
} else {
vo.SetIsSuperfanshipUnlocked(consts.IsSuperfanshipUnlocked_Yes)
}
// 是否解锁动态
s.utilFillIsZoneMomentUnlocked(vo, zoneZidMap)
}
return
}
@ -2912,17 +2820,28 @@ func (s *Service) ApiGetZoneMomentThumbsUpList(ctx *gin.Context, req *zonemoment
return
}
func (s *Service) ApiUpdateZoneSession(ctx *gin.Context, req *zonesessionproto.ApiUpdateReq) (ec errcode.ErrCode) {
func (s *Service) ApiUpsertZoneSession(ctx *gin.Context, req *zonesessionproto.ApiUpsertReq) (ec errcode.ErrCode) {
ec = errcode.ErrCodeZoneSrvOk
err := _DefaultZoneSession.OpUpdateBySentence(ctx, req.BaseRequest.Mid, req.Zid)
err := _DefaultZoneSession.OpUpdateBySentence(ctx, req.BaseRequest.Mid, util.DerefInt64(req.Zid))
// 如果命中失败，则创建空间对话
if err == qmgo.ErrNoSuchDocuments {
ec = errcode.ErrCodeZoneNotExist
err = nil
err := _DefaultZoneSession.OpCreate(ctx, &zonesessionproto.OpCreateReq{
BaseRequest: req.BaseRequest,
ZoneSession: &dbstruct.ZoneSession{
SubMid: goproto.Int64(req.BaseRequest.Mid),
ObjZid: req.Zid,
},
})
if err != nil {
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSessionSrvFail
return
}
return
}
if err != nil {
logger.Error("OpUpdateBySentence fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSrvFail
logger.Error("OpUpdate fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeZoneSessionSrvFail
return
}
return
@ -3089,7 +3008,7 @@ func (s *Service) ApiGetZoneCollaboratorList(ctx *gin.Context, req *zone_collabo
midSet := make(map[int64]*dbstruct.Moment)
mids := make([]int64, 0)
for _, zone_collaborator := range list {
mid := util.DerefInt64(zone_collaborator.CollaboratorMid)
mid := zone_collaborator.GetCollaboratorMid()
if midSet[mid] == nil {
midSet[mid] = &dbstruct.Moment{}
mids = append(mids, mid)
@ -3104,7 +3023,7 @@ func (s *Service) ApiGetZoneCollaboratorList(ctx *gin.Context, req *zone_collabo
}
for _, zone_collaborator := range list {
mid := util.DerefInt64(zone_collaborator.CollaboratorMid)
mid := zone_collaborator.GetCollaboratorMid()
vo := &zone_collaborator_proto.ZoneCollaboratorApiVO{
ZoneCollaborator: zone_collaborator,
Account: acctMp[mid],

2
app/mix/service/apiservice_business_validation.go
View File

@ -576,7 +576,7 @@ func (s *Service) ApiCreateZoneMomentBusinessValidate(ctx *gin.Context, req *zon
return
}
// 验证码登录
// 代运营创建验证码
func (s *Service) ApiCreateZoneThirdPartnerBusinessValidate(ctx *gin.Context, req *zone_third_partner_proto.ApiCreateReq) (vericode *dbstruct.VeriCode, ec errcode.ErrCode) {
ec = errcode.ErrCodeLoginSrvOk

28
app/mix/service/logic/vas_zone.go
View File

@ -3,9 +3,6 @@ package logic
import (
"database/sql"
"fmt"
"github.com/gin-gonic/gin"
"github.com/jmoiron/sqlx"
goproto "google.golang.org/protobuf/proto"
"service/api/errs"
vasproto "service/api/proto/vas/proto"
zone_collaborator_proto "service/api/proto/zone_collaborator/proto"
@ -14,6 +11,10 @@ import (
"service/dbstruct"
"service/library/logger"
"time"
"github.com/gin-gonic/gin"
"github.com/jmoiron/sqlx"
goproto "google.golang.org/protobuf/proto"
)
// 检查mid对空间的解锁是否存在
@ -599,6 +600,19 @@ func (v *Vas) GetZoneMomentStatByIds(ctx *gin.Context, momentIds []int64) (midZm
return
}
// 获取用户已解锁的空间的信息，返回值：key: zid, value: 解锁信息
func (v *Vas) GetZoneUnlockMapByMid(ctx *gin.Context, mid int64) (zidZuMap map[int64]*dbstruct.ZoneUnlock, err error) {
zidZuMap = make(map[int64]*dbstruct.ZoneUnlock)
list, err := v.store.GetZoneUnlockListByMid(ctx, nil, mid)
if err != nil {
return
}
for _, v := range list {
zidZuMap[v.GetZid()] = v
}
return
}
// 获取空间解锁人的信息，返回值：key: mid, value: 解锁信息
func (v *Vas) GetZoneUnlockMapByZid(ctx *gin.Context, zid int64) (midZuMap map[int64]*dbstruct.ZoneUnlock, err error) {
midZuMap = make(map[int64]*dbstruct.ZoneUnlock)
@ -625,15 +639,15 @@ func (v *Vas) GetZoneUnlockMapByMidZids(ctx *gin.Context, mid int64, zids []int6
return
}
// 获取mid对动态解锁信息 by mid, momentIds，返回值：key: zid, value: 解锁信息
func (v *Vas) GetZoneMomentUnlockMapByMidMomentIds(ctx *gin.Context, mid int64, momentIds []int64) (zidZuMap map[int64]*dbstruct.ZoneMomentUnlock, err error) {
zidZuMap = make(map[int64]*dbstruct.ZoneMomentUnlock)
// 获取mid对动态解锁信息 by mid, momentIds，返回值：key: moment_id, value: 解锁信息
func (v *Vas) GetZoneMomentUnlockMapByMidMomentIds(ctx *gin.Context, mid int64, momentIds []int64) (momentIdZmuMap map[int64]*dbstruct.ZoneMomentUnlock, err error) {
momentIdZmuMap = make(map[int64]*dbstruct.ZoneMomentUnlock)
list, err := v.store.GetZoneMomentUnlockListByMidMomentIds(ctx, nil, mid, momentIds)
if err != nil {
return
}
for _, v := range list {
zidZuMap[v.GetZid()] = v
momentIdZmuMap[v.GetMomentId()] = v
}
return
}

2
app/mix/service/logic/zone_collaborator.go
View File

@ -72,7 +72,7 @@ func (p *ZoneCollaborator) OpList(ctx *gin.Context, req *zone_collaborator_proto
return list, nil
}
func (p *ZoneCollaborator) GetZoneCollaboratorMapByTpMid(ctx *gin.Context, c_mid int64) (map[int64]*dbstruct.ZoneCollaborator, error) {
func (p *ZoneCollaborator) GetZoneCollaboratorMapByCMid(ctx *gin.Context, c_mid int64) (map[int64]*dbstruct.ZoneCollaborator, error) {
list, err := p.store.GetZoneCollaboratorListByCMid(ctx, c_mid)
if err != nil {
logger.Error("GetZoneCollaboratorListByCMid fail, err: %v", err)

5
app/mix/service/logic/zonesession.go
View File

@ -65,9 +65,10 @@ func (p *ZoneSession) OpList(ctx *gin.Context, req *zonesessionproto.OpListReq)
return list, nil
}
func (p *ZoneSession) GetZoneSessionMapByMid(ctx *gin.Context, mid int64) (map[int64]*dbstruct.ZoneSession, error) {
func (p *ZoneSession) GetZoneSessionMapByMidAndZids(ctx *gin.Context, mid int64, zids []int64) (map[int64]*dbstruct.ZoneSession, error) {
list, err := p.store.GetZoneSessionList(ctx, &zonesessionproto.OpListReq{
Mid: mid,
Mid: mid,
Zids: zids,
})
if err != nil {
logger.Error("GetZoneSessionList fail, err: %v", err)

174
app/mix/service/utilservice.go
View File

@ -895,7 +895,7 @@ func (s *Service) utilEncryptInaccessibleZoneMoment(vo *zonemomentproto.ApiZoneM
}
// 填充动态是否解锁
func (s *Service) utilFillIsZoneMomentUnlocked(vo *zonemomentproto.ApiZoneMomentVO, zoneZidMap map[int64]*dbstruct.Zone) {
func (s *Service) utilFillIsZoneMomentUnlocked(vo *zonemomentproto.ApiZoneMomentVO, zoneZidMap map[int64]*dbstruct.Zone, momentIdZmuMap map[int64]*dbstruct.ZoneMomentUnlock) {
// 若动态在本人创建的空间内，则必然解锁
if zoneZidMap[util.DerefInt64(vo.ZoneMoment.Zid)] != nil {
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_Yes)
@ -905,12 +905,13 @@ func (s *Service) utilFillIsZoneMomentUnlocked(vo *zonemomentproto.ApiZoneMoment
case consts.ZoneMomentCType_Free:
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_Yes)
case consts.ZoneMomentCType_Paid:
if vo.IsSuperfanshipUnlocked == consts.IsIronfanshipUnlocked_Yes {
if vo.IsSuperfanshipUnlocked == consts.IsSuperfanshipUnlocked_Yes { // 超粉解锁
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_Yes)
} else if util.DerefInt64(vo.IsIronfanVisible) == consts.IsIronfanVisible_Yes && vo.IsIronfanshipUnlocked == consts.IsIronfanshipUnlocked_Yes {
} else if util.DerefInt64(vo.IsIronfanVisible) == consts.IsIronfanVisible_Yes && vo.IsIronfanshipUnlocked == consts.IsIronfanshipUnlocked_Yes { // 铁粉可见
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_Yes)
} else {
// 是否已购买该条动态
} else if momentIdZmuMap[vo.ZoneMoment.GetId()].IsUnlock() { // 动态已购买
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_Yes)
} else { // 未解锁，上锁
vo.SetIsZoneMomentUnlocked(consts.IsZoneMomentUnlocked_No)
s.utilEncryptInaccessibleZoneMoment(vo)
}
@ -1445,18 +1446,25 @@ func (s *Service) utilGetApiMomentVOListByIds(ctx *gin.Context, visitorMid int64
return
}
func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.Zone, visitorMid int64) (volist []*zoneproto.ApiZoneVO, err error) {
func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.Zone, visitorMid int64, zidZuMap map[int64]*dbstruct.ZoneUnlock) (volist []*zoneproto.ApiZoneVO, err error) {
// 1.获取mids，并填充空间基底
// 1.获取mids，zids，并填充空间基底
volist = make([]*zoneproto.ApiZoneVO, 0)
mids := make([]int64, 0)
zids := make([]int64, 0)
midSet := make(map[int64]*dbstruct.Zone)
zidSet := make(map[int64]*dbstruct.Zone)
for _, zone := range list {
mid := util.DerefInt64(zone.Mid)
mid := zone.GetMid()
zid := zone.GetId()
if midSet[mid] == nil {
midSet[mid] = &dbstruct.Zone{}
mids = append(mids, mid)
}
if zidSet[zid] == nil {
zidSet[zid] = &dbstruct.Zone{}
zids = append(zids, zid)
}
vo := &zoneproto.ApiZoneVO{}
vo.CopyZone(zone)
volist = append(volist, vo)
@ -1471,10 +1479,10 @@ func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.
return
}
// 3.获取访客所有空间的session
zonesessionMp, err := _DefaultZoneSession.GetZoneSessionMapByMid(ctx, visitorMid)
// 3.获取访客访问这些空间的session
zonesessionMp, err := _DefaultZoneSession.GetZoneSessionMapByMidAndZids(ctx, visitorMid, zids)
if err != nil {
logger.Error("GetZoneSessionMapByMid fail, req: %v, err: %v", err)
logger.Error("GetZoneSessionMapByMidAndZids fail, req: %v, err: %v", err)
return
}
@ -1486,9 +1494,9 @@ func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.
}
// 5.获取访客协作的空间
collabZoneMap, err := _DefaultZoneCollaborator.GetZoneCollaboratorMapByTpMid(ctx, visitorMid)
collabZoneMap, err := _DefaultZoneCollaborator.GetZoneCollaboratorMapByCMid(ctx, visitorMid)
if err != nil {
logger.Error("GetZoneCollaboratorMapByTpMid fail, req: %v, err: %v", err)
logger.Error("GetZoneCollaboratorMapByCMid fail, req: %v, err: %v", err)
return
}
@ -1504,33 +1512,38 @@ func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.
zones := zoneMap[visitorMid]
zoneZidMap := make(map[int64]*dbstruct.Zone, 0)
for _, zone := range zones {
zoneZidMap[util.DerefInt64(zone.Id)] = zone
zoneZidMap[zone.GetId()] = zone
}
// 8.填充信息
for _, vo := range volist {
zid := vo.Zone.GetId()
// 填充主播信息
vo.CopyStreamerExt(streamerExtMap[vo.GetMid()])
// 填充是否有未读信息
zonesession := zonesessionMp[util.DerefInt64(vo.Zone.Id)]
if zonesession != nil && util.DerefInt64(zonesession.Ut) < util.DerefInt64(vo.Zone.LastZoneMomentCt) {
zonesession := zonesessionMp[zid]
if zonesession != nil && zonesession.GetUt() < vo.Zone.GetLastZoneMomentCt() {
vo.IsUnreadZoneMomentExist = consts.IsUnreadZoneMomentExist_Yes
} else {
vo.IsUnreadZoneMomentExist = consts.IsUnreadZoneMomentExist_No
}
// 填充访客身份
vo.VisitorRole = consts.Zone_Visitor
if zoneZidMap[util.DerefInt64(vo.Zone.Id)] != nil {
vo.VisitorRole = consts.Zone_Outsider
if zidZuMap[zid] != nil { // 访客已解锁空间是否有该zid
vo.VisitorRole = consts.Zone_Visitor
} else if zoneZidMap[zid] != nil { // 访客创建的空间是否有该zid
vo.VisitorRole = consts.Zone_Creater
} else if tpZoneMap[visitorMid] != nil {
} else if tpZoneMap[zid] != nil { // 访客代运营的空间是否有该zid
vo.VisitorRole = consts.Zone_ThridPartner
} else if collabZoneMap[visitorMid] != nil {
} else if collabZoneMap[zid] != nil { // 访客协作的空间是否有该zid
vo.VisitorRole = consts.Zone_Collaborator
}
// 填充该空间预览图
zid := util.DerefInt64(vo.Zone.Id)
if zonePreviewsMp[zid] != nil {
vo.Previews = zonePreviewsMp[zid]
} else {
@ -1543,7 +1556,21 @@ func (s *Service) utilFillZonesWithApiVOInfo(ctx *gin.Context, list []*dbstruct.
}
// 填充该空间总消耗费用
vo.Expenditure = 0
vo.Expenditure = zidZuMap[zid].GetConsume()
// 填充铁粉解锁信息
if zidZuMap[zid].IsUnlockIronfanship() {
vo.IsIronfanshipUnlocked = consts.IsIronfanshipUnlocked_Yes
} else {
vo.IsIronfanshipUnlocked = consts.IsIronfanshipUnlocked_No
}
// 填充超粉解锁信息
if zidZuMap[zid].IsUnlockSuperfanship() {
vo.IsSuperfanshipUnlocked = consts.IsSuperfanshipUnlocked_Yes
} else {
vo.IsSuperfanshipUnlocked = consts.IsSuperfanshipUnlocked_No
}
}
return
@ -1578,3 +1605,106 @@ func (s *Service) utilGetZonePreviews(ctx *gin.Context, zid int64) (previews *db
return
}
func (s *Service) utilFillZoneMomentsWithApiVOInfo(ctx *gin.Context, list []*dbstruct.ZoneMoment, visitorMid int64, zidZuMap map[int64]*dbstruct.ZoneUnlock) (volist []*zonemomentproto.ApiZoneMomentVO, err error) {
// 1.填充信息
volist = make([]*zonemomentproto.ApiZoneMomentVO, 0)
midSet := make(map[int64]*dbstruct.Moment)
mids := make([]int64, 0)
zids := make([]int64, 0)
zidSet := make(map[int64]*dbstruct.Zone)
momentIds := make([]int64, 0)
for _, zonemoment := range list {
vo := &zonemomentproto.ApiZoneMomentVO{
ZoneMoment: zonemoment,
}
volist = append(volist, vo)
momentIds = append(momentIds, zonemoment.GetId())
mid := zonemoment.GetMid()
if midSet[mid] == nil {
midSet[mid] = &dbstruct.Moment{}
mids = append(mids, mid)
}
zid := zonemoment.GetZid()
if zidSet[zid] == nil {
zidSet[zid] = &dbstruct.Zone{}
zids = append(zids, zid)
}
}
// 2.通过mids获取主播信息map
ignoreMap := make(map[string]bool)
ignoreMap["zones"] = true
streamerExtMap, err := s.utilGetStreamerExtMapByMids(ctx, mids, consts.InterfaceType_Api, ignoreMap)
if err != nil {
logger.Error("utilGetStreamerExtMapByMids fail, err: %v", err)
return
}
// 3.获取访客创建的空间
zoneMap, err := _DefaultZone.GetZoneMapByMids(ctx, []int64{visitorMid})
if err != nil {
logger.Error("_DefaultZone GetZoneMapByMids fail, req: %v, err: %v", err)
return
}
zones := zoneMap[visitorMid]
zoneZidMap := make(map[int64]*dbstruct.Zone, 0)
for _, zone := range zones {
zoneZidMap[zone.GetId()] = zone
}
// 4.获取动态的一些静态数据信息
zmStatMap, _ := _DefaultVas.GetZoneMomentStatByIds(ctx, momentIds)
// 5.获取该mid是否已解锁这些动态
momentIdZmuMap, _ := _DefaultVas.GetZoneMomentUnlockMapByMidMomentIds(ctx, visitorMid, momentIds)
// 6.获取空间价格
zvMap, _ := _DefaultVas.GetZoneVasByIds(ctx, zids)
// 7.填充所有信息
for _, vo := range volist {
zid := vo.ZoneMoment.GetId()
// 主播信息
vo.CopyStreamerExt(streamerExtMap[vo.GetMid()])
// 是否点赞
if err = s.utilFillIsZoneMomentThumbedUpFillable(ctx, vo.GetMid(), vo); err != nil {
logger.Error("utilFillIsZoneMomentThumbedUpFillable fail, err: %v", err)
return
}
// 填充铁粉解锁信息
if zidZuMap[zid].IsUnlockIronfanship() {
vo.IsIronfanshipUnlocked = consts.IsIronfanshipUnlocked_Yes
} else {
vo.IsIronfanshipUnlocked = consts.IsIronfanshipUnlocked_No
}
// 填充超粉解锁信息
if zidZuMap[zid].IsUnlockSuperfanship() {
vo.IsSuperfanshipUnlocked = consts.IsSuperfanshipUnlocked_Yes
} else {
vo.IsSuperfanshipUnlocked = consts.IsSuperfanshipUnlocked_No
}
// 是否解锁动态
s.utilFillIsZoneMomentUnlocked(vo, zoneZidMap, momentIdZmuMap)
// 动态已解锁信息
if zmStat, ok := zmStatMap[vo.ZoneMoment.GetId()]; ok {
vo.BuyerCnt = zmStat.BuyerCnt
}
// 已消费金额
vo.Expenditure = zidZuMap[zid].GetConsume()
// 铁粉价格
vo.IronfanshipPrice = zvMap[zid].IronfanshipPrice
}
return
}

9
dbstruct/vas_mysql.go
View File

@ -943,6 +943,9 @@ type ZoneUnlock struct {
}
func (p *ZoneUnlock) IsUnlockAdmission() bool {
if p.AdmissionCt == nil {
return false
}
if p.GetAdmissionUntil() == -1 || p.GetAdmissionUntil() < time.Now().Unix() {
return true
}
@ -950,6 +953,9 @@ func (p *ZoneUnlock) IsUnlockAdmission() bool {
}
func (p *ZoneUnlock) IsUnlockIronfanship() bool {
if p.IronfanshipCt == nil {
return false
}
if p.GetIronfanshipUntil() == -1 || p.GetIronfanshipUntil() < time.Now().Unix() {
return true
}
@ -957,6 +963,9 @@ func (p *ZoneUnlock) IsUnlockIronfanship() bool {
}
func (p *ZoneUnlock) IsUnlockSuperfanship() bool {
if p.SuperfanshipCt == nil {
return false
}
if p.GetSuperfanshipUntil() == -1 || p.GetSuperfanshipUntil() < time.Now().Unix() {
return true
}

14
dbstruct/zone.go
View File

@ -19,3 +19,17 @@ func (p *Zone) GetId() int64 {
}
return 0
}
func (p *Zone) GetMid() int64 {
if p != nil && p.Mid != nil {
return *p.Mid
}
return 0
}
func (p *Zone) GetLastZoneMomentCt() int64 {
if p != nil && p.LastZoneMomentCt != nil {
return *p.LastZoneMomentCt
}
return 0
}

28
dbstruct/zonemoment.go
View File

@ -45,3 +45,31 @@ func (p *ZoneMoment) GetMid() int64 {
}
return 0
}
func (p *ZoneMoment) GetZid() int64 {
if p != nil && p.Zid != nil {
return *p.Zid
}
return 0
}
func (p *ZoneMoment) GetMType() int64 {
if p != nil && p.MType != nil {
return *p.MType
}
return 0
}
func (p *ZoneMoment) GetCType() int64 {
if p != nil && p.CType != nil {
return *p.CType
}
return 0
}
func (p *ZoneMoment) GetUt() int64 {
if p != nil && p.Ut != nil {
return *p.Ut
}
return 0
}

7
dbstruct/zonesession.go
View File

@ -8,3 +8,10 @@ type ZoneSession struct {
Ut *int64 `json:"ut" bson:"ut"` // 更新时间
DelFlag *int64 `json:"del_flag" bson:"del_flag"` // 删除标记
}
func (p *ZoneSession) GetUt() int64 {
if p != nil && p.Ut != nil {
return *p.Ut
}
return 0
}