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 []string
	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 {
			globals.SugarLogger.Debugf("CreateWaybillOnProviders orderID:%s userName:%s vendorID:%d failed with error:%v", order.VendorOrderID, userName, courierVendorID, err)
			errList = append(errList, fmt.Sprintf("%s运单创建失败，错误：%s", model.VendorChineseNames[courierVendorID], err.Error()))
		}
	}
	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 bills, err
}

func (c *BaseScheduler) SelfDeliveredAndUpdateStatus(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
	jxutils.CallMsgHandler(func() {
		err = func() (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
		}()
	}, jxutils.ComposeUniversalOrderID(vendorOrderID, vendorID))
	return err
}

func (c *BaseScheduler) PickupGoodsAndUpdateStatus(ctx *jxcontext.Context, vendorOrderID string, vendorID int, userName string) (err error) {
	jxutils.CallMsgHandler(func() {
		err = func() (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
		}()
	}, jxutils.ComposeUniversalOrderID(vendorOrderID, vendorID))
	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
}