package auto_delivery

import (
	"crypto/rand"
	"encoding/json"
	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/jx-callback/business/jxcallback/scheduler/defsch"
	"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"
	"math/big"
	"strings"
)

var riderListInfo = make(map[string][]map[string]string, 0)

func Init() {
	db := dao.GetDB()
	// 骑手列表
	configRiderList, err := dao.QueryConfigs(db, "riderList", "Sys", "")
	if err != nil {
		globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
		return
	}
	list := make(map[string][]map[string]string, 0)
	if len(configRiderList[0].Value) > 0 {
		if err := json.Unmarshal([]byte(configRiderList[0].Value), &list); err != nil {
			globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
			return
		}
	}

	// 获取刷单地址
	addressList, err := dao.QueryConfigs(db, "refundAddress", "Sys", "")
	if err != nil {
		globals.SugarLogger.Errorf("抖音自动刷单获取刷单地址列表错误:%v", err)
		return
	}

	for _, v := range strings.Split(addressList[0].Value, ",") {
		if _, ok := list[v]; ok && len(list[v]) >= 200 {
			continue
		}
		riderList, err := dao.GetAddressRiderInfo(db, v)
		if err != nil {
			globals.SugarLogger.Errorf("初始化各省份骑手信息错误:[%v]", err)
			return
		}
		addressRiderList := make([]map[string]string, 0)
		for i := 0; i < len(riderList); i++ {
			if len(riderList[i].CourierMobile) == 11 {
				riderMap := make(map[string]string, 1)
				riderMap[riderList[i].CourierName] = riderList[i].CourierMobile
				addressRiderList = append(addressRiderList, riderMap)
			}
			if len(addressRiderList) >= 200 {
				list[v] = addressRiderList
				break
			}
		}
	}

	listStr, err := json.Marshal(list)
	if err != nil {
		globals.SugarLogger.Errorf("Marshal 骑手信息错误:[%v]", err)
		return
	}

	if err := dao.UpdateOperatorConfig(string(listStr), "Sys", "riderList"); err != nil {
		globals.SugarLogger.Errorf("UpdateOperatorConfig 骑手配置信息错误:[%v]", err)
		return
	}
	riderListInfo = list
}

// AutoSettingFakeDelivery 抖音自动设置骑手, 推送假订单
func AutoSettingFakeDelivery() {
	db := dao.GetDB()

	// 查询需要刷单的门店
	configList, err := dao.QueryConfigs(db, "storeIdList", "Sys", "")
	if err != nil {
		globals.SugarLogger.Errorf("抖音自动刷单获取刷单门店列表错误:%v", err)
		return
	}
	if len(configList) != model.YES {
		globals.SugarLogger.Errorf("newConfig 刷单门店设置异常")
		return
	}

	// 获取刷单门店订单
	orderList, err := dao.GetOrderListByStoreList(db, utils.StringSlice2Int64(strings.Split(configList[0].Value, ",")))
	if err != nil {
		globals.SugarLogger.Errorf("获取门店刷单记录错误")
		return
	}
	if len(orderList) == model.NO {
		return
	}

	for _, v := range orderList {
		//jxutils.CallMsgHandler(func() {
		// 1.根据订单客户地址获取骑手列表
		riderKey := ""
		if strings.Contains(v.ConsigneeAddress, "重庆") || strings.Contains(v.ConsigneeAddress, "上海") || strings.Contains(v.ConsigneeAddress, "北京") {
			riderKey = strings.Split(v.ConsigneeAddress, "市")[0]
		} else {
			riderKey = strings.Split(v.ConsigneeAddress, "省")[0]
		}
		if len(riderListInfo[riderKey]) == model.NO {
			// 骑手列表
			configRiderList, err := dao.QueryConfigs(db, "riderList", "Sys", "")
			if err != nil {
				globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
				return
			}
			if err := json.Unmarshal([]byte(configRiderList[0].Value), &riderListInfo); err != nil {
				globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
				return
			}
		}

		randNumber, _ := rand.Int(rand.Reader, big.NewInt(int64(len(riderListInfo[riderKey]))))
		randTime := randNumber.Int64()
		if randTime < 0 {
			randTime = 1
		}
		if randTime >= int64(len(riderListInfo[riderKey])) {
			randTime = int64(len(riderListInfo[riderKey])) - 1
		}
		if v.PhoneAscription == "" || strings.Split(v.PhoneAscription, "-")[0] != model.PhoneAscriptionAddressYes {
			continue
		}
		// 自动拣货
		if v.Status < model.OrderStatusFinishedPickup { // 未拣货
			handler := partner.GetPurchaseOrderHandlerFromVendorID(v.VendorID)
			flag := model.IsOrderDeliveryByStore(v) || model.IsOrderDeliveryBySelf(v)
			if err := handler.PickupGoods(v, flag, jxcontext.AdminCtx.GetUserName()); err != nil {
				globals.SugarLogger.Errorf("自动拣货错误:[%v]", err)
				break
			}
		}
		//自动发单
		if len(riderListInfo[riderKey]) == 0 {
			globals.SugarLogger.Errorf("riderListInfo[riderKey][randTime] :%s,%s,%d", riderListInfo[riderKey][randTime], riderKey, randTime)
			break
		}
		for riderName, riderPhone := range riderListInfo[riderKey][randTime] {
			if err := defsch.FixedScheduler.SelfDeliveringAndUpdateStatus(jxcontext.AdminCtx, v.VendorOrderID, v.VendorID, jxcontext.AdminCtx.GetUserName(), riderName, riderPhone); err != nil {
				globals.SugarLogger.Errorf("自动发货错误:[%v]", err)
				break
			}
		}
		//}, jxutils.ComposeUniversalOrderID(v.VendorOrderID, model.VendorIDDD))
	}
}