邮件红点问题

dbproxy/main.go

@@ -42,8 +42,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopConsumer()
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

gamesrv/main.go

@@ -52,7 +52,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

gatesrv/main.go

@@ -22,7 +22,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

mgrsrv/main.go

@@ -27,7 +27,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
 		return nil
 	})
 	// module模块

ranksrv/main.go

@@ -31,7 +31,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopConsumer()
 		return nil
 	})
 	// module模块

worldsrv/action_player.go

@@ -1956,6 +1956,7 @@ func CSPlayerData(s *netlib.Session, packetid int, data interface{}, sid int64)
 				p.TotalIn = 0
 				p.TotalOut = 0
 				p.PlayerTax = 0
+				p.dirty = true
 			}
 		}
 	}

worldsrv/main.go

@@ -51,8 +51,6 @@ func main() {
 		return nil
 	})
 	core.RegisteHook(core.HOOK_AFTER_STOP, func() error {
-		mq.StopPublisher()
-		mq.StopConsumer()
 		return nil
 	})
 	//启动定时任务

worldsrv/player.go

@@ -654,6 +654,7 @@ func (this *Player) LoadMessage(lastLogoutTime int64, isFirstLogin, isSkipWeek b
 					}
 					this.verifyMessage(maxTs)
 				}
+				this.MessageShowRed()
 			}
 		}), "GetMessage").StartByFixExecutor("logic_message")
 }