using MES.Service.DB; using MES.Service.Dto.webApi; using MES.Service.Modes; using SqlSugar; namespace MES.Service.service; public class WomcaaManager : Repository { private readonly WomcabManager _womcabManager = new(); public bool SaveList(List rohIns) { var result = rohIns.Select(Save).ToList(); return result.All(b => b); } public bool Save(ErpWOM wom) { var womErpCaa = wom.ErpCaa; var mesWomcaa = MapErpCAAtoWomcaa(womErpCaa); var mesWomcabs = MapErpCABtoWomcab(wom.ErpCabs); return UseTransaction(db => { switch (womErpCaa.Type) { case "3": return UpdateData(db, mesWomcaa, mesWomcabs) ? 1 : 0; case "2": case "4": case "5": return SaveOrUpdateData(db, mesWomcaa, mesWomcabs) ? 1 : 0; default: throw new NotImplementedException( $"type类型为{womErpCaa.Type}的不存在"); } }) > 0; } private bool SaveOrUpdateData(SqlSugarScope db, Womcaa mesWomcaa, List mesWomcabs) { if (mesWomcaa.Id != null) base.DeleteById(mesWomcaa.Id); if (mesWomcabs.Count > 0) db.Deleteable() .Where(s => s.Eid == mesWomcaa.Erpid).ExecuteCommand(); var orUpdate = db.Insertable(mesWomcaa) .IgnoreColumns(true).ExecuteCommand() > 0; var baOrUpdate = db.Insertable(mesWomcabs).PageSize(1) .IgnoreColumnsNull() .ExecuteCommand() > 0; if (orUpdate && baOrUpdate) return true; throw new NotImplementedException("更新失败"); } private bool UpdateData(SqlSugarScope db, Womcaa mesWomcaa, List mesWomcabs) { var decimals = mesWomcabs.Select(s => s.Id).ToArray(); var update = base.DeleteById(mesWomcaa.Id); var insertOrUpdate = db .Deleteable().In(decimals) .ExecuteCommand() > 0; if (update && insertOrUpdate) return true; throw new NotImplementedException("更新失败"); } private Womcaa MapErpCAAtoWomcaa(ErpCAA dto) { var entity = new Womcaa { Erpid = Convert.ToInt32(dto.Id), Caa001 = dto.FBillNo, Caa021 = dto.FWorkShopID, RoutingId = dto.FRoutingId, WorkShopId = dto.FREMWorkShopId, DepotCode = dto.FStockId, CreateDate = dto.FDate, Caa004 = dto.FBillType, Caa023 = dto.FStatus, Caa006 = dto.FMaterialId, Caa009 = dto.FUnitId, Caa012 = !string.IsNullOrEmpty(dto.FQty) ? Convert.ToDecimal(dto.FQty) : null, WorkGroupId = dto.FWorkGroupId, PlanId = dto.FPlannerID, Caa010 = dto.FPlanStartDate, Caa011 = dto.FPlanFinishDate, Caa005 = dto.FConveyDate, StockInlimith = dto.FStockInLimitH, StockInlimitl = dto.FStockInLimitL, Mtono = dto.FMTONO, Lot = dto.FLot, Caa013 = dto.FBomId, CreateType = dto.FCreateType, Caa018 = !string.IsNullOrEmpty(dto.PLAN_ID) ? Convert.ToInt32(dto.PLAN_ID) : null, Caa019 = Convert.ToInt32(dto.PLAN_SEQ), Caa020 = dto.PLAN_NUM, SrcBillType = dto.FSrcBillType, SrcBillNo = dto.FSrcBillNo, SrcBillentryseq = dto.FSrcBillEntrySeq, SaleOrderNo = dto.FSaleOrderNo, SaleOrderEntryseq = dto.FSaleOrderEntrySeq, ForceCloserid = dto.FForceCloserId, CloseType = dto.FCloseType, SrcSplitBillno = dto.FSrcSplitBillNo, Caa016 = dto.FDescription, //BTBZ = dto.BTBZ, PrdOrg = dto.FPrdOrgId, TrustOrg = dto.FEnTrustOrgId //Typea = dto.TypeA }; var single = base.GetSingle(it => it.Erpid == entity.Erpid); if (single != null) entity.Id = single.Id; return entity; } private List MapErpCABtoWomcab(List dtoList) { var womcabList = new List(); foreach (var dto in dtoList) { var womcab = new Womcab { Erpid = Convert.ToDecimal(dto.ID), Cab001 = dto.FBillNo, Cab002 = dto.FSeq, Cab003 = dto.FMaterialID, Cab006 = Convert.ToDecimal(dto.FNeedQty), MustQty = Convert.ToDecimal(dto.FMustQty), Cab007 = Convert.ToDecimal(dto.FPickedQty), PositionNo = dto.FPositionNO, SupplyOrganization = dto.FChildSupplyOrgId, IssuingOrganization = dto.FSupplyOrg, OwnerId = dto.FOwnerID, Mtono = dto.FMTONO, Lot = dto.FLot, DepotCode = dto.FStockID, IssueType = dto.FIssueType, Cab009 = dto.FUnitID, SupplyType = dto.FSupplyType, Cab012 = Convert.ToDecimal(dto.FStdQty), FreplaceGroup = Convert.ToInt32(dto.FReplaceGroup), UseRate = Convert.ToDecimal(dto.FUseRate), MaterialType = dto.FMaterialType, Cab014 = Convert.ToInt32(dto.FIsKeyItem), Numerator = Convert.ToDecimal(dto.FNumerator), Denominator = Convert.ToDecimal(dto.FDenominator), Pid = Convert.ToDecimal(dto.FID), Eid = Convert.ToDecimal(dto.FID), Scrapqty = Convert.ToDecimal(dto.FFixScrapQty), Scraprate = Convert.ToDecimal(dto.FScrapRate), TypeB = dto.TypeB // WR_F_XIFG_Base_qtr = dto.F_XIFG_Base_qtr, // WR_F_XIFG_Base_83g = dto.F_XIFG_Base_83g }; var entity = Db.Queryable() .Where(s => s.Erpid == womcab.Erpid).Single(); if (entity != null) womcab.Id = entity.Id; womcabList.Add(womcab); } return womcabList; } }