114 lines
3.4 KiB
Go
114 lines
3.4 KiB
Go
package ebaiapi
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"net/http"
|
|
"net/url"
|
|
|
|
"git.rosy.net.cn/baseapi"
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
)
|
|
|
|
const (
|
|
CmdOrderCreate = "order.create"
|
|
CmdOrderDeliveryStatus = "order.deliveryStatus.push"
|
|
CmdOrderPartRefund = "order.partrefund.push" // 售前只能是商户发起 售后是用户, 你看是由谁发起的就可以知道，来自惠焕
|
|
CmdOrderStatus = "order.status.push"
|
|
CmdOrderUserCancel = "order.user.cancel"
|
|
|
|
CmdShopMsgPush = "shop.msg.push"
|
|
CmdShopBindMsg = "shop.bind.msg"
|
|
CmdShopUnbindMsg = "shop.unbind.msg"
|
|
)
|
|
|
|
type CallbackResponse struct {
|
|
Cmd string `json:"cmd"`
|
|
Sign string `json:"sign"`
|
|
Source string `json:"source"`
|
|
Ticket string `json:"ticket"`
|
|
Encrypt string `json:"encrypt"`
|
|
Timestamp int64 `json:"timestamp"`
|
|
Version int `json:"version"`
|
|
Body *ResponseResult `json:"body"`
|
|
}
|
|
|
|
type CallbackMsg struct {
|
|
Cmd string `json:"cmd"`
|
|
Timestamp int64 `json:"timestamp"`
|
|
Body map[string]interface{} `json:"body"`
|
|
}
|
|
|
|
func (a *API) Err2CallbackResponse(cmd string, err error, data interface{}) *CallbackResponse {
|
|
response := &CallbackResponse{
|
|
Cmd: "resp." + cmd,
|
|
Source: a.source,
|
|
Ticket: utils.GetUpperUUID(),
|
|
Timestamp: utils.GetCurTimestamp(),
|
|
Version: 3,
|
|
}
|
|
if err == nil {
|
|
response.Body = &ResponseResult{
|
|
Error: "success",
|
|
ErrNo: 0,
|
|
Data: data,
|
|
}
|
|
} else {
|
|
response.Body = &ResponseResult{
|
|
Error: fmt.Sprintf("error:%v, data:%v", err, data),
|
|
ErrNo: -1,
|
|
Data: data,
|
|
}
|
|
}
|
|
params := url.Values{
|
|
"cmd": []string{response.Cmd},
|
|
"version": []string{utils.Int2Str(response.Version)},
|
|
"timestamp": []string{utils.Int64ToStr(response.Timestamp)},
|
|
"ticket": []string{response.Ticket},
|
|
"source": []string{response.Source},
|
|
"body": []string{string(utils.MustMarshal(response.Body))},
|
|
"encrypt": []string{""},
|
|
}
|
|
response.Sign = a.signParams(params)
|
|
return response
|
|
}
|
|
|
|
func (a *API) unmarshalData(cmd string, data []byte, msg interface{}) (callbackResponse *CallbackResponse) {
|
|
err := utils.UnmarshalUseNumber(data, msg)
|
|
if err != nil {
|
|
return a.Err2CallbackResponse(cmd, err, nil)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (a *API) CheckCallbackValidation(request *http.Request) (callbackResponse *CallbackResponse) {
|
|
params := make(url.Values)
|
|
for k, v := range request.PostForm {
|
|
params[k] = v
|
|
}
|
|
sign := a.signParams(params)
|
|
if sign != request.FormValue(signKey) {
|
|
msg := fmt.Sprintf("Signature is not ok, mine:%v, get:%v", sign, request.FormValue(signKey))
|
|
baseapi.SugarLogger.Info(msg)
|
|
return a.Err2CallbackResponse(request.FormValue("cmd"), errors.New(msg), nil)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (a *API) GetCallbackMsg(request *http.Request) (msg *CallbackMsg, callbackResponse *CallbackResponse) {
|
|
err := request.ParseForm()
|
|
if err == nil {
|
|
if callbackResponse = a.CheckCallbackValidation(request); callbackResponse != nil {
|
|
return nil, callbackResponse
|
|
}
|
|
msg = new(CallbackMsg)
|
|
if callbackResponse = a.unmarshalData(request.FormValue("cmd"), []byte(request.FormValue("body")), &msg.Body); callbackResponse != nil {
|
|
return nil, callbackResponse
|
|
}
|
|
msg.Cmd = request.FormValue("cmd")
|
|
msg.Timestamp = utils.Str2Int64(utils.Interface2String(request.FormValue("timestamp")))
|
|
return msg, nil
|
|
}
|
|
return nil, a.Err2CallbackResponse("", err, nil)
|
|
}
|