using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using Tiger.Business.SqlSugarHepler;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Entitys.WMS.DTOS;
using Tiger.Model.Extensions;

namespace Tiger.Business.WMS
{
    /// <summary>
    ///
    /// </summary>
    public class TrasferInfoBusiness : ITrasferInfoBusiness
    {
        /// <summary>
        /// 存储T100推送过来的调拨信息
        /// </summary>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public int SaveTrasferInfo(List<TrasferInfoDTO> input, string type = "1")
        {
            var masterData = input.ToObject<List<BIZ_WMS_TRANSFER>>();// 实体映射
            if (masterData != null && type == "2")
            {
                foreach (var item in masterData)
                {
                    item.SOURCECODE = item.BILLCODE;
                }
            }
            var detailSource = new List<TrasferInfoDetailDTO>();
            var time = DateTime.Now;
            foreach (var item in input)
            {
                if (!item.details.Any())
                {
                    continue;
                }
                foreach (var detail in item.details)
                {
                    detail.AUTH_ORG = item.AUTH_ORG;
                    detail.BILLCODE = item.BILLCODE;
                    detail.CREATE_TIME = time;
                    detail.LINESTATUS = string.IsNullOrWhiteSpace(detail.LINESTATUS) ? "0" : detail.LINESTATUS;
                }
                detailSource.AddRange(item.details);
            }
            var detailData = detailSource.ToObject<List<BIZ_WMS_TRANSFER_DTL>>();// 实体映射

            int res = 0;
            //var db = input.First()?.CorporateCode == "88" ? Biz.Db : Biz.DataSource["WMS57"].Client;// 区分正式库还是测试库
            //var db = Biz.Db;// 区分正式库还是测试库
            var db = Biz.DataSource["WMS57"].Client; // 区分正式库还是测试库

            var BILLCODELst = masterData.Select(i => i.BILLCODE).Distinct().ToList();

            #region 区分主表需要插入及更新的数据

            var hostoryMasterData = db.Queryable<BIZ_WMS_TRANSFER>().Where(i => BILLCODELst.Contains(i.BILLCODE)).ToList();// 获取主表旧数据
            var resMaster = hostoryMasterData.Select(i => i.BILLCODE).Distinct().ToList();
            var masterNeedInsert = masterData.Where(i => !resMaster.Contains(i.BILLCODE)).ToList();// 需要插入的数据
            var masterNeedUpdate = masterData.Where(i => resMaster.Contains(i.BILLCODE)).ToList();// 需要更新的数据
            foreach (var item in masterNeedUpdate)
            {
                item.ID = hostoryMasterData.Where(i => i.BILLCODE == item.BILLCODE).FirstOrDefault()?.ID;
            }

            #endregion 区分主表需要插入及更新的数据

            #region 区分明细表需要插入及更新的数据

            var hostoryDetailData = db.Queryable<BIZ_WMS_TRANSFER_DTL>().Where(i => BILLCODELst.Contains(i.BILLCODE)).ToList();// 获取明细表旧数据   剔除状态为2的数据
            var resDetail = hostoryDetailData.Select(i => i.ITEM_CODE).Distinct().ToList();// 获取所有的物料编号
            var ignoreCode = hostoryDetailData.Where(i => i.LINESTATUS == 2 || i.LINESTATUS == 3).Select(i => i.ITEM_CODE).Distinct().ToList();// 需要忽略的物料编号
            var needInsertData = detailData.Where(i => !resDetail.Contains(i.ITEM_CODE) && !ignoreCode.Contains(i.ITEM_CODE)).ToList();// 需要插入的数据
            if (type == "1")
            {
                foreach (var item in needInsertData)
                {
                    item.OUTQTY = 0;
                }
            }

            var needUpdateDetail = detailData.Where(i => resDetail.Contains(i.ITEM_CODE)).ToList();// 确认需要更新的数据

            foreach (var item in needUpdateDetail)
            {
                if (item.LINESTATUS == 0 && type == "1")
                {
                    item.OUTQTY = 0;
                }
                item.AUTH_ORG = input[0].AUTH_ORG;
            }

            var exceptCode = detailData.Select(i => i.ITEM_CODE).Distinct().ToList();
            var deletecode = resDetail.Except(exceptCode).ToList();

            var needDeleteData = hostoryDetailData.Where(i => deletecode.Contains(i.ITEM_CODE) && BILLCODELst.Contains(i.BILLCODE)).ToList();

            foreach (var item in needUpdateDetail)
            {
                item.ID = hostoryDetailData.Where(i => i.ITEM_CODE == item.ITEM_CODE).FirstOrDefault()?.ID;
            }
            //var needInsertData = detailData.Except(hostoryDetailData).ToList();// 需要插入的数据
            //var needDeleteData = hostoryDetailData.Except(detailData).ToList();// 需要删除的数据

            #endregion 区分明细表需要插入及更新的数据

            try
            {
                BizSqlsugar.CreateTran(() =>
                {
                    if (masterNeedInsert.Any())
                    {
                        res = BizSqlsugar.InsertDataTable(masterNeedInsert, db);
                    }
                    if (masterNeedUpdate.Any())
                    {
                        res += BizSqlsugar.UpdateDataTable(masterNeedUpdate, db);
                    }
                    if (detailData.Any())
                    {
                        if (needDeleteData.Any())
                        {
                            db.Deleteable(needDeleteData).ExecuteCommand();
                        }
                        if (needUpdateDetail.Any())
                        {
                            res += db.Updateable(needUpdateDetail).ExecuteCommand();
                        }
                        if (needInsertData.Any())
                        {
                            res += BizSqlsugar.InsertDataTable(needInsertData, db);
                        }
                    }
                }, db);
            }
            catch (Exception)
            {
            }

            return res;
        }
    }
}