liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

好友同意时清理好友申请数据

Browse Source
This commit is contained in:
meixiongfeng 2023-12-25 15:55:45 +08:00
parent 39cc62ee40
commit 5aff341043
2 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/friend/api_cross_agree.go
View File

@ -120,9 +120,13 @@ func (this *apiComp) Agree(session comm.IUserSession, req *pb.FriendAgreeReq) (e
} }
target.FriendIds = append(target.FriendIds, self.Uid) target.FriendIds = append(target.FriendIds, self.Uid)
} }
target.Weapplyids = utils.DeleteString(target.Weapplyids, self.Uid) // 同意 移除已经申请的好友
if err = this.module.modelFriend.Change(target.Uid, map[string]interface{}{ if err = this.module.modelFriend.Change(target.Uid, map[string]interface{}{
"friendIds": target.FriendIds, "friendIds": target.FriendIds,
"applyIds": target.ApplyIds, "applyIds": target.ApplyIds,
"weapplyids": target.Weapplyids,
}); err != nil { }); err != nil {
errdata = &pb.ErrorData{ errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError, Code: pb.ErrorCode_DBError,

20
modules/hero/module.go
View File

@ -228,21 +228,23 @@ func (this *Hero) CreateRepeatHeros(session comm.IUserSession, heros map[string]
this.Errorf("create hero %s failed", heroCfgId) this.Errorf("create hero %s failed", heroCfgId)
continue continue
} }
szAddHero = append(szAddHero, heroCfgId)
for _, v := range atno { for _, v := range atno {
if v.A == "hero" && v.N == 1 { if v.A == "hero" && v.N == 1 {
changeList = append(changeList, hero) changeList = append(changeList, hero)
szAddHero = append(szAddHero, heroCfgId)
break break
} }
} }
} }
if db.IsCross() {
go this.moduleFetter.SendRpcAddHero(session.GetUserId(), szAddHero, session.GetServiecTag())
} else {
go this.moduleFetter.AddHerosFetterData(session.GetUserId(), szAddHero)
}
if len(changeList) > 0 { if len(changeList) > 0 {
session.SendMsg("hero", "change", &pb.HeroChangePush{List: changeList}) session.SendMsg("hero", "change", &pb.HeroChangePush{List: changeList})
if db.IsCross() {
go this.moduleFetter.SendRpcAddHero(session.GetUserId(), szAddHero, session.GetServiecTag())
} else {
go this.moduleFetter.AddHerosFetterData(session.GetUserId(), szAddHero)
}
} }
return return
} }
@ -910,14 +912,10 @@ func (this *Hero) CreateOneHero(session comm.IUserSession, heroCfgId string) (he
} }
szAddHero = append(szAddHero, heroCfgId) szAddHero = append(szAddHero, heroCfgId)
if db.IsCross() {
go this.moduleFetter.SendRpcAddHero(session.GetUserId(), szAddHero, session.GetServiecTag())
} else {
go this.moduleFetter.AddHerosFetterData(session.GetUserId(), szAddHero) // 异步调用
}
for _, v := range atno { for _, v := range atno {
if v.A == "hero" && v.N == 1 { if v.A == "hero" && v.N == 1 {
changeList = append(changeList, hero) changeList = append(changeList, hero)
go this.moduleFetter.AddHerosFetterData(session.GetUserId(), szAddHero) // 异步调用
break break
} }
} }