package jdshop

import (
	"fmt"
	"regexp"
	"time"

	"git.rosy.net.cn/baseapi/platformapi/jdshopapi"

	"git.rosy.net.cn/jx-callback/globals/api"

	"git.rosy.net.cn/baseapi/platformapi/yinbaoapi"
	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/jx-callback/business/jxutils"
	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
	"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/business/partner/putils"
	"git.rosy.net.cn/jx-callback/globals"
)

var (
	sensitiveWordRegexp = regexp.MustCompile(`商品名称中含有敏感词(\[.*\])`)
)

func (p *PurchaseHandler) CreateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		for _, v := range storeSkuList {
			createSkuParamWare, createSkuParamSkus, err := buildCreateWareParam(v)
			if err != nil {
				failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
				return failedList, err
			}
			createSkuResult, err := api.JdShopAPI.CreateWare(createSkuParamWare, createSkuParamSkus)
			if err != nil {
				failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "创建商品")
				return failedList, err
			}
			v.JdsWareID = createSkuResult.WareID
			for _, vv2 := range v.StoreSkuSyncInfoJds {
				for _, vv := range createSkuParamSkus {
					for _, vvv := range vv.SaleAttrs {
						for _, vv1 := range createSkuResult.Skus {
							for _, vvv1 := range vv1.SaleAttrs {
								if vvv1.AttrValues[0] == vvv.AttrValues[0] {
									vv2.VendorSkuID = utils.Int64ToStr(vv1.SkuID)
								}
							}
						}
					}
				}
			}
		}
	}
	return failedList, err
}

func (p *PurchaseHandler) UpdateStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*dao.StoreSkuSyncInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		for _, v := range storeSkuList {
			updateWareParam := &jdshopapi.UpdateWareParam{
				WareID: v.JdsWareID,
				Title:  v.SkuName,
				Weight: v.Weight,
			}
			err = api.JdShopAPI.UpdateWare(updateWareParam)
		}
		if err != nil {
			failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "更新商品基础信息")
		}
	}
	return failedList, err
}

func (p *PurchaseHandler) DeleteStoreSkus(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		for _, v := range storeSkuList {
			err = api.JdShopAPI.DeleteWare(utils.Str2Int(v.VendorSkuID2))
		}
		if err != nil {
			failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "删除商品")
		}
	}
	return failedList, err
}

func (p *PurchaseHandler) GetStoreSkusFullInfo(ctx *jxcontext.Context, parentTask tasksch.ITask, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo) (skuNameList []*partner.SkuNameInfo, err error) {

	return skuNameList, err
}

func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo, status int) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite {
		var stock = 0
		for _, v := range storeSkuList {
			if status == model.SkuStatusNormal {
				stock = 9999
			}
			if vendorStoreID == model.JdShopMainVendorStoreID {
				err = api.JdShopAPI.UpdateSkuStock(utils.Str2Int(v.VendorSkuID), stock)
			} else {
				err = api.JdShopAPI.UpdateSkuSiteStock(utils.Str2Int(v.VendorSkuID), stock, utils.Str2Int(vendorStoreID))
			}
		}
		if err != nil {
			failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "修改商品库存")
		}
	}
	return failedList, err
}

func (p *PurchaseHandler) UpdateStoreSkusPrice(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		for _, v := range storeSkuList {
			err = api.JdShopAPI.UpdateSkuJdPrice(utils.Str2Int(v.VendorSkuID), utils.Float64TwoInt(jxutils.IntPrice2Standard(v.VendorPrice)))
		}
		if err != nil {
			failedList = putils.GetErrMsg2FailedSingleList(storeSkuList, err, storeID, model.VendorChineseNames[model.VendorIDJDShop], "修改商品价格")
		}
	}
	return failedList, err
}

func (p *PurchaseHandler) UpdateStoreSkusStock(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo) (failedList []*partner.StoreSkuInfoWithErr, err error) {
	if globals.EnableJdShopWrite {

	}
	return failedList, err
}

