|
|
@ -6,6 +6,7 @@ using System.Linq; |
|
|
|
using System.Text; |
|
|
|
using System.Threading.Tasks; |
|
|
|
using Volo.Abp; |
|
|
|
using Volo.Abp.DependencyInjection; |
|
|
|
using Volo.Abp.Domain.Repositories; |
|
|
|
using Volo.Abp.Domain.Services; |
|
|
|
using Volo.Abp.ObjectMapping; |
|
|
@ -14,6 +15,7 @@ using WY.NewJit.PrintTable; |
|
|
|
|
|
|
|
namespace WY.NewJit.MsgCheck |
|
|
|
{ |
|
|
|
[Dependency(Microsoft.Extensions.DependencyInjection.ServiceLifetime.Singleton, ReplaceServices =true)] |
|
|
|
public class BillNumberRecordDomainService : DomainService |
|
|
|
{ |
|
|
|
private readonly IRepository<BillNumberRecord, Guid> _billNumberRepository; |
|
|
@ -47,18 +49,18 @@ namespace WY.NewJit.MsgCheck |
|
|
|
ObjectResultDto ret = new ObjectResultDto(true, null); |
|
|
|
if (isupdate) |
|
|
|
{ |
|
|
|
await _billNumberRepository.UpdateManyAsync(_billNumberRecordCaches); |
|
|
|
//await _billNumberRepository.UpdateManyAsync(_billNumberRecordCaches);
|
|
|
|
foreach (var item in _billNumberRecordCaches) |
|
|
|
{ |
|
|
|
var re = await _billNumberRepository.GetListAsync(r=>r.Id==item.Id); |
|
|
|
if (re.Count == 0) |
|
|
|
{ |
|
|
|
await _billNumberRepository.InsertAsync(item); |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
await _billNumberRepository.UpdateAsync(item); |
|
|
|
} |
|
|
|
if (re.Count == 0) |
|
|
|
{ |
|
|
|
await _billNumberRepository.InsertAsync(item); |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
await _billNumberRepository.UpdateAsync(item); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|