diff --git a/platformapi/jdapi/fake_jdapi.go b/platformapi/jdapi/fake_jdapi.go index c04da037..c4eddd48 100644 --- a/platformapi/jdapi/fake_jdapi.go +++ b/platformapi/jdapi/fake_jdapi.go @@ -6,15 +6,17 @@ import ( "git.rosy.net.cn/baseapi/utils" ) -func (a *API) FakeOrderQuery(jdParams map[string]interface{}) (retVal []interface{}, totalCount int, err error) { - retVal, totalCount, err = a.AccessAPIHavePage("order/orderQuery", jdParams, nil, nil, nil) +func (a *API) FakeOrderQuery(jdParams map[string]interface{}) (retVal []*OrderInfo, totalCount int, err error) { + orderList, totalCount, err := a.AccessAPIHavePage("order/orderQuery", jdParams, nil, nil, nil) + if err == nil { + err = JdMap2StructByJson(orderList, &retVal, true) + } return retVal, totalCount, err } -func (a *API) FakeQuerySingleOrder(orderId, deliveryStationNo string) (map[string]interface{}, error) { +func (a *API) FakeQuerySingleOrder(orderId string) (*OrderInfo, error) { jdParams := make(map[string]interface{}) jdParams["orderId"] = orderId - jdParams["deliveryStationNo "] = deliveryStationNo result, _, err := a.FakeOrderQuery(jdParams) if err != nil { return nil, err @@ -22,7 +24,7 @@ func (a *API) FakeQuerySingleOrder(orderId, deliveryStationNo string) (map[strin if len(result) == 0 { return nil, ErrCanNotFindOrder } - return result[0].(map[string]interface{}), nil + return result[0], nil } func (a *API) FakeBatchUpdateCurrentQtys(trackInfo, outStationNo, stationNo string, skuStockList []*SkuStock, userPin string) (responseList []*StoreSkuBatchUpdateResponse, err error) { diff --git a/platformapi/jdapi/fake_jdapi_test.go b/platformapi/jdapi/fake_jdapi_test.go index 8b712d0b..80531607 100644 --- a/platformapi/jdapi/fake_jdapi_test.go +++ b/platformapi/jdapi/fake_jdapi_test.go @@ -10,7 +10,7 @@ import ( func TestFakeOrderQuery(t *testing.T) { api := NewFakeJD("ndslkv9asl@djf_n7askdjfk$", "http://test.jxc4.com/qqqq") - retVal, err := api.FakeQuerySingleOrder("2000483691000741", "11866256") + retVal, err := api.FakeQuerySingleOrder("2002984074001021") t.Log(utils.Format4Output(retVal, false)) if err != nil { t.Error(err) diff --git a/platformapi/wxpayapi/callback.go b/platformapi/wxpayapi/callback.go index acb4c27c..488a12db 100644 --- a/platformapi/wxpayapi/callback.go +++ b/platformapi/wxpayapi/callback.go @@ -171,8 +171,9 @@ func (a *API) getCallbackMsg(msgBody string) (msg *CallbackMsg, callbackResponse reqInfo := utils.Interface2String(mapData["req_info"]) transactionID := utils.Interface2String(mapData["transaction_id"]) if reqInfo == "" && transactionID != "" { // 对于支付结果通知进行签名验证(退款结果通知不支持验证) + sigType := utils.Interface2String(mapData[sigTypeKey]) sign := utils.Interface2String(mapData[sigKey]) - desiredSign := a.signParam(mapData) + desiredSign := a.signParam(sigType, mapData) if desiredSign != sign { return nil, Err2CallbackResponse(fmt.Errorf("desiredSign:%s <> sign:%s", desiredSign, sign), "") } diff --git a/platformapi/wxpayapi/wxpayapi.go b/platformapi/wxpayapi/wxpayapi.go index c9bc3457..68d60b3e 100644 --- a/platformapi/wxpayapi/wxpayapi.go +++ b/platformapi/wxpayapi/wxpayapi.go @@ -2,6 +2,8 @@ package wxpayapi import ( "bytes" + "crypto/hmac" + "crypto/md5" "crypto/sha256" "crypto/tls" "encoding/xml" @@ -26,9 +28,10 @@ const ( ResponseCodeSuccess = "SUCCESS" ResponseCodeFail = "FAIL" - sigKey = "sign" - sigTypeKey = "sign_type" - sigType = "HMAC-SHA256" + sigKey = "sign" + sigTypeKey = "sign_type" + sigTypeMd5 = "MD5" + sigTypeSha256 = "HMAC-SHA256" ) const ( @@ -328,7 +331,7 @@ func (a *API) GetMchID() string { return a.mchID } -func (a *API) signParam(params map[string]interface{}) (sig string) { +func (a *API) signParam(signType string, params map[string]interface{}) (sig string) { var valueList []string for k, v := range params { if k != sigKey { @@ -340,7 +343,17 @@ func (a *API) signParam(params map[string]interface{}) (sig string) { sort.Sort(sort.StringSlice(valueList)) valueList = append(valueList, fmt.Sprintf("key=%s", a.appKey)) sig = strings.Join(valueList, "&") - sig = fmt.Sprintf("%X", sha256.Sum256([]byte(sig))) + var binSig []byte + if signType == sigTypeMd5 { + binSig2 := md5.Sum([]byte(sig)) + binSig = binSig2[:] + } else if signType == sigTypeSha256 { + mac := hmac.New(sha256.New, []byte(a.appKey)) + mac.Write([]byte(sig)) + binSig = mac.Sum(nil) + } + sig = fmt.Sprintf("%X", binSig) + // baseapi.SugarLogger.Debug(sig) return sig } @@ -356,8 +369,10 @@ func (a *API) AccessAPI(action string, requestParam IRequestBase) (retVal map[st requestParam.SetAppID(a.appID) requestParam.SetMchID(a.mchID) requestParam.SetNonceStr(utils.GetUUID()) + sigType := sigTypeSha256 + // sigType := sigTypeMd5 requestParam.SetSignType(sigType) - signStr := a.signParam(utils.Struct2FlatMap(requestParam)) + signStr := a.signParam(sigType, utils.Struct2FlatMap(requestParam)) requestParam.SetSign(signStr) fullURL := utils.GenerateGetURL(prodURL, action, nil)