去除日志

client.siteinfo.go

@@ -2,7 +2,6 @@ package siterpc
 
 import (
 	"encoding/json"
-	"log"
 	"strconv"
 	"time"
 
@@ -80,8 +79,6 @@ func GetSiteInfoByHost(host string, params ...string) (*SiteInfoRes, error) {
 
 	res_data, err := GetOrgData(res)
 
-	log.Println(res_data, err)
-
 	if err != nil {
 		return nil, err
 	}

code_bank.go

@@ -0,0 +1,57 @@
+package siterpc
+
+import (
+	"encoding/json"
+	"errors"
+)
+
+/**
+ * 获取code_bank一条可用记录
+ * 2021/09/09
+ * linsen
+ */
+func GetOneCode(site_id, dbname string, url ...string) (string, error) {
+
+	if dbname == "" {
+		return "", errors.New("参数错误")
+	}
+
+	conn, err := rpc_server_conn(url...)
+
+	if err != nil {
+		return "", err
+	}
+	defer conn.Close()
+
+	arg := SiteConfigItemReqArg{site_id, dbname, ""}
+
+	req, err := SetReqData(arg)
+	if err != nil {
+		return "", err
+	}
+	res := &Response{}
+
+	err = conn.GetOneCode(req, res)
+
+	if err != nil {
+		return "", err
+	}
+
+	res_data_de, err := GetResData(res)
+	if err != nil {
+		return "", err
+	}
+
+	var bankCode string
+	err = json.Unmarshal([]byte(res_data_de),&bankCode)
+
+	if err != nil {
+		return "", err
+	}
+
+	if res_data_de == "" {
+		return "", nil
+	}
+
+	return bankCode, nil
+}

code_bank_test.go

@@ -0,0 +1,9 @@
+package siterpc
+
+import "testing"
+
+func Test_getcode(t *testing.T){
+	res,err := GetOneCode("1058278","shop_v2")
+	t.Log(res)
+	t.Log(err)
+}

go.mod

@@ -6,7 +6,7 @@ require (
 	git.tetele.net/tgo/conf v0.33.1
 	git.tetele.net/tgo/crypter v0.2.2
 	git.tetele.net/tgo/helper v0.1.8
-	github.com/chai2010/protorpc v1.0.0
+	github.com/chai2010/protorpc v1.1.3
 	github.com/golang/protobuf v1.5.2
 	golang.org/x/crypto v0.0.0-20210616213533-5ff15b29337e // indirect
 )

go.sum

@@ -6,12 +6,16 @@ git.tetele.net/tgo/helper v0.1.8 h1:6eeUYmO0Xv2n+HluHKAOm6y2CcLmr2QPnGxzHy3yyWc=
 git.tetele.net/tgo/helper v0.1.8/go.mod h1:89mQwyfqZ+t8YXiVwzSxA70gLlUNqoZGDEUxvV46jXk=
 github.com/chai2010/protorpc v1.0.0 h1:aJ45G9sl1utSKo35EqnBSTs5jqTpdJDJAuZMMYPAtFo=
 github.com/chai2010/protorpc v1.0.0/go.mod h1:woR3WwjaQDqFjlzdVsFEKiK5Ur12QL8mYxVPjfr5z54=
+github.com/chai2010/protorpc v1.1.3 h1:VJK5hIoZn0XCGol0GmbxZkUG6FbTI5LP2Lam6RVd15w=
+github.com/chai2010/protorpc v1.1.3/go.mod h1:/wO0kiyVdu7ug8dCMrA2yDr2vLfyhsLEuzLa9J2HJ+I=
 github.com/golang/protobuf v1.0.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
 github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
 github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
 github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
 github.com/golang/snappy v0.0.0-20170215233205-553a64147049 h1:K9KHZbXKpGydfDN0aZrsoHpLJlZsBrGMFWbgLDGnPZk=
 github.com/golang/snappy v0.0.0-20170215233205-553a64147049/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/golang/snappy v0.0.3 h1:fHPg5GQYlCeLIPB9BZqMVR5nR9A+IM5zcgeTdjMYmLA=
+github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 golang.org/x/crypto v0.0.0-20210616213533-5ff15b29337e h1:gsTQYXdTw2Gq7RBsWvlQ91b+aEQ6bXFUngBGuR8sPpI=

site.pb.go

@@ -104,6 +104,7 @@ type SiteService interface {
 	GetSiteInfoByHost(in *Request, out *Response) error
 	GetAllConfig(in *Request, out *Response) error
 	GetGroupConfig(in *Request, out *Response) error
+	GetOneCode(in *Request, out *Response) error
 }
 
 // AcceptSiteServiceClient accepts connections on the listener and serves requests
@@ -193,6 +194,9 @@ func (c *SiteServiceClient) GetAllConfig(in *Request, out *Response) error {
 func (c *SiteServiceClient) GetGroupConfig(in *Request, out *Response) error {
 	return c.Call("SiteService.GetGroupConfig", in, out)
 }
+func (c *SiteServiceClient) GetOneCode(in *Request, out *Response) error {
+	return c.Call("SiteService.GetOneCode", in, out)
+}
 
 // DialSiteService connects to an SiteService at the specified network address.
 func DialSiteService(network, addr string) (*SiteServiceClient, *rpc.Client, error) {

site.proto

@@ -24,4 +24,5 @@ service SiteService {
     rpc getSiteInfoByHost(Request) returns (Response);//根据host获取站点关键信息
     rpc getAllConfig (Request) returns (Response);    // 查询所有配置信息
     rpc getGroupConfig (Request) returns (Response);    // 查询分组下所有配置信息
+    rpc getOneCode (Request) returns (Response);        // 获取code_bank未使用的一条code
 }