分布式调拨新表

hao

2025-11-25 1f41e51bfa04d8c324dace8ae16d166fdfa90866

 StandardInterface/MES.Service/service/DbckaManager.cs

@@ -10,7 +10,7 @@

namespace MES.Service.service
{
    public class DbckaManager : Repository<MesInvItemDbsq>
    public class DbckaManager : Repository<MesInvItemDbsq2>
    {
        public bool SaveList(List<ERPDBCK> list)
        {
@@ -39,9 +39,9 @@
            }) > 0;
        }

        private MesInvItemDbsq MapErpToMesHead(ErpDBCKA dto)
        private MesInvItemDbsq2 MapErpToMesHead(ErpDBCKA dto)
        {
            var entity = new MesInvItemDbsq
            var entity = new MesInvItemDbsq2
            {
                BillNo = dto.billno,
                Djlx = dto.dj_lx,
@@ -59,13 +59,14 @@
                CreateDate = DateTime.Now,
                CreateBy = "System",
                DbStatus="未调拨",
                Status=1
                Status=1,
                Type2 = "分布式调拨单",
            };

            //    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>()
            var single = Db.Queryable<MesInvItemDbsq2>()
               .Where(it => it.Erpid == entity.Erpid)
               .First();
            if (single != null)
@@ -75,13 +76,13 @@
        }


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

            foreach (var dto in list)
            {
                var item = new MesInvItemDbsqItems
                var item = new MesInvItemDbsqItems2
                {
                    ItemId = Convert.ToDecimal(dto.itemid),
                    ItemUnit = Convert.ToDecimal(dto.unit),
@@ -98,7 +99,7 @@
                   
                };

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

                result.Add(item);
@@ -107,12 +108,12 @@
            return result;
        }

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

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

@@ -134,11 +135,11 @@
            throw new NotImplementedException("插入或更新失败");
        }

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

         
            if (deletedHead && deletedDetails) return true;