ソースを参照

清除店长缓存

abiao 5 年 前
コミット
a885a45f4c

+ 7 - 0
go/gopath/src/fohow.com/apps/controllers/railsadmin_controller/update_shop_application.go

@@ -5,6 +5,7 @@ import (
 	"fohow.com/apps"
 	"fohow.com/apps/models/balance_model"
 	"fohow.com/apps/models/user_model"
+	"fohow.com/cache"
 	"github.com/astaxie/beego"
 	"strconv"
 	"time"
@@ -42,6 +43,12 @@ func (self *RailsadminController) UpdateShopApplication() {
 	//更改下级会员群主ID
 	inviteList := user_model.GetWxUsersByInviteIdAll(wxUser.Id, false)
 	go user_model.UpdateClass(inviteList, wxUser.Id, wxUser.IntroUserId)
+
+	//消除user,wxuser缓存
+	userKey := fmt.Sprintf("user.GetByUid[%d]", wxUser.UserId)
+	wxUserKey := cache.GetKey(cache.GetWxUserById, wxUser.Id)
+	cache.Cache.Delete(userKey)
+	cache.Cache.Delete(wxUserKey)
 	self.ServeJSON()
 }
 

+ 5 - 4
go/gopath/src/fohow.com/apps/helpers/redis_helper.go

@@ -53,7 +53,6 @@ func GetRedisValue(key string, resp interface{}) (bool, interface{}) {
 		Password: beego.AppConfig.String("AliRedisPwd"), //默认空密码
 		DB:       db,                                    //使用默认数据库
 	})
-	beego.BeeLogger.Info("Connect redis name (%s), pwd=%s", beego.AppConfig.String("AliRedisHost"), beego.AppConfig.String("AliRedisPwd"))
 	defer client.Close() //最后关闭
 	_, err = client.Ping().Result()
 	if err != nil {
@@ -64,9 +63,11 @@ func GetRedisValue(key string, resp interface{}) (bool, interface{}) {
 	if err != nil {
 		return false, ""
 	}
-	beego.BeeLogger.Info("result 返回字符:%s", val)
-	json.Unmarshal([]byte(val), &resp)
-
+	//beego.BeeLogger.Info("result 返回字符:%s", val)
+	err = json.Unmarshal([]byte(val), &resp)
+	if err != nil {
+		return false, ""
+	}
 	return true, resp
 }