| | |
| | | // 将 ErpDepartment 对象转换为 SysDepartment 对象的方法 |
| | | private SysDepartment GetSysDepartment(ErpDepartment department) |
| | | { |
| | | var unixTimeSeconds = string.IsNullOrEmpty(department.Id) |
| | | ? DateTimeOffset.UtcNow.ToUnixTimeSeconds() |
| | | : Convert.ToDecimal(department.Id); |
| | | // var unixTimeSeconds = string.IsNullOrEmpty(department.Id) |
| | | // ? DateTimeOffset.UtcNow.ToUnixTimeSeconds() |
| | | // : Convert.ToDecimal(department.Id); |
| | | |
| | | var fForbidStatus = department.FForbidStatus; |
| | | if (department.FForbidStatus == "0") |
| | |
| | | { |
| | | Departmentcode = department.FNumber, |
| | | Departmentname = department.FName, |
| | | Departmentid = unixTimeSeconds, |
| | | Id = unixTimeSeconds, |
| | | // Departmentid = unixTimeSeconds, |
| | | // Id = unixTimeSeconds, |
| | | Depextr1 = department.FDeptProperty, |
| | | Depextr2 = department.FGroup, |
| | | Depextr3 = department.FWIPStockID, |
| | |
| | | // SaveList 方法用于保存多个部门记录,根据类型批量执行不同的操作 |
| | | public bool SaveList(List<ErpDepartment> departments) |
| | | { |
| | | var list = new List<SysDepartment>(); |
| | | departments.ForEach(s => |
| | | if (departments == null || !departments.Any()) |
| | | { |
| | | var entity = |
| | | GetSysDepartment(s); // 将 ErpDepartment 转换为 SysDepartment |
| | | entity.Type = s.Type; |
| | | list.Add(entity); |
| | | }); |
| | | Console.WriteLine("警告: 传入的物料列表为空"); |
| | | return false; |
| | | } |
| | | |
| | | var groupBy = list.GroupBy(s => s.Type) |
| | | .ToDictionary(g => g.Key, g => g.ToList()); |
| | | return UseTransaction(db => |
| | | { |
| | | foreach (var departmentGroup in groupBy) |
| | | switch (departmentGroup.Key) |
| | | { |
| | | case "0": |
| | | if (!UpdateDepartmentStatusBatch(db, |
| | | departmentGroup.Value, "A")) // 批量启用部门 |
| | | throw new NotImplementedException("启用失败"); |
| | | break; |
| | | case "1": |
| | | if (!UpdateDepartmentStatusBatch(db, |
| | | departmentGroup.Value, "B")) // 批量禁用部门 |
| | | throw new NotImplementedException("禁用失败"); |
| | | break; |
| | | case "3": |
| | | if (!DeleteDepartmentBatch(db, |
| | | departmentGroup.Value)) // 批量删除部门 |
| | | throw new NotImplementedException("删除失败"); |
| | | break; |
| | | case "2": |
| | | case "4": |
| | | if (!InsertOrUpdateDepartmentBatch(db, |
| | | departmentGroup.Value)) // 批量插入或更新部门 |
| | | throw new NotImplementedException("同步失败"); |
| | | break; |
| | | default: |
| | | throw new ArgumentNullException( |
| | | $"type没有{departmentGroup.Key}这个类型的参数"); |
| | | } |
| | | |
| | | return 1; |
| | | }) > 0; |
| | | // 逐条处理,全部成功才返回true(事务内批量处理更优,此处保持原有逻辑) |
| | | var result = departments.Select(Save).ToList(); |
| | | return result.All(b => b); |
| | | } |
| | | |
| | | // 批量更新部门状态的方法 |