Merge branch 'master' of e.coding.net:rosydev/baseapi

platformapi/uuptapi/callback.go

@@ -1,10 +1,11 @@
 package uuptapi
 
 import (
+	"bytes"
 	"encoding/json"
+	"errors"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/globals"
-	"io/ioutil"
 	"net/http"
 )
 
@@ -40,37 +41,20 @@ func (a *API) WaybillCallback(request *http.Request) (*WaybillCallbackParam, *Ca
 	//if callbackResponse := a.CheckCallbackValidation(request); callbackResponse != nil {
 	//	return nil, callbackResponse
 	//}
-
+	retVal := WaybillCallbackParam{}
-	buf, err := ioutil.ReadAll(request.Body)
+	data := request.PostForm.Get("data")
-	if err != nil {
+	b := bytes.NewBufferString(data)
-		globals.SugarLogger.Debugf("========buf err %v", err)
+	decoder := json.NewDecoder(b)
-		return nil, &CallbackResponse{
+	if err := decoder.Decode(&retVal); err != nil {
-			ReturnCode: "2065",
+		return nil, Err2CallbackResponse(errors.New("uu跑腿回调参数解析错误,请检查"))
-			ReturnMsg:  "错误",
-		}
 	}
-	retVal := &WaybillCallbackParam{}
+	globals.SugarLogger.Debugf("uupt WaybillCallback retVal======%s", utils.Format4Output(retVal, false))
-	if err := json.Unmarshal(buf, retVal); err != nil {
+	con := retVal != WaybillCallbackParam{}
-		globals.SugarLogger.Debugf("========buf err %v", err)
+	if con {
-		return nil, &CallbackResponse{
+		return &retVal, Err2CallbackResponse(nil)
-			ReturnCode: "20625",
+	} else {
-			ReturnMsg:  "错误2",
+		return nil, Err2CallbackResponse(errors.New("UU跑腿运单回调信息为空"))
-		}
 	}
-	globals.SugarLogger.Debugf("====retVal := %s", utils.Format4Output(retVal, false))
-
-	//retVal := WaybillCallbackParam{}
-	//if err := utils.Map2StructByJson(utils.URLValues2Map(request.PostForm), &retVal, true); err != nil {
-	//	return nil, Err2CallbackResponse(err)
-	//}
-	globals.SugarLogger.Debugf("retval======%s", utils.Format4Output(retVal, false))
-	//con := retVal != WaybillCallbackParam{}
-	//if con {
-	//	return &retVal, Err2CallbackResponse(nil)
-	//} else {
-	//	return nil, Err2CallbackResponse(fmt.Errorf("UU跑腿运单回调信息为空"))
-	//}
-	return retVal, Err2CallbackResponse(nil)
 }
 
 func (a *API) CheckCallbackValidation(request *http.Request) (callbackResponse *CallbackResponse) {