From 9b2f51de66fdd85b99f5f19ec4738801c6bd65c3 Mon Sep 17 00:00:00 2001
From: guzeng <gz@flyrise.cn>
Date: Tue, 17 Aug 2021 18:47:25 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0sku=E6=9F=A5=E8=AF=A2?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 getskuinfo.go      | 74 ++++++++++++++++++++++++++++++++++++++++++++++
 getskuinfo_test.go | 15 ++++++++++
 2 files changed, 89 insertions(+)
 create mode 100644 getskuinfo.go
 create mode 100644 getskuinfo_test.go

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