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

namespace Tiger.Business.WMS.T100ToWMS
{
    /// <summary>
    ///出货通知单业务类
    /// </summary>
    public class SaleOutInfoBusiness : ISaleOutInfoBusiness
    {
        /// <summary>
        ///业务方法
        /// </summary>
        public int SaveSaleOutInfo(List<SaleOutInfoDTO> input)
        {
            if (input == null || input.Count() == 0)
            {
                return 0;
            }
            var masterData = input.ToObject<List<BIZ_ERP_SALE_OUT>>();// 实体映射
            var detailSource = new List<SalDetailDTO>();
            foreach (var item in input)
            {
                if (!item.Details.Any())
                {
                    continue;
                }
                //把主表的公共数据赋值到明细
                foreach (var detail in item.Details)
                {
                    detail.BILLCODE = item.BILLCODE;
                    detail.CREATE_TIME = item.BILLDATE;
                    detail.DELIVERYDATE = item.BILLDATE;
                    detail.AUTH_ORG = item.AUTH_ORG;
                }
                detailSource.AddRange(item.Details);
            }
            var detailData = detailSource.ToObject<List<BIZ_ERP_SALE_OUT_DTL>>();// 实体映射
            int res = 0;
            //var db = Business.Biz.Db;
            var db = Biz.DataSource["WMS57"].Client;

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

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

            var hostoryMasterData = db.Queryable<BIZ_ERP_SALE_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) && i.GHOST_ROW == false).ToList();// 需要插入的数据
            var masterNeedUpdate = masterData.Where(i => resMaster.Contains(i.BILLCODE) && i.GHOST_ROW == false).ToList();// 需要更新的数据
                                                                                                                          // var masterNeedUpdate = hostoryMasterData.Except(masterData).ToList();// 需要更新的数据
                                                                                                                          //更新
            foreach (var itemnew in masterNeedUpdate)
            {
                itemnew.ID = hostoryMasterData.Where(i => i.BILLCODE == itemnew.BILLCODE).FirstOrDefault()?.ID;
            }
            //删除明细表
            foreach (var ith in hostoryMasterData)
            {
                db.Deleteable<BIZ_ERP_SALE_OUT_DTL>().Where(i => i.BILLCODE == ith.BILLCODE).ExecuteCommand();
            }

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

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

            //  var hostoryDetailData = db.Queryable<BIZ_ERP_SALE_OUT_DTL>().Where(i => BILLCODELst.Contains(i.BILLCODE)).ToList();// 获取明细表旧数据
            // var resDetail = hostoryDetailData.Select(i => i.BILLCODE).Distinct().ToList();
            // var detailNeedInsert = detailData.Where(i => !resDetail.Contains(i.BILLCODE)).ToList();// 需要插入的数据
            // var detailNeedUpdate = detailData.Where(i => resDetail.Contains(i.BILLCODE)).ToList();// 需要更新的数据
            // var detailNeedUpdate = hostoryDetailData.Except(detailData).ToList();// 需要更新的数据

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

            try
            {
                BizSqlsugar.CreateTran(() =>
                {
                    if (masterNeedInsert.Any())
                    {
                        res = BizSqlsugar.InsertDataTable(masterNeedInsert, db);
                    }
                    if (detailData.Any())
                    {
                        res += BizSqlsugar.InsertDataTable(detailData, db);
                    }
                    if (masterNeedUpdate.Any())
                    {
                        res += BizSqlsugar.UpdateDataTable(masterNeedUpdate, db);
                    }
                    /* if (detailNeedUpdate.Any())
                     {
                         res += BizSqlsugar.UpdateDataTable(detailNeedUpdate, db);
                     }*/
                }, db);
            }
            catch (Exception ex)
            {
                new ApiAction().CatchExceptionWithLog(ex, $"接口新增或更新数据异常！");
            }
            return res;
        }
    }
}