package service

import (
	"go_sku_server/model"
	"go_sku_server/pkg/gredis"
	"go_sku_server/service/sorter"
	"sort"
	"sync"

	"github.com/gin-gonic/gin"
	"github.com/gogf/gf/util/gconv"
	"github.com/gomodule/redigo/redis"
	"github.com/tidwall/gjson"
)

type LyService struct {
}

type Power struct {
	UserId          string `json:"user_id"`
	Mobile          string `json:"mobile"`
	Email           string `json:"email"`
	Member          string `json:"member"`
	VerifyBlacklist string `json:"verify_blacklist"`
	Invoice         string `json:"invoice"`
	SpecialInvoice  string `json:"special_invoice"`
}

/*
联营数据详情
*/
func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan sync.Map) {
	redisConn := gredis.Conn("search_r")
	redisConnSpu := gredis.Conn("spu")
	defer func() {
		redisConn.Close()
		redisConnSpu.Close()
	}()
	fast := ctx.Request.FormValue("power[fast]")
	//是否展示属性
	showAttr := ctx.Request.FormValue("show_attr")
	//是否展示在途库存
	showStockInfo := ctx.Request.FormValue("show_stock_info")
	//批量获取商品详情
	skuArr := gredis.Hmget("default_r", "sku", goodsIds)
	//为了性能着想,这边也先去批量获取spu的信息
	var spuService SpuService
	spuList := spuService.getSpuList(skuArr)

	GoodsRes := sync.Map{}
	for goodsId, skuStr := range skuArr {
		if skuStr == "" {
			GoodsRes.Store(goodsId, false)
			continue
		}
		//初始化有序map，拼接data数据,就是从redis取出初始数据
		sku := model.InitSkuData(skuStr)
		sku.GoodsId = goodsId
		spu := spuList[sku.SpuId]
		//读取包装字段的缓存
		if sku.SupplierId == 7 || sku.SupplierId == 13 || sku.SupplierId == 1688 {
			//sku_raw_map哪里写入(成意写的)
			packing, _ := redis.String(redisConnSpu.Do("HGET", "sku_raw_map", goodsId))
			sku.Packing = gjson.Get(packing, "pack").String()
		}
		sku = ls.GetGoodsImages(sku, spu)
		sku = ls.GetPdf(sku, spu)

		//获取商品名称
		//1688就是mro的sku spuName和GoodsName不是一个东西，不能公用
		if sku.GoodsName != "" && sku.SupplierId == 1688 {
			sku.GoodsName = gjson.Get(spu, "spu_name").String()
		}
		if sku.GoodsName == "" {
			sku.GoodsName = gjson.Get(spu, "spu_name").String()
		}

		//获取品牌名称
		brandId := gjson.Get(spu, "brand_id").Int()
		brandName, _ := redis.String(redisConn.Do("HGET", "brand", brandId))
		sku.BrandName = brandName

		//判断是否要取精简信息
		if fast != "1" {
			sku = ls.GetGoodsClass(sku, spu)
			//仅提供价格和库存
			if sku.GoodsName != "" && brandId != 0 {
				sku.ErpTax = ls.GetErpTax(sku.GoodsName, brandName)
			}
			sku.SupplierName = ls.GetPoolSupplierName(sku.SupplierId)
			if showAttr == "1" {
				//获取属性
				sku.Attrs = ls.GetSpuAttr(sku.SpuId)
			}
			if sku.Attrs == nil {
				sku.Attrs = []interface{}{}
			}
		}

		//获取在途库存信息
		if showStockInfo == "1" && sku.OldGoodsId != 0 {
			sku.StockInfo = ls.getStockInfo(sku.SupplierId, sku.OldGoodsId)
		}
		//格式化为对象返回
		if sku.StockInfo == nil {
			type StockInfoResult struct {
			}
			sku.StockInfo = new(StockInfoResult)
		}

		//获取供应链标准品牌
		//什么是供应链的标准品牌  供应链那边报关的时候要求他们的标准品牌,所以要吧自己的品牌映射上去
		//继来那边对接的标准品牌(下单的时候)
		sku.ScmBrand = ls.GetScmBrand(brandId)

		//获取新版的标准品牌
		sku.StandardBrand = ls.GetStandardBrand(brandId)

		//处理过期,todo 2022.7.13 专卖没有过期
		if sku.SupplierId != 17 && gjson.Get(skuStr, "is_expire").Int() != 0 {
			sku.LadderPrice = nil
		}

		//处理活动
		sku.AcType = 0
		sku.AllowCoupon = 1
		sku.BrandId = brandId

		//这里获取活动价格和活动类型
		sku = ls.GetActivity(sku)

		//最小起订量要大于阶梯价的最小阶梯数量
		if len(sku.LadderPrice) > 0 {
			//排序
			sort.Sort(sorter.LadderPriceSorter(sku.LadderPrice))
			//取出第一个阶梯价
			purchases := sku.LadderPrice[0].Purchases
			if purchases > sku.Moq {
				sku.Moq = purchases
			}
		}

		//获取系数
		sku = ls.GetCoefficientAndPrice(sku)

		//仅提供价格和库存
		if fast != "1" {
			if sku.SupplierId != 0 {
				sku.SuppExtendFee = ls.GetExtendFee(sku.SupplierId, sku.Canal)
			}
			//还要处理货期
			delivery := ls.GetDelivery(sku.SupplierId, sku.Canal)
			if sku.CnDeliveryTime == "" {
				sku.CnDeliveryTime = delivery["cn_delivery"]
			}
			if sku.HkDeliveryTime == "" {
				sku.HkDeliveryTime = delivery["hk_delivery"]
			}

		}

		//处理是否可以购买
		if sku.Mpq == 0 {
			sku.Mpq = 1
		}

		if len(sku.LadderPrice) > 0 {
			sku.LadderPriceResult = sku.LadderPrice
		} else {
			sku.LadderPriceResult = []int{}
		}

		//判断是否可以购买
		sku.IsBuy = ls.GetIsBuy(sku)
		//过期修改库存为0
		if sku.IsExpire == 1 && sku.SupplierId != 17 {
			sku.Stock = 0
		}

		//获取标签信息
		var TagService TagsService
		sku.GoodsTag = TagService.GetTags(sku.GoodsId, 0)

		//用spuInfo补全信息
		sku = ls.CombineSup(sku, spu)
		//最后一步,将sku的全部信息放到有序map里面
		GoodsRes.Store(goodsId, sku)
		//(*goodsRes)[goodsId] = A

	}
	ch <- GoodsRes
}

// 获取活动
func (ls *LyService) GetActivity(sku model.LySku) model.LySku {
	//去判断是否有活动(促销打折活动和满赠活动)
	checkData := model.ActivityCheckData{
		SupplierId:      int(sku.SupplierId),
		BrandId:         int(sku.BrandId),
		StandardBrandId: int(sku.StandardBrand.StandardBrandId),
		GoodsId:         sku.GoodsId,
		Canal:           sku.Canal,
		GoodsName:       sku.GoodsName,
		ClassId:         sku.ClassID2,
	}
	var activityService ActivityService
	priceActivity, giftActivity := activityService.GetActivityData(checkData)
	if priceActivity.HasActivity {
		sku.AcType = 10
		sku.Ratio = priceActivity.Ratio
		sku.RatioUs = priceActivity.RatioUs

		sku.ActivityInfo = priceActivity
	}
	if giftActivity.HasActivity {
		sku.HasGiftActivity = gconv.Int(giftActivity.HasActivity)
		sku.GiftActivity = giftActivity
	}

	//获取是否能使用优惠券
	if giftActivity.AllowCoupon == 2 || priceActivity.AllowCoupon == 2 {
		sku.AllowCoupon = 2
	}
	return sku
}