This commit is contained in:
aozhiwei 2024-04-11 19:50:34 +08:00
parent f27e2d721e
commit 56fce60ff5
2 changed files with 6 additions and 51 deletions

View File

@ -187,26 +187,6 @@ func (this *guild) asyncLeave(accountId string, cb func(int32, string)) {
}) })
} }
func (this *guild) asyncUpdateOwner(ownerId string, cb func(int32, string)) {
f5.GetJsStyleDb().Update(
constant.FRIEND_DB,
"t_guild",
[][]string{
{"owner_id", ownerId},
},
[][]string{
{"guild_id", this.guildId},
},
func (err error, lastInsertId int64, rowsAffected int64) {
if err != nil {
cb(500, "server internal error")
return
}
cb(0, "")
return
})
}
func (this *guild) getOwnerId() string { func (this *guild) getOwnerId() string {
ownerId := "" ownerId := ""
this.traverseMembers( this.traverseMembers(

View File

@ -486,16 +486,7 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
{constant.GUILD_MEMBER_LOCK_KEY, targetId}, {constant.GUILD_MEMBER_LOCK_KEY, targetId},
}, },
func (task *f5.LockAsyncTask) { func (task *f5.LockAsyncTask) {
f5.GetJsStyleDb().Update( model.GuildMember.SetJob(guild.guildId, member.memberId, guildJob,
constant.FRIEND_DB,
"t_guild_member",
[][]string{
{"guild_job", q5.ToString(guildJob)},
},
[][]string{
{"member_id", member.memberId},
{"guild_id", guild.guildId},
},
func (err error, lastInsertId int64, rowsAffected int64) { func (err error, lastInsertId int64, rowsAffected int64) {
if err != nil { if err != nil {
task.SetFail() task.SetFail()
@ -503,17 +494,9 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
return return
} }
member.guildJob = guildJob member.guildJob = guildJob
if guildJob == constant.GuildMemberLevelLeader { if member.guildJob == constant.GuildMemberLevelLeader {
f5.GetJsStyleDb().Update( model.GuildMember.SetJob(guild.guildId, owner.memberId,
constant.FRIEND_DB, constant.GuildMemberLevelDefault,
"t_guild_member",
[][]string{
{"guild_job", q5.ToString(constant.GuildMemberLevelDefault)},
},
[][]string{
{"member_id", owner.memberId},
{"guild_id", guild.guildId},
},
func (err error, lastInsertId int64, rowsAffected int64) { func (err error, lastInsertId int64, rowsAffected int64) {
if err != nil { if err != nil {
task.SetFail() task.SetFail()
@ -521,16 +504,8 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
return return
} }
owner.guildJob = constant.GuildMemberLevelDefault owner.guildJob = constant.GuildMemberLevelDefault
guild.asyncUpdateOwner(member.memberId, task.SetSucc()
func (errCode int32, errMsg string) { cb(0, "")
if err != nil {
task.SetFail()
cb(500, "")
return
}
task.SetSucc()
cb(0, "")
})
}) })
} else { } else {
task.SetSucc() task.SetSucc()