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) +} +