using AlibabaSDK.Api;
using AlibabaSDK.Domain;
using AlibabaSDK.Request;
using CommonUtil;
using CommonUtil.RabbitMQ;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Operater.DAL;
using Operater.DbModel;
using Operater.DTO.System;
using Operater.Service;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using YouZanSDKStandard.Api;
using YouZanSDKStandard.Api.Domain;
using YouZanSDKStandard.Api.Request;

namespace Api.Operater.Controllers
{
    [Route(TopConstants.API_ROUTE)]
    public class ProductBatchUpdateController : BaseController
    {
        private readonly ILoginUserInfoService _loginUserInfoService;
        private readonly IItemDistributionService _itemDistributionService;
        private readonly IProductManageService _productManageService;
        public ProductBatchUpdateController(ILoginUserInfoService loginUserInfoService, IItemDistributionService itemDistributionService, IProductManageService productManageService)
        {
            _loginUserInfoService = loginUserInfoService;
            _itemDistributionService = itemDistributionService;
            _productManageService = productManageService;
        }
        /// <summary>
        /// 获取商品分组
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public IActionResult GetProductTags()
        {
            var userInfo = _loginUserInfoService.GetUserInfo();
            YouZanItemcategoriesTagsRequest tagReq = new YouZanItemcategoriesTagsRequest()
            { is_sort = true };
            var tagRsp = YouZanClient.Execute(tagReq, userInfo.YzToken);
            if (tagRsp.IsNull() || !tagRsp.success)
            {
                return Error("接口调用失败：" + tagRsp.message);
            }
            //查询各分组执行状态
            var historyTask = new BatchUpdateDAL().ListGet(t => t.TaskStatus != 2);
            List<GetProductTagsResponse> response = JSONUtil.JsonToObject<List<GetProductTagsResponse>>(JSONUtil.ObjectToJson(tagRsp.data.tags));
            string tagsStr = "";
            if (!historyTask.IsNull() && historyTask.Count > 0)
            {
                List<string> tags = historyTask.Select(t => t.Tagids).ToList();
                tagsStr = string.Join(',', tags);
            }
            foreach (var item in response)
            {
                if (!tagsStr.IsNullOrEmpty() && tagsStr.Contains(item.id.ToString()))
                {
                    item.tagStatus = 1;
                }
            }
            return Success(response);
        }

        /// <summary>
        /// 提交批量修改价格任务
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public IActionResult AddBatchUpdatePriceTask([FromBody] AddBatchUpdatePriceTaskRequest request)
        {
            //先查询是否有tagid在执行中
            var historyTask = new BatchUpdateDAL().ListGet(t => t.TaskStatus != 2);
            if (!historyTask.IsNull() && historyTask.Count > 0)
            {
                List<string> tags = historyTask.Select(t => t.Tagids).ToList();
                string tagsStr = string.Join(',', tags);
                List<string> tagLsit = tagsStr.Split(',').ToList();
                if (tagLsit.Any(t => request.Tags.Contains(t)))
                {
                    return Error("有商品分组的任务未执行完成，请勿重复提交");
                }
            }
            string taskId = Guid.NewGuid().ToString();
            BatchUpdate batchUpdate = new BatchUpdate()
            {
                Id = taskId,
                CreateTime = DateTime.Now,
                TaskStatus = 0,
                Tagids = request.Tags,
                TaskRule = JSONUtil.ObjectToJson(request.Rule),
                TaskType = 0
            };
            new BatchUpdateDAL().Insert(batchUpdate);
            //发送修改mq
            ProductDistributionMq mqBody = new ProductDistributionMq()
            {
                TaskType = 2,
                TaskId = taskId
            };
            string ret = MQClientFullChannel.SendMessageStatic(0, "product_distribution", JSONUtil.ObjectToJson(mqBody));
            if (ret != "ok")
            {
                return Error("mq发送失败");
            }
            return Success(true);
        }

