package jxutils

import (
	"bytes"
	"context"
	"fmt"
	"io/ioutil"
	"math"
	"math/rand"
	"regexp"
	"sort"
	"strings"
	"time"

	"git.rosy.net.cn/baseapi/platformapi/autonavi"
	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/baseapi/utils/routinepool"
	"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
	"git.rosy.net.cn/jx-callback/business/model"
	"git.rosy.net.cn/jx-callback/business/model/dao"
	"git.rosy.net.cn/jx-callback/globals"
	"git.rosy.net.cn/jx-callback/globals/api"
	"git.rosy.net.cn/jx-callback/globals/api2"
	"github.com/qiniu/api.v7/storage"
)

var (
	routinePool *routinepool.Pool
	skuNamePat  *regexp.Regexp

	resourceTypeMap = map[int][]string{
		model.VendorIDQiNiuCloud: []string{
			"image.jxc4.com",
		},
		model.VendorIDJD: []string{
			"img30.360buyimg.com",
		},
		model.VendorIDMTWM: []string{
			"",
		},
		model.VendorIDEBAI: []string{
			"image-star.elemecdn.com",
		},
	}
)

type OrderSkuList []*model.OrderSku

func (l OrderSkuList) Len() int {
	return len(l)
}

// Less reports whether the element with
// index i should sort before the element with index j.
func (l OrderSkuList) Less(i, j int) bool {
	return l[i].SalePrice < l[j].SalePrice
}

// Swap swaps the elements with indexes i and j.
func (l OrderSkuList) Swap(i, j int) {
	tmp := l[i]
	l[i] = l[j]
	l[j] = tmp
}

func init() {
	rand.Seed(time.Now().Unix())
	routinePool = routinepool.New(1000, 1000)

	// Go regex does not support lookarounds.
	// https://stackoverflow.com/questions/38933898/error-parsing-regexp-invalid-or-unsupported-perl-syntax
	skuNamePat = regexp.MustCompile(`([\(（\[【][^\(（\[【\)）\]】]*[\)）\]】])?(.*?)([(（].*[)）])?\s*约?([1-9][\d\.]*)(g|G|kg|kG|Kg|KG|l|L|ml|mL|Ml|ML|克)\s*([(（].*[)）])?\s*(?:\/|／|)\s*([^\s（）()]{0,2})\s*([（(].*[）)])?$`)
}

func getJxStoreIDFromOrder(order *model.GoodsOrder) (retVal int) {
	if order.JxStoreID != 0 {
		return order.JxStoreID
	}
	return order.StoreID
}

// 此函数得到的是order的销售门店京西ID，与GetJxStoreIDFromOrder的区别是order.StoreID的解释不同，参考其它相关资料
func GetSaleStoreIDFromOrder(order *model.GoodsOrder) (retVal int) {
	if order.VendorID != model.VendorIDWSC {
		return getJxStoreIDFromOrder(order)
	}
	return order.StoreID
}

// 此函数得到的是order的商品的展示门店京西ID，与GetJxStoreIDFromOrder的区别是order.StoreID的解释不同，参考其它相关资料
func GetShowStoreIDFromOrder(order *model.GoodsOrder) (retVal int) {
	if order.VendorID != model.VendorIDWSC {
		return getJxStoreIDFromOrder(order)
	}
	return order.JxStoreID
}

func GetSkuIDFromOrderSku(sku *model.OrderSku) (skuID int) {
	if sku.JxSkuID > 0 {
		return sku.JxSkuID
	}
	return sku.SkuID
}

func GetSaleStoreIDFromAfsOrder(order *model.AfsOrder) (retVal int) {
	if order.JxStoreID > 0 {
		return order.JxStoreID
	}
	return order.StoreID
}

func GetSkuIDFromOrderSkuFinancial(sku *model.OrderSkuFinancial) (skuID int) {
	if sku.JxSkuID > 0 {
		return sku.JxSkuID
	}
	return sku.SkuID
}

