using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using MES.Service.DB;
using MES.Service.Dto.webApi;
using MES.Service.Modes;
using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
using System.Net.NetworkInformation;

namespace MES.Service.service
{
    public class DbckaManager : Repository<MesInvItemDbsq>
    {
        public bool SaveList(List<ERPDBCK> list)
        {
            var result = list.Select(Save).ToList();
            return result.All(b => b);
        }

        public bool Save(ERPDBCK data)
        {
            var head = MapErpToMesHead(data.erpDbcka);
            var details = MapErpDbckbToDbckb(data.erpDbckB);

            return UseTransaction(db =>
            {
                switch (data.erpDbcka.type)
                {
                    case "3":
                        return UpdateData(db, head, details) ? 1 : 0;
                    case "2":
                    case "4":
                    case "5":
                        return SaveOrUpdateData(db, head, details) ? 1 : 0;
                    default:
                        throw new NotImplementedException($"type没有 {data.erpDbcka.type} 这个类型");
                }
            }) > 0;
        }

        private MesInvItemDbsq MapErpToMesHead(ErpDBCKA dto)
        {
            var entity = new MesInvItemDbsq
            {
                BillNo = dto.billno,
                Djlx = dto.dj_lx,
                DbLx1 = dto.db_lx1,
                DbFx = dto.db_fx,
                DbLx = dto.db_lx,
                YwLx = dto.yw_lx,
                DjZt = dto.dj_zt,
                SqBm = dto.sq_bm,
                SqZz = dto.sq_zz,
                SqTime = dto.sq_time,
                DcHz = dto.dc_hz,
                Remark = dto.bz,
                Erpid = dto.erpid,
                CreateDate = DateTime.Now,
                CreateBy = "System",
                DbStatus="未调拨",
                Status=1
            };

            //    var single = base.GetSingle(it => it.Erpid == entity.Erpid);
            /* if (single != null && single.Id.HasValue)
                 entity.Id = single.Id.Value;*/
            var single = Db.Queryable<MesInvItemDbsq>()
               .Where(it => it.Erpid == entity.Erpid)
               .First();
            if (single != null)
                entity.Id = single.Id;

            return entity;
        }


        private List<MesInvItemDbsqItems> MapErpDbckbToDbckb(List<ErpDBCKB> list)
        {
            var result = new List<MesInvItemDbsqItems>();

            foreach (var dto in list)
            {
                var item = new MesInvItemDbsqItems
                {
                    ItemId = Convert.ToDecimal(dto.itemid),
                    ItemUnit = Convert.ToDecimal(dto.unit),
                    SqNum = decimal.TryParse(dto.quantity, out var qty) ? qty : 0,
                    DcOrg = dto.dc_org,
                    DcDepot = dto.dc_depot,
                    DrOrg = dto.dr_org,
                    DrDepot = dto.dr_depot,
                    DcHz = dto.dc_hz,
                    DrHz = dto.dr_hz,
                    Remark = dto.bz,
                    Erpid = dto.erpid,
                    Eid = dto.eid,
                   
                };

                var existing = Db.Queryable<MesInvItemDbsqItems>().Where(s => s.Erpid == item.Erpid).Single();
                if (existing != null) item.Id = existing.Id;

                result.Add(item);
            }

            return result;
        }

        private bool SaveOrUpdateData(SqlSugarScope db, MesInvItemDbsq head, List<MesInvItemDbsqItems> details)
        {
            if (head.Id != null)
                base.DeleteById(head.Id);

            db.Deleteable<MesInvItemDbsqItems>()
              .Where(d => d.Eid == head.Erpid)
              .ExecuteCommand();

            var insertedHead = db.Insertable(head)
                .IgnoreColumns(true)
                .ExecuteReturnIdentity();
            if (insertedHead <= 0)
                throw new Exception("主表插入失败，未返回ID");



            var success = db.Insertable(details)
                .PageSize(10)
                .IgnoreColumnsNull()
                .ExecuteCommand() > 0;

            
            if (insertedHead >= 0 && success) return true;
            throw new NotImplementedException("插入或更新失败");
        }

        private bool UpdateData(SqlSugarScope db, MesInvItemDbsq head, List<MesInvItemDbsqItems> details)
        {
            var ids = details.Select(d => d.Id).ToArray();
            var deletedHead = base.DeleteById(head.Id);
            var deletedDetails = db.Deleteable<MesInvItemDbsqItems>().In(ids).ExecuteCommand() > 0;

         
            if (deletedHead && deletedDetails) return true;
            throw new NotImplementedException("更新失败");
        }
    }
}