From 6ab9ca3015d7b99be3346c6e91e686a6681c01ea Mon Sep 17 00:00:00 2001 From: tongfei <244188119@qq.com> Date: Fri, 12 Apr 2024 18:11:51 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=8F=91=E9=80=81=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/WMS.Web.Domain/Services/Public/SendMessageService.cs | 9 ++++++--- src/WMS.Web.Repositories/InStockRepositories.cs | 3 ++- 2 files changed, 8 insertions(+), 4 deletions(-) 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(); } ///