func (p *PurchaseHandler) GetStoreAllCategories(ctx *jxcontext.Context, storeID int, vendorStoreID string) (cats []*partner.BareCategoryInfo, err error) {
	result, err := api.JdShopAPI.FindShopCategories()
	for _, v := range result {
		var cat = &partner.BareCategoryInfo{
			VendorCatID: utils.Int64ToStr(v.CID),
			Name:        v.Name,
		}
		if v.ParentCID == 0 {
			cat.Level = 1
		} else {
			cat.Level = 2
		}
		cats = append(cats, cat)
	}
	return cats, err
}

func (p *PurchaseHandler) CreateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		err = updateOrCreateCategories(storeCat, true)
		result, err := api.JdShopAPI.FindShopCategories()
		if err != nil {
			return err
		}
		for _, v := range result {
			if v.Name == storeCat.Name {
				storeCat.VendorCatID = utils.Int64ToStr(v.CID)
			}
		}
	}
	return err
}

func (p *PurchaseHandler) UpdateStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID string, storeCat *dao.SkuStoreCatInfo) (err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		err = updateOrCreateCategories(storeCat, false)
	}
	return err
}

func (p *PurchaseHandler) DeleteStoreCategory(ctx *jxcontext.Context, storeID int, vendorStoreID, vendorCatID string, level int) (err error) {
	if globals.EnableJdShopWrite && vendorStoreID == model.JdShopMainVendorStoreID {
		_, err = api.JdShopAPI.DeleteShopCategory(utils.Str2Int64(vendorCatID))
	}
	return err
}

func (p *PurchaseHandler) IsErrSkuExist(err error) (isExist bool) {
	return false
}

func (p *PurchaseHandler) IsErrCategoryExist(err error) (isExist bool) {
	return false
}

func (p *PurchaseHandler) IsErrCategoryNotExist(err error) (isNotExist bool) {
	return false
}

func (p *PurchaseHandler) GetStoreSkusBatchSize(funcID int) (batchSize int) {
	return 1
}

func (p *PurchaseHandler) GetSensitiveWordRegexp() *regexp.Regexp {
	return sensitiveWordRegexp
}

func (p *PurchaseHandler) IsErrSkuNotExist(err error) (isNotExist bool) {
	return false
}

func ybSkuStatus2Jx(ybStatus int) (jxSkuStatus int) {
	if ybStatus == yinbaoapi.SkuStatusEnable {
		jxSkuStatus = model.SkuStatusNormal
	} else if ybStatus == yinbaoapi.SkuStatusDisabled {
		jxSkuStatus = model.SkuStatusDontSale
	} else if ybStatus == yinbaoapi.SkuStatusDeleted {
		jxSkuStatus = model.SkuStatusDeleted
	}
	return jxSkuStatus
}

func vendorSku2Jx(result *yinbaoapi.QueryProductByBarcodeResult, resultp []*yinbaoapi.QueryProductImagesByBarcodeResult) (skuName *partner.SkuNameInfo) {
	var picList []string
	if result == nil {
		globals.SugarLogger.Warnf("vendorSku2Jx, strange result:%s", utils.Format4Output(result, true))
		return nil
	}
	if len(resultp) > 0 {
		if resultp[0].ImageURL != "" {
			// for _, v := range resultp.Productimages {
			picList = append(picList, resultp[0].ImageURL)
			// }
		}
	}
	prefix, name, comment, specUnit, unit, specQuality := jxutils.SplitSkuName(result.Name)
	skuName = &partner.SkuNameInfo{
		Prefix:    prefix,
		Name:      name,
		Unit:      unit,
		YbBarCode: result.Barcode,
		SkuList: []*partner.SkuInfo{
			&partner.SkuInfo{
				StoreSkuInfo: partner.StoreSkuInfo{
					VendorSkuID: utils.Int64ToStr(result.UID),
					Stock:       int(utils.Float64TwoInt64(result.Stock)),
					VendorPrice: jxutils.StandardPrice2Int(result.SellPrice),
					Status:      ybSkuStatus2Jx(result.Enable),
				},
				SkuName:     result.Name,
				Comment:     comment,
				SpecQuality: float64(specQuality),
				SpecUnit:    specUnit,
				Weight:      int(utils.Float64TwoInt64(float64(specQuality))),
			},
		},
		PictureList: picList,
	}
	return skuName
}

