修改查询条件

client.info.go

@@ -0,0 +1,94 @@
+package supplierrpc
+
+import (
+	"encoding/json"
+	"errors"
+)
+
+func Get(site_id, dbname, id string, field string, url ...string) (map[string]string, error) {
+
+	if dbname == "" || id == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	arg := ReqParam{site_id, dbname, id, field}
+
+	req, err := SetReqData(arg)
+	if err != nil {
+		return nil, err
+	}
+	res := &Response{}
+
+	err = conn.Get(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}
+
+func Get380Star(site_id, dbname string, field string, url ...string) (map[string]string, error) {
+
+	if dbname == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	arg := ReqParam{site_id, dbname, "", field}
+
+	req, err := SetReqData(arg)
+	if err != nil {
+		return nil, err
+	}
+	res := &Response{}
+
+	err = conn.Get380Star(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr map[string]string
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return res_arr, nil
+
+}

client.info_test.go

@@ -0,0 +1,16 @@
+package supplierrpc
+
+import (
+	"testing"
+)
+
+func Test_Get(t *testing.T) {
+	siteid := "1056475"
+	dbname := "shop_v2"
+	key := "*"
+
+	res, err := Get380Star(siteid, dbname, key)
+	t.Log(res)
+	t.Log(err)
+
+}

client.is_open.go

@@ -0,0 +1,50 @@
+package supplierrpc
+
+import (
+	"encoding/json"
+	"errors"
+)
+
+func IsOpen(site_id, dbname, id string, url ...string) (*BoolRet, error) {
+
+	if dbname == "" || id == "" {
+		return nil, errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+	if err != nil {
+		return nil, err
+	}
+	defer conn.Close()
+
+	arg := GetParam{site_id, dbname, id}
+
+	req, err := SetReqData(arg)
+	if err != nil {
+		return nil, err
+	}
+	res := &Response{}
+
+	err = conn.IsOpen(req, res)
+
+	if err != nil {
+		return nil, err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return nil, err
+	}
+	if res_data_de == "" {
+		return nil, nil
+	}
+	var res_arr BoolRet
+
+	err = json.Unmarshal([]byte(res_data_de), &res_arr)
+
+	if err != nil {
+		return nil, err
+	}
+	return &res_arr, nil
+
+}

client.is_open_test.go

@@ -0,0 +1,17 @@
+package supplierrpc
+
+import (
+	"testing"
+)
+
+func Test_IsOpen(t *testing.T) {
+	siteid := "1056475"
+	dbname := "shop_v2"
+	key := "1"
+
+	res, err := IsOpen(siteid, dbname, key)
+	t.Log(res)
+	t.Log(res.Value)
+	t.Log(err)
+
+}

conn.go

@@ -0,0 +1,25 @@
+package supplierrpc
+
+import (
+	"git.tetele.net/tgo/conf"
+)
+
+func rpc_server_conn(url ...string) (*SupplierServiceClient, error) {
+
+	var rpc_url string
+	if len(url) > 0 && url[0] != "" {
+		rpc_url = url[0]
+	} else if conf.SUPPLIER_RPC_URL != "" {
+		rpc_url = conf.SUPPLIER_RPC_URL
+	} else {
+		rpc_url = "127.0.0.1:" + conf.SUPPLIER_RPC_PORT
+	}
+
+	conn, _, err := DialSupplierService("tcp", rpc_url)
+	if err != nil {
+		return nil, err
+	}
+
+	return conn, nil
+
+}

supplier.pb.go

@@ -101,6 +101,7 @@ type SupplierService interface {
 	Get(in *Request, out *Response) error
 	GetByUuid(in *Request, out *Response) error
 	IsOpen(in *Request, out *Response) error
+	Get380Star(in *Request, out *Response) error
 }
 
 // AcceptSupplierServiceClient accepts connections on the listener and serves requests
@@ -181,6 +182,9 @@ func (c *SupplierServiceClient) GetByUuid(in *Request, out *Response) error {
 func (c *SupplierServiceClient) IsOpen(in *Request, out *Response) error {
 	return c.Call("SupplierService.IsOpen", in, out)
 }
+func (c *SupplierServiceClient) Get380Star(in *Request, out *Response) error {
+	return c.Call("SupplierService.Get380Star", in, out)
+}
 
 // DialSupplierService connects to an SupplierService at the specified network address.
 func DialSupplierService(network, addr string) (*SupplierServiceClient, *rpc.Client, error) {

supplier.proto

@@ -20,4 +20,5 @@ service SupplierService {
     rpc Get (Request) returns (Response);    // 使用id查询
     rpc GetByUuid (Request) returns (Response);    // 使用uuid查询
     rpc IsOpen (Request) returns (Response);    // 是否营业中
+    rpc Get380Star (Request) returns (Response);    // 查询380star供应商数据
 }

variable.go

@@ -12,8 +12,16 @@ type GetUuidParam struct {
 	SiteId string `json:"site_id"`
 	Dbname string `json:"database"`
 	Uuid   string `json:"uuid"`
+	Field  string `json:"field"`
 }
 type BoolRet struct {
 	Value bool   `json:"value"`
 	Msg   string `json:"msg"`
 }
+
+type ReqParam struct {
+	SiteId string `json:"site_id"`
+	Dbname string `json:"database"`
+	Id     string `json:"id"`
+	Field  string `json:"field"`
+}