|
|
@ -92,13 +92,7 @@ namespace Win.Sfs.SettleAccount.Entities.Prices |
|
|
|
where itm1.Price != itm2.Price |
|
|
|
select new PriceList(itm2.Id, itm2.BeginDate, itm2.EndDate, itm1.Price, itm2.MaterialCode, itm2.Type, itm2.ParentId, itm2.Version, itm1.CustomerCode); |
|
|
|
|
|
|
|
if (update.Count() > 0) |
|
|
|
{ |
|
|
|
|
|
|
|
await _repository.GetDbContext().BulkUpdateAsync(update.ToList()); |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
var add = from itm1 in entities |
|
|
|
join itm2 in pricelist |
|
|
|
on new { itm1.Type, itm1.MaterialCode, itm1.CustomerCode } |
|
|
@ -107,14 +101,22 @@ namespace Win.Sfs.SettleAccount.Entities.Prices |
|
|
|
from itm3 in temp.DefaultIfEmpty() |
|
|
|
where itm3 == null |
|
|
|
select itm1; |
|
|
|
await _repository.GetDbContext().BulkInsertAsync<PriceList>(add.ToList()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (update!=null&&update.Count() > 0) |
|
|
|
{ |
|
|
|
|
|
|
|
await _repository.GetDbContext().BulkUpdateAsync(update.ToList()); |
|
|
|
} |
|
|
|
if(add!=null && add.Count()>0) |
|
|
|
{ |
|
|
|
|
|
|
|
await _repository.GetDbContext().BulkInsertAsync<PriceList>(add.ToList()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
var _first = _versionRepository.FirstOrDefault(p => p.Version == version); |
|
|
|
if (_first == null) |
|
|
|