112 lines
5.0 KiB
Go
112 lines
5.0 KiB
Go
package basesch
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/jx-callback/business/jxcallback/scheduler"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/business/model/dao"
|
|
"git.rosy.net.cn/jx-callback/business/partner"
|
|
"git.rosy.net.cn/jx-callback/globals"
|
|
)
|
|
|
|
func (c *BaseScheduler) CreateWaybillOnProviders(order *model.GoodsOrder, userName string, courierVendorIDs []int, policyHandler func(deliveryFee, addFee int64) error) (bills []*model.Waybill, err error) {
|
|
globals.SugarLogger.Infof("CreateWaybillOnProviders orderID:%s userName:%s", order.VendorOrderID, userName)
|
|
var errList []error
|
|
for _, courierVendorID := range courierVendorIDs {
|
|
bill, err2 := c.CreateWaybill(courierVendorID, order, policyHandler)
|
|
if err = err2; err == nil {
|
|
globals.SugarLogger.Debugf("CreateWaybillOnProviders orderID:%s userName:%s vendorID:%d bill:%v", order.VendorOrderID, userName, courierVendorID, bill)
|
|
bills = append(bills, bill)
|
|
} else {
|
|
errList = append(errList, err)
|
|
}
|
|
}
|
|
if len(bills) > 0 {
|
|
err = nil
|
|
} else {
|
|
err = fmt.Errorf("所有运单失败：\n%s", utils.Format4Output(errList, false))
|
|
}
|
|
globals.SugarLogger.Infof("CreateWaybillOnProviders orderID:%s userName:%s error:%v", order.VendorOrderID, userName, err)
|
|
return nil, err
|
|
}
|
|
|
|
func (c *BaseScheduler) CreateWaybillOnProvidersEx(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (bills []*model.Waybill, err error) {
|
|
globals.SugarLogger.Infof("CreateWaybillOnProvidersEx orderID:%s userName:%s", vendorOrderID, userName)
|
|
if vendorID == model.VendorIDELM {
|
|
return nil, fmt.Errorf("不要直接使用饿了么订单号，请使用相应的饿百订单号")
|
|
}
|
|
order, err := partner.CurOrderManager.LoadOrder(vendorOrderID, vendorID)
|
|
if err == nil {
|
|
if order.LockStatus != model.OrderStatusLocked && order.Status >= model.OrderStatusFinishedPickup && order.Status < model.OrderStatusEndBegin {
|
|
bills, err = c.CreateWaybillOnProviders(order, userName, partner.UseableDeliveryVendorIDs, nil)
|
|
} else {
|
|
err = scheduler.ErrOrderStatusIsNotSuitable4CurOperation
|
|
}
|
|
}
|
|
globals.SugarLogger.Infof("CreateWaybillOnProvidersEx orderID:%s userName:%s error:%v", vendorOrderID, userName, err)
|
|
return bills, err
|
|
}
|
|
|
|
func (c *BaseScheduler) SelfDeliveredAndUpdateStatus(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
|
|
globals.SugarLogger.Infof("SelfDeliveredAndUpdateStatus orderID:%s userName:%s", vendorOrderID, userName)
|
|
order, err := partner.CurOrderManager.LoadOrder(vendorOrderID, vendorID)
|
|
if err == nil {
|
|
if GetStoreDeliveryType(order, nil) == scheduler.StoreDeliveryTypeByStore {
|
|
err = c.SelfDeliverDelievered(order, userName)
|
|
} else {
|
|
err = c.Swtich2SelfDelivered(order, userName)
|
|
}
|
|
if err == nil {
|
|
order.Status = model.OrderStatusDelivered
|
|
if err = partner.CurOrderManager.UpdateOrderStatusAndFlag(order); err == nil {
|
|
globals.SugarLogger.Infof("SelfDeliveredAndUpdateStatus orderID:%s userName:%s successfully", vendorOrderID, userName)
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
globals.SugarLogger.Infof("SelfDeliveredAndUpdateStatus orderID:%s userName:%s error:%v", vendorOrderID, userName, err)
|
|
return err
|
|
}
|
|
|
|
func (c *BaseScheduler) PickupGoodsAndUpdateStatus(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
|
|
globals.SugarLogger.Infof("PickupGoodsAndUpdateStatus orderID:%s userName:%s", vendorOrderID, userName)
|
|
order, err := partner.CurOrderManager.LoadOrder(vendorOrderID, vendorID)
|
|
if err == nil {
|
|
err = c.PickupGoods(order, userName)
|
|
if err == nil {
|
|
order.Status = model.OrderStatusFinishedPickup
|
|
if err = partner.CurOrderManager.UpdateOrderStatusAndFlag(order); err == nil {
|
|
globals.SugarLogger.Infof("PickupGoodsAndUpdateStatus orderID:%s userName:%s successfully", vendorOrderID, userName)
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
globals.SugarLogger.Infof("PickupGoodsAndUpdateStatus orderID:%s userName:%s error:%v", vendorOrderID, userName, err)
|
|
return err
|
|
}
|
|
|
|
func GetStoreDeliveryType(order *model.GoodsOrder, storeMap *model.StoreMap) (deliveryType int) {
|
|
globals.SugarLogger.Debugf("GetStoreDeliveryType orderID:%s", order.VendorOrderID)
|
|
jxStoreID := jxutils.GetSaleStoreIDFromOrder(order)
|
|
if storeMap == nil {
|
|
storeMap, _ = dao.FakeGetStoreMapByStoreID(nil, jxStoreID, order.VendorID)
|
|
}
|
|
|
|
deliveryType = scheduler.StoreDeliveryTypeByPlatform // 缺省值
|
|
if storeMap != nil {
|
|
deliveryType = int(storeMap.DeliveryType)
|
|
// 微盟订单，要确认有绑达达，才能是非自送的
|
|
if order.VendorID == model.VendorIDWSC && deliveryType != scheduler.StoreDeliveryTypeByStore {
|
|
if courierMapList, _ := dao.GetOpenedStoreCouriersByStoreID(nil, jxStoreID, model.VendorIDDada); len(courierMapList) == 0 {
|
|
deliveryType = scheduler.StoreDeliveryTypeByStore
|
|
}
|
|
}
|
|
}
|
|
globals.SugarLogger.Debugf("GetStoreDeliveryType orderID:%s, deliveryType:%d", order.VendorOrderID, deliveryType)
|
|
return deliveryType
|
|
}
|