liulei/baseapi
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

111

Browse Source
This commit is contained in:
邹宗楠
2022-04-01 14:50:35 +08:00
parent f95c43c47d
commit d235e9b4c9
1 changed files with 42 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
platformapi/fnpsapi/callback.go
View File

@@ -43,20 +43,13 @@ type ShortStatus struct {
BusinessData string `json:"business_data"`
}
// 门店状态回调
type ChainstoreStatusNotify struct {
CallbackBusinessType string `json:"callback_business_type"`
Param *ChainstoreParam `json:"param"`
}
//#region 订单
// 门店状态回调paramter
type ChainstoreParam struct {
MerchantId string `json:"merchant_id"` // 商户id
ChainStoreId string `json:"chain_store_id"` // 蜂鸟门店id
OutShopCode string `json:"out_shop_code"` // 外部门店编码
Status string `json:"status"` // 门店认证状态
ModifyStatus string `json:"modify_status"` // 门店修改状态
Remark string `json:"remark"` // 门店认证、修改等驳回时返回原因
type CallBackOrder struct {
AppId string `json:"app_id"`
Signature string `json:"signature"`
Timestamp string `json:"timestamp"`
BusinessData *OrderStatusNottify `json:"business_data"`
}
// 订单状态
@@ -84,6 +77,23 @@ type OrderCallbackParam struct {
Transfer int `json:"transfer"` // 转单标识 转单标识 1 是转单 0非转单
}
//#endregion
// 门店状态回调
type ChainstoreStatusNotify struct {
CallbackBusinessType string `json:"callback_business_type"`
Param *ChainstoreParam `json:"param"`
}
// 门店状态回调paramter
type ChainstoreParam struct {
MerchantId string `json:"merchant_id"` // 商户id
ChainStoreId string `json:"chain_store_id"` // 蜂鸟门店id
OutShopCode string `json:"out_shop_code"` // 外部门店编码
Status string `json:"status"` // 门店认证状态
ModifyStatus string `json:"modify_status"` // 门店修改状态
Remark string `json:"remark"` // 门店认证、修改等驳回时返回原因
}
// 出餐回调
type CookingFinishNotify struct {
OrderId int64 `json:"order_id"` // 订单号
@@ -142,34 +152,18 @@ func (a *API) GetChainstoreStatusNotify(request *http.Request) (shopStatusMsg *C
// 获取订单状态回调消息
func (a *API) GetChainOrderStatusNotify(request *http.Request) (shopStatusMsg *OrderStatusNottify, callbackResponse *CallbackResponse) {
data, err := ioutil.ReadAll(request.Body)
if err != nil {
baseapi.SugarLogger.Debugf("FN GetChainOrderStatusNotify failed with No result msg err:%v", err)
callbackResponse = &CallbackResponse{Code: -1}
return nil, callbackResponse
err := request.ParseForm()
var refundData *CallBackOrder
if err == nil {
data := utils.URLValues2Map(request.Form)
if err = utils.Map2StructByJson(data, &refundData, true); err == nil {
return nil, SignatureIsNotOk
}
}
//storeNotify := &OrderStatusNottify{}
fmt.Println("string==================", string(data))
//if err := json.Unmarshal(data, &storeNotify); err != nil {
// baseapi.SugarLogger.Debugf("FN GetShopStatusCallbackMsg failed with err:%v", err)
// callbackResponse = &CallbackResponse{Code: -1}
// return nil, callbackResponse
//}
//fmt.Println("======================", storeNotify)
//fnNotify := &OrderCallbackParam{}
//if err := json.Unmarshal([]byte(storeNotify.Param), fnNotify); err != nil {
// baseapi.SugarLogger.Debugf("FN callback string to ChainstoreStatusNotify failed with err:%v", err)
// callbackResponse = &CallbackResponse{Code: -1}
// return nil, callbackResponse
//}
//fmt.Println("======================business_data", storeNotify.Param)
//fmt.Println("======================business_data", storeNotify.Param.OrderId)
//fmt.Println("======================business_data", storeNotify.Param.PartnerOrderCode)
//fmt.Println("======================business_data", storeNotify.CallbackBusinessType)
return nil, SuccessResponse
fmt.Println("==============", refundData.BusinessData)
fmt.Println("==============", refundData.BusinessData.Param)
fmt.Println("==============", refundData.BusinessData.Param.PartnerOrderCode)
return refundData.BusinessData, SuccessResponse
}
// 异常配送
@@ -197,3 +191,11 @@ func (a *API) GetChainAbnormaltatusNotify(request *http.Request) (shopStatusMsg
return fnNotify, SuccessResponse
}
func (a *API) CheckCallbackValidation(request *http.Request) (callbackResponse *CallbackResponse) {
err := request.ParseForm()
if err != nil {
callbackResponse = Err2CallbackResponse(err, "")
}
return callbackResponse
}