diff --git a/getskuinfo.go b/getskuinfo.go new file mode 100644 index 0000000..e33d025 --- /dev/null +++ b/getskuinfo.go @@ -0,0 +1,74 @@ +package productrpc + +import ( + "encoding/json" + // "strconv" + // "time" + "github.com/golang/protobuf/proto" +) + +/** + * id获取商品sku信息 + * 2021/08/20 + * GZ + */ +func GetSku(dbname, id string, url ...string) (map[string]string, error) { + + conn, err := rpc_server_conn(url...) + if err != nil { + return nil, err + } + defer conn.Close() + + req := &GetRequest{proto.String(dbname), proto.String(id), nil} + + res := &GetResponse{} + + err = conn.GetSku(req, res) + + if err != nil { + return nil, err + } + + value := res.GetValue() + + var data map[string]string + + err = json.Unmarshal(value, &data) + + return data, err + +} + +/** + * uuid获取商品sku信息 + * 2021/08/20 + * GZ + */ +func GetSkuByUuid(dbname, uuid string, url ...string) (map[string]string, error) { + + conn, err := rpc_server_conn(url...) + if err != nil { + return nil, err + } + defer conn.Close() + + req := &GetUuidRequest{proto.String(dbname), proto.String(uuid), nil} + + res := &GetResponse{} + + err = conn.GetSkuByUuid(req, res) + + if err != nil { + return nil, err + } + + value := res.GetValue() + + var data map[string]string + + err = json.Unmarshal(value, &data) + + return data, err + +} diff --git a/getskuinfo_test.go b/getskuinfo_test.go new file mode 100644 index 0000000..837b0ca --- /dev/null +++ b/getskuinfo_test.go @@ -0,0 +1,15 @@ +package productrpc + +import ( + "testing" +) + +func Test_GetSku(t *testing.T) { + dbname := "shop_v2" + id := "10" + + ret, err := GetSku(dbname, id) + + t.Log(ret) + t.Log(err) +}