using HH.Redis.ReisModel;
using HH.WMS.BLL;
using HH.WMS.BLL.Basic;
using HH.WMS.BLL.Common;
using HH.WMS.BLL.InStock;
using HH.WMS.Common;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using HH.WMS.WebApi.Areas.Common.Controllers;
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Web.Http;
using System.Xml;

namespace HH.WMS.WebApi.Areas.InStock.Controllers
{
    public class XmlUpController : BaseController
    {
        #region Xml文件导入
        /// <summary>
        /// Xml文件导入
        /// </summary>
        /// <param name="entity">审批实体</param>
        /// <returns></returns>
        /// <History>[HANHE(XDL)] CREATED BY 2018-11-30</History>
        [HttpPost]
        public OperateResult ImportXmlDataString(dynamic entityStr)
        {
            string tokenId = entityStr.tokenId.ToString();
            try
            {
                return ValidateToken(tokenId, t =>
                    {
                        //最终实体
                        List<TN_WM_B_UNIQUE_BARCODEEntity> uniqueEntityList = new List<TN_WM_B_UNIQUE_BARCODEEntity>();

                        string stream = entityStr.streamStr.ToString();

                        var newStr = stream.Replace("[\"", "").Replace("\"]", "").Replace("\",\"", ",");
                        string[] splitXml = newStr.Split(',');
                        //当存在多文件时，使用循环
                        foreach (var splitnewStr in splitXml)
                        {
                            XmlDocument xmldoc = new XmlDocument();
                            xmldoc.LoadXml(splitnewStr.Replace("\\", "").Trim());

                            XmlNodeList listNode = xmldoc.SelectSingleNode("DataList").ChildNodes;  //获取Product节点下的所有节点列表

                            //到Product一级
                            foreach (XmlNode node in listNode)
                            {
                                XmlElement xe = (XmlElement)node;
                                var productName = xe.GetAttribute("productName");    //产品名称
                                var pzwh = xe.GetAttribute("pzwh");                   //批准文号

                                XmlNodeList xnfChild = xe.ChildNodes;
                                //到Batch一级
                                foreach (XmlNode child in xnfChild)
                                {
                                    XmlElement xmlchild = (XmlElement)child;

                                    List<string> dataCodeList = new List<string>();

                                    XmlNodeList xnfDataChild = xmlchild.ChildNodes;
                                    //到Data一级
                                    foreach (XmlNode datachild in xnfDataChild)
                                    {
                                        XmlElement xmldatachild = (XmlElement)datachild;
                                        var dataCode = xmldatachild.GetAttribute("code");      //所有Data
                                        dataCodeList.Add(dataCode);
                                    }

                                    var res = BLLCreator.Create<TN_WM_B_UNIQUE_BARCODEBLL>().GetValue(dataCodeList[0]);
                                    if (res != null)
                                    {
                                        return OperateResult.Error("该XML已上传，请选择其他未上传的XML文件！");
                                    }

                                    //创建实体
                                    uniqueEntityList = DoCreateEntity(productName, pzwh, xmlchild, dataCodeList, t);
                                }
                            }
                        }

                        // OperateResult or = BLLCreator.Create<TN_WM_MONGOBLL>().AddList(uniqueEntityList, "TN_WM_B_UNIQUE_BARCODE");

                        //SqlBulkCopy不支持事务，没法trans
                        OperateResult or = BLLCreator.Create<TN_WM_B_UNIQUE_BARCODEBLL>().AddList(uniqueEntityList);

                        if (or.Success)//mongo不支持事务，没法trans
                        {
                            or = BLLCreator.Create<TN_WM_MONGOBLL>().AddList(TempList, "MONGO_KEYTYPE_MAP");
                        }
                        return or;

                    });
            }
            catch (Exception ex)
            {
                return OperateResult.Error(ex.Message);
            }
        }
        /// <summary>
        /// 拼接实体
        /// </summary>
        /// <param name="productName">产品名称</param>
        /// <param name="pzwh">批准文号</param>
        /// <param name="xmlchild">xml节点</param>
        /// <param name="dataCodeList">所有Data的List集合</param>
        /// <param name="userEntity">用户实体</param>
        /// <returns></returns>
        private List<TN_WM_B_UNIQUE_BARCODEEntity> DoCreateEntity(string productName, string pzwh, XmlElement xmlchild, List<string> dataCodeList, RedisUserEntity userEntity)
        {

            var specification = xmlchild.GetAttribute("specification");   //包装规格
            var batchNo = xmlchild.GetAttribute("batchNo");               //批次编码

            AutoBomItemEntity itemEntity = new AutoBomItemEntity();
            List<AutoBomItemEntity> itemEnityList = BLLCreator.Create<TN_WMS_ITEMBLL>().GetItemByNameSpec(productName, specification);
            Log.Info("XML导入获取mongo实体", JsonConvert.SerializeObject(itemEnityList));

            bool noExist = false;
            if (itemEnityList != null)
            {
                if (itemEnityList.Any())
                {
                    if (itemEnityList.Count == 1)//mongo返回单条
                    {
                        itemEntity = itemEnityList[0];
                    }
                    else
                    {
                        List<TN_WM_INCREASE_INVENTORY_DTLEntity> inDtlEntity = BLLCreator.Create<TN_WM_INCREASE_INVENTORYBLL>().GetDtlByBatch(batchNo);
                        Log.Info("XML导入获取入库单实体", JsonConvert.SerializeObject(inDtlEntity));

                        if (inDtlEntity.Count > 0)
                        {
                            noExist = true;
                        }
                        else
                        {
                            if (inDtlEntity.Count == 1)
                            {
                                string itemCode = inDtlEntity[0].CN_S_ITEM_CODE;
                                itemEntity = BLLCreator.Create<TN_WMS_ITEMBLL>().GetItem(itemCode);
                            }
                            else
                            {
                                var entity = inDtlEntity.Where(x => x.CN_S_ITEM_NAME.Contains(productName)).ToList();
                                Log.Info("XML导入匹配产品名称", JsonConvert.SerializeObject(entity));

                                if (entity.Count != 1)
                                {
                                    Exception ex = new Exception("在入库单明细表中未找到或找到多条生产批次是<" + batchNo + ">的数据！");
                                    throw ex;
                                }
                                else
                                {
                                    string itemCode = inDtlEntity[0].CN_S_ITEM_CODE;
                                    itemEntity = BLLCreator.Create<TN_WMS_ITEMBLL>().GetItem(itemCode);
                                }
                            }
                        }
                    }
                }
                else
                {
                    noExist = true;
                }

            }
            else
            {
                noExist = true;
            }
            if (noExist)//不存在、抛异常
            {
                Exception ex = new Exception("未找到物料<" + productName + ">的Mongo实体！");
                throw ex;
            }

            List<TN_WM_B_UNIQUE_BARCODEEntity> uniqueEntityList = new List<TN_WM_B_UNIQUE_BARCODEEntity>();

            var tagRatio = xmlchild.GetAttribute("tagRatio");//级别

            int position = Convert.ToInt32(tagRatio.Split(':')[1]);

            if (tagRatio.Split(':').Length == 2)
            {
                uniqueEntityList = ForeachData(productName, pzwh, xmlchild, dataCodeList, "", itemEntity, userEntity);
            }
            if (tagRatio.Split(':').Length == 3)
            {
                string[] tagRatios = tagRatio.Split(':');
                var foreachCount = Convert.ToInt32(tagRatios[0]) + Convert.ToInt32(tagRatios[1]) + Convert.ToInt32(tagRatios[2]);

                var boci = 0;
                List<string> foreachList = new List<string>();
                for (int i = 1; i <= (dataCodeList.Count) / foreachCount; i++)
                {
                    foreachList = dataCodeList.GetRange(boci * foreachCount, foreachCount);
                    var list = ForeachData(productName, pzwh, xmlchild, foreachList, foreachList[foreachList.Count - 1], itemEntity, userEntity);
                    uniqueEntityList.AddRange(list);
                    boci++;
                }


            }

            return uniqueEntityList;
        }


        List<MONGO_KEYTYPE_MAP> TempList = new List<MONGO_KEYTYPE_MAP>() { };
        /// <summary>
        /// 内部循环
        /// </summary>
        /// <param name="productName">产品名称</param>
        /// <param name="pzwh">批准文号</param>
        /// <param name="xmlchild">xml节点</param>
        /// <param name="dataCodeList">所有Data的List集合</param>
        /// <param name="endCode">结束点</param>
        /// <param name="itemEnity">Item实体</param>
        /// <param name="userEntity">用户实体</param>
        /// <returns></returns>
        private List<TN_WM_B_UNIQUE_BARCODEEntity> ForeachData(string productName, string pzwh, XmlElement xmlchild, List<string> dataCodeList, string endCode, AutoBomItemEntity itemEnity, RedisUserEntity userEntity)
        {
            List<TN_WM_B_UNIQUE_BARCODEEntity> uniqueEntityList = new List<TN_WM_B_UNIQUE_BARCODEEntity>();
            var batchNo = xmlchild.GetAttribute("batchNo");               //批次编码
            var specification = xmlchild.GetAttribute("specification");   //包装规格
            var minPackUnit = xmlchild.GetAttribute("minPackUnit");       //
            var minTagUnit = xmlchild.GetAttribute("minTagUnit");         //
            var tagPackRatio = xmlchild.GetAttribute("tagPackRatio");     //
            var produceDate = xmlchild.GetAttribute("produceDate");       //
            var operatorName = xmlchild.GetAttribute("operator");         //
            var oprDate = xmlchild.GetAttribute("oprDate");               //
            var count = xmlchild.GetAttribute("count");                   //
            var countUnit = xmlchild.GetAttribute("countUnit");           //
            var tagRatio = xmlchild.GetAttribute("tagRatio");             //

            int position = Convert.ToInt32(tagRatio.Split(':')[1]);
            int xiangPos = 1;   //标记箱码位置
            int foreachIndex = 0; //标记循环位置
            foreach (var dataCode in dataCodeList)
            {
                string[] tagRatios = tagRatio.Split(':');
                var qty = 0; var unit = "";

                int packingJb = tagRatios.Length;
                if (foreachIndex != xiangPos * position + (xiangPos - 1))
                {
                    if (dataCode == endCode)
                    {
                        if (packingJb == 2)//    盒/箱两级的情况下，这个条件就是箱码的包装数量和单位
                        {
                            qty = Convert.ToInt32(tagRatios[1]) / (Convert.ToInt32(tagRatios[0]));
                            unit = qty + "盒/箱";
                        }
                        if (packingJb == 3)//    支/盒/箱三级的情况下，这个条件就是箱码的包装数量和单位
                        {
                            qty = Convert.ToInt32(tagRatios[2]) / (Convert.ToInt32(tagRatios[0]));
                            unit = qty + minPackUnit + "/" + minTagUnit;
                        }

                    }
                    TN_WM_B_UNIQUE_BARCODEEntity bar = new TN_WM_B_UNIQUE_BARCODEEntity();

                    bar.CN_S_CODE = dataCode;
                    bar.CN_S_CODE_TYPE = "";
                    bar.CN_S_PARENT_CODE = (dataCode == endCode) ? "" : dataCodeList[xiangPos * position + (xiangPos - 1)];
                    bar.CN_S_PRODUCT_NAME = productName;
                    bar.CN_S_PZWH = pzwh;
                    bar.CN_S_BATCH_NO = batchNo;
                    bar.CN_S_SPECIFICATION = specification;
                    bar.CN_S_MIN_PACK_UNIT = minPackUnit;
                    bar.CN_S_MIN_TAG_UNIT = minTagUnit;
                    bar.CN_S_TAG_PACK_RATIO = tagPackRatio;
                    bar.CN_T_PRODUCT_DATE = Convert.ToDateTime(produceDate);
                    bar.CN_S_OPERATOR = operatorName;
                    bar.CN_T_OPR_DATE = Convert.ToDateTime(oprDate);
                    bar.CN_F_QUANTITY = Convert.ToInt32(count);
                    bar.CN_S_QUANTITY_UNIT = countUnit;
                    bar.CN_S_TAG_RATIO = tagRatio;
                    bar.CN_S_CREATOR = userEntity.CN_S_LOGIN;
                    bar.CN_S_CREATOR_BY = userEntity.CN_S_NAME;
                    bar.CN_T_CREATE = DateTime.Now;
                    bar.CN_S_MODIFY = userEntity.CN_S_LOGIN;
                    bar.CN_S_MODIFY_BY = userEntity.CN_S_NAME;
                    bar.CN_T_MODIFY = DateTime.Now;

                    bar.CN_S_PACKING_UNIT = unit;
                    bar.CN_F_PACKING_QTY = qty;
                    bar.CN_S_ITEM_CODE = itemEnity.CN_S_ITEM_CODE;
                    bar.CN_S_ITEM_NAME = itemEnity.CN_S_ITEM_NAME;
                    bar.CN_S_MEASURE_UNIT = itemEnity.CN_S_MEASURE_UNIT;
                    bar.CN_S_MODEL = itemEnity.CN_S_MODEL;
                    bar.CN_S_ITEM_STATE = "待检";//Constants.DefaultItemState;
                    bar.CN_S_OWNER = Constants.DefaultOwner;
                    uniqueEntityList.Add(bar);

                }
                else
                {
                    if (dataCode != endCode)
                    {
                        if (packingJb == 2)//    盒/箱三级的情况下，这个条件就是箱码的包装数量和单位
                        {
                            qty = Convert.ToInt32(tagRatios[1]) / (Convert.ToInt32(tagRatios[0]));
                            unit = qty + "盒/箱"; //minPackUnit + "/" + minTagUnit;
                        }
                        if (packingJb == 3)//    支/盒/箱三级的情况下，这个条件就是箱码的包装数量和单位
                        {
                            qty = Convert.ToInt32(tagRatios[2]) / (Convert.ToInt32(tagRatios[0]));
                            unit = qty + minPackUnit + "/" + minTagUnit;
                        }
                    }
                    TN_WM_B_UNIQUE_BARCODEEntity bar = new TN_WM_B_UNIQUE_BARCODEEntity();

                    bar.CN_S_CODE = dataCode;
                    bar.CN_S_CODE_TYPE = "";
                    bar.CN_S_PARENT_CODE = endCode;
                    bar.CN_S_PRODUCT_NAME = productName;
                    bar.CN_S_PZWH = pzwh;
                    bar.CN_S_BATCH_NO = batchNo;
                    bar.CN_S_SPECIFICATION = specification;
                    bar.CN_S_MIN_PACK_UNIT = minPackUnit;
                    bar.CN_S_MIN_TAG_UNIT = minTagUnit;
                    bar.CN_S_TAG_PACK_RATIO = tagPackRatio;
                    bar.CN_T_PRODUCT_DATE = Convert.ToDateTime(produceDate);
                    bar.CN_S_OPERATOR = operatorName;
                    bar.CN_T_OPR_DATE = Convert.ToDateTime(oprDate);
                    bar.CN_F_QUANTITY = Convert.ToInt32(count);
                    bar.CN_S_QUANTITY_UNIT = countUnit;
                    bar.CN_S_TAG_RATIO = tagRatio;
                    bar.CN_S_CREATOR = userEntity.CN_S_LOGIN;
                    bar.CN_S_CREATOR_BY = userEntity.CN_S_NAME;
                    bar.CN_T_CREATE = DateTime.Now;
                    bar.CN_S_MODIFY = userEntity.CN_S_LOGIN;
                    bar.CN_S_MODIFY_BY = userEntity.CN_S_NAME;
                    bar.CN_T_MODIFY = DateTime.Now;

                    bar.CN_S_PACKING_UNIT = unit;
                    bar.CN_F_PACKING_QTY = qty;
                    bar.CN_S_ITEM_CODE = itemEnity.CN_S_ITEM_CODE;
                    bar.CN_S_ITEM_NAME = itemEnity.CN_S_ITEM_NAME;
                    bar.CN_S_MEASURE_UNIT = itemEnity.CN_S_MEASURE_UNIT;
                    bar.CN_S_MODEL = itemEnity.CN_S_MODEL;
                    bar.CN_S_ITEM_STATE = "待检";
                    bar.CN_S_OWNER = Constants.DefaultOwner;
                    uniqueEntityList.Add(bar);

                    if ((xiangPos + 1) * position == dataCodeList.Count)
                    {
                        continue;
                    }
                    xiangPos++;
                }

                TempList.Add(new MONGO_KEYTYPE_MAP { Key = dataCode, Type = "2" });

                foreachIndex++;
            }

            return uniqueEntityList;
        }

        #endregion

        #region 查询数据集
        /// <summary>
        /// 获取Xml列表
        /// </summary>
        /// <param name="searchModel">查询实体（页码，显示条数，条件等）</param>
        /// <returns></returns>
        /// <History>[HANHE(XDL)] CREATED BY 2018-11-30</History>
        [HttpPost]
        public string GetXmlList(SearchModel searchModel)
        {
            try
            {
                return ValidateToken(searchModel.TokenId, t =>
                {
                    //根据tokenId 获取当前登陆信息
                    OperateResult resultInfo = GetTokenInfo(searchModel.TokenId);
                    if (!resultInfo.Success) return JsonConvert.SerializeObject(resultInfo);
                    IsoDateTimeConverter timeFormat = new IsoDateTimeConverter();
                    timeFormat.DateTimeFormat = "yyyy-MM-dd HH:mm:ss";

                    OperateResult pagingList = BLLCreator.Create<TN_WM_B_UNIQUE_BARCODEBLL>().GetXmlList(searchModel);
                    return JsonConvert.SerializeObject(pagingList, timeFormat);
                });
            }
            catch (Exception ex)
            {
                return JsonConvert.SerializeObject(OperateResult.Error(ex.ToString()));
                throw;
            }

        }
        #endregion

    }
}