diff --git a/worldsrv/welfmgr.go b/worldsrv/welfmgr.go
index d1d4295..671ee0e 100644
--- a/worldsrv/welfmgr.go
+++ b/worldsrv/welfmgr.go
@@ -1937,6 +1937,19 @@ func (this *WelfareMgr) UpdateDiamondBankData(p *Player, coinNum int64, isWin bo
 	diamondStr := fmt.Sprintf("%.4f", addDiamond)
 	addDiamond, _ = strconv.ParseFloat(diamondStr, 64)
 	p.WelfData.DiamondBank.BankDiamond += addDiamond
+	pool := srvdata.PBDB_PigBank_DiamondMgr.Datas.GetArr()
+	infoData := pool[0]
+	for _, data := range pool {
+		if p.WelfData.DiamondBank.DayBuyTimes+1 >= data.BuyCountMin && p.WelfData.DiamondBank.DayBuyTimes+1 <= data.BuyCountMax {
+			infoData = data
+			break
+		}
+	}
+
+	BankMaxDiamond := int64(infoData.MaxDiamond)
+	if p.WelfData.DiamondBank.BankDiamond >= float64(BankMaxDiamond) {
+		p.WelfData.DiamondBank.BankDiamond = float64(BankMaxDiamond)
+	}
 	logger.Logger.Tracef("玩家更新钻石存储罐数据 snid = %d,coinNum = %d,isWin = %s,当前钻石存储罐钻石数量：%f，本次增加钻石数量:%f", p.SnId, coinNum, isWin, p.WelfData.DiamondBank.BankDiamond, addDiamond)
 }
 func (this *WelfareMgr) Update() {