func SplitUniversalOrderID(universalOrderID string) (orderID string, vendorID int) {
	index := strings.Index(universalOrderID, "|")
	if index != -1 {
		orderID = universalOrderID[:index]
		vendorID = int(utils.Str2Int64(universalOrderID[index+1:]))
	} else {
		if vendorID = GetPossibleVendorIDFromVendorOrderID(universalOrderID); vendorID == model.VendorIDUnknown {
			// globals.SugarLogger.Errorf("unkown order type:%v", universalOrderID)
			panic(fmt.Sprintf("unkown order type, orderID:%s", universalOrderID))
		}
		orderID = universalOrderID
	}
	return orderID, vendorID
}

func GetPossibleVendorIDFromVendorOrderID(vendorOrderID string) (vendorID int) {
	vendorID = model.VendorIDUnknown
	if vendorOrderIDInt64 := utils.Str2Int64WithDefault(vendorOrderID, 0); vendorOrderIDInt64 > 0 {
		orderIDLen := len(vendorOrderID)
		// 5287873015048 13 wsc
		// 15380342248732 14 old ebai order
		// 800402581000221 15 jd order
		// 33437032333978492 17 mtwm order
		// 3022716176275221584 19 elm order, new ebai order
		if orderIDLen == len("800402581000221") {
			vendorID = model.VendorIDJD
		} else if orderIDLen == len("3022716176275221584") {
			// vendorID = model.VendorIDELM
			vendorID = model.VendorIDEBAI // 饿百零售开放平台订单接口中订单ID“order_id”字段长度将调整为19位，和饿了么订单ID“eleme_order_id”字段格式保持一致。
		} else if orderIDLen == len("15380342248732") {
			vendorID = model.VendorIDEBAI
		} else if orderIDLen == len("33437032333978492") {
			vendorID = model.VendorIDMTWM
		} else if orderIDLen == len("5287873015048") {
			vendorID = model.VendorIDWSC
		} else if orderIDLen == len("1000004390") {
			vendorID = model.VendorIDJX
		}
	}
	return vendorID
}

func GetPossibleVendorIDFromAfsOrderID(afsOrderID string) (vendorID int) {
	vendorID = model.VendorIDUnknown
	if afsOrderIDInt64 := utils.Str2Int64WithDefault(afsOrderID, 0); afsOrderIDInt64 > 0 {
		orderIDLen := len(afsOrderID)
		if orderIDLen == len("22586438") {
			vendorID = model.VendorIDJD
		} else if orderIDLen == len("579557034") {
			vendorID = model.VendorIDEBAI
		}
	}
	return vendorID
}

func ComposeUniversalOrderID(orderID string, vendorID int) string {
	// return fmt.Sprintf("%s|%d", orderID, vendorID)
	return orderID // 当前用长度就能区分，先不加上vendorID
}

func GetUniversalOrderIDFromWaybill(bill *model.Waybill) string {
	return ComposeUniversalOrderID(bill.VendorOrderID, bill.OrderVendorID)
}

func GetUniversalOrderIDFromOrder(order *model.GoodsOrder) string {
	return ComposeUniversalOrderID(order.VendorOrderID, order.VendorID)
}

func GetUniversalOrderIDFromOrderStatus(status *model.OrderStatus) string {
	return ComposeUniversalOrderID(status.VendorOrderID, status.VendorID)
}

// distance单位为米
func ConvertDistanceToLogLat(lng, lat, distance, angle float64) (newLng, newLat float64) {
	oneDu := 111319.55                                                                      // 单位为米
	newLng = lng + (distance*math.Sin(angle*math.Pi/180))/(oneDu*math.Cos(lat*math.Pi/180)) //将距离转换成经度的计算公式
	newLat = lat + (distance*math.Cos(angle*math.Pi/180))/oneDu                             //将距离转换成纬度的计算公式
	return newLng, newLat
}

// 返回结果单元为公里
func EarthDistance(lng1, lat1, lng2, lat2 float64) float64 {
	radius := 6378.137
	rad := math.Pi / 180.0
	lat1 = lat1 * rad
	lng1 = lng1 * rad
	lat2 = lat2 * rad
	lng2 = lng2 * rad
	theta := lng2 - lng1
	dist := math.Acos(math.Sin(lat1)*math.Sin(lat2) + math.Cos(lat1)*math.Cos(lat2)*math.Cos(theta))
	return dist * radius
}

func StandardCoordinate2Int(value float64) int {
	return int(math.Round(value * 1000000))
}

func IntCoordinate2Standard(value int) float64 {
	return float64(value) / 1000000
}

