1
This commit is contained in:
parent
305123c493
commit
a376e6a56c
@ -600,6 +600,17 @@ func (this *guildMgr) AsyncUpdateGuild(accountId string, kv map[int32]string, cb
|
||||
cb(2, "Insufficient permissions")
|
||||
return
|
||||
}
|
||||
if name, ok := kv[constant.GUILD_UPDATE_FIELD_NAME]; ok {
|
||||
if this.internalGetGuildByGuildName(name) != nil {
|
||||
cb(4, "Cube name already exists")
|
||||
return
|
||||
}
|
||||
if this.isUsingName(name) {
|
||||
cb(4, "Cube name already exists")
|
||||
return
|
||||
}
|
||||
this.addUsingName(name)
|
||||
}
|
||||
f5.NewLockAsyncTask([][]string{
|
||||
{constant.GUILD_ID_LOCK_KEY, guild.guildId},
|
||||
{constant.GUILD_NAME_LOCK_KEY, guild.guildName},
|
||||
@ -633,8 +644,20 @@ func (this *guildMgr) AsyncUpdateGuild(accountId string, kv map[int32]string, cb
|
||||
},
|
||||
fields,
|
||||
func (err error, lastInsertId int64, rowsAffected int64) {
|
||||
|
||||
if err != nil {
|
||||
task.SetFail()
|
||||
cb(500, "server internal error")
|
||||
return
|
||||
}
|
||||
task.SetSucc()
|
||||
cb(0, "")
|
||||
return
|
||||
})
|
||||
}).OnExit(
|
||||
func (task *f5.LockAsyncTask) {
|
||||
if name, ok := kv[constant.GUILD_UPDATE_FIELD_NAME]; ok {
|
||||
this.removeUsingName(name)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user