package defsch

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/partner"
	"git.rosy.net.cn/jx-callback/globals"
)

func (s *DefScheduler) SelfDeliveringAndUpdateStatus(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
	globals.SugarLogger.Infof("SelfDeliveringAndUpdateStatus orderID:%s userName:%s", vendorOrderID, userName)
	status := &model.OrderStatus{
		RefVendorOrderID: vendorOrderID,
		RefVendorID:      vendorID,
	}
	savedOrderInfo := s.loadSavedOrderFromMap(status, false)
	if savedOrderInfo != nil {
		order := savedOrderInfo.order
		err = s.cancelOtherWaybills(savedOrderInfo, nil, partner.CancelWaybillReasonOther, partner.CancelWaybillReasonStrActive)
		if err == nil {
			if savedOrderInfo.storeDeliveryType == scheduler.StoreDeliveryTypeByStore {
				if order.Status <= model.OrderStatusFinishedPickup {
					err = s.SelfDeliverDelivering(order, "")
				}
			} else {
				if order.Status <= model.OrderStatusFinishedPickup {
					err = s.Swtich2SelfDeliver(order, userName)
				} else if order.VendorID == order.WaybillVendorID { // 状态为配送中，且是购物平台运单，不能转自送了
					err = scheduler.ErrOrderStatusIsNotSuitable4CurOperation
				}
			}
		}
		if err == nil {
			order.Status = model.OrderStatusDelivering
			order.DeliveryFlag |= model.OrderDeliveryFlagMaskScheduleDisabled | model.OrderDeliveryFlagMaskPurcahseDisabled
			if err = partner.CurOrderManager.UpdateOrderStatusAndFlag(order); err == nil {
				s.stopTimer(savedOrderInfo)
				globals.SugarLogger.Infof("SelfDeliveringAndUpdateStatus orderID:%s userName:%s successfully", vendorOrderID, userName)
				return err
			}
		}
	} else {
		err = scheduler.ErrCanNotFindOrder
	}
	globals.SugarLogger.Infof("SelfDeliveringAndUpdateStatus orderID:%s userName:%s error:%v", vendorOrderID, userName, err)
	return err
}

func (s *DefScheduler) SelfDeliveringAndUpdateStatusExt(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
	jxutils.CallMsgHandler(func() {
		err = s.SelfDeliveringAndUpdateStatus(ctx, vendorOrderID, vendorID, userName)
	}, jxutils.ComposeUniversalOrderID(vendorOrderID, vendorID))
	return err
}

func (s *DefScheduler) CreateWaybillOnProvidersEx(ctx *jxcontext.Context, vendorOrderID string, vendorID int, forceCreate bool) (bills []*model.Waybill, err error) {
	userName := ctx.GetUserName()
	globals.SugarLogger.Debugf("CreateWaybillOnProvidersEx orderID:%s userName:%s", vendorOrderID, userName)
	if vendorID == model.VendorIDELM {
		return nil, fmt.Errorf("不要直接使用饿了么订单号，请使用相应的饿百订单号")
	}
	status := &model.OrderStatus{
		RefVendorOrderID: vendorOrderID,
		RefVendorID:      vendorID,
	}
	savedOrderInfo := s.loadSavedOrderFromMap(status, true)
	if savedOrderInfo != nil {
		order := savedOrderInfo.order
		if forceCreate || (order.LockStatus != model.OrderStatusLocked && order.Status >= model.OrderStatusFinishedPickup && order.Status < model.OrderStatusEndBegin) {
			if bills, err = s.CreateWaybillOnProviders(order, userName, partner.UseableDeliveryVendorIDs, nil); err == nil {
				order.DeliveryFlag |= model.OrderDeliveryFlagMaskScheduleDisabled
				if err = partner.CurOrderManager.UpdateOrderStatusAndFlag(order); err == nil {
					s.stopTimer(savedOrderInfo)
					globals.SugarLogger.Debugf("CreateWaybillOnProvidersEx orderID:%s userName:%s successfully", vendorOrderID, userName)
					return bills, err
				}
			}
		} else {
			globals.SugarLogger.Debugf("CreateWaybillOnProvidersEx orderID:%s orderDetails:%s", vendorOrderID, utils.Format4Output(order, true))
			err = fmt.Errorf("必须是处于拣货完成但没有结束的订单才能进行召唤配送操作")
		}
	} else {
		err = scheduler.ErrCanNotFindOrder
	}
	globals.SugarLogger.Infof("CreateWaybillOnProvidersEx orderID:%s userName:%s error:%v", vendorOrderID, userName, err)
	return bills, err
}