func updateOrCreateCategories(storeCat *dao.SkuStoreCatInfo, isCreate bool) (err error) {
	var createShopCategoryParams []*jdshopapi.CreateShopCategoryParam
	result, err := api.JdShopAPI.FindShopCategories()
	if err != nil {
		return err
	}
	for _, v := range result {
		createShopCategoryParam := &jdshopapi.CreateShopCategoryParam{
			HomeShow: "0",
			ID:       utils.Int64ToStr(v.CID),
			Open:     "",
			OrderNo:  utils.Int2Str(v.OrderNo),
			ParentID: utils.Int64ToStr(v.ParentCID),
			Title:    v.Name,
			Type:     jdshopapi.UpdateCatType,
		}
		createShopCategoryParams = append(createShopCategoryParams, createShopCategoryParam)
	}
	createShopCategoryParam2 := &jdshopapi.CreateShopCategoryParam{
		HomeShow: "0",
		Open:     "",
		OrderNo:  utils.Int2Str(storeCat.Seq),
		ParentID: storeCat.ParentVendorCatID,
		Title:    storeCat.Name,
	}
	if isCreate {
		createShopCategoryParam2.Type = jdshopapi.CreateCatType
		createShopCategoryParam2.ID = "1"
		createShopCategoryParams = append(createShopCategoryParams, createShopCategoryParam2)
	} else {
		for _, v := range createShopCategoryParams {
			if v.ID == storeCat.VendorCatID {
				v.Title = createShopCategoryParam2.Title
				v.OrderNo = createShopCategoryParam2.OrderNo
			}
		}
	}
	err = api.JdShopAPI.CreateShopCategory(createShopCategoryParams)
	return err
}

