清除缓存

app/system/api/cache.go

@@ -11,7 +11,10 @@ import (
 	"gfast/app/common/api"
 	"gfast/app/common/global"
 	commService "gfast/app/common/service"
+	"github.com/gogf/gf/encoding/gbase64"
+	"github.com/gogf/gf/frame/g"
 	"github.com/gogf/gf/net/ghttp"
+	"github.com/gogf/gf/util/gconv"
 )
 
 type cache struct {
@@ -26,5 +29,32 @@ func (c *cache) Clear(r *ghttp.Request) {
 	cs.RemoveByTag(global.SysAuthTag)
 	cs.RemoveByTag(global.SysDictTag)
 	cs.RemoveByTag(global.SysConfigTag)
+	cacheRedis := g.Cfg().GetBool("redis.open")
+	if cacheRedis {
+		cursor := 0
+		for {
+			v, err := g.Redis().DoVar("scan", cursor, "match", global.CachePrefix+"*", "count", "100")
+			if err != nil {
+				c.FailJsonExit(r, err.Error())
+			}
+			data := gconv.SliceAny(v)
+			var dataSlice []string
+			err = gconv.Structs(data[1], &dataSlice)
+			if err != nil {
+				c.FailJsonExit(r, err.Error())
+			}
+			for _, d := range dataSlice {
+				dk := gbase64.MustDecodeToString(d)
+				_, err = g.Redis().DoVar("del", dk)
+				if err != nil {
+					c.FailJsonExit(r, err.Error())
+				}
+			}
+			cursor = gconv.Int(data[0])
+			if cursor == 0 {
+				break
+			}
+		}
+	}
 	c.SusJsonExit(r, "缓存清除成功")
 }