using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using MES.Service.DB;
using MES.Service.Dto.webApi;
using MES.Service.Modes;

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

        public bool Save(ERPZZCXD data)
        {
            var head = MapErpToMesHead(data.Main);
            var children = MapErpChildren(data.Children, data.Main.erpid);

            return UseTransaction(db =>
            {
                switch (data.Main.type)
                {
                    case "3": // 删除 / 禁用
                        return UpdateData(db, head, children) ? 1 : 0;

                    case "2":
                    case "4":
                    case "5": // 新增或更新
                        return SaveOrUpdateData(db, head, children) ? 1 : 0;

                    default:
                        throw new NotImplementedException($"type 没有 {data.Main.type} 这个类型");
                }
            }) > 0;
        }

        private ZZCX MapErpToMesHead(ERPZZCXMain dto)
        {
            var entity = new ZZCX
            {
                BillNo = dto.bill_no,   // 单据编码
                Erpid = string.IsNullOrEmpty(dto.erpid) ? (decimal?)null : Convert.ToDecimal(dto.erpid),
                // ERP 主表 ID
                DjLx = dto.dj_lx,
                KcZz = dto.kc_zz,
                SwLx = dto.sw_lx,
                // Time = string.IsNullOrEmpty(dto.time) ? (DateTime?)null : DateTime.Parse(dto.time),
                Time = dto.time,
                Bm = dto.bm,
                Cgy = dto.cgy,
                Kcz = dto.kcz,
                DjZt = dto.dj_zt,
                Memo = dto.memo,
                Cphzlx = dto.cphzlx,
                Cphz = dto.cphz,
                Zjhzlx = dto.zjhzlx,
                Zjhz = dto.zjhz,
            };

            var single = Db.Queryable<ZZCX>()
                           .Where(it => it.Erpid == entity.Erpid)
                           .First();
            if (single != null)
                entity.Id = single.Id;

            return entity;
        }

        private List<ZZCXA> MapErpChildren(List<ERPZZCXA> list, string mainErpId)
        {
            var result = new List<ZZCXA>();

            foreach (var dto in list)
            {
                var item = new ZZCXA
                {
                       /*   BillNo = dto.bill_no,
                       DjLx = dto.dj_lx,
                       KcZz = dto.kc_zz,
                       SwLx = dto.sw_lx,
                      // Time = string.IsNullOrEmpty(dto.time) ? (DateTime?)null : DateTime.Parse(dto.time),
                       Time = dto.time,
                       Bm = dto.bm,
                       Cgy = dto.cgy,
                       Kcz = dto.kcz,
                       DjZt = dto.dj_zt,
                       Memo = dto.memo,
                       Cphzlx = dto.cphzlx,
                       Cphz = dto.cphz,
                       Zjhzlx = dto.zjhzlx,
                       Zjhz = dto.zjhz,*/ 
                    Erpid = string.IsNullOrEmpty(dto.erpid) ? (decimal?)null : Convert.ToDecimal(dto.erpid),
                    YdId = string.IsNullOrEmpty(dto.yd_id) ? (decimal?)null : Convert.ToDecimal(dto.yd_id),
                    ItemId = string.IsNullOrEmpty(dto.item_id) ? (decimal?)null : Convert.ToDecimal(dto.item_id),
                    Qty = string.IsNullOrEmpty(dto.qty) ? (decimal?)null : Convert.ToDecimal(dto.qty),
                    Unit = dto.unit,
                    DepotId = string.IsNullOrEmpty(dto.depot_id) ? (decimal?)null : Convert.ToDecimal(dto.depot_id)

                };

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

                result.Add(item);

                // 孙表处理
                if (dto.SubItems != null && dto.SubItems.Count > 0)
                {
                    foreach (var subDto in dto.SubItems)
                    {
                        var subEntity = new ZZCXB
                        {
                            Eid = string.IsNullOrEmpty(subDto.eid) ? (decimal?)null : Convert.ToDecimal(subDto.eid),
                            Erpid = string.IsNullOrEmpty(subDto.erpid) ? (decimal?)null : Convert.ToDecimal(subDto.erpid),
                            YdId = string.IsNullOrEmpty(subDto.yd_id) ? (decimal?)null : Convert.ToDecimal(subDto.yd_id),
                            ItemId = string.IsNullOrEmpty(subDto.item_id) ? (decimal?)null : Convert.ToDecimal(subDto.item_id),
                            Qty = string.IsNullOrEmpty(subDto.qty) ? (decimal?)null : Convert.ToDecimal(subDto.qty),
                            Unit = subDto.unit,
                            DepotId = string.IsNullOrEmpty(subDto.depot_id) ? (decimal?)null : Convert.ToDecimal(subDto.depot_id),
                            LotNo = subDto.lot_no,
                            Memo = subDto.memo
                        };

                        var existingSub = Db.Queryable<ZZCXB>().Where(s => s.Eid == subEntity.Eid).Single();
                        if (existingSub != null) subEntity.Id = existingSub.Id;

                        item.SubItems ??= new List<ZZCXB>();
                        item.SubItems.Add(subEntity);
                    }
                }
            }

            return result;
        }

        private bool SaveOrUpdateData(SqlSugarScope db, ZZCX head, List<ZZCXA> children)
        {
            // 1. 校验是否存在领料记录（MES_INV_ITEM_OUTS）
            var hasMaterialOut = db.Queryable<MesInvItemOuts>()
                                   .Any(x => x.WorkNo == head.BillNo);

            if (hasMaterialOut)
            {
                throw new Exception($"MES已有领料记录，单号：{head.BillNo}，不能更新！");
            }

            if (head.Id != null)
                base.DeleteById(head.Id);

            db.Deleteable<ZZCXA>().Where(d => d.YdId == head.Erpid).ExecuteCommand();
            db.Deleteable<ZZCXB>().Where(d => d.Erpid == head.Erpid).ExecuteCommand();

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

            foreach (var child in children)
            {
                child.Pid = insertedHead;
                var childId = db.Insertable(child).IgnoreColumns(true).ExecuteReturnIdentity();

                if (child.SubItems != null && child.SubItems.Count > 0)
                {
                    foreach (var sub in child.SubItems)
                    {
                        sub.Pid = childId;
                        db.Insertable(sub).IgnoreColumns(true).ExecuteCommand();
                    }
                }
            }

            return true;
        }

        /* private bool UpdateData(SqlSugarScope db, ZZCX head, List<ZZCXA> children)
         {
             // 删除主表 & 子孙表
             var deletedHead = base.DeleteById(head.Id);
             var deletedChildren = db.Deleteable<ZZCXA>().Where(d => d.YdId == head.Erpid).ExecuteCommand();
             var deletedGrand = db.Deleteable<ZZCXB>().Where(d => d.Erpid == head.Erpid).ExecuteCommand();

             if (deletedHead && deletedChildren >= 0 && deletedGrand >= 0) return true;
             throw new NotImplementedException("删除失败");
         }*/

        private bool UpdateData(SqlSugarScope db, ZZCX head, List<ZZCXA> children)
        {

            // 1. 校验是否存在领料记录（MES_INV_ITEM_OUTS）
            var hasMaterialOut = db.Queryable<MesInvItemOuts>()
                                   .Any(x => x.WorkNo == head.BillNo);

            if (hasMaterialOut)
            {
                throw new Exception($"MES已有领料记录，单号：{head.BillNo}，不能删除！");
            }

            // 删除主表
            var deletedHead = db.Deleteable<ZZCX>()
                                .Where(d => d.Erpid == head.Erpid)
                                .ExecuteCommand();

            // 删除子表
            var deletedChildren = db.Deleteable<ZZCXA>()
                                    .Where(d => d.YdId == head.Erpid)
                                    .ExecuteCommand();

            // 删除孙表
            var deletedGrand = db.Deleteable<ZZCXB>()
                                 .Where(d => d.Erpid == head.Erpid)
                                 .ExecuteCommand();

            // 如果主表没删到记录，也认为允许（可能之前就不存在）
            if (deletedHead >= 0 && deletedChildren >= 0 && deletedGrand >= 0)
                return true;

            throw new NotImplementedException("删除失败");
        }


    }
}