From f221b299cd04d71ce193d3833c21800be4c98b05 Mon Sep 17 00:00:00 2001
From: xinian <eBCmZThyqEBRX6cZZseEVK+xinian@noreply.cnb.cool>
Date: Thu, 2 Apr 2026 22:38:02 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=B9=B6=E5=8F=91=E5=AE=89=E5=85=A8?=
 =?UTF-8?q?=E5=9C=B0=E6=9B=B4=E6=96=B0=E5=9C=B0=E5=9B=BE=E8=AE=A1=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 logic/service/space/hot.go    | 26 ++++++++++++++++++--------
 logic/service/space/in_out.go |  4 ++--
 2 files changed, 20 insertions(+), 10 deletions(-)

diff --git a/logic/service/space/hot.go b/logic/service/space/hot.go
index 467868589..b65d5990d 100644
--- a/logic/service/space/hot.go
+++ b/logic/service/space/hot.go
@@ -1,11 +1,14 @@
 package space
 
+import "sync"
+
 // MapHotInfo 表示地图热度信息
 type MapHotInfo struct {
 	MapID uint32 `json:"mapId"`                // 地图ID
 	Count int32  `struc:"uint32" json:"count"` // 地图里的人数
 }
 type MapTip struct {
+	mu       sync.RWMutex
 	Count    int                 `struc:"uint32" json:"count"` // 地图里的人数
 	TipInfoS map[uint32]*TipInfo `json:"tipInfoS"`
 }
@@ -17,20 +20,27 @@ type TipInfo struct {
 	Diao []uint32 `json:"diao"` //掉落
 }
 
-func (m *MapTip) GetCount(t int) int {
+func (m *MapTip) ChangeCount(delta int) int {
+	m.mu.Lock()
+	defer m.mu.Unlock()
 
-	switch {
-	case t < 0:
-		if m.Count > 0 {
-			m.Count -= t
+	if delta != 0 {
+		m.Count += delta
+		if m.Count < 0 {
+			m.Count = 0
 		}
-	case t > 0:
-		m.Count += t
 	}
 
 	return m.Count
 }
 
+func (m *MapTip) CountValue() int {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	return m.Count
+}
+
 var maphot = make(map[uint32]*MapTip, 0)
 
 func GetMapHot() []MapHotInfo {
@@ -38,7 +48,7 @@ func GetMapHot() []MapHotInfo {
 	for k, v := range maphot {
 		ret = append(ret, MapHotInfo{
 			MapID: k,
-			Count: int32(v.GetCount(0)),
+			Count: int32(v.CountValue()),
 		})
 
 	}
diff --git a/logic/service/space/in_out.go b/logic/service/space/in_out.go
index 4c8b1a74a..ee2686985 100644
--- a/logic/service/space/in_out.go
+++ b/logic/service/space/in_out.go
@@ -41,7 +41,7 @@ func (s *Space) LeaveMap(c common.PlayerI) {
 
 	current, ok := maphot[s.Super]
 	if ok {
-		current.GetCount(-1)
+		current.ChangeCount(-1)
 
 	}
 	if atomic.CompareAndSwapUint32(&s.Owner.UserID, c.GetInfo().UserID, 0) {
@@ -67,7 +67,7 @@ func (s *Space) EnterMap(c common.PlayerI) {
 	s.UserInfo.Store(c.GetInfo().UserID, *out)
 	curmaps, ok := maphot[s.Super]
 	if ok {
-		curmaps.GetCount(1)
+		curmaps.ChangeCount(1)
 		//atomic.AddInt32(maphot[s.Super], 1)
 	}