修改fans调用

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
 }

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