func IntCoordinate2MarsStandard(gpsLng, gpsLat int, coordinateType int) (marsLng, marsLat float64, err error) {
	marsLng = IntCoordinate2Standard(gpsLng)
	marsLat = IntCoordinate2Standard(gpsLat)
	coordSys := ""
	switch coordinateType {
	case model.CoordinateTypeGPS:
		coordSys = autonavi.CoordSysGPS
	case model.CoordinateTypeMars:
		coordSys = autonavi.CoordSysAutonavi
	case model.CoordinateTypeBaiDu:
		coordSys = autonavi.CoordSysBaidu
	case model.CoordinateTypeMapbar:
		coordSys = autonavi.CoordSysMapbar
	default:
		panic(fmt.Sprintf("known coordinate type:%d", coordinateType))
	}
	return api.AutonaviAPI.CoordinateConvert(marsLng, marsLat, coordSys)
}

func IntPrice2Standard(value int64) float64 {
	return float64(value) / 100
}

func StandardPrice2Int(value float64) int64 {
	return int64(math.Round(value * 100))
}

func IntPrice2StandardString(value int64) string {
	return fmt.Sprintf("%.2f", IntPrice2Standard(value))
}

func IntPrice2StandardCurrencyString(value int64) string {
	return fmt.Sprintf("￥%.2f", IntPrice2Standard(value))
}

func CallMsgHandler(handler func(), primaryID string) {
	routinePool.CallFun(func() {
		handler()
	}, primaryID)
}

func CallMsgHandlerAsync(handler func(), primaryID string) {
	routinePool.CallFunAsync(func() {
		handler()
	}, primaryID)
}

func GetNameAndUnitFromSkuName(fullName string) (name string, unit string) {
	unit = "份"
	index := strings.Index(fullName, "/")
	if index >= 0 {
		name = fullName[:index]
		unitTmp := []rune(fullName[index+1:])
		if len(unitTmp) >= 1 {
			unit = string(unitTmp[:1])
		}
	} else {
		name = fullName
	}
	return name, unit
}

func MapValue2Scope(value, fromMin, fromMax, toMin, toMax int64) int64 {
	if value < fromMin {
		value = fromMin
	}
	if value > fromMax {
		value = fromMax
	}
	return int64(math.Round(float64(value-fromMin)/float64(fromMax-fromMin)*float64(toMax-toMin) + float64(toMin)))
}

func Errs2Str(sep string, errs ...error) (retVal string) {
	if sep == "" {
		sep = "\n"
	}
	for _, err := range errs {
		if err != nil {
			retVal += err.Error() + sep
		}
	}
	return retVal
}

func IntWeight2Float(weight int) float32 {
	return float32(weight) / 1000.0
}

func FloatWeight2Int(weight float32) int {
	return int(math.Round(float64(weight * 1000)))
}

func ComposeSkuName(prefix, name, comment, unit string, spec_quality float32, spec_unit string, maxLen int) (skuName string) {
	if prefix != "" {
		skuName = "[" + prefix + "]"
	}
	skuName += name
	if unit == "份" {
		skuName += "约"
	}
	if unit != "" {
		skuName += ComposeSkuSpec(spec_quality, spec_unit)
		skuName += "/" + unit
	}
	if comment != "" {
		skuName += "(" + comment + ")"
	}
	if maxLen > 0 {
		skuName = utils.LimitUTF8StringLen(skuName, maxLen)
	}
	return skuName
}

func ComposeSpuName(prefix, name string, maxLen int) (spuName string) {
	if prefix != "" {
		spuName = "[" + prefix + "]"
	}
	spuName += name
	return utils.LimitUTF8StringLen(spuName, maxLen)
}

func ComposeSkuSpec(spec_quality float32, spec_unit string) (spec string) {
	if spec_unit != "" {
		if math.Round(float64(spec_quality)) == float64(spec_quality) || (spec_unit != "L" && spec_unit != "kg") {
			spec = fmt.Sprintf("%d", int(spec_quality))
		} else {
			spec = strings.TrimRight(fmt.Sprintf("%.2f", spec_quality), "0.")
		}
		spec += spec_unit
	}
	return spec
}

