From 9f63205cba254a1943491874cdaf555fc1fb5447 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Tue, 13 Jun 2023 09:32:30 +0800 Subject: [PATCH] 1 --- .../jxcallback/scheduler/defsch/defsch.go | 4 +++ controllers/taobao_vegetable.go | 27 +++++++++++++++++++ routers/router.go | 10 +++---- 3 files changed, 36 insertions(+), 5 deletions(-) create mode 100644 controllers/taobao_vegetable.go diff --git a/business/jxcallback/scheduler/defsch/defsch.go b/business/jxcallback/scheduler/defsch/defsch.go index 517342e93..bef0e9261 100644 --- a/business/jxcallback/scheduler/defsch/defsch.go +++ b/business/jxcallback/scheduler/defsch/defsch.go @@ -986,6 +986,10 @@ func (s *DefScheduler) createWaybillOn3rdProviders(savedOrderInfo *WatchOrderInf partner.CurOrderManager.OnOrderMsg(order, fmt.Sprintf("发起自动创建三方运单,目标创建运单平台[%s],排除平台[%s]", jxutils.GetVendorName(vendorID), utils.Format4Output(excludeVendorIDs, false)), "") if _, err = s.CreateWaybillOnProviders4SavedOrder(jxcontext.AdminCtx, savedOrderInfo, nil, excludeVendorIDs, false, maxDeliveryFee); err == nil { savedOrderInfo.retryCount++ + } else { + partner.CurOrderManager.OnOrderMsg(order, fmt.Sprintf("发起自动创建三方运单,目标创建运单平台[%s],创建失败:%v", jxutils.GetVendorName(vendorID), err), "") + content := "您的门店 [" + storeDetail.Name + "],OrderID:[" + order.VendorOrderID + "],自动呼叫骑手失败[" + fmt.Sprintf(err.Error()) + "],请手动呼叫骑手" + ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "平台门店状态变化", content) } } } else { diff --git a/controllers/taobao_vegetable.go b/controllers/taobao_vegetable.go new file mode 100644 index 000000000..38c4c7ec0 --- /dev/null +++ b/controllers/taobao_vegetable.go @@ -0,0 +1,27 @@ +package controllers + +import ( + "github.com/astaxie/beego/server/web" +) + +type TaoBaoVegetableController struct { + web.Controller +} + +// GetCode 淘菜菜获取商户授权code +func (c *TaoBaoVegetableController) GetCode() { + //if c.Ctx.Input.Method() == http. + //body, err := ioutil.ReadAll(c.Ctx.Request.Body) + //globals.SugarLogger.Debug("商户收取code获取:%s",string(body)) + //if err != nil { + // return + //} + // + //var codeObj *tao_vegetable.ShopCode + //if err := json.Unmarshal(body,&codeObj);err != nil { + // return + //} + // + //if codeObj.ResponseType + +} diff --git a/routers/router.go b/routers/router.go index cffa98c5c..1a0ff0a95 100644 --- a/routers/router.go +++ b/routers/router.go @@ -195,12 +195,12 @@ func init() { web.AutoRouter(&controllers.TicTocController{}) web.AutoRouter(&controllers.EnterpriseController{}) - web.AutoRouter(&controllers.TiktokController{}) // 订单 - web.AutoRouter(&controllers.TiktokShopController{}) // 门店授权 - web.AutoRouter(&controllers.LogisticsController{}) // 抖音快递信息同步 - web.AutoRouter(&controllers.KuaiShouController{}) // 快手支付回调 + web.AutoRouter(&controllers.TiktokController{}) // 订单 + web.AutoRouter(&controllers.TiktokShopController{}) // 门店授权 + web.AutoRouter(&controllers.LogisticsController{}) // 抖音快递信息同步 + web.AutoRouter(&controllers.KuaiShouController{}) // 快手支付回调 + web.AutoRouter(&controllers.TaoBaoVegetableController{}) // 淘菜菜回调 //web.AutoRouter(&controllers.IMController{}) //im - // 如下都是用于检测存活的空接口 web.Any("/", func(ctx *beecontext.Context) { ctx.WriteString("pong\n")