func buildCreateWareParam(storeSku *dao.StoreSkuSyncInfo) (createSkuParamWare *jdshopapi.CreateSkuParamWare, createSkuParamSkus []*jdshopapi.CreateSkuParamSkus, err error) {
	var images []*jdshopapi.CreateSkuParamImages
	createSkuParamWare = &jdshopapi.CreateSkuParamWare{
		Title:         storeSku.Name,
		ShopCategorys: []int{utils.Str2Int(storeSku.VendorCatID)},
		CategoryID:    int(storeSku.VendorVendorCatID),
		BrandID:       jdshopapi.JxBrandId,
		TransportID:   jdshopapi.TransportID,
		MobileDesc:    "因生鲜比较脆弱，发货途中如果有磕碰损坏，请收到联系客服，闪电赔付。请核对好地址，发货后不可修改地址，因改地址导致损坏不能赔付，谢谢理解",
		Introduction:  "因生鲜比较脆弱，发货途中如果有磕碰损坏，请收到联系客服，闪电赔付。请核对好地址，发货后不可修改地址，因改地址导致损坏不能赔付，谢谢理解",
		WareStatus:    8, //上架待审核
		OuterID:       utils.Int2Str(storeSku.NameID),
		VenderID:      0,
		Is7ToReturn:   0, //不支持7天退货
		Length:        100,
		Width:         100,
		Height:        100,
		Weight:        500,
		JdPrice:       int(storeSku.UnitPrice),
		MarketPrice:   int(storeSku.UnitPrice),
	}

	//上传京东图片 start
	//规则，有两张就传两张，没有就重复传一张
	data, _, err := jxutils.DownloadFileByURL(storeSku.Img)
	if err != nil {
		return createSkuParamWare, createSkuParamSkus, err
	}
	uploadResult, err := api.JdShopAPI.UploadPicture(data, 0, utils.Int64ToStr(time.Now().Unix())+storeSku.Name)
	if err != nil {
		return createSkuParamWare, createSkuParamSkus, err
	}
	img1 := &jdshopapi.CreateSkuParamImages{
		ColorID:  "0000000000",
		ImgIndex: 1,
		ImgURL:   uploadResult.PictureURL,
	}
	img2 := &jdshopapi.CreateSkuParamImages{
		ColorID:  "0000000000",
		ImgIndex: 2,
	}
	if storeSku.Img2 == "" {
		img2.ImgURL = uploadResult.PictureURL
	} else {
		data2, _, err := jxutils.DownloadFileByURL(storeSku.Img2)
		if err != nil {
			return createSkuParamWare, createSkuParamSkus, err
		}
		uploadResult2, err := api.JdShopAPI.UploadPicture(data2, 0, utils.Int64ToStr(time.Now().Unix())+storeSku.Name)
		if err != nil {
			return createSkuParamWare, createSkuParamSkus, err
		}
		img2.ImgURL = uploadResult2.PictureURL
	}
	images = append(images, img1)
	images = append(images, img2)
	createSkuParamWare.Images = images
	//end

	//设置商品属性值
	var (
		attrIDs     = make(map[string]int) //贮存方式,净含量,保质期IDs
		zctjValueID int64                  //贮存条件冷藏0-4的id
		attrsProp   []*jdshopapi.CreateSkuParamAttrs
	)
	attrs, err := api.JdShopAPI.FindAttrs(int(storeSku.VendorVendorCatID))
	for _, v := range attrs {
		if v.Name == "保质期" {
			attrIDs[v.Name] = v.ID
		} else if v.Name == "贮存条件" {
			attrIDs[v.Name] = v.ID
		} else if v.Name == "净含量" {
			attrIDs[v.Name] = v.ID
		} else if v.Name == "规格" {
			attrIDs[v.Name] = v.ID
		}
	}
	values, _, err := api.JdShopAPI.FindValuesByAttrId(attrIDs["贮存条件"])
	for _, v := range values {
		if v.Name == "冷藏 0-4℃" {
			zctjValueID = v.ID
		}
	}
	attrZctj := &jdshopapi.CreateSkuParamAttrs{
		AttrID:     utils.Int2Str(attrIDs["贮存条件"]),
		AttrValues: []string{utils.Int64ToStr(zctjValueID)},
	}
	attrJhl := &jdshopapi.CreateSkuParamAttrs{
		AttrID:     utils.Int2Str(attrIDs["净含量"]),
		AttrValues: []string{"0.5"},
	}
	attrBzq := &jdshopapi.CreateSkuParamAttrs{
		AttrID:     utils.Int2Str(attrIDs["保质期"]),
		AttrValues: []string{"5"},
	}
	attrsProp = append(attrsProp, attrZctj)
	attrsProp = append(attrsProp, attrJhl)
	attrsProp = append(attrsProp, attrBzq)
	createSkuParamWare.MultiCateProps = attrsProp

	//组合sku
	var (
		ggValueID int64 //规格的属性id
	)
	valuesSku, maxNo, err := api.JdShopAPI.FindValuesByAttrId(attrIDs["规格"])
	for _, v := range storeSku.StoreSkuSyncInfoJds {
		var attrsPropSku []*jdshopapi.CreateSkuParamAttrs
		specQuality := utils.Float64ToStr(float64(storeSku.SpecQuality)) + storeSku.SpecUnit
		fmt.Println("test2222222222222222222222", utils.Format4Output(storeSku, false))
		for _, v := range valuesSku {
			if v.Name == specQuality {
				ggValueID = v.ID
			}
		}
		// fmt.Println("test11111111111111111111111", ggValueID)
		if ggValueID == 0 { //说明没有建这个规格，要建上
			catID, _ := api.JdShopAPI.SaveVenderAttrValue(specQuality, attrIDs["规格"], int(storeSku.VendorVendorCatID), maxNo+1)
			ggValueID = catID
		}
		attrSku := &jdshopapi.CreateSkuParamAttrs{
			AttrID:     utils.Int2Str(attrIDs["规格"]),
			AttrValues: []string{utils.Int64ToStr(ggValueID)},
		}
		attrsPropSku = append(attrsPropSku, attrSku)
		sku := &jdshopapi.CreateSkuParamSkus{
			JdPrice:  int(v.VendorPrice),
			StockNum: 9999,
			Type:     "com.jd.pop.ware.ic.api.domain.sku",
			Type2:    "com.jd.pop.ware.ic.api.domain.Sku",
			OuterID:  utils.Int2Str(v.SkuID),
		}
		sku.SaleAttrs = attrsPropSku
		createSkuParamSkus = append(createSkuParamSkus, sku)
	}
	return createSkuParamWare, createSkuParamSkus, err
}