增加日志

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<TakeStockController> _logger;
         public TakeStockController(IMapper mapper, ILoginService loginService, 
             ITakeStockRepositories repositories, ITakeStockService takeStockService
-            , IOptions<QiniuOptions> option, IExportExcelService exportExcelServic)
+            , IOptions<QiniuOptions> option, IExportExcelService exportExcelServic,
+            ILogger<TakeStockController> logger)
         {
             _mapper = mapper;
             _loginService = loginService;
@@ -42,6 +46,7 @@ namespace WMS.Web.Api.Controllers
             _takeStockService = takeStockService;
             _option = option?.Value;
             _exportExcelService = exportExcelServic;
+            _logger = logger;
         }
         /// <summary>
         /// 列表
@@ -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);
         }
     }

src/WMS.Web.Domain/Services/TakeStockService.cs

@@ -150,13 +150,17 @@ namespace WMS.Web.Domain.Services
         /// <returns></returns>
         public Task<Result> 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}");
                 }