前言
由于學(xué)校有個項目類似輕松籌，基于微信支付，便深入了解微信支付流程及其接口調(diào)用离斩，其業(yè)務(wù)流程有些繁瑣，但其策略是不錯的瘪匿。
業(yè)務(wù)流程
首先貼微信官方文檔的時序圖官方文檔
image.png
看不懂的可以參考我寫的大概步驟如下：
- 首先由前端發(fā)起支付請求跛梗，這時前端應(yīng)該先確定好支付的金額，然后請求給后端
- 后端收到前端的支付請求棋弥，根據(jù)自定義的訂單號生成算法生成本次支付的訂單號（微信要求一個商戶中的所有訂單號不能重復(fù)核偿，推薦使用時間加隨機數(shù)生成訂單號，建議生成訂單號后插入數(shù)據(jù)庫顽染，置支付狀態(tài)為未支付，待后續(xù)流程再修改該訂單）
- 后端將訂單號，金額遏暴，用戶IP般卑，用戶OPENID落剪，支付信息通知地址（后臺服務(wù)器一個api，用于接收微信支付結(jié)果通知）等信息打包成結(jié)構(gòu)體并根據(jù)簽名算法對該結(jié)構(gòu)體簽名，簽名算法參考官方簽名算法
- 后端將該結(jié)構(gòu)體解析成xml并發(fā)給微信服務(wù)器，微信服務(wù)器將返回預(yù)訂單號等信息
- 后端收到微信發(fā)來的預(yù)訂單號等信息（可以記錄該信息進入數(shù)據(jù)庫）液样，將其打包并簽名發(fā)送給前端，準(zhǔn)備讓前端向微信發(fā)起真正的支付請求
- 前端調(diào)用H5接口發(fā)起請求并支付（此處由用戶輸入支付密碼支付）
- 支付成功后微信服務(wù)器將會通知在步驟三的通知地址巧还，在前端的成功回調(diào)應(yīng)再次發(fā)起詢問后端是否收到微信的成功通知鞭莽，若沒有收到，則后端主動發(fā)起請求請求支付結(jié)果麸祷，并修改數(shù)據(jù)庫狀態(tài)
微信支付的大致流程就是這樣
源碼樣例
下面是我開發(fā)的go源碼主要業(yè)務(wù)代碼
簡單統(tǒng)一封裝post：
func post(url string, data interface{}) (res_buf []byte, err error) {
if url == "" {
return nil, errors.New("wepay post fail: url nil")
}
if data == nil {
return nil, errors.New("wepay post fail: buf nil")
}
buf, err := xml.Marshal(data)
if err != nil {
return nil, err
}
r, err := http.Post(url, "application/x-www-form-urlencoded", bytes.NewBuffer([]byte(buf)))
if err != nil {
return nil, err
}
res_buf, err = ioutil.ReadAll(r.Body)
if err != nil {
return nil, err
}
r.Body.Close()
return res_buf, nil
}
統(tǒng)一下單請求
//請求統(tǒng)一下單反饋結(jié)構(gòu)體
type QueryRespon struct {
ReturnCode CDATA `xml:"return_code"` //返回錯誤碼
ReturnMsg CDATA `xml:"return_msg"` //返回信息
AppID CDATA `xml:"appid"` //公眾賬號ID
MchID CDATA `xml:"mch_id"` //商戶號
NonceStr CDATA `xml:"nonce_str"` //隨機字符串
Sign CDATA `xml:"sign"` //簽名
ResultCode CDATA `xml:"result_code"` //業(yè)務(wù)結(jié)果
ErrCode CDATA `xml:"err_code"` //錯誤代碼
ErrCodeDes CDATA `xml:"err_code_des"` //錯誤代碼描述
DeviceInfo CDATA `xml:"device_info"` //設(shè)備號
OpenID CDATA `xml:"openid"` //用戶標(biāo)識
IsSubscribe CDATA `xml:"is_subscribe"` //是否關(guān)注公眾賬號
TradeType CDATA `xml:"trade_type"` //交易類型
TradeState CDATA `xml:"trade_state"` //交易狀態(tài)
BankType CDATA `xml:"bank_type"` //付款銀行
TotalFee int `xml:"total_fee"` //訂單金額
FeeType CDATA `xml:"fee_type"` //貨幣種類
CashFee CDATA `xml:"cash_fee"` //現(xiàn)金支付金額
CashFeeType CDATA `xml:"cash_fee_type"` //現(xiàn)金支付貨幣類型
TransactionID CDATA `xml:"transaction_id"` //微信支付訂單號
OutTradeNO CDATA `xml:"out_trade_no"` //商戶訂單號
Attach CDATA `xml:"attach"` //商家數(shù)據(jù)包
TimeEnd CDATA `xml:"time_end"` //支付完成時間
SignType CDATA `xml:"sign_type"` //簽名類型
TradeStateDesc CDATA `xml:"trade_state_desc"` //交易狀態(tài)描述
}
//請求統(tǒng)一下單
func (wp *WePay) Request(out_trade_no string, fee int, client_ip string, duration int, open_id string) (*UnifiedOrderRespone, error) {
//參數(shù)檢查
if wp.MchID == "" || wp.AppId == "" {
return nil, errors.New("wepay request fail: mchid or appid nil")
}
if wp.Key == "" {
return nil, errors.New("wepay request fail: key nil")
}
if out_trade_no == "" {
return nil, errors.New("wepay request fail: out_trade_no nil")
}
randomStr := createNonceStr()
if len(randomStr) != 32 {
return nil, errors.New("wepay request fail: random str error")
}
if fee <= 0 {
return nil, errors.New("wepay request fail: fee smaller than 0")
}
if duration <= 0 {
return nil, errors.New("wepay request fail: duration smaller than 0")
}
if client_ip == "" {
return nil, errors.New("wepay request fail: client_ip nil")
}
if open_id == "" {
return nil, errors.New("wepay request fail: open_id nil")
}
//生成請求結(jié)構(gòu)體
request := &UnifiedOrderRequest{
AppID: wp.AppId,
MchID: wp.MchID,
DeviceInfo: "DeviceInfo",
NonceStr: randomStr,
Sign: "Sign",
SignType: "MD5",
Body: "XXX捐贈基金會",
Attach: "",
OutTradeNo: out_trade_no,
FeeType: "CNY",
TotalFee: fee,
SpbillCreateIP: client_ip,
TimeStart: time.Now().Format("20060102150405"),
TimeExpire: time.Now().Add(time.Minute * time.Duration(duration)).Format("20060102150405"),
NotifyUrl: wp.NotifyUrl,
TradeType: "JSAPI",
OpenID: open_id,
}
//簽名
var err error
err = request.SignUp(wp.Key)
if err != nil {
return nil, err
}
//轉(zhuǎn)成xml并發(fā)給微信服務(wù)器
buf, err := post(wp.UnifiedOrderUrl, request)
if err != nil {
return nil, err
}
//解析反饋
respon := &UnifiedOrderRespone{}
err = xml.Unmarshal(buf, respon)
if err != nil {
return nil, err
}
return respon, nil
}
統(tǒng)一下單并生成前端需要的參數(shù)并簽名
func (wp *WePay) WebRequest(out_trade_no string, fee int, client_ip string, duration int, open_id string) (*WebRequest, string, error) {
if wp.Key == "" {
return nil, "", errors.New("web request fail: key nil")
}
res, err := wp.Request(out_trade_no, fee, client_ip, duration, open_id)
if err != nil {
return nil, "", err
}
if res.ReturnCode.Text != "SUCCESS" || res.ResultCode.Text != "SUCCESS" {
return nil, "", errors.New("web request fail:" + res.ErrCodeDes.Text)
}
webres := &WebRequest{
AppID: wp.AppId,
TimeStamp: strconv.FormatInt(time.Now().Unix(), 10),
NonceStr: createNonceStr(),
Package: "prepay_id=" + res.PrepayID.Text,
SignType: "MD5",
}
err = webres.SignUp(wp.Key)
if err != nil {
return nil, "", err
}
return webres, res.PrepayID.Text, nil
}
查詢訂單
type QueryRespon struct {
ReturnCode CDATA `xml:"return_code"` //返回錯誤碼
ReturnMsg CDATA `xml:"return_msg"` //返回信息
AppID CDATA `xml:"appid"` //公眾賬號ID
MchID CDATA `xml:"mch_id"` //商戶號
NonceStr CDATA `xml:"nonce_str"` //隨機字符串
Sign CDATA `xml:"sign"` //簽名
ResultCode CDATA `xml:"result_code"` //業(yè)務(wù)結(jié)果
ErrCode CDATA `xml:"err_code"` //錯誤代碼
ErrCodeDes CDATA `xml:"err_code_des"` //錯誤代碼描述
DeviceInfo CDATA `xml:"device_info"` //設(shè)備號
OpenID CDATA `xml:"openid"` //用戶標(biāo)識
IsSubscribe CDATA `xml:"is_subscribe"` //是否關(guān)注公眾賬號
TradeType CDATA `xml:"trade_type"` //交易類型
TradeState CDATA `xml:"trade_state"` //交易狀態(tài)
BankType CDATA `xml:"bank_type"` //付款銀行
TotalFee int `xml:"total_fee"` //訂單金額
FeeType CDATA `xml:"fee_type"` //貨幣種類
CashFee CDATA `xml:"cash_fee"` //現(xiàn)金支付金額
CashFeeType CDATA `xml:"cash_fee_type"` //現(xiàn)金支付貨幣類型
TransactionID CDATA `xml:"transaction_id"` //微信支付訂單號
OutTradeNO CDATA `xml:"out_trade_no"` //商戶訂單號
Attach CDATA `xml:"attach"` //商家數(shù)據(jù)包
TimeEnd CDATA `xml:"time_end"` //支付完成時間
SignType CDATA `xml:"sign_type"` //簽名類型
TradeStateDesc CDATA `xml:"trade_state_desc"` //交易狀態(tài)描述
}
//查詢訂單
func (wp *WePay) Query(out_trade_no string) (res *QueryRespon, err error) {
if wp.MchID == "" || wp.AppId == "" {
return nil, errors.New("wepay query fail: mchid or appid nil")
}
if out_trade_no == "" {
return nil, errors.New("wepay query fail: out_trade_no nil")
}
randomStr := createNonceStr()
if len(randomStr) != 32 {
return nil, errors.New("wepay query fail: random str error")
}
q := &QueryRequest{
AppID: wp.AppId,
MchID: wp.MchID,
OutTradeNo: out_trade_no,
NonceStr: randomStr,
SignType: "MD5",
}
err = q.SignUp(wp.Key)
if err != nil {
return nil, errors.New("wepay query fail: " + err.Error())
}
respon, err := post(wp.OrderQueryUrl, q)
if err != nil {
return nil, err
}
logger.Info("查詢訂單：" + string(respon))
queryRespon := &QueryRespon{}
err = xml.Unmarshal(respon, &queryRespon)
if err != nil {
return nil, err
}
return queryRespon, nil
}
