diff --git a/src/WMS.Web.Api/Controllers/TakeStockController.cs b/src/WMS.Web.Api/Controllers/TakeStockController.cs index ed217328..5d590bea 100644 --- a/src/WMS.Web.Api/Controllers/TakeStockController.cs +++ b/src/WMS.Web.Api/Controllers/TakeStockController.cs @@ -1,7 +1,9 @@ using AutoMapper; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc; +using Microsoft.Extensions.Logging; using Microsoft.Extensions.Options; +using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; @@ -32,9 +34,11 @@ namespace WMS.Web.Api.Controllers private readonly ITakeStockService _takeStockService; private readonly QiniuOptions _option; private readonly IExportExcelService _exportExcelService; + private readonly ILogger _logger; public TakeStockController(IMapper mapper, ILoginService loginService, ITakeStockRepositories repositories, ITakeStockService takeStockService - , IOptions option, IExportExcelService exportExcelServic) + , IOptions option, IExportExcelService exportExcelServic, + ILogger logger) { _mapper = mapper; _loginService = loginService; @@ -42,6 +46,7 @@ namespace WMS.Web.Api.Controllers _takeStockService = takeStockService; _option = option?.Value; _exportExcelService = exportExcelServic; + _logger = logger; } /// /// 列表 @@ -109,7 +114,7 @@ namespace WMS.Web.Api.Controllers var loginInfo = _loginService.GetLoginInfo(this.HttpContext.Request.Headers["Authorization"]); if (loginInfo == null || loginInfo.UserInfo == null) return Result.ReFailure(ResultCodes.Token_Invalid_Error); - + _logger.LogInformation($"盘点重传:{JsonConvert.SerializeObject(dto)}"); return await _takeStockService.Sync(dto); } } diff --git a/src/WMS.Web.Domain/Services/TakeStockService.cs b/src/WMS.Web.Domain/Services/TakeStockService.cs index f88fdbfa..bcde7dfc 100644 --- a/src/WMS.Web.Domain/Services/TakeStockService.cs +++ b/src/WMS.Web.Domain/Services/TakeStockService.cs @@ -150,13 +150,17 @@ namespace WMS.Web.Domain.Services /// public Task Sync(OperateRequest dto) { + _logger.LogInformation($"盘点同步1:{JsonConvert.SerializeObject(dto)}"); Task.Run(async () => { + _logger.LogInformation($"盘点同步2"); var list = _takeStockRepositories.GetEntityList(dto.Ids).GetAwaiter().GetResult(); list = list.Where(w => w.SuccessSync == SyncStatus.Fail || w.SuccessSync == SyncStatus.SyncIng).ToList(); foreach (var entity in list) { + _logger.LogInformation($"盘点同步3"); var res = await Loss_Profit(entity); + _logger.LogInformation($"盘点同步4:{JsonConvert.SerializeObject(res)}"); if (!res.IsSuccess) _logger.LogError($"盘点同步失败:{res.Message}"); }