This commit is contained in:
suyl
2021-08-27 09:59:16 +08:00
parent 9f694a9873
commit ced5e1b12c

View File

@@ -2,6 +2,7 @@ package defsch
import ( import (
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/jxutils/smsmsg"
"math/rand" "math/rand"
"sync" "sync"
"time" "time"
@@ -20,7 +21,6 @@ import (
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/jxutils/netprinter" "git.rosy.net.cn/jx-callback/business/jxutils/netprinter"
"git.rosy.net.cn/jx-callback/business/jxutils/smsmsg"
"git.rosy.net.cn/jx-callback/business/msghub" "git.rosy.net.cn/jx-callback/business/msghub"
"git.rosy.net.cn/baseapi/platformapi/dingdingapi" "git.rosy.net.cn/baseapi/platformapi/dingdingapi"
@@ -293,6 +293,8 @@ func init() {
TimeoutAction: func(savedOrderInfo *WatchOrderInfo, bill *model.Waybill) (err error) { TimeoutAction: func(savedOrderInfo *WatchOrderInfo, bill *model.Waybill) (err error) {
if err = sch.autoPickupGood(savedOrderInfo); err != nil { if err = sch.autoPickupGood(savedOrderInfo); err != nil {
partner.CurOrderManager.OnOrderMsg(savedOrderInfo.order, "自动拣货失败", err.Error()) partner.CurOrderManager.OnOrderMsg(savedOrderInfo.order, "自动拣货失败", err.Error())
} else {
smsmsg.NotifyPickOrder(savedOrderInfo.order)
} }
return nil return nil
}, },
@@ -484,9 +486,6 @@ func (s *DefScheduler) OnOrderStatusChanged(order *model.GoodsOrder, status *mod
if statusChanged && status.Status == model.OrderStatusCanceled { if statusChanged && status.Status == model.OrderStatusCanceled {
s.notifyOrderCanceled(savedOrderInfo.order) s.notifyOrderCanceled(savedOrderInfo.order)
} }
if status.Status == model.OrderStatusFinishedPickup {
smsmsg.NotifyPickOrder(order)
}
msghub.OnFinishedPickup(savedOrderInfo.order) msghub.OnFinishedPickup(savedOrderInfo.order)
} else if status.Status == model.OrderStatusApplyCancel || //model.IsOrderLockStatus(status.Status) || } else if status.Status == model.OrderStatusApplyCancel || //model.IsOrderLockStatus(status.Status) ||
status.Status == model.OrderStatusApplyFailedGetGoods || //model.IsOrderUnlockStatus(status.Status) || status.Status == model.OrderStatusApplyFailedGetGoods || //model.IsOrderUnlockStatus(status.Status) ||
@@ -595,9 +594,9 @@ func (s *DefScheduler) OnWaybillStatusChanged(bill *model.Waybill, isPending boo
s.solutionJdsOrder(bill) s.solutionJdsOrder(bill)
} }
//如果是商城的订单, 骑手取货时,需要发短信提醒 //如果是商城的订单, 骑手取货时,需要发短信提醒
if bill.Status == model.WaybillStatusDelivering && order.VendorID == model.VendorIDJX && order.OrderType == model.OrderTypeNormal { //if bill.Status == model.WaybillStatusDelivering && order.VendorID == model.VendorIDJX && order.OrderType == model.OrderTypeNormal {
smsmsg.NotifyJxOrder(order, bill) // smsmsg.NotifyJxOrder(order, bill)
} //}
//门店发单的门店,需要根据实际运费更新账户(多退少补) //门店发单的门店,需要根据实际运费更新账户(多退少补)
if storeDetail, err2 := dao.GetStoreDetail(dao.GetDB(), jxutils.GetSaleStoreIDFromOrder(order), order.VendorID, ""); err2 == nil { if storeDetail, err2 := dao.GetStoreDetail(dao.GetDB(), jxutils.GetSaleStoreIDFromOrder(order), order.VendorID, ""); err2 == nil {
if storeDetail.CreateDeliveryType == model.YES { if storeDetail.CreateDeliveryType == model.YES {