| | |
| | | |
| | | public bool SaveList(List<ErpUnit> units) |
| | | { |
| | | var list = units.Select(GetMesUnit).ToList(); |
| | | var groupBy = list.GroupBy(s => s.Type) |
| | | .ToDictionary(g => g.Key, g => g.ToList()); |
| | | |
| | | return UseTransaction(db => |
| | | if (units == null || !units.Any()) |
| | | { |
| | | foreach (var unitGroup in groupBy) |
| | | switch (unitGroup.Key) |
| | | { |
| | | case "0": |
| | | if (!UpdateUnitStatusBatch(db, unitGroup.Value, "A")) |
| | | throw new NotImplementedException("启用失败"); |
| | | break; |
| | | case "1": |
| | | if (!UpdateUnitStatusBatch(db, unitGroup.Value, "B")) |
| | | throw new NotImplementedException("禁用失败"); |
| | | break; |
| | | case "3": |
| | | if (!DeleteUnitBatch(db, unitGroup.Value)) |
| | | throw new NotImplementedException("删除失败"); |
| | | break; |
| | | case "2": |
| | | case "4": |
| | | if (!InsertOrUpdateBatch(db, unitGroup.Value)) |
| | | throw new NotImplementedException("同步失败"); |
| | | break; |
| | | default: |
| | | throw new ArgumentNullException( |
| | | $"type没有{unitGroup.Key}这个类型的参数"); |
| | | } |
| | | Console.WriteLine("警告: 传入的列表为空"); |
| | | return false; |
| | | } |
| | | |
| | | return 1; |
| | | }) > 0; |
| | | // 逐条处理,全部成功才返回true(事务内批量处理更优,此处保持原有逻辑) |
| | | var result = units.Select(Save).ToList(); |
| | | return result.All(b => b); |
| | | } |
| | | |
| | | private bool UpdateUnitStatus(SqlSugarScope db, decimal unitId, |
| | |
| | | |
| | | private MesUnit GetMesUnit(ErpUnit unit) |
| | | { |
| | | return new MesUnit |
| | | var fForbidStatus = unit.FForbidStatus; |
| | | if (unit.FForbidStatus == "0") |
| | | { |
| | | Id = Convert.ToDecimal(unit.Id), |
| | | fForbidStatus = "A"; |
| | | } |
| | | else if (unit.FForbidStatus == "1") |
| | | { |
| | | fForbidStatus = "B"; |
| | | } |
| | | |
| | | var entity = new MesUnit |
| | | { |
| | | // Id = string.IsNullOrEmpty(unit.Id) |
| | | // ? DateTimeOffset.UtcNow.ToUnixTimeSeconds() |
| | | // : Convert.ToDecimal(unit.Id), |
| | | Fnumber = unit.FNumber, |
| | | Fname = unit.FName, |
| | | Funitgroupid = unit.FUnitGroupId, |
| | | Fconvertdenominator = Convert.ToDouble(unit.FConvertDenominator), |
| | | Fconvertdenominator = Convert.ToDecimal(unit.FConvertDenominator), |
| | | Fcurrentunitid = unit.FCurrentUnitId, |
| | | Fconvertnumerator = unit.FConvertNumerator, |
| | | Fconvertnumerator = Convert.ToDecimal(unit.FConvertNumerator), |
| | | Fbaseunit = unit.FBaseUnit, |
| | | Froundtype = unit.FRoundType, |
| | | Fprecision = unit.FPrecision, |
| | | Fdescription = unit.FDescription, |
| | | Fforbidstatus = unit.FForbidStatus, |
| | | Fforbidstatus = fForbidStatus, |
| | | CreateDate = DateTime.Now, |
| | | LastupdateDate = DateTime.Now, |
| | | Company = "1000", |
| | | Factory = "1000", |
| | | Type = unit.Type, |
| | | FDocumentStatus = unit.FDocumentStatus |
| | | Type = unit.Type |
| | | }; |
| | | |
| | | var mesUnit = Db.Queryable<MesUnit>() |
| | | .Where(s => s.Fnumber == entity.Fnumber) |
| | | .First(); |
| | | |
| | | if (mesUnit != null) |
| | | { |
| | | entity.Id = mesUnit.Id; |
| | | } |
| | | |
| | | return entity; |
| | | } |
| | | |
| | | private bool UpdateUnitStatusBatch(SqlSugarScope db, List<MesUnit> unitList, |