golang微信支付服务端

一般来说,使用golang主要还是写服务端。所以本文主要讲golang在处理微信移动支付的服务端时的统一下单接口和支付回调接口,以及查询接口。

微信支付流程

下图是微信官网的支付流程描述:
微信支付流程

图中红色部分就是微信支付中,我们的系统包括app,后台需要参与的流程。
其中需要后台也就是Server需要参与的流程有三个:
1. 统一下单并返回客户端
2. 异步通知结果回调处理
3. 调用微信支付查询接口

微信所有的接口都是以http RESTFul的API来提供,所以对于server而言其实就是call这些接口并处理返回值。

golang的服务端实现

1,调用统一下单接口
首先需要呼叫:https://api.mch.weixin.qq.com/pay/unifiedorder 这是微信的api,呼叫之后微信会返回我们一个prepay_id。调用的结果以微信正确的返回给我们prepay id为准。

按照微信文档说明,这个接口的参数没有,我们传入的参数需要以xml的形式来写入http request的body部分传给微信。

//首先定义一个UnifyOrderReq用于填入我们要传入的参数。
type UnifyOrderReq struct {
 Appid string `xml:"appid"`
 Body string `xml:"body"`
 Mch_id string `xml:"mch_id"`
 Nonce_str string `xml:"nonce_str"`
 Notify_url string `xml:"notify_url"`
 Trade_type string `xml:"trade_type"`
 Spbill_create_ip string `xml:"spbill_create_ip"`
 Total_fee int `xml:"total_fee"`
 Out_trade_no string `xml:"out_trade_no"`
 Sign string `xml:"sign"`
}
//wxpay计算签名的函数
func wxpayCalcSign(mReq map[string]interface{}, key string) (sign string) {
 fmt.Println("微信支付签名计算, API KEY:", key)
 //STEP 1, 对key进行升序排序.
 sorted_keys := make([]string, 0)
 for k, _ := range mReq {
 sorted_keys = append(sorted_keys, k)
 }
 sort.Strings(sorted_keys)
 //STEP2, 对key=value的键值对用&连接起来,略过空值
 var signStrings string
 for _, k := range sorted_keys {
 fmt.Printf("k=%v, v=%v\n", k, mReq[k])
 value := fmt.Sprintf("%v", mReq[k])
 if value != "" {
 signStrings = signStrings + k + "=" + value + "&"
 }
 }
 //STEP3, 在键值对的最后加上key=API_KEY
 if key != "" {
 signStrings = signStrings + "key=" + key
 }
 //STEP4, 进行MD5签名并且将所有字符转为大写.
 md5Ctx := md5.New()
 md5Ctx.Write([]byte(signStrings))
 cipherStr := md5Ctx.Sum(nil)
 upperSign := strings.ToUpper(hex.EncodeToString(cipherStr))
 return upperSign
}

 //请求UnifiedOrder的代码
 var yourReq UnifyOrderReq
 yourReq.Appid = "app_id" //微信开放平台我们创建出来的app的app id
 yourReq.Body = "商品名"
 yourReq.Mch_id = "商户编号"
 yourReq.Nonce_str = "your nonce"
 yourReq.Notify_url = "www.yourserver.com/wxpayNotify"
 yourReq.Trade_type = "APP"
 yourReq.Spbill_create_ip = "xxx.xxx.xxx.xxx"
 yourReq.Total_fee = 10 //单位是分,这里是1毛钱
 yourReq.Out_trade_no = "后台系统单号"
 var m map[string]interface{}
 m = make(map[string]interface{}, 0)
 m["appid"] = yourReq.Appid
 m["body"] = yourReq.Body
 m["mch_id"] = yourReq.Mch_id
 m["notify_url"] = yourReq.Notify_url
 m["trade_type"] = yourReq.Trade_type
 m["spbill_create_ip"] = yourReq.Spbill_create_ip
 m["total_fee"] = yourReq.Total_fee
 m["out_trade_no"] = yourReq.Out_trade_no
 m["nonce_str"] = yourReq.Nonce_str
 yourReq.Sign = wxpayCalcSign(m, "wxpay_api_key") //这个是计算wxpay签名的函数上面已贴出
 bytes_req, err := xml.Marshal(yourReq)
 if err != nil {
 fmt.Println("以xml形式编码发送错误, 原因:", err)
 return
 }
 str_req := string(bytes_req)
 //wxpay的unifiedorder接口需要http body中xmldoc的根节点是<xml></xml>这种,所以这里需要replace一下
 str_req = strings.Replace(str_req, "XUnifyOrderReq", "xml", -1)
 bytes_req = []byte(str_req)
 //发送unified order请求.
 req, err := http.NewRequest("POST", unify_order_req, bytes.NewReader(bytes_req))
 if err != nil {
 fmt.Println("New Http Request发生错误,原因:", err)
 return
 }
 req.Header.Set("Accept", "application/xml")
 //这里的http header的设置是必须设置的.
 req.Header.Set("Content-Type", "application/xml;charset=utf-8")
 c := http.Client{}
 resp, _err := c.Do(req)
 if _err != nil {
 fmt.Println("请求微信支付统一下单接口发送错误, 原因:", _err)
 return
 }
 //到这里统一下单接口就已经执行完成了

2,微信回调函数的处理
3,客户端查询订单请求响应

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传