| | |
| | | |
| | | public bool SaveList(List<ErpSupplier> suppliers) |
| | | { |
| | | var list = suppliers.Select(GetMesSupplier).ToList(); |
| | | var groupBy = list.GroupBy(s => s.Type) |
| | | .ToDictionary(g => g.Key, g => g.ToList()); |
| | | |
| | | return UseTransaction(db => |
| | | if (suppliers == null || !suppliers.Any()) |
| | | { |
| | | foreach (var supplierGroup in groupBy) |
| | | switch (supplierGroup.Key) |
| | | { |
| | | case "0": |
| | | if (!UpdateSupplierStatusBatch(db, supplierGroup.Value, |
| | | "A")) |
| | | throw new NotImplementedException("启用失败"); |
| | | break; |
| | | case "1": |
| | | if (!UpdateSupplierStatusBatch(db, supplierGroup.Value, |
| | | "B")) |
| | | throw new NotImplementedException("禁用失败"); |
| | | break; |
| | | case "3": |
| | | if (!DeleteSupplierBatch(db, supplierGroup.Value)) |
| | | throw new NotImplementedException("删除失败"); |
| | | break; |
| | | case "2": |
| | | case "4": |
| | | if (!InsertOrUpdateBatch(db, supplierGroup.Value)) |
| | | throw new NotImplementedException("同步失败"); |
| | | break; |
| | | default: |
| | | throw new ArgumentNullException( |
| | | $"type没有{supplierGroup.Key}这个类型的参数"); |
| | | } |
| | | Console.WriteLine("警告: 传入的列表为空"); |
| | | return false; |
| | | } |
| | | |
| | | return 1; |
| | | }) > 0; |
| | | // 逐条处理,全部成功才返回true(事务内批量处理更优,此处保持原有逻辑) |
| | | var result = suppliers.Select(Save).ToList(); |
| | | return result.All(b => b); |
| | | } |
| | | |
| | | private bool UpdateSupplierStatus(SqlSugarScope db, decimal supplierId, |
| | |
| | | |
| | | private MesSupplier GetMesSupplier(ErpSupplier supplier) |
| | | { |
| | | return new MesSupplier |
| | | var entity = new MesSupplier |
| | | { |
| | | Id = Convert.ToDecimal(supplier.Id), |
| | | // Id = string.IsNullOrEmpty(supplier.Id) |
| | | // ? DateTimeOffset.UtcNow.ToUnixTimeSeconds() |
| | | // : Convert.ToDecimal(supplier.Id), |
| | | Type = supplier.Type, |
| | | SuppNo = supplier.FNumber, |
| | | SuppSname = supplier.FShortName, |
| | |
| | | Lxr = supplier.FTContact, |
| | | Telf1 = supplier.Fmobilephone, |
| | | Fstaffid = supplier.FStaffId, |
| | | FDocumentStatus = supplier.FDocumentStatus, |
| | | Fforbidstatus = supplier.FForbidStatus, |
| | | FSubsidiary = supplier.FUseOrgId, |
| | | Fumbrella = supplier.FCreateOrgId, |
| | | FSubsidiary = string.IsNullOrEmpty(supplier.FUseOrgId) |
| | | ? "1" |
| | | : supplier.FUseOrgId, |
| | | Fumbrella = string.IsNullOrEmpty(supplier.FCreateOrgId) |
| | | ? "1" |
| | | : supplier.FCreateOrgId, |
| | | Remark = supplier.Remark, |
| | | CreateDate = DateTime.Now, |
| | | LastupdateDate = DateTime.Now, |
| | | Company = "1000", |
| | | Factory = "1000", |
| | | |
| | | }; |
| | | |
| | | var mesSupplier = Db.Queryable<MesSupplier>() |
| | | .Where(s => s.SuppNo == entity.SuppNo) |
| | | .First(); |
| | | |
| | | if (mesSupplier != null) |
| | | { |
| | | entity.Id = mesSupplier.Id; |
| | | } |
| | | |
| | | return entity; |
| | | } |
| | | |
| | | private bool UpdateSupplierStatusBatch(SqlSugarScope db, |