diff --git a/fans.client.go b/fans.client.go index d0d5a6f..ce50c4c 100644 --- a/fans.client.go +++ b/fans.client.go @@ -1,7 +1,5 @@ package userrpc -// "encoding/json" - /** * 绑定粉丝 * 2021/10/23 @@ -9,5 +7,69 @@ package userrpc */ func Fans(site_id, dbname, user_id, business_id string, url ...string) error { + conn, err := rpc_server_conn(url...) + if err != nil { + return err + } + defer conn.Close() + + data := FansReq{} + data.SiteId = site_id + data.Dbname = dbname + data.UserId = user_id + data.BusinessId = business_id + data.Lock = false + + req, err := SetReqData(data) + if err != nil { + return err + } + + res := &Response{} + + err = conn.Fans(req, res) + + if err != nil { + return err + } + + _, err = GetResData(res) + return nil +} + +/** + * 绑定粉丝 + * 2021/10/23 + * gz + */ +func LockFans(site_id, dbname, user_id, business_id string, url ...string) error { + + conn, err := rpc_server_conn(url...) + if err != nil { + return err + } + defer conn.Close() + + data := FansReq{} + data.SiteId = site_id + data.Dbname = dbname + data.UserId = user_id + data.BusinessId = business_id + data.Lock = true + + req, err := SetReqData(data) + if err != nil { + return err + } + + res := &Response{} + + err = conn.Fans(req, res) + + if err != nil { + return err + } + + _, err = GetResData(res) return nil } diff --git a/fans.client_test.go b/fans.client_test.go new file mode 100644 index 0000000..439d774 --- /dev/null +++ b/fans.client_test.go @@ -0,0 +1,16 @@ +package userrpc + +import ( + "testing" +) + +func Test_Fans(t *testing.T) { + + dbname := "shop_v2" + user_id := "6" + business_id := "5" + + err := LockFans("", dbname, user_id, business_id) + + t.Log(err) +}