From aa2d29032f3b1eecf2c92fa6cefd0c4d9ac4c3bb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Thu, 4 Jul 2024 14:27:28 +0800 Subject: [PATCH] =?UTF-8?q?plugin=20=E4=BA=91=E9=97=AA=E4=BB=98=EF=BC=8C?= =?UTF-8?q?=E4=B8=8B=E5=8D=95=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- plugins/union_pay/go.mod | 37 ++++++ plugins/union_pay/go.sum | 70 +++++++++++ plugins/union_pay/internal/po/notify.go | 11 ++ plugins/union_pay/internal/po/order.go | 38 ++++++ plugins/union_pay/internal/po/po.go | 74 ++++++++++++ plugins/union_pay/internal/po/query.go | 18 +++ plugins/union_pay/internal/transform.go | 71 ++++++++++++ plugins/union_pay/internal/union_pay.go | 54 +++++++++ plugins/union_pay/internal/union_pay_test.go | 87 ++++++++++++++ plugins/union_pay/internal/util.go | 35 ++++++ plugins/union_pay/internal/utils/rsa.go | 28 +++++ plugins/union_pay/internal/utils/sha.go | 29 +++++ plugins/union_pay/internal/utils/sign.go | 68 +++++++++++ plugins/union_pay/internal/utils/sign_test.go | 22 ++++ plugins/union_pay/internal/vo/code.go | 9 ++ plugins/union_pay/internal/vo/status.go | 43 +++++++ plugins/union_pay/internal/vo/sub_code.go | 109 ++++++++++++++++++ plugins/union_pay/main.go | 15 +++ .../zltx/internal/vo/{result.go => code.go} | 0 plugins/zltx/internal/zltx.go | 3 +- 20 files changed, 819 insertions(+), 2 deletions(-) create mode 100644 plugins/union_pay/go.mod create mode 100644 plugins/union_pay/go.sum create mode 100644 plugins/union_pay/internal/po/notify.go create mode 100644 plugins/union_pay/internal/po/order.go create mode 100644 plugins/union_pay/internal/po/po.go create mode 100644 plugins/union_pay/internal/po/query.go create mode 100644 plugins/union_pay/internal/transform.go create mode 100644 plugins/union_pay/internal/union_pay.go create mode 100644 plugins/union_pay/internal/union_pay_test.go create mode 100644 plugins/union_pay/internal/util.go create mode 100644 plugins/union_pay/internal/utils/rsa.go create mode 100644 plugins/union_pay/internal/utils/sha.go create mode 100644 plugins/union_pay/internal/utils/sign.go create mode 100644 plugins/union_pay/internal/utils/sign_test.go create mode 100644 plugins/union_pay/internal/vo/code.go create mode 100644 plugins/union_pay/internal/vo/status.go create mode 100644 plugins/union_pay/internal/vo/sub_code.go create mode 100644 plugins/union_pay/main.go rename plugins/zltx/internal/vo/{result.go => code.go} (100%) diff --git a/plugins/union_pay/go.mod b/plugins/union_pay/go.mod new file mode 100644 index 0000000..24d4343 --- /dev/null +++ b/plugins/union_pay/go.mod @@ -0,0 +1,37 @@ +module plugins/union_pay + +go 1.21 + +require ( + codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin v0.0.0-20240703025635-39098bff7a4c + github.com/carlmjohnson/requests v0.23.5 + github.com/go-playground/validator/v10 v10.22.0 + github.com/hashicorp/go-plugin v1.6.1 + github.com/stretchr/testify v1.9.0 +) + +require ( + github.com/davecgh/go-spew v1.1.1 // indirect + github.com/envoyproxy/protoc-gen-validate v1.0.4 // indirect + github.com/fatih/color v1.7.0 // indirect + github.com/gabriel-vasile/mimetype v1.4.3 // indirect + github.com/go-playground/locales v0.14.1 // indirect + github.com/go-playground/universal-translator v0.18.1 // indirect + github.com/golang/protobuf v1.5.4 // indirect + github.com/hashicorp/go-hclog v0.14.1 // indirect + github.com/hashicorp/yamux v0.1.1 // indirect + github.com/leodido/go-urn v1.4.0 // indirect + github.com/mattn/go-colorable v0.1.4 // indirect + github.com/mattn/go-isatty v0.0.10 // indirect + github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77 // indirect + github.com/oklog/run v1.0.0 // indirect + github.com/pmezard/go-difflib v1.0.0 // indirect + golang.org/x/crypto v0.21.0 // indirect + golang.org/x/net v0.22.0 // indirect + golang.org/x/sys v0.18.0 // indirect + golang.org/x/text v0.14.0 // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237 // indirect + google.golang.org/grpc v1.64.0 // indirect + google.golang.org/protobuf v1.34.2 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect +) diff --git a/plugins/union_pay/go.sum b/plugins/union_pay/go.sum new file mode 100644 index 0000000..22db8c8 --- /dev/null +++ b/plugins/union_pay/go.sum @@ -0,0 +1,70 @@ +codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin v0.0.0-20240703025635-39098bff7a4c h1:JnLzT0jm8viTbNMdMuC+sVQJJnVHo9K+OZ6JouLq118= +codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin v0.0.0-20240703025635-39098bff7a4c/go.mod h1:QdW8HjHYQN8LCkFAB9e4oh7HziePCYnDXnUaKtmb8iQ= +github.com/bufbuild/protocompile v0.4.0 h1:LbFKd2XowZvQ/kajzguUp2DC9UEIQhIq77fZZlaQsNA= +github.com/bufbuild/protocompile v0.4.0/go.mod h1:3v93+mbWn/v3xzN+31nwkJfrEpAUwp+BagBSZWx+TP8= +github.com/carlmjohnson/requests v0.23.5 h1:NPANcAofwwSuC6SIMwlgmHry2V3pLrSqRiSBKYbNHHA= +github.com/carlmjohnson/requests v0.23.5/go.mod h1:zG9P28thdRnN61aD7iECFhH5iGGKX2jIjKQD9kqYH+o= +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/envoyproxy/protoc-gen-validate v1.0.4 h1:gVPz/FMfvh57HdSJQyvBtF00j8JU4zdyUgIUNhlgg0A= +github.com/envoyproxy/protoc-gen-validate v1.0.4/go.mod h1:qys6tmnRsYrQqIhm2bvKZH4Blx/1gTIZ2UKVY1M+Yew= +github.com/fatih/color v1.7.0 h1:DkWD4oS2D8LGGgTQ6IvwJJXSL5Vp2ffcQg58nFV38Ys= +github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4= +github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0= +github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk= +github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s= +github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4= +github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA= +github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY= +github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY= +github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY= +github.com/go-playground/validator/v10 v10.22.0 h1:k6HsTZ0sTnROkhS//R0O+55JgM8C4Bx7ia+JlgcnOao= +github.com/go-playground/validator/v10 v10.22.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM= +github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= +github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= +github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= +github.com/hashicorp/go-hclog v0.14.1 h1:nQcJDQwIAGnmoUWp8ubocEX40cCml/17YkF6csQLReU= +github.com/hashicorp/go-hclog v0.14.1/go.mod h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ= +github.com/hashicorp/go-plugin v1.6.1 h1:P7MR2UP6gNKGPp+y7EZw2kOiq4IR9WiqLvp0XOsVdwI= +github.com/hashicorp/go-plugin v1.6.1/go.mod h1:XPHFku2tFo3o3QKFgSYo+cghcUhw1NA1hZyMK0PWAw0= +github.com/hashicorp/yamux v0.1.1 h1:yrQxtgseBDrq9Y652vSRDvsKCJKOUD+GzTS4Y0Y8pvE= +github.com/hashicorp/yamux v0.1.1/go.mod h1:CtWFDAQgb7dxtzFs4tWbplKIe2jSi3+5vKbgIO0SLnQ= +github.com/jhump/protoreflect v1.15.1 h1:HUMERORf3I3ZdX05WaQ6MIpd/NJ434hTp5YiKgfCL6c= +github.com/jhump/protoreflect v1.15.1/go.mod h1:jD/2GMKKE6OqX8qTjhADU1e6DShO+gavG9e0Q693nKo= +github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ= +github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI= +github.com/mattn/go-colorable v0.1.4 h1:snbPLB8fVfU9iwbbo30TPtbLRzwWu6aJS6Xh4eaaviA= +github.com/mattn/go-colorable v0.1.4/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE= +github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s= +github.com/mattn/go-isatty v0.0.10 h1:qxFzApOv4WsAL965uUPIsXzAKCZxN2p9UqdhFS4ZW10= +github.com/mattn/go-isatty v0.0.10/go.mod h1:qgIWMr58cqv1PHHyhnkY9lrL7etaEgOFcMEpPG5Rm84= +github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77 h1:7GoSOOW2jpsfkntVKaS2rAr1TJqfcxotyaUcuxoZSzg= +github.com/mitchellh/go-testing-interface v0.0.0-20171004221916-a61a99592b77/go.mod h1:kRemZodwjscx+RGhAo8eIhFbs2+BFgRtFPeD/KE+zxI= +github.com/oklog/run v1.0.0 h1:Ru7dDtJNOyC66gQ5dQmaCa0qIsAUFY3sFpK1Xk8igrw= +github.com/oklog/run v1.0.0/go.mod h1:dlhp/R75TPv97u0XWUtDeV/lRKWPKSdTuV0TZvrmrQA= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs= +github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= +github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +golang.org/x/crypto v0.21.0 h1:X31++rzVUdKhX5sWmSOFZxx8UW/ldWx55cbf08iNAMA= +golang.org/x/crypto v0.21.0/go.mod h1:0BP7YvVV9gBbVKyeTG0Gyn+gZm94bibOW5BjDEYAOMs= +golang.org/x/net v0.22.0 h1:9sGLhx7iRIHEiX0oAJ3MRZMUCElJgy7Br1nO+AMN3Tc= +golang.org/x/net v0.22.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg= +golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20191008105621-543471e840be/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4= +golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237 h1:NnYq6UN9ReLM9/Y01KWNOWyI5xQ9kbIms5GGJVwS/Yc= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237/go.mod h1:WtryC6hu0hhx87FDGxWCDptyssuo68sk10vYjF+T9fY= +google.golang.org/grpc v1.64.0 h1:KH3VH9y/MgNQg1dE7b3XfVK0GsPSIzJwdF617gUSbvY= +google.golang.org/grpc v1.64.0/go.mod h1:oxjF8E3FBnjp+/gVFYdWacaLDx9na1aqy9oovLpxQYg= +google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg= +google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/plugins/union_pay/internal/po/notify.go b/plugins/union_pay/internal/po/notify.go new file mode 100644 index 0000000..8535670 --- /dev/null +++ b/plugins/union_pay/internal/po/notify.go @@ -0,0 +1,11 @@ +package po + +import "plugins/union_pay/internal/vo" + +type Notify struct { + MerchantId int `json:"merchantId" validate:"required"` + OutTradeNo string `json:"outTradeNo" validate:"required"` + RechargeAccount string `json:"rechargeAccount" validate:"required"` + Status vo.OrderStatus `json:"status" validate:"required"` + Sign string `json:"sign" validate:"required"` +} diff --git a/plugins/union_pay/internal/po/order.go b/plugins/union_pay/internal/po/order.go new file mode 100644 index 0000000..5ef21d3 --- /dev/null +++ b/plugins/union_pay/internal/po/order.go @@ -0,0 +1,38 @@ +package po + +import ( + "fmt" + "plugins/union_pay/internal/vo" +) + +type OrderReq struct { + ChNlId string `validate:"required" json:"chnlId"` // 渠道方代码-必填 + Qid string `validate:"required" json:"qid"` // 外部接入方定义的主键，保证唯一，即流水号，用于幂等校验 + OrderDt string `validate:"required" json:"orderDt"` // 请求日期-格式为yyyyMMdd + // 银联营销平台用于上下文串联，取值可与QID相同，不强制校验是否唯一,-请求跟踪号 + TraceId string `validate:"required" json:"traceId"` + // 优惠券ID-票券活动ID，由银联营销平台生成，31打头的16位数字 ，同优惠券状态通知接口的couponId + DiscountId string `validate:"required" json:"discountId"` + // 01：手机号维度；02：卡号维度；03：云闪付注册用户ID维度；05：外部用户ID维度；06：网络支付平台用户。 + // 07：证件号用户维度。票券的账户维度，同一个优惠券ID下的优惠券，其发放维度与核销维度一致，银行需确保支付交易中上送对应的要素。 + EntityTp string `validate:"required" json:"entityTp"` + // 当entityTp为03时，cardNo、mobile、openId三选一必填；当entityTp为01时，mobile必填 该参数已配置加密规则：SM4 + Mobile string `validate:"required" json:"mobile"` + Cmd string `validate:"required" json:"cmd"` + AccessId string `validate:"required" json:"accessId"` + DiscountNum uint32 `validate:"required" json:"discountNum"` +} + +type OrderResp struct { + Code vo.Code `json:"code"` + Msg string `json:"msg"` + SubCode vo.SubCode `json:"subCode"` + SubMsg string `json:"subMsg"` + DiscountId string `json:"discountId"` + Qid string `json:"qid"` + CouponCd string `json:"couponCd"` +} + +func (o *OrderResp) GetMsg() string { + return fmt.Sprintf("Msg:%s,SubMsg:%s,自定处理msg:%s", o.Msg, o.SubMsg, o.SubCode.GetMsg()) +} diff --git a/plugins/union_pay/internal/po/po.go b/plugins/union_pay/internal/po/po.go new file mode 100644 index 0000000..7cff32b --- /dev/null +++ b/plugins/union_pay/internal/po/po.go @@ -0,0 +1,74 @@ +package po + +import ( + "encoding/json" + "fmt" + "github.com/go-playground/validator/v10" +) + +type Req interface { + Validate() error + GetReId() string + ToJson() []byte +} + +var _ Req = (*OrderReq)(nil) +var _ Req = (*QueryReq)(nil) +var _ Req = (*Notify)(nil) + +func (req *OrderReq) Validate() error { + err := validator.New().Struct(req) + if err != nil { + for _, err = range err.(validator.ValidationErrors) { + return fmt.Errorf("参数有误：" + err.Error()) + } + } + return nil +} + +func (req *OrderReq) GetReId() string { + return req.Qid +} + +func (req *OrderReq) ToJson() []byte { + b, _ := json.Marshal(req) + return b +} + +func (req *QueryReq) Validate() error { + err := validator.New().Struct(req) + if err != nil { + for _, err = range err.(validator.ValidationErrors) { + return fmt.Errorf("参数有误：" + err.Error()) + } + } + return nil +} + +func (req *QueryReq) GetReId() string { + return "" +} + +func (req *QueryReq) ToJson() []byte { + b, _ := json.Marshal(req) + return b +} + +func (req *Notify) Validate() error { + err := validator.New().Struct(req) + if err != nil { + for _, err = range err.(validator.ValidationErrors) { + return fmt.Errorf("参数有误：" + err.Error()) + } + } + return nil +} + +func (req *Notify) GetReId() string { + return "" +} + +func (req *Notify) ToJson() []byte { + b, _ := json.Marshal(req) + return b +} diff --git a/plugins/union_pay/internal/po/query.go b/plugins/union_pay/internal/po/query.go new file mode 100644 index 0000000..7240475 --- /dev/null +++ b/plugins/union_pay/internal/po/query.go @@ -0,0 +1,18 @@ +package po + +import "plugins/union_pay/internal/vo" + +type QueryReq struct { + MerchantId string `validate:"required"` + OutTradeNo string `validate:"required"` + TimeStamp int64 `validate:"required"` + Version string `validate:"required"` + Sign string +} + +type QueryResp struct { + Code vo.Code `json:"code"` + Status vo.OrderStatus `json:"status"` + Message string `json:"message"` + OutTradeNo string `json:"outTradeNo"` +} diff --git a/plugins/union_pay/internal/transform.go b/plugins/union_pay/internal/transform.go new file mode 100644 index 0000000..5a03d08 --- /dev/null +++ b/plugins/union_pay/internal/transform.go @@ -0,0 +1,71 @@ +package internal + +import ( + "codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin/proto" + "encoding/json" + "plugins/union_pay/internal/po" +) + +type Config struct { + Config *proto.Config + Extra *ConfigExtra +} + +type ConfigExtra struct { + ChNlId string `json:"chnlId"` // 渠道方代码 + IV string `json:"iv"` // 加密密钥 + KEY string `json:"key"` // 加密密钥 + RsaPrk string `json:"rsa_prk"` // 私钥 + RsaNpk string `json:"rsa_npk"` // 回调公钥 +} + +func transformConfig(config *proto.Config) (*Config, error) { + var extra ConfigExtra + err := json.Unmarshal(config.Extra, &extra) + if err != nil { + return nil, err + } + return &Config{ + Config: config, + Extra: &extra, + }, nil +} + +func rechargeReq(in *proto.OrderRequest, chNlId string) *po.OrderReq { + type Extra struct { + OrderDt string `json:"orderDt"` + } + var e Extra + _ = json.Unmarshal(in.Order.Extra, &e) + + return &po.OrderReq{ + Cmd: "couponAcquire", + AccessId: "UP", + EntityTp: "03", + + ChNlId: chNlId, + Qid: in.Order.OrderNo, + OrderDt: e.OrderDt, + TraceId: in.Order.OrderNo, + DiscountId: in.Product.ProductNo, + Mobile: in.Order.Account, + DiscountNum: in.Order.Quantity, + } +} + +func rechargeResp(request *proto.OrderRequest, resp po.OrderResp) *proto.OrderResponse { + data, _ := json.Marshal(resp) + result := &proto.Result{ + OrderNo: request.Order.OrderNo, + TradeNo: resp.CouponCd, + Message: resp.Msg, + Data: data, + } + if !resp.Code.IsSuccess() { + result.Status = proto.Status_FAIL + result.Message = resp.GetMsg() + } else { + result.Status = proto.Status_ING + } + return &proto.OrderResponse{Result: result} +} diff --git a/plugins/union_pay/internal/union_pay.go b/plugins/union_pay/internal/union_pay.go new file mode 100644 index 0000000..aa75b52 --- /dev/null +++ b/plugins/union_pay/internal/union_pay.go @@ -0,0 +1,54 @@ +package internal + +import ( + "codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin/proto" + "context" + "fmt" + "github.com/carlmjohnson/requests" + "plugins/union_pay/internal/po" +) + +// 插件通信信息,若不对应则会报错panic +const ( + Tag = "union_pay" + Version = 1 + CookieKey = "union_pay" + CookieValue = "union_pay" +) + +const ( + orderMethod = "/upapi/mkt/cpn/couponAcquire/v1" + orderBizMethod = "mkt.cpn.couponAcquire.v1" +) + +const ( + queryMethod = "/upapi/mkt/cpn/couponAcqQuery/v1" + queryBizMethod = "mkt.cpn.couponAcqQuery.v1" +) + +type UnionPayService struct{} + +func (p *UnionPayService) Order(ctx context.Context, request *proto.OrderRequest) (*proto.OrderResponse, error) { + conf, err := transformConfig(request.Config) + if err != nil { + return nil, err + } + uv := rechargeReq(request, conf.Extra.ChNlId) + + var response po.OrderResp + url := fmt.Sprintf("%s%s", request.Config.BaseUri, orderMethod) + err = requests.URL(url).Headers(headers(conf, uv, orderBizMethod)).BodyJSON(uv).ToJSON(&response).Fetch(ctx) + if err != nil { + return nil, fmt.Errorf("请求异常，msg:" + err.Error()) + } + + return rechargeResp(request, response), nil +} + +func (p *UnionPayService) Query(ctx context.Context, request *proto.QueryRequest) (*proto.QueryResponse, error) { + return nil, nil +} + +func (p *UnionPayService) Notify(_ context.Context, request *proto.NotifyRequest) (*proto.NotifyResponse, error) { + return nil, nil +} diff --git a/plugins/union_pay/internal/union_pay_test.go b/plugins/union_pay/internal/union_pay_test.go new file mode 100644 index 0000000..308fe42 --- /dev/null +++ b/plugins/union_pay/internal/union_pay_test.go @@ -0,0 +1,87 @@ +package internal + +import ( + "codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin/proto" + "context" + "fmt" + "github.com/stretchr/testify/assert" + "testing" +) + +var appId = "up_49pau3fu6latj_03h" +var appKey = "" +var baseUri = "https://openapi.unionpay.com" +var notifyUrl = "" + +var server = &UnionPayService{} + +var config = &proto.Config{ + AppId: appId, + AppKey: appKey, + BaseUri: baseUri, + NotifyUrl: notifyUrl, + Extra: []byte(`{"chnlId":"8091","iv":"0123456789123456","key":"16fb034dead44ff6f599b1ca373ccfd1", +"rsa_prk":"MIIEogIBAAKCAQEAllAo3AbVfNg1iDT3CisgueIm2Pya2C6qatF0S8/aAKW8A6HBIuvrk1sb2TjbI0UDVowaNDsPa7nNdZHkQa6CQKf2BwFRy7gB8vAD1YSq23NTwplGe5IpuRe2Cbljh5diQ/+0zwZPZQEvjSMqZJILYVluGBw656JSndRdXHCs608CBib14l35A6D7rSZNd53nM9yXj/WOpLuY/jX0sbKJrBUIhcQcMiCFK/Nx06vhhCGZSWwaj0TTSMEOj9nyU+56MMx+N7527JUnOYMyVbbEx5h1S5sPjntMVVzz8c8FC5MKbgXCgjTt5Depl6YgrvoSCNNXZqnXN2l9dtBxKGSEdQIDAQABAoIBAD7r606/pZqPP0l3MnqVNyvY2X43r/ITBs+UQmSB67Ydqqiyi5C8xW530x6JSGJpP055c3atynTD4Jf4rF46WNgL91dTXBQ1QMubYV9+G6+lhUiOtQyBUOnkXRWQ/3MBEed5IQ0QjSew6WDheZuD7zOfJhD9sELKll7vSO2rVRdi5Kf3pps0K4aeYLvlelHjPtu2EkMyAD4d37QO2q8A/+acOf7wyx1uZ55nobe0jVgQBa2Tuuwhd2JilmsgMvcVxeAJoocyQxPVTU+iMidgZKxyW/fJUaR7V2KgKfP0H2OZbSruD2HyHL7o70+/XBg250msh691oTCXSGWiITFXRDkCgYEA1KF3daSzWK2vTZeNMxj++VRNZfyigNqBwgRZxrSGIUeNGpDdDp7flldM/fO/0RijKnh+nXLBCMZlxffSI7W3jkkjosEq0uyXv6Ez4WlhwHEAE6KrZYQ8VDU3We1LXERu/3SMU16Uq2Vme8J6kpshr7OLGeuTNfsSG79lpHU/OO8CgYEAtPjF/AY/t85u4JV0w6FJ/K7Iya+AyIyZhsgnxsPv5NwVtNsQzTRbXlpgnVmaKUXzLBTBJA2P6Gie35R6kJuOuMnvHjtG7umI5lOUJaqYk5GZEXHxbIKTXUxAbv+WKRHcFwcH54Ppurs7bN6ultWdE+yyU5PvabFRAidL+rV+MNsCgYBkqx2XwSZ4MaLxpXLgYlE1UkhipL17K/iLFuw6O3XVg762eSdvqKBK2YJGKYUDRhraHLo1aQMjWGsO00nWRk5lOxN4FuRjgEhIHdYmPnJdXiKfKUDkizrU020lUkd/o5a5s0BMqFbS3usqZOULTA8i1GpjFzlXMUtdf7xrpGcOWQKBgFJXWuX4Befg8owXFKCqc1qYQF2cEBGv/27XBVon7rAH/4xhnHxx1RzSLGGL0lvzKtikvNhln1PUvmzmRvoi/UZRAw6TVAwCkDqUTrTwsSl7ttS8Lmf75Ycu2aZnfnBDYwvLNCp/18oRxNEdZPzWRvk42k6y4d0KQ9yh+q0hBUC/AoGASgJro5HgKWkSzYx1Fk3rvo7EWeZwXNfWuzIhtCiVDG4+df0ZdybkbjxbaRwL2rbTSBeqSaZw4UwpE1JyF8erfzx0qpHCY5V3ocnA8kg56mX9kE5H9WKjMe1tbuZpba4i08zvM8vpz9gASf3z/WrWWqgpvynxDWpy4xFAqrWC0VQ=", +"rsa_npk":"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAy05sCMKEYZQGryKKq7qxxMi4uIRcOuv0aQcptjEifc/TS56bU0iGlkuH9k90tPp6EoKYLUfnL1FdHQOWXboFktwoxjy372gc6CsQfU9ZNjsWMYI8CTZF6gWLk4HjfBO4HcCKJs7oGntgVZxfVqVxJ8N/M1ZC2sDuVkoHYymONgNwgO+yYXrAlPPfJBltG5QNOcGTHBZ4PTc6A0M17+2BiskKUJfLEbN2soEZR0b5v5qy0D1xe5w+CdNcvtEb5CemPRxxRYjIqfHlhQPO7ZCUFPmhtoIbtBYG+BIU+qK3Q1DDiBndOVkQGVBQcOnMfYpxp82hlA1TAVeRICWubH3nJwIDAQAB"}`), +} + +func TestOrder(t *testing.T) { + request := &proto.OrderRequest{ + Config: config, + Order: &proto.OrderRequest_Order{ + OrderNo: "240403164049635931", + Account: "R2wVgntY8aP9QTvCN/bWfw==", + Extra: []byte(`{orderDt:"20240704"}`), + }, + Product: &proto.OrderRequest_Product{ + ProductNo: "3102024032977191", + Extra: []byte(`{}`), + }, + } + t.Run("TestOrder", func(t *testing.T) { + got, err := server.Order(context.Background(), request) + if err != nil { + t.Errorf("Order() error = %v", err) + return + } + fmt.Printf("%+v", got) + assert.Equal(t, int(proto.Status_ING), int(got.Result.Status)) + }) +} + +func TestQuery(t *testing.T) { + request := &proto.QueryRequest{ + Config: config, + Order: &proto.QueryRequest_Order{ + OrderNo: "test_zltx_4", + TradeNo: "", + Account: "", + Extra: nil, + }, + } + t.Run("TestQuery", func(t *testing.T) { + got, err := server.Query(context.Background(), request) + if err != nil { + t.Errorf("Query() error = %v", err) + return + } + fmt.Printf("%+v \n", got) + assert.Equal(t, int(proto.Status_SUCCESS), int(got.Result.Status)) + }) +} + +func TestNotify(t *testing.T) { + in := &proto.NotifyRequest{ + Queries: nil, + Headers: nil, + Body: []byte(`{"merchantId":10, "outTradeNo":"123", "rechargeAccount":"1866666666", "status":"01", "sign":"sign"}`), + } + t.Run("TestNotify", func(t *testing.T) { + got, err := server.Notify(context.Background(), in) + if assert.Nil(t, err) { + assert.Equal(t, true, got.Result) + } + fmt.Printf("%+v \n", got) + assert.Equal(t, int(proto.Status_SUCCESS), int(got.Result.Status)) + }) +} diff --git a/plugins/union_pay/internal/util.go b/plugins/union_pay/internal/util.go new file mode 100644 index 0000000..d77e566 --- /dev/null +++ b/plugins/union_pay/internal/util.go @@ -0,0 +1,35 @@ +package internal + +import ( + "fmt" + "net/http" + "plugins/union_pay/internal/po" + "plugins/union_pay/internal/utils" + "time" +) + +func headers(config *Config, req po.Req, bizMethod string) map[string][]string { + version := "1.0.0" + h := make(http.Header) + h.Add("Content-type", "application/json") + h.Add("version", version) + h.Add("appType", "01") + h.Add("signMethod", "RSA2") + + h.Add("appId", config.Config.AppId) + h.Add("bizMethod", bizMethod) + + h.Add("reqId", req.GetReId()) + + now := time.Now() + milliseconds := now.Unix()*1000 + int64(now.Nanosecond())/1e6 + h.Add("reqTs", fmt.Sprintf("%d", milliseconds)) + + encodedHash := utils.Sha(version, config.Config.AppId, bizMethod, req.GetReId(), string(req.ToJson())) + signValue, err := utils.Sign(encodedHash, utils.FormatPEMPrivateKey(config.Extra.RsaPrk)) + if err != nil { + return nil + } + h.Add("sign", signValue) + return h +} diff --git a/plugins/union_pay/internal/utils/rsa.go b/plugins/union_pay/internal/utils/rsa.go new file mode 100644 index 0000000..b91e797 --- /dev/null +++ b/plugins/union_pay/internal/utils/rsa.go @@ -0,0 +1,28 @@ +package utils + +import ( + "strings" +) + +func FormatPEMPrivateKey(privateKeyStr string) []byte { + const pemHeader = "-----BEGIN RSA PRIVATE KEY-----" + const pemFooter = "-----END RSA PRIVATE KEY-----" + + return buildKey(pemHeader, privateKeyStr, pemFooter) +} + +func FormatPEMPublicKey(publicKeyStr string) []byte { + const pemHeader = "-----BEGIN PUBLIC KEY-----" + const pemFooter = "-----END PUBLIC KEY-----" + + return buildKey(pemHeader, publicKeyStr, pemFooter) +} + +func buildKey(pemHeader, keyStr, pemFooter string) []byte { + var lines []string + lines = append(lines, pemHeader) + lines = append(lines, keyStr) + lines = append(lines, pemFooter) + + return []byte(strings.Join(lines, "\n")) +} diff --git a/plugins/union_pay/internal/utils/sha.go b/plugins/union_pay/internal/utils/sha.go new file mode 100644 index 0000000..4ad7425 --- /dev/null +++ b/plugins/union_pay/internal/utils/sha.go @@ -0,0 +1,29 @@ +package utils + +import ( + "crypto/sha256" + "fmt" +) + +func Sha(version, appId, bizMethod, reId, body string) string { + s := fmt.Sprintf("version=%s&appId=%s&bizMethod=%s&reqId=%s&body=%s", version, appId, bizMethod, reId, body) + return encodeBySHA256([]byte(s)) +} + +func encodeBySHA256(str []byte) string { + hash := sha256.Sum256(str) + return getFormattedText(hash[:]) +} + +func getFormattedText(bytes []byte) string { + HexDigits := "0123456789abcdef" + + l := len(bytes) + buf := make([]byte, l*2) + for j := 0; j < l; j++ { + buf[j*2] = HexDigits[(bytes[j]>>4)&0x0f] + buf[j*2+1] = HexDigits[bytes[j]&0x0f] + } + + return string(buf) +} diff --git a/plugins/union_pay/internal/utils/sign.go b/plugins/union_pay/internal/utils/sign.go new file mode 100644 index 0000000..324663a --- /dev/null +++ b/plugins/union_pay/internal/utils/sign.go @@ -0,0 +1,68 @@ +package utils + +import ( + "crypto" + "crypto/rand" + "crypto/rsa" + "crypto/sha256" + "crypto/x509" + "encoding/base64" + "encoding/pem" + "errors" + "fmt" +) + +func Sign(data string, privateKeyPEM []byte) (string, error) { + block, _ := pem.Decode(privateKeyPEM) + if block == nil { + return "", errors.New("failed to parse PEM block containing the private key") + } + + privyKey, err := x509.ParsePKCS1PrivateKey(block.Bytes) + if err != nil { + return "", fmt.Errorf("failed to parse DER encoded private key: %v", err) + } + + hashed := sha256.Sum256([]byte(data)) + signature, err := rsa.SignPKCS1v15(rand.Reader, privyKey, crypto.SHA256, hashed[:]) + if err != nil { + return "", fmt.Errorf("failed to sign: %v", err) + } + + return base64.StdEncoding.EncodeToString(signature), nil +} + +func Verify(data, signature string, publicKeyPEM []byte) bool { + block, _ := pem.Decode(publicKeyPEM) + if block == nil { + fmt.Println("failed to parse PEM block containing the public key") + return false + } + + pubKey, err := x509.ParsePKIXPublicKey(block.Bytes) + if err != nil { + fmt.Println("error parsing public key:", err) + return false + } + + rsaPubKey, ok := pubKey.(*rsa.PublicKey) + if !ok { + fmt.Println("not an RSA public key") + return false + } + + hashed := sha256.Sum256([]byte(data)) + sig, err := base64.StdEncoding.DecodeString(signature) + if err != nil { + fmt.Println("error decoding signature:", err) + return false + } + + err = rsa.VerifyPKCS1v15(rsaPubKey, crypto.SHA256, hashed[:], sig) + if err != nil { + fmt.Println("signature verification error:", err) + return false + } + + return true +} diff --git a/plugins/union_pay/internal/utils/sign_test.go b/plugins/union_pay/internal/utils/sign_test.go new file mode 100644 index 0000000..c14f123 --- /dev/null +++ b/plugins/union_pay/internal/utils/sign_test.go @@ -0,0 +1,22 @@ +package utils + +import ( + "testing" +) + +var privateKeyPEM = FormatPEMPrivateKey("MIIEogIBAAKCAQEAllAo3AbVfNg1iDT3CisgueIm2Pya2C6qatF0S8/aAKW8A6HBIuvrk1sb2TjbI0UDVowaNDsPa7nNdZHkQa6CQKf2BwFRy7gB8vAD1YSq23NTwplGe5IpuRe2Cbljh5diQ/+0zwZPZQEvjSMqZJILYVluGBw656JSndRdXHCs608CBib14l35A6D7rSZNd53nM9yXj/WOpLuY/jX0sbKJrBUIhcQcMiCFK/Nx06vhhCGZSWwaj0TTSMEOj9nyU+56MMx+N7527JUnOYMyVbbEx5h1S5sPjntMVVzz8c8FC5MKbgXCgjTt5Depl6YgrvoSCNNXZqnXN2l9dtBxKGSEdQIDAQABAoIBAD7r606/pZqPP0l3MnqVNyvY2X43r/ITBs+UQmSB67Ydqqiyi5C8xW530x6JSGJpP055c3atynTD4Jf4rF46WNgL91dTXBQ1QMubYV9+G6+lhUiOtQyBUOnkXRWQ/3MBEed5IQ0QjSew6WDheZuD7zOfJhD9sELKll7vSO2rVRdi5Kf3pps0K4aeYLvlelHjPtu2EkMyAD4d37QO2q8A/+acOf7wyx1uZ55nobe0jVgQBa2Tuuwhd2JilmsgMvcVxeAJoocyQxPVTU+iMidgZKxyW/fJUaR7V2KgKfP0H2OZbSruD2HyHL7o70+/XBg250msh691oTCXSGWiITFXRDkCgYEA1KF3daSzWK2vTZeNMxj++VRNZfyigNqBwgRZxrSGIUeNGpDdDp7flldM/fO/0RijKnh+nXLBCMZlxffSI7W3jkkjosEq0uyXv6Ez4WlhwHEAE6KrZYQ8VDU3We1LXERu/3SMU16Uq2Vme8J6kpshr7OLGeuTNfsSG79lpHU/OO8CgYEAtPjF/AY/t85u4JV0w6FJ/K7Iya+AyIyZhsgnxsPv5NwVtNsQzTRbXlpgnVmaKUXzLBTBJA2P6Gie35R6kJuOuMnvHjtG7umI5lOUJaqYk5GZEXHxbIKTXUxAbv+WKRHcFwcH54Ppurs7bN6ultWdE+yyU5PvabFRAidL+rV+MNsCgYBkqx2XwSZ4MaLxpXLgYlE1UkhipL17K/iLFuw6O3XVg762eSdvqKBK2YJGKYUDRhraHLo1aQMjWGsO00nWRk5lOxN4FuRjgEhIHdYmPnJdXiKfKUDkizrU020lUkd/o5a5s0BMqFbS3usqZOULTA8i1GpjFzlXMUtdf7xrpGcOWQKBgFJXWuX4Befg8owXFKCqc1qYQF2cEBGv/27XBVon7rAH/4xhnHxx1RzSLGGL0lvzKtikvNhln1PUvmzmRvoi/UZRAw6TVAwCkDqUTrTwsSl7ttS8Lmf75Ycu2aZnfnBDYwvLNCp/18oRxNEdZPzWRvk42k6y4d0KQ9yh+q0hBUC/AoGASgJro5HgKWkSzYx1Fk3rvo7EWeZwXNfWuzIhtCiVDG4+df0ZdybkbjxbaRwL2rbTSBeqSaZw4UwpE1JyF8erfzx0qpHCY5V3ocnA8kg56mX9kE5H9WKjMe1tbuZpba4i08zvM8vpz9gASf3z/WrWWqgpvynxDWpy4xFAqrWC0VQ=") +var publicKeyPEM = FormatPEMPublicKey("MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA3ErEoBiGNPT3iIt9ZIuf8znScpOpVk8cToo810EGP8AE/Z6M2s7r18kHCLPCBHvxOjcOTJNWwD2bbDnfY5HNHCXSTWwQUDtFpPAsm4orEaB4Qsh6ohTXTcyNhWp9cCIg42i7jVi5Eq7TVzKuVezCXk3XeLltT56wuCVRfe35SNPe8RDakvbE+fl46+yorz0AKXBoqvsgR8q9QKc6HDSUcFEDZkuFCt7PnMek6L0dQdmb7NHQdG2+8RnUAR4wMEVKuGAX5nCp4IeDE4L23658KPijK1Hg6u6dAqKTfCarj4Act+WOjYYCaARcU/rNX8RGthdvLhUc4lT0ALnbmOEj2QIDAQAB") + +func Test_sign_verify(t *testing.T) { + data := "123456" + t.Run("test_sign", func(t *testing.T) { + got, err := Sign(data, privateKeyPEM) + if err != nil { + t.Errorf("sign() error = %v", err) + return + } + t.Log(got) + b := Verify(data, got, publicKeyPEM) + t.Log(b) + }) +} diff --git a/plugins/union_pay/internal/vo/code.go b/plugins/union_pay/internal/vo/code.go new file mode 100644 index 0000000..ead9dba --- /dev/null +++ b/plugins/union_pay/internal/vo/code.go @@ -0,0 +1,9 @@ +package vo + +type Code string + +const CodeSuccess Code = "0000000000" + +func (c Code) IsSuccess() bool { + return c == CodeSuccess +} diff --git a/plugins/union_pay/internal/vo/status.go b/plugins/union_pay/internal/vo/status.go new file mode 100644 index 0000000..2d1a8be --- /dev/null +++ b/plugins/union_pay/internal/vo/status.go @@ -0,0 +1,43 @@ +package vo + +import ( + "codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin/proto" +) + +type OrderStatus string + +const ( + OrderSuccess OrderStatus = "01" // 充值成功 + OrderPending OrderStatus = "02" // 充值处理中 + OrderFail OrderStatus = "03" // 充值失败 + OrderAbnormal OrderStatus = "04" // 充值异常，处理中 +) + +var orderStatusMap = map[OrderStatus]proto.Status{ + OrderSuccess: proto.Status_SUCCESS, + OrderPending: proto.Status_ING, + OrderFail: proto.Status_FAIL, +} + +func (o OrderStatus) IsSuccess() bool { + return o == OrderSuccess +} + +func (o OrderStatus) IsPending() bool { + return o == OrderPending +} + +func (o OrderStatus) IsFail() bool { + return o == OrderFail +} + +func (o OrderStatus) IsAbnormal() bool { + return o == OrderAbnormal +} + +func (o OrderStatus) GetOrderStatus() proto.Status { + if resultStatus, ok := orderStatusMap[o]; ok { + return resultStatus + } + return proto.Status_ING +} diff --git a/plugins/union_pay/internal/vo/sub_code.go b/plugins/union_pay/internal/vo/sub_code.go new file mode 100644 index 0000000..c2f40f7 --- /dev/null +++ b/plugins/union_pay/internal/vo/sub_code.go @@ -0,0 +1,109 @@ +package vo + +type SubCode string + +const ( + SubCodeUp02094 SubCode = "UP02094" + SubCodeUp02099 SubCode = "UP02099" + SubCodeUp06003 SubCode = "UP06003" + SubCodeUp06004 SubCode = "UP06004" + SubCodeUp06005 SubCode = "UP06005" + SubCodeUp06006 SubCode = "UP06006" + SubCodeUp06007 SubCode = "UP06007" + SubCodeUp06008 SubCode = "UP06008" + SubCodeUp06009 SubCode = "UP06009" + SubCodeUp06010 SubCode = "UP06010" + SubCodeUp06011 SubCode = "UP06011" + SubCodeUp06012 SubCode = "UP06012" + SubCodeUp06021 SubCode = "UP06021" + SubCodeUp06022 SubCode = "UP06022" + SubCodeUp06034 SubCode = "UP06034" + SubCodeUp06035 SubCode = "UP06035" + SubCodeUp06036 SubCode = "UP06036" + SubCodeUp06037 SubCode = "UP06037" + SubCodeUp06038 SubCode = "UP06038" + SubCodeUp06039 SubCode = "UP06039" + SubCodeUp06040 SubCode = "UP06040" + SubCodeUp06041 SubCode = "UP06041" + SubCodeUp06042 SubCode = "UP06042" + SubCodeUp06043 SubCode = "UP06043" + SubCodeUp06044 SubCode = "UP06044" + SubCodeUp06045 SubCode = "UP06045" + SubCodeUp07001 SubCode = "UP07001" + SubCodeUp07002 SubCode = "UP07002" + SubCodeUp07003 SubCode = "UP07003" + SubCodeUp07004 SubCode = "UP07004" + SubCodeUp07005 SubCode = "UP07005" + SubCodeUp07010 SubCode = "UP07010" + SubCodeUp07012 SubCode = "UP07012" + SubCodeUp07013 SubCode = "UP07013" + SubCodeUp07014 SubCode = "UP07014" + SubCodeUp07015 SubCode = "UP07015" + SubCodeUp07020 SubCode = "UP07020" + SubCodeUp07030 SubCode = "UP07030" + SubCodeUp07050 SubCode = "UP07050" + SubCodeUp07051 SubCode = "UP07051" + SubCodeUp07052 SubCode = "UP07052" + SubCodeUp00030 SubCode = "UP00030" + SubCodeUp00050 SubCode = "UP00050" + SubCodeUp00080 SubCode = "UP00080" + SubCodeUp02025 SubCode = "UP02025" + SubCodeUp02071 SubCode = "UP02071" +) + +var codeMsg = map[SubCode]string{ + SubCodeUp02094: "交易重复", + SubCodeUp02099: "交易单品信息无效", + SubCodeUp06003: "线上折扣活动不存在", + SubCodeUp06004: "线上折扣活动已下线", + SubCodeUp06005: "线上折扣活动未开始", + SubCodeUp06006: "线上折扣活动已结束", + SubCodeUp06007: "线上折扣活动已过期(当前消费请求已不满足)", + SubCodeUp06008: "线上折扣活动多方出资配置或者计算错误", + SubCodeUp06009: "线上折扣活动查询结果不满足消费请求(适用于查询并承兑)", + SubCodeUp06010: "折扣活动承兑金额检验错误", + SubCodeUp06011: "线上折扣活动余额不足", + SubCodeUp06012: "线上折扣活动当前周期余额不足", + SubCodeUp06021: "线上折扣活动城市校验失败，定位城市非活动城市", + SubCodeUp06022: "线上折扣活动城市校验失败，交易未上送定位城市", + SubCodeUp06034: "线上折扣活动参与卡付失败封顶", + SubCodeUp06035: "线上折扣活动参与手机封顶", + SubCodeUp06036: "线上折扣活动参与银行卡封顶", + SubCodeUp06037: "线上折扣活动参与迷你付终端封顶", + SubCodeUp06038: "线上折扣活动参与用户封顶", + SubCodeUp06039: "线上折扣活动参与账单号封顶", + SubCodeUp06040: "线上折扣活动参与用户商品数量封顶", + SubCodeUp06041: "线上折扣活动参与证件号封顶", + SubCodeUp06042: "线上折扣活动参与商户号封顶", + SubCodeUp06043: "线上折扣活动参与人脸证件号封顶", + SubCodeUp06044: "线上折扣活动参与商户Pos终端封顶", + SubCodeUp06045: "线上折扣活动参与活动封顶", + SubCodeUp07001: "优惠券下载失败", + SubCodeUp07002: "优惠券冻结失败", + SubCodeUp07003: "优惠券删除失败", + SubCodeUp07004: "优惠券操作结果查询失败", + SubCodeUp07005: "优惠券开放平台权限校验失败", + SubCodeUp07010: "用户优惠券张数超过限制", + SubCodeUp07012: "优惠券下载封顶累计失败", + SubCodeUp07013: "优惠券下载调用账务失败", + SubCodeUp07014: "优惠券下载卡号反查用户ID失败", + SubCodeUp07015: "优惠券下载手机号反查用户ID失败", + SubCodeUp07020: "优惠券冻结调用账务失败", + SubCodeUp07030: "优惠券删除调用账户失败", + SubCodeUp07050: "优惠券下载维度无效", + SubCodeUp07051: "用户送券维度：当前用户未实名认证", + SubCodeUp07052: "用户送券维度：可用银行卡与当前账户不同名，需绑定同名卡", + SubCodeUp00030: "请求报文错误(无效)", + SubCodeUp00050: "线上折扣系统并发控制限制", + SubCodeUp00080: "线上折扣系统内部错误", + SubCodeUp02025: "原交易不存在", + SubCodeUp02071: "交易无效", +} + +func (code SubCode) GetMsg() string { + msg, ok := codeMsg[code] + if !ok { + return "未知错误代码" + } + return msg +} diff --git a/plugins/union_pay/main.go b/plugins/union_pay/main.go new file mode 100644 index 0000000..8ae562c --- /dev/null +++ b/plugins/union_pay/main.go @@ -0,0 +1,15 @@ +package main + +import ( + "codeup.aliyun.com/6552e56cc3b2728a4557fc18/plugin/shared" + "github.com/hashicorp/go-plugin" + "plugins/union_pay/internal" +) + +func main() { + plugin.Serve(&plugin.ServeConfig{ + HandshakeConfig: shared.HandshakeConfig(internal.Version, internal.CookieKey, internal.CookieValue), + Plugins: shared.PluginSet(shared.NewPlugin(&internal.UnionPayService{}, internal.Tag)), + GRPCServer: plugin.DefaultGRPCServer, + }) +} diff --git a/plugins/zltx/internal/vo/result.go b/plugins/zltx/internal/vo/code.go similarity index 100% rename from plugins/zltx/internal/vo/result.go rename to plugins/zltx/internal/vo/code.go diff --git a/plugins/zltx/internal/zltx.go b/plugins/zltx/internal/zltx.go index ca24352..8f0c8ee 100644 --- a/plugins/zltx/internal/zltx.go +++ b/plugins/zltx/internal/zltx.go @@ -23,8 +23,7 @@ const ( queryMethod = "/recharge/query" ) -type ZltxService struct { -} +type ZltxService struct{} func (p *ZltxService) Order(ctx context.Context, request *proto.OrderRequest) (*proto.OrderResponse, error) { uv, err := req(rechargeReq(request), request.Config.AppKey)