using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using AlibabaSDK.Api;
using AlibabaSDK.Domain;
using AlibabaSDK.Request;
using CommonUtil;
using CommonUtil.RabbitMQ;
using Operater.DAL;
using Operater.DbModel;
using Operater.DTO.TopMessage;
using static CommonUtil.DbEnum;

namespace Api.MessageReceive.Service
{
    public class AliMessageService
    {
        /// <summary>
        /// 消息入库
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public static async Task RecordMessage(BaseAliMessage request)
        {
            try
            {
                AliMsgHistory aliMsgHistory = new AliMsgHistory()
                {
                    Id = TopUtil.GetId().ToString(),
                    MsgId = request.msgId,
                    GmtBorn = request.gmtBorn.ToDateTime(),
                    UserInfo = request.userInfo,
                    MsgType = request.type,
                    CreateTime = DateTime.Now,
                    Data = request.data.ToString()
                };
                new AliMsgHistoryDAL().Insert(aliMsgHistory);
            }
            catch (Exception e)
            {
                LogUtil.Info(e.ToString(), "1688消息入库错误");
            }
        }

        /// <summary>
        /// 精选货源商品下架消息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>

        public static async Task OfferQuitHandle(BaseAliMessage request)
        {
            try
            {
                OfferQuitData data = JSONUtil.JsonToObject<OfferQuitData>(request.data.ToString());
                //查询是否有关联铺货商品
                var relationList = new DistributionRelationDAL().ListGet(t => t.SourceProduct == data.offerId && t.ReStatus == 1);
                if (relationList.IsNull() || relationList.Count == 0)
                {
                    return;
                }
                //查询商品信息
                var productInfo = new DistributionHistoryDAL().GetFirst(t => t.ProductId == data.offerId, i => new { i.CreateTime }, OrderType.Desc);
                List<ProductUpdateLog> logList = new List<ProductUpdateLog>();
                foreach (var item in relationList)
                {
                    ProductUpdateLog productUpdateLog = new ProductUpdateLog()
                    {
                        Id = TopUtil.GetId().ToString(),
                        CreateTime = DateTime.Now,
                        UpdateContent = "精选货源商品下架",
                        ProductId = data.offerId,
                        MsgType = request.type,
                        ProcessingStatus = 0,
                        YzProductId = item.YzProduct,
                        MsgId = request.msgId
                    };
                    if (!productInfo.IsNull() && !productInfo.Id.IsNullOrEmpty())
                    {
                        productUpdateLog.ProductImg = productInfo.ProImg;
                        productUpdateLog.ProductTitle = productInfo.ProTitle;
                    }
                    logList.Add(productUpdateLog);
                }
                if (!logList.IsNull() && logList.Count > 0)
                {
                    new ProductUpdateLogDAL().InsertRange(logList);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info($"【消息】{JSONUtil.ObjectToJson(request)}--【错误】{e.ToString()}", "1688消息处理失败");
            }
        }

       
        /// <summary>
        /// 1688商品库存变更消息（关系用户视角）
        /// </summary>
        /// <param name="request"></param>
        public static async Task InventoryChange(BaseAliMessage request)
        {
            try
            {
                OfferInventoryChangeListModel change = JSONUtil.JsonToObject<OfferInventoryChangeListModel>(request.data.ToString());
                var changeList = change.OfferInventoryChangeList;
                var list = changeList.Where(t => t.skuOnSale <= 50).ToList();
                if (list.IsNull() || list.Count == 0)
                {
                    return;
                }
                if(changeList[0].skuId==0)
                {
                    return;
                }
                //小于50提醒
                await AliMessageService.RecordMessage(request);
                var changeDis = list.GroupBy(t => new { t.offerId }).Select(t => t.FirstOrDefault()).ToList();
                var disOffids = changeDis.Select(t => t.offerId.ToString()).ToList();
                //查询是否有关联铺货商品
                var relationList = new DistributionRelationDAL().ListGet(t => disOffids.Contains(t.SourceProduct) && t.ReStatus == 1);
                if (relationList.IsNull() || relationList.Count == 0)
                {
                    return;
                }
                List<ProductUpdateLog> logList = new List<ProductUpdateLog>();
                foreach (var re in relationList)
                {

                    string context = string.Empty;
                    List<SkuInfosItem> skuInfos = JSONUtil.JsonToObject<List<SkuInfosItem>>(re.AliskuInfo);
                    var skuitem = list.Where(t => t.offerId == long.Parse(re.SourceProduct)).ToList();
                    foreach (var sku in skuitem)
                    {
                        var aliSku = skuInfos.Where(t => t.skuId == sku.skuId).ToList();
                        if (aliSku.IsNull() || aliSku.Count == 0)
                        {
                            continue;
                        }
                        var aliSkuItem = aliSku[0];
                        context += $"【{aliSkuItem.attributes[0].attributeValue}】规格库存：{sku.skuOnSale};";
                    }
                    var productInfo = new DistributionHistoryDAL().GetFirst(t => t.ProductId == re.SourceProduct, i => new { i.CreateTime }, OrderType.Desc);
                    ProductUpdateLog productUpdateLog = new ProductUpdateLog()
                    {
                        Id = TopUtil.GetId().ToString(),
                        CreateTime = DateTime.Now,
                        UpdateContent = context,
                        ProductId = re.SourceProduct,
                        MsgType = request.type,
                        ProcessingStatus = 0,
                        YzProductId = re.YzProduct,
                        MsgId = request.msgId
                    };
                    if (!productInfo.IsNull() && !productInfo.Id.IsNullOrEmpty())
                    {
                        productUpdateLog.ProductImg = productInfo.ProImg;
                        productUpdateLog.ProductTitle = productInfo.ProTitle;
                    }
                    logList.Add(productUpdateLog);
                }

                if (!logList.IsNull() && logList.Count > 0)
                {
                    new ProductUpdateLogDAL().InsertRange(logList);
                }
            }
            catch (Exception e)
            {
                LogUtil.Info($"【消息】{JSONUtil.ObjectToJson(request)}--【错误】{e.ToString()}", "1688消息处理失败");
            }
        }

        /// <summary>
        /// 订单消息转发
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        public static async Task TradeMessageSend(string message, BaseAliMessage baseAliMessage)
        {
            try
            {
                TradeMqMessage tradeMqMessage = new TradeMqMessage()
                {
                    MsgType = "ali_trade",
                    MsgBody = message
                };
                if(baseAliMessage.type.StartsWith("PRODUCT_"))
                {
                    tradeMqMessage.MsgType = "ali_product";
                }
                string ret = MQClientFullChannel.SendMessageStatic(0, "trade_interflow", JSONUtil.ObjectToJson(tradeMqMessage));
                if (ret != "ok")
                {
                    LogUtil.Info($"发MQ失败：{message}", "处理失败");
                }
            }
            catch (Exception e)
            {
                LogUtil.Info($"【消息】{message}--【错误】{e.ToString()}", "1688消息处理失败");
            }
        }
    }
}