diff --git a/controllers/dada_order.go b/controllers/dada_order.go index bf9a258e6..290e91d62 100644 --- a/controllers/dada_order.go +++ b/controllers/dada_order.go @@ -3,8 +3,10 @@ package controllers import ( "net/http" + "git.rosy.net.cn/baseapi/platformapi/dadaapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/partner/delivery/dada" + "git.rosy.net.cn/jx-callback/globals" "git.rosy.net.cn/jx-callback/globals/api" "github.com/astaxie/beego" ) @@ -30,3 +32,21 @@ func (c *DadaDeliveryController) Msg() { c.Abort("404") } } + +func (c *DadaDeliveryController) Notify() { + if c.Ctx.Input.Method() == http.MethodPost { + obj, notifyResponse := api.DadaAPI.GetNotifyMsg(c.Ctx.Input.RequestBody) + if notifyResponse == nil { + err := api.DadaAPI.ConfirmRidderCancel(obj.MessageObj.OrderID, obj.MessageObj.DadaOrderID, true) + globals.SugarLogger.Debugf("dada notify, obj:%s, err:%v", utils.Format4Output(obj, false), err) + } + if notifyResponse == nil { + notifyResponse = dadaapi.SuccessNotifyResponse + } else { + c.Data["json"] = notifyResponse + c.ServeJSON() + } + } else { + c.Abort("404") + } +}