liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
richboo111
2024-01-10 16:27:39 +08:00
parent bf27e49297
commit 6092ee22f9
1 changed files with 3 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
business/partner/delivery/sfps/waybill.go
View File

@@ -1,7 +1,6 @@
package sfps package sfps
import ( import (
"bufio"
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
@@ -380,9 +379,7 @@ func OnWaybillMsg(urlIndex string, msg interface{}) (resp *sfps2.CallbackRespons
order, goodsOrder := GetWaybillByStatus(urlIndex, msg) order, goodsOrder := GetWaybillByStatus(urlIndex, msg)
//判断是否是果园 //判断是否是果园
globals.SugarLogger.Debugf("sfsfsf goodsOrder=%s runMode=%s", utils.Format4Output(goodsOrder, false), beego.BConfig.RunMode)
if goodsOrder == nil && beego.BConfig.RunMode != "jxgy" { if goodsOrder == nil && beego.BConfig.RunMode != "jxgy" {
globals.SugarLogger.Debugf("sfsfsf 我在这里")
pushCallbackToGy(urlIndex, msg) pushCallbackToGy(urlIndex, msg)
return sfps2.SuccessResponse return sfps2.SuccessResponse
} }
@@ -401,10 +398,8 @@ func OnWaybillMsg(urlIndex string, msg interface{}) (resp *sfps2.CallbackRespons
sfOrder, err := api.SfPsAPI.GetOrderStatus(order.VendorWaybillID) sfOrder, err := api.SfPsAPI.GetOrderStatus(order.VendorWaybillID)
if err != nil { if err != nil {
globals.SugarLogger.Debugf("SFPS OnWaybillMsg GetOrderStatus err=%v", err)
return sfps2.Err2CallbackResponse(err) return sfps2.Err2CallbackResponse(err)
} }
globals.SugarLogger.Debugf("SFPS OnWaybillMsg sfOrder=%s", utils.Format4Output(sfOrder, false))
if order.CourierMobile == "" { if order.CourierMobile == "" {
order.CourierName = sfOrder.RiderName order.CourierName = sfOrder.RiderName
} }
@@ -414,7 +409,6 @@ func OnWaybillMsg(urlIndex string, msg interface{}) (resp *sfps2.CallbackRespons
sfTotalPrice := utils.Float64TwoInt(sfOrder.TotalPrice) sfTotalPrice := utils.Float64TwoInt(sfOrder.TotalPrice)
sfActualPrice := utils.Float64TwoInt64(sfOrder.RealPayMoney) sfActualPrice := utils.Float64TwoInt64(sfOrder.RealPayMoney)
globals.SugarLogger.Debugf("SFPS OnWaybillMsg,sfTotalPrice=%d,sfActualPrice=%d", sfTotalPrice, sfActualPrice)
store, _ := dao.GetStoreDetail(dao.GetDB(), goodsOrder.JxStoreID, goodsOrder.VendorID, goodsOrder.VendorOrgCode) store, _ := dao.GetStoreDetail(dao.GetDB(), goodsOrder.JxStoreID, goodsOrder.VendorID, goodsOrder.VendorOrgCode)
sfTotalPrice += store.FreightMarkup sfTotalPrice += store.FreightMarkup
@@ -469,17 +463,13 @@ func pushCallbackToGy(urlIndex string, msg interface{}) {
err error err error
client = &http.Client{} client = &http.Client{}
request *http.Request request *http.Request
param = make(map[string]interface{})
) )
//param = changeToRaw(urlIndex, msg)
//globals.SugarLogger.Debugf("sfsfsf pushCallbackToGy param=%s", utils.Format4Output(param, false))
globals.SugarLogger.Debugf("pushCallbackToGy msg=%s", utils.Format4Output(msg, false))
b, _ := json.Marshal(msg) b, _ := json.Marshal(msg)
//sign := api.SfPsAPI.SignParam(b)
switch urlIndex { switch urlIndex {
case sfps2.UrlIndexRiderException: case sfps2.UrlIndexRiderException:
request, err = http.NewRequest(http.MethodPost, "http://callback-jxgy.jxc4.com/SFPS/SfAbnormal", bufio.NewReader(strings.NewReader(utils.Map2URLValues(param).Encode()))) request, err = http.NewRequest(http.MethodPost, "http://callback-jxgy.jxc4.com/SFPS/SfAbnormal", strings.NewReader(string(b)))
default: default:
//fullUrl := utils.GenerateGetURL("http://callback-jxgy.jxc4.com/SFPS/SfOrder", "", map[string]interface{}{"sign": sign}) //fullUrl := utils.GenerateGetURL("http://callback-jxgy.jxc4.com/SFPS/SfOrder", "", map[string]interface{}{"sign": sign})
//request, err = http.NewRequest(http.MethodPost, fullUrl, strings.NewReader(string(b))) //request, err = http.NewRequest(http.MethodPost, fullUrl, strings.NewReader(string(b)))
@@ -487,10 +477,9 @@ func pushCallbackToGy(urlIndex string, msg interface{}) {
} }
if err != nil { if err != nil {
globals.SugarLogger.Debugf("pushCallbackToGy test reqData err=%v", err) globals.SugarLogger.Debugf("pushCallbackToGy req err=%v", err)
return return
} }
//request.Header.Set("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
request.Header.Set("Content-Type", "application/json; charset=UTF-8") request.Header.Set("Content-Type", "application/json; charset=UTF-8")
resp, err := client.Do(request) resp, err := client.Do(request)
resopp, _ := ioutil.ReadAll(resp.Body) resopp, _ := ioutil.ReadAll(resp.Body)