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 09:51:58 +08:00
parent e4f3e17527
commit b35d5029dc
1 changed files with 62 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -470,7 +470,7 @@ func pushCallbackToGy(urlIndex string, msg interface{}) {
request *http.Request request *http.Request
param = make(map[string]interface{}) param = make(map[string]interface{})
) )
param = msg.(map[string]interface{}) param = changeToRaw(urlIndex, msg)
globals.SugarLogger.Debugf("sfsfsf pushCallbackToGy param=%s", utils.Format4Output(param, false)) globals.SugarLogger.Debugf("sfsfsf pushCallbackToGy param=%s", utils.Format4Output(param, false))
switch urlIndex { switch urlIndex {
case sfps2.UrlIndexRiderException: case sfps2.UrlIndexRiderException:
@@ -633,6 +633,67 @@ func getWaybillByStatus(urlIndex string, msg interface{}) (waybill *model.Waybil
return waybill return waybill
} }
//转换原始数据 转发果园
func changeToRaw(urlIndex string, msg interface{}) (retVal map[string]interface{}) {
switch urlIndex {
case sfps2.UrlIndexRiderStatus:
temp := msg.(sfps2.RiderStatus)
retVal["shop_id"] = temp.ShopId
retVal["sf_order_id"] = temp.SFOrderID
retVal["shop_order_id"] = temp.ShopOrderID
retVal["url_index"] = temp.UrlIndex
retVal["operator_name"] = temp.OperatorName
retVal["operator_phone"] = temp.OperatorPhone
retVal["rider_lng"] = temp.RiderLng
retVal["rider_lat"] = temp.RiderLat
retVal["order_status"] = temp.OrderStatus
retVal["status_desc"] = temp.StatusDesc
retVal["sf_ucode"] = temp.SFUCode
retVal["push_time"] = temp.PushTime
case sfps2.UrlIndexRiderRecall:
temp := msg.(sfps2.RiderRecall)
retVal["order_status"] = temp.OrderStatus
retVal["push_time"] = temp.PushTime
retVal["sf_order_id"] = temp.SFOrderID
retVal["shop_id"] = temp.ShopId
retVal["shop_order_id"] = temp.ShopOrderID
retVal["url_index"] = temp.UrlIndex
retVal["status_desc"] = temp.StatusDesc
case sfps2.UrlIndexOrderComplete:
temp := msg.(sfps2.OrderComplete)
retVal["operator_name"] = temp.OperatorName
retVal["operator_phone"] = temp.OperatorPhone
retVal["order_status"] = temp.OrderStatus
retVal["push_time"] = temp.PushTime
retVal["receiRpt_type"] = temp.ReceiRptType
retVal["rider_lat"] = temp.RiderLat
retVal["rider_lng"] = temp.RiderLng
retVal["sf_order_id"] = temp.SfOrderID
retVal["sf_ucode"] = temp.SfUcode
retVal["shop_id"] = temp.ShopId
retVal["shop_order_id"] = temp.ShopOrderID
retVal["status_desc"] = temp.StatusDesc
retVal["url_index"] = temp.UrlIndex
case sfps2.UrlIndexSFCancel:
temp := msg.(sfps2.SFCancel)
retVal["cancel_reason"] = temp.CancelReason
retVal["cancel_code"] = temp.CancelCode
retVal["operator_name"] = temp.OperatorName
retVal["operator_phone"] = temp.OperatorPhone
retVal["order_status"] = temp.OrderStatus
retVal["push_time"] = temp.PushTime
retVal["rider_lat"] = temp.RiderLat
retVal["rider_lng"] = temp.RiderLng
retVal["sf_order_id"] = temp.SFOrderID
retVal["sf_ucode"] = temp.SFUCode
retVal["shop_id"] = temp.ShopId
retVal["shop_order_id"] = temp.ShopOrderID
retVal["url_index"] = temp.UrlIndex
retVal["status_desc"] = temp.StatusDesc
}
return retVal
}
// GetVendorSource 辅助函数 // GetVendorSource 辅助函数
//获取订单来源标识符 //获取订单来源标识符
func GetVendorSource(vendorID int) (source string) { func GetVendorSource(vendorID int) (source string) {