//  1：商品特殊前缀
//  2：商品名字
//  3：商品说明1（可缺失）
//  4：质量数字
//  5：质量单位
//  6：商品说明2（可缺失）
//  7：商品单位
//  8：商品说明3（可缺失）
func SplitSkuName(skuName string) (prefix, name, comment, specUnit, unit string, specQuality float32) {
	searchResult := skuNamePat.FindStringSubmatch(skuName)
	if searchResult != nil {
		if searchResult[3] != "" {
			comment = searchResult[3]
		} else if searchResult[6] != "" {
			comment = searchResult[6]
		} else if searchResult[8] != "" {
			comment = searchResult[8]
		}
		comment = TrimDecorationChar(comment)
		name = TrimDecorationChar(searchResult[2])
		// if comment != "" {
		// 	// if utf8.RuneCountInString(comment) <= 5 {
		// 	// 	name += "-" + comment
		// 	// 	comment = ""
		// 	// }
		// }
		specUnit = strings.ToLower(strings.Replace(searchResult[5], "克", "g", -1))
		if specUnit == "l" {
			specUnit = "L"
		}
		if searchResult[7] == "" {
			unit = "份"
		} else {
			unit = searchResult[7]
		}
		specQuality = float32(utils.Str2Float64(searchResult[4]))
		prefix = TrimDecorationChar(searchResult[1])
	}
	return prefix, name, comment, specUnit, unit, specQuality
}

func MakeValidationMapFromSlice(validValues []string, flag int) map[string]int {
	retVal := make(map[string]int)
	for _, v := range validValues {
		retVal[v] = flag
	}
	return retVal
}

func ComposeQiniuResURL(key string) string {
	return "http://image.jxc4.com/" + key
}

func IsLegalMobileNumber(num int64) bool {
	return num >= 13000000000 && num <= 19999999999
}

func TrimDecorationChar(value string) string {
	return strings.Trim(value, " \t\n[]()【】（）-_——")
}

func BatchStr2Time(strTime ...string) (timeList []time.Time, err error) {
	timeList = make([]time.Time, len(strTime))
	for k, v := range strTime {
		if v == "" {
			timeList[k] = utils.DefaultTimeValue
		} else {
			if timeList[k], err = utils.TryStr2Time(v); err != nil {
				return nil, err
			}
		}
	}
	return timeList, nil
}

// strAndObjAddPairs必须按字符串1,转换地址1，字符串2，转换地址2这样的格式传递
func Strings2Objs(strAndObjAddPairs ...interface{}) (err error) {
	str := ""
	for k, v := range strAndObjAddPairs {
		if k%2 == 0 {
			str, _ = v.(string)
		} else if str != "" {
			if err = utils.UnmarshalUseNumber([]byte(str), v); err != nil {
				return err
			}
		}
	}
	return nil
}

func HandleUserWXRemark(db *dao.DaoDB, mobile string, mobileIsUerID bool) (err error) {
	if db == nil {
		db = dao.GetDB()
	}
	openIDs := []string{}
	storeID := 0
	remark := ""

	// if !globals.DisableWXAuth1 {
	// 	wxinfo, err := dao.GetUserStoreInfo(db, "tel", mobile)
	// 	if err == nil {
	// 		openIDs = []string{wxinfo.OpenID}
	// 		storeID = wxinfo.JxStoreID
	// 	}
	// }
	if globals.EnableWXAuth2 {
		userID := ""
		if mobileIsUerID {
			userID = mobile
		} else {
			userList, _, err2 := dao.GetUsers(db, model.UserTypeStoreBoss, "", nil, "", mobile, 0, -1)
			if err = err2; len(userList) > 0 {
				userID = userList[0].GetID()
			}
		}
		if userID != "" {
			authBindList, err2 := dao.GetUserBindAuthInfo(db, userID, model.AuthBindTypeAuth, []string{weixin.AuthTypeMP}, "", "")
			if err = err2; err == nil {
				for _, v := range authBindList {
					openIDs = append(openIDs, v.AuthID)
				}
			}
			roleList, err2 := api2.RoleMan.GetUserRoleList(userID)
			if err = err2; err == nil && len(roleList) > 0 {
				storeID = roleList[0].StoreID
			}
		}
	}

	if len(openIDs) > 0 {
		if storeID > 0 {
			store := &model.Store{}
			store.ID = storeID
			if err = dao.GetEntity(db, store); err == nil {
				city := &model.Place{
					Code: store.CityCode,
				}
				if err = dao.GetEntity(db, city, "Code"); err == nil {
					remark = city.Name + "-" + store.Name
				}
			}
		}
		if err == nil {
			if globals.EnableStoreWrite {
				for _, openID := range openIDs {
					err = api.WeixinAPI.CBUpdateRemark(openID, remark)
				}
			}
		}
	}
	return err
}

