1

server/imserver_new/guild/guild.go

@@ -248,6 +248,26 @@ func (this *guild) asyncLeave(accountId string, cb func(int32, string)) {
 		})
 }
 
+func (this *guild) asyncUpdateOwner(owner string, cb func(int32, string)) {
+	f5.GetJsStyleDb().Update(
+		constant.FRIEND_DB,
+		"t_guild",
+		[][]string{
+			{"owner_id", owner},
+		},
+		[][]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 newGuild() *guild {
 	p := new(guild)
 	p.idHash = make(map[string]*member)

server/imserver_new/guild/guildmgr.go

@@ -563,6 +563,11 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
 		cb(0, "")
 		return;
 	}
+	owner := guild.getMember(accountId)
+	if owner == nil {
+		cb(0, "")
+		return;
+	}
 	member := guild.getMember(targetId)
 	if member == nil {
 		cb(0, "")
@@ -580,11 +585,11 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
 				constant.FRIEND_DB,
 				"t_guild_member",
 				[][]string{
-					{"member_id", member.memberId},
+					{"guild_job", q5.ToString(guildJob)},
-					{"guild_id", guild.guildId},
 				},
 				[][]string{
-					{"guild_job", q5.ToString(guildJob)},
+					{"member_id", member.memberId},
+					{"guild_id", guild.guildId},
 				},
 				func (err error, lastInsertId int64, rowsAffected int64) {
 					if err != nil {
@@ -593,8 +598,39 @@ func (this *guildMgr) AsyncSetGuildJob(accountId string, targetId string, guildJ
 						return
 					}
 					member.guildJob = guildJob
-					task.SetSucc()
+					if guildJob == constant.GuildMemberLevelLeader {
-					cb(0, "")
+						f5.GetJsStyleDb().Update(
+							constant.FRIEND_DB,
+							"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) {
+								if err != nil {
+									task.SetFail()
+									cb(500, "")
+									return
+								}
+								owner.guildJob = constant.GuildMemberLevelDefault
+								guild.asyncUpdateOwner(member.memberId,
+									func (errCode int32, errMsg string) {
+										if err != nil {
+											task.SetFail()
+											cb(500, "")
+											return
+										}
+										task.SetSucc()
+										cb(0, "")
+									})
+							})
+					} else {
+						task.SetSucc()
+						cb(0, "")
+					}
 				})
 		})
 }