using MES.Service.DB; using MES.Service.Dto.webApi; using MES.Service.Modes; using SqlSugar; namespace MES.Service.service.BasicData; public class MesPositionManager : Repository { public bool Save(ErpPosition unit) { var entity = GetMesPosition(unit); // 将 ErpPosition 转换为 MesPosition return UseTransaction(db => { switch (unit.Type) { case "0": if (UpdatePositionStatus(db, entity.Id, "A")) // 启用岗位 return 1; break; case "1": if (UpdatePositionStatus(db, entity.Id, "B")) // 禁用岗位 return 1; break; case "2": if (InsertOrUpdatePosition(db, entity)) // 插入或更新岗位 return 1; break; case "3": if (UpdatePositionStatus(db, entity.Id, "B")) // 删除岗位 return 1; break; case "4": if (InsertOrUpdatePosition(db, entity)) // 插入或更新岗位 return 1; break; default: throw new ArgumentNullException($"type没有{unit.Type}这个类型的参数"); } throw new NotImplementedException("操作失败"); }) > 0; } // 更新岗位状态的方法 private bool UpdatePositionStatus(SqlSugarScope db, decimal positionId , string status) { var result = db.Updateable().SetColumns(s => s.Fforbidstatus == status).Where(s => s.Id == positionId).ExecuteCommand(); return true; } // 插入或更新岗位的方法 private bool InsertOrUpdatePosition(SqlSugarScope db, MesPosition entity) { var exists = db.Queryable().Any(e => e.Id == entity.Id); if (exists) { var update = db.Updateable(entity).ExecuteCommand(); return true; } else { var insert = db.Insertable(entity).ExecuteCommand(); if (insert > 0) { return true; } else { return false; } } } // 将 ErpPosition 对象转换为 MesPosition 对象的方法 private MesPosition GetMesPosition(ErpPosition position) { return new MesPosition { Id = Convert.ToDecimal(position.Id), PositionId = position.FNumber, PositionName = position.FName, PositionDescription = position.FDESCRIPTIONS, Department = position.FDept, Fforbidstatus = position.FForbidStatus, CreationDate = DateTime.Now, FCreateOrgId = position.FCreateOrgId, FUserOrgId = position.FUseOrgId }; } // SaveList 方法用于保存多个岗位记录,根据类型批量执行不同的操作 public bool SaveList(List positions) { var list = new List(); var groupBy = list.GroupBy(s => s.Type).ToDictionary(g => g.Key, g => g.ToList()); return UseTransaction(db => { foreach (var positionGroup in groupBy) switch (positionGroup.Key) { case "0": if (!UpdatePositionStatusBatch(db, positionGroup.Value,"A")) // 批量启用岗位 throw new NotImplementedException("启用失败"); break; case "1": if (!UpdatePositionStatusBatch(db, positionGroup.Value,"B")) // 批量禁用岗位 throw new NotImplementedException("禁用失败"); break; case "2": if (!InsertOrUpdatePositionBatch(db, positionGroup.Value)) // 批量插入或更新岗位 throw new NotImplementedException("插入失败"); break; case "3": if (!UpdatePositionStatusBatch(db, positionGroup.Value, "B")) // 批量禁用岗位 throw new NotImplementedException("删除失败"); break; case "4": if (!InsertOrUpdatePositionBatch(db,positionGroup.Value)) // 批量插入或更新岗位 throw new NotImplementedException("同步失败"); break; default: throw new ArgumentNullException($"type没有{positionGroup.Key}这个类型的参数"); } return 1; }) > 0; } // 批量更新岗位状态的方法 private bool UpdatePositionStatusBatch(SqlSugarScope db,List positionList, string status) { var ids = positionList.Select(it => it.Id).ToArray(); var result = db.Updateable().SetColumns(s => s.Fforbidstatus == status).Where(s => ids.Contains(s.Id)).ExecuteCommand(); return true; } // 批量插入或更新岗位的方法 private bool InsertOrUpdatePositionBatch(SqlSugarScope db,List positionList) { foreach (var entity in positionList) { if (!InsertOrUpdatePosition(db, entity)) { return false; } } return true; } }