| | |
| | | { |
| | | var entity = GetMesStaff(unit); // å° ErpStaff 转æ¢ä¸º MesStaff |
| | | var sysUser = GetUser(unit); // è·å SysUser å®ä¾ |
| | | var mesStaffPositionLink = |
| | | GetMesStaffPositionLink(unit); // è·å MesStaffPositionLink å®ä¾ |
| | | |
| | | return UseTransaction(db => |
| | | { |
| | | switch (unit.Type) |
| | | { |
| | | case "0": |
| | | if (UpdateStaffStatus(db, entity.Id, "A")) // å¯ç¨åå·¥ |
| | | return 1; |
| | | break; |
| | | case "1": |
| | | if (UpdateStaffStatus(db, entity.Id, "B")) // ç¦ç¨åå·¥ |
| | | return 1; |
| | | break; |
| | | case "2": |
| | | case "4": |
| | | if (InsertOrUpdateStaff(db, sysUser, entity, |
| | | mesStaffPositionLink)) // æå
¥ææ´æ°åå·¥ |
| | | if (InsertOrUpdateStaff(db, sysUser, entity)) // æå
¥ææ´æ°åå·¥ |
| | | return 1; |
| | | break; |
| | | case "3": |
| | |
| | | throw new NotImplementedException(status == "A" ? "å¯ç¨å¤±è´¥" : "ç¦ç¨å¤±è´¥"); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// "æå
¥ææ´æ°åå·¥çæ¹æ³"è°æ´ï¼ä¿®æ¹ä¸ºå
å é¤åæå
¥ï¼åæ¶ç¨idåPositionCodeä½ä¸ºå¤æä¾æ® |
| | | /// </summary> |
| | | /// <remarks> |
| | | /// ä¿®æ¹äººï¼æ± åéª |
| | | /// ä¿®æ¹æ¥æï¼2024-12-30 |
| | | /// ä¿®æ¹è¯´æï¼` |
| | | /// </remarks> |
| | | |
| | | //// - å代ç ï¼ |
| | | // æå
¥ææ´æ°åå·¥çæ¹æ³ |
| | | //private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, |
| | | // MesStaff entity) |
| | | //{ |
| | | // var exists = db.Queryable<SysUser>().Any(u => u.Sid == sysUser.Sid); |
| | | // if (exists) |
| | | // { |
| | | // var updateUser = db.Updateable<SysUser>() |
| | | // .SetColumns(s => s.Fcode == sysUser.Fcode) |
| | | // .SetColumns(s => s.Fname == sysUser.Fname) |
| | | // .Where(s => s.Sid == sysUser.Sid) |
| | | // .ExecuteCommand(); |
| | | // if (updateUser > 0) |
| | | // { |
| | | // var updateStaff = db.Updateable(entity).ExecuteCommand(); |
| | | // if (updateStaff > 0) |
| | | // return true; |
| | | // } |
| | | // } |
| | | // else |
| | | // { |
| | | // var insertUser = db.Insertable(sysUser).ExecuteCommand(); |
| | | // if (insertUser > 0) |
| | | // { |
| | | // var insertStaff = db.Insertable(entity).ExecuteCommand(); |
| | | // if (insertStaff > 0) |
| | | // return true; |
| | | // } |
| | | // } |
| | | |
| | | // return false; |
| | | //} |
| | | |
| | | // æå
¥ææ´æ°åå·¥çæ¹æ³ |
| | | |
| | | /// æ°ä»£ç |
| | | // æå
¥ææ´æ°åå·¥çæ¹æ³ |
| | | /// <summary> |
| | | /// æ¥å£åæ®µè°æ´ï¼ä¿®æ¹åæ°ï¼æ°å¢List<MesStaffPositionLink>çåæ° |
| | |
| | | /// ä¿®æ¹è¯´æï¼ä¸ºäºåºä¸ºä¸ä¸ªåå·¥å¤å²ä½çæ
åµ |
| | | /// </remarks> |
| | | private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, |
| | | MesStaff entity, List<MesStaffPositionLink> mesStaffPositionLink) |
| | | MesStaff entity) |
| | | { |
| | | var exists = db.Queryable<SysUser>().Any(u => u.Sid == sysUser.Sid); |
| | | if (!exists) |
| | | { |
| | | var insertUser = db.Insertable(sysUser).ExecuteCommand(); |
| | | db.Insertable(sysUser).ExecuteCommand(); |
| | | } |
| | | |
| | | |
| | | |
| | | db.Deleteable<MesStaff>() |
| | | .Where(s => s.Id == entity.Id) |
| | | .ExecuteCommand(); |
| | |
| | | var insertStaff = |
| | | db.Insertable(entity).IgnoreColumns(true).ExecuteCommand(); |
| | | |
| | | |
| | | var insertPosition = 1; |
| | | if (mesStaffPositionLink != null && mesStaffPositionLink.Count > 0) |
| | | { |
| | | //å
å é¤ï¼åæ°å¢ |
| | | db.Deleteable<MesStaffPositionLink>() |
| | | .Where(s => |
| | | mesStaffPositionLink.Any(m => m.StaffId == s.StaffId)) |
| | | .ExecuteCommand(); |
| | | |
| | | |
| | | //æ¹éæå
¥æ¶ï¼å¿½ç¥ç©ºå段 |
| | | insertPosition = db.Insertable(mesStaffPositionLink).PageSize(1) |
| | | .IgnoreColumnsNull().ExecuteCommand(); |
| | | } |
| | | |
| | | |
| | | return insertStaff > 0 && insertPosition > 0; |
| | | return insertStaff > 0; |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// ä¿®æ¹æ¥æï¼2024-12-30 |
| | | /// ä¿®æ¹è¯´æï¼` |
| | | /// </remarks> |
| | | |
| | | //// å代ç |
| | | // å é¤åå·¥çæ¹æ³ |
| | | //private bool DeleteStaff(SqlSugarScope db, SysUser sysUser, decimal staffId) |
| | | //{ |
| | | // var deleteUser = db.Deleteable<SysUser>() |
| | | // .Where(s => s.Sid == sysUser.Sid).ExecuteCommand(); |
| | | // if (deleteUser > 0) |
| | | // { |
| | | // var deleteStaff = |
| | | // db.Deleteable<MesStaff>().In(staffId).ExecuteCommand(); |
| | | // if (deleteStaff > 0) |
| | | // return true; |
| | | // } |
| | | |
| | | // throw new NotImplementedException("åå®¡æ ¸å¤±è´¥"); |
| | | //} |
| | | |
| | | /// æ°ä»£ç |
| | | // å é¤åå·¥çæ¹æ³ |
| | | private bool DeleteStaff(SqlSugarScope db, SysUser sysUser, MesStaff entity) |
| | | { |
| | | var deleteUser = db.Deleteable<SysUser>() |
| | |
| | | s.Id == entity.Id && |
| | | s.PositionCode == entity.PositionCode) |
| | | .ExecuteCommand(); |
| | | |
| | | //å é¤å¯¹åºåå·¥å²ä½ä¿¡æ¯å
³è表 æ± åéª 2025-01-02 |
| | | var insertPosition = db.Deleteable<MesStaffPositionLink>() |
| | | .Where(s => s.StaffId == entity.Id) |
| | | .ExecuteCommand(); |
| | | |
| | | if (deleteStaff > 0) |
| | | return true; |
| | |
| | | Id = Convert.ToDecimal(staff.Id), |
| | | StaffNo = staff.FStaffNumber, |
| | | StaffName = staff.FName, |
| | | //å é¤ 2025-01-04 æ± åéª |
| | | //DepartmentNo = staff.FPostDept, |
| | | |
| | | /// <summary> |
| | | /// æ¥å£åæ®µè°æ´ï¼å°FPoståæ®µéå½å为FPostIdã |
| | | /// </summary> |
| | | /// <remarks> |
| | | /// ä¿®æ¹äººï¼æ± åéª |
| | | /// ä¿®æ¹æ¥æï¼2024-12-25 |
| | | /// ä¿®æ¹è¯´æï¼ |
| | | /// - å代ç ï¼`PositionCode = staff.FPost, |
| | | /// - ä¿®æ¹åï¼`PositionCode = staff.FPostId, |
| | | /// - äºæ¬¡ä¿®æ¹ï¼å é¤ |
| | | /// </remarks> |
| | | //PositionCode = staff.FPostId, |
| | | PhoneNumber = staff.FMobile, |
| | | CreateOrg = Convert.ToDecimal(staff.FCreateOrgId), |
| | | UseOrg = Convert.ToDecimal(staff.FUseOrgId), |
| | | CreateDate = DateTime.Now, |
| | | Remark = staff.FDescription, |
| | | FDOCUMENTSTATUS = staff.FDocumentStatus, |
| | | FforbidStatus = staff.FForbidStatus |
| | | PositionCode = staff.FPostId, |
| | | KeyPosts = staff.KeyPosts, |
| | | StartDate = staff.FStaffStartDate != null |
| | | ? DateTime.ParseExact(staff.FStaffStartDate, |
| | | "yyyy-MM-dd HH:mm:ss", null) |
| | | : null, |
| | | SeparationTime = staff.SeparationTime != null |
| | | ? DateTime.ParseExact(staff.SeparationTime, |
| | | "yyyy-MM-dd HH:mm:ss", null) |
| | | : null, |
| | | FforbidStatus = staff.FforbidStatus, |
| | | DepartmentName = staff.DepartmentName, |
| | | UseOrg = staff.FUseOrgId, |
| | | Remark = staff.Remark |
| | | }; |
| | | |
| | | //å é¤ 2025-01-04 æ± åéª |
| | | //if (staff.FStaffStartDate != null) |
| | | // entity.StartDate = DateTime.ParseExact(staff.FStaffStartDate, |
| | | // "yyyy-MM-dd HH:mm:ss", null); |
| | | |
| | | return entity; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// æ¥å£åæ®µè°æ´ï¼æ ¹æ®jsonæ ¼å¼ï¼å¨MesStaffPositionLink<List>ä¸åå
¥æ°æ®ã |
| | | /// </summary> |
| | | /// <remarks> |
| | | /// ä¿®æ¹äººï¼æ± åéª |
| | | /// ä¿®æ¹æ¥æï¼2025-01-02 ââã 2025-01-05 äºæ¬¡ä¿®æ¹ |
| | | /// ä¿®æ¹è¯´æï¼ |
| | | /// - æ°å¢ä»£ç |
| | | /// </remarks> |
| | | private List<MesStaffPositionLink> GetMesStaffPositionLink(ErpStaff staff) |
| | | { |
| | | List<MesStaffPositionLink> staffDetails = new(); |
| | | |
| | | if (staff.ErpStaffDetails != null && staff.ErpStaffDetails.Count > 0) |
| | | staffDetails = staff.ErpStaffDetails.Select(staffDetail => |
| | | new MesStaffPositionLink |
| | | { |
| | | StaffId = Convert.ToDecimal(staff.Id), |
| | | PositionId = |
| | | string.IsNullOrEmpty(staffDetail.fPostId.ToString()) |
| | | ? null |
| | | : Convert.ToDecimal(staffDetail.fPostId), |
| | | FPostDeptId = |
| | | string.IsNullOrEmpty(staffDetail.fPostDeptid.ToString()) |
| | | ? null |
| | | : Convert.ToDecimal(staffDetail.fPostDeptid), |
| | | FStaffStartDate = |
| | | string.IsNullOrEmpty(staffDetail.fStaffStartDate |
| | | .ToString()) |
| | | ? null |
| | | : DateTime.ParseExact(staffDetail.fStaffStartDate, |
| | | "yyyy-MM-dd HH:mm:ss", null) |
| | | }).ToList(); |
| | | //postIds.AddRange(links); |
| | | |
| | | return staffDetails; |
| | | } |
| | | |
| | | // å° ErpStaff 对象转æ¢ä¸º SysUser å¯¹è±¡çæ¹æ³ |
| | | private SysUser GetUser(ErpStaff staff) |
| | | { |
| | | //è·åå½åç¨æ·ä½¿ç¨ç»ç»å¯¹åºçç»ç»åç§° |
| | | var db = SqlSugarHelper.GetInstance(); |
| | | var organize = db.Queryable<Organize>() |
| | | .Where(it => |
| | | it.Id == |
| | | Convert.ToDecimal(staff.FUseOrgId)) // ä½¿ç¨ Where æ¹æ³æ ¹æ®å个 ID æ¥è¯¢ |
| | | .Select(it => it.Fname) // éæ© Fname 屿§ |
| | | .Single(); // ä½¿ç¨ Single å 为æä»¬ææåªæä¸ä¸ªå¹é
项 |
| | | |
| | | //string organizeName = organize.f; |
| | | |
| | | return new SysUser |
| | | { |
| | | Sid = Convert.ToDecimal(staff.Id), |
| | | Fcode = staff.FStaffNumber, |
| | | Fname = staff.FName, |
| | | Fpassword = "8+()./,", // åå§å¯ç |
| | | Fsystem = organize, |
| | | Lever = 0, |
| | | Fcompany = "1000", |
| | | Ffactory = "1000", |
| | |
| | | // SaveList æ¹æ³ç¨äºä¿åå¤ä¸ªå工记å½ï¼æ ¹æ®ç±»åæ¹éæ§è¡ä¸åçæä½ |
| | | public bool SaveList(List<ErpStaff> departments) |
| | | { |
| | | var list = new List<MesStaff>(); |
| | | var userList = new List<SysUser>(); |
| | | var mesStaffPositionLinkList = new List<MesStaffPositionLink>(); |
| | | |
| | | departments.ForEach(s => |
| | | { |
| | | var entity = GetMesStaff(s); |
| | | entity.Type = s.Type; |
| | | list.Add(entity); |
| | | |
| | | var sysUser = GetUser(s); |
| | | sysUser.Type = s.Type; |
| | | userList.Add(sysUser); |
| | | |
| | | var mesStaffPositionLink = |
| | | GetMesStaffPositionLink(s); // è·å SysUser å®ä¾ |
| | | mesStaffPositionLinkList.AddRange(mesStaffPositionLink); |
| | | }); |
| | | |
| | | var groupBy = list.GroupBy(s => s.Type) |
| | | .ToDictionary(g => g.Key, g => g.ToList()); |
| | | return UseTransaction(db => |
| | | { |
| | | foreach (var staffGroup in groupBy) |
| | | switch (staffGroup.Key) |
| | | { |
| | | case "0": |
| | | if (!UpdateStaffStatusBatch(db, staffGroup.Value, |
| | | "A")) // æ¹éå¯ç¨åå·¥ |
| | | throw new NotImplementedException("å¯ç¨å¤±è´¥"); |
| | | break; |
| | | case "1": |
| | | if (!UpdateStaffStatusBatch(db, staffGroup.Value, |
| | | "B")) // æ¹éç¦ç¨åå·¥ |
| | | throw new NotImplementedException("ç¦ç¨å¤±è´¥"); |
| | | break; |
| | | case "3": |
| | | if (!DeleteStaffBatch(db, userList, |
| | | staffGroup.Value)) // æ¹éå é¤åå·¥ |
| | | throw new NotImplementedException("å é¤å¤±è´¥"); |
| | | break; |
| | | case "2": |
| | | case "4": |
| | | if (!InsertOrUpdateBatch(db, userList, |
| | | staffGroup.Value, |
| | | mesStaffPositionLinkList)) // æ¹éæå
¥ææ´æ°åå·¥ |
| | | throw new NotImplementedException("åæ¥å¤±è´¥"); |
| | | break; |
| | | default: |
| | | throw new ArgumentNullException( |
| | | $"type没æ{staffGroup.Key}è¿ä¸ªç±»åçåæ°"); |
| | | } |
| | | |
| | | return 1; |
| | | }) > 0; |
| | | } |
| | | |
| | | // æ¹éæ´æ°åå·¥ç¶æçæ¹æ³ |
| | | private bool UpdateStaffStatusBatch(SqlSugarScope db, |
| | | List<MesStaff> staffList, string status) |
| | | { |
| | | var ids = staffList.Select(it => it.Id).ToArray(); |
| | | var result = db.Updateable<MesStaff>() |
| | | .SetColumns(s => s.FforbidStatus == status) |
| | | .Where(s => ids.Contains(s.Id)).ExecuteCommand(); |
| | | |
| | | if (result > 0) |
| | | return true; |
| | | |
| | | throw new NotImplementedException(status == "A" ? "å¯ç¨å¤±è´¥" : "ç¦ç¨å¤±è´¥"); |
| | | } |
| | | |
| | | // æ¹éæå
¥åå·¥çæ¹æ³ |
| | | private bool InsertStaffBatch(SqlSugarScope db, List<SysUser> userList, |
| | | List<MesStaff> staffList) |
| | | { |
| | | var userInsert = userList.FindAll(s => s.Type == "INSERT"); |
| | | var executeCommand = db.Insertable(userInsert).ExecuteCommand(); |
| | | if (executeCommand > 0) |
| | | if (db.Insertable(staffList).ExecuteCommand() > 0) |
| | | return true; |
| | | |
| | | throw new ArgumentNullException("å®¡æ ¸å¤±è´¥"); |
| | | } |
| | | |
| | | // æ¹éå é¤åå·¥çæ¹æ³ |
| | | private bool DeleteStaffBatch(SqlSugarScope db, List<SysUser> userList, |
| | | List<MesStaff> staffList) |
| | | { |
| | | var sid = userList.FindAll(s => s.Type == "DELETE").Select(s => s.Sid) |
| | | .ToArray(); |
| | | var result = db.Deleteable<SysUser>() |
| | | .Where(s => sid.Contains(s.Sid)).ExecuteCommand(); |
| | | |
| | | if (result > 0) |
| | | { |
| | | var ids = staffList.Select(it => it.Id).ToArray(); |
| | | if (db.Deleteable<MesStaff>().In(ids).ExecuteCommand() > 0) |
| | | return true; |
| | | } |
| | | |
| | | throw new ArgumentNullException("åå®¡æ ¸å¤±è´¥"); |
| | | } |
| | | |
| | | // æ¹éæå
¥ææ´æ°åå·¥çæ¹æ³ |
| | | private bool InsertOrUpdateBatch(SqlSugarScope db, List<SysUser> userList, |
| | | List<MesStaff> staffList, |
| | | List<MesStaffPositionLink> mesStaffPositionLink) |
| | | { |
| | | foreach (var sysUser in userList) |
| | | { |
| | | var entity = staffList.First(s => s.Id == sysUser.Sid); |
| | | if (!InsertOrUpdateStaff(db, sysUser, entity, mesStaffPositionLink)) |
| | | return false; |
| | | } |
| | | |
| | | return true; |
| | | var result = departments.Select(Save).ToList(); |
| | | return result.All(b => b); |
| | | } |
| | | } |