From fce67e3255c402ebe191573866ae9d94ed1f7532 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Tue, 11 Apr 2023 14:37:29 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- md/alipay.go | 59 ++++++++ pay/alipay.go | 394 ++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 453 insertions(+) create mode 100644 pay/alipay.go diff --git a/md/alipay.go b/md/alipay.go index 17799ac..0dd45de 100644 --- a/md/alipay.go +++ b/md/alipay.go @@ -15,3 +15,62 @@ type PayData struct { PriKey string `json:"pay_ali_new_private_key"` WxAppletFilepathUrl string `json:"wx_applet_filepath_url"` } + +type ZhimaCreditPayafteruseCreditagreementQuery struct { + ZhimaCreditPayafteruseCreditagreementQueryResponse struct { + Code string `json:"code"` + Msg string `json:"msg"` + AgreementStatus string `json:"agreement_status"` + BizTime string `json:"biz_time"` + CreditAgreementId string `json:"credit_agreement_id"` + OutAgreementNo string `json:"out_agreement_no"` + } `json:"zhima_credit_payafteruse_creditagreement_query_response"` + AlipayCertSn string `json:"alipay_cert_sn"` + Sign string `json:"sign"` +} +type ZhimaCreditPayafteruseCreditbizorderOrder struct { + ZhimaCreditPayafteruseCreditbizorderOrderResponse struct { + Code string `json:"code"` + Msg string `json:"msg"` + OutOrderNo string `json:"out_order_no"` + CreditBizOrderId string `json:"credit_biz_order_id"` + } `json:"zhima_credit_payafteruse_creditbizorder_order_response"` + Sign string `json:"sign"` +} +type ZhimaCreditPayafteruseCreditbizorderQuery struct { + ZhimaCreditPayafteruseCreditbizorderQueryResponse struct { + Code string `json:"code"` + Msg string `json:"msg"` + CreditBizOrderId string `json:"credit_biz_order_id"` + CreditAgreementId string `json:"credit_agreement_id"` + TotalAmount float64 `json:"total_amount"` + CreateTime string `json:"create_time"` + ZmServiceId string `json:"zm_service_id"` + ProductCode string `json:"product_code"` + OrderStatus string `json:"order_status"` + TradeNo string `json:"trade_no"` + } `json:"zhima_credit_payafteruse_creditbizorder_query_response"` + Sign string `json:"sign"` +} +type AlipayFundTransUniTransfer struct { + AlipayFundTransUniTransferResponse struct { + Code string `json:"code"` + Msg string `json:"msg"` + OutBizNo string `json:"out_biz_no"` + OrderId string `json:"order_id"` + PayFundOrderId string `json:"pay_fund_order_id"` + Status string `json:"status"` + TransDate string `json:"trans_date"` + } `json:"alipay_fund_trans_uni_transfer_response"` + Sign string `json:"sign"` +} +type ZhimaCreditPayafteruseCreditbizorderFinish struct { + ZhimaCreditPayafteruseCreditbizorderFinishResponse struct { + Code string `json:"code"` + Msg string `json:"msg"` + OutRequestNo string `json:"out_request_no"` + CreditBizOrderId string `json:"credit_biz_order_id"` + OrderStatus string `json:"order_status"` + } `json:"zhima_credit_payafteruse_creditbizorder_finish_response"` + Sign string `json:"sign"` +} diff --git a/pay/alipay.go b/pay/alipay.go new file mode 100644 index 0000000..8ee0ea6 --- /dev/null +++ b/pay/alipay.go @@ -0,0 +1,394 @@ +package pay + +import ( + "code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git/md" + zhios_pay_utils "code.fnuoos.com/go_rely_warehouse/zyos_go_pay.git/utils" + "encoding/json" + "errors" + "fmt" + "github.com/iGoogle-ink/gopay" + "github.com/iGoogle-ink/gopay/alipay" + "github.com/iGoogle-ink/gopay/pkg/util" + "github.com/iGoogle-ink/gopay/pkg/xhttp" + "github.com/iGoogle-ink/gopay/pkg/xlog" + "time" +) + +const ( + baseUrl = "https://openapi.alipay.com/gateway.do" + sandboxBaseUrl = "https://openapi.alipaydev.com/gateway.do" + baseUrlUtf8 = "https://openapi.alipay.com/gateway.do?charset=utf-8" + sandboxBaseUrlUtf8 = "https://openapi.alipaydev.com/gateway.do?charset=utf-8" +) + +func Comm(args map[string]string) *alipay.Client { + paySet := AlipayCofing(args) + if args["private_key"] == "" || args["app_id"] == "" { + return nil + } + //初始化支付宝客户端 + // appID 是在支付宝申请的APPID + // priKey 是支付宝私钥 + // code 支付宝授权码 + client := alipay.NewClient(args["app_id"], args["private_key"], true) + client.DebugSwitch = gopay.DebugOn + //判断密钥的类型 + rsa_type := alipay.RSA2 + pkcs_type := alipay.PKCS1 + if args["rsa"] == "1" { + rsa_type = alipay.RSA + } + if args["pkcs"] == "1" { + pkcs_type = alipay.PKCS8 + } + if paySet.PayAliUseType == "1" { + rsa_type = alipay.RSA2 + pkcs_type = alipay.PKCS8 + } + //配置公共参数 + client.SetCharset("utf-8"). + SetSignType(rsa_type). + SetPrivateKeyType(pkcs_type) + //新支付宝支付 + if paySet.PayAliUseType == "1" { + client.SetAppCertSN(paySet.PayAppCertSn) + aliPayRootCertSN := "687b59193f3f462dd5336e5abf83c5d8_02941eef3187dddf3d3b83462e1dfcf6" + client.SetAliPayRootCertSN(aliPayRootCertSN) + client.SetAliPayPublicCertSN(paySet.PayAlipayrsaPublicKey) + } + fmt.Println(client) + return client + +} +func OpenAuthTokenApp(args map[string]string) (*alipay.SystemOauthTokenResponse, error) { + client := Comm(args) + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + body := make(gopay.BodyMap) + body.Set("grant_type", "authorization_code") + body.Set("code", args["code"]) + + payParam, err := client.SystemOauthToken(body) + if err != nil { + return nil, err + } + return payParam, nil +} + +func CreditagreementSign(args map[string]string) (string, error) { + client := Comm(args) + client.AppAuthToken = args["app_auth_token"] + if client == nil { + return "", errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_agreement_no", args["out_agreement_no"]) + bz.Set("zm_service_id", args["zm_service_id"]) + bz.Set("category_id", args["category_id"]) + }) + + aliPsp := "" + bs, err := PostAliPayAPISelfV2(client, bm, "zhima.credit.payafteruse.creditagreement.sign", &aliPsp) + if err != nil { + xlog.Error(err) + return "", err + } + return zhios_pay_utils.AnyToString(bs), nil +} +func CreditagreementQuery(args map[string]string) (*md.ZhimaCreditPayafteruseCreditagreementQuery, error) { + client := Comm(args) + client.AppAuthToken = args["app_auth_token"] + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_agreement_no", args["out_agreement_no"]) + }) + + var aliPsp md.ZhimaCreditPayafteruseCreditagreementQuery + bs, err := PostAliPayAPISelfV2(client, bm, "zhima.credit.payafteruse.creditagreement.query", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.ZhimaCreditPayafteruseCreditagreementQuery) + return res, nil +} + +//信用下单 +func CreditagreementOrder(args map[string]string) (*md.ZhimaCreditPayafteruseCreditbizorderOrder, error) { + client := Comm(args) + client.AppAuthToken = args["app_auth_token"] + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_order_no", args["out_order_no"]) + bz.Set("credit_agreement_id", args["credit_agreement_id"]) + bz.Set("category_id", args["category_id"]) + bz.Set("order_amount", args["order_amount"]) + bz.Set("amount_type", args["amount_type"]) + bz.Set("subject", args["subject"]) + }) + + var aliPsp md.ZhimaCreditPayafteruseCreditbizorderOrder + bs, err := PostAliPayAPISelfV2(client, bm, "zhima.credit.payafteruse.creditbizorder.order", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.ZhimaCreditPayafteruseCreditbizorderOrder) + return res, nil +} + +//查询信用订单 +func CreditagreementOrderQuery(args map[string]string) (*md.ZhimaCreditPayafteruseCreditbizorderQuery, error) { + client := Comm(args) + client.AppAuthToken = args["app_auth_token"] + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("credit_biz_order_id", args["credit_biz_order_id"]) + }) + + var aliPsp md.ZhimaCreditPayafteruseCreditbizorderQuery + bs, err := PostAliPayAPISelfV2(client, bm, "zhima.credit.payafteruse.creditbizorder.query", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.ZhimaCreditPayafteruseCreditbizorderQuery) + return res, nil +} + +//转账 +func AlipayFundTransUniTransfer(args map[string]string) (*md.AlipayFundTransUniTransfer, error) { + client := Comm(args) + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + payeeInfo := map[string]string{ + "identity": args["identity"], + "identity_type": args["identity_type"], + "name": args["name"], + } + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_biz_no", args["out_biz_no"]) + bz.Set("trans_amount", args["trans_amount"]) + bz.Set("product_code", args["product_code"]) + bz.Set("biz_scene", args["biz_scene"]) + bz.Set("order_title", args["order_title"]) + bz.Set("payee_info", payeeInfo) + }) + + var aliPsp md.AlipayFundTransUniTransfer + bs, err := PostAliPayAPISelfV2(client, bm, "alipay.fund.trans.uni.transfer", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.AlipayFundTransUniTransfer) + return res, nil +} + +//扣款 +func AlipayTradePay(args map[string]string) { + client := Comm(args) + if client == nil { + return + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + extendParams := map[string]string{ + "creditTradeScene": args["creditTradeScene"], + } + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("is_async_pay", args["is_async_pay"]) + bz.Set("total_amount", args["total_amount"]) + bz.Set("auth_code", args["auth_code"]) + bz.Set("scene", args["scene"]) + bz.Set("order_title", args["order_title"]) + bz.Set("extend_params", extendParams) + }) + var aliPsp = "" + PostAliPayAPISelfV2(client, bm, "alipay.trade.pay", &aliPsp) + + return +} +func AlipayTradeQuery(args map[string]string) (*md.AlipayFundTransUniTransfer, error) { + client := Comm(args) + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_trade_no", args["out_trade_no"]) + }) + + var aliPsp md.AlipayFundTransUniTransfer + bs, err := PostAliPayAPISelfV2(client, bm, "alipay.trade.query", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.AlipayFundTransUniTransfer) + return res, nil +} + +//结束信用服务订单 +func CreditagreementOrderFinish(args map[string]string) (*md.ZhimaCreditPayafteruseCreditbizorderFinish, error) { + client := Comm(args) + client.AppAuthToken = args["app_auth_token"] + if client == nil { + return nil, errors.New("获取失败") + } + //请求参数 + bm := make(gopay.BodyMap) + // biz_content + bm.SetBodyMap("biz_content", func(bz gopay.BodyMap) { + bz.Set("out_request_no", args["out_request_no"]) + bz.Set("credit_biz_order_id", args["credit_biz_order_id"]) + bz.Set("is_fulfilled", args["is_fulfilled"]) + bz.Set("remark", args["remark"]) + }) + + var aliPsp md.ZhimaCreditPayafteruseCreditbizorderFinish + bs, err := PostAliPayAPISelfV2(client, bm, "zhima.credit.payafteruse.creditbizorder.finish", &aliPsp) + if err != nil { + xlog.Error(err) + return nil, err + } + res := bs.(*md.ZhimaCreditPayafteruseCreditbizorderFinish) + return res, nil +} + +func PostAliPayAPISelfV2(a *alipay.Client, bm gopay.BodyMap, method string, aliRsp interface{}) (aliRsps interface{}, err error) { + var ( + bs, bodyBs []byte + ) + // check if there is biz_content + bz := bm.GetInterface("biz_content") + if bzBody, ok := bz.(gopay.BodyMap); ok { + if bodyBs, err = json.Marshal(bzBody); err != nil { + return aliRsp, fmt.Errorf("json.Marshal(%v)：%w", bzBody, err) + } + bm.Set("biz_content", string(bodyBs)) + } + + if bs, err = doAliPaySelf(a, bm, method); err != nil { + return aliRsp, err + } + switch method { + case "alipay.trade.app.pay": + return string(bs), nil + case "alipay.trade.wap.pay", "alipay.trade.page.pay", "alipay.user.certify.open.certify", "zhima.credit.payafteruse.creditagreement.sign": + return string(bs), nil + default: + if err = json.Unmarshal(bs, aliRsp); err != nil { + return aliRsp, err + } + return aliRsp, nil + } +} + +// 向支付宝发送自定义请求 +func doAliPaySelf(a *alipay.Client, bm gopay.BodyMap, method string) (bs []byte, err error) { + var ( + url, sign string + ) + bm.Set("method", method) + + // check public parameter + checkPublicParam(a, bm) + + // check sign + if bm.GetString("sign") == "" { + sign, err = alipay.GetRsaSign(bm, bm.GetString("sign_type"), a.PrivateKeyType, a.PrivateKey) + if err != nil { + return nil, fmt.Errorf("GetRsaSign Error: %v", err) + } + bm.Set("sign", sign) + } + + if a.DebugSwitch == gopay.DebugOn { + req, _ := json.Marshal(bm) + xlog.Debugf("Alipay_Request: %s", req) + } + param := alipay.FormatURLParam(bm) + switch method { + case "alipay.trade.app.pay": + return []byte(param), nil + case "alipay.trade.wap.pay", "alipay.trade.page.pay", "alipay.user.certify.open.certify", "zhima.credit.payafteruse.creditagreement.sign": + return []byte(baseUrl + "?" + param), nil + default: + httpClient := xhttp.NewClient() + url = baseUrlUtf8 + res, bs, errs := httpClient.Type(xhttp.TypeForm).Post(url).SendString(param).EndBytes() + if len(errs) > 0 { + return nil, errs[0] + } + if a.DebugSwitch == gopay.DebugOn { + xlog.Debugf("Alipay_Response: %s%d %s%s", xlog.Red, res.StatusCode, xlog.Reset, string(bs)) + } + if res.StatusCode != 200 { + return nil, fmt.Errorf("HTTP Request Error, StatusCode = %d", res.StatusCode) + } + return bs, nil + } +} +func checkPublicParam(a *alipay.Client, bm gopay.BodyMap) { + bm.Set("format", "JSON") + + if bm.GetString("app_id") == "" && a.AppId != util.NULL { + bm.Set("app_id", a.AppId) + } + if bm.GetString("app_cert_sn") == "" && a.AppCertSN != util.NULL { + bm.Set("app_cert_sn", a.AppCertSN) + } + if bm.GetString("alipay_root_cert_sn") == "" && a.AliPayRootCertSN != util.NULL { + bm.Set("alipay_root_cert_sn", a.AliPayRootCertSN) + } + if bm.GetString("return_url") == "" && a.ReturnUrl != util.NULL { + bm.Set("return_url", a.ReturnUrl) + } + bm.Set("charset", "utf-8") + if bm.GetString("charset") == "" && a.Charset != util.NULL { + bm.Set("charset", a.Charset) + } + bm.Set("sign_type", alipay.RSA2) + if bm.GetString("sign_type") == "" && a.SignType != util.NULL { + bm.Set("sign_type", a.SignType) + } + bm.Set("timestamp", time.Now().Format(util.TimeLayout)) + + bm.Set("version", "1.0") + if bm.GetString("notify_url") == "" && a.NotifyUrl != util.NULL { + bm.Set("notify_url", a.NotifyUrl) + } + if bm.GetString("app_auth_token") == "" && a.AppAuthToken != util.NULL { + bm.Set("app_auth_token", a.AppAuthToken) + } + if bm.GetString("auth_token") == "" && a.AuthToken != util.NULL { + bm.Set("auth_token", a.AuthToken) + } +}