func RefreshOrderSkuRelated(order *model.GoodsOrder) *model.GoodsOrder {
	order.SkuCount = 0
	order.GoodsCount = 0
	order.SalePrice = 0
	order.VendorPrice = 0
	order.ShopPrice = 0
	order.Weight = 0
	for _, sku := range order.Skus {
		if sku.SkuID > math.MaxInt32 {
			sku.SkuID = 0
		}
		sku.OrderCreatedAt = order.OrderCreatedAt
		sku.VendorID = order.VendorID
		sku.VendorOrderID = order.VendorOrderID
		order.SkuCount++
		order.GoodsCount += sku.Count
		order.SalePrice += sku.SalePrice * int64(sku.Count)
		order.VendorPrice += sku.VendorPrice * int64(sku.Count)
		order.ShopPrice += sku.ShopPrice * int64(sku.Count)
		order.Weight += sku.Weight * sku.Count
	}
	return order
}

func RefreshAfsOrderSkuRelated(afsOrder *model.AfsOrder) *model.AfsOrder {
	afsOrder.SkuUserMoney = 0
	afsOrder.PmSkuSubsidyMoney = 0
	for _, orderSku := range afsOrder.Skus {
		if orderSku.SkuID > math.MaxInt32 {
			orderSku.SkuID = 0
		}
		afsOrder.SkuUserMoney += orderSku.UserMoney
		afsOrder.PmSkuSubsidyMoney += orderSku.PmSkuSubsidyMoney
	}
	return afsOrder
}

func RemoveSkuFromOrder(order *model.GoodsOrder, removedSkuList []*model.OrderSku) *model.GoodsOrder {
	removedSkuMap := make(map[int]*model.OrderSku)
	removedSkuMap2 := make(map[string]*model.OrderSku)
	for _, sku := range removedSkuList {
		if skuID := GetSkuIDFromOrderSku(sku); skuID > 0 {
			if removedSkuMap[skuID] == nil {
				removedSkuMap[skuID] = sku
			} else {
				removedSkuMap[skuID].Count += sku.Count
			}
		}
		if vendorSkuID := sku.VendorSkuID; vendorSkuID != "" {
			if removedSkuMap2[vendorSkuID] == nil {
				removedSkuMap2[vendorSkuID] = sku
			} else {
				removedSkuMap2[vendorSkuID].Count += sku.Count
			}
		}
	}
	var skuList []*model.OrderSku
	sort.Sort(sort.Reverse(OrderSkuList(order.Skus)))
	for _, sku := range order.Skus {
		var removedSku *model.OrderSku
		if skuID := GetSkuIDFromOrderSku(sku); skuID > 0 {
			removedSku = removedSkuMap[skuID]
		}
		if removedSku == nil {
			if vendorSkuID := sku.VendorSkuID; vendorSkuID != "" {
				removedSku = removedSkuMap2[vendorSkuID]
			}
		}
		copiedSku := *sku
		tmp := &copiedSku
		if removedSku != nil {
			if removedSku.Count >= sku.Count {
				tmp = nil
				removedSku.Count -= sku.Count
			} else {
				tmp.Count -= removedSku.Count
				removedSku.Count = 0
			}
		}
		if tmp != nil {
			skuList = append(skuList, tmp)
		}
	}
	order.Skus = skuList
	return RefreshOrderSkuRelated(order)
}

func UploadExportContent(content []byte, key string) (downloadURL string, err error) {
	putPolicy := storage.PutPolicy{
		Scope:           globals.QiniuBucket,
		Expires:         10 * 60,
		DeleteAfterDays: 1,
	}
	upToken := putPolicy.UploadToken(api.QiniuAPI)
	cfg := &storage.Config{}
	formUploader := storage.NewFormUploader(cfg)
	ret := storage.PutRet{}
	for i := 0; i < 3; i++ {
		if err = formUploader.Put(context.Background(), &ret, upToken, key, bytes.NewReader(content), int64(len(content)), &storage.PutExtra{}); err == nil {
			break
		}
	}
	if err == nil {
		downloadURL = ComposeQiniuResURL(key)
	}
	return downloadURL, err
}

func TaskResult2Hint(resultList []interface{}) (hint string) {
	strList := make([]string, len(resultList))
	for k, v := range resultList {
		strList[k] = fmt.Sprint(v)
	}
	hint = strings.Join(strList, ",")
	return hint
}

// 这个函数用于将两个整数合并为一单一int64，不要用于持久化的场景
func Combine2Int(int1, int2 int) (outInt int64) {
	return int64(int1)*100000 + int64(int2)
}

func GetLastTimeFromList(now time.Time, timeList []string) (snapshotAt time.Time) {
	dateStr := utils.Time2DateStr(now)
	selectTime := utils.Str2Time(utils.Time2DateStr(now.Add(-24*time.Hour)) + " " + timeList[len(timeList)-1])
	for _, v := range timeList {
		tmpTime := utils.Str2Time(dateStr + " " + v)
		if tmpTime.Sub(now) > 0 {
			break
		}
		selectTime = tmpTime
	}
	return selectTime
}

func GetNextTimeFromList(now time.Time, timeList []string) (snapshotAt time.Time) {
	dateStr := utils.Time2DateStr(now)
	timeListLen := len(timeList)
	selectTime := utils.Str2Time(utils.Time2DateStr(now.Add(24*time.Hour)) + " " + timeList[0])
	for k := range timeList {
		v := timeList[timeListLen-k-1]
		tmpTime := utils.Str2Time(dateStr + " " + v)
		if tmpTime.Sub(now) < 0 {
			break
		}
		selectTime = tmpTime
	}
	return selectTime
}

func OperationTime2StrWithSecond(opTime int16) (str string) {
	str = fmt.Sprintf("%02d:%02d:00", opTime/100, opTime%100)
	return str
}

func OperationTime2Str(opTime int16) (str string) {
	str = fmt.Sprintf("%02d:%02d", opTime/100, opTime%100)
	return str
}

func OperationTime2Str2(openTime, closeTime int16) (str string) {
	str = fmt.Sprintf("%s-%s", OperationTime2Str(openTime), OperationTime2Str(closeTime))
	return str
}

func OperationTimeStr4VendorStore(v *model.VendorStoreSnapshot) (str string) {
	str = fmt.Sprintf("%s", OperationTime2Str2(v.OpenTime1, v.CloseTime1))
	if v.OpenTime2 > 0 && v.CloseTime2 > 0 {
		str += fmt.Sprintf(",%s", OperationTime2Str2(v.OpenTime2, v.CloseTime2))
	}
	return str
}

// 得到饿百订单的取货码
func GetEbaiOrderGetCode(order *model.GoodsOrder) (getCode string) {
	if order.VendorID == model.VendorIDEBAI && len(order.VendorOrderID2) >= 4 {
		getCode = order.VendorOrderID2[len(order.VendorOrderID2)-4:]
	}
	return getCode
}

func WriteFile(fileName string, binData []byte) error {
	err := ioutil.WriteFile(fileName, binData, 0666)
	return err
}

func GetRealMobile4Order(order *model.GoodsOrder) (mobileNumber string) {
	mobileNumber = order.ConsigneeMobile2
	if mobileNumber == "" {
		mobileNumber = order.ConsigneeMobile
	}
	if !IsStringLikeMobile(mobileNumber) {
		mobileNumber = ""
	}
	return mobileNumber
}

func GetAuthType4Vendor(vendorID int) (authType string) {
	authType = dao.ConvertJsonFieldPrefix(model.VendorNames[vendorID])
	if authType != "" {
		authType = "vendor." + authType
	}
	return authType
}

func GuessDataResourceVendor(resourceURL string) (vendorID int) {
	vendorID = -1
	for tmpVendorID, urlList := range resourceTypeMap {
		for _, v := range urlList {
			if v != "" && strings.Index(resourceURL, "//"+v) >= 0 {
				vendorID = tmpVendorID
				break
			}
		}
		if vendorID >= 0 {
			break
		}
	}
	return vendorID
}