liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加自动发单,只发一个

Browse Source
This commit is contained in:
邹宗楠
2023-06-08 09:26:31 +08:00
parent e48f0e5b8b
commit 7d8724b02a
2 changed files with 40 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

79
business/jxcallback/scheduler/defsch/defsch.go
View File

@@ -946,45 +946,46 @@ func (s *DefScheduler) createWaybillOn3rdProviders(savedOrderInfo *WatchOrderInf
if err == nil && err2 == nil { if err == nil && err2 == nil {
// 1.检查门店三方配送配置,达达>蜂鸟>美团>顺丰>uu // 1.检查门店三方配送配置,达达>蜂鸟>美团>顺丰>uu
// excludeVendorIDs 包括上面已经发送的平台id // excludeVendorIDs 包括上面已经发送的平台id
//storeCourierList, err := dao.GetStoreCourierList2(dao.GetDB(), []int{jxutils.GetSaleStoreIDFromOrder(order)}, nil, model.StoreStatusOpened, []int{model.StoreAuditStatusOnline, model.StoreAuditStatusUpdated}) storeCourierList, err := dao.GetStoreCourierList2(dao.GetDB(), []int{jxutils.GetSaleStoreIDFromOrder(order)}, nil, model.StoreStatusOpened, []int{model.StoreAuditStatusOnline, model.StoreAuditStatusUpdated})
//excludeVendorIDsMap := make(map[int]int, 0) // 被排除的配送 excludeVendorIDsMap := make(map[int]int, 0) // 被排除的配送
//for _, v := range excludeVendorIDs { globals.SugarLogger.Debugf("excludeVendorIDs 1 ===========初始排除平台id列表 : %s", utils.Format4Output(excludeVendorIDs, false))
// excludeVendorIDsMap[v] = model.YES for _, v := range excludeVendorIDs {
//} excludeVendorIDsMap[v] = model.YES
// }
//vendorID := 0
//for _, v := range storeCourierList { vendorID := 0
// if excludeVendorIDsMap[v.VendorID] == model.YES { for _, v := range storeCourierList {
// continue if excludeVendorIDsMap[v.VendorID] == model.YES {
// } continue
// if v.VendorID == model.VendorIDDada { }
// excludeVendorIDs = []int{model.VendorIDFengNiao, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDSFPS} if v.VendorID == model.VendorIDDada {
// vendorID = v.VendorID excludeVendorIDs = []int{model.VendorIDFengNiao, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDSFPS}
// break vendorID = v.VendorID
// } break
// if v.VendorID == model.VendorIDFengNiao { }
// excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDSFPS} if v.VendorID == model.VendorIDFengNiao {
// vendorID = v.VendorID excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDSFPS}
// break vendorID = v.VendorID
// } break
// if v.VendorID == model.VendorIDMTPS { }
// excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDFengNiao, model.VendorIDUUPT, model.VendorIDSFPS} if v.VendorID == model.VendorIDMTPS {
// vendorID = v.VendorID excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDFengNiao, model.VendorIDUUPT, model.VendorIDSFPS}
// break vendorID = v.VendorID
// } break
// if v.VendorID == model.VendorIDUUPT { }
// excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDSFPS} if v.VendorID == model.VendorIDUUPT {
// vendorID = v.VendorID excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDSFPS}
// break vendorID = v.VendorID
// } break
// if v.VendorID == model.VendorIDSFPS { }
// excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDFengNiao} if v.VendorID == model.VendorIDSFPS {
// vendorID = v.VendorID excludeVendorIDs = []int{model.VendorIDDada, model.VendorIDMTPS, model.VendorIDUUPT, model.VendorIDFengNiao}
// break vendorID = v.VendorID
// } break
//} }
// }
//partner.CurOrderManager.OnOrderMsg(order, fmt.Sprintf("发起自动创建三方运单,目标创建运单平台[%s],排除平台[%s]", jxutils.GetVendorName(vendorID), utils.Format4Output(excludeVendorIDs, false)), err.Error()) globals.SugarLogger.Debugf("excludeVendorIDs 2 ===========初始排除平台id列表 : %s", 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++
} }

6
controllers/kuaishou_callback.go
View File

@@ -2,9 +2,7 @@ package controllers
import ( import (
"git.rosy.net.cn/baseapi/platformapi/kuaishou_mini" "git.rosy.net.cn/baseapi/platformapi/kuaishou_mini"
"git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/partner/purchase/jx/localjx" "git.rosy.net.cn/jx-callback/business/partner/purchase/jx/localjx"
"git.rosy.net.cn/jx-callback/globals"
"git.rosy.net.cn/jx-callback/globals/api" "git.rosy.net.cn/jx-callback/globals/api"
"github.com/astaxie/beego/server/web" "github.com/astaxie/beego/server/web"
) )
@@ -16,10 +14,6 @@ type KuaiShouController struct {
// KuaiShouCallBack 快手回调 // KuaiShouCallBack 快手回调
func (c *KuaiShouController) KuaiShouCallback() { func (c *KuaiShouController) KuaiShouCallback() {
payOrder, refundOrder, payType, msgId, err := api.KuaiShouApi.KauiShouCallback(c.Ctx.Request) payOrder, refundOrder, payType, msgId, err := api.KuaiShouApi.KauiShouCallback(c.Ctx.Request)
globals.SugarLogger.Debugf("KuaiShouCallBack payOrder =: %s", utils.Format4Output(payOrder, false))
globals.SugarLogger.Debugf("KuaiShouCallBack refundOrder=: %s", utils.Format4Output(refundOrder, false))
globals.SugarLogger.Debugf("KuaiShouCallBack payType=: %s", payType)
globals.SugarLogger.Debugf("KuaiShouCallBack err=: %s", utils.Format4Output(err, false))
if err != nil { if err != nil {
c.Data["json"] = CallBackFail(msgId) c.Data["json"] = CallBackFail(msgId)
c.ServeJSON() c.ServeJSON()