From 357bf1c377f4810282847587050d72d1384b0507 Mon Sep 17 00:00:00 2001 From: guzeng Date: Fri, 22 Oct 2021 15:39:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E4=BB=98=E8=B0=83=E7=94=A8=E6=96=B9?= =?UTF-8?q?=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- payed.go | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++ payed_test.go | 25 ++++++++++++++++++++++++ 2 files changed, 78 insertions(+) create mode 100644 payed.go create mode 100644 payed_test.go diff --git a/payed.go b/payed.go new file mode 100644 index 0000000..966bbd7 --- /dev/null +++ b/payed.go @@ -0,0 +1,53 @@ +package orderrpcv2 + +import ( + "encoding/json" + "errors" +) + +func Payed(dbname, platform string, data map[string]interface{}, url ...string) (*OrderCancelRes, error) { + + if dbname == "" || len(data) < 1 { + return nil, errors.New("参数错误") + } + + conn, err := rpc_server_conn(url...) + if err != nil { + return nil, err + } + defer conn.Close() + + data["dbname"] = dbname + data["platform"] = platform + + req, err := SetReqData(data) + if err != nil { + return nil, err + } + res := &Response{} + + err = conn.Payed(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 OrderCancelRes + + err = json.Unmarshal([]byte(res_data_de), &res_arr) + + if err != nil { + return nil, err + } + + return &res_arr, nil + +} diff --git a/payed_test.go b/payed_test.go new file mode 100644 index 0000000..15328a2 --- /dev/null +++ b/payed_test.go @@ -0,0 +1,25 @@ +package orderrpcv2 + +import ( + "testing" +) + +func Test_Payed(t *testing.T) { + + payData := map[string]interface{}{ + "pay_type": "wechat", + "pay_method": "jsapi", + "order_sn": "2163040248896658", + "payment_sn": "ddddd", + "payer_total": 17.66, + "total": 33.33, //单位转为元 + "user_openid": "adfawrkepoieirpwoer", + "user_id": "55", + "success_time": "2021-10-12 10:20:30", + } + + ret, err := Payed("shop_v2", "miniapp", payData) + + t.Log(ret) + t.Log(err) +}