From 297dea7f40d5582d1aa2d4453cc256ec04da7ff3 Mon Sep 17 00:00:00 2001
From: meixiongfeng <766881921@qq.com>
Date: Tue, 6 Feb 2024 15:14:57 +0800
Subject: [PATCH] =?UTF-8?q?redis=20=E6=95=B0=E6=8D=AE=E6=B8=85=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 modules/pagoda/model_cycle.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/modules/pagoda/model_cycle.go b/modules/pagoda/model_cycle.go
index 57b675e54..a81507c10 100644
--- a/modules/pagoda/model_cycle.go
+++ b/modules/pagoda/model_cycle.go
@@ -77,6 +77,7 @@ func (this *ModelCycle) getCycelData() (data *pb.DBCycelData) {
 		cycelData *pb.DBCycelData
 		err       error
 	)
+
 	this.conflock.RLock()
 	cycelData = this.cycelData
 	this.conflock.RUnlock()
@@ -133,6 +134,15 @@ func (this *ModelCycle) refreshCycelData() (data *pb.DBCycelData, err error) {
 		"itype": data.Itype,
 		"etime": data.Etime,
 	})
+	tableName := fmt.Sprintf("%s-%s", db.CrossTag(), this.TableName)
+	// 清理缓存的redis 数据
+	_, err = this.DBModel.Redis.Keys(tableName)
+	if err == nil {
+		if model, err := this.module.GetCrossDBModel(this.TableName); err == nil {
+			err = model.Redis.Delete(tableName)
+		}
+	}
+
 	return
 }