diff --git a/src/WMS.Web.Domain/Services/Public/SendMessageService.cs b/src/WMS.Web.Domain/Services/Public/SendMessageService.cs index cd2cef71..6b762d3a 100644 --- a/src/WMS.Web.Domain/Services/Public/SendMessageService.cs +++ b/src/WMS.Web.Domain/Services/Public/SendMessageService.cs @@ -168,8 +168,7 @@ namespace WMS.Web.Domain.Services //要处理发送的明细 //var notSendDetails = await _inStockTaskRepositories.GetNotSendErpDetails(); var notSendDetails = await _inStockRepositories.GetNotSendDetails(); - - + _logger.LogInformation("发送消息:要处理发送的明细->:" + JsonConvert.SerializeObject(notSendDetails)); var sendDataList = new List(); if (customerList != null && customerList.Count != 0) @@ -288,7 +287,7 @@ namespace WMS.Web.Domain.Services } } - update_DetailsIds = updateList.Select(x => x.Id).ToList(); + update_DetailsIds = updateList.GroupBy(x=>x.Id).Select(x => x.Key).ToList(); //任务明细:修改的 //var tasksDetails = await _inStockTaskRepositories.GetDetailsList(update_taskDetailsIds); var inStockDetails = await _inStockRepositories.GetDetailsList(update_DetailsIds); @@ -301,6 +300,10 @@ namespace WMS.Web.Domain.Services { _logger.LogInformation("发送消息:失败-修改入库明细->:" + JsonConvert.SerializeObject(inStockDetails)); } + else + { + _logger.LogInformation("发送消息:成功-修改入库明细->:" + JsonConvert.SerializeObject(inStockDetails)); + } } } else diff --git a/src/WMS.Web.Repositories/InStockRepositories.cs b/src/WMS.Web.Repositories/InStockRepositories.cs index eb56191f..e1f8d3fe 100644 --- a/src/WMS.Web.Repositories/InStockRepositories.cs +++ b/src/WMS.Web.Repositories/InStockRepositories.cs @@ -430,7 +430,8 @@ namespace WMS.Web.Repositories /// public async Task> GetNotSendDetails() { - return await _context.InStockDetails.Where(x =>x.IsHasSend != null && x.IsHasSend == false && !string.IsNullOrEmpty(x.CustomerCode)).ToListAsync(); + var result= await _context.InStockDetails.Where(x =>x.IsHasSend != null && x.IsHasSend == false && !string.IsNullOrEmpty(x.CustomerCode)).ToListAsync(); + return result.Clone(); } ///