From 92a8a51699f7f54a211bc465d4d1fdef815778ce Mon Sep 17 00:00:00 2001
From: listen <494177603@qq.com>
Date: Tue, 23 Nov 2021 16:53:53 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5=E6=9B=B4=E6=96=B0=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E4=BF=A1=E6=81=AF=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 account.client_test.go |  6 +++---
 user.client.go         | 49 ++++++++++++++++++++++++++++++++++++++++++
 user.client_test.go    | 15 +++++++++++++
 3 files changed, 67 insertions(+), 3 deletions(-)

diff --git a/account.client_test.go b/account.client_test.go
index 6c4bead..a453735 100644
--- a/account.client_test.go
+++ b/account.client_test.go
@@ -31,7 +31,7 @@ func Test_AddUserScore(t *testing.T) {
     userid := "2"
     score := "20"
 
-    ret, err := AddUserScore(dbname, userid, score)
+    ret, err := AddUserScore(dbname, userid, score,"")
     t.Log(ret)
     t.Log(err)
 }
@@ -71,7 +71,7 @@ func Test_AddUserUpgrade(t *testing.T) {
     userid := "5"
     upgrade := "100"
 
-    ret, err := AddUserUpgrade(dbname, userid, upgrade)
+    ret, err := AddUserUpgrade(dbname, userid, upgrade,"")
     t.Log(ret)
     t.Log(err)
 }
@@ -105,7 +105,7 @@ func Test_AddUserRedEnvelope(t *testing.T) {
     userid := "5"
     money := "20"
 
-    ret, err := AddUserRedEnvelope(dbname, userid, money)
+    ret, err := AddUserRedEnvelope(dbname, userid, money,"")
     t.Log(ret)
     t.Log(err)
 }
diff --git a/user.client.go b/user.client.go
index 11e54da..49b72e3 100644
--- a/user.client.go
+++ b/user.client.go
@@ -193,3 +193,52 @@ func GetById(site_id, dbname, user_id string, url ...string) (map[string]string,
 
 	return HandleUserRes(res)
 }
+
+
+/**
+ * 更新用户缓存
+ * 2021/11/23
+ * linsen
+ */
+func UpdateUserCache(site_id, dbname, user_id string, url ...string) (map[string]string, error) {
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	data := GetUserReq{}
+	data.SiteId = site_id
+	data.Dbname = dbname
+	data.UserId = user_id
+
+	data_json, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	encryData := crypter.DesEn(string(data_json), DES_KEY)
+
+	now_int64 := time.Now().Unix()
+
+	now := strconv.FormatInt(now_int64, 10)
+
+	sign := Sign(encryData, now)
+
+	req := &Request{
+		proto.String(encryData),
+		proto.String(now),
+		proto.String(sign),
+		nil}
+
+	res := &Response{}
+
+	err = conn.UpdateUserCache(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return HandleUserRes(res)
+}
diff --git a/user.client_test.go b/user.client_test.go
index bf50143..d7c1162 100644
--- a/user.client_test.go
+++ b/user.client_test.go
@@ -33,3 +33,18 @@ func Test_GetUserByToken(t *testing.T) {
 // 	t.Log(err)
 
 // }
+
+func Test_UpdateUserCache(t *testing.T){
+	dbname := "shop"
+
+	siteId := "1198881"
+
+	res,err := UpdateUserCache(siteId,dbname,"6")
+
+	if err != nil {
+		t.Error(err.Error())
+	}
+
+	t.Log(res)
+}
+