using MES.Service.DB; using MES.Service.Dto.webApi; using MES.Service.Modes; using MES.Service.util; using SqlSugar; namespace MES.Service.service.BasicData; public class MesItemTypeManager : Repository { //当前类已经继承了 Repository 增、删、查、改的方法 public bool Save(ErpItemType unit) { var entity = GetMesItemType(unit); return UseTransaction(db => { switch (unit.Type) { case "3": if (DeleteItemType(entity)) return 1; break; case "2": case "4": if (InsertItemType(db, entity)) return 1; break; default: throw new ArgumentNullException( $"type没有{unit.Type}这个类型的参数"); } throw new NotImplementedException("操作失败"); }) > 0; } private bool InsertItemType(SqlSugarScope db, List entity) { DeleteItemType(entity); var insert = db.Insertable(entity).PageSize(1).IgnoreColumnsNull() .ExecuteCommand(); return insert > 0; } private bool DeleteItemType(List supplierId) { // 提取所有需要的 MesId 组合 var ids = supplierId.Select(customer => customer.Id.ToString()) .ToList(); // 使用这些 MesId 去查询 MesLinkU9 表,找到对应的 U9Id var u9Ids = Db.Queryable() .Where(u => ids.Contains(u.MesId) && u.TableType == "MES_ITEM_TYPE") .Select(u => u.U9Id) .Distinct() // 应用 Distinct 去重 .ToList(); // 根据 U9Id 找到所有对应的 MesId,进行删除 // 注意:这里假设您确实想要删除这些记录。如果不确定,请先查询以验证结果。 var idsToDelete = Db.Queryable() .Where(u => u9Ids.Contains(u.U9Id) && u.TableType == "MES_ITEM_TYPE") .Select(u => u.MesId) .Distinct() // 应用 Distinct 去重 .ToList(); var deleteByIds = Db.Deleteable().In(idsToDelete) .ExecuteCommand(); // if (deleteByIds > 0) // return true; return true; //throw new NotImplementedException("删除失败"); } private List GetMesItemType(ErpItemType department) { List list = new(); foreach (var erpDetail in department.FUseOrgId) { var exists = Db.Queryable().Any(u => u.U9Id == department.Id && u.OrgId == erpDetail.FUseOrgId && u.TableType == "MES_ITEM_TYPE"); decimal mesId = 0; if (exists) { //获取mesid mesId = Convert.ToDecimal(Db.Queryable() .Where(u => u.U9Id == department.Id && u.OrgId == erpDetail.FUseOrgId && u.TableType == "MES_ITEM_TYPE") .Select(u => u.MesId) // 选择 MesId 字段 .First()); } else { mesId = GetSeqUtil.GetSeq("SEQ_ITEM_ID"); var entity = new MesLinkU9 { CreateDate = DateTime.Now, MesId = mesId.ToString(), U9Id = department.Id, OrgId = erpDetail.FUseOrgId, TableType = "MES_ITEM_TYPE" }; Db.Insertable(entity).ExecuteCommand(); } var mesItemType = new MesItemType { Id = mesId, Pgroup = department.FParentId, Tcode = department.FNumber, Tname = department.FName, Unit = department.Unit, ForbidStatus = department.FForbidStatus, IqcType = department.IqcType, UseOrgId = erpDetail.FUseOrgId, CreateDate = DateTime.Now, Company = "1000", Factory = "1000" }; list.Add(mesItemType); } return list; } public bool SaveList(List departments) { var result = departments.Select(Save).ToList(); return result.All(b => b); } }