1
This commit is contained in:
@@ -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)), "")
|
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 {
|
if _, err = s.CreateWaybillOnProviders4SavedOrder(jxcontext.AdminCtx, savedOrderInfo, nil, excludeVendorIDs, false, maxDeliveryFee); err == nil {
|
||||||
savedOrderInfo.retryCount++
|
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 {
|
} else {
|
||||||
|
|||||||
27
controllers/taobao_vegetable.go
Normal file
27
controllers/taobao_vegetable.go
Normal file
@@ -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
|
||||||
|
|
||||||
|
}
|
||||||
@@ -199,8 +199,8 @@ func init() {
|
|||||||
web.AutoRouter(&controllers.TiktokShopController{}) // 门店授权
|
web.AutoRouter(&controllers.TiktokShopController{}) // 门店授权
|
||||||
web.AutoRouter(&controllers.LogisticsController{}) // 抖音快递信息同步
|
web.AutoRouter(&controllers.LogisticsController{}) // 抖音快递信息同步
|
||||||
web.AutoRouter(&controllers.KuaiShouController{}) // 快手支付回调
|
web.AutoRouter(&controllers.KuaiShouController{}) // 快手支付回调
|
||||||
|
web.AutoRouter(&controllers.TaoBaoVegetableController{}) // 淘菜菜回调
|
||||||
//web.AutoRouter(&controllers.IMController{}) //im
|
//web.AutoRouter(&controllers.IMController{}) //im
|
||||||
|
|
||||||
// 如下都是用于检测存活的空接口
|
// 如下都是用于检测存活的空接口
|
||||||
web.Any("/", func(ctx *beecontext.Context) {
|
web.Any("/", func(ctx *beecontext.Context) {
|
||||||
ctx.WriteString("pong\n")
|
ctx.WriteString("pong\n")
|
||||||
|
|||||||
Reference in New Issue
Block a user