From 6767075dcdd013fa897f24b1a0117f857806750d Mon Sep 17 00:00:00 2001
From: xinian <eBCmZThyqEBRX6cZZseEVK+xinian@noreply.cnb.cool>
Date: Fri, 27 Mar 2026 16:53:07 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E8=B4=AD=E4=B9=B0?=
 =?UTF-8?q?=E9=81=93=E5=85=B7=E6=95=B0=E9=87=8F=E4=B8=8A=E9=99=90=E6=A0=A1?=
 =?UTF-8?q?=E9=AA=8C=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 logic/controller/item_buy.go   |  5 +++-
 modules/player/service/talk.go | 50 ++++++++++++++++++++++++++--------
 2 files changed, 43 insertions(+), 12 deletions(-)

diff --git a/logic/controller/item_buy.go b/logic/controller/item_buy.go
index 7113daa1c..6074318fe 100644
--- a/logic/controller/item_buy.go
+++ b/logic/controller/item_buy.go
@@ -147,9 +147,12 @@ func (h Controller) BuyGoldItem(data *item.C2S_GOLD_BUY_PRODUCT, player *player.
 			player.Info.Coins -= int64(usegold)
 
 		case 1:
+			r := player.Service.Talk.Update(int(pro.ProductID), int(data.Count))
+			if !r {
+				return nil, errorcode.ErrorCodes.ErrGoldBeanSingleLimit
+			}
 			player.User.UpdateGold(player.Info.UserID, -int64(usegold))
 			//购买成功，执行记录
-			player.Service.Talk.Update(int(pro.ProductID), int(data.Count))
 
 		}
 
diff --git a/modules/player/service/talk.go b/modules/player/service/talk.go
index 80ae4a22b..0e5a6b735 100644
--- a/modules/player/service/talk.go
+++ b/modules/player/service/talk.go
@@ -77,19 +77,47 @@ func (s *TalkService) Cheak(mapid uint32, flag int) (int, bool) {
 	return int(talks.Count), true //int(config.MaxDailyCnt - talks.Count)
 
 }
-func (s *TalkService) Update(flag int, count int) {
+
+// Update 原子更新，返回是否更新成功（true=成功 false=上限/失败/VIP）
+func (s *TalkService) Update(flag int, count int) bool {
+	// VIP 直接返回失败
 	if cool.Config.ServerInfo.IsVip != 0 {
-
-		return
-	}
-	m := s.dbm(s.Model).Where("talk_id", flag)
-	if condition, _ := m.Exist(); !condition {
-		talks := model.NewTalk()
-		talks.PlayerID = uint64(s.userid)
-		talks.TalkID = uint32(flag)
-		s.dbm(s.Model).Data(talks).FieldsEx("id").Insert()
+		return false
 	}
 
-	s.dbm(s.Model).Where("talk_id", flag).Increment("count", count)
+	talkID := uint32(flag)
+	userID := uint64(s.userid)
+	db := s.dbm(s.Model)
 
+	// 1. 获取配置上限
+	cfg := config.NewTalkConfigService().GetCache(flag)
+	if cfg == nil {
+		return false
+	}
+	maxCount := int(cfg.DailyCollectCount)
+
+	// 2. 原子插入（不存在则插入，存在忽略，高并发安全）
+	talk := model.NewTalk()
+	talk.PlayerID = userID
+	talk.TalkID = talkID
+	_, _ = db.Data(talk).FieldsEx("id").InsertIgnore()
+
+	// 3. 原子条件自增：只有没超过上限才会更新
+	// 核心：数据库原子判断，绝对不溢出
+	affected, err := db.
+		Where("talk_id = ?", talkID).
+		Where("count + ? <= ?", count, maxCount).
+		Increment("count", count)
+	if err != nil {
+
+		return false
+	}
+	row, _ := affected.RowsAffected()
+	// 有错误 或 没有影响行数 = 更新失败（已达上限）
+	if row == 0 {
+
+		return false
+	}
+
+	return true
 }