using Org.BouncyCastle.Asn1.Cmp;
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 OtherOutInfoBusiness : IOtherOutInfoBusiness
    {
        /// <summary>
        /// 存储T100推送过来的其他出库单信息
        /// </summary>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public int SaveOthOutInfo(List<otherOutInfoDTO> input)
        {
            var masterData = input.ToObject<List<BIZ_ERP_OTH_OUT>>();// 实体映射
            var detailSource = new List<DetailDTO>();

            foreach (var item in input)
            {
                if (!item.Details.Any())
                {
                    continue;
                }
                foreach (var detail in item.Details)
                {
                    detail.BILLCODE = item.BILLCODE;
                    detail.LINESTATUS = 0;
                    detail.AUTH_ORG = item.AUTH_ORG;
                }
                detailSource.AddRange(item.Details);
            }
            var detailData = detailSource.ToObject<List<BIZ_ERP_OTH_OUT_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_ERP_OTH_OUT>().Where(i => BILLCODELst.Contains(i.BILLCODE) && i.GHOST_ROW == false).ToList();// 获取主表旧数据
            var resMaster = hostoryMasterData.Select(i => i.BILLCODE).Distinct().ToList();
            var masterNeedInsert = masterData.Where(i => !resMaster.Contains(i.BILLCODE)).ToList();// 需要插入的数据
            foreach (var item in masterNeedInsert)
            {
                item.STATUS = 0;
            }

            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_ERP_OTH_OUT_DTL>().Where(i => BILLCODELst.Contains(i.BILLCODE) && i.GHOST_ROW == false).ToList();// 获取明细表旧数据
            var itemcodeLst = hostoryDetailData.Select(i => i.ITEM_CODE).Distinct().ToList();// 查询历史物料编号
            var insertDetailData = detailData.Where(i => !resMaster.Contains(i.BILLCODE) && !itemcodeLst.Contains(i.ITEM_CODE)).ToList();// 需要插入的数据
            var updateDetailData = detailData.Where(i => resMaster.Contains(i.BILLCODE) && itemcodeLst.Contains(i.ITEM_CODE)).ToList();// 需要更新的数据
            foreach (var item in updateDetailData)
            {
                item.ID = hostoryDetailData.Where(i => i.BILLCODE == item.BILLCODE && i.ITEM_CODE == item.ITEM_CODE).FirstOrDefault()?.ID;
                item.AUTH_ORG = input[0].AUTH_ORG;
            }

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

            var needDeleteData = hostoryDetailData.Where(i => deletecode.Contains(i.ITEM_CODE) && BILLCODELst.Contains(i.BILLCODE)).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 (insertDetailData.Any())
                        {
                            res += BizSqlsugar.InsertDataTable(insertDetailData, db);
                        }
                        if (updateDetailData.Any())
                        {
                            res += BizSqlsugar.InsertDataTable(updateDetailData, db);
                        }

                        //res += BizSqlsugar.InsertDataTable(detailData, db);
                    }
                }, db);
            }
            catch (Exception)
            {
            }

            return res;
        }
    }
}