using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using AlibabaSDK.Api;
using AlibabaSDK.Domain;
using AlibabaSDK.Request;
using BaiDuSdk;
using CommonUtil;
using CommonUtil.RabbitMQ;
using HtmlAgilityPack;
using Operater.DAL;
using Operater.DbModel;
using Operater.DTO.System;
using YouZanSDKStandard.Api;
using YouZanSDKStandard.Api.Domain;
using YouZanSDKStandard.Api.Request;
using YouZanSDKStandard.Api.Response;

namespace Operater.Service.System
{
    public class ItemDistributionService : IItemDistributionService
    {

        /// <summary>
        /// 精选货源铺货
        /// </summary>
        /// <param name="sourcePid"></param>
        public async Task<bool> RunDistribution(DistributionHistory taskInfo, string aliToken, string yzToken, List<ProductFilter> filter)
        {
            DistributionHistory finalHis = new DistributionHistory();
            try
            {
                //任务状态改成执行中
                DistributionHistory distributionHistory = new DistributionHistory()
                {
                    DisStatus = 1,
                    RunTime = DateTime.Now
                };
                new DistributionHistoryDAL().Update(distributionHistory, t => new { t.DisStatus, t.RunTime }, t => t.Id == taskInfo.Id);
                //获取1688商品详情
                List<string> ls = new List<string>();
                ls.Add(taskInfo.ProductId);
                PFTProductDetailRequest request = new PFTProductDetailRequest()
                {
                    offerIds = ls
                };
                var response = AliabaClient.Execute(request, aliToken);
                if (response.IsNull() || !response.result.success || response.result.result.Count == 0)
                {//获取商品详情失败
                    LogUtil.Info($"获取商品详情失败：{taskInfo.Id}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "获取商品详情失败:" + (response.IsNull() ? "null" : response.ErrorMsg);
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                //判断1688商品状态
                if (response.result.result[0].productInfo.status != "published")
                {//不可铺货
                    LogUtil.Info($"商品状态不对：{response.result.result[0].productInfo.status}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "商品状态不对:" + (response.result.result[0].productInfo.status);
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                if (!response.result.result[0].productInfo.saleInfo.supportOnlineTrade)
                {
                    LogUtil.Info($"不支持网上交易：{response.result.result[0].productInfo.saleInfo.supportOnlineTrade}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "商品不支持网上交易";
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                StringBuilder imgError = new StringBuilder();
                //商品图片
                finalHis.ProImg = "https://cbu01.alicdn.com/img/" + response.result.result[0].productInfo.image.images[0];
                //string imgMsg = FilterImg(filter, finalHis.ProImg);
                //if (!imgMsg.IsNullOrEmpty())
                //{
                //    imgError.Append($"主图:[{imgMsg}]");
                //}
                //商品title
                finalHis.ProTitle = response.result.result[0].productInfo.subject;

                //根据规则调整字段
                var aliPro = response.result.result[0].productInfo;
                //是否包邮 精选货源默认包邮
                finalHis.IsFreeShipping = 1;
                //调用有赞新增商品接口 youzan.item.add.1.0.1
                YouZanItemAddRequest yzReq = new YouZanItemAddRequest();
                yzReq.param = GetAliInfoToYz(aliPro, yzToken, filter, ref imgError);
                var yzRsp = YouZanClient.Execute(yzReq, yzToken);
                if (yzRsp.IsNull() || !yzRsp.success)
                {//新增失败
                    finalHis.DisStatus = 3;
                    finalHis.Memo = yzRsp.IsNull() ? "有赞接口错误" : yzRsp.message;
                    LogUtil.Info($"有赞错误：{finalHis.Memo}--request:" + JSONUtil.ObjectToJson(yzReq), "铺货错误");
                }
                else
                {
                    //有赞返回商品id
                    string yzProductId = yzRsp.data.item_id;
                    //修改任务状态
                    finalHis.DisStatus = 2;
                    finalHis.YzItemId = yzProductId;
                    finalHis.YzAlias = yzRsp.data.alias;
                    string yzskuInfo = UpdateYzSku(yzProductId, yzToken);
                    if (!imgError.IsNull() && imgError.Length > 0)
                    {
                        finalHis.Memo = imgError.ToString();
                    }
                    yzskuInfo = yzskuInfo.IsNullOrEmpty() ? JSONUtil.ObjectToJson(yzReq.param.sku_list) : yzskuInfo;
                    //记录1688id与有赞id的关系
                    DistributionRelation distributionRelation = new DistributionRelation()
                    {
                        Id = TopUtil.GetId().ToString(),
                        SourceProduct = taskInfo.ProductId,
                        YzProduct = yzProductId,
                        YzAlias = yzRsp.data.alias,
                        ReStatus = 1,
                        InstanceCode = response.result.result[0].instanceCode,
                        CreateTime = DateTime.Now,
                        AliskuInfo = JSONUtil.ObjectToJson(response.result.result[0].productInfo.skuInfos),
                        YzskuInfo = yzskuInfo,
                        ProSource = 0
                    };
                    new DistributionRelationDAL().Insert(distributionRelation);
                    //关注商品
                    AlibabaProductFollowRequest followReq = new AlibabaProductFollowRequest()
                    {
                        productId = long.Parse(taskInfo.ProductId)
                    };
                    var followRsp = AliabaClient.Execute(followReq, aliToken);
                    if (followRsp.IsNull() || followRsp.message != "success")
                    {
                        LogUtil.Info($"关注商品{taskInfo.ProductId}失败，错误：" + (followRsp.IsNull() ? "null" : followRsp.message), "铺货错误");
                    }
                }
            }
            catch (Exception e)
            {
                finalHis.DisStatus = 3;
                finalHis.Memo = e.Message;
                LogUtil.Info($"错误：{e.ToString()}", "铺货错误");
                new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                return false;
            }
            new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo, t.ProImg, t.ProTitle, t.YzAlias, t.YzItemId, t.IsFreeShipping }, t => t.Id == taskInfo.Id);
            return true;
        }

        /// <summary>
        /// 精品货源商品属性赋值给有赞
        /// </summary>
        /// <param name="aliPro"></param>
        /// <returns></returns>
        public static YouZanItemAddDomain GetAliInfoToYz(PFTProductDetailDomainProInfo aliPro, string yzToken, List<ProductFilter> filter, ref StringBuilder imgError)
        {

            YouZanItemAddDomain yzPara = new YouZanItemAddDomain();
            yzPara.item_no = aliPro.productID.ToString();
            string desc = FilterMsg(filter, aliPro.description);
           // desc = FilterDesc(filter, desc);
            yzPara.desc = desc;

            //yzPara.start_sale_num = aliPro.saleInfo.minOrderQuantity;
            yzPara.start_sale_num = 1;
            DeliverySetting deliverySetting = new DeliverySetting()
            {
                express = true
            };
            //售后信息
            PostSaleParam postSaleParam = new PostSaleParam()
            { is_support_barter = 0 };
            postSaleParam.support_unconditional_return = aliPro.sevenDaysRefunds;
            yzPara.post_sale_param = postSaleParam;
            //获取默认运费模板
            var appset = new AppsetDAL().ListGet(t => t.Id != null);
            ItemDeliveryParam itemDeliveryParam = new ItemDeliveryParam
            {
                delivery_setting = deliverySetting,
                delivery_template_id = long.Parse(appset[0].YzPostMould)
            };
            yzPara.item_delivery_param = itemDeliveryParam;
            switch (aliPro.saleInfo.invReduceType)
            {
                case "1"://下单减库存
                    yzPara.stock_deduct_mode = 0;
                    break;
                case "2"://付款减库存
                    yzPara.stock_deduct_mode = 1;
                    break;
            }
            yzPara.title = FilterMsg(filter, aliPro.subject);
            yzPara.is_display = 0;
            //商品库存， 无sku情况下库存必填，如果有sku则无效
            yzPara.quantity = long.Parse(aliPro.saleInfo.amountOnSale.ToString());
            List<SkuList> skuLists = new List<SkuList>();
            List<SkuValueProps> skuValues = new List<SkuValueProps>();
            Dictionary<string, long> imgDic = new Dictionary<string, long>();
            bool isImgShow = false;
            long replaceImgId = 0;
            foreach (var aliSkuItem in aliPro.skuInfos)
            {
                if (aliSkuItem.retailPrice <= 0)
                {
                    continue;
                }
                List<SkuProps> skuPropsList = new List<SkuProps>();
                aliSkuItem.attributes = aliSkuItem.attributes.OrderBy(t => t.skuImageUrl.IsNullOrEmpty()).ToList();
                int index = 0;
                foreach (var attr in aliSkuItem.attributes)
                {//属性信息
                    index++;
                    SkuProps skuProps = new SkuProps()
                    {
                        prop_value_name = attr.attributeValue,
                        prop_name = attr.attributeName,
                        prop_name_id = attr.attValueID,
                        prop_value_id = attr.attributeID
                    };
                    skuPropsList.Add(skuProps);
                    if (index == 1 && !attr.skuImageUrl.IsNullOrEmpty())
                    {
                        isImgShow = true;
                        //处理有赞sku图片信息
                        long imgId = 0;
                        if (imgDic.ContainsKey(attr.skuImageUrl))
                        {
                            imgId = imgDic[attr.skuImageUrl];
                        }
                        else
                        {
                            imgId = UploadImg(yzToken, attr.skuImageUrl);
                            //string imgstr = ImgCheck(filter, attr.skuImageUrl);
                            //if (!imgstr.IsNullOrEmpty())
                            //{
                            //    imgError.Append($"sku:[{imgstr}]");
                            //}
                            imgDic.Add(attr.skuImageUrl, imgId);
                        }
                        SkuValueProps skuValueProps = new SkuValueProps()
                        {
                            name = attr.attributeValue,
                            id = attr.attributeID
                        };
                        if (imgId > 0)
                        {
                            replaceImgId = replaceImgId == 0 ? imgId : replaceImgId;
                            skuValueProps.img_id = imgId;
                        }
                        skuValues.Add(skuValueProps);
                    }
                }
                //价格计算。上涨50%
                long price = long.Parse(Math.Ceiling(aliSkuItem.retailPrice * 100 + aliSkuItem.retailPrice * 100 * 0.5).ToString());
                SkuList skuitem = new SkuList()
                {
                    //price = long.Parse((Math.Round(aliSkuItem.price * 100, 2)).ToString()),
                    price = price,
                    sku_no = aliSkuItem.skuId.ToString(),
                    stock_num = aliSkuItem.amountOnSale,
                    sku_props = skuPropsList
                };
                skuLists.Add(skuitem);
            }
            if (!skuValues.IsNull() && skuValues.Count > 0)
            {
                yzPara.sku_value_props = skuValues;
                yzPara.sku_picture_display_config = isImgShow;
            }
            //sku信息
            yzPara.sku_list = skuLists;
            ItemPriceParam itemPriceParam = new ItemPriceParam()
            {
                price = long.Parse(Math.Round(aliPro.saleInfo.priceRanges[0].price * 100, 2).ToString())
            };
            yzPara.item_price_param = itemPriceParam;
            //处理商品图片
           
            int currentIndex = 0;
            List<long> imageIds = new List<long>();
            foreach (var img in aliPro.image.images)
            {
                currentIndex++;
                long imgId = 0;
                if (currentIndex==1)
                {
                    //检测第一张主图
                    string imgstr = ImgCheck(filter, aliPro.image.images[0]);
                    if (!imgstr.IsNullOrEmpty())
                    {
                        imgError.Append($"主图:[{imgstr}]");
                        imgId = replaceImgId;
                        imageIds.Add(imgId);
                        continue;
                    }
                }
                if (imgDic.ContainsKey(img))
                {
                    imgId = imgDic[img];
                }
                else
                {
                    imgId = UploadImg(yzToken, img);

                    imgDic.Add(img, imgId);
                }
                if (imgId == 0)
                {//上传失败
                    continue;
                }
                imageIds.Add(imgId);
            }
            yzPara.image_ids = imageIds;
            return yzPara;
        }

        /// <summary>
        /// 代发方案铺货
        /// </summary>
        /// <param name="taskInfo"></param>
        /// <param name="aliToken"></param>
        /// <param name="yzToken"></param>
        /// <param name="filter"></param>
        /// <returns></returns>
        public async Task<bool> DaiFaRunDistribution(DistributionHistory taskInfo, string aliToken, string yzToken, string yzShopId, List<ProductFilter> filter)
        {
            DistributionHistory finalHis = new DistributionHistory();
            try
            {
                //任务状态改成执行中
                DistributionHistory distributionHistory = new DistributionHistory()
                {
                    DisStatus = 1,
                    RunTime = DateTime.Now
                };
                new DistributionHistoryDAL().Update(distributionHistory, t => new { t.DisStatus, t.RunTime }, t => t.Id == taskInfo.Id);
                //获取1688商品详情
                FenXiaoProductInfoGetRequest request = new FenXiaoProductInfoGetRequest()
                {
                    offerId = long.Parse(taskInfo.ProductId)
                };
                var response = AliabaClient.Execute(request, aliToken);
                if (response.IsNull() || !response.Success)
                {//获取商品详情失败
                    LogUtil.Info($"获取商品详情失败：{taskInfo.Id}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "获取商品详情失败:" + (response.IsNull() ? "null" : response.ErrorMsg);
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                //判断1688商品状态
                if (response.productInfo.status != "published")
                {//不可铺货
                    LogUtil.Info($"商品状态不对：{response.productInfo.status}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "商品状态不对:" + (response.productInfo.status);
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                if (!response.productInfo.productSaleInfo.supportOnlineTrade)
                {
                    LogUtil.Info($"不支持网上交易：{response.productInfo.productSaleInfo.supportOnlineTrade}", "铺货错误");
                    finalHis.DisStatus = 3;
                    finalHis.Memo = "商品不支持网上交易";
                    new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                    return false;
                }
                StringBuilder imgError = new StringBuilder();
                //商品图片
                finalHis.ProImg = response.productInfo.productImage.images[0];
                //string imgMsg = FilterImg(filter, finalHis.ProImg);
                //if (!imgMsg.IsNullOrEmpty())
                //{
                //    imgError.Append($"主图:[{imgMsg}]");
                //}
                //商品title
                finalHis.ProTitle = response.productInfo.subject;

                //根据规则调整字段
                var aliPro = response.productInfo;

                //是否包邮
                bool isPost = IsPost(aliPro);
                finalHis.IsFreeShipping = isPost ? 1 : 0;
                //调用有赞新增商品接口 youzan.item.add.1.0.1
                YouZanItemAddRequest yzReq = new YouZanItemAddRequest();
                yzReq.param = DaiFaGetAliInfoToYz(aliPro, yzToken, filter, ref imgError);
                var yzRsp = YouZanClient.Execute(yzReq, yzToken);
                if (yzRsp.IsNull() || !yzRsp.success)
                {//新增失败
                    finalHis.DisStatus = 3;
                    finalHis.Memo = yzRsp.IsNull() ? "有赞接口错误" : yzRsp.message;
                    LogUtil.Info($"有赞错误：{finalHis.Memo}--request:" + JSONUtil.ObjectToJson(yzReq), "铺货错误");
                }
                else
                {
                    //有赞返回商品id
                    string yzProductId = yzRsp.data.item_id;

                    //添加分销商品关系
                    FenXiaoOutproductRelationAddRequest relaReq = new FenXiaoOutproductRelationAddRequest()
                    {
                        channel = "youzan",
                        offerId = long.Parse(taskInfo.ProductId),
                        outItemCode = yzProductId,
                        outShopCode = yzShopId
                    };
                    var relaRsp = AliabaClient.Execute(relaReq, aliToken);
                    if (relaRsp.IsNull() || !relaRsp.Success)
                    {
                        finalHis.DisStatus = 3;
                        finalHis.Memo = "添加分销商品关系失败:" + (relaRsp.IsNull() ? "null" : relaRsp.ErrorMsg);
                        LogUtil.Info($"添加分销商品关系失败：{JSONUtil.ObjectToJson(relaReq)}--返回：" + (relaRsp.IsNull() ? "null" : relaRsp.ErrorMsg), "铺货错误");
                        new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                        return false;
                    }
                    //修改任务状态
                    finalHis.DisStatus = 2;
                    finalHis.YzItemId = yzProductId;
                    finalHis.YzAlias = yzRsp.data.alias;
                    string yzskuInfo = UpdateYzSku(yzProductId, yzToken);

                    if (!imgError.IsNull() && imgError.Length > 0)
                    {
                        finalHis.Memo = imgError.ToString();
                    }
                    yzskuInfo = yzskuInfo.IsNullOrEmpty() ? JSONUtil.ObjectToJson(yzReq.param.sku_list) : yzskuInfo;
                    //记录1688id与有赞id的关系
                    DistributionRelation distributionRelation = new DistributionRelation()
                    {
                        Id = TopUtil.GetId().ToString(),
                        SourceProduct = taskInfo.ProductId,
                        YzProduct = yzProductId,
                        YzAlias = yzRsp.data.alias,
                        ReStatus = 1,
                        InstanceCode = response.productInfo.sellerId.ToString(),
                        CreateTime = DateTime.Now,
                        AliskuInfo = JSONUtil.ObjectToJson(response.productInfo.productSkuInfos),
                        YzskuInfo = yzskuInfo,
                        ProSource = 1
                    };
                    new DistributionRelationDAL().Insert(distributionRelation);
                    //关注商品
                    AlibabaProductFollowRequest followReq = new AlibabaProductFollowRequest()
                    {
                        productId = long.Parse(taskInfo.ProductId)
                    };
                    var followRsp = AliabaClient.Execute(followReq, aliToken);
                    if (followRsp.IsNull() || followRsp.message != "success")
                    {
                        LogUtil.Info($"关注商品{taskInfo.ProductId}失败，错误：" + (followRsp.IsNull() ? "null" : followRsp.message), "铺货错误");
                    }
                    //修改代发商品表铺货状态
                    DaifaProduct daifaProduct = new DaifaProduct()
                    {
                        IsDistribute = 1
                    };
                    new DaifaProductDAL().Update(daifaProduct, i => new { i.IsDistribute }, t => t.Id == taskInfo.ProductId);
                }
            }
            catch (Exception e)
            {
                finalHis.DisStatus = 3;
                finalHis.Memo = e.Message;
                LogUtil.Info($"错误：{e.ToString()}", "铺货错误");
                new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo }, t => t.Id == taskInfo.Id);
                return false;
            }

            //修改任务状态
            new DistributionHistoryDAL().Update(finalHis, t => new { t.DisStatus, t.Memo, t.ProImg, t.ProTitle, t.YzAlias, t.YzItemId, t.IsFreeShipping }, t => t.Id == taskInfo.Id);
            return true;
        }

        #region 是否包邮
        public bool IsPost(FenXiaoProductInfoGetDomain productInfo)
        {
            if (productInfo.productShippingInfo.freightTemplateID == 1)
            {
                return true;
            }
            double PfMinPrice = productInfo.productSaleInfo.priceRanges.Max(t => t.price);
            double FxMinPrice = productInfo.productSkuInfos.Min(t => t.consignPrice);
            if (FxMinPrice > PfMinPrice && FxMinPrice - PfMinPrice > 2)
            {
                return true;
            }
            return false;
        }

        #endregion


        public static YouZanItemAddDomain DaiFaGetAliInfoToYz(FenXiaoProductInfoGetDomain aliPro, string yzToken, List<ProductFilter> filter, ref StringBuilder imgError)
        {
            YouZanItemAddDomain yzPara = new YouZanItemAddDomain();
            yzPara.item_no = aliPro.productID.ToString();
            yzPara.desc = FilterMsg(filter, aliPro.description);
            //yzPara.start_sale_num = aliPro.saleInfo.minOrderQuantity;
            yzPara.start_sale_num = 1;
            DeliverySetting deliverySetting = new DeliverySetting()
            {
                express = true
            };
            //售后信息
            PostSaleParam postSaleParam = new PostSaleParam()
            { is_support_barter = 0 };
            //是否支持7天无理由退货
            //postSaleParam.support_unconditional_return = aliPro.sevenDaysRefunds;
            bool support_unconditional_return = false;
            foreach (var m in aliPro.productExtendInfos)
            {
                if (!"buyerProtection,buyerProtectionDistribution".Contains(m.key) || m.value.IsNullOrEmpty())
                {
                    continue;
                }
                List<string> arr = JSONUtil.JsonToObject<List<string>>(m.value);
                foreach (var a in arr)
                {
                    if (a.Contains("wlybt"))
                    {
                        support_unconditional_return = true;
                        break;
                    }
                }
                if (support_unconditional_return) break;
            }
            postSaleParam.support_unconditional_return = support_unconditional_return;
            yzPara.post_sale_param = postSaleParam;
            //获取默认运费模板
            var appset = new AppsetDAL().ListGet(t => t.Id != null);
            ItemDeliveryParam itemDeliveryParam = new ItemDeliveryParam
            {
                delivery_setting = deliverySetting,
                delivery_template_id = long.Parse(appset[0].YzPostMould)
            };
            yzPara.item_delivery_param = itemDeliveryParam;
            //默认付款减库存
            yzPara.stock_deduct_mode = 1;
            yzPara.title = FilterMsg(filter, aliPro.subject);
            yzPara.is_display = 0;
            //商品库存， 无sku情况下库存必填，如果有sku则无效
            yzPara.quantity = long.Parse(aliPro.productSkuInfos.Min(t => t.amountOnSale).ToString());
            List<SkuList> skuLists = new List<SkuList>();
            List<SkuValueProps> skuValues = new List<SkuValueProps>();
            Dictionary<string, long> imgDic = new Dictionary<string, long>();
            bool isImgShow = false;
            long replaceImgId = 0;
            foreach (var aliSkuItem in aliPro.productSkuInfos)
            {
                if (aliSkuItem.consignPrice <= 0)
                {
                    continue;
                }
                List<SkuProps> skuPropsList = new List<SkuProps>();
                aliSkuItem.attributes = aliSkuItem.attributes.OrderBy(t => t.skuImageUrl.IsNullOrEmpty()).ToList();
                int index = 0;
                foreach (var attr in aliSkuItem.attributes)
                {//属性信息
                    index++;
                    SkuProps skuProps = new SkuProps()
                    {
                        prop_value_name = attr.attributeValue,
                        prop_name = attr.attributeName,
                        prop_name_id = 0,
                        prop_value_id = attr.attributeID
                    };
                    skuPropsList.Add(skuProps);
                    if (index == 1 && !attr.skuImageUrl.IsNullOrEmpty())
                    {
                        isImgShow = true;
                        //处理有赞sku图片信息
                        long imgId = 0;
                        if (imgDic.ContainsKey(attr.skuImageUrl))
                        {
                            imgId = imgDic[attr.skuImageUrl];
                        }
                        else
                        {
                            imgId = UploadImg(yzToken, attr.skuImageUrl);
                            //string imgstr = ImgCheck(filter, attr.skuImageUrl);
                            //if (!imgstr.IsNullOrEmpty())
                            //{
                            //    imgError.Append($"sku:[{imgstr}]");
                            //}
                            imgDic.Add(attr.skuImageUrl, imgId);
                        }
                        SkuValueProps skuValueProps = new SkuValueProps()
                        {
                            name = attr.attributeValue,
                            id = attr.attributeID
                        };
                        if (imgId > 0)
                        {
                            replaceImgId = replaceImgId == 0 ? imgId : replaceImgId;
                            skuValueProps.img_id = imgId;
                        }
                        skuValues.Add(skuValueProps);
                    }
                }
                //价格计算。上涨50%
                long price = long.Parse(Math.Ceiling(aliSkuItem.consignPrice * 100 + aliSkuItem.consignPrice * 100 * 0.5).ToString());
                SkuList skuitem = new SkuList()
                {
                    //price = long.Parse((Math.Round(aliSkuItem.price * 100, 2)).ToString()),
                    price = price,
                    sku_no = aliSkuItem.skuId.ToString(),
                    stock_num = aliSkuItem.amountOnSale,
                    sku_props = skuPropsList
                };
                skuLists.Add(skuitem);
            }
            if (!skuValues.IsNull() && skuValues.Count > 0)
            {
                yzPara.sku_value_props = skuValues;
                yzPara.sku_picture_display_config = isImgShow;
            }
            //sku信息
            yzPara.sku_list = skuLists;

            ItemPriceParam itemPriceParam = new ItemPriceParam()
            {
                price = long.Parse(Math.Round(aliPro.productSaleInfo.priceRanges[0].price * 100, 2).ToString())
            };
            yzPara.item_price_param = itemPriceParam;
            //处理商品图片
            List<long> imageIds = new List<long>();
            int currentIndex = 0;
            foreach (var img in aliPro.productImage.images)
            {
                currentIndex++;
                long imgId = 0;
                if (currentIndex == 1)
                {
                    //检测第一张主图
                    string imgstr = ImgCheck(filter, aliPro.productImage.images[0]);
                    if (!imgstr.IsNullOrEmpty())
                    {
                        imgError.Append($"主图:[{imgstr}]");
                        imgId = replaceImgId;
                        imageIds.Add(imgId);
                        continue;
                    }
                }
                if (imgDic.ContainsKey(img))
                {
                    imgId = imgDic[img];
                }
                else
                {
                    imgId = UploadImg(yzToken, img);
                    //string imgstr = ImgCheck(filter, img);
                    //if (!imgstr.IsNullOrEmpty())
                    //{
                    //    imgError.Append($"主图:[{imgstr}]");
                    //}
                    imgDic.Add(img, imgId);
                }
                if (imgId == 0)
                {//上传失败
                    continue;
                }
                imageIds.Add(imgId);
            }
            yzPara.image_ids = imageIds;
            return yzPara;
        }


        #region 更新有赞信息
        private string UpdateYzSku(string yzItemId, string yzToken)
        {
            ////获取有赞商品详情
            YouZanProductDetailGetRequest detailReq = new YouZanProductDetailGetRequest()
            {
                item_id = long.Parse(yzItemId)
            };
            var detailRs = YouZanClient.Execute(detailReq, yzToken);
            if (detailRs.IsNull() || !detailRs.success)
            {
                return null;
            }
            else
            {
                return JSONUtil.ObjectToJson(detailRs.data.sku_list);
            }
        }

        #endregion

        /// <summary>
        /// 图片上传有赞
        /// </summary>
        /// <param name="urls"></param>
        /// <returns></returns>
        private static long UploadImg(string yzToken, string url)
        {
            if (url.IsNullOrEmpty())
            {
                return 0;
            }
            string[] urlArr = url.Split('.');
            string fileName = "D://Img/" + Guid.NewGuid().ToString() + $".{urlArr[urlArr.Length - 1]}";
            WebClient MyWebClient = new WebClient();
            if (!url.StartsWith("http"))
            {
                url = "https://cbu01.alicdn.com/img/" + url;
            }
            MyWebClient.DownloadFile(url, fileName);
            //上传至有赞
            UploadImageResponse response = YouZanUploadeImg.UploadImage(yzToken, fileName);

            if (!response.IsNull() && response.success)
            {
                return response.data.image_id;
            }
            return 0;
        }

        /// <summary>
        /// 添加铺货任务
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public async Task<bool> AddDistributionTask(ProductDistributionRequest request)
        {
            //判断是否有生成中的
            var history = new DistributionHistoryDAL().ListGet(t => request.ProductId.Contains(t.ProductId) && (t.DisStatus == 0 || t.DisStatus == 1));
            List<DistributionHistory> tasks = new List<DistributionHistory>();
            string taskId = TopUtil.GetId().ToString();
            foreach (var pid in request.ProductId)
            {
                if (history.Any(t => t.ProductId == pid))
                {//正在执行中或未执行的跳过
                    continue;
                }
                DistributionHistory distributionHistory = new DistributionHistory()
                {
                    Id = TopUtil.GetId().ToString(),
                    ProductId = pid,
                    CreateTime = DateTime.Now,
                    TaskId = taskId,
                    DisStatus = 0,
                    ProSource = request.ProSource
                };
                tasks.Add(distributionHistory);
            }
            if (!tasks.IsNull() && tasks.Count > 0)
            {
                //插入记录表
                new DistributionHistoryDAL().InsertRange(tasks);
                //发执行mq
                ProductDistributionMq productDistributionMq = new ProductDistributionMq()
                {
                    TaskId = taskId
                };
                string ret = MQClientFullChannel.SendMessageStatic(0, "product_distribution", JSONUtil.ObjectToJson(productDistributionMq));
                if (ret != "ok")
                {
                    LogUtil.Info($"发MQ失败：{taskId}", "铺货任务mq失败");
                    return false;
                }
                return true;
            }
            return false;
        }

        /// <summary>
        /// 解除商品关联
        /// </summary>
        /// <param name="aliProductId"></param>
        /// <param name="aliToken"></param>
        /// <returns></returns>

        public bool RemoveRelatProduct(string aliProductId, string aliToken, string yzToken, DistributionHistory history, string yzShopId)
        {
            try
            {
                //取消关注商品
                AlibabaProductUnFollowRequest request = new AlibabaProductUnFollowRequest()
                {
                    productId = long.Parse(aliProductId)
                };
                var response = AliabaClient.Execute(request, aliToken);
                if (response.IsNull() || response.message != "success")
                {
                    return false;
                }
                if (history.ProSource == 1)
                {//代发方案商品，需额外解除分销关系
                    FenXiaoOutproductRelationDeleteRequest deReq = new FenXiaoOutproductRelationDeleteRequest()
                    {
                        channel = "youzan",
                        offerId = long.Parse(history.ProductId),
                        outItemCode = history.YzItemId,
                        outShopCode = yzShopId
                    };
                    var relaRsp = AliabaClient.Execute(deReq, aliToken);
                    if (relaRsp.IsNull() || !relaRsp.Success)
                    {
                        return false;
                    }
                    DaifaProduct daifaProduct = new DaifaProduct()
                    {
                        IsDistribute = 0
                    };
                    new DaifaProductDAL().Update(daifaProduct, i => new { i.IsDistribute }, t => t.Id == history.ProductId);
                }
                //表里关系解除关注
                DistributionRelation distributionRelation = new DistributionRelation()
                {
                    ReStatus = 0
                };
                new DistributionRelationDAL().Update(distributionRelation, i => new { i.ReStatus }, t => t.SourceProduct == aliProductId);
                //删除有赞商品
                YouZanItemDeleteRequest youZanItemDeleteRequest = new YouZanItemDeleteRequest()
                {
                    item_id = long.Parse(history.YzItemId)
                };
                var youZanItemDeleteRsp = YouZanClient.Execute(youZanItemDeleteRequest, yzToken);
                if (youZanItemDeleteRsp.IsNull() || !youZanItemDeleteRsp.success || !youZanItemDeleteRsp.data.is_success)
                {
                    LogUtil.Info($"id：{history.YzItemId}--error:{youZanItemDeleteRsp.message}", "有赞商品删除error");
                }

                return true;

            }
            catch (Exception e)
            {
                LogUtil.Info("aliProductId:" + aliProductId + "--" + e.ToString(), "解除商品关联error");
                return false;
            }
        }

        public static string FilterMsg(List<ProductFilter> filter, string msg)
        {
            try
            {
                foreach (var fi in filter)
                {
                    string replaceStr = fi.Replace.IsNullOrEmpty() ? "" : fi.Replace;
                    msg = msg.Replace(fi.KeyWord, replaceStr);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info(e.ToString(), "过滤关键词error");
            }
            return msg;
        }

        public static string ImgCheck(List<ProductFilter> filter, string imgUrl)
        {
            if (!imgUrl.StartsWith("http"))
            {
                imgUrl = "https://cbu01.alicdn.com/img/" + imgUrl;
            }
            string imgMsg = FilterImg(filter, imgUrl);
            if (!imgMsg.IsNullOrEmpty())
            {
                return imgMsg;
            }
            return null;
        }

        #region 处理商品详情图片
        public static string FilterDesc(List<ProductFilter> filter, string desc)
        {
            HtmlDocument doc = new HtmlDocument();
            doc.LoadHtml(desc);
            var imgNode = doc.DocumentNode.SelectNodes("//img");
            foreach (var imgItem in imgNode)
            {
                var imgsrc = imgItem.Attributes["src"].Value;
                string imgError = ImgCheck(filter, imgsrc);
                if (!imgError.IsNullOrEmpty())
                {
                    imgItem.Remove();
                }
            }
            return doc.DocumentNode.OuterHtml;
        }

        #endregion

        #region 图片关键词过滤
        public static string FilterImg(List<ProductFilter> filter, string imgUrl)
        {
            try
            {
                StringBuilder keyError = new StringBuilder();
                //百度ai图片识别
                var res = BaiDuClient.WebImageUrl(imgUrl);
                if (!res.IsSuccess)
                {
                    LogUtil.Info($"百度ai错误：{res.error_msg}--图片：{imgUrl}", "过滤关键词error");
                }
                if (res.words_result_num <= 0)
                {
                    return null;
                }
                var msgList = res.words_result.Select(t => t.words).ToList();
                string msg = string.Join(',', msgList);
                var filterKey = filter.Where(t => msg.Contains(t.KeyWord)).ToList();
                if (!filterKey.IsNull() && filterKey.Count > 0)
                {
                    var filterList = filterKey.Select(t => t.KeyWord).ToList();
                    return string.Join(',', filterList);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info(e.ToString(), "过滤关键词error");
            }
            return null;
        }
        #endregion

        #region 处理sku不对应的情况
        private List<SkuList> ResetSkuInfo(List<SkuInfosItem> aliSkuinfo, List<SkuList> youzanSkuInfo)
        {
            try
            {
                Dictionary<string, List<string>> attrbuteDic = new Dictionary<string, List<string>>();

            }
            catch (Exception e)
            {

            }
            return null;
        }

        #endregion

        public List<string> GetYzItemIdByTag(ListGetDistributionHistoryRequest request, string yzToken)
        {
            List<string> itemList = new List<string>();
            int pageSize = 50;
            int currentPage = 1;
            int totalPage = 1;
            while (currentPage <= totalPage)
            {

                YouZanItemCommonSearchRequest itemReq = new YouZanItemCommonSearchRequest()
                {
                    page_size = pageSize,
                    page_no = currentPage,
                    tag_ids = request.TagIds,
                    is_display = request.IsDisplay
                };
                var itemRsp = YouZanClient.Execute(itemReq, yzToken);
                currentPage++;
                if (itemRsp.IsNull() || !itemRsp.success)
                {
                    continue;
                }
                //计算总页数
                if (totalPage == 1)
                {
                    totalPage = itemRsp.data.paginator.total_count % pageSize == 0 ? itemRsp.data.paginator.total_count / pageSize : (itemRsp.data.paginator.total_count / pageSize) + 1;
                }
                foreach (var yzpro in itemRsp.data.items)
                {
                    if (!itemList.Contains(yzpro.item_id.ToString()))
                    {
                        itemList.Add(yzpro.item_id.ToString());
                    }
                }
            }
            return itemList;

        }



        //public void Dispose()
        //{
        //    return base.dis
        //}
    }
}