        /// <summary>
        /// 获取修改记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult GetUpdateHistory([FromBody] GetUpdateHistoryRequest request)
        {
            var userInfo = _loginUserInfoService.GetUserInfo();
            int totalCount = 0;
            var recordHistory = new BatchUpdateDAL().ListPageGet(t => t.Id != null, t => t.CreateTime, DbEnum.OrderType.Desc, request.PageNo, request.PageSize, ref totalCount);
            List<GetUpdateHistoryResponse> response = JSONUtil.JsonToObject<List<GetUpdateHistoryResponse>>(JSONUtil.ObjectToJson(recordHistory));
            //获取商品分组
            YouZanItemcategoriesTagsRequest tagReq = new YouZanItemcategoriesTagsRequest()
            { is_sort = true };
            var tagRsp = YouZanClient.Execute(tagReq, userInfo.YzToken);
            if (tagRsp.IsNull() || !tagRsp.success)
            {
                return Error("分组接口调用失败：" + tagRsp.message);
            }
            foreach (var rec in response)
            {
                rec.RuleModel = JSONUtil.JsonToObject<PriceUpdateRule>(rec.TaskRule);
                string[] tagIds = rec.Tagids.Split(',');
                string tagName = "";
                foreach (string tag in tagIds)
                {
                    var tagItem = tagRsp.data.tags.Where(t => t.id == long.Parse(tag)).ToList();
                    tagName += "," + ((tagItem.IsNull() || tagItem.Count == 0) ? "" : tagItem[0].name);
                }
                rec.TagName = tagName.IsNullOrEmpty() ? "" : (tagName.Substring(1, tagName.Length - 1));
            }
            return Success(response, request.PageNo, request.PageSize, totalCount);
        }

        /// <summary>
        /// 重新激活任务
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult ReAddTask([FromBody] ReAddTaskRequest request)
        {
            var updateRecord = new BatchUpdateDAL().GetById(request.TaskId);
            string taskId = Guid.NewGuid().ToString();
            BatchUpdate batchUpdate = new BatchUpdate()
            {
                Id = taskId,
                CreateTime = DateTime.Now,
                TaskStatus = 0,
                Tagids = updateRecord.Tagids,
                TaskRule = updateRecord.TaskRule,
                TaskType = 0
            };
            new BatchUpdateDAL().Insert(batchUpdate);
            //发送修改mq
            ProductDistributionMq mqBody = new ProductDistributionMq()
            {
                TaskType = 2,
                TaskId = taskId
            };
            string ret = MQClientFullChannel.SendMessageStatic(0, "product_distribution", JSONUtil.ObjectToJson(mqBody));
            if (ret != "ok")
            {
                return Error("mq发送失败");
            }
            return Success(true);
        }
        /// <summary>
        /// 删除有赞的sku
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult DeleteYzSku([FromBody] DeleteYzSkuRequest request)
        {
            var userInfo = _loginUserInfoService.GetUserInfo();
            //获取有赞商品详情
            YouZanProductDetailGetRequest udetailReq = new YouZanProductDetailGetRequest()
            {
                item_id = long.Parse(request.YzItemId)
            };
            var udetailRs = YouZanClient.Execute(udetailReq, userInfo.YzToken);
            if (udetailRs.IsNull() || !udetailRs.success)
            {
                return Error("获取有赞商品详情失败：" + udetailRs.message);
            }
            YouZanFullSkuUpdateRequest youZanFullSkuUpdateRequest = new YouZanFullSkuUpdateRequest()
            {
                item_id = long.Parse(request.YzItemId),
                sku_picture_display_config = true,

            };
            List<SkuList> newSku = new List<SkuList>();
            List<SkuValueProps> skuProp = new List<SkuValueProps>();
            foreach (var skuItem in udetailRs.data.sku_list)
            {
                if (request.DelSkuId.Contains(skuItem.sku_id))
                {
                    continue;
                }
                newSku.Add(skuItem);
                //查找图片
                foreach (var proItem in skuItem.sku_props)
                {
                    var prop = udetailRs.data.sku_value_props.Where(t => t.name == proItem.prop_value_name).ToList();
                    if (!prop.IsNull() && prop.Count > 0)
                    {
                        skuProp.Add(prop[0]);
                    }
                }

            }
            youZanFullSkuUpdateRequest.sku_list = newSku;
            youZanFullSkuUpdateRequest.sku_value_props = skuProp;
            var fullUpRsp = YouZanClient.Execute(youZanFullSkuUpdateRequest, userInfo.YzToken);
            if (fullUpRsp.IsNull() || !fullUpRsp.success)
            {
                return Error("修改有赞失败：" + fullUpRsp.message);
            }
            ////获取有赞商品详情
            YouZanProductDetailGetRequest detailReq = new YouZanProductDetailGetRequest()
            {
                item_id = long.Parse(request.YzItemId)
            };
            var detailRs = YouZanClient.Execute(detailReq, userInfo.YzToken);
            if (detailRs.IsNull() || !detailRs.success)
            {
                LogUtil.Info("获取有赞商品详情失败：" + detailRs.message, "商品错误");
            }
            else
            {
                //记录有赞最新sku信息
                DistributionRelation distributionRelation = new DistributionRelation()
                {
                    YzskuInfo = JSONUtil.ObjectToJson(detailRs.data.sku_list)
                };
                new DistributionRelationDAL().Update(distributionRelation, i => new { i.YzskuInfo }, t => t.YzProduct == request.YzItemId);
            }
            return Success(true);
        }

        /// <summary>
        /// 获取有赞 1688商品sku对比详情
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult GetTopProductDetail([FromBody] GetTopProductDetailRequest request)
        {
            var userInfo = _loginUserInfoService.GetUserInfo();
            var relate = new DistributionRelationDAL().ListGet(t => t.YzProduct == request.YzProductId && t.ReStatus == 1);
            if (relate.IsNull() || relate.Count == 0)
            {
                return Error("获取铺货关系失败！");
            }
            //获取有赞商品详情
            YouZanProductDetailGetRequest detailReq = new YouZanProductDetailGetRequest()
            {
                item_id = long.Parse(request.YzProductId)
            };
            var detailRs = YouZanClient.Execute(detailReq, userInfo.YzToken);
            if (detailRs.IsNull() || !detailRs.success)
            {
                return Error($"获取有赞商品详情错误：" + detailRs.message);
            }
            List<SkuInfosItem> aliSkuList = new List<SkuInfosItem>();
            bool ispost = false;
            CompareChangeRequest compareChangeRequest = new CompareChangeRequest()
            {
                AliProductId = long.Parse(relate[0].SourceProduct),
                AliToken = userInfo.AlibabaToken,
                ProSource = relate[0].ProSource
            };
            var aliPro = _productManageService.GetAliProductInfo(compareChangeRequest);
            if (!aliPro.Success)
            {
                return Error(aliPro.Error);
            }
            //获取1688或精选商品详情
            if (relate[0].ProSource == 0)
            {//精选
                aliSkuList = aliPro.JXProduct.skuInfos;
                ispost = true;
            }
            else
            {//代发
                List<SkuInfosItem> res = JSONUtil.JsonToObject<List<SkuInfosItem>>(JSONUtil.ObjectToJson(aliPro.DFProduct.productSkuInfos));
                aliSkuList = res;
                ispost = _itemDistributionService.IsPost(aliPro.DFProduct);
            }
            List<ProSkuItem> skuList = new List<ProSkuItem>();
            foreach (var sitem in detailRs.data.sku_list)
            {

                var aliSku = aliSkuList.Where(t => t.skuId == long.Parse(sitem.sku_no)).ToList();
                if (aliSku.IsNull() || aliSku.Count == 0)
                {
                    continue;
                }
                List<ProSkuItemProps> propsList = new List<ProSkuItemProps>();
                foreach (var pro in sitem.sku_props)
                {
                    ProSkuItemProps pr = new ProSkuItemProps()
                    {
                        Name = pro.prop_name,
                        Value = pro.prop_value_name
                    };
                    propsList.Add(pr);
                }
                string aliSkuPrice = relate[0].ProSource == 1 ? aliSku[0].consignPrice.ToString("0.00##") : aliSku[0].retailPrice.ToString("0.00##");
                ProSkuItem proSkuItem = new ProSkuItem()
                {
                    YzSkuId = sitem.sku_id,
                    YzSkuPrice = (decimal.Parse(sitem.price.ToString()) / 100).ToString("0.00##"),
                    Props = propsList,
                    AliSkuId = aliSku[0].skuId.ToString(),
                    AliSkuPrice = aliSkuPrice,
                    YzItemId = request.YzProductId,
                    IsAliPost = ispost
                };
                skuList.Add(proSkuItem);
            }
            return Success(skuList);
        }

        /// <summary>
        /// 修改有赞商品分组
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public IActionResult UpdateProTags([FromBody] UpdateProTagsRequest request)
        {
            var userInfo = _loginUserInfoService.GetUserInfo();
            YouZanProductUpdateReqDomain upDomain = new YouZanProductUpdateReqDomain()
            {
                item_id = long.Parse(request.YzProductId),
                tag_ids = request.TagList
            };
            YouZanProductUpdateRequest yzReq = new YouZanProductUpdateRequest()
            { param = upDomain };
            var yzRsp = YouZanClient.Execute(yzReq, userInfo.YzToken);
            if (!yzRsp.success)
            {
                return Error($"修改失败：" + yzRsp.message);
            }
            return Success(true);
        }


        public class GetProductTagsResponse : YouZanItemcategoriesTagsDomainItem
        {
            /// <summary>
            /// 0未执行 1有任务执行中
            /// </summary>
            public int tagStatus { get; set; }